diff options
Diffstat (limited to 'jstests/replsets/rollback_rename_collection_on_sync_source.js')
-rw-r--r-- | jstests/replsets/rollback_rename_collection_on_sync_source.js | 65 |
1 files changed, 32 insertions, 33 deletions
diff --git a/jstests/replsets/rollback_rename_collection_on_sync_source.js b/jstests/replsets/rollback_rename_collection_on_sync_source.js index 0f781eb6b8d..be03faa94bf 100644 --- a/jstests/replsets/rollback_rename_collection_on_sync_source.js +++ b/jstests/replsets/rollback_rename_collection_on_sync_source.js @@ -5,48 +5,47 @@ */ (function() { - 'use strict'; +'use strict'; - load("jstests/replsets/libs/rollback_test.js"); +load("jstests/replsets/libs/rollback_test.js"); - let dbName = "rollback_rename_collection_on_sync_source"; - let sourceCollName = "sourceColl"; - let destCollName = "destColl"; +let dbName = "rollback_rename_collection_on_sync_source"; +let sourceCollName = "sourceColl"; +let destCollName = "destColl"; - let doc1 = {x: 1}; - let doc2 = {x: 2}; +let doc1 = {x: 1}; +let doc2 = {x: 2}; - let CommonOps = (node) => { - // Insert a document that will exist on the sync source and rollback node. - assert.writeOK(node.getDB(dbName)[sourceCollName].insert(doc1)); - }; +let CommonOps = (node) => { + // Insert a document that will exist on the sync source and rollback node. + assert.writeOK(node.getDB(dbName)[sourceCollName].insert(doc1)); +}; - let RollbackOps = (node) => { - // Delete the document on rollback node so it will be refetched from sync source. - assert.writeOK(node.getDB(dbName)[sourceCollName].remove(doc1)); - }; +let RollbackOps = (node) => { + // Delete the document on rollback node so it will be refetched from sync source. + assert.writeOK(node.getDB(dbName)[sourceCollName].remove(doc1)); +}; - let SyncSourceOps = (node) => { - // Rename the original collection on the sync source. - assert.commandWorked(node.getDB(dbName)[sourceCollName].renameCollection(destCollName)); - assert.writeOK(node.getDB(dbName)[destCollName].insert(doc2)); - }; +let SyncSourceOps = (node) => { + // Rename the original collection on the sync source. + assert.commandWorked(node.getDB(dbName)[sourceCollName].renameCollection(destCollName)); + assert.writeOK(node.getDB(dbName)[destCollName].insert(doc2)); +}; - // Set up Rollback Test. - let rollbackTest = new RollbackTest(); - CommonOps(rollbackTest.getPrimary()); +// Set up Rollback Test. +let rollbackTest = new RollbackTest(); +CommonOps(rollbackTest.getPrimary()); - let rollbackNode = rollbackTest.transitionToRollbackOperations(); - RollbackOps(rollbackNode); +let rollbackNode = rollbackTest.transitionToRollbackOperations(); +RollbackOps(rollbackNode); - let syncSourceNode = rollbackTest.transitionToSyncSourceOperationsBeforeRollback(); - SyncSourceOps(syncSourceNode); +let syncSourceNode = rollbackTest.transitionToSyncSourceOperationsBeforeRollback(); +SyncSourceOps(syncSourceNode); - // Wait for rollback to finish. - rollbackTest.transitionToSyncSourceOperationsDuringRollback(); - rollbackTest.transitionToSteadyStateOperations(); - - // Check the replica set. - rollbackTest.stop(); +// Wait for rollback to finish. +rollbackTest.transitionToSyncSourceOperationsDuringRollback(); +rollbackTest.transitionToSteadyStateOperations(); +// Check the replica set. +rollbackTest.stop(); }());
\ No newline at end of file |