summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEric Milkie <milkie@10gen.com>2016-09-14 10:19:23 -0400
committerEric Milkie <milkie@10gen.com>2016-09-15 12:48:37 -0400
commit1116c9d3d903e103d2fc6c3ce792134808cc8691 (patch)
treefe2caf371cc8f780b16c9b5b1e369f1c2e4cde43
parent01b41016456ed15b36b2f4b9f62bc87113069380 (diff)
downloadmongo-1116c9d3d903e103d2fc6c3ce792134808cc8691.tar.gz
SERVER-26106 raise oplog socket timeout for rollback
-rw-r--r--src/mongo/db/repl/bgsync.cpp4
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();
};