summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Russotto <matthew.russotto@mongodb.com>2022-07-07 11:26:02 -0400
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-07-16 01:12:22 +0000
commit7466bae6d8080110fc9fd8a1913a17f3459d564d (patch)
tree36bffbda696aa1edcc7b2eebdcc03268f729c4ce
parente5b531d247980a6fb1fb11992e2fb7c2b11f59c2 (diff)
downloadmongo-7466bae6d8080110fc9fd8a1913a17f3459d564d.tar.gz
SERVER-67954 Add logging to make it easier to track w:1 and w:majority unavailability after elections.
-rw-r--r--src/mongo/db/repl/replication_coordinator_impl.cpp4
-rw-r--r--src/mongo/db/repl/topology_coordinator.cpp8
2 files changed, 11 insertions, 1 deletions
diff --git a/src/mongo/db/repl/replication_coordinator_impl.cpp b/src/mongo/db/repl/replication_coordinator_impl.cpp
index 27ddfdcbc69..99db6940f3b 100644
--- a/src/mongo/db/repl/replication_coordinator_impl.cpp
+++ b/src/mongo/db/repl/replication_coordinator_impl.cpp
@@ -1327,7 +1327,9 @@ void ReplicationCoordinatorImpl::signalDrainComplete(OperationContext* opCtx,
_updateWriteAbilityFromTopologyCoordinator(lk, opCtx);
_updateMemberStateFromTopologyCoordinator(lk);
- LOGV2(21331, "Transition to primary complete; database writes are now permitted");
+ LOGV2(21331,
+ "Transition to primary complete; database writes are now permitted",
+ "term"_attr = _termShadow.load());
_externalState->startNoopWriter(_getMyLastAppliedOpTime_inlock());
}
diff --git a/src/mongo/db/repl/topology_coordinator.cpp b/src/mongo/db/repl/topology_coordinator.cpp
index e8044d24af6..6f3daeb392a 100644
--- a/src/mongo/db/repl/topology_coordinator.cpp
+++ b/src/mongo/db/repl/topology_coordinator.cpp
@@ -2943,6 +2943,14 @@ bool TopologyCoordinator::advanceLastCommittedOpTimeAndWallTime(OpTimeAndWallTim
return false;
}
+ if (committedOpTime.opTime.getTerm() != _lastCommittedOpTimeAndWallTime.opTime.getTerm()) {
+ LOGV2(6795400,
+ "Advancing committed opTime to a new term",
+ "newCommittedOpTime"_attr = committedOpTime.opTime,
+ "newCommittedWallime"_attr = committedOpTime.wallTime,
+ "oldTerm"_attr = _lastCommittedOpTimeAndWallTime.opTime.getTerm());
+ }
+
LOGV2_DEBUG(21826,
2,
"Updating _lastCommittedOpTimeAndWallTime to {_lastCommittedOpTimeAndWallTime}",