jstests/sharding/advance_logical_time_with_valid_signature.js


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

/**
 * Tests that the mongo shell can use a cluster time with a valid signature to advance a server's
 * cluster time.
 */
(function() {
"use strict";

// Setup 2 mongos processes with mongobridge.
let st = new ShardingTest({shards: 1, mongos: 2, useBridge: true});

// Sever outgoing communications from the second mongos.
st.s0.disconnect(st.s1);
st._configServers.forEach(function(configSvr) {
    configSvr.disconnect(st.s1);
});

st._rsObjects.forEach(function(rsNodes) {
    rsNodes.nodes.forEach(function(conn) {
        conn.disconnect(st.s1);
    });
});

let connectedDB = st.s0.getDB("test");
let disconnectedDB = st.s1.getDB("test");

// Send an insert to the connected mongos to advance its cluster time.
let res = assert.commandWorked(connectedDB.runCommand({insert: "foo", documents: [{x: 1}]}));

// Get logicalTime metadata from the connected mongos's response and send it in an isMaster
// command to the disconnected mongos. isMaster does not require mongos to contact any other
// servers, so the command should succeed.
let lt = res.$clusterTime;
res =
    assert.commandWorked(disconnectedDB.runCommand({isMaster: 1, $clusterTime: lt}),
                         "expected the disconnected mongos to accept cluster time: " + tojson(lt));

// Verify cluster time response from the disconnected mongos matches what was passed.
assert.eq(lt,
          res.$clusterTime,
          "expected the disconnected mongos to send cluster time: " + tojson(lt) +
              ", received: " + tojson(res.$clusterTime));

st.stop();
})();