Comparing version 0.1.7 to 0.1.8
@@ -13,2 +13,4 @@ var fwk = require('fwk'); | ||
config['DATTSS_DRIVER_DEBUG'] = false; | ||
exports.config = config; |
@@ -71,4 +71,2 @@ // Copyright Teleportd Ltd. | ||
var agg; /* agg(stat, value); */ | ||
//var error; /* error(err, ctx); */ | ||
//var warning; /* warning(err, ctx); */ | ||
@@ -153,5 +151,8 @@ var start; /* start(); */ | ||
prt: make_partials() }; | ||
//console.log('========================================'); | ||
//console.log(JSON.stringify(commit)); | ||
//console.log('=++++++++++++++++++++++++++++++++++++++='); | ||
if(exports.CONFIG['DATTSS_DRIVER_DEBUG']) { | ||
console.log('========================================'); | ||
console.log(JSON.stringify(commit)); | ||
console.log('=++++++++++++++++++++++++++++++++++++++='); | ||
} | ||
@@ -169,7 +170,11 @@ if(my.creq) | ||
my.creq = http.request(options, function(res) { | ||
//console.log('/agg ' + res.statusCode + ' [' + my.auth + ']'); | ||
if(exports.CONFIG['DATTSS_DRIVER_DEBUG']) { | ||
console.log('/agg ' + res.statusCode + ' [' + my.auth + ']'); | ||
} | ||
delete my.creq; | ||
}); | ||
my.creq.on('error', function(err) { | ||
//console.log('/agg ' + err.message + ' [' + my.auth + ']'); | ||
if(exports.CONFIG['DATTSS_DRIVER_DEBUG']) { | ||
console.log('ERROR: /agg ' + err.message + ' [' + my.auth + ']'); | ||
} | ||
}); | ||
@@ -196,4 +201,8 @@ my.creq.write(JSON.stringify(commit)); | ||
var stat_m = /^([A-Za-z0-9\-_\.\!]+)$/.exec(stat); | ||
if(!stat_m) | ||
if(!stat_m) { | ||
if(exports.CONFIG['DATTSS_DRIVER_DEBUG']) { | ||
console.log('ERROR: agg invalid stat name [' + my.auth + ']'); | ||
} | ||
return; // fail silently | ||
} | ||
@@ -218,3 +227,7 @@ var val_m = /^(-?[0-9]+)(c|ms|g)(\!?)/.exec(value); | ||
function(err, bytes) { | ||
// fail silently | ||
if(err) { | ||
if(exports.CONFIG['DATTSS_DRIVER_DEBUG']) { | ||
console.log('ERROR: udp ' + err.message + ' [' + my.auth + ']'); | ||
} | ||
} | ||
}); | ||
@@ -221,0 +234,0 @@ } |
{ | ||
"name": "dattss", | ||
"version": "0.1.7", | ||
"version": "0.1.8", | ||
"description": "NodeJS Driver for DaTtSs", | ||
@@ -5,0 +5,0 @@ "author": { "name": "Stanislas Polu", |
@@ -1,3 +0,3 @@ | ||
var dts_test = require('dattss').process('test'); | ||
var dts_cache = require('dattss').process('cache'); | ||
var dts_test = require('../../lib/dattss.js').process('test'); | ||
var dts_cache = require('../../lib/dattss.js').process('cache'); | ||
@@ -55,3 +55,3 @@ | ||
var v = Math.floor(Math.random() * (max - min + 1)) + min; | ||
dts_cache.agg('test', + v+'c'); | ||
dts_cache.agg('test', + v+'c', true); | ||
}, 10); | ||
@@ -64,3 +64,3 @@ | ||
var v = Math.floor(Math.random() * (max - min + 1)) + min; | ||
dts_cache.agg('search', v+'ms'); | ||
dts_cache.agg('search', v+'ms', true); | ||
}, 10); |
13121
339