summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/base_cloner.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/base_cloner.cpp')
-rw-r--r--src/mongo/db/repl/base_cloner.cpp32
1 files changed, 16 insertions, 16 deletions
diff --git a/src/mongo/db/repl/base_cloner.cpp b/src/mongo/db/repl/base_cloner.cpp
index cbad2e60b11..fcfa04d746a 100644
--- a/src/mongo/db/repl/base_cloner.cpp
+++ b/src/mongo/db/repl/base_cloner.cpp
@@ -93,8 +93,8 @@ Status BaseCloner::run() {
if (!_sharedData->getInitialSyncStatus(lk).isOK()) {
LOGV2(21065,
"Failing data clone because initial sync failed outside data clone: "
- "{sharedData_getInitialSyncStatus_lk}",
- "sharedData_getInitialSyncStatus_lk"_attr = _sharedData->getInitialSyncStatus(lk));
+ "{status}",
+ "status"_attr = _sharedData->getInitialSyncStatus(lk));
}
return _sharedData->getInitialSyncStatus(lk);
}
@@ -119,8 +119,8 @@ void BaseCloner::pauseForFuzzer(BaseClonerStage* stage) {
// initial_sync_test_fixture_test.js, so if you change it here you will need to change
// it there.
LOGV2(21066,
- "Collection Cloner scheduled a remote command on the {describeForFuzzer_stage}",
- "describeForFuzzer_stage"_attr = describeForFuzzer(stage));
+ "Collection Cloner scheduled a remote command on the {stage}",
+ "stage"_attr = describeForFuzzer(stage));
LOGV2(21067, "initialSyncFuzzerSynchronizationPoint1 fail point enabled.");
initialSyncFuzzerSynchronizationPoint1.pauseWhileSet();
@@ -135,9 +135,9 @@ void BaseCloner::pauseForFuzzer(BaseClonerStage* stage) {
BaseCloner::AfterStageBehavior BaseCloner::runStage(BaseClonerStage* stage) {
LOGV2_DEBUG(21069,
1,
- "Cloner {getClonerName} running stage {stage_getName}",
- "getClonerName"_attr = getClonerName(),
- "stage_getName"_attr = stage->getName());
+ "Cloner {cloner} running stage {stage}",
+ "cloner"_attr = getClonerName(),
+ "stage"_attr = stage->getName());
pauseForFuzzer(stage);
auto isThisStageFailPoint = [this, stage](const BSONObj& data) {
return data["stage"].str() == stage->getName() && isMyFailPoint(data);
@@ -145,9 +145,9 @@ BaseCloner::AfterStageBehavior BaseCloner::runStage(BaseClonerStage* stage) {
hangBeforeClonerStage.executeIf(
[&](const BSONObj& data) {
LOGV2(21070,
- "Cloner {getClonerName} hanging before running stage {stage_getName}",
- "getClonerName"_attr = getClonerName(),
- "stage_getName"_attr = stage->getName());
+ "Cloner {cloner} hanging before running stage {stage}",
+ "cloner"_attr = getClonerName(),
+ "stage"_attr = stage->getName());
while (!mustExit() && hangBeforeClonerStage.shouldFail(isThisStageFailPoint)) {
sleepmillis(100);
}
@@ -157,9 +157,9 @@ BaseCloner::AfterStageBehavior BaseCloner::runStage(BaseClonerStage* stage) {
hangAfterClonerStage.executeIf(
[&](const BSONObj& data) {
LOGV2(21071,
- "Cloner {getClonerName} hanging after running stage {stage_getName}",
- "getClonerName"_attr = getClonerName(),
- "stage_getName"_attr = stage->getName());
+ "Cloner {cloner} hanging after running stage {stage}",
+ "cloner"_attr = getClonerName(),
+ "stage"_attr = stage->getName());
while (!mustExit() && hangAfterClonerStage.shouldFail(isThisStageFailPoint)) {
sleepmillis(100);
}
@@ -167,9 +167,9 @@ BaseCloner::AfterStageBehavior BaseCloner::runStage(BaseClonerStage* stage) {
isThisStageFailPoint);
LOGV2_DEBUG(21072,
1,
- "Cloner {getClonerName} finished running stage {stage_getName}",
- "getClonerName"_attr = getClonerName(),
- "stage_getName"_attr = stage->getName());
+ "Cloner {cloner} finished running stage {stage}",
+ "cloner"_attr = getClonerName(),
+ "stage"_attr = stage->getName());
return afterStageBehavior;
}