summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorScott Hernandez <scotthernandez@gmail.com>2014-10-16 09:51:26 -0400
committerScott Hernandez <scotthernandez@gmail.com>2014-10-17 11:31:49 -0400
commit39c48e85f8563119caa769f34e2b6f22c4790430 (patch)
tree3e7cf7f6ec1e858185eda530599063cf45890769 /src
parentaaf740d1748b5ed1ce890d88c489bd6f9399aeac (diff)
downloadmongo-39c48e85f8563119caa769f34e2b6f22c4790430.tar.gz
SERVER-14702: add syncingTo to self output of replSetGetStatus
Diffstat (limited to 'src')
-rw-r--r--src/mongo/db/repl/health.cpp8
-rw-r--r--src/mongo/db/repl/topology_coordinator_impl.cpp4
2 files changed, 11 insertions, 1 deletions
diff --git a/src/mongo/db/repl/health.cpp b/src/mongo/db/repl/health.cpp
index 237b2adb4f6..68ff1f03a7e 100644
--- a/src/mongo/db/repl/health.cpp
+++ b/src/mongo/db/repl/health.cpp
@@ -366,6 +366,7 @@ namespace repl {
verify( _self );
MemberState myState = box.getState();
+ const HostAndPort syncTarget = BackgroundSync::get()->getSyncTarget();
// add self
{
@@ -386,6 +387,12 @@ namespace repl {
bb.append("maintenanceMode", maintenance);
}
+ if ( !syncTarget.empty() &&
+ (myState != MemberState::RS_PRIMARY) &&
+ (myState != MemberState::RS_REMOVED) ) {
+ bb.append("syncingTo", syncTarget.toString());
+ }
+
if (theReplSet) {
string s = theReplSet->hbmsg();
if( !s.empty() )
@@ -448,7 +455,6 @@ namespace repl {
b.append("set", name());
b.appendTimeT("date", time(0));
b.append("myState", myState.s);
- const HostAndPort syncTarget = BackgroundSync::get()->getSyncTarget();
if ( !syncTarget.empty() &&
(myState != MemberState::RS_PRIMARY) &&
(myState != MemberState::RS_REMOVED) ) {
diff --git a/src/mongo/db/repl/topology_coordinator_impl.cpp b/src/mongo/db/repl/topology_coordinator_impl.cpp
index 3eef4aae331..df7731b7719 100644
--- a/src/mongo/db/repl/topology_coordinator_impl.cpp
+++ b/src/mongo/db/repl/topology_coordinator_impl.cpp
@@ -1228,6 +1228,10 @@ namespace {
bb.appendDate("optimeDate", Date_t(lastOpApplied.getSecs() * 1000ULL));
}
+ if (!_syncSource.empty()) {
+ bb.append("syncingTo", _syncSource.toString());
+ }
+
if (_maintenanceModeCalls) {
bb.append("maintenanceMode", _maintenanceModeCalls);
}