diff options
author | Eric Milkie <milkie@10gen.com> | 2016-09-14 10:19:23 -0400 |
---|---|---|
committer | Eric Milkie <milkie@10gen.com> | 2016-09-15 12:48:37 -0400 |
commit | 1116c9d3d903e103d2fc6c3ce792134808cc8691 (patch) | |
tree | fe2caf371cc8f780b16c9b5b1e369f1c2e4cde43 | |
parent | 01b41016456ed15b36b2f4b9f62bc87113069380 (diff) | |
download | mongo-1116c9d3d903e103d2fc6c3ce792134808cc8691.tar.gz |
SERVER-26106 raise oplog socket timeout for rollback
-rw-r--r-- | src/mongo/db/repl/bgsync.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/mongo/db/repl/bgsync.cpp b/src/mongo/db/repl/bgsync.cpp index d323703a0e6..77f803fd303 100644 --- a/src/mongo/db/repl/bgsync.cpp +++ b/src/mongo/db/repl/bgsync.cpp @@ -68,7 +68,7 @@ namespace { const char kHashFieldName[] = "h"; const int kSleepToAllowBatchingMillis = 2; const int kSmallBatchLimitBytes = 40000; -const Milliseconds kOplogSocketTimeout(30000); +const Milliseconds kRollbackOplogSocketTimeout(10 * 60 * 1000); /** * Extends DataReplicatorExternalStateImpl to be member state aware. @@ -423,7 +423,7 @@ void BackgroundSync::_produce(OperationContext* txn) { auto getConnection = [&connection, &connectionPool, source]() -> DBClientBase* { if (!connection.get()) { connection.reset(new ConnectionPool::ConnectionPtr( - &connectionPool, source, Date_t::now(), kOplogSocketTimeout)); + &connectionPool, source, Date_t::now(), kRollbackOplogSocketTimeout)); }; return connection->get(); }; |