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
|
doTest = function( signal ) {
var name = "buildIndexes";
var host = getHostName();
var replTest = new ReplSetTest( {name: name, nodes: 3} );
var nodes = replTest.startSet();
var config = replTest.getReplSetConfig();
config.members[2].priority = 0;
config.members[2].buildIndexes = false;
replTest.initiate(config);
var master = replTest.getMaster().getDB(name);
var slaveConns = replTest.liveNodes.slaves;
var slave = [];
for (var i in slaveConns) {
slaveConns[i].setSlaveOk();
slave.push(slaveConns[i].getDB(name));
}
replTest.awaitReplication();
print("creating an index on x");
master.x.ensureIndex({y : 1});
printjson(master.x.stats());
for (var i=0; i<100; i++) {
master.x.insert({x:1,y:"abc",c:1});
}
replTest.awaitReplication();
printjson(slave[0].runCommand({count: "x"}));
var ns = master.x+"";
print("namespace: "+ns);
// can't query system.indexes from slave, so we'll look at coll.stats()
printjson(slave[0].adminCommand({replSetGetStatus:1}));
printjson(slave[0].getSisterDB("local").system.replset.findOne());
printjson(master.stats());
printjson(slave[0].stats());
printjson(slave[1].stats());
printjson(master.x.stats());
printjson(slave[0].x.stats());
printjson(slave[1].x.stats());
print("sleeping");
sleep(20000);
var indexes = slave[0].stats().indexes;
assert.eq(indexes, 2, 'number of indexes');
indexes = slave[1].stats().indexes;
assert.eq(indexes, 1);
indexes = slave[0].x.stats().indexSizes;
printjson(indexes);
var count = 0;
for (var i in indexes) {
count++;
if (i == "_id_") {
continue;
}
print(i);
print(i.match(/y_/));
assert(i.match(/y_/));
}
assert.eq(count, 2);
indexes = slave[1].x.stats().indexSizes;
printjson(indexes);
count = 0;
for (var i in indexes) {
count++;
}
assert.eq(count, 1);
replTest.stopSet(15);
}
doTest(15);
|