summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp')
-rw-r--r--src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp11
1 files changed, 8 insertions, 3 deletions
diff --git a/src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp b/src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp
index 6660ac6366d..4c66e4f7f95 100644
--- a/src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp
+++ b/src/mongo/db/s/migration_chunk_cloner_source_legacy.cpp
@@ -361,9 +361,14 @@ void MigrationChunkClonerSourceLegacy::cancelClone(OperationContext* opCtx) {
switch (_state) {
case kDone:
break;
- case kCloning:
- _callRecipient(createRequestWithSessionId(kRecvChunkAbort, _args.getNss(), _sessionId))
- .status_with_transitional_ignore();
+ case kCloning: {
+ const auto status = _callRecipient(createRequestWithSessionId(
+ kRecvChunkAbort, _args.getNss(), _sessionId))
+ .getStatus();
+ if (!status.isOK()) {
+ LOG(0) << "Failed to cancel migration " << causedBy(redact(status));
+ }
+ }
// Intentional fall through
case kNew:
_cleanup(opCtx);