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
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
// auto2.js
s = new ShardingTest( "auto2" , 2 , 1 , 1 );
s.adminCommand( { enablesharding : "test" } );
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;
for ( j=0; j<30; j++ ){
print( "j:" + j + " : " +
Date.timeFunc(
function(){
for ( var k=0; k<100; k++ ){
coll.save( { num : i , s : bigString } );
i++;
}
}
) );
}
s.adminCommand( "connpoolsync" );
db.getLastError();
print( "done inserting data" );
print( "datasize: " + tojson( s.getServer( "test" ).getDB( "admin" ).runCommand( { datasize : "test.foo" } ) ) );
s.printChunks();
counta = s._connections[0].getDB( "test" ).foo.count();
countb = s._connections[1].getDB( "test" ).foo.count();
assert( counta > 0 , "diff1" );
assert( countb > 0 , "diff2" );
print( "checkpoint B" )
assert.eq( j * 100 , counta + countb , "from each a:" + counta + " b:" + countb + " i:" + i );
print( "checkpoint B.a" )
assert.eq( j * 100 , coll.find().limit(100000000).itcount() , "itcount A" );
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.runCommand( "cursorInfo" ).total , "cursor1" );
gc();
}
gc(); gc();
assert.eq( 0 , db.runCommand( "cursorInfo" ).total , "cursor2" );
print( "checkpoint E")
x = db.runCommand( "connPoolStats" );
for ( host in x.hosts ){
var foo = x.hosts[host];
assert.lt( 0 , foo.available , "pool: " + host );
}
print( "checkpoint F")
assert( t.findOne() , "check close 0" );
for ( i=0; i<20; i++ ){
temp = new Mongo( db.getMongo().host )
temp2 = temp.getDB( "test2" ).foobar;
assert.eq( temp._fullNameSpace , t._fullNameSpace , "check close 1" );
assert( temp2.findOne() , "check close 2" );
temp = null;
gc();
}
print( "checkpoint G")
s.stop();
|
