[grpc][Gpr_To_Absl_Logging] Migrating from gpr to absl logging - gpr_log

pull/36939/head
tanvi-jagtap 5 months ago
parent 6650e34a2a
commit 2dc26fe18a
  1. 5
      src/core/client_channel/client_channel.cc
  2. 8
      src/core/client_channel/retry_filter_legacy_call_data.cc
  3. 9
      src/core/client_channel/subchannel.cc

@ -283,7 +283,8 @@ class ClientChannel::SubchannelWrapper::WatcherWrapper
}
}
} else {
LOG(ERROR) << "client_channel=" << subchannel_wrapper_->client_channel_
LOG(ERROR) << "client_channel="
<< subchannel_wrapper_->client_channel_.get()
<< ": Illegal keepalive throttling value "
<< std::string(keepalive_throttling.value());
}
@ -452,7 +453,7 @@ class ClientChannel::ClientChannelControlHelper
const char* extra = client_channel_->disconnect_error_.ok()
? ""
: " (ignoring -- channel shutting down)";
LOG(INFO) << "client_channel=" << client_channel_
LOG(INFO) << "client_channel=" << client_channel_.get()
<< ": update: state=" << ConnectivityStateName(state)
<< " status=(" << status << ") picker=" << picker.get()
<< extra;

@ -668,8 +668,8 @@ void RetryFilter::LegacyCallData::CallAttempt::OnPerAttemptRecvTimerLocked(
if (GRPC_TRACE_FLAG_ENABLED(retry)) {
LOG(INFO) << "chand=" << calld->chand_ << " calld=" << calld
<< " attempt=" << call_attempt
<< ": perAttemptRecvTimeout timer fired: "
<< "error=" << StatusToString(error)
<< ": perAttemptRecvTimeout timer fired: error="
<< StatusToString(error)
<< ", per_attempt_recv_timer_handle_.has_value()="
<< call_attempt->per_attempt_recv_timer_handle_.has_value();
}
@ -707,8 +707,8 @@ void RetryFilter::LegacyCallData::CallAttempt::
if (per_attempt_recv_timer_handle_.has_value()) {
if (GRPC_TRACE_FLAG_ENABLED(retry)) {
LOG(INFO) << "chand=" << calld_->chand_ << " calld=" << calld_
<< " attempt=" << this << ": cancelling "
<< "perAttemptRecvTimeout timer";
<< " attempt=" << this
<< ": cancelling perAttemptRecvTimeout timer";
}
if (calld_->chand_->event_engine()->Cancel(
*per_attempt_recv_timer_handle_)) {

@ -418,9 +418,9 @@ class Subchannel::ConnectedSubchannelStateWatcher final
new_state == GRPC_CHANNEL_SHUTDOWN) {
if (GRPC_TRACE_FLAG_ENABLED(subchannel)) {
LOG(INFO) << "subchannel " << c << " " << c->key_.ToString()
<< ": Connected subchannel " << c->connected_subchannel_
<< " reports " << ConnectivityStateName(new_state) << ": "
<< status;
<< ": Connected subchannel "
<< c->connected_subchannel_.get() << " reports "
<< ConnectivityStateName(new_state) << ": " << status;
}
c->connected_subchannel_.reset();
if (c->channelz_node() != nullptr) {
@ -875,7 +875,8 @@ bool Subchannel::PublishTransportLocked() {
// Publish.
if (GRPC_TRACE_FLAG_ENABLED(subchannel)) {
LOG(INFO) << "subchannel " << this << " " << key_.ToString()
<< ": new connected subchannel at " << connected_subchannel_;
<< ": new connected subchannel at "
<< connected_subchannel_.get();
}
if (channelz_node_ != nullptr) {
channelz_node_->SetChildSocket(std::move(socket_node));

Loading…
Cancel
Save