s = new ShardingTest( "migrateBig" , 2 , 0 , 1 , { chunksize : 1 } ); s.adminCommand( { enablesharding : "test" } ); s.adminCommand( { shardcollection : "test.foo" , key : { x : 1 } } ); db = s.getDB( "test" ) coll = db.foo big = "" while ( big.length < 10000 ) big += "eliot" for ( x=0; x<100; x++ ) coll.insert( { x : x , big : big } ) s.adminCommand( { split : "test.foo" , middle : { x : 33 } } ) s.adminCommand( { split : "test.foo" , middle : { x : 66 } } ) s.adminCommand( { movechunk : "test.foo" , find : { x : 90 } , to : s.getOther( s.getServer( "test" ) ).name } ) db.printShardingStatus() print( "YO : " + s.getServer( "test" ).host ) direct = new Mongo( s.getServer( "test" ).host ) print( "direct : " + direct ) directDB = direct.getDB( "test" ) for ( done=0; done<2*1024*1024; done+=big.length ){ directDB.foo.insert( { x : 50 + Math.random() , big : big } ) directDB.getLastError(); } db.printShardingStatus() assert.throws( function(){ s.adminCommand( { movechunk : "test.foo" , find : { x : 50 } , to : s.getOther( s.getServer( "test" ) ).name } ); } , [] , "move should fail" ) for ( i=0; i<20; i+= 2 ) { try { s.adminCommand( { split : "test.foo" , middle : { x : i } } ); } catch ( e ) { // we may have auto split on some of these // which is ok print(e); } } db.printShardingStatus() assert.soon( function(){ var x = s.chunkDiff( "foo" , "test" ); print( "chunk diff: " + x ); return x < 2; } , "no balance happened" , 8 * 60 * 1000 , 2000 ) s.stop()