summaryrefslogtreecommitdiff
path: root/jstests/sharding/features3.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/features3.js')
-rw-r--r--jstests/sharding/features3.js273
1 files changed, 136 insertions, 137 deletions
diff --git a/jstests/sharding/features3.js b/jstests/sharding/features3.js
index bc1f9f3658d..0ccf500804f 100644
--- a/jstests/sharding/features3.js
+++ b/jstests/sharding/features3.js
@@ -6,154 +6,153 @@
// - Verifies a $where query can be killed on multiple DBs
// - Tests fsync and fsync+lock permissions on sharded db
(function() {
- 'use strict';
-
- var s = new ShardingTest({shards: 2, mongos: 1});
- var dbForTest = s.getDB("test");
- var admin = s.getDB("admin");
- dbForTest.foo.drop();
-
- var numDocs = 10000;
-
- // shard test.foo and add a split point
- s.adminCommand({enablesharding: "test"});
- s.ensurePrimaryShard('test', s.shard1.shardName);
- s.adminCommand({shardcollection: "test.foo", key: {_id: 1}});
- s.adminCommand({split: "test.foo", middle: {_id: numDocs / 2}});
-
- // move a chunk range to the non-primary shard
- s.adminCommand({
- moveChunk: "test.foo",
- find: {_id: 3},
- to: s.getNonPrimaries("test")[0],
- _waitForDelete: true
- });
-
- // restart balancer
- s.startBalancer();
-
- // insert 10k small documents into the sharded collection
- var bulk = dbForTest.foo.initializeUnorderedBulkOp();
- for (var i = 0; i < numDocs; i++) {
- bulk.insert({_id: i});
- }
- assert.writeOK(bulk.execute());
-
- var x = dbForTest.foo.stats();
-
- // verify the colleciton has been sharded and documents are evenly distributed
- assert.eq("test.foo", x.ns, "namespace mismatch");
- assert(x.sharded, "collection is not sharded");
- assert.eq(numDocs, x.count, "total count");
- assert.eq(numDocs / 2, x.shards[s.shard0.shardName].count, "count on " + s.shard0.shardName);
- assert.eq(numDocs / 2, x.shards[s.shard1.shardName].count, "count on " + s.shard1.shardName);
- assert(x.totalIndexSize > 0);
- assert(x.totalSize > 0);
-
- // insert one doc into a non-sharded collection
- dbForTest.bar.insert({x: 1});
- var x = dbForTest.bar.stats();
- assert.eq(1, x.count, "XXX1");
- assert.eq("test.bar", x.ns, "XXX2");
- assert(!x.sharded, "XXX3: " + tojson(x));
-
- // fork shell and start querying the data
- var start = new Date();
-
- var whereKillSleepTime = 1000;
- var parallelCommand = "db.foo.find(function() { " + " sleep(" + whereKillSleepTime + "); " +
- " return false; " + "}).itcount(); ";
-
- // fork a parallel shell, but do not wait for it to start
- print("about to fork new shell at: " + Date());
- var awaitShell = startParallelShell(parallelCommand, s.s.port);
- print("done forking shell at: " + Date());
-
- // Get all current $where operations
- function getInProgWhereOps() {
- let inProgressOps = admin.aggregate([{$currentOp: {'allUsers': true}}]);
- let inProgressStr = '';
-
- // Find all the where queries
- var myProcs = [];
- while (inProgressOps.hasNext()) {
- let op = inProgressOps.next();
- inProgressStr += tojson(op);
- if (op.command && op.command.filter && op.command.filter.$where) {
- myProcs.push(op);
- }
- }
-
- if (myProcs.length == 0) {
- print('No $where operations found: ' + inProgressStr);
- } else {
- print('Found ' + myProcs.length + ' $where operations: ' + tojson(myProcs));
+'use strict';
+
+var s = new ShardingTest({shards: 2, mongos: 1});
+var dbForTest = s.getDB("test");
+var admin = s.getDB("admin");
+dbForTest.foo.drop();
+
+var numDocs = 10000;
+
+// shard test.foo and add a split point
+s.adminCommand({enablesharding: "test"});
+s.ensurePrimaryShard('test', s.shard1.shardName);
+s.adminCommand({shardcollection: "test.foo", key: {_id: 1}});
+s.adminCommand({split: "test.foo", middle: {_id: numDocs / 2}});
+
+// move a chunk range to the non-primary shard
+s.adminCommand({
+ moveChunk: "test.foo",
+ find: {_id: 3},
+ to: s.getNonPrimaries("test")[0],
+ _waitForDelete: true
+});
+
+// restart balancer
+s.startBalancer();
+
+// insert 10k small documents into the sharded collection
+var bulk = dbForTest.foo.initializeUnorderedBulkOp();
+for (var i = 0; i < numDocs; i++) {
+ bulk.insert({_id: i});
+}
+assert.writeOK(bulk.execute());
+
+var x = dbForTest.foo.stats();
+
+// verify the colleciton has been sharded and documents are evenly distributed
+assert.eq("test.foo", x.ns, "namespace mismatch");
+assert(x.sharded, "collection is not sharded");
+assert.eq(numDocs, x.count, "total count");
+assert.eq(numDocs / 2, x.shards[s.shard0.shardName].count, "count on " + s.shard0.shardName);
+assert.eq(numDocs / 2, x.shards[s.shard1.shardName].count, "count on " + s.shard1.shardName);
+assert(x.totalIndexSize > 0);
+assert(x.totalSize > 0);
+
+// insert one doc into a non-sharded collection
+dbForTest.bar.insert({x: 1});
+var x = dbForTest.bar.stats();
+assert.eq(1, x.count, "XXX1");
+assert.eq("test.bar", x.ns, "XXX2");
+assert(!x.sharded, "XXX3: " + tojson(x));
+
+// fork shell and start querying the data
+var start = new Date();
+
+var whereKillSleepTime = 1000;
+var parallelCommand = "db.foo.find(function() { " +
+ " sleep(" + whereKillSleepTime + "); " +
+ " return false; " +
+ "}).itcount(); ";
+
+// fork a parallel shell, but do not wait for it to start
+print("about to fork new shell at: " + Date());
+var awaitShell = startParallelShell(parallelCommand, s.s.port);
+print("done forking shell at: " + Date());
+
+// Get all current $where operations
+function getInProgWhereOps() {
+ let inProgressOps = admin.aggregate([{$currentOp: {'allUsers': true}}]);
+ let inProgressStr = '';
+
+ // Find all the where queries
+ var myProcs = [];
+ while (inProgressOps.hasNext()) {
+ let op = inProgressOps.next();
+ inProgressStr += tojson(op);
+ if (op.command && op.command.filter && op.command.filter.$where) {
+ myProcs.push(op);
}
-
- return myProcs;
}
- var curOpState = 0; // 0 = not found, 1 = killed
- var killTime = null;
- var mine;
-
- assert.soon(function() {
- // Get all the current operations
- mine = getInProgWhereOps();
-
- // Wait for the queries to start (one per shard, so 2 total)
- if (curOpState == 0 && mine.length == 2) {
- // queries started
- curOpState = 1;
- // kill all $where
- mine.forEach(function(z) {
- printjson(dbForTest.getSisterDB("admin").killOp(z.opid));
- });
- killTime = new Date();
- }
- // Wait for killed queries to end
- else if (curOpState == 1 && mine.length == 0) {
- // Queries ended
- curOpState = 2;
- return true;
- }
-
- }, "Couldn't kill the $where operations.", 2 * 60 * 1000);
+ if (myProcs.length == 0) {
+ print('No $where operations found: ' + inProgressStr);
+ } else {
+ print('Found ' + myProcs.length + ' $where operations: ' + tojson(myProcs));
+ }
- print("after loop: " + Date());
- assert(killTime, "timed out waiting too kill last mine:" + tojson(mine));
+ return myProcs;
+}
+
+var curOpState = 0; // 0 = not found, 1 = killed
+var killTime = null;
+var mine;
+
+assert.soon(function() {
+ // Get all the current operations
+ mine = getInProgWhereOps();
+
+ // Wait for the queries to start (one per shard, so 2 total)
+ if (curOpState == 0 && mine.length == 2) {
+ // queries started
+ curOpState = 1;
+ // kill all $where
+ mine.forEach(function(z) {
+ printjson(dbForTest.getSisterDB("admin").killOp(z.opid));
+ });
+ killTime = new Date();
+ }
+ // Wait for killed queries to end
+ else if (curOpState == 1 && mine.length == 0) {
+ // Queries ended
+ curOpState = 2;
+ return true;
+ }
+}, "Couldn't kill the $where operations.", 2 * 60 * 1000);
- assert.eq(2, curOpState, "failed killing");
+print("after loop: " + Date());
+assert(killTime, "timed out waiting too kill last mine:" + tojson(mine));
- killTime = new Date().getTime() - killTime.getTime();
- print("killTime: " + killTime);
- print("time if run full: " + (numDocs * whereKillSleepTime));
- assert.gt(whereKillSleepTime * numDocs / 20, killTime, "took too long to kill");
+assert.eq(2, curOpState, "failed killing");
- // wait for the parallel shell we spawned to complete
- var exitCode = awaitShell({checkExitSuccess: false});
- assert.neq(
- 0, exitCode, "expected shell to exit abnormally due to JS execution being terminated");
+killTime = new Date().getTime() - killTime.getTime();
+print("killTime: " + killTime);
+print("time if run full: " + (numDocs * whereKillSleepTime));
+assert.gt(whereKillSleepTime * numDocs / 20, killTime, "took too long to kill");
- var end = new Date();
- print("elapsed: " + (end.getTime() - start.getTime()));
+// wait for the parallel shell we spawned to complete
+var exitCode = awaitShell({checkExitSuccess: false});
+assert.neq(0, exitCode, "expected shell to exit abnormally due to JS execution being terminated");
- // test fsync command on non-admin db
- x = dbForTest.runCommand("fsync");
- assert(!x.ok, "fsync on non-admin namespace should fail : " + tojson(x));
- assert(x.code == 13, "fsync on non-admin succeeded, but should have failed: " + tojson(x));
+var end = new Date();
+print("elapsed: " + (end.getTime() - start.getTime()));
- // test fsync on admin db
- x = dbForTest._adminCommand("fsync");
- assert(x.ok == 1, "fsync failed: " + tojson(x));
- if (x.all[s.shard0.shardName] > 0) {
- assert(x.numFiles > 0, "fsync failed: " + tojson(x));
- }
+// test fsync command on non-admin db
+x = dbForTest.runCommand("fsync");
+assert(!x.ok, "fsync on non-admin namespace should fail : " + tojson(x));
+assert(x.code == 13, "fsync on non-admin succeeded, but should have failed: " + tojson(x));
- // test fsync+lock on admin db
- x = dbForTest._adminCommand({"fsync": 1, lock: true});
- assert(!x.ok, "lock should fail: " + tojson(x));
+// test fsync on admin db
+x = dbForTest._adminCommand("fsync");
+assert(x.ok == 1, "fsync failed: " + tojson(x));
+if (x.all[s.shard0.shardName] > 0) {
+ assert(x.numFiles > 0, "fsync failed: " + tojson(x));
+}
- s.stop();
+// test fsync+lock on admin db
+x = dbForTest._adminCommand({"fsync": 1, lock: true});
+assert(!x.ok, "lock should fail: " + tojson(x));
+s.stop();
})();
View Lorry Controller Status