summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorFrederic Vitzikam <frederic.vitzikam@mongodb.com>2022-04-13 17:59:18 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-04-13 18:56:22 +0000
commit22a3d06c6f1569257dd17d7feb69c98d76de8557 (patch)
tree47071df673ba3076c9a2fcfd2c085b0230b2ad8d
parent0cbab484cd11c36403e6fc330bfe2e89bc9bd3c9 (diff)
downloadmongo-22a3d06c6f1569257dd17d7feb69c98d76de8557.tar.gz
SERVER-65246 log for waitInHello only if the fail point is set
-rw-r--r--src/mongo/s/commands/cluster_hello_cmd.cpp15
1 files changed, 9 insertions, 6 deletions
diff --git a/src/mongo/s/commands/cluster_hello_cmd.cpp b/src/mongo/s/commands/cluster_hello_cmd.cpp
index 062dc90a32f..5600a29661d 100644
--- a/src/mongo/s/commands/cluster_hello_cmd.cpp
+++ b/src/mongo/s/commands/cluster_hello_cmd.cpp
@@ -120,12 +120,15 @@ public:
const bool apiStrict = APIParameters::get(opCtx).getAPIStrict().value_or(false);
auto cmd = HelloCommand::parse({"hello", apiStrict}, cmdObj);
- LOGV2(6524600,
- "Fail point blocks Hello response until removed",
- "cmd"_attr = cmdObj,
- "client"_attr = opCtx->getClient()->clientAddress(true),
- "desc"_attr = opCtx->getClient()->desc());
- waitInHello.pauseWhileSet(opCtx);
+ waitInHello.execute([&](const BSONObj&) {
+ LOGV2(6524600,
+ "Fail point blocks Hello response until removed",
+ "cmd"_attr = cmdObj,
+ "client"_attr = opCtx->getClient()->clientAddress(true),
+ "desc"_attr = opCtx->getClient()->desc());
+
+ waitInHello.pauseWhileSet(opCtx);
+ });
// "hello" is exempt from error code rewrites.
rpc::RewriteStateChangeErrors::setEnabled(opCtx, false);