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
|
// this tests that slaveOk'd queries in sharded setups get correctly routed when
// a slave goes into RECOVERING state, and don't break
function prt(s) {
print("\nstale_clustered.js " + s);
print();
}
var shardTest = new ShardingTest( name = "clusteredstale" ,
numShards = 2 ,
verboseLevel = 0 ,
numMongos = 2 ,
otherParams = { rs : true } )//,
//rs0 : { logpath : "$path/mongod.log" },
//rs1 : { logpath : "$path/mongod.log" } } );
shardTest.setBalancer( false )
var mongos = shardTest.s0
var mongosSOK = shardTest.s1
mongosSOK.setSlaveOk()
var admin = mongos.getDB("admin")
var config = mongos.getDB("config")
var dbase = mongos.getDB("test")
var coll = dbase.getCollection("foo")
var dbaseSOk = mongosSOK.getDB( "" + dbase )
var collSOk = mongosSOK.getCollection( "" + coll )
var rsA = shardTest._rs[0].test
var rsB = shardTest._rs[1].test
rsA.getMaster().getDB( "test_a" ).dummy.insert( { x : 1 } )
rsB.getMaster().getDB( "test_b" ).dummy.insert( { x : 1 } )
rsA.awaitReplication()
rsB.awaitReplication()
prt("1: initial insert")
coll.save({ _id : -1, a : "a", date : new Date() })
coll.save({ _id : 1, b : "b", date : new Date() })
prt("2: shard collection")
shardTest.shardGo( coll, /* shardBy */ { _id : 1 }, /* splitAt */ { _id : 0 } )
prt("3: test normal and slaveOk queries")
// Make shardA and rsA the same
var shardA = shardTest.getShard( coll, { _id : -1 } )
var shardAColl = shardA.getCollection( "" + coll )
var shardB = shardTest.getShard( coll, { _id : 1 } )
if( shardA.name == rsB.getURL() ){
var swap = rsB
rsB = rsA
rsA = swap
}
rsA.awaitReplication()
rsB.awaitReplication()
assert.eq( coll.find().itcount(), collSOk.find().itcount() )
assert.eq( shardAColl.find().itcount(), 1 )
assert.eq( shardAColl.findOne()._id, -1 )
prt("5: overflow oplog");
var secs = rsA.getSecondaries()
var goodSec = secs[0]
var badSec = secs[1]
rsA.overflow( badSec )
prt("6: stop non-overflowed secondary")
rsA.stop( goodSec, undefined, true )
prt("7: check our regular and slaveok query")
assert.eq( coll.find().itcount(), collSOk.find().itcount() )
prt("8: restart both our secondaries clean")
rsA.restart( rsA.getSecondaries(), { remember : true, startClean : true }, undefined, 5 * 60 * 1000 )
prt("9: wait for recovery")
rsA.waitForState( rsA.getSecondaries(), rsA.SECONDARY, 5 * 60 * 1000 )
prt("10: check our regular and slaveok query")
assert.eq( coll.find().itcount(), collSOk.find().itcount() )
prt("DONE\n\n\n");
//shardTest.stop()
|
