vnfmarket/src/main/webapp/vnfmarket/node_modules/redis/benches/stress/rpushblpop/server.js

   1 'use strict';
   2
   3 var freemem = require('os').freemem;
   4 var codec = require('../codec');
   5
   6 var id = Math.random();
   7 var recv = 0;
   8
   9 var cmd = require('redis').createClient();
  10 var sub = require('redis').createClient()
  11         .on('ready', function() {
  12                 this.emit('timeline');
  13         })
  14         .on('timeline', function() {
  15                 var self = this;
  16                 this.blpop('timeline', 0, function(err, result) {
  17                         var message = result[1];
  18                         if (message) {
  19                                 message = codec.decode(message);
  20                                 ++recv;
  21                         }
  22                         self.emit('timeline');
  23                 });
  24         });
  25
  26 setInterval(function() {
  27         cmd.llen('timeline', function(err, result) {
  28                 console.error('id', id, 'received', recv, 'free', freemem(), 'llen', result);
  29         });
  30 }, 2000);