From edcf17984fbf15815b710319dacf01abb8f5c84e Mon Sep 17 00:00:00 2001 From: calzoneman Date: Fri, 30 Oct 2015 22:25:00 -0700 Subject: [PATCH] Fix socket.io counters --- src/counters.js | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/src/counters.js b/src/counters.js index c3f13f66..13dbada1 100644 --- a/src/counters.js +++ b/src/counters.js @@ -2,6 +2,7 @@ var Logger = require('./logger'); var counterLog = new Logger.Logger('counters.log'); import os from 'os'; import io from 'socket.io'; +import Socket from 'socket.io/lib/socket'; var counters = {}; @@ -17,11 +18,17 @@ exports.add = function (counter, value) { } }; +Socket.prototype._packet = Socket.prototype.packet; +Socket.prototype.packet = function () { + this._packet.apply(this, arguments); + exports.add('socket.io:packet'); +}; + setInterval(function () { try { counters['memory:rss'] = process.memoryUsage().rss / 1048576; counters['load:1min'] = os.loadavg()[0]; - counters['socket.io:count'] = io.instance.sockets.length; + counters['socket.io:count'] = io.instance.sockets.sockets.length; counterLog.log(JSON.stringify(counters)); } catch (e) { Logger.errlog.log(e.stack);