summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/migration_destination_manager_legacy_commands.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/migration_destination_manager_legacy_commands.cpp')
-rw-r--r--src/mongo/db/s/migration_destination_manager_legacy_commands.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/mongo/db/s/migration_destination_manager_legacy_commands.cpp b/src/mongo/db/s/migration_destination_manager_legacy_commands.cpp
index 8233113e409..e5fabf86335 100644
--- a/src/mongo/db/s/migration_destination_manager_legacy_commands.cpp
+++ b/src/mongo/db/s/migration_destination_manager_legacy_commands.cpp
@@ -94,6 +94,7 @@ public:
const BSONObj& cmdObj,
std::string& errmsg,
BSONObjBuilder& result) override {
+ opCtx->setAlwaysInterruptAtStepDownOrUp();
uassertStatusOK(ShardingState::get(opCtx)->canAcceptShardedCommands());
auto nss = NamespaceString(parseNs(dbname, cmdObj));
@@ -109,7 +110,7 @@ public:
// Ensure this shard is not currently receiving or donating any chunks.
auto scopedReceiveChunk(
uassertStatusOK(ActiveMigrationsRegistry::get(opCtx).registerReceiveChunk(
- opCtx, nss, chunkRange, cloneRequest.getFromShardId())));
+ opCtx, nss, chunkRange, cloneRequest.getFromShardId(), false)));
// We force a refresh immediately after registering this migration to guarantee that this
// shard will not receive a chunk after refreshing.