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
|
//
// Tests that mongos validating writes when stale does not DOS config servers
//
// Note that this is *unsafe* with broadcast removes and updates
//
var st = new ShardingTest({shards: 2, mongos: 3, other: {shardOptions: {verbose: 2}}});
st.stopBalancer();
var mongos = st.s0;
var staleMongosA = st.s1;
var staleMongosB = st.s2;
// Additional logging
printjson(mongos.getDB("admin").runCommand({setParameter: 1, logLevel: 2}));
printjson(staleMongosA.getDB("admin").runCommand({setParameter: 1, logLevel: 2}));
printjson(staleMongosB.getDB("admin").runCommand({setParameter: 1, logLevel: 2}));
printjson(st._connections[0].getDB("admin").runCommand({setParameter: 1, logLevel: 2}));
printjson(st._connections[1].getDB("admin").runCommand({setParameter: 1, logLevel: 2}));
var admin = mongos.getDB("admin");
var config = mongos.getDB("config");
var coll = mongos.getCollection("foo.bar");
var staleCollA = staleMongosA.getCollection(coll + "");
var staleCollB = staleMongosB.getCollection(coll + "");
printjson(admin.runCommand({enableSharding: coll.getDB() + ""}));
st.ensurePrimaryShard(coll.getDB().getName(), 'shard0001');
coll.ensureIndex({a: 1});
printjson(admin.runCommand({shardCollection: coll + "", key: {a: 1}}));
// Let the stale mongos see the collection state
staleCollA.findOne();
staleCollB.findOne();
// Change the collection sharding state
coll.drop();
coll.ensureIndex({b: 1});
printjson(admin.runCommand({shardCollection: coll + "", key: {b: 1}}));
// Make sure that we can successfully insert, even though we have stale state
assert.writeOK(staleCollA.insert({b: "b"}));
// Make sure we unsuccessfully insert with old info
assert.writeError(staleCollB.insert({a: "a"}));
// Change the collection sharding state
coll.drop();
coll.ensureIndex({c: 1});
printjson(admin.runCommand({shardCollection: coll + "", key: {c: 1}}));
// Make sure we can successfully upsert, even though we have stale state
assert.writeOK(staleCollA.update({c: "c"}, {c: "c"}, true));
// Make sure we unsuccessfully upsert with old info
assert.writeError(staleCollB.update({b: "b"}, {b: "b"}, true));
// Change the collection sharding state
coll.drop();
coll.ensureIndex({d: 1});
printjson(admin.runCommand({shardCollection: coll + "", key: {d: 1}}));
// Make sure we can successfully update, even though we have stale state
assert.writeOK(coll.insert({d: "d"}));
assert.writeOK(staleCollA.update({d: "d"}, {$set: {x: "x"}}, false, false));
assert.eq(staleCollA.findOne().x, "x");
// Make sure we unsuccessfully update with old info
assert.writeError(staleCollB.update({c: "c"}, {$set: {x: "y"}}, false, false));
assert.eq(staleCollB.findOne().x, "x");
// Change the collection sharding state
coll.drop();
coll.ensureIndex({e: 1});
// Deletes need to be across two shards to trigger an error - this is probably an exceptional case
printjson(admin.runCommand({movePrimary: coll.getDB() + "", to: "shard0000"}));
printjson(admin.runCommand({shardCollection: coll + "", key: {e: 1}}));
printjson(admin.runCommand({split: coll + "", middle: {e: 0}}));
printjson(admin.runCommand({moveChunk: coll + "", find: {e: 0}, to: "shard0001"}));
// Make sure we can successfully remove, even though we have stale state
assert.writeOK(coll.insert({e: "e"}));
assert.writeOK(staleCollA.remove({e: "e"}, true));
assert.eq(null, staleCollA.findOne());
// Make sure we unsuccessfully remove with old info
assert.writeError(staleCollB.remove({d: "d"}, true));
st.stop();
|
