redis/node-redis
1
0
Fork 0
mirror of https://github.com/redis/node-redis.git synced 2025-08-09 00:22:08 +03:00
Code Activity

updated stress tests

Browse Source
This commit is contained in:
Vladimir Dronnikov
2011-07-01 08:40:02 -04:00
parent cc2c3f7776
commit f93af92fac
7 changed files with 37 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
tests/stress/codec.js
View File

@@ -11,6 +11,6 @@ msgpack = {
bison = require('bison');
module.exports = json;
//module.exports = json;
//module.exports = msgpack;
module.exports = bison;

10
tests/stress/pubsub/pub.js
View File

@@ -1,6 +1,7 @@
'use strict';
var freemem = require('os').freemem;
var profiler = require('v8-profiler');
var codec = require('../codec');
var sent = 0;
@@ -16,7 +17,7 @@ var pub = require('redis').createClient(null, null, {
process.nextTick(exec);
});
var payload = '1'; for (var i = 0; i < 10; ++i) payload += payload;
var payload = '1'; for (var i = 0; i < 12; ++i) payload += payload;
function exec() {
pub.publish('timeline', codec.encode({ foo: payload }));
@@ -26,8 +27,11 @@ function exec() {
}
}
profiler.takeSnapshot('s_0');
exec();
setInterval(function() {
console.log('sent', sent, 'free', freemem(), 'cmdqlen', pub.command_queue.length, 'offqlen', pub.offline_queue.length);
}, 1000);
profiler.takeSnapshot('s_' + sent);
console.error('sent', sent, 'free', freemem(), 'cmdqlen', pub.command_queue.length, 'offqlen', pub.offline_queue.length);
}, 2000);

4
tests/stress/pubsub/run
View File

@@ -1,3 +1,5 @@
#!/bin/sh
node server.js &
node pub.js
node server.js &
node server.js &
node --debug pub.js

5
tests/stress/pubsub/server.js
View File

@@ -3,6 +3,7 @@
var freemem = require('os').freemem;
var codec = require('../codec');
var id = Math.random();
var recv = 0;
var sub = require('redis').createClient()
@@ -18,5 +19,5 @@ var sub = require('redis').createClient()
});
setInterval(function() {
console.log('received', recv, 'free', freemem());
}, 1000);
console.error('id', id, 'received', recv, 'free', freemem());
}, 2000);

16
tests/stress/rpushblpop/pub.js
View File

@@ -1,6 +1,7 @@
'use strict';
var freemem = require('os').freemem;
//var profiler = require('v8-profiler');
var codec = require('../codec');
var sent = 0;
@@ -17,7 +18,8 @@ var pub = require('redis').createClient(null, null, {
process.nextTick(exec);
});
var payload = '1'; for (var i = 0; i < 10; ++i) payload += payload;
var payload = '1'; for (var i = 0; i < 12; ++i) payload += payload;
console.log(payload.length);
function exec() {
pub.rpush('timeline', codec.encode({ foo: payload }));
@@ -27,13 +29,21 @@ function 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.log('sent', sent, 'free', freemem(),
console.error('sent', sent, 'free', freemem(),
'cmdqlen', pub.command_queue.length, 'offqlen', pub.offline_queue.length,
'llen', result
);
});
}, 1000);
}, 2000);
/*setTimeout(function() {
process.exit();
}, 30000);*/

5
tests/stress/rpushblpop/run
View File

@@ -1,3 +1,6 @@
#!/bin/sh
node server.js &
node pub.js
node server.js &
node server.js &
node server.js &
node --debug pub.js

8
tests/stress/rpushblpop/server.js
View File

@@ -3,8 +3,10 @@
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');
@@ -22,5 +24,7 @@ var sub = require('redis').createClient()
});
setInterval(function() {
console.log('received', recv, 'free', freemem());
}, 1000);
cmd.llen('timeline', function(err, result) {
console.error('id', id, 'received', recv, 'free', freemem(), 'llen', result);
});
}, 2000);