blob: cb1838c392fe69249987a67798a73e09ece18a83 (
plain)
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
|
// Test startParallelShell() in a replica set.
var db;
(function() {
'use strict';
const setName = 'rs0';
const replSet = new ReplSetTest({name: setName, nodes: 3});
const nodes = replSet.nodeList();
replSet.startSet();
replSet.initiate();
const url = replSet.getURL();
print("* Connecting to " + url);
const mongo = new Mongo(url);
db = mongo.getDB('admin');
assert.eq(url, mongo.host, "replSet.getURL() should match active connection string");
print("* Starting parallel shell on --host " + db.getMongo().host);
var awaitShell = startParallelShell('db.coll0.insert({test: "connString only"});');
assert.soon(function() {
return db.coll0.find({test: "connString only"}).count() === 1;
});
awaitShell();
const uri = new MongoURI(url);
const port0 = uri.servers[0].port;
print("* Starting parallel shell w/ --port " + port0);
awaitShell = startParallelShell('db.coll0.insert({test: "explicit port"});', port0);
assert.soon(function() {
return db.coll0.find({test: "explicit port"}).count() === 1;
});
awaitShell();
replSet.stopSet();
})();
|
