summaryrefslogtreecommitdiff
path: root/jstests/sharding/move_chunk_find_and_modify_with_write_retryability.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/move_chunk_find_and_modify_with_write_retryability.js')
-rw-r--r--jstests/sharding/move_chunk_find_and_modify_with_write_retryability.js221
1 files changed, 110 insertions, 111 deletions
diff --git a/jstests/sharding/move_chunk_find_and_modify_with_write_retryability.js b/jstests/sharding/move_chunk_find_and_modify_with_write_retryability.js
index 06802d65c61..c7602b4f644 100644
--- a/jstests/sharding/move_chunk_find_and_modify_with_write_retryability.js
+++ b/jstests/sharding/move_chunk_find_and_modify_with_write_retryability.js
@@ -1,126 +1,125 @@
load("jstests/sharding/move_chunk_with_session_helper.js");
(function() {
- "use strict";
+"use strict";
- load("jstests/libs/retryable_writes_util.js");
+load("jstests/libs/retryable_writes_util.js");
- if (!RetryableWritesUtil.storageEngineSupportsRetryableWrites(jsTest.options().storageEngine)) {
- jsTestLog("Retryable writes are not supported, skipping test");
- return;
- }
+if (!RetryableWritesUtil.storageEngineSupportsRetryableWrites(jsTest.options().storageEngine)) {
+ jsTestLog("Retryable writes are not supported, skipping test");
+ return;
+}
- var checkFindAndModifyResult = function(expected, toCheck) {
- assert.eq(expected.ok, toCheck.ok);
- assert.eq(expected.value, toCheck.value);
- assert.eq(expected.lastErrorObject, toCheck.lastErrorObject);
- };
+var checkFindAndModifyResult = function(expected, toCheck) {
+ assert.eq(expected.ok, toCheck.ok);
+ assert.eq(expected.value, toCheck.value);
+ assert.eq(expected.lastErrorObject, toCheck.lastErrorObject);
+};
- var lsid = UUID();
- var tests = [
- {
- coll: 'findAndMod-upsert',
- cmd: {
- findAndModify: 'findAndMod-upsert',
- query: {x: 60},
- update: {$inc: {y: 1}},
- new: true,
- upsert: true,
- lsid: {id: lsid},
- txnNumber: NumberLong(37),
- },
- setup: function(coll) {},
- checkRetryResult: function(result, retryResult) {
- checkFindAndModifyResult(result, retryResult);
- },
- checkDocuments: function(coll) {
- assert.eq(1, coll.findOne({x: 60}).y);
- },
+var lsid = UUID();
+var tests = [
+ {
+ coll: 'findAndMod-upsert',
+ cmd: {
+ findAndModify: 'findAndMod-upsert',
+ query: {x: 60},
+ update: {$inc: {y: 1}},
+ new: true,
+ upsert: true,
+ lsid: {id: lsid},
+ txnNumber: NumberLong(37),
},
- {
- coll: 'findAndMod-update-preImage',
- cmd: {
- findAndModify: 'findAndMod-update-preImage',
- query: {x: 60},
- update: {$inc: {y: 1}},
- new: false,
- upsert: false,
- lsid: {id: lsid},
- txnNumber: NumberLong(38),
- },
- setup: function(coll) {
- coll.insert({x: 60});
- },
- checkRetryResult: function(result, retryResult) {
- checkFindAndModifyResult(result, retryResult);
- },
- checkDocuments: function(coll) {
- assert.eq(1, coll.findOne({x: 60}).y);
- },
+ setup: function(coll) {},
+ checkRetryResult: function(result, retryResult) {
+ checkFindAndModifyResult(result, retryResult);
},
- {
- coll: 'findAndMod-update-postImage',
- cmd: {
- findAndModify: 'findAndMod-update-postImage',
- query: {x: 60},
- update: {$inc: {y: 1}},
- new: true,
- upsert: false,
- lsid: {id: lsid},
- txnNumber: NumberLong(39),
- },
- setup: function(coll) {
- coll.insert({x: 60});
- },
- checkRetryResult: function(result, retryResult) {
- checkFindAndModifyResult(result, retryResult);
- },
- checkDocuments: function(coll) {
- assert.eq(1, coll.findOne({x: 60}).y);
- },
+ checkDocuments: function(coll) {
+ assert.eq(1, coll.findOne({x: 60}).y);
},
- {
- coll: 'findAndMod-delete',
- cmd: {
- findAndModify: 'findAndMod-delete',
- query: {x: 10},
- remove: true,
- lsid: {id: lsid},
- txnNumber: NumberLong(40),
- },
- setup: function(coll) {
- var bulk = coll.initializeUnorderedBulkOp();
- for (let i = 0; i < 10; i++) {
- bulk.insert({x: 10});
- }
- assert.writeOK(bulk.execute());
-
- },
- checkRetryResult: function(result, retryResult) {
- checkFindAndModifyResult(result, retryResult);
- },
- checkDocuments: function(coll) {
- assert.eq(9, coll.find({x: 10}).itcount());
- },
+ },
+ {
+ coll: 'findAndMod-update-preImage',
+ cmd: {
+ findAndModify: 'findAndMod-update-preImage',
+ query: {x: 60},
+ update: {$inc: {y: 1}},
+ new: false,
+ upsert: false,
+ lsid: {id: lsid},
+ txnNumber: NumberLong(38),
+ },
+ setup: function(coll) {
+ coll.insert({x: 60});
+ },
+ checkRetryResult: function(result, retryResult) {
+ checkFindAndModifyResult(result, retryResult);
+ },
+ checkDocuments: function(coll) {
+ assert.eq(1, coll.findOne({x: 60}).y);
+ },
+ },
+ {
+ coll: 'findAndMod-update-postImage',
+ cmd: {
+ findAndModify: 'findAndMod-update-postImage',
+ query: {x: 60},
+ update: {$inc: {y: 1}},
+ new: true,
+ upsert: false,
+ lsid: {id: lsid},
+ txnNumber: NumberLong(39),
+ },
+ setup: function(coll) {
+ coll.insert({x: 60});
},
- ];
+ checkRetryResult: function(result, retryResult) {
+ checkFindAndModifyResult(result, retryResult);
+ },
+ checkDocuments: function(coll) {
+ assert.eq(1, coll.findOne({x: 60}).y);
+ },
+ },
+ {
+ coll: 'findAndMod-delete',
+ cmd: {
+ findAndModify: 'findAndMod-delete',
+ query: {x: 10},
+ remove: true,
+ lsid: {id: lsid},
+ txnNumber: NumberLong(40),
+ },
+ setup: function(coll) {
+ var bulk = coll.initializeUnorderedBulkOp();
+ for (let i = 0; i < 10; i++) {
+ bulk.insert({x: 10});
+ }
+ assert.writeOK(bulk.execute());
+ },
+ checkRetryResult: function(result, retryResult) {
+ checkFindAndModifyResult(result, retryResult);
+ },
+ checkDocuments: function(coll) {
+ assert.eq(9, coll.find({x: 10}).itcount());
+ },
+ },
+];
- // Prevent unnecessary elections in the first shard replica set. Shard 'rs1' shard will need its
- // secondary to get elected, so we don't give it a zero priority.
- var st = new ShardingTest({
- mongos: 2,
- shards: {
- rs0: {nodes: [{rsConfig: {}}, {rsConfig: {priority: 0}}]},
- rs1: {nodes: [{rsConfig: {}}, {rsConfig: {}}]}
- }
- });
- assert.commandWorked(st.s.adminCommand({enableSharding: 'test'}));
- st.ensurePrimaryShard('test', st.shard0.shardName);
+// Prevent unnecessary elections in the first shard replica set. Shard 'rs1' shard will need its
+// secondary to get elected, so we don't give it a zero priority.
+var st = new ShardingTest({
+ mongos: 2,
+ shards: {
+ rs0: {nodes: [{rsConfig: {}}, {rsConfig: {priority: 0}}]},
+ rs1: {nodes: [{rsConfig: {}}, {rsConfig: {}}]}
+ }
+});
+assert.commandWorked(st.s.adminCommand({enableSharding: 'test'}));
+st.ensurePrimaryShard('test', st.shard0.shardName);
- tests.forEach(function(test) {
- testMoveChunkWithSession(
- st, test.coll, test.cmd, test.setup, test.checkRetryResult, test.checkDocuments);
- });
+tests.forEach(function(test) {
+ testMoveChunkWithSession(
+ st, test.coll, test.cmd, test.setup, test.checkRetryResult, test.checkDocuments);
+});
- st.stop();
+st.stop();
})();
View Lorry Controller Status