[grpc][Gpr_To_Absl_Logging] Deleting multiple instances of gpr_set_lo…

…g_function (grpc#36833) Deleting multiple instances of gpr_set_log_function . This function will be deleted soon. grpc/proposal#425 Closes grpc#36833 COPYBARA_INTEGRATE_REVIEW=grpc#36833 from tanvi-jagtap:remove_gpr_log_partial_code 17517ef PiperOrigin-RevId: 641268299
arvindbr8 · Jun 7, 2024 · 1dbfd4c · 1dbfd4c
1 parent bc6a1c6
commit 1dbfd4c
Show file tree

Hide file tree

Showing 28 changed files with 83 additions and 267 deletions.
diff --git a/CMakeLists.txt b/CMakeLists.txt
diff --git a/build_autogenerated.yaml b/build_autogenerated.yaml
diff --git a/grpc.def b/grpc.def
diff --git a/include/grpc/support/log.h b/include/grpc/support/log.h
@@ -69,6 +69,8 @@ GPRAPI void gpr_set_log_verbosity(gpr_log_severity min_severity_to_print);
 
 GPRAPI void gpr_log_verbosity_init(void);
 
+GPRAPI void gpr_disable_all_logs(void);
+
 /** Log overrides: applications can use this API to intercept logging calls
    and use their own implementations */
 
@@ -82,6 +84,7 @@ struct gpr_log_func_args {
 typedef struct gpr_log_func_args gpr_log_func_args;
 
 typedef void (*gpr_log_func)(gpr_log_func_args* args);
+
 GPRAPI void gpr_set_log_function(gpr_log_func func);
 
 GPRAPI void gpr_assertion_failed(const char* filename, int line,

diff --git a/src/core/util/log.cc b/src/core/util/log.cc
@@ -187,3 +187,8 @@ void gpr_log_verbosity_init() {
 void gpr_set_log_function(gpr_log_func f) {
   gpr_atm_no_barrier_store(&g_log_func, (gpr_atm)(f ? f : gpr_default_log));
 }
+
+void gpr_disable_all_logs() {
+  absl::SetMinLogLevel(absl::LogSeverityAtLeast::kInfinity);
+  absl::SetVLogLevel("*grpc*/*", -1);
+}
diff --git a/src/ruby/ext/grpc/rb_grpc_imports.generated.c b/src/ruby/ext/grpc/rb_grpc_imports.generated.c
diff --git a/src/ruby/ext/grpc/rb_grpc_imports.generated.h b/src/ruby/ext/grpc/rb_grpc_imports.generated.h
diff --git a/test/core/call/yodel/fuzzer_main.cc b/test/core/call/yodel/fuzzer_main.cc
@@ -33,7 +33,6 @@
 #include "test/core/test_util/proto_bit_gen.h"
 
 bool squelch = true;
-static void dont_log(gpr_log_func_args* /*args*/) {}
 
 DEFINE_PROTO_FUZZER(const transport_test_suite::Msg& msg) {
   static const grpc_core::NoDestruct<
@@ -43,7 +42,7 @@ DEFINE_PROTO_FUZZER(const transport_test_suite::Msg& msg) {
   const int test_id = msg.test_id() % tests->size();
 
   if (squelch && !grpc_core::GetEnv("GRPC_TRACE_FUZZER").has_value()) {
-    gpr_set_log_function(dont_log);
+    gpr_disable_all_logs();
   }
 
   grpc_core::ConfigVars::Overrides overrides =

diff --git a/test/core/end2end/end2end_test_fuzzer.cc b/test/core/end2end/end2end_test_fuzzer.cc
@@ -48,7 +48,6 @@ using ::grpc_event_engine::experimental::FuzzingEventEngine;
 using ::grpc_event_engine::experimental::GetDefaultEventEngine;
 
 bool squelch = true;
-static void dont_log(gpr_log_func_args* /*args*/) {}
 
 namespace grpc_core {
 
@@ -92,7 +91,7 @@ void RunEnd2endFuzzer(const core_end2end_test_fuzzer::Msg& msg) {
   const int test_id = msg.test_id() % tests.size();
 
   if (squelch && !GetEnv("GRPC_TRACE_FUZZER").has_value()) {
-    gpr_set_log_function(dont_log);
+    gpr_disable_all_logs();
   }
 
   // TODO(ctiller): make this per fixture?

diff --git a/test/core/end2end/fuzzers/api_fuzzer.cc b/test/core/end2end/fuzzers/api_fuzzer.cc
@@ -78,8 +78,6 @@
 bool squelch = true;
 bool leak_check = true;
 
-static void dont_log(gpr_log_func_args* /*args*/) {}
-
 ////////////////////////////////////////////////////////////////////////////////
 // dns resolution
 
@@ -506,7 +504,7 @@ using grpc_core::testing::ApiFuzzer;
 
 DEFINE_PROTO_FUZZER(const api_fuzzer::Msg& msg) {
   if (squelch && !grpc_core::GetEnv("GRPC_TRACE_FUZZER").has_value()) {
-    gpr_set_log_function(dont_log);
+    gpr_disable_all_logs();
   }
   grpc_core::ApplyFuzzConfigVars(msg.config_vars());
   grpc_core::TestOnlyReloadExperimentsFromConfigVariables();

diff --git a/test/core/end2end/fuzzers/client_fuzzer.cc b/test/core/end2end/fuzzers/client_fuzzer.cc
@@ -49,8 +49,6 @@ bool leak_check = true;
 
 static void discard_write(grpc_slice /*slice*/) {}
 
-static void dont_log(gpr_log_func_args* /*args*/) {}
-
 namespace grpc_core {
 namespace testing {
 
@@ -101,7 +99,7 @@ class ClientFuzzer final : public BasicFuzzer {
 
 DEFINE_PROTO_FUZZER(const fuzzer_input::Msg& msg) {
   if (squelch && !grpc_core::GetEnv("GRPC_TRACE_FUZZER").has_value()) {
-    gpr_set_log_function(dont_log);
+    gpr_disable_all_logs();
   }
   if (msg.network_input().size() != 1) return;
   grpc_core::ApplyFuzzConfigVars(msg.config_vars());

diff --git a/test/core/end2end/fuzzers/server_fuzzer.cc b/test/core/end2end/fuzzers/server_fuzzer.cc
@@ -35,8 +35,6 @@
 bool squelch = true;
 bool leak_check = true;
 
-static void dont_log(gpr_log_func_args* /*args*/) {}
-
 namespace grpc_core {
 namespace testing {
 
@@ -97,7 +95,7 @@ void RunServerFuzzer(
     absl::FunctionRef<void(grpc_server*, int, const ChannelArgs&)>
         server_setup) {
   if (squelch && !GetEnv("GRPC_TRACE_FUZZER").has_value()) {
-    gpr_set_log_function(dont_log);
+    gpr_disable_all_logs();
   }
   static const int once = []() {
     ForceEnableExperiment("event_engine_client", true);

diff --git a/test/core/ext/filters/event_engine_client_channel_resolver/resolver_fuzzer.cc b/test/core/ext/filters/event_engine_client_channel_resolver/resolver_fuzzer.cc
@@ -50,7 +50,6 @@
 #include "test/core/test_util/fuzzing_channel_args.h"
 
 bool squelch = true;
-static void dont_log(gpr_log_func_args* /*args*/) {}
 
 namespace {
 
@@ -254,7 +253,9 @@ grpc_core::ResolverArgs ConstructResolverArgs(
 }  // namespace
 
 DEFINE_PROTO_FUZZER(const event_engine_client_channel_resolver::Msg& msg) {
-  if (squelch) gpr_set_log_function(dont_log);
+  if (squelch) {
+    gpr_disable_all_logs();
+  }
   bool done_resolving = false;
   grpc_core::ApplyFuzzConfigVars(msg.config_vars());
   grpc_core::TestOnlyReloadExperimentsFromConfigVariables();

diff --git a/test/core/nanopb/fuzzer_response.cc b/test/core/nanopb/fuzzer_response.cc
@@ -25,12 +25,13 @@
 bool squelch = true;
 bool leak_check = true;
 
-static void dont_log(gpr_log_func_args* /*args*/) {}
-
 extern "C" int LLVMFuzzerTestOneInput(const uint8_t* /*data*/,
                                       size_t /*size*/) {
   grpc_init();
-  if (squelch) gpr_set_log_function(dont_log);
+  if (squelch) {
+    gpr_disable_all_logs();
+  }
+
   // TODO(veblush): Convert this to upb.
   //
   // grpc_slice slice = grpc_slice_from_copied_buffer((const char*)data, size);

diff --git a/test/core/nanopb/fuzzer_serverlist.cc b/test/core/nanopb/fuzzer_serverlist.cc
@@ -25,12 +25,13 @@
 bool squelch = true;
 bool leak_check = true;
 
-static void dont_log(gpr_log_func_args* /*args*/) {}
-
 extern "C" int LLVMFuzzerTestOneInput(const uint8_t* /*data*/,
                                       size_t /*size*/) {
   grpc_init();
-  if (squelch) gpr_set_log_function(dont_log);
+  if (squelch) {
+    gpr_disable_all_logs();
+  }
+
   // TODO(veblush): Convert this to upb.
   //
   // grpc_slice slice = grpc_slice_from_copied_buffer((const char*)data, size);

diff --git a/test/core/resource_quota/memory_quota_fuzzer.cc b/test/core/resource_quota/memory_quota_fuzzer.cc
@@ -187,10 +187,10 @@ class Fuzzer {
 }  // namespace testing
 }  // namespace grpc_core
 
-static void dont_log(gpr_log_func_args* /*args*/) {}
-
 DEFINE_PROTO_FUZZER(const memory_quota_fuzzer::Msg& msg) {
-  if (squelch) gpr_set_log_function(dont_log);
+  if (squelch) {
+    gpr_disable_all_logs();
+  }
   grpc_core::ApplyFuzzConfigVars(msg.config_vars());
   grpc_core::TestOnlyReloadExperimentsFromConfigVariables();
   gpr_log_verbosity_init();

diff --git a/test/core/security/alts_credentials_fuzzer.cc b/test/core/security/alts_credentials_fuzzer.cc
@@ -42,8 +42,6 @@ using grpc_core::testing::input_stream;
 bool squelch = true;
 bool leak_check = true;
 
-static void dont_log(gpr_log_func_args* /*args*/) {}
-
 // Add a random number of target service accounts to client options.
 static void read_target_service_accounts(
     input_stream* inp, grpc_alts_credentials_options* options) {
@@ -65,7 +63,7 @@ static void read_target_service_accounts(
 
 extern "C" int LLVMFuzzerTestOneInput(const uint8_t* data, size_t size) {
   if (squelch && !grpc_core::GetEnv("GRPC_TRACE_FUZZER").has_value()) {
-    gpr_set_log_function(dont_log);
+    gpr_disable_all_logs();
   }
   input_stream inp = {data, data + size};
   grpc_init();

diff --git a/test/core/security/ssl_server_fuzzer.cc b/test/core/security/ssl_server_fuzzer.cc
@@ -43,8 +43,6 @@ bool squelch = true;
 // Turning this on will fail the leak check.
 bool leak_check = false;
 
-static void dont_log(gpr_log_func_args* /*args*/) {}
-
 struct handshake_state {
   grpc_core::Notification done_signal;
 };
@@ -60,7 +58,9 @@ static void on_handshake_done(void* arg, grpc_error_handle error) {
 }
 
 extern "C" int LLVMFuzzerTestOneInput(const uint8_t* data, size_t size) {
-  if (squelch) gpr_set_log_function(dont_log);
+  if (squelch) {
+    gpr_disable_all_logs();
+  }
   grpc_init();
   {
     grpc_core::ExecCtx exec_ctx;

diff --git a/test/core/transport/binder/end2end/fuzzers/client_fuzzer.cc b/test/core/transport/binder/end2end/fuzzers/client_fuzzer.cc
@@ -35,10 +35,10 @@ bool leak_check = true;
 
 static void* tag(intptr_t t) { return reinterpret_cast<void*>(t); }
 
-static void dont_log(gpr_log_func_args*) {}
-
 DEFINE_PROTO_FUZZER(const binder_transport_fuzzer::Input& input) {
-  if (squelch) gpr_set_log_function(dont_log);
+  if (squelch) {
+    gpr_disable_all_logs();
+  }
   grpc_init();
   {
     // Copied and modified from grpc/test/core/end2end/fuzzers/client_fuzzer.cc

diff --git a/test/core/transport/binder/end2end/fuzzers/server_fuzzer.cc b/test/core/transport/binder/end2end/fuzzers/server_fuzzer.cc
@@ -30,10 +30,10 @@ bool leak_check = true;
 
 static void* tag(intptr_t t) { return reinterpret_cast<void*>(t); }
 
-static void dont_log(gpr_log_func_args* /*args*/) {}
-
 DEFINE_PROTO_FUZZER(const binder_transport_fuzzer::Input& input) {
-  if (squelch) gpr_set_log_function(dont_log);
+  if (squelch) {
+    gpr_disable_all_logs();
+  }
   grpc_init();
   {
     // Copied and modified from grpc/test/core/end2end/fuzzers/server_fuzzer.cc

diff --git a/test/core/transport/chttp2/hpack_parser_fuzzer_test.cc b/test/core/transport/chttp2/hpack_parser_fuzzer_test.cc
@@ -50,10 +50,10 @@
 bool squelch = true;
 bool leak_check = true;
 
-static void dont_log(gpr_log_func_args* /*args*/) {}
-
 DEFINE_PROTO_FUZZER(const hpack_parser_fuzzer::Msg& msg) {
-  if (squelch) gpr_set_log_function(dont_log);
+  if (squelch) {
+    gpr_disable_all_logs();
+  }
   grpc_core::ProtoBitGen proto_bit_src(msg.random_numbers());
   grpc_core::ApplyFuzzConfigVars(msg.config_vars());
   grpc_core::TestOnlyReloadExperimentsFromConfigVariables();

diff --git a/test/core/transport/chttp2/hpack_sync_fuzzer.cc b/test/core/transport/chttp2/hpack_sync_fuzzer.cc
@@ -52,8 +52,6 @@
 bool squelch = true;
 bool leak_check = true;
 
-static void dont_log(gpr_log_func_args* /*args*/) {}
-
 namespace grpc_core {
 namespace {
 
@@ -170,7 +168,9 @@ void FuzzOneInput(const hpack_sync_fuzzer::Msg& msg) {
 }  // namespace grpc_core
 
 DEFINE_PROTO_FUZZER(const hpack_sync_fuzzer::Msg& msg) {
-  if (squelch) gpr_set_log_function(dont_log);
+  if (squelch) {
+    gpr_disable_all_logs();
+  }
   grpc_core::ApplyFuzzConfigVars(msg.config_vars());
   grpc_core::TestOnlyReloadExperimentsFromConfigVariables();
   grpc_core::FuzzOneInput(msg);