summaryrefslogtreecommitdiff
path: root/buildscripts/resmokelib/testing/fixtures/replicaset.py
diff options
context:
space:
mode:
authorMike Grundy <michael.grundy@10gen.com>2016-07-13 14:53:34 -0400
committerMike Grundy <michael.grundy@10gen.com>2016-07-13 14:54:39 -0400
commitf18bb78b469cc980c45ce0e5a3eb66d4c090292e (patch)
tree205eba8c85accd23935a6cd4e2f79d310ac3332f /buildscripts/resmokelib/testing/fixtures/replicaset.py
parente572d00484bafd5689c18010388675afa9e26f96 (diff)
downloadmongo-f18bb78b469cc980c45ce0e5a3eb66d4c090292e.tar.gz
SERVER-24716 Remove the CheckReplDBHashDeprecated hook
Diffstat (limited to 'buildscripts/resmokelib/testing/fixtures/replicaset.py')
-rw-r--r--buildscripts/resmokelib/testing/fixtures/replicaset.py27
1 files changed, 0 insertions, 27 deletions
diff --git a/buildscripts/resmokelib/testing/fixtures/replicaset.py b/buildscripts/resmokelib/testing/fixtures/replicaset.py
index 7eec3a84a8f..be24295ece7 100644
--- a/buildscripts/resmokelib/testing/fixtures/replicaset.py
+++ b/buildscripts/resmokelib/testing/fixtures/replicaset.py
@@ -156,33 +156,6 @@ class ReplicaSetFixture(interface.ReplFixture):
def get_secondaries(self):
return self.nodes[1:]
- def await_repl(self):
- client = utils.new_mongo_client(port=self.port)
-
- self.logger.info("Starting fsync on primary on port %d to flush all pending writes",
- self.port)
- client.fsync()
- self.logger.info("fsync on primary completed")
-
- self.logger.info("Awaiting replication of insert (w=%d, wtimeout=%d min) to primary on port"
- " %d", self.num_nodes, interface.ReplFixture.AWAIT_REPL_TIMEOUT_MINS,
- self.port)
-
- # Keep retrying this until it times out waiting for replication.
- def insert_fn(remaining_secs):
- remaining_millis = int(round(remaining_secs * 1000))
- write_concern = pymongo.WriteConcern(w=self.num_nodes, wtimeout=remaining_millis)
- coll = client.resmoke.get_collection("await_repl", write_concern=write_concern)
- coll.insert_one({"awaiting": "repl"})
-
- try:
- self.retry_until_wtimeout(insert_fn)
- except pymongo.errors.WTimeoutError:
- self.logger.info("Replication of write operation timed out.")
- raise
-
- self.logger.info("Replication of write operation completed.")
-
def _new_mongod(self, index, replset_name):
"""
Returns a standalone.MongoDFixture configured to be used as a