diff options
Diffstat (limited to 'jstests/sharding/unowned_doc_filtering.js')
-rw-r--r-- | jstests/sharding/unowned_doc_filtering.js | 67 |
1 files changed, 34 insertions, 33 deletions
diff --git a/jstests/sharding/unowned_doc_filtering.js b/jstests/sharding/unowned_doc_filtering.js index e54cb21f3c7..2c12ef4b0cf 100644 --- a/jstests/sharding/unowned_doc_filtering.js +++ b/jstests/sharding/unowned_doc_filtering.js @@ -7,43 +7,44 @@ * @tags: [requires_persistence] */ (function() { -"use strict"; + "use strict"; -var st = new ShardingTest({ shards: 2 }); + var st = new ShardingTest({shards: 2}); -var testDB = st.s.getDB('test'); + var testDB = st.s.getDB('test'); -assert.commandWorked(testDB.adminCommand({ enableSharding: 'test' })); -st.ensurePrimaryShard('test', 'shard0000'); -assert.commandWorked(testDB.adminCommand({ shardCollection: 'test.foo', key: { x: 1 }})); + assert.commandWorked(testDB.adminCommand({enableSharding: 'test'})); + st.ensurePrimaryShard('test', 'shard0000'); + assert.commandWorked(testDB.adminCommand({shardCollection: 'test.foo', key: {x: 1}})); -var inserts = []; -for (var i = 0; i < 100; i++) { - inserts.push({x:i}); -} -assert.writeOK(testDB.foo.insert(inserts)); - -assert.commandWorked(testDB.adminCommand({split:'test.foo', find: {x:50}})); -assert.commandWorked(testDB.adminCommand({moveChunk:'test.foo', find:{x:100}, to: 'shard0001'})); - -// Insert some documents directly into the shards into chunks not owned by that shard. -st.d0.getDB('test').foo.insert({x:100}); -st.d1.getDB('test').foo.insert({x:0}); - -st.restartMongod(0); -st.restartMongod(1); - -var fooCount; -for (var retries = 0; retries <= 2; retries++) { - try { - fooCount = testDB.foo.find().itcount(); - break; - } catch (e) { - // expected for reestablishing connections broken by the mongod restart. - assert.eq(ErrorCodes.HostUnreachable, e.code, tojson(e)); + var inserts = []; + for (var i = 0; i < 100; i++) { + inserts.push({x: i}); + } + assert.writeOK(testDB.foo.insert(inserts)); + + assert.commandWorked(testDB.adminCommand({split: 'test.foo', find: {x: 50}})); + assert.commandWorked( + testDB.adminCommand({moveChunk: 'test.foo', find: {x: 100}, to: 'shard0001'})); + + // Insert some documents directly into the shards into chunks not owned by that shard. + st.d0.getDB('test').foo.insert({x: 100}); + st.d1.getDB('test').foo.insert({x: 0}); + + st.restartMongod(0); + st.restartMongod(1); + + var fooCount; + for (var retries = 0; retries <= 2; retries++) { + try { + fooCount = testDB.foo.find().itcount(); + break; + } catch (e) { + // expected for reestablishing connections broken by the mongod restart. + assert.eq(ErrorCodes.HostUnreachable, e.code, tojson(e)); + } } -} -assert.eq(100, fooCount); + assert.eq(100, fooCount); -st.stop(); + st.stop(); }()); |