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
|
// Test for SERVER-8786 - if the first operation on an authenticated shard is moveChunk, it breaks the cluster.
var st = new ShardingTest({ keyFile : 'jstests/libs/key1', shards : 2, chunksize : 1, config : 3, verbose : 2,
other : { nopreallocj : 1, verbose : 2, useHostname : true,
configOptions : { verbose : 2 }}});
var mongos = st.s;
var adminDB = mongos.getDB('admin');
var db = mongos.getDB('test')
adminDB.addUser('admin', 'password');
adminDB.auth('admin', 'password');
adminDB.runCommand({enableSharding : "test"});
adminDB.runCommand({shardCollection : "test.foo", key : {x : 1}});
for (var i = 0; i < 100; i++) {
db.foo.insert({x:i});
}
adminDB.runCommand({split: "test.foo", middle: {x:50}});
var curShard = st.getShard("test.foo", {x:75});
var otherShard = st.getOther(curShard).name;
adminDB.runCommand({moveChunk: "test.foo", find: {x:25}, to: otherShard});
assert.soon( function() { return !st.isAnyBalanceInFlight(); });
st.printShardingStatus();
var savedOptions = st.shard0.savedOptions;
printjson(savedOptions);
savedOptions.restart = true;
MongoRunner.stopMongod(st.shard0.port);
MongoRunner.runMongod(savedOptions);
// May fail the first couple times due to socket exceptions
assert.soon( function() {
var res = adminDB.runCommand({moveChunk: "test.foo",
find: {x:75},
to: otherShard});
printjson(res);
return res.ok;
});
printjson(db.foo.findOne({x:25}));
printjson(db.foo.findOne({x:75}));
st.stop();
|
