summaryrefslogtreecommitdiff
path: root/jstests/sharding/csrs_upgrade_basic.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/csrs_upgrade_basic.js')
-rw-r--r--jstests/sharding/csrs_upgrade_basic.js23
1 files changed, 12 insertions, 11 deletions
diff --git a/jstests/sharding/csrs_upgrade_basic.js b/jstests/sharding/csrs_upgrade_basic.js
index 46f725f601d..2aed74f3aa8 100644
--- a/jstests/sharding/csrs_upgrade_basic.js
+++ b/jstests/sharding/csrs_upgrade_basic.js
@@ -31,11 +31,11 @@ var st;
/**
* Runs a split command with a never-before used middle split point. Returns the command result.
*/
- var runNextSplit = function (snode) {
+ var runNextSplit = function(snode) {
var splitPoint = nextSplit;
nextSplit += 10;
- return snode.adminCommand({split: coordinator.getShardedCollectionName(),
- middle: { _id: splitPoint }});
+ return snode.adminCommand(
+ {split: coordinator.getShardedCollectionName(), middle: {_id: splitPoint}});
};
/**
@@ -43,7 +43,7 @@ var st;
* spliting the data collection, and doing basic crud ops against the data collection, and
* expects all operations to succeed.
*/
- var assertOpsWork = function (snode, msg) {
+ var assertOpsWork = function(snode, msg) {
if (msg) {
jsTest.log("Confirming that " + snode.name + " CAN run basic sharding ops " + msg);
}
@@ -55,14 +55,14 @@ var st;
assert.eq(40, dataColl.find().itcount());
assert.writeOK(dataColl.insert({_id: 100, x: 1}));
assert.writeOK(dataColl.update({_id: 100}, {$inc: {x: 1}}));
- assert.writeOK(dataColl.remove({x:2}));
+ assert.writeOK(dataColl.remove({x: 2}));
};
/**
* Runs a config.version read, then splits the data collection and expects the read to succed
* and the split to fail.
*/
- var assertCannotSplit = function (snode, msg) {
+ var assertCannotSplit = function(snode, msg) {
jsTest.log("Confirming that " + snode.name + " CANNOT run a split " + msg);
assert(snode.getCollection("config.version").findOne());
assert.commandFailed(runNextSplit(snode));
@@ -73,17 +73,18 @@ var st;
assert.commandWorked(runNextSplit(coordinator.getMongos(0)));
assert.commandWorked(coordinator.getMongos(0).adminCommand({
moveChunk: coordinator.getShardedCollectionName(),
- find: { _id: 0 },
+ find: {_id: 0},
to: coordinator.getShardName(1)
}));
jsTest.log("Inserting data into " + coordinator.getShardedCollectionName());
- coordinator.getMongos(1).getCollection(coordinator.getShardedCollectionName()).insert(
- (function () {
+ coordinator.getMongos(1)
+ .getCollection(coordinator.getShardedCollectionName())
+ .insert((function() {
var result = [];
var i;
for (i = -20; i < 20; ++i) {
- result.push({ _id: i });
+ result.push({_id: i});
}
return result;
}()));
@@ -99,7 +100,7 @@ var st;
"node with secondaries");
assertOpsWork(coordinator.getMongos(0),
"using SCCC protocol when first config server is primary of " +
- coordinator.getCSRSNodes().length + "-node replica set");
+ coordinator.getCSRSNodes().length + "-node replica set");
coordinator.waitUntilConfigsCaughtUp();
coordinator.shutdownOneSCCCNode();