3 files changed, 85 insertions, 0 deletions
diff --git a/signaling-server/node_modules/socket.io/node_modules/redis/benches/stress/rpushblpop/pub.js b/signaling-server/node_modules/socket.io/node_modules/redis/benches/stress/rpushblpop/pub.js
new file mode 100644
index 0000000..9caf1d0
--- /dev/null
+++ b/signaling-server/node_modules/socket.io/node_modules/redis/benches/stress/rpushblpop/pub.js
@@ -0,0 +1,49 @@
+'use strict';
+
+var freemem = require('os').freemem;
+//var profiler = require('v8-profiler');
+var codec = require('../codec');
+
+var sent = 0;
+
+var pub = require('redis').createClient(null, null, {
+	//command_queue_high_water: 5,
+	//command_queue_low_water: 1
+})
+.on('ready', function() {
+	this.del('timeline');
+	this.emit('drain');
+})
+.on('drain', function() {
+	process.nextTick(exec);
+});
+
+var payload = '1'; for (var i = 0; i < 12; ++i) payload += payload;
+console.log('Message payload length', payload.length);
+
+function exec() {
+	pub.rpush('timeline', codec.encode({ foo: payload }));
+	++sent;
+	if (!pub.should_buffer) {
+		process.nextTick(exec);
+	}
+}
+
+//profiler.takeSnapshot('s_0');
+
+exec();
+
+setInterval(function() {
+	//var ss = profiler.takeSnapshot('s_' + sent);
+	//console.error(ss.stringify());
+	pub.llen('timeline', function(err, result) {
+		console.error('sent', sent, 'free', freemem(),
+			'cmdqlen', pub.command_queue.length, 'offqlen', pub.offline_queue.length,
+			'llen', result
+		);
+	});
+}, 2000);
+
+/*setTimeout(function() {
+	process.exit();
+}, 30000);*/
diff --git a/signaling-server/node_modules/socket.io/node_modules/redis/benches/stress/rpushblpop/run b/signaling-server/node_modules/socket.io/node_modules/redis/benches/stress/rpushblpop/run
new file mode 100755
index 0000000..8045ae8
--- /dev/null
+++ b/signaling-server/node_modules/socket.io/node_modules/redis/benches/stress/rpushblpop/run
@@ -0,0 +1,6 @@
+#!/bin/sh
+node server.js &
+#node server.js &
+#node server.js &
+#node server.js &
+node --debug pub.js
diff --git a/signaling-server/node_modules/socket.io/node_modules/redis/benches/stress/rpushblpop/server.js b/signaling-server/node_modules/socket.io/node_modules/redis/benches/stress/rpushblpop/server.js
new file mode 100644
index 0000000..9cbcdd9
--- /dev/null
+++ b/signaling-server/node_modules/socket.io/node_modules/redis/benches/stress/rpushblpop/server.js
@@ -0,0 +1,30 @@
+'use strict';
+
+var freemem = require('os').freemem;
+var codec = require('../codec');
+
+var id = Math.random();
+var recv = 0;
+
+var cmd = require('redis').createClient();
+var sub = require('redis').createClient()
+	.on('ready', function() {
+		this.emit('timeline');
+	})
+	.on('timeline', function() {
+		var self = this;
+		this.blpop('timeline', 0, function(err, result) {
+			var message = result[1];
+			if (message) {
+				message = codec.decode(message);
+				++recv;
+			}
+			self.emit('timeline');
+		});
+	});
+
+setInterval(function() {
+	cmd.llen('timeline', function(err, result) {
+		console.error('id', id, 'received', recv, 'free', freemem(), 'llen', result);
+	});
+}, 2000);