summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_coordinator_impl_heartbeat.cpp
diff options
context:
space:
mode:
authorTess Avitabile <tess.avitabile@mongodb.com>2020-06-02 09:26:36 -0400
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2020-06-04 19:46:54 +0000
commit5f1a69aaf69bc12124f68e7b489a1437f9cdd575 (patch)
treecc5970ebedebf82b2ecd8ffaf6044ef82ca1c370 /src/mongo/db/repl/replication_coordinator_impl_heartbeat.cpp
parentf0077c360158023ebd259c80429c19c42619bceb (diff)
downloadmongo-5f1a69aaf69bc12124f68e7b489a1437f9cdd575.tar.gz
SERVER-47645 Must invalidate all sessions on stepdown
Diffstat (limited to 'src/mongo/db/repl/replication_coordinator_impl_heartbeat.cpp')
-rw-r--r--src/mongo/db/repl/replication_coordinator_impl_heartbeat.cpp2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/mongo/db/repl/replication_coordinator_impl_heartbeat.cpp b/src/mongo/db/repl/replication_coordinator_impl_heartbeat.cpp
index 21a59cf9b08..c8d1edc54a3 100644
--- a/src/mongo/db/repl/replication_coordinator_impl_heartbeat.cpp
+++ b/src/mongo/db/repl/replication_coordinator_impl_heartbeat.cpp
@@ -510,6 +510,7 @@ void ReplicationCoordinatorImpl::_stepDownFinish(
lk.unlock();
yieldLocksForPreparedTransactions(opCtx.get());
+ invalidateSessionsForStepdown(opCtx.get());
lk.lock();
@@ -791,6 +792,7 @@ void ReplicationCoordinatorImpl::_heartbeatReconfigFinish(
lk.unlock();
yieldLocksForPreparedTransactions(opCtx.get());
+ invalidateSessionsForStepdown(opCtx.get());
lk.lock();