summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/session_catalog_migration_destination.cpp
diff options
context:
space:
mode:
authorRandolph Tan <randolph@mongodb.com>2019-09-13 18:46:46 +0000
committerevergreen <evergreen@mongodb.com>2019-09-13 18:46:46 +0000
commitc4467548514ff07721f4de215b3b74d1111ee9d1 (patch)
tree8441af03d79e894ff41e1f93b265c0eb7fd661fe /src/mongo/db/s/session_catalog_migration_destination.cpp
parent707ee6aa025936c5566625cc1b23cf2ffc6de9dc (diff)
downloadmongo-c4467548514ff07721f4de215b3b74d1111ee9d1.tar.gz
SERVER-43174 Make migration destination threads killable
Diffstat (limited to 'src/mongo/db/s/session_catalog_migration_destination.cpp')
-rw-r--r--src/mongo/db/s/session_catalog_migration_destination.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/db/s/session_catalog_migration_destination.cpp b/src/mongo/db/s/session_catalog_migration_destination.cpp
index ea24c80f7e3..ae7ca172c5f 100644
--- a/src/mongo/db/s/session_catalog_migration_destination.cpp
+++ b/src/mongo/db/s/session_catalog_migration_destination.cpp
@@ -366,8 +366,8 @@ void SessionCatalogMigrationDestination::join() {
* 6. Wait for writes to be committed to majority of the replica set.
*/
void SessionCatalogMigrationDestination::_retrieveSessionStateFromSource(ServiceContext* service) {
- Client::initThread(
- "sessionCatalogMigrationProducer-" + _migrationSessionId.toString(), service, nullptr);
+ Client::initKillableThread("sessionCatalogMigrationProducer-" + _migrationSessionId.toString(),
+ service);
bool oplogDrainedAfterCommiting = false;
ProcessOplogResult lastResult;