diff options
author | Randolph Tan <randolph@10gen.com> | 2015-07-29 17:24:35 -0400 |
---|---|---|
committer | Randolph Tan <randolph@10gen.com> | 2015-08-06 09:58:01 -0400 |
commit | 1cfa49411655640a5b1d2da60573c3f01d3c7c38 (patch) | |
tree | ad5b8f6c570905441a51fb283910125f6ebfae65 /src/mongo/executor/network_test_env.cpp | |
parent | 1eee2b3a8c079c15ddc79e03e1b1d16b37d427d2 (diff) | |
download | mongo-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.cpp | 11 |
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); |