Record how many UDP messages we receive every interval.

mgb · Jun 21, 2011 · f04693b · f04693b
1 parent 5f75080
commit f04693b
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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);