diff options
Diffstat (limited to 'jstests/sharding/auto2.js')
| -rw-r--r-- | jstests/sharding/auto2.js | 255 |
1 files changed, 128 insertions, 127 deletions
diff --git a/jstests/sharding/auto2.js b/jstests/sharding/auto2.js index 81f0c1f17ea..3d21559f8d6 100644 --- a/jstests/sharding/auto2.js +++ b/jstests/sharding/auto2.js @@ -1,151 +1,152 @@ (function() { -var s = new ShardingTest({ name: "auto2", - shards: 2, - mongos: 2 }); - -s.adminCommand( { enablesharding : "test" } ); -s.ensurePrimaryShard('test', 'shard0001'); -s.adminCommand( { shardcollection : "test.foo" , key : { num : 1 } } ); - -var bigString = ""; -while (bigString.length < 1024 * 50) { - bigString += "asocsancdnsjfnsdnfsjdhfasdfasdfasdfnsadofnsadlkfnsaldknfsad"; -} - -var db = s.getDB("test" ); -var coll = db.foo; - -var i = 0; -for (var j = 0; j < 30; j++) { - print("j:" + j + " : " + - Date.timeFunc(function() { - var bulk = coll.initializeUnorderedBulkOp(); - for (var k = 0; k < 100; k++) { - bulk.insert({ num : i, s : bigString }); - i++; - } - assert.writeOK(bulk.execute()); - })); -} + var s = new ShardingTest({name: "auto2", shards: 2, mongos: 2}); + + s.adminCommand({enablesharding: "test"}); + s.ensurePrimaryShard('test', 'shard0001'); + s.adminCommand({shardcollection: "test.foo", key: {num: 1}}); -s.startBalancer(); + var bigString = ""; + while (bigString.length < 1024 * 50) { + bigString += "asocsancdnsjfnsdnfsjdhfasdfasdfasdfnsadofnsadlkfnsaldknfsad"; + } -assert.eq( i , j * 100 , "setup" ); + var db = s.getDB("test"); + var coll = db.foo; + + var i = 0; + for (var j = 0; j < 30; j++) { + print("j:" + j + " : " + + Date.timeFunc(function() { + var bulk = coll.initializeUnorderedBulkOp(); + for (var k = 0; k < 100; k++) { + bulk.insert({num: i, s: bigString}); + i++; + } + assert.writeOK(bulk.execute()); + })); + } -// Until SERVER-9715 is fixed, the sync command must be run on a diff connection -new Mongo(s.s.host).adminCommand("connpoolsync"); + s.startBalancer(); -print("done inserting data" ); + assert.eq(i, j * 100, "setup"); -print("datasize: " + tojson( s.getPrimaryShard("test" ).getDB("admin" ) - .runCommand( { datasize : "test.foo" } ) ) ); -s.printChunks(); + // Until SERVER-9715 is fixed, the sync command must be run on a diff connection + new Mongo(s.s.host).adminCommand("connpoolsync"); -function doCountsGlobal(){ - counta = s._connections[0].getDB("test" ).foo.count(); - countb = s._connections[1].getDB("test" ).foo.count(); - return counta + countb; -} + print("done inserting data"); -// Wait for the chunks to distribute -assert.soon( function(){ - doCountsGlobal(); - print("Counts: " + counta + countb); + print("datasize: " + + tojson(s.getPrimaryShard("test").getDB("admin").runCommand({datasize: "test.foo"}))); + s.printChunks(); - return counta > 0 && countb > 0; -}); + function doCountsGlobal() { + counta = s._connections[0].getDB("test").foo.count(); + countb = s._connections[1].getDB("test").foo.count(); + return counta + countb; + } + // Wait for the chunks to distribute + assert.soon(function() { + doCountsGlobal(); + print("Counts: " + counta + countb); -print("checkpoint B" ); + return counta > 0 && countb > 0; + }); -var missing = []; + print("checkpoint B"); -for ( i=0; i<j*100; i++ ){ - var x = coll.findOne( { num : i } ); - if ( ! x ){ - missing.push( i ); - print("can't find: " + i ); - sleep( 5000 ); - x = coll.findOne( { num : i } ); - if ( ! x ){ - print("still can't find: " + i ); + var missing = []; - for ( var zzz=0; zzz<s._connections.length; zzz++ ){ - if ( s._connections[zzz].getDB("test" ).foo.findOne( { num : i } ) ){ - print("found on wrong server: " + s._connections[zzz] ); + for (i = 0; i < j * 100; i++) { + var x = coll.findOne({num: i}); + if (!x) { + missing.push(i); + print("can't find: " + i); + sleep(5000); + x = coll.findOne({num: i}); + if (!x) { + print("still can't find: " + i); + + for (var zzz = 0; zzz < s._connections.length; zzz++) { + if (s._connections[zzz].getDB("test").foo.findOne({num: i})) { + print("found on wrong server: " + s._connections[zzz]); + } } } - } } -} - -s.printChangeLog(); - -print("missing: " + tojson( missing ) ); -assert.soon( function(z){ return doCountsGlobal() == j * 100; } , "from each a:" + counta + " b:" + countb + " i:" + i ); -print("checkpoint B.a" ); -s.printChunks(); -assert.eq( j * 100 , coll.find().limit(100000000).itcount() , "itcount A" ); -assert.eq( j * 100 , counta + countb , "from each 2 a:" + counta + " b:" + countb + " i:" + i ); -assert( missing.length == 0 , "missing : " + tojson( missing ) ); - -print("checkpoint C" ); - -assert( Array.unique( s.config.chunks.find().toArray().map( function(z){ return z.shard; } ) ).length == 2 , "should be using both servers" ); - -for ( i=0; i<100; i++ ){ - cursor = coll.find().batchSize(5); - cursor.next(); - cursor = null; - gc(); -} - -print("checkpoint D"); - -// test not-sharded cursors -db = s.getDB("test2" ); -t = db.foobar; -for ( i =0; i<100; i++ ) - t.save( { _id : i } ); -for ( i=0; i<100; i++ ){ - t.find().batchSize( 2 ).next(); - assert.lt(0 , db.serverStatus().metrics.cursor.open.total, "cursor1"); - gc(); -} - -for ( i=0; i<100; i++ ){ - gc(); -} -assert.eq(0, db.serverStatus().metrics.cursor.open.total, "cursor2"); - -// Stop the balancer, otherwise it may grab some connections from the pool for itself -s.stopBalancer(); - -print("checkpoint E"); - -assert( t.findOne() , "check close 0" ); - -for (i = 0; i < 20; i++) { - var conn = new Mongo( db.getMongo().host ); - temp2 = conn.getDB("test2" ).foobar; - assert.eq( conn._fullNameSpace , t._fullNameSpace , "check close 1" ); - assert( temp2.findOne() , "check close 2" ); - conn = null; - gc(); -} - -print("checkpoint F"); - -assert.throws(function() { - s.getDB("test" ).foo.find().sort({ s : 1 }).forEach(function(x) { - printjsononeline(x.substring(0, x.length > 30 ? 30 : x.length)); + + s.printChangeLog(); + + print("missing: " + tojson(missing)); + assert.soon(function(z) { + return doCountsGlobal() == j * 100; + }, "from each a:" + counta + " b:" + countb + " i:" + i); + print("checkpoint B.a"); + s.printChunks(); + assert.eq(j * 100, coll.find().limit(100000000).itcount(), "itcount A"); + assert.eq(j * 100, counta + countb, "from each 2 a:" + counta + " b:" + countb + " i:" + i); + assert(missing.length == 0, "missing : " + tojson(missing)); + + print("checkpoint C"); + + assert(Array.unique(s.config.chunks.find().toArray().map(function(z) { + return z.shard; + })).length == 2, + "should be using both servers"); + + for (i = 0; i < 100; i++) { + cursor = coll.find().batchSize(5); + cursor.next(); + cursor = null; + gc(); + } + + print("checkpoint D"); + + // test not-sharded cursors + db = s.getDB("test2"); + t = db.foobar; + for (i = 0; i < 100; i++) + t.save({_id: i}); + for (i = 0; i < 100; i++) { + t.find().batchSize(2).next(); + assert.lt(0, db.serverStatus().metrics.cursor.open.total, "cursor1"); + gc(); + } + + for (i = 0; i < 100; i++) { + gc(); + } + assert.eq(0, db.serverStatus().metrics.cursor.open.total, "cursor2"); + + // Stop the balancer, otherwise it may grab some connections from the pool for itself + s.stopBalancer(); + + print("checkpoint E"); + + assert(t.findOne(), "check close 0"); + + for (i = 0; i < 20; i++) { + var conn = new Mongo(db.getMongo().host); + temp2 = conn.getDB("test2").foobar; + assert.eq(conn._fullNameSpace, t._fullNameSpace, "check close 1"); + assert(temp2.findOne(), "check close 2"); + conn = null; + gc(); + } + + print("checkpoint F"); + + assert.throws(function() { + s.getDB("test").foo.find().sort({s: 1}).forEach(function(x) { + printjsononeline(x.substring(0, x.length > 30 ? 30 : x.length)); + }); }); -}); -print("checkpoint G"); + print("checkpoint G"); -s.stop(); + s.stop(); })(); |