summaryrefslogtreecommitdiff
path: root/src/mongo/s/sharding_test_fixture.cpp
diff options
context:
space:
mode:
authorRandolph Tan <randolph@10gen.com>2017-03-08 11:31:04 -0500
committerRandolph Tan <randolph@10gen.com>2017-03-08 17:59:35 -0500
commit34dbe2a42d1db621f16555878b57f48efb30cc28 (patch)
treee8533f9703177022e21073a1b5a3fceb76b5b178 /src/mongo/s/sharding_test_fixture.cpp
parent91cf24955de997983ab675e35c98ccfa1e608d62 (diff)
downloadmongo-34dbe2a42d1db621f16555878b57f48efb30cc28.tar.gz
SERVER-27750 Attach LogicalTimeMetadata to globalConnPool and shardConnectionPool
This also include refactor work to cleanup ShardingEgressMetadataHook api and allow ShardingConnectionHook to take EgressMetadataHookList.
Diffstat (limited to 'src/mongo/s/sharding_test_fixture.cpp')
-rw-r--r--src/mongo/s/sharding_test_fixture.cpp5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/mongo/s/sharding_test_fixture.cpp b/src/mongo/s/sharding_test_fixture.cpp
index 59d3762925f..4068545c113 100644
--- a/src/mongo/s/sharding_test_fixture.cpp
+++ b/src/mongo/s/sharding_test_fixture.cpp
@@ -108,14 +108,15 @@ void ShardingTestFixture::setUp() {
// Set up executor pool used for most operations.
auto fixedNet = stdx::make_unique<executor::NetworkInterfaceMock>();
- fixedNet->setEgressMetadataHook(stdx::make_unique<ShardingEgressMetadataHookForMongos>());
+ fixedNet->setEgressMetadataHook(stdx::make_unique<ShardingEgressMetadataHookForMongos>(false));
_mockNetwork = fixedNet.get();
auto fixedExec = makeThreadPoolTestExecutor(std::move(fixedNet));
_networkTestEnv = stdx::make_unique<NetworkTestEnv>(fixedExec.get(), _mockNetwork);
_executor = fixedExec.get();
auto netForPool = stdx::make_unique<executor::NetworkInterfaceMock>();
- netForPool->setEgressMetadataHook(stdx::make_unique<ShardingEgressMetadataHookForMongos>());
+ netForPool->setEgressMetadataHook(
+ stdx::make_unique<ShardingEgressMetadataHookForMongos>(false));
auto execForPool = makeThreadPoolTestExecutor(std::move(netForPool));
std::vector<std::unique_ptr<executor::TaskExecutor>> executorsForPool;
executorsForPool.emplace_back(std::move(execForPool));