summaryrefslogtreecommitdiff
path: root/jstests/replsets/startParallelShell.js
diff options
context:
space:
mode:
authorApollon Oikonomopoulos <apoikos@debian.org>2018-03-22 12:08:05 +0200
committerApollon Oikonomopoulos <apoikos@debian.org>2018-03-22 12:08:05 +0200
commit72ad42c506a506ef238d4b1fdcf2b9da5668bfb9 (patch)
treedf94bdab3d6f16e14016f4547b9e86f368ba8150 /jstests/replsets/startParallelShell.js
parent648fcfa3cf11ba8fdb7bb64c52f3159b4351ae3c (diff)
parentc49e99631589113663b1a3ac691870421965a315 (diff)
Update upstream source from tag 'upstream/3.4.14'
Update to upstream version '3.4.14' with Debian dir 8c079cd0bdbb1831aa5b89a3b7d4c1b4a1b891a2
Diffstat (limited to 'jstests/replsets/startParallelShell.js')
-rw-r--r--jstests/replsets/startParallelShell.js33
1 files changed, 33 insertions, 0 deletions
diff --git a/jstests/replsets/startParallelShell.js b/jstests/replsets/startParallelShell.js
new file mode 100644
index 00000000000..beca88d19a9
--- /dev/null
+++ b/jstests/replsets/startParallelShell.js
@@ -0,0 +1,33 @@
+// 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);
+ startParallelShell('db.coll0.insert({test: "connString only"});');
+ assert.soon(function() {
+ return db.coll0.find({test: "connString only"}).count() === 1;
+ });
+
+ const uri = new MongoURI(url);
+ const port0 = uri.servers[0].port;
+ print("* Starting parallel shell w/ --port " + port0);
+ startParallelShell('db.coll0.insert({test: "explicit port"});', port0);
+ assert.soon(function() {
+ return db.coll0.find({test: "explicit port"}).count() === 1;
+ });
+})();