SERVER-34649 Return a bad status when the MovePrimarySourceManager receives a bad return from commitMovePrimary

Author: BlakeIsBlake

buildscripts/resmokeconfig/suites/sharding_continuous_config_stepdown.yml

@@ -82,6 +82,7 @@ selector:
   - jstests/sharding/parallel.js
   - jstests/sharding/migrateBig.js
   - jstests/sharding/sharding_rs1.js
+  - jstests/sharding/move_primary_fails_without_database_version.js
   # Calls the config server primary directly (not through mongos)
   - jstests/sharding/configsvr_metadata_commands_require_majority_write_concern.js
   - jstests/sharding/min_optime_recovery_on_successful_move_chunk_commit.js

buildscripts/resmokeconfig/suites/sharding_last_stable_mongos_and_mixed_shards.yml

@@ -31,6 +31,7 @@ selector:
   - jstests/sharding/safe_secondary_reads_single_migration_suspend_range_deletion.js
   - jstests/sharding/safe_secondary_reads_single_migration_waitForDelete.js
   - jstests/sharding/move_primary_basic.js
+  - jstests/sharding/move_primary_fails_without_database_version.js
   - jstests/sharding/movePrimary1.js
   - jstests/sharding/mongos_validate_writes.js
   - jstests/sharding/resume_change_stream_on_subset_of_shards.js

buildscripts/resmokeconfig/suites/sharding_last_stable_mongos_and_mixed_shards_misc.yml

@@ -39,6 +39,7 @@ selector:
   - jstests/sharding/safe_secondary_reads_single_migration_suspend_range_deletion.js
   - jstests/sharding/safe_secondary_reads_single_migration_waitForDelete.js
   - jstests/sharding/move_primary_basic.js
+  - jstests/sharding/move_primary_fails_without_database_version.js
   - jstests/sharding/movePrimary1.js
   - jstests/sharding/mongos_validate_writes.js
   - jstests/sharding/resume_change_stream_on_subset_of_shards.js

jstests/sharding/move_primary_fails_without_database_version.js

@@ -0,0 +1,19 @@
+// Tests that a movePrimary will fail if the database doesn't have a version in config.databases
+(function() {
+    "use strict";
+
+    const dbName = "test";
+
+    const st = new ShardingTest({shards: 2});
+
+    assert.commandWorked(st.s.getDB("config").getCollection("databases").insert({
+        _id: dbName,
+        partitioned: false,
+        primary: st.shard0.shardName
+    }));
+
+    assert.commandFailedWithCode(st.s.adminCommand({movePrimary: dbName, to: st.shard1.shardName}),
+                                 ErrorCodes.InternalError);
+
+    st.stop();
+})();

src/mongo/db/s/move_primary_source_manager.cpp

@@ -266,13 +266,19 @@ Status MovePrimarySourceManager::commitOnConfig(OperationContext* opCtx) {
             }
         }
 
+        // We would not be able to guarantee our next database refresh would pick up the write for
+        // the movePrimary commit (if it happened), because we were unable to get the latest config
+        // OpTime.
         fassert(50762,
                 validateStatus.withContext(
                     str::stream() << "Failed to commit movePrimary for database " << getNss().ns()
                                   << " due to "
                                   << redact(commitStatus)
                                   << ". Updating the optime with a write before clearing the "
                                   << "version also failed"));
+
+        // If we can validate but the commit still failed, return the status.
+        return commitStatus;
     }
 
     _state = kCommitted;