summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/migration_destination_manager.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/migration_destination_manager.cpp')
-rw-r--r--src/mongo/db/s/migration_destination_manager.cpp6
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());
}