[export] [grpc][Gpr_To_Absl_Logging] Migrating from gpr to absl loggi…

…ng - 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.

----
DO NOT SUBMIT. This PR is for testing purposes only. [cl/633802449](http://cl/633802449)

PiperOrigin-RevId: 633802449

src/core/ext/transport/binder/client/channel_create.cc

@@ -35,6 +35,7 @@
 #ifdef GPR_SUPPORT_BINDER_TRANSPORT
 
 #include "absl/log/check.h"
+#include "absl/log/log.h"
 #include "absl/memory/memory.h"
 #include "absl/strings/substitute.h"
 #include "absl/time/clock.h"
@@ -111,7 +112,7 @@ std::shared_ptr<grpc::Channel> CreateCustomBinderChannel(
   std::string connection_id =
       grpc_binder::GetConnectionIdGenerator()->Generate(uri);
 
-  gpr_log(GPR_ERROR, "connection id is %s", connection_id.c_str());
+  LOG(ERROR) << "connection id is " << connection_id;
 
   // After invoking this Java method, Java code will put endpoint binder into
   // `EndpointBinderPool` after the connection succeeds

src/core/ext/transport/binder/client/endpoint_binder_pool.cc

@@ -15,6 +15,7 @@
 #include "src/core/ext/transport/binder/client/endpoint_binder_pool.h"
 
 #include "absl/log/check.h"
+#include "absl/log/log.h"
 
 #include <grpc/support/port_platform.h>
 
@@ -36,11 +37,11 @@ Java_io_grpc_binder_cpp_GrpcBinderConnection_notifyConnected__Ljava_lang_String_
     JNIEnv* jni_env, jobject, jstring conn_id_jstring, jobject ibinder) {
   jboolean isCopy;
   const char* conn_id = jni_env->GetStringUTFChars(conn_id_jstring, &isCopy);
-  gpr_log(GPR_INFO, "%s invoked with conn_id = %s", __func__, conn_id);
+  LOG(INFO) << __func__ << " invoked with conn_id = " << conn_id;
   CHECK_NE(ibinder, nullptr);
   grpc_binder::ndk_util::SpAIBinder aibinder =
       grpc_binder::FromJavaBinder(jni_env, ibinder);
-  gpr_log(GPR_INFO, "%s got aibinder = %p", __func__, aibinder.get());
+  LOG(INFO) << __func__ << " got aibinder = " << aibinder.get();
   auto b = std::make_unique<grpc_binder::BinderAndroid>(aibinder);
   CHECK(b != nullptr);
   grpc_binder::GetEndpointBinderPool()->AddEndpointBinder(conn_id,
@@ -58,7 +59,7 @@ namespace grpc_binder {
 void EndpointBinderPool::GetEndpointBinder(
     std::string conn_id,
     std::function<void(std::unique_ptr<grpc_binder::Binder>)> cb) {
-  gpr_log(GPR_INFO, "EndpointBinder requested. conn_id = %s", conn_id.c_str());
+  LOG(INFO) << "EndpointBinder requested. conn_id = " << conn_id.c_str();
   std::unique_ptr<grpc_binder::Binder> b;
   {
     grpc_core::MutexLock l(&m_);
@@ -83,7 +84,7 @@ void EndpointBinderPool::GetEndpointBinder(
 
 void EndpointBinderPool::AddEndpointBinder(
     std::string conn_id, std::unique_ptr<grpc_binder::Binder> b) {
-  gpr_log(GPR_INFO, "EndpointBinder added. conn_id = %s", conn_id.c_str());
+  LOG(INFO) << "EndpointBinder added. conn_id = " << conn_id.c_str();
   CHECK(b != nullptr);
   // cb will be set in the following block if there is a pending callback
   std::function<void(std::unique_ptr<grpc_binder::Binder>)> cb = nullptr;

src/core/ext/transport/binder/client/jni_utils.cc

@@ -15,6 +15,7 @@
 #include "src/core/ext/transport/binder/client/jni_utils.h"
 
 #include "absl/log/check.h"
+#include "absl/log/log.h" // IWYU pragma: keep
 
 #include <grpc/support/port_platform.h>
 
@@ -83,7 +84,7 @@ void TryEstablishConnection(JNIEnv* env, jobject application,
 
   jmethodID mid = env->GetStaticMethodID(cl, method.c_str(), type.c_str());
   if (mid == nullptr) {
-    gpr_log(GPR_ERROR, "No method id %s", method.c_str());
+    LOG(ERROR) << "No method id " << method;
   }
 
   env->CallStaticVoidMethod(cl, mid, application,
@@ -107,7 +108,7 @@ void TryEstablishConnectionWithUri(JNIEnv* env, jobject application,
 
   jmethodID mid = env->GetStaticMethodID(cl, method.c_str(), type.c_str());
   if (mid == nullptr) {
-    gpr_log(GPR_ERROR, "No method id %s", method.c_str());
+    LOG(ERROR) << "No method id " << method;
   }
 
   env->CallStaticVoidMethod(cl, mid, application,
@@ -126,7 +127,7 @@ bool IsSignatureMatch(JNIEnv* env, jobject context, int uid1, int uid2) {
 
   jmethodID mid = env->GetStaticMethodID(cl, method.c_str(), type.c_str());
   if (mid == nullptr) {
-    gpr_log(GPR_ERROR, "No method id %s", method.c_str());
+    LOG(ERROR) << "No method id " << method;
   }
 
   jboolean result = env->CallStaticBooleanMethod(cl, mid, context, uid1, uid2);

src/core/ext/transport/binder/server/binder_server.cc

@@ -23,6 +23,7 @@
 #include <utility>
 
 #include "absl/log/check.h"
+#include "absl/log/log.h"
 #include "absl/memory/memory.h"
 
 #include <grpc/grpc.h>
@@ -54,8 +55,8 @@ Java_io_grpc_binder_cpp_GrpcCppServerBuilder_GetEndpointBinderInternal__Ljava_la
     ai_binder = static_cast<grpc_binder::ndk_util::AIBinder*>(
         grpc_get_endpoint_binder(std::string(conn_id)));
     if (ai_binder == nullptr) {
-      gpr_log(GPR_ERROR, "Cannot find endpoint binder with connection id = %s",
-              conn_id);
+      LOG(ERROR) << "Cannot find endpoint binder with connection id = "
+                 << conn_id;
     }
     if (isCopy == JNI_TRUE) {
       jni_env->ReleaseStringUTFChars(conn_id_jstring, conn_id);
@@ -180,7 +181,7 @@ class BinderServerListener : public Server::ListenerInterface {
       return absl::InvalidArgumentError("Not a SETUP_TRANSPORT request");
     }
 
-    gpr_log(GPR_INFO, "BinderServerListener calling uid = %d", uid);
+    LOG(INFO) << "BinderServerListener calling uid = " << uid;
     if (!security_policy_->IsAuthorized(uid)) {
       // TODO(mingcl): For now we just ignore this unauthorized
       // SETUP_TRANSPORT transaction and ghost the client. Check if we should
@@ -196,7 +197,7 @@ class BinderServerListener : public Server::ListenerInterface {
     if (!status.ok()) {
       return status;
     }
-    gpr_log(GPR_INFO, "BinderTransport client protocol version = %d", version);
+    LOG(INFO) << "BinderTransport client protocol version = " << version;
     // TODO(mingcl): Make sure we only give client a version that is not newer
     // than the version they specify. For now, we always tell client that we
     // only support version=1.

src/core/ext/transport/binder/transport/binder_transport.cc

@@ -297,7 +297,7 @@ static void recv_trailing_metadata_locked(void* arg,
         // Append status to metadata
         // TODO(b/192208695): See if we can avoid to manually put status
         // code into the header
-        gpr_log(GPR_INFO, "status = %d", args->status);
+        LOG(INFO) << "status = " << args->status;
         stream->recv_trailing_metadata->Set(
             grpc_core::GrpcStatusMetadata(),
             static_cast<grpc_status_code>(args->status));
@@ -350,7 +350,7 @@ class MetadataEncoder {
   }
 
   void Encode(grpc_core::GrpcStatusMetadata, grpc_status_code status) {
-    gpr_log(GPR_INFO, "send trailing metadata status = %d", status);
+    LOG(INFO) << "send trailing metadata status = " << status;
     tx_->SetStatus(status);
   }
 
@@ -395,7 +395,7 @@ static void perform_stream_op_locked(void* stream_op,
     CHECK(!op->send_initial_metadata && !op->send_message &&
           !op->send_trailing_metadata && !op->recv_initial_metadata &&
           !op->recv_message && !op->recv_trailing_metadata);
-    gpr_log(GPR_INFO, "cancel_stream is_client = %d", stream->is_client);
+    LOG(INFO) << "cancel_stream is_client = " << stream->is_client;
     if (!stream->is_client) {
       // Send trailing metadata to inform the other end about the cancellation,
       // regardless if we'd already done that or not.

src/core/ext/transport/binder/utils/ndk_binder.cc

@@ -23,6 +23,7 @@
 #include <dlfcn.h>
 
 #include "absl/log/check.h"
+#include "absl/log/log.h"
 
 #include <grpc/support/log.h>
 
@@ -60,10 +61,10 @@ void SetJvm(JNIEnv* env) {
   JavaVM* jvm = nullptr;
   jint error = env->GetJavaVM(&jvm);
   if (error != JNI_OK) {
-    gpr_log(GPR_ERROR, "Failed to get JVM");
+    LOG(ERROR) << "Failed to get JVM";
   }
   g_jvm = jvm;
-  gpr_log(GPR_INFO, "JVM cached");
+  LOG(INFO) << "JVM cached";
 }
 
 // `SetJvm` need to be called in the process before `AttachJvm`. This is always
@@ -77,14 +78,14 @@ bool AttachJvm() {
   // Note: The following code would be run at most once per thread.
   grpc_core::MutexLock lock(&g_jvm_mu);
   if (g_jvm == nullptr) {
-    gpr_log(GPR_ERROR, "JVM not cached yet");
+    LOG(ERROR) << "JVM not cached yet";
     return false;
   }
   JNIEnv* env_unused;
   // Note that attach a thread that is already attached is a no-op, so it is
   // fine to call this again if the thread has already been attached by other.
   g_jvm->AttachCurrentThread(&env_unused, /* thr_args= */ nullptr);
-  gpr_log(GPR_INFO, "JVM attached successfully");
+  LOG(INFO) << "JVM attached successfully";
   g_is_jvm_attached = true;
   return true;
 }
@@ -151,7 +152,7 @@ binder_status_t AIBinder_transact(AIBinder* binder, transaction_code_t code,
                                   AParcel** in, AParcel** out,
                                   binder_flags_t flags) {
   if (!AttachJvm()) {
-    gpr_log(GPR_ERROR, "failed to attach JVM. AIBinder_transact might fail.");
+    LOG(ERROR) << "failed to attach JVM. AIBinder_transact might fail.";
   }
   FORWARD(AIBinder_transact)(binder, code, in, out, flags);
 }

src/core/ext/transport/binder/utils/transport_stream_receiver_impl.cc

@@ -23,8 +23,7 @@
 #include <utility>
 
 #include "absl/log/check.h"
-
-#include <grpc/support/log.h>
+#include "absl/log/log.h"
 
 #include "src/core/lib/gprpp/crash.h"
 
@@ -36,7 +35,7 @@ const absl::string_view
 
 void TransportStreamReceiverImpl::RegisterRecvInitialMetadata(
     StreamIdentifier id, InitialMetadataCallbackType cb) {
-  gpr_log(GPR_INFO, "%s id = %d is_client = %d", __func__, id, is_client_);
+  LOG(INFO) << __func__ << " id = " << id << " is_client = " << is_client_;
   absl::StatusOr<Metadata> initial_metadata{};
   {
     grpc_core::MutexLock l(&m_);
@@ -64,7 +63,7 @@ void TransportStreamReceiverImpl::RegisterRecvInitialMetadata(
 
 void TransportStreamReceiverImpl::RegisterRecvMessage(
     StreamIdentifier id, MessageDataCallbackType cb) {
-  gpr_log(GPR_INFO, "%s id = %d is_client = %d", __func__, id, is_client_);
+  LOG(INFO) << __func__ << " id = " << id << " is_client = " << is_client_;
   absl::StatusOr<std::string> message{};
   {
     grpc_core::MutexLock l(&m_);
@@ -98,7 +97,7 @@ void TransportStreamReceiverImpl::RegisterRecvMessage(
 
 void TransportStreamReceiverImpl::RegisterRecvTrailingMetadata(
     StreamIdentifier id, TrailingMetadataCallbackType cb) {
-  gpr_log(GPR_INFO, "%s id = %d is_client = %d", __func__, id, is_client_);
+  LOG(INFO) << __func__ << " id = " << id << " is_client = " << is_client_;
   std::pair<absl::StatusOr<Metadata>, int> trailing_metadata{};
   {
     grpc_core::MutexLock l(&m_);
@@ -122,7 +121,7 @@ void TransportStreamReceiverImpl::RegisterRecvTrailingMetadata(
 
 void TransportStreamReceiverImpl::NotifyRecvInitialMetadata(
     StreamIdentifier id, absl::StatusOr<Metadata> initial_metadata) {
-  gpr_log(GPR_INFO, "%s id = %d is_client = %d", __func__, id, is_client_);
+  LOG(INFO) << __func__ << " id = " << id << " is_client = " << is_client_;
   if (!is_client_ && accept_stream_callback_ && initial_metadata.ok()) {
     accept_stream_callback_();
   }
@@ -143,7 +142,7 @@ void TransportStreamReceiverImpl::NotifyRecvInitialMetadata(
 
 void TransportStreamReceiverImpl::NotifyRecvMessage(
     StreamIdentifier id, absl::StatusOr<std::string> message) {
-  gpr_log(GPR_INFO, "%s id = %d is_client = %d", __func__, id, is_client_);
+  LOG(INFO) << __func__ << " id = " << id << " is_client = " << is_client_;
   MessageDataCallbackType cb;
   {
     grpc_core::MutexLock l(&m_);
@@ -166,7 +165,7 @@ void TransportStreamReceiverImpl::NotifyRecvTrailingMetadata(
   // assumes in-order commitments of transactions and that trailing metadata is
   // parsed after message data, we can safely cancel all upcoming callbacks of
   // recv_message.
-  gpr_log(GPR_INFO, "%s id = %d is_client = %d", __func__, id, is_client_);
+  LOG(INFO) << __func__ << " id = " << id << " is_client = " << is_client_;
   OnRecvTrailingMetadata(id);
   TrailingMetadataCallbackType cb;
   {
@@ -233,7 +232,7 @@ void TransportStreamReceiverImpl::CancelTrailingMetadataCallback(
 }
 
 void TransportStreamReceiverImpl::OnRecvTrailingMetadata(StreamIdentifier id) {
-  gpr_log(GPR_INFO, "%s id = %d is_client = %d", __func__, id, is_client_);
+  LOG(INFO) << __func__ << " id = " << id << " is_client = " << is_client_;
   m_.Lock();
   trailing_metadata_recvd_.insert(id);
   m_.Unlock();
@@ -245,7 +244,7 @@ void TransportStreamReceiverImpl::OnRecvTrailingMetadata(StreamIdentifier id) {
 }
 
 void TransportStreamReceiverImpl::CancelStream(StreamIdentifier id) {
-  gpr_log(GPR_INFO, "%s id = %d is_client = %d", __func__, id, is_client_);
+  LOG(INFO) << __func__ << " id = " << id << " is_client = " << is_client_;
   CancelInitialMetadataCallback(id, absl::CancelledError("Stream cancelled"));
   CancelMessageCallback(id, absl::CancelledError("Stream cancelled"));
   CancelTrailingMetadataCallback(id, absl::CancelledError("Stream cancelled"));

src/core/ext/transport/binder/wire_format/binder_android.cc

@@ -21,6 +21,7 @@
 #include <map>
 
 #include "absl/log/check.h"
+#include "absl/log/log.h"
 #include "absl/memory/memory.h"
 #include "absl/strings/str_cat.h"
 
@@ -65,7 +66,7 @@ ndk_util::binder_status_t f_onTransact(ndk_util::AIBinder* binder,
                                        const ndk_util::AParcel* in,
                                        ndk_util::AParcel* /*out*/) {
   gpr_log(GPR_INFO, __func__);
-  gpr_log(GPR_INFO, "tx code = %u", code);
+  LOG(INFO) << "tx code = " << code;
 
   auto* user_data =
       static_cast<BinderUserData*>(ndk_util::AIBinder_getUserData(binder));
@@ -79,7 +80,7 @@ ndk_util::binder_status_t f_onTransact(ndk_util::AIBinder* binder,
   if (status.ok()) {
     return ndk_util::STATUS_OK;
   } else {
-    gpr_log(GPR_ERROR, "Callback failed: %s", status.ToString().c_str());
+    LOG(ERROR) << "Callback failed: " << status.ToString();
     return ndk_util::STATUS_UNKNOWN_ERROR;
   }
 }