diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/mongo/db/repl/health.cpp | 8 | ||||
| -rw-r--r-- | src/mongo/db/repl/topology_coordinator_impl.cpp | 4 |
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); } |