summaryrefslogtreecommitdiffstats
path: root/vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop
diff options
context:
space:
mode:
Diffstat (limited to 'vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop')
-rw-r--r--vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop/pub.js49
-rw-r--r--vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop/run6
-rw-r--r--vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop/server.js30
3 files changed, 0 insertions, 85 deletions
diff --git a/vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop/pub.js b/vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop/pub.js
deleted file mode 100644
index 9caf1d0b..00000000
--- a/vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop/pub.js
+++ /dev/null
@@ -1,49 +0,0 @@
-'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/vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop/run b/vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop/run
deleted file mode 100644
index 8045ae80..00000000
--- a/vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop/run
+++ /dev/null
@@ -1,6 +0,0 @@
-#!/bin/sh
-node server.js &
-#node server.js &
-#node server.js &
-#node server.js &
-node --debug pub.js
diff --git a/vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop/server.js b/vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop/server.js
deleted file mode 100644
index 9cbcdd9e..00000000
--- a/vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop/server.js
+++ /dev/null
@@ -1,30 +0,0 @@
-'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);