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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
(function() {
var s = new ShardingTest({ name: "auto1",
shards: 2,
mongos: 1,
other: { enableBalancer : 1 } });
s.adminCommand( { enablesharding : "test" } );
s.ensurePrimaryShard('test', 'shard0001');
s.adminCommand( { shardcollection : "test.foo" , key : { num : 1 } } );
bigString = "";
while ( bigString.length < 1024 * 50 )
bigString += "asocsancdnsjfnsdnfsjdhfasdfasdfasdfnsadofnsadlkfnsaldknfsad";
db = s.getDB( "test" );
coll = db.foo;
var i=0;
var bulk = coll.initializeUnorderedBulkOp();
for ( ; i<100; i++ ){
bulk.insert( { num : i , s : bigString } );
}
assert.writeOK( bulk.execute() );
primary = s.getPrimaryShard( "test" ).getDB( "test" );
counts = [];
s.printChunks();
counts.push( s.config.chunks.count() );
assert.eq(100, db.foo.find().itcount());
print( "datasize: " + tojson( s.getPrimaryShard( "test" ).getDB( "admin" )
.runCommand( { datasize : "test.foo" } ) ) );
bulk = coll.initializeUnorderedBulkOp();
for ( ; i<200; i++ ){
bulk.insert( { num : i , s : bigString } );
}
assert.writeOK( bulk.execute() );
s.printChunks();
s.printChangeLog();
counts.push( s.config.chunks.count() );
bulk = coll.initializeUnorderedBulkOp();
for ( ; i<400; i++ ){
bulk.insert( { num : i , s : bigString } );
}
assert.writeOK( bulk.execute() );
s.printChunks();
s.printChangeLog();
counts.push( s.config.chunks.count() );
bulk = coll.initializeUnorderedBulkOp();
for ( ; i<700; i++ ){
bulk.insert( { num : i , s : bigString } );
}
assert.writeOK( bulk.execute() );
s.printChunks();
s.printChangeLog();
counts.push( s.config.chunks.count() );
assert( counts[counts.length-1] > counts[0] , "counts 1 : " + tojson( counts ) );
sorted = counts.slice(0);
// Sort doesn't sort numbers correctly by default, resulting in fail
sorted.sort( function(a, b){ return a - b; } );
assert.eq( counts , sorted , "counts 2 : " + tojson( counts ) );
print( counts );
printjson( db.stats() );
s.stop();
})();
|
