aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorTanvi Jagtap <139093547+tanvi-jagtap@users.noreply.github.com>2024-05-11 00:53:18 -0700
committerCopybara-Service <copybara-worker@google.com>2024-05-11 00:56:12 -0700
commit989268253ee500c72848645dd5233653e0a635eb (patch)
tree46727860cacb30cd651c2ab820b7315118e7064b
parente5cd63f971ffbeef9afc6c6efbea85f10dd80477 (diff)
downloadgrpc-grpc-upstream-master.tar.gz
[grpc][Gpr_To_Absl_Logging] Migrating from gpr to absl logging - gpr_log (#36580)upstream-master
[grpc][Gpr_To_Absl_Logging] Migrating from gpr to absl logging - gpr_log In this CL we are migrating from gRPCs own gpr logging mechanism to absl logging mechanism. The intention is to deprecate gpr_log in the future. We have the following mapping 1. gpr_log(GPR_INFO,...) -> LOG(INFO) 2. gpr_log(GPR_ERROR,...) -> LOG(ERROR) 3. gpr_log(GPR_DEBUG,...) -> VLOG(2) Reviewers need to check : 1. If the above mapping is correct. 2. The content of the log is as before. gpr_log format strings did not use string_view or std::string . absl LOG accepts these. So there will be some elimination of string_view and std::string related conversions. This is expected. `#define GPR_INFO __FILE__, __LINE__, GPR_LOG_SEVERITY_INFO` Which means passing explicit parameters to gpr_info will over-ride the file name and line number of the call site. The right replacement API for this is `LOG(INFO).AtLocation(absl::string_view file, int line) << ... ` Closes #36580 COPYBARA_INTEGRATE_REVIEW=https://github.com/grpc/grpc/pull/36580 from tanvi-jagtap:large_seq_state_tjagtap 8f6dd756c62434b13d9f0a90150934a3677c4e81 PiperOrigin-RevId: 632721079
-rw-r--r--src/core/lib/promise/detail/seq_state.h711
1 files changed, 342 insertions, 369 deletions
diff --git a/src/core/lib/promise/detail/seq_state.h b/src/core/lib/promise/detail/seq_state.h
index 3e69e60b74..841cd6cb04 100644
--- a/src/core/lib/promise/detail/seq_state.h
+++ b/src/core/lib/promise/detail/seq_state.h
@@ -23,6 +23,7 @@
#include "absl/base/attributes.h"
#include "absl/log/check.h"
+#include "absl/log/log.h"
#include "absl/strings/str_cat.h"
#include <grpc/support/log.h>
@@ -144,22 +145,21 @@ struct SeqState<Traits, P, F0> {
switch (state) {
case State::kState0: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 1/2", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 1/2";
}
auto result = prior.current_promise();
PromiseResult0* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 1/2 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits0::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits0::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 1/2 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits0::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits0::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits0::IsOk(*p)) {
@@ -177,14 +177,14 @@ struct SeqState<Traits, P, F0> {
default:
case State::kState1: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 2/2", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 2/2";
}
auto result = current_promise();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 2/2 gets %s", this,
- result.ready() ? "ready" : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 2/2 gets "
+ << (result.ready() ? "ready" : "pending");
}
auto* p = result.value_if_ready();
if (p == nullptr) return Pending{};
@@ -287,22 +287,21 @@ struct SeqState<Traits, P, F0, F1> {
switch (state) {
case State::kState0: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 1/3", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 1/3";
}
auto result = prior.prior.current_promise();
PromiseResult0* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 1/3 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits0::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits0::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 1/3 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits0::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits0::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits0::IsOk(*p)) {
@@ -319,22 +318,21 @@ struct SeqState<Traits, P, F0, F1> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState1: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 2/3", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 2/3";
}
auto result = prior.current_promise();
PromiseResult1* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 2/3 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits1::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits1::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 2/3 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits1::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits1::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits1::IsOk(*p)) {
@@ -352,14 +350,14 @@ struct SeqState<Traits, P, F0, F1> {
default:
case State::kState2: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 3/3", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 3/3";
}
auto result = current_promise();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 3/3 gets %s", this,
- result.ready() ? "ready" : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 3/3 gets "
+ << (result.ready() ? "ready" : "pending");
}
auto* p = result.value_if_ready();
if (p == nullptr) return Pending{};
@@ -489,22 +487,21 @@ struct SeqState<Traits, P, F0, F1, F2> {
switch (state) {
case State::kState0: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 1/4", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 1/4";
}
auto result = prior.prior.prior.current_promise();
PromiseResult0* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 1/4 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits0::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits0::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 1/4 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits0::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits0::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits0::IsOk(*p)) {
@@ -521,22 +518,21 @@ struct SeqState<Traits, P, F0, F1, F2> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState1: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 2/4", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 2/4";
}
auto result = prior.prior.current_promise();
PromiseResult1* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 2/4 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits1::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits1::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 2/4 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits1::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits1::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits1::IsOk(*p)) {
@@ -553,22 +549,21 @@ struct SeqState<Traits, P, F0, F1, F2> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState2: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 3/4", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 3/4";
}
auto result = prior.current_promise();
PromiseResult2* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 3/4 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits2::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits2::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 3/4 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits2::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits2::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits2::IsOk(*p)) {
@@ -586,14 +581,14 @@ struct SeqState<Traits, P, F0, F1, F2> {
default:
case State::kState3: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 4/4", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 4/4";
}
auto result = current_promise();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 4/4 gets %s", this,
- result.ready() ? "ready" : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 4/4 gets "
+ << (result.ready() ? "ready" : "pending");
}
auto* p = result.value_if_ready();
if (p == nullptr) return Pending{};
@@ -751,22 +746,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3> {
switch (state) {
case State::kState0: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 1/5", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 1/5";
}
auto result = prior.prior.prior.prior.current_promise();
PromiseResult0* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 1/5 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits0::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits0::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 1/5 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits0::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits0::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits0::IsOk(*p)) {
@@ -783,22 +777,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState1: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 2/5", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 2/5";
}
auto result = prior.prior.prior.current_promise();
PromiseResult1* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 2/5 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits1::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits1::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 2/5 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits1::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits1::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits1::IsOk(*p)) {
@@ -815,22 +808,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState2: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 3/5", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 3/5";
}
auto result = prior.prior.current_promise();
PromiseResult2* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 3/5 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits2::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits2::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 3/5 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits2::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits2::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits2::IsOk(*p)) {
@@ -847,22 +839,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState3: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 4/5", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 4/5";
}
auto result = prior.current_promise();
PromiseResult3* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 4/5 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits3::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits3::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 4/5 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits3::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits3::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits3::IsOk(*p)) {
@@ -880,14 +871,14 @@ struct SeqState<Traits, P, F0, F1, F2, F3> {
default:
case State::kState4: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 5/5", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 5/5";
}
auto result = current_promise();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 5/5 gets %s", this,
- result.ready() ? "ready" : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 5/5 gets "
+ << (result.ready() ? "ready" : "pending");
}
auto* p = result.value_if_ready();
if (p == nullptr) return Pending{};
@@ -1082,22 +1073,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4> {
switch (state) {
case State::kState0: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 1/6", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 1/6";
}
auto result = prior.prior.prior.prior.prior.current_promise();
PromiseResult0* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 1/6 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits0::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits0::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 1/6 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits0::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits0::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits0::IsOk(*p)) {
@@ -1115,22 +1105,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState1: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 2/6", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 2/6";
}
auto result = prior.prior.prior.prior.current_promise();
PromiseResult1* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 2/6 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits1::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits1::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 2/6 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits1::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits1::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits1::IsOk(*p)) {
@@ -1147,22 +1136,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState2: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 3/6", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 3/6";
}
auto result = prior.prior.prior.current_promise();
PromiseResult2* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 3/6 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits2::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits2::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 3/6 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits2::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits2::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits2::IsOk(*p)) {
@@ -1179,22 +1167,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState3: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 4/6", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 4/6";
}
auto result = prior.prior.current_promise();
PromiseResult3* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 4/6 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits3::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits3::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 4/6 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits3::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits3::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits3::IsOk(*p)) {
@@ -1211,22 +1198,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState4: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 5/6", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 5/6";
}
auto result = prior.current_promise();
PromiseResult4* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 5/6 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits4::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits4::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 5/6 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits4::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits4::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits4::IsOk(*p)) {
@@ -1249,9 +1235,9 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4> {
}
auto result = current_promise();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 6/6 gets %s", this,
- result.ready() ? "ready" : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 6/6 gets "
+ << (result.ready() ? "ready" : "pending");
}
auto* p = result.value_if_ready();
if (p == nullptr) return Pending{};
@@ -1478,22 +1464,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5> {
switch (state) {
case State::kState0: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 1/7", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 1/7";
}
auto result = prior.prior.prior.prior.prior.prior.current_promise();
PromiseResult0* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 1/7 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits0::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits0::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 1/7 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits0::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits0::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits0::IsOk(*p)) {
@@ -1511,22 +1496,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState1: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 2/7", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 2/7";
}
auto result = prior.prior.prior.prior.prior.current_promise();
PromiseResult1* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 2/7 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits1::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits1::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 2/7 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits1::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits1::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits1::IsOk(*p)) {
@@ -1544,22 +1528,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState2: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 3/7", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 3/7";
}
auto result = prior.prior.prior.prior.current_promise();
PromiseResult2* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 3/7 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits2::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits2::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 3/7 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits2::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits2::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits2::IsOk(*p)) {
@@ -1576,22 +1559,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState3: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 4/7", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 4/7";
}
auto result = prior.prior.prior.current_promise();
PromiseResult3* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 4/7 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits3::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits3::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 4/7 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits3::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits3::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits3::IsOk(*p)) {
@@ -1608,22 +1590,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState4: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 5/7", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 5/7";
}
auto result = prior.prior.current_promise();
PromiseResult4* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 5/7 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits4::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits4::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 5/7 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits4::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits4::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits4::IsOk(*p)) {
@@ -1640,22 +1621,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState5: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 6/7", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 6/7";
}
auto result = prior.current_promise();
PromiseResult5* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 6/7 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits5::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits5::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 6/7 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits5::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits5::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits5::IsOk(*p)) {
@@ -1673,14 +1653,14 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5> {
default:
case State::kState6: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 7/7", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 7/7";
}
auto result = current_promise();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 7/7 gets %s", this,
- result.ready() ? "ready" : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 7/7 gets "
+ << (result.ready() ? "ready" : "pending");
}
auto* p = result.value_if_ready();
if (p == nullptr) return Pending{};
@@ -1940,23 +1920,22 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5, F6> {
switch (state) {
case State::kState0: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 1/8", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 1/8";
}
auto result =
prior.prior.prior.prior.prior.prior.prior.current_promise();
PromiseResult0* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 1/8 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits0::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits0::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 1/8 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits0::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits0::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits0::IsOk(*p)) {
@@ -1975,22 +1954,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5, F6> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState1: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 2/8", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 2/8";
}
auto result = prior.prior.prior.prior.prior.prior.current_promise();
PromiseResult1* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 2/8 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits1::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits1::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 2/8 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits1::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits1::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits1::IsOk(*p)) {
@@ -2008,22 +1986,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5, F6> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState2: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 3/8", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 3/8";
}
auto result = prior.prior.prior.prior.prior.current_promise();
PromiseResult2* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 3/8 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits2::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits2::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 3/8 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits2::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits2::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits2::IsOk(*p)) {
@@ -2041,22 +2018,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5, F6> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState3: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 4/8", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 4/8";
}
auto result = prior.prior.prior.prior.current_promise();
PromiseResult3* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 4/8 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits3::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits3::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 4/8 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits3::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits3::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits3::IsOk(*p)) {
@@ -2073,22 +2049,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5, F6> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState4: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 5/8", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 5/8";
}
auto result = prior.prior.prior.current_promise();
PromiseResult4* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 5/8 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits4::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits4::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 5/8 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits4::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits4::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits4::IsOk(*p)) {
@@ -2105,22 +2080,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5, F6> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState5: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 6/8", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 6/8";
}
auto result = prior.prior.current_promise();
PromiseResult5* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 6/8 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits5::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits5::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 6/8 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits5::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits5::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits5::IsOk(*p)) {
@@ -2137,22 +2111,21 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5, F6> {
ABSL_FALLTHROUGH_INTENDED;
case State::kState6: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 7/8", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 7/8";
}
auto result = prior.current_promise();
PromiseResult6* p = result.value_if_ready();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(
- whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 7/8 gets %s", this,
- p != nullptr
- ? (PromiseResultTraits6::IsOk(*p)
- ? "ready"
- : absl::StrCat("early-error:",
- PromiseResultTraits6::ErrorString(*p))
- .c_str())
- : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 7/8 gets "
+ << (p != nullptr
+ ? (PromiseResultTraits6::IsOk(*p)
+ ? "ready"
+ : absl::StrCat(
+ "early-error:",
+ PromiseResultTraits6::ErrorString(*p)))
+ : "pending");
}
if (p == nullptr) return Pending{};
if (!PromiseResultTraits6::IsOk(*p)) {
@@ -2170,14 +2143,14 @@ struct SeqState<Traits, P, F0, F1, F2, F3, F4, F5, F6> {
default:
case State::kState7: {
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: begin poll step 8/8", this);
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: begin poll step 8/8";
}
auto result = current_promise();
if (grpc_trace_promise_primitives.enabled()) {
- gpr_log(whence.file(), whence.line(), GPR_LOG_SEVERITY_INFO,
- "seq[%p]: poll step 8/8 gets %s", this,
- result.ready() ? "ready" : "pending");
+ LOG(INFO).AtLocation(whence.file(), whence.line())
+ << "seq[" << this << "]: poll step 8/8 gets "
+ << (result.ready() ? "ready" : "pending");
}
auto* p = result.value_if_ready();
if (p == nullptr) return Pending{};