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
|
// Test update modifier uassert during initial sync. SERVER-4781
load("jstests/replsets/rslib.js");
basename = "jstests_initsync4";
print("1. Bring up set");
replTest = new ReplSetTest( {name: basename, nodes: 1} );
replTest.startSet();
replTest.initiate();
m = replTest.getMaster();
md = m.getDB("d");
mc = m.getDB("d")["c"];
print("2. Insert some data");
N = 5000;
mc.ensureIndex({x:1});
var bulk = mc.initializeUnorderedBulkOp();
for( i = 0; i < N; ++i ) {
bulk.insert({ _id: i, x: i, a: {} });
}
assert.writeOK(bulk.execute());
print("3. Make sure synced");
replTest.awaitReplication();
print("4. Bring up a new node");
ports = allocatePorts( 3 );
basePath = MongoRunner.dataPath + basename;
hostname = getHostName();
s = startMongodTest (ports[2], basename, false, {replSet : basename, oplogSize : 2} );
var config = replTest.getReplSetConfig();
config.version = 2;
config.members.push({_id:2, host:hostname+":"+ports[2]});
try {
m.getDB("admin").runCommand({replSetReconfig:config});
}
catch(e) {
print(e);
}
reconnect(s);
print("5. Wait for new node to start cloning");
s.setSlaveOk();
sc = s.getDB("d")["c"];
wait( function() { printjson( sc.stats() ); return sc.stats().count > 0; } );
print("6. Start updating documents on primary");
for( i = N-1; i >= N-10000; --i ) {
// If the document is cloned as {a:1}, the {$set:{'a.b':1}} modifier will uassert.
mc.update( {_id:i}, {$set:{'a.b':1}} );
mc.update( {_id:i}, {$set:{a:1}} );
}
for ( i = N; i < N*2; i++ ) {
mc.insert( { _id : i, x : i } )
}
assert.eq( N*2, mc.count() );
print("7. Wait for new node to become SECONDARY");
wait(function() {
var status = s.getDB("admin").runCommand({replSetGetStatus:1});
printjson(status);
return status.members &&
(status.members[1].state == 2);
});
print("8. Wait for new node to have all the data")
wait(function() {
return sc.count() == mc.count();
} );
assert.eq( mc.getIndexKeys().length,
sc.getIndexKeys().length );
assert.eq( mc.find().sort( { x : 1 } ).itcount(),
sc.find().sort( { x : 1 } ).itcount() );
replTest.stopSet( 15 );
|
