diff options
| author | Benety Goh <benety@mongodb.com> | 2015-07-10 17:12:01 -0400 |
|---|---|---|
| committer | Benety Goh <benety@mongodb.com> | 2015-07-13 14:49:59 -0400 |
| commit | 62ff4ee275f5a38abcc2bc7b400d4d185e89044d (patch) | |
| tree | ad6bafba0825bc883fe90896b624b924d67d4e20 /src/mongo/db/repl/oplogreader.cpp | |
| parent | a23c7a22a838f91112bcc273654c9606331a9114 (diff) | |
| download | mongo-62ff4ee275f5a38abcc2bc7b400d4d185e89044d.tar.gz | |
SERVER-19307 converted OplogReader::tcp_timeout from int to Seconds
Diffstat (limited to 'src/mongo/db/repl/oplogreader.cpp')
| -rw-r--r-- | src/mongo/db/repl/oplogreader.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/mongo/db/repl/oplogreader.cpp b/src/mongo/db/repl/oplogreader.cpp index bb3e5c85fe3..950517d6192 100644 --- a/src/mongo/db/repl/oplogreader.cpp +++ b/src/mongo/db/repl/oplogreader.cpp @@ -76,6 +76,8 @@ bool replAuthenticate(DBClientBase* conn) { return authenticateInternalUser(conn); } +const Seconds OplogReader::kSocketTimeout(30); + OplogReader::OplogReader() { _tailingQueryOptions = QueryOption_SlaveOk; _tailingQueryOptions |= QueryOption_CursorTailable | QueryOption_OplogReplay; @@ -89,7 +91,8 @@ OplogReader::OplogReader() { bool OplogReader::connect(const HostAndPort& host) { if (conn() == NULL || _host != host) { resetConnection(); - _conn = shared_ptr<DBClientConnection>(new DBClientConnection(false, tcp_timeout)); + _conn = + shared_ptr<DBClientConnection>(new DBClientConnection(false, kSocketTimeout.count())); string errmsg; if (!_conn->connect(host, errmsg) || (getGlobalAuthorizationManager()->isAuthEnabled() && !replAuthenticate(_conn.get()))) { |