summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--src/mongo/db/s/migration_chunk_cloner_source.h3
-rw-r--r--src/mongo/db/s/migration_source_manager.cpp4
2 files changed, 4 insertions, 3 deletions
diff --git a/src/mongo/db/s/migration_chunk_cloner_source.h b/src/mongo/db/s/migration_chunk_cloner_source.h
index 65b2a6d23f6..75dd433c702 100644
--- a/src/mongo/db/s/migration_chunk_cloner_source.h
+++ b/src/mongo/db/s/migration_chunk_cloner_source.h
@@ -93,6 +93,9 @@ public:
* This must only be called once and no more methods on the cloner must be used afterwards
* regardless of whether it succeeds or not.
*
+ * Returns statistics about the move. These are informational only and should not be
+ * interpreted by the caller for any means other than reporting.
+ *
* NOTE: Must be called without any locks.
*/
virtual StatusWith<BSONObj> commitClone(OperationContext* opCtx) = 0;
diff --git a/src/mongo/db/s/migration_source_manager.cpp b/src/mongo/db/s/migration_source_manager.cpp
index 558e32f667a..7e7df93638c 100644
--- a/src/mongo/db/s/migration_source_manager.cpp
+++ b/src/mongo/db/s/migration_source_manager.cpp
@@ -369,9 +369,7 @@ Status MigrationSourceManager::commitChunkOnRecipient(OperationContext* opCtx) {
return commitCloneStatus.getStatus().withContext("commit clone failed");
}
- if (commitCloneStatus.getValue()["counts"].type() == BSONType::Object) {
- _recipientCloneCounts = commitCloneStatus.getValue()["counts"].Obj().getOwned();
- }
+ _recipientCloneCounts = commitCloneStatus.getValue()["counts"].Obj().getOwned();
_state = kCloneCompleted;
scopedGuard.Dismiss();