SERVER-15849 add test for removing a chained member

1 files changed, 53 insertions, 0 deletions

diff --git a/jstests/replsets/chaining_removal.js b/jstests/replsets/chaining_removal.js
new file mode 100644
index 00000000000..c3c23c59d38
--- /dev/null
+++ b/jstests/replsets/chaining_removal.js
@@ -0,0 +1,53 @@
+// ensure removing a chained node does not break reporting of replication progress (SERVER-15849)
+
+(function() {
+    "use strict";
+    var numNodes = 5;
+    var host = getHostName();
+    var name = "chaining_removal";
+
+    var replTest = new ReplSetTest({name: name, nodes: numNodes});
+    var nodes = replTest.startSet();
+    var port = replTest.ports;
+    replTest.initiate({_id: name, members:
+            [
+                {_id: 0, host: nodes[0].host, priority: 3},
+                {_id: 1, host: nodes[1].host},
+                {_id: 2, host: nodes[2].host},
+                {_id: 3, host: nodes[3].host},
+                {_id: 4, host: nodes[4].host},
+            ],
+            });
+    var primary = replTest.getPrimary();
+    // force node 4 to chain through node 1
+    assert.commandWorked(nodes[4].getDB("admin").runCommand({"replSetSyncFrom": nodes[1].host}));
+    var res;
+    assert.soon(function() {
+        res = nodes[4].getDB("admin").runCommand({"replSetGetStatus": 1});
+        return res.syncingTo === nodes[1].host;
+    }, "node 4 failed to start chaining: "+ tojson(res));
+
+    // write that should reach all nodes
+    var timeout = 15 * 1000;
+    var options = {writeConcern: {w: numNodes, wtimeout: timeout}};
+    assert.writeOK(primary.getDB(name).foo.insert({x: 1}, options));
+
+    var config = primary.getDB("local").system.replset.findOne();
+    config.members.pop();
+    config.version++;
+    // remove node 4
+    replTest.stop(4);
+    try {
+        primary.adminCommand({replSetReconfig:config});
+    }
+    catch (e) {
+        print("error: "+e);
+    }
+
+    // ensure writing to all four nodes still works
+    primary = replTest.getPrimary();
+    options.writeConcern.w = 4;
+    assert.writeOK(primary.getDB(name).foo.insert({x: 2}, options));
+    
+    replTest.stopSet();
+}());