summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_consistency_markers_impl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/replication_consistency_markers_impl.cpp')
-rw-r--r--src/mongo/db/repl/replication_consistency_markers_impl.cpp74
1 files changed, 53 insertions, 21 deletions
diff --git a/src/mongo/db/repl/replication_consistency_markers_impl.cpp b/src/mongo/db/repl/replication_consistency_markers_impl.cpp
index 8d7046a89f2..6464b0311cc 100644
--- a/src/mongo/db/repl/replication_consistency_markers_impl.cpp
+++ b/src/mongo/db/repl/replication_consistency_markers_impl.cpp
@@ -39,6 +39,7 @@
#include "mongo/db/repl/optime.h"
#include "mongo/db/repl/replication_coordinator.h"
#include "mongo/db/repl/storage_interface.h"
+#include "mongo/logv2/log.h"
#include "mongo/util/log.h"
namespace mongo {
@@ -93,7 +94,7 @@ void ReplicationConsistencyMarkersImpl::_updateMinValidDocument(
}
void ReplicationConsistencyMarkersImpl::initializeMinValidDocument(OperationContext* opCtx) {
- LOG(3) << "Initializing minValid document";
+ LOGV2_DEBUG(21282, 3, "Initializing minValid document");
// This initializes the values of the required fields if they are not already set.
// If one of the fields is already set, the $max will prefer the existing value since it
@@ -114,22 +115,25 @@ void ReplicationConsistencyMarkersImpl::initializeMinValidDocument(OperationCont
bool ReplicationConsistencyMarkersImpl::getInitialSyncFlag(OperationContext* opCtx) const {
auto doc = _getMinValidDocument(opCtx);
if (!doc) {
- LOG(3) << "No min valid document found, returning initial sync flag value of false.";
+ LOGV2_DEBUG(
+ 21283, 3, "No min valid document found, returning initial sync flag value of false.");
return false;
}
boost::optional<bool> flag = doc->getInitialSyncFlag();
if (!flag) {
- LOG(3) << "No initial sync flag set, returning initial sync flag value of false.";
+ LOGV2_DEBUG(
+ 21284, 3, "No initial sync flag set, returning initial sync flag value of false.");
return false;
}
- LOG(3) << "returning initial sync flag value of " << flag.get();
+ LOGV2_DEBUG(
+ 21285, 3, "returning initial sync flag value of {flag_get}", "flag_get"_attr = flag.get());
return flag.get();
}
void ReplicationConsistencyMarkersImpl::setInitialSyncFlag(OperationContext* opCtx) {
- LOG(3) << "setting initial sync flag";
+ LOGV2_DEBUG(21286, 3, "setting initial sync flag");
TimestampedBSONObj update;
update.obj = BSON("$set" << kInitialSyncFlag);
@@ -143,7 +147,7 @@ void ReplicationConsistencyMarkersImpl::setInitialSyncFlag(OperationContext* opC
}
void ReplicationConsistencyMarkersImpl::clearInitialSyncFlag(OperationContext* opCtx) {
- LOG(3) << "clearing initial sync flag";
+ LOGV2_DEBUG(21287, 3, "clearing initial sync flag");
auto replCoord = repl::ReplicationCoordinator::get(opCtx);
OpTimeAndWallTime opTimeAndWallTime = replCoord->getMyLastAppliedOpTimeAndWallTime();
@@ -184,15 +188,22 @@ OpTime ReplicationConsistencyMarkersImpl::getMinValid(OperationContext* opCtx) c
auto minValid = OpTime(doc->getMinValidTimestamp(), doc->getMinValidTerm());
- LOG(3) << "returning minvalid: " << minValid.toString() << "(" << minValid.toBSON() << ")";
+ LOGV2_DEBUG(21288,
+ 3,
+ "returning minvalid: {minValid}({minValid2})",
+ "minValid"_attr = minValid.toString(),
+ "minValid2"_attr = minValid.toBSON());
return minValid;
}
void ReplicationConsistencyMarkersImpl::setMinValid(OperationContext* opCtx,
const OpTime& minValid) {
- LOG(3) << "setting minvalid to exactly: " << minValid.toString() << "(" << minValid.toBSON()
- << ")";
+ LOGV2_DEBUG(21289,
+ 3,
+ "setting minvalid to exactly: {minValid}({minValid2})",
+ "minValid"_attr = minValid.toString(),
+ "minValid2"_attr = minValid.toBSON());
TimestampedBSONObj update;
update.obj =
BSON("$set" << BSON(MinValidDocument::kMinValidTimestampFieldName
@@ -209,8 +220,11 @@ void ReplicationConsistencyMarkersImpl::setMinValid(OperationContext* opCtx,
void ReplicationConsistencyMarkersImpl::setMinValidToAtLeast(OperationContext* opCtx,
const OpTime& minValid) {
- LOG(3) << "setting minvalid to at least: " << minValid.toString() << "(" << minValid.toBSON()
- << ")";
+ LOGV2_DEBUG(21290,
+ 3,
+ "setting minvalid to at least: {minValid}({minValid2})",
+ "minValid"_attr = minValid.toString(),
+ "minValid2"_attr = minValid.toBSON());
auto& termField = MinValidDocument::kMinValidTermFieldName;
auto& tsField = MinValidDocument::kMinValidTimestampFieldName;
@@ -250,7 +264,11 @@ void ReplicationConsistencyMarkersImpl::setAppliedThrough(OperationContext* opCt
const OpTime& optime,
bool setTimestamp) {
invariant(!optime.isNull());
- LOG(3) << "setting appliedThrough to: " << optime.toString() << "(" << optime.toBSON() << ")";
+ LOGV2_DEBUG(21291,
+ 3,
+ "setting appliedThrough to: {optime}({optime2})",
+ "optime"_attr = optime.toString(),
+ "optime2"_attr = optime.toBSON());
// We set the 'appliedThrough' to the provided timestamp. The 'appliedThrough' is only valid
// in checkpoints that contain all writes through this timestamp since it indicates the top of
@@ -266,7 +284,10 @@ void ReplicationConsistencyMarkersImpl::setAppliedThrough(OperationContext* opCt
void ReplicationConsistencyMarkersImpl::clearAppliedThrough(OperationContext* opCtx,
const Timestamp& writeTimestamp) {
- LOG(3) << "clearing appliedThrough at: " << writeTimestamp.toString();
+ LOGV2_DEBUG(21292,
+ 3,
+ "clearing appliedThrough at: {writeTimestamp}",
+ "writeTimestamp"_attr = writeTimestamp.toString());
TimestampedBSONObj update;
update.timestamp = writeTimestamp;
@@ -281,11 +302,15 @@ OpTime ReplicationConsistencyMarkersImpl::getAppliedThrough(OperationContext* op
auto appliedThrough = doc->getAppliedThrough();
if (!appliedThrough) {
- LOG(3) << "No appliedThrough OpTime set, returning empty appliedThrough OpTime.";
+ LOGV2_DEBUG(
+ 21293, 3, "No appliedThrough OpTime set, returning empty appliedThrough OpTime.");
return {};
}
- LOG(3) << "returning appliedThrough: " << appliedThrough->toString() << "("
- << appliedThrough->toBSON() << ")";
+ LOGV2_DEBUG(21294,
+ 3,
+ "returning appliedThrough: {appliedThrough}({appliedThrough2})",
+ "appliedThrough"_attr = appliedThrough->toString(),
+ "appliedThrough2"_attr = appliedThrough->toBSON());
return appliedThrough.get();
}
@@ -313,8 +338,11 @@ ReplicationConsistencyMarkersImpl::_getOplogTruncateAfterPointDocument(
void ReplicationConsistencyMarkersImpl::ensureFastCountOnOplogTruncateAfterPoint(
OperationContext* opCtx) {
- LOG(3) << "Updating cached fast-count on collection " << _oplogTruncateAfterPointNss
- << " in case an unclean shutdown caused it to become incorrect.";
+ LOGV2_DEBUG(21295,
+ 3,
+ "Updating cached fast-count on collection {oplogTruncateAfterPointNss} in case an "
+ "unclean shutdown caused it to become incorrect.",
+ "oplogTruncateAfterPointNss"_attr = _oplogTruncateAfterPointNss);
auto result = _storageInterface->findSingleton(opCtx, _oplogTruncateAfterPointNss);
@@ -354,7 +382,10 @@ void ReplicationConsistencyMarkersImpl::_upsertOplogTruncateAfterPointDocument(
void ReplicationConsistencyMarkersImpl::setOplogTruncateAfterPoint(OperationContext* opCtx,
const Timestamp& timestamp) {
- LOG(3) << "setting oplog truncate after point to: " << timestamp.toBSON();
+ LOGV2_DEBUG(21296,
+ 3,
+ "setting oplog truncate after point to: {timestamp}",
+ "timestamp"_attr = timestamp.toBSON());
_upsertOplogTruncateAfterPointDocument(
opCtx,
BSON("$set" << BSON(OplogTruncateAfterPointDocument::kOplogTruncateAfterPointFieldName
@@ -365,13 +396,14 @@ Timestamp ReplicationConsistencyMarkersImpl::getOplogTruncateAfterPoint(
OperationContext* opCtx) const {
auto doc = _getOplogTruncateAfterPointDocument(opCtx);
if (!doc) {
- LOG(3) << "Returning empty oplog truncate after point since document did not exist";
+ LOGV2_DEBUG(
+ 21297, 3, "Returning empty oplog truncate after point since document did not exist");
return {};
}
Timestamp out = doc->getOplogTruncateAfterPoint();
- LOG(3) << "returning oplog truncate after point: " << out;
+ LOGV2_DEBUG(21298, 3, "returning oplog truncate after point: {out}", "out"_attr = out);
return out;
}
View Lorry Controller Status