diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/mongo/db/repl/repl_coordinator_legacy.cpp | 1 | ||||
| -rw-r--r-- | src/mongo/db/repl/sync_source_feedback.cpp | 2 |
2 files changed, 2 insertions, 1 deletions
diff --git a/src/mongo/db/repl/repl_coordinator_legacy.cpp b/src/mongo/db/repl/repl_coordinator_legacy.cpp index f1d20741a76..d3e3ccdc729 100644 --- a/src/mongo/db/repl/repl_coordinator_legacy.cpp +++ b/src/mongo/db/repl/repl_coordinator_legacy.cpp @@ -389,6 +389,7 @@ namespace { if (rid != getMyRID(txn)) { BSONObj config; if (getReplicationMode() == modeReplSet) { + invariant(_ridMemberMap.count(rid)); Member* mem = _ridMemberMap[rid]; invariant(mem); config = BSON("_id" << mem->id()); diff --git a/src/mongo/db/repl/sync_source_feedback.cpp b/src/mongo/db/repl/sync_source_feedback.cpp index e8a6e7efe03..63951cd8d8a 100644 --- a/src/mongo/db/repl/sync_source_feedback.cpp +++ b/src/mongo/db/repl/sync_source_feedback.cpp @@ -156,7 +156,6 @@ namespace repl { return false; } - replHandshake(txn); return hasConnection(); } @@ -256,6 +255,7 @@ namespace repl { sleepmillis(500); continue; } + handshakeNeeded = true; } if (handshakeNeeded) { if (!replHandshake(&txn)) { |