summaryrefslogtreecommitdiff
path: root/jstests/noPassthroughWithMongod/sharding_rs1.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/noPassthroughWithMongod/sharding_rs1.js')
-rw-r--r--jstests/noPassthroughWithMongod/sharding_rs1.js90
1 files changed, 0 insertions, 90 deletions
diff --git a/jstests/noPassthroughWithMongod/sharding_rs1.js b/jstests/noPassthroughWithMongod/sharding_rs1.js
deleted file mode 100644
index c85fa2a8e54..00000000000
--- a/jstests/noPassthroughWithMongod/sharding_rs1.js
+++ /dev/null
@@ -1,90 +0,0 @@
-// tests sharding with replica sets
-
-var s = new ShardingTest({ shards: 3,
- other: { rs: true , chunkSize: 1, enableBalancer: true }});
-
-s.adminCommand( { enablesharding : "test" } );
-s.ensurePrimaryShard('test', 'test-rs0');
-s.config.settings.update( { _id: "balancer" }, { $set : { _waitForDelete : true } } , true );
-
-s.config.settings.find().forEach( printjson )
-
-db = s.getDB( "test" );
-
-bigString = ""
-while ( bigString.length < 10000 )
- bigString += "asdasdasdasdadasdasdasdasdasdasdasdasda";
-
-inserted = 0;
-num = 0;
-
-while ( inserted < ( 20 * 1024 * 1024 ) ){
- var bulk = db.foo.initializeUnorderedBulkOp();
- for (var i = 0; i < 100; i ++) {
- bulk.insert({ _id: num++, s: bigString, x: Math.random() });
- inserted += bigString.length;
- }
- assert.writeOK(bulk.execute({w: 3}));
-}
-
-s.adminCommand( { shardcollection : "test.foo" , key : { _id : 1 } } );
-assert.lt( 20 , s.config.chunks.count() , "setup2" );
-
-function diff1(){
- var x = s.chunkCounts( "foo" );
- var total = 0;
- var min = 1000000000;
- var max = 0;
- for ( var sn in x ){
- total += x[sn];
- if ( x[sn] < min )
- min = x[sn];
- if ( x[sn] > max )
- max = x[sn];
- }
-
- print( tojson(x) + " total: " + total + " min: " + min + " max: " + max )
- return max - min;
-}
-
-assert.lt( 20 , diff1() , "big differential here" );
-print( diff1() )
-
-{
- // quick test for SERVER-2686
- var mydbs = db.getMongo().getDBs().databases;
- for ( var i=0; i<mydbs.length; i++ ) {
- assert( mydbs[i].name != "local" , "mongos listDatabases can't return local" );
- }
-}
-
-
-assert.soon( function(){
- var d = diff1();
- return d < 5;
-} , "balance didn't happen" , 1000 * 60 * 6 , 5000 );
-
-jsTest.log("Stopping balancer");
-s.stopBalancer();
-
-jsTest.log("Balancer stopped, checking dbhashes");
-for ( i=0; i<s._rs.length; i++ ){
- r = s._rs[i];
- r.test.awaitReplication();
- x = r.test.getHashes( "test" );
- print( r.url + "\t" + tojson( x ) )
- for ( j=0; j<x.slaves.length; j++ )
- assert.eq( x.master.md5 , x.slaves[j].md5 , "hashes not same for: " + r.url + " slave: " + j );
-}
-
-
-assert.eq( num , db.foo.find().count() , "C1" )
-assert.eq( num , db.foo.find().itcount() , "C2" )
-assert.eq( num , db.foo.find().sort( { _id : 1 } ).itcount() , "C3" )
-assert.eq( num , db.foo.find().sort( { _id : -1 } ).itcount() , "C4" )
-db.foo.ensureIndex( { x : 1 } )
-assert.eq( num , db.foo.find().sort( { x : 1 } ).itcount() , "C5" )
-assert.eq( num , db.foo.find().sort( { x : -1 } ).itcount() , "C6" )
-
-
-s.stop()