diff options
author | Misha Tyulenev <misha@mongodb.com> | 2020-03-12 17:02:32 -0400 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-03-12 21:15:59 +0000 |
commit | 78fa0cdbbbaf95f211c12640f4101b9f8c5800e1 (patch) | |
tree | df9f334aefae96c95244fe5fdc80b215db3cd7b7 | |
parent | 497f50a5e25db6171290f6e791ad02dd2b607498 (diff) | |
download | mongo-78fa0cdbbbaf95f211c12640f4101b9f8c5800e1.tar.gz |
Revert "SERVER-46512 do not use baton to run hedge requests"
This reverts commit 729b70ce06625ed73b023a6a41a1e4d1a7e58363.
-rw-r--r-- | src/mongo/executor/connection_pool.cpp | 11 | ||||
-rw-r--r-- | src/mongo/executor/network_interface_tl.cpp | 12 |
2 files changed, 1 insertions, 22 deletions
diff --git a/src/mongo/executor/connection_pool.cpp b/src/mongo/executor/connection_pool.cpp index 4738ee69971..0cc26800c65 100644 --- a/src/mongo/executor/connection_pool.cpp +++ b/src/mongo/executor/connection_pool.cpp @@ -92,21 +92,10 @@ void ConnectionPool::ConnectionInterface::indicateUsed() { } void ConnectionPool::ConnectionInterface::indicateSuccess() { - LOGV2_DEBUG(4651201, - 4, - "Success indicated for connection", - "getHostAndPort"_attr = getHostAndPort(), - "generation"_attr = getGeneration()); _status = Status::OK(); } void ConnectionPool::ConnectionInterface::indicateFailure(Status status) { - LOGV2_DEBUG(4651202, - 4, - "Failure indicated for connection", - "getHostAndPort"_attr = getHostAndPort(), - "generation"_attr = getGeneration(), - "status"_attr = status.toString()); _status = std::move(status); } diff --git a/src/mongo/executor/network_interface_tl.cpp b/src/mongo/executor/network_interface_tl.cpp index a41f7e8be2b..fbd19671d2c 100644 --- a/src/mongo/executor/network_interface_tl.cpp +++ b/src/mongo/executor/network_interface_tl.cpp @@ -327,12 +327,6 @@ void NetworkInterfaceTL::RequestState::returnConnection(Status status) noexcept auto connToReturn = std::exchange(conn, {}); - LOGV2_DEBUG(4651200, - logSeverityV1toV2(kDiagnosticLogLevel).toInt(), - "Returning a connection to the pool", - "status"_attr = status.toString(), - "is_hedge"_attr = isHedge); - if (!status.isOK()) { connToReturn->indicateFailure(std::move(status)); return; @@ -435,11 +429,7 @@ Status NetworkInterfaceTL::startCommand(const TaskExecutor::CallbackHandle& cbHa if (cmdState->requestOnAny.timeout != cmdState->requestOnAny.kNoTimeout) { cmdState->deadline = cmdState->stopwatch.start() + cmdState->requestOnAny.timeout; } - - // TODO: SERVER-46821 - if (!cmdState->requestOnAny.hedgeOptions) { - cmdState->baton = baton; - } + cmdState->baton = baton; if (_svcCtx && cmdState->requestOnAny.hedgeOptions) { auto hm = HedgingMetrics::get(_svcCtx); |