diff options
Diffstat (limited to 'src/mongo/db/s/migration_destination_manager.cpp')
-rw-r--r-- | src/mongo/db/s/migration_destination_manager.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/s/migration_destination_manager.cpp b/src/mongo/db/s/migration_destination_manager.cpp index 059dfe85723..b526b23816b 100644 --- a/src/mongo/db/s/migration_destination_manager.cpp +++ b/src/mongo/db/s/migration_destination_manager.cpp @@ -387,7 +387,8 @@ repl::OpTime MigrationDestinationManager::cloneDocumentsFromDonor( repl::OpTime lastOpApplied; stdx::thread inserterThread{[&] { - ThreadClient tc("chunkInserter", opCtx->getServiceContext()); + Client::initKillableThread("chunkInserter", opCtx->getServiceContext()); + auto inserterOpCtx = Client::getCurrent()->makeOperationContext(); auto consumerGuard = makeGuard([&] { batches.closeConsumerEnd(); @@ -692,10 +693,9 @@ void MigrationDestinationManager::cloneCollectionIndexesAndOptions(OperationCont } void MigrationDestinationManager::_migrateThread() { - Client::initThread("migrateThread"); + Client::initKillableThread("migrateThread", getGlobalServiceContext()); auto opCtx = Client::getCurrent()->makeOperationContext(); - if (AuthorizationManager::get(opCtx->getServiceContext())->isAuthEnabled()) { AuthorizationSession::get(opCtx->getClient())->grantInternalAuthorization(opCtx.get()); } |