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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
// Test background index creation
parallel = function() {
return db[ baseName + "_parallelStatus" ];
}
resetParallel = function() {
parallel().drop();
}
doParallel = function(work) {
resetParallel();
print("doParallel: " + work);
startMongoProgramNoConnect("mongo", "--eval", work + "; db." + baseName + "_parallelStatus.save( {done:1} );", db.getMongo().host);
}
doneParallel = function() {
return !!parallel().findOne();
}
waitParallel = function() {
assert.soon( function() { return doneParallel(); }, "parallel did not finish in time", 300000, 1000 );
}
// waiting on SERVER-620
print( "index11.js host:" );
print( db.getMongo().host );
if (1) {
size = 500000;
while( 1 ) { // if indexing finishes before we can run checks, try indexing w/ more data
print( "size: " + size );
baseName = "jstests_index11";
fullName = "db." + baseName;
t = db[ baseName ];
t.drop();
db.eval( function( size ) {
for( i = 0; i < size; ++i ) {
db.jstests_index11.save( {i:i} );
}
},
size );
assert.eq( size, t.count() );
doParallel( fullName + ".ensureIndex( {i:1}, {background:true} )" );
try {
// wait for indexing to start
print("wait for indexing to start");
assert.soon( function() { return 2 == db.system.indexes.count( {ns:"test."+baseName} ) }, "no index created", 30000, 50 );
print("started.");
assert.eq( size, t.count() );
assert.eq( 100, t.findOne( {i:100} ).i );
q = t.find();
for( i = 0; i < 120; ++i ) { // getmore
q.next();
assert( q.hasNext(), "no next" );
}
assert.eq( "BasicCursor", t.find( {i:100} ).explain().cursor, "used btree cursor" );
t.remove( {i:40} );
t.update( {i:10}, {i:-10} );
id = t.find().hint( {$natural:-1} )._id;
t.update( {_id:id}, {i:-2} );
t.save( {i:-50} );
t.save( {i:size+2} );
assert( !db.getLastError() );
print("calling ensureIndex");
t.ensureIndex( {i:1} );
printjson( db.getLastError() );
assert( db.getLastError() );
assert.eq( size + 1, t.count() );
assert( !db.getLastError() );
print("calling dropIndex");
t.dropIndex( {i:1} );
printjson( db.getLastError() );
assert( db.getLastError() );
} catch( e ) {
// only a failure if we're still indexing
// wait for parallel status to update to reflect indexing status
print("caught exception");
sleep( 1000 );
if ( !doneParallel() ) {
throw e;
}
print("but that's OK")
}
if ( !doneParallel() ) {
break;
}
print( "indexing finished too soon, retrying..." );
size *= 2;
assert( size < 20000000, "unable to run checks in parallel with index creation" );
}
print("our tests done, waiting for parallel to finish");
waitParallel();
print("finished");
assert.eq( "BtreeCursor i_1", t.find( {i:100} ).explain().cursor );
assert.eq( 1, t.count( {i:-10} ) );
assert.eq( 1, t.count( {i:-2} ) );
assert.eq( 1, t.count( {i:-50} ) );
assert.eq( 1, t.count( {i:size+2} ) );
assert.eq( 0, t.count( {i:40} ) );
assert( !db.getLastError() );
print("about to drop index");
t.dropIndex( {i:1} );
printjson( db.getLastError() );
assert( !db.getLastError() );
} // if 1
|
