From b60df56157ee1fd0bd4938799bac05a62fda91a1 Mon Sep 17 00:00:00 2001
From: lookshe <github@lookshe.org>
Date: Sat, 14 Mar 2015 20:45:20 +0100
Subject: initial commit from working version

---
 .../redis/benches/stress/rpushblpop/pub.js         | 49 ++++++++++++++++++++++
 1 file changed, 49 insertions(+)
 create mode 100644 signaling-server/node_modules/socket.io/node_modules/redis/benches/stress/rpushblpop/pub.js

(limited to 'signaling-server/node_modules/socket.io/node_modules/redis/benches/stress/rpushblpop/pub.js')

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);*/
-- 
cgit v1.2.3