diff options
Diffstat (limited to 'jstests/sharding/min_optime_recovery_on_successful_move_chunk_commit.js')
-rw-r--r-- | jstests/sharding/min_optime_recovery_on_successful_move_chunk_commit.js | 47 |
1 files changed, 23 insertions, 24 deletions
diff --git a/jstests/sharding/min_optime_recovery_on_successful_move_chunk_commit.js b/jstests/sharding/min_optime_recovery_on_successful_move_chunk_commit.js index b67f0bde73e..ffbe5ab8ef0 100644 --- a/jstests/sharding/min_optime_recovery_on_successful_move_chunk_commit.js +++ b/jstests/sharding/min_optime_recovery_on_successful_move_chunk_commit.js @@ -2,35 +2,34 @@ * Tests that the minOpTimeRecovery document will be created after a migration. */ (function() { - "use strict"; +"use strict"; - var st = new ShardingTest({shards: 2}); +var st = new ShardingTest({shards: 2}); - var testDB = st.s.getDB('test'); - testDB.adminCommand({enableSharding: 'test'}); - st.ensurePrimaryShard('test', st.shard0.shardName); - testDB.adminCommand({shardCollection: 'test.user', key: {x: 1}}); +var testDB = st.s.getDB('test'); +testDB.adminCommand({enableSharding: 'test'}); +st.ensurePrimaryShard('test', st.shard0.shardName); +testDB.adminCommand({shardCollection: 'test.user', key: {x: 1}}); - var priConn = st.configRS.getPrimary(); - var replStatus = priConn.getDB('admin').runCommand({replSetGetStatus: 1}); - replStatus.members.forEach(function(memberState) { - if (memberState.state == 1) { // if primary - assert.neq(null, memberState.optime); - assert.neq(null, memberState.optime.ts); - assert.neq(null, memberState.optime.t); - } - }); +var priConn = st.configRS.getPrimary(); +var replStatus = priConn.getDB('admin').runCommand({replSetGetStatus: 1}); +replStatus.members.forEach(function(memberState) { + if (memberState.state == 1) { // if primary + assert.neq(null, memberState.optime); + assert.neq(null, memberState.optime.ts); + assert.neq(null, memberState.optime.t); + } +}); - testDB.adminCommand({moveChunk: 'test.user', find: {x: 0}, to: st.shard1.shardName}); +testDB.adminCommand({moveChunk: 'test.user', find: {x: 0}, to: st.shard1.shardName}); - var shardAdmin = st.rs0.getPrimary().getDB('admin'); - var minOpTimeRecoveryDoc = shardAdmin.system.version.findOne({_id: 'minOpTimeRecovery'}); +var shardAdmin = st.rs0.getPrimary().getDB('admin'); +var minOpTimeRecoveryDoc = shardAdmin.system.version.findOne({_id: 'minOpTimeRecovery'}); - assert.neq(null, minOpTimeRecoveryDoc); - assert.eq('minOpTimeRecovery', minOpTimeRecoveryDoc._id); - assert.gt(minOpTimeRecoveryDoc.minOpTime.ts.getTime(), 0); - assert.eq(0, minOpTimeRecoveryDoc.minOpTimeUpdaters); - - st.stop(); +assert.neq(null, minOpTimeRecoveryDoc); +assert.eq('minOpTimeRecovery', minOpTimeRecoveryDoc._id); +assert.gt(minOpTimeRecoveryDoc.minOpTime.ts.getTime(), 0); +assert.eq(0, minOpTimeRecoveryDoc.minOpTimeUpdaters); +st.stop(); })(); |