keuss
Advanced tools
Comparing version 1.6.12 to 1.6.13
@@ -29,6 +29,6 @@ /* | ||
// test dimensions: elems to produce and consume, number of consumers, number of producers | ||
const num_elems = 10000000; | ||
const num_elems = 1000000; | ||
const num_producers = 3; | ||
const num_consumers = 7; | ||
const commit_likelihood = 95; | ||
const commit_likelihood = 75; | ||
@@ -227,3 +227,3 @@ // stats holder | ||
var timer = setInterval (() => { | ||
console.log ('**** state: %j', _.map (shareds, (v, k) => {return {cnt: v.push_count || v.pop_count, max: v.push_max || v.pop_max }})); | ||
console.log ('**** state: %o', _.map (shareds, (v, k) => {return {cnt: v.push_count || v.pop_count, max: v.push_max || v.pop_max }})); | ||
@@ -233,3 +233,3 @@ console.log ('das pop %d, ko %d, ok %d', das_pop, das_ko, das_ok); | ||
q.status ((err ,res) => { | ||
console.log ('**** status: %j', res); | ||
console.log ('**** status: %o', res); | ||
}); | ||
@@ -269,3 +269,3 @@ }, 2000); | ||
q.status ((err ,res) => { | ||
console.log ('**** status: %j', res); | ||
console.log ('**** status: %o', res); | ||
q.drain (() => factory.close ()); | ||
@@ -272,0 +272,0 @@ }); |
{ | ||
"name": "keuss", | ||
"version": "1.6.12", | ||
"version": "1.6.13", | ||
"keywords": [ | ||
@@ -5,0 +5,0 @@ "queue", |
@@ -540,2 +540,4 @@ var async = require ('async'); | ||
type: cb => cb (null, this.type()), | ||
capabilities: cb => cb (null, this.capabilities ()), | ||
factory: cb => cb (null, this._factory.to_descriptor_obj ()), | ||
stats: cb => this.stats (cb), | ||
@@ -547,3 +549,3 @@ paused: cb => this.paused (cb), | ||
schedSize: cb => this.schedSize (cb), | ||
resvSize: cb => this.resvSize (cb) | ||
resvSize: cb => this.resvSize (cb) | ||
}, cb); | ||
@@ -550,0 +552,0 @@ } |
Sorry, the diff of this file is not supported yet
374718
10244