summaryrefslogtreecommitdiff
path: root/jstests/sharding/delete_during_migrate.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/delete_during_migrate.js')
-rw-r--r--jstests/sharding/delete_during_migrate.js32
1 files changed, 17 insertions, 15 deletions
diff --git a/jstests/sharding/delete_during_migrate.js b/jstests/sharding/delete_during_migrate.js
index 81daf3c3e52..5872e6d88b5 100644
--- a/jstests/sharding/delete_during_migrate.js
+++ b/jstests/sharding/delete_during_migrate.js
@@ -3,7 +3,7 @@
// starts. Protect against that by making chunk very large.
// start up a new sharded cluster
-var st = new ShardingTest({ shards : 2, mongos : 1 });
+var st = new ShardingTest({shards: 2, mongos: 1});
// stop balancer since we want manual control for this
st.stopBalancer();
@@ -12,35 +12,37 @@ var dbname = "testDB";
var coll = "foo";
var ns = dbname + "." + coll;
var s = st.s0;
-var t = s.getDB( dbname ).getCollection( coll );
+var t = s.getDB(dbname).getCollection(coll);
-s.adminCommand({ enablesharding: dbname });
+s.adminCommand({enablesharding: dbname});
st.ensurePrimaryShard(dbname, 'shard0001');
// Create fresh collection with lots of docs
t.drop();
var bulk = t.initializeUnorderedBulkOp();
for (var i = 0; i < 200000; i++) {
- bulk.insert({ a: i });
+ bulk.insert({a: i});
}
assert.writeOK(bulk.execute());
// enable sharding of the collection. Only 1 chunk.
-t.ensureIndex( { a : 1 } );
-s.adminCommand( { shardcollection : ns , key: { a : 1 } } );
+t.ensureIndex({a: 1});
+s.adminCommand({shardcollection: ns, key: {a: 1}});
// start a parallel shell that deletes things
-startMongoProgramNoConnect( "mongo" ,
- "--host" , getHostName() ,
- "--port" , st.s0.port ,
- "--eval" , "db." + coll + ".remove({});" ,
- dbname );
+startMongoProgramNoConnect("mongo",
+ "--host",
+ getHostName(),
+ "--port",
+ st.s0.port,
+ "--eval",
+ "db." + coll + ".remove({});",
+ dbname);
// migrate while deletions are happening
-var moveResult = s.adminCommand( { moveChunk : ns ,
- find : { a : 1 } ,
- to : st.getOther( st.getServer( dbname ) ).name } );
+var moveResult =
+ s.adminCommand({moveChunk: ns, find: {a: 1}, to: st.getOther(st.getServer(dbname)).name});
// check if migration worked
-assert( moveResult.ok , "migration didn't work while doing deletes" );
+assert(moveResult.ok, "migration didn't work while doing deletes");
st.stop();