diff options
author | Mike Grundy <michael.grundy@10gen.com> | 2016-07-13 14:53:34 -0400 |
---|---|---|
committer | Mike Grundy <michael.grundy@10gen.com> | 2016-07-13 14:54:39 -0400 |
commit | f18bb78b469cc980c45ce0e5a3eb66d4c090292e (patch) | |
tree | 205eba8c85accd23935a6cd4e2f79d310ac3332f /buildscripts/resmokelib/testing/fixtures/replicaset.py | |
parent | e572d00484bafd5689c18010388675afa9e26f96 (diff) | |
download | mongo-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.py | 27 |
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 |