blob: 51cae86670a4bb2cd8af1468d560711db13bbabb (
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
|
// test for SERVER-6303 - if documents move backward during an initial sync.
var rt = new ReplSetTest( { name : "replset8tests" , nodes: 1 } );
var nodes = rt.startSet();
rt.initiate();
var master = rt.getMaster();
var bigstring = "a";
var md = master.getDB( 'd' );
var mdc = md[ 'c' ];
// prep the data
// idea: create x documents of increasing size, then create x documents of size n.
// delete first x documents. start initial sync (cloner). update all remaining
// documents to be increasing size.
// this should result in the updates moving the docs backwards.
var doccount = 5000;
// Avoid empty extent issues
mdc.insert( { _id:-1, x:"dummy" } );
print ("inserting bigstrings");
var bulk = mdc.initializeUnorderedBulkOp();
for( i = 0; i < doccount; ++i ) {
bulk.insert( { _id:i, x:bigstring } );
bigstring += "a";
}
assert.writeOK(bulk.execute());
print ("inserting x");
bulk = mdc.initializeUnorderedBulkOp();
for( i = doccount; i < doccount*2; ++i ) {
bulk.insert( { _id:i, x:i } );
}
assert.writeOK(bulk.execute());
print ("deleting bigstrings");
bulk = mdc.initializeUnorderedBulkOp();
for( i = 0; i < doccount; ++i ) {
bulk.find({ _id: i }).remove();
}
assert.writeOK(bulk.execute());
// add a secondary
var slave = rt.add();
rt.reInitiate();
print ("initiation complete!");
var sc = slave.getDB( 'd' )[ 'c' ];
slave.setSlaveOk();
sleep(25000);
print ("updating documents backwards");
// Move all documents to the beginning by growing them to sizes that should
// fit the holes we made in phase 1
bulk = mdc.initializeUnorderedBulkOp();
for (i = doccount*2; i > doccount; --i) {
mdc.update( { _id:i, x:i }, { _id:i, x:bigstring } );
bigstring = bigstring.slice(0, -1); // remove last char
}
print ("finished");
// Wait for replication to catch up.
rt.awaitSecondaryNodes();
assert.eq(doccount+1, slave.getDB( 'd' )['c'].count());
|
