summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEric Milkie <milkie@10gen.com>2017-01-03 15:08:36 -0500
committerEric Milkie <milkie@10gen.com>2017-01-03 15:08:36 -0500
commit6f9314992e5a5c320a84fd3c40ad3f84cacab32b (patch)
treef19bae645672939deb5e19cbde674de92347d3c5
parent6673eaeacc7fb115b1174226377a1b6a484e1fc5 (diff)
downloadmongo-6f9314992e5a5c320a84fd3c40ad3f84cacab32b.tar.gz
SERVER-26106 raise oplog socket timeout for rollback
-rw-r--r--src/mongo/db/repl/bgsync.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/repl/bgsync.cpp b/src/mongo/db/repl/bgsync.cpp
index a0312fa30f2..7e2587b4561 100644
--- a/src/mongo/db/repl/bgsync.cpp
+++ b/src/mongo/db/repl/bgsync.cpp
@@ -317,7 +317,7 @@ void BackgroundSync::_produce(OperationContext* txn) {
_replCoord->signalUpstreamUpdater();
}
- const Milliseconds oplogSocketTimeout(OplogReader::kSocketTimeout);
+ const Milliseconds kRollbackOplogSocketTimeout(10 * 60 * 1000);
const auto isV1ElectionProtocol = _replCoord->isV1ElectionProtocol();
// Under protocol version 1, make the awaitData timeout (maxTimeMS) dependent on the election
@@ -409,10 +409,10 @@ void BackgroundSync::_produce(OperationContext* txn) {
ConnectionPool connectionPool(messagingPortTags);
std::unique_ptr<ConnectionPool::ConnectionPtr> connection;
auto getConnection =
- [&connection, &connectionPool, oplogSocketTimeout, source]() -> DBClientBase* {
+ [&connection, &connectionPool, kRollbackOplogSocketTimeout, source]() -> DBClientBase* {
if (!connection.get()) {
connection.reset(new ConnectionPool::ConnectionPtr(
- &connectionPool, source, Date_t::now(), oplogSocketTimeout));
+ &connectionPool, source, Date_t::now(), kRollbackOplogSocketTimeout));
};
return connection->get();
};