summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorKristina <kristina@10gen.com>2012-09-05 10:11:55 -0400
committerKristina <kristina@10gen.com>2012-09-05 10:14:04 -0400
commitf0a27d72c5b41866db1b49b83e4e176e0952ea23 (patch)
treedd0610cc3aca81e42fe27e7437955e502f7e5fcf
parent9756b2f18eb091c9e0c98caf20e28c8e66e712e7 (diff)
downloadmongo-f0a27d72c5b41866db1b49b83e4e176e0952ea23.tar.gz
Check repl cursor before using SERVER-6762
-rw-r--r--src/mongo/db/repl/rs_sync.cpp5
1 files changed, 5 insertions, 0 deletions
diff --git a/src/mongo/db/repl/rs_sync.cpp b/src/mongo/db/repl/rs_sync.cpp
index 012c4d60199..6bd7d0b0b89 100644
--- a/src/mongo/db/repl/rs_sync.cpp
+++ b/src/mongo/db/repl/rs_sync.cpp
@@ -766,6 +766,11 @@ namespace replset {
return;
}
slave->reader.ghostQueryGTE(rsoplog, last);
+ // if we lose the connection between connecting and querying, the cursor may not
+ // exist so we have to check again before using it.
+ if (!slave->reader.haveCursor()) {
+ return;
+ }
}
LOG(1) << "replSet last: " << slave->last.toString() << " to " << last.toString() << rsLog;