summaryrefslogtreecommitdiff
path: root/jstests/replsets/rollback_rename_collection_on_sync_source.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/replsets/rollback_rename_collection_on_sync_source.js')
-rw-r--r--jstests/replsets/rollback_rename_collection_on_sync_source.js65
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