summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_coordinator_mock.h
diff options
context:
space:
mode:
authorRandolph Tan <randolph@10gen.com>2019-06-27 16:02:28 -0400
committerRandolph Tan <randolph@10gen.com>2019-07-17 11:43:27 -0400
commit31016beb5503c9ecf783826fb3b761ea92bfff7f (patch)
treeadb736ddac3dfdc24646e2c5a723e5a2e89a33f8 /src/mongo/db/repl/replication_coordinator_mock.h
parented935ffffae8dd373063da350e4cb61547e20688 (diff)
downloadmongo-31016beb5503c9ecf783826fb3b761ea92bfff7f.tar.gz
SERVER-40785 Create WaitForMajorityService to allow waiting for write concern asynchronously
(cherry picked from commit 2dfbaadb85f32869c75f87117d9f6e98b4e948ea)
Diffstat (limited to 'src/mongo/db/repl/replication_coordinator_mock.h')
-rw-r--r--src/mongo/db/repl/replication_coordinator_mock.h8
1 files changed, 5 insertions, 3 deletions
diff --git a/src/mongo/db/repl/replication_coordinator_mock.h b/src/mongo/db/repl/replication_coordinator_mock.h
index 38ec9d5a3b6..67f7d2cead8 100644
--- a/src/mongo/db/repl/replication_coordinator_mock.h
+++ b/src/mongo/db/repl/replication_coordinator_mock.h
@@ -286,9 +286,10 @@ public:
/**
* Sets the function to generate the return value for calls to awaitReplication().
- * 'opTime' is the optime passed to awaitReplication().
+ * 'OperationContext' and 'opTime' are the parameters passed to awaitReplication().
*/
- using AwaitReplicationReturnValueFunction = stdx::function<StatusAndDuration(const OpTime&)>;
+ using AwaitReplicationReturnValueFunction =
+ stdx::function<StatusAndDuration(OperationContext*, const OpTime&)>;
void setAwaitReplicationReturnValueFunction(
AwaitReplicationReturnValueFunction returnValueFunction);
@@ -324,7 +325,8 @@ private:
OpTime _myLastAppliedOpTime;
Date_t _myLastAppliedWallTime;
ReplSetConfig _getConfigReturnValue;
- AwaitReplicationReturnValueFunction _awaitReplicationReturnValueFunction = [](const OpTime&) {
+ AwaitReplicationReturnValueFunction _awaitReplicationReturnValueFunction = [](OperationContext*,
+ const OpTime&) {
return StatusAndDuration(Status::OK(), Milliseconds(0));
};
bool _alwaysAllowWrites = false;