diff --git a/packages/mongo-livedata/mongo_driver.js b/packages/mongo-livedata/mongo_driver.js index d1f9ea0516..ef4f0796d3 100644 --- a/packages/mongo-livedata/mongo_driver.js +++ b/packages/mongo-livedata/mongo_driver.js @@ -287,10 +287,14 @@ MongoConnection.prototype._startOplogTailing = function (oplogUrl, if (!_.has(callbacksByCollection, collectionName)) callbacksByCollection[collectionName] = {}; var callbackId = nextId++; + Package.facts && Package.facts.Facts.incrementServerFact( + "mongo-livedata", "oplog-watchers", 1); callbacksByCollection[collectionName][callbackId] = callback; return { stop: function () { delete callbacksByCollection[collectionName][callbackId]; + Package.facts && Package.facts.Facts.incrementServerFact( + "mongo-livedata", "oplog-watchers", -1); } }; }, diff --git a/packages/mongo-livedata/oplog.js b/packages/mongo-livedata/oplog.js index f021b0ec81..69de5899c5 100644 --- a/packages/mongo-livedata/oplog.js +++ b/packages/mongo-livedata/oplog.js @@ -22,6 +22,9 @@ MongoConnection.prototype._observeChangesWithOplog = function ( cursorDescription, callbacks) { var self = this; + Package.facts && Package.facts.Facts.incrementServerFact( + "mongo-livedata", "oplog-observers", 1); + var phase = PHASE.INITIALIZING; var published = new IdMap; @@ -233,6 +236,8 @@ MongoConnection.prototype._observeChangesWithOplog = function ( stop: function () { listenersHandle.stop(); oplogHandle.stop(); + Package.facts && Package.facts.Facts.incrementServerFact( + "mongo-livedata", "oplog-observers", -1); } }; };