summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/oplogreader.cpp
diff options
context:
space:
mode:
authorBenety Goh <benety@mongodb.com>2015-06-05 14:21:38 -0400
committerBenety Goh <benety@mongodb.com>2015-06-09 12:38:31 -0400
commita0f7f8ca367dcb79f5dd5c6a62b32876144e6eef (patch)
tree2f2a3331e0dcd13ddffca347897648e5eafc0ddb /src/mongo/db/repl/oplogreader.cpp
parent089c07c95443283390db78937ab5785041b991fd (diff)
downloadmongo-a0f7f8ca367dcb79f5dd5c6a62b32876144e6eef.tar.gz
SERVER-18807 OplogReader connection should use same MessagePort tag as connection pool in replication coordinator
Diffstat (limited to 'src/mongo/db/repl/oplogreader.cpp')
-rw-r--r--src/mongo/db/repl/oplogreader.cpp2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/mongo/db/repl/oplogreader.cpp b/src/mongo/db/repl/oplogreader.cpp
index 4809a96546b..f0b0d98d891 100644
--- a/src/mongo/db/repl/oplogreader.cpp
+++ b/src/mongo/db/repl/oplogreader.cpp
@@ -47,6 +47,7 @@
#include "mongo/db/repl/minvalid.h"
#include "mongo/db/repl/oplog.h"
#include "mongo/db/repl/replication_coordinator.h"
+#include "mongo/executor/network_interface.h"
#include "mongo/util/assert_util.h"
#include "mongo/util/log.h"
@@ -101,6 +102,7 @@ namespace repl {
error() << errmsg << endl;
return false;
}
+ _conn->port().tag |= executor::NetworkInterface::kMessagingPortKeepOpen;
_host = host;
}
return true;