1 files changed, 30 insertions, 0 deletions
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);