diff --git a/stats.js b/stats.js index 95f9e90f..0af89790 100644 --- a/stats.js +++ b/stats.js @@ -5,7 +5,7 @@ var dgram = require('dgram') var counters = {}; var timers = {}; -var debugInt, flushInt, server; +var debugInt, flushInt, server, packetCount; config.configFile(process.argv[2], function (config, oldConfig) { if (! config.debug && debugInt) { @@ -21,8 +21,10 @@ config.configFile(process.argv[2], function (config, oldConfig) { } if (server === undefined) { + packetCount = 0; server = dgram.createSocket('udp4', function (msg, rinfo) { if (config.dumpMessages) { sys.log(msg.toString()); } + packetCount += 1; var bits = msg.toString().split(':'); var key = bits.shift() .replace(/\s+/g, '_') @@ -130,6 +132,8 @@ config.configFile(process.argv[2], function (config, oldConfig) { } statString += 'statsd.numStats ' + numStats + ' ' + ts + "\n"; + statString += 'statsd.packetCount ' + packetCount + ' ' + ts + "\n"; + packetCount = 0; try { var graphite = net.createConnection(config.graphitePort, config.graphiteHost);