diff options
author | Eric Milkie <milkie@10gen.com> | 2017-01-03 15:08:36 -0500 |
---|---|---|
committer | Eric Milkie <milkie@10gen.com> | 2017-01-03 15:08:36 -0500 |
commit | 6f9314992e5a5c320a84fd3c40ad3f84cacab32b (patch) | |
tree | f19bae645672939deb5e19cbde674de92347d3c5 | |
parent | 6673eaeacc7fb115b1174226377a1b6a484e1fc5 (diff) | |
download | mongo-6f9314992e5a5c320a84fd3c40ad3f84cacab32b.tar.gz |
SERVER-26106 raise oplog socket timeout for rollback
-rw-r--r-- | src/mongo/db/repl/bgsync.cpp | 6 |
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(); }; |