diff --git a/changelog.md b/changelog.md index fbf825ca80..524b125185 100644 --- a/changelog.md +++ b/changelog.md @@ -1,6 +1,16 @@ Changelog ========= +## v0.6.5 - July 6, 2011 + +Contributed changes: + +* Support SlowBuffers (Umair Siddique) +* Add Multi to exports (Louis-Philippe Perron) +* Fix for drain event calculation (Vladimir Dronnikov) + +Thanks! + ## v0.6.4 - June 30, 2011 Fix bug with optional callbacks for hmset. diff --git a/examples/backpressure_drain.js b/examples/backpressure_drain.js index a64456e8de..3488ef4d3f 100644 --- a/examples/backpressure_drain.js +++ b/examples/backpressure_drain.js @@ -3,7 +3,7 @@ var redis = require("../index"), command_queue_high_water: 5, command_queue_low_water: 1 }), - remaining_ops = 10000, paused = false; + remaining_ops = 100000, paused = false; function op() { if (remaining_ops <= 0) { diff --git a/index.js b/index.js index 6b813d3648..001452bd26 100644 --- a/index.js +++ b/index.js @@ -285,7 +285,7 @@ RedisClient.prototype.send_offline_queue = function () { } this.offline_queue = new Queue(); // Even though items were shifted off, Queue backing store still uses memory until next add, so just get a new Queue - + if (!buffered_writes) { this.should_buffer = false; this.emit("drain"); diff --git a/package.json b/package.json index 3ae78e7b39..50f3251eaa 100644 --- a/package.json +++ b/package.json @@ -1,5 +1,5 @@ { "name" : "redis", - "version" : "0.6.4", + "version" : "0.6.5", "description" : "Redis client library", "author": "Matt Ranney ", "contributors": [ diff --git a/tests/buffer_bench.js b/tests/buffer_bench.js index 245ae0e52c..a504fbc087 100644 --- a/tests/buffer_bench.js +++ b/tests/buffer_bench.js @@ -5,6 +5,37 @@ for (i = 99 ; i >= 0 ; i--) { source[i] = 120; } +var str = "This is a nice String.", + buf = new Buffer("This is a lovely Buffer."); + +var start = new Date(); +for (i = count * 100; i > 0 ; i--) { + if (Buffer.isBuffer(str)) {} +} +var end = new Date(); +console.log("Buffer.isBuffer(str) " + (end - start) + " ms"); + +var start = new Date(); +for (i = count * 100; i > 0 ; i--) { + if (Buffer.isBuffer(buf)) {} +} +var end = new Date(); +console.log("Buffer.isBuffer(buf) " + (end - start) + " ms"); + +var start = new Date(); +for (i = count * 100; i > 0 ; i--) { + if (str instanceof Buffer) {} +} +var end = new Date(); +console.log("str instanceof Buffer " + (end - start) + " ms"); + +var start = new Date(); +for (i = count * 100; i > 0 ; i--) { + if (buf instanceof Buffer) {} +} +var end = new Date(); +console.log("buf instanceof Buffer " + (end - start) + " ms"); + for (i = bytes ; i > 0 ; i --) { var start = new Date(); for (j = count ; j > 0; j--) {