summaryrefslogtreecommitdiff
path: root/src/mongo/executor/network_test_env.cpp
diff options
context:
space:
mode:
authorRandolph Tan <randolph@10gen.com>2015-07-29 17:24:35 -0400
committerRandolph Tan <randolph@10gen.com>2015-08-06 09:58:01 -0400
commit1cfa49411655640a5b1d2da60573c3f01d3c7c38 (patch)
treead5b8f6c570905441a51fb283910125f6ebfae65 /src/mongo/executor/network_test_env.cpp
parent1eee2b3a8c079c15ddc79e03e1b1d16b37d427d2 (diff)
downloadmongo-1cfa49411655640a5b1d2da60573c3f01d3c7c38.tar.gz
SERVER-19390 Make config server read commands do read committed
Diffstat (limited to 'src/mongo/executor/network_test_env.cpp')
-rw-r--r--src/mongo/executor/network_test_env.cpp11
1 files changed, 11 insertions, 0 deletions
diff --git a/src/mongo/executor/network_test_env.cpp b/src/mongo/executor/network_test_env.cpp
index c65d1adcf2a..64241e72c12 100644
--- a/src/mongo/executor/network_test_env.cpp
+++ b/src/mongo/executor/network_test_env.cpp
@@ -64,6 +64,17 @@ void NetworkTestEnv::onCommand(OnCommandFunction func) {
_mockNetwork->exitNetwork();
}
+void NetworkTestEnv::onCommandWithMetadata(OnCommandWithMetadataFunction func) {
+ _mockNetwork->enterNetwork();
+
+ const NetworkInterfaceMock::NetworkOperationIterator noi = _mockNetwork->getNextReadyRequest();
+ const RemoteCommandRequest& request = noi->getRequest();
+ _mockNetwork->scheduleResponse(noi, _mockNetwork->now(), func(request));
+ _mockNetwork->runReadyNetworkOperations();
+
+ _mockNetwork->exitNetwork();
+}
+
void NetworkTestEnv::onFindCommand(OnFindCommandFunction func) {
onCommand([&func](const RemoteCommandRequest& request) -> StatusWith<BSONObj> {
const auto& resultStatus = func(request);