1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
|
function setupMoveChunkTest(st) {
//Stop Balancer
st.stopBalancer();
var testdb = st.getDB( "test" );
var testcoll = testdb.foo;
st.adminCommand( { enablesharding : "test" } );
st.adminCommand( { shardcollection : "test.foo" , key : { _id : 1 } } );
var str = "";
while ( str.length < 10000 ) {
str += "asdasdsdasdasdasdas";
}
var data = num = 0;
//Insert till you get to 10MB of data
while ( data < ( 1024 * 1024 * 10 ) ) {
testcoll.insert( { _id : num++ , s : str } )
data += str.length
}
//Flush and wait
testdb.getLastError()
var stats = st.chunkCounts( "foo" )
var to = ""
for ( shard in stats ){
if ( stats[shard] == 0 ) {
to = shard
break;
}
}
var result = st.adminCommand( { movechunk : "test.foo" ,
find : { _id : 1 } ,
to : to ,
_waitForDelete : true} ); //some tests need this...
assert(result, "movechunk failed: " + tojson( result ) )
}
|
