From 2d170a09712942cbff3ed6071b6c8ea859989f16 Mon Sep 17 00:00:00 2001
From: David Glasser <glasser@meteor.com>
Date: Tue, 22 Oct 2013 23:16:52 -0700
Subject: [PATCH] Add some facts to oplog.

---
 packages/mongo-livedata/mongo_driver.js | 4 ++++
 packages/mongo-livedata/oplog.js        | 5 +++++
 2 files changed, 9 insertions(+)

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);
     }
   };
 };