don't die

This commit is contained in:
David Glasser
2013-10-24 20:09:21 -07:00
parent 2e5f96a867
commit 062b475134

View File

@@ -207,7 +207,7 @@ MongoConnection.prototype._observeChangesWithOplog = function (
// This write cannot complete until we've caught up to "this point" in the
// oplog, and then made it back to the steady state.
self._oplogHandle.callWhenProcessedLatest(function () {
if (phase === PHASE.STEADY)
if (stopped || phase === PHASE.STEADY)
write.committed();
else
writesToCommitWhenWeReachSteady.push(write);