blob: d046547614423a1adba625963c218bd171c6b0be (
plain)
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
|
// Check index rebuild when MongoDB is killed
var ports = allocatePorts(1);
mongod = new MongodRunner(ports[0], MongoRunner.dataDir + "/index_retry", null, null, ["--journal"]);
var conn = mongod.start();
var test = conn.getDB("test");
var name = 'jstests_slownightly_index_retry';
t = test.getCollection(name);
t.drop();
// Insert a large number of documents, enough to ensure that an index build on these documents can
// be interrupted before complete.
for (i = 0; i < 5e5; ++i) {
t.save( { a:i } );
if (i % 10000 == 0) {
print("i: " + i);
}
}
test.getLastError();
function debug(x) {
printjson(x);
}
/**
* @return if there's a current running index build
*/
function indexBuildInProgress() {
inprog = test.currentOp().inprog;
debug(inprog);
indexBuildOpId = -1;
inprog.forEach(
function( op ) {
// Identify the index build as an insert into the 'test.system.indexes'
// namespace. It is assumed that no other clients are concurrently
// accessing the 'test' database.
if ( op.op == 'insert' && op.ns == 'test.system.indexes' ) {
debug(op.opid);
// SERVER-4295 Make sure the index details are there
// we can't assert these things, since there is a race in reporting
// but we won't count if they aren't
if ( "a_1" == op.insert.name &&
1 == op.insert.key.a &&
op.insert.background ) {
indexBuildOpId = op.opid;
}
}
}
);
return indexBuildOpId != -1;
}
function abortDuringIndexBuild(options) {
// Create an index asynchronously by using a new connection.
new Mongo(test.getMongo().host).getCollection(t.toString()).createIndex(
{ a:1 }, { background:true } );
// Wait for the index build to start.
var times = 0;
assert.soon(
function() {
return indexBuildInProgress() && times++ >= 2;
}
);
print("killing the mongod");
stopMongod(ports[0], /* signal */ 9);
}
abortDuringIndexBuild();
conn = mongod.start(/* reuseData */ true);
assert.soon(
function() {
try {
printjson(conn.getDB("test").getCollection(name).find({a:42}).hint({a:1}).next());
} catch (e) {
print(e);
return false;
}
return true;
},
'index builds successfully',
60000
);
print("Index built");
stopMongod(ports[0]);
print("SUCCESS!");
|
