Fix old trace vars

reviewable/pr10961/r1
Craig Tiller 8 years ago
parent 01651ae98d
commit 1dbd063dbf
  1. 2
      src/core/ext/filters/http/server/http_server_filter.c
  2. 6
      src/core/ext/transport/chttp2/transport/hpack_encoder.c
  3. 7
      src/core/ext/transport/chttp2/transport/hpack_table.c
  4. 6
      src/core/lib/iomgr/tcp_client_uv.c
  5. 3
      src/core/lib/iomgr/tcp_uv.h
  6. 13
      test/core/iomgr/timer_list_test.c

@ -46,8 +46,6 @@
#define EXPECTED_CONTENT_TYPE "application/grpc" #define EXPECTED_CONTENT_TYPE "application/grpc"
#define EXPECTED_CONTENT_TYPE_LENGTH sizeof(EXPECTED_CONTENT_TYPE) - 1 #define EXPECTED_CONTENT_TYPE_LENGTH sizeof(EXPECTED_CONTENT_TYPE) - 1
extern int grpc_http_trace;
typedef struct call_data { typedef struct call_data {
grpc_linked_mdelem status; grpc_linked_mdelem status;
grpc_linked_mdelem content_type; grpc_linked_mdelem content_type;

@ -69,7 +69,7 @@ static grpc_slice_refcount terminal_slice_refcount = {NULL, NULL};
static const grpc_slice terminal_slice = {&terminal_slice_refcount, static const grpc_slice terminal_slice = {&terminal_slice_refcount,
.data.refcounted = {0, 0}}; .data.refcounted = {0, 0}};
extern int grpc_http_trace; extern grpc_tracer_flag grpc_http_trace;
typedef struct { typedef struct {
int is_first_frame; int is_first_frame;
@ -425,7 +425,7 @@ static void hpack_enc(grpc_exec_ctx *exec_ctx, grpc_chttp2_hpack_compressor *c,
"Reserved header (colon-prefixed) happening after regular ones."); "Reserved header (colon-prefixed) happening after regular ones.");
} }
if (grpc_http_trace && !GRPC_MDELEM_IS_INTERNED(elem)) { if (GRPC_TRACER_ON(grpc_http_trace) && !GRPC_MDELEM_IS_INTERNED(elem)) {
char *k = grpc_slice_to_c_string(GRPC_MDKEY(elem)); char *k = grpc_slice_to_c_string(GRPC_MDKEY(elem));
char *v = grpc_slice_to_c_string(GRPC_MDVALUE(elem)); char *v = grpc_slice_to_c_string(GRPC_MDVALUE(elem));
gpr_log( gpr_log(
@ -616,7 +616,7 @@ void grpc_chttp2_hpack_compressor_set_max_table_size(
} }
} }
c->advertise_table_size_change = 1; c->advertise_table_size_change = 1;
if (grpc_http_trace) { if (GRPC_TRACER_ON(grpc_http_trace)) {
gpr_log(GPR_DEBUG, "set max table size from encoder to %d", max_table_size); gpr_log(GPR_DEBUG, "set max table size from encoder to %d", max_table_size);
} }
} }

@ -40,9 +40,10 @@
#include <grpc/support/log.h> #include <grpc/support/log.h>
#include <grpc/support/string_util.h> #include <grpc/support/string_util.h>
#include "src/core/lib/debug/trace.h"
#include "src/core/lib/support/murmur_hash.h" #include "src/core/lib/support/murmur_hash.h"
extern int grpc_http_trace; extern grpc_tracer_flag grpc_http_trace;
static struct { static struct {
const char *key; const char *key;
@ -260,7 +261,7 @@ void grpc_chttp2_hptbl_set_max_bytes(grpc_exec_ctx *exec_ctx,
if (tbl->max_bytes == max_bytes) { if (tbl->max_bytes == max_bytes) {
return; return;
} }
if (grpc_http_trace) { if (GRPC_TRACER_ON(grpc_http_trace)) {
gpr_log(GPR_DEBUG, "Update hpack parser max size to %d", max_bytes); gpr_log(GPR_DEBUG, "Update hpack parser max size to %d", max_bytes);
} }
while (tbl->mem_used > max_bytes) { while (tbl->mem_used > max_bytes) {
@ -284,7 +285,7 @@ grpc_error *grpc_chttp2_hptbl_set_current_table_size(grpc_exec_ctx *exec_ctx,
gpr_free(msg); gpr_free(msg);
return err; return err;
} }
if (grpc_http_trace) { if (GRPC_TRACER_ON(grpc_http_trace)) {
gpr_log(GPR_DEBUG, "Update hpack parser table size to %d", bytes); gpr_log(GPR_DEBUG, "Update hpack parser table size to %d", bytes);
} }
while (tbl->mem_used > bytes) { while (tbl->mem_used > bytes) {

@ -46,7 +46,7 @@
#include "src/core/lib/iomgr/tcp_uv.h" #include "src/core/lib/iomgr/tcp_uv.h"
#include "src/core/lib/iomgr/timer.h" #include "src/core/lib/iomgr/timer.h"
extern int grpc_tcp_trace; extern grpc_tracer_flag grpc_tcp_trace;
typedef struct grpc_uv_tcp_connect { typedef struct grpc_uv_tcp_connect {
uv_connect_t connect_req; uv_connect_t connect_req;
@ -72,7 +72,7 @@ static void uv_tc_on_alarm(grpc_exec_ctx *exec_ctx, void *acp,
grpc_error *error) { grpc_error *error) {
int done; int done;
grpc_uv_tcp_connect *connect = acp; grpc_uv_tcp_connect *connect = acp;
if (grpc_tcp_trace) { if (GRPC_TRACER_ON(grpc_tcp_trace)) {
const char *str = grpc_error_string(error); const char *str = grpc_error_string(error);
gpr_log(GPR_DEBUG, "CLIENT_CONNECT: %s: on_alarm: error=%s", gpr_log(GPR_DEBUG, "CLIENT_CONNECT: %s: on_alarm: error=%s",
connect->addr_name, str); connect->addr_name, str);
@ -156,7 +156,7 @@ static void tcp_client_connect_impl(grpc_exec_ctx *exec_ctx,
uv_tcp_init(uv_default_loop(), connect->tcp_handle); uv_tcp_init(uv_default_loop(), connect->tcp_handle);
connect->connect_req.data = connect; connect->connect_req.data = connect;
if (grpc_tcp_trace) { if (GRPC_TRACER_ON(grpc_tcp_trace)) {
gpr_log(GPR_DEBUG, "CLIENT_CONNECT: %s: asynchronously connecting", gpr_log(GPR_DEBUG, "CLIENT_CONNECT: %s: asynchronously connecting",
connect->addr_name); connect->addr_name);
} }

@ -44,11 +44,12 @@
otherwise specified. otherwise specified.
*/ */
#include "src/core/lib/debug/trace.h"
#include "src/core/lib/iomgr/endpoint.h" #include "src/core/lib/iomgr/endpoint.h"
#include <uv.h> #include <uv.h>
extern int grpc_tcp_trace; extern grpc_tracer_flag grpc_tcp_trace;
#define GRPC_TCP_DEFAULT_READ_SLICE_SIZE 8192 #define GRPC_TCP_DEFAULT_READ_SLICE_SIZE 8192

@ -41,12 +41,13 @@
#include <string.h> #include <string.h>
#include <grpc/support/log.h> #include <grpc/support/log.h>
#include "src/core/lib/debug/trace.h"
#include "test/core/util/test_config.h" #include "test/core/util/test_config.h"
#define MAX_CB 30 #define MAX_CB 30
extern int grpc_timer_trace; extern grpc_tracer_flag grpc_timer_trace;
extern int grpc_timer_check_trace; extern grpc_tracer_flag grpc_timer_check_trace;
static int cb_called[MAX_CB][2]; static int cb_called[MAX_CB][2];
@ -63,8 +64,8 @@ static void add_test(void) {
gpr_log(GPR_INFO, "add_test"); gpr_log(GPR_INFO, "add_test");
grpc_timer_list_init(start); grpc_timer_list_init(start);
grpc_timer_trace = 1; grpc_timer_trace.value = 1;
grpc_timer_check_trace = 1; grpc_timer_check_trace.value = 1;
memset(cb_called, 0, sizeof(cb_called)); memset(cb_called, 0, sizeof(cb_called));
/* 10 ms timers. will expire in the current epoch */ /* 10 ms timers. will expire in the current epoch */
@ -138,8 +139,8 @@ void destruction_test(void) {
gpr_log(GPR_INFO, "destruction_test"); gpr_log(GPR_INFO, "destruction_test");
grpc_timer_list_init(gpr_time_0(GPR_CLOCK_REALTIME)); grpc_timer_list_init(gpr_time_0(GPR_CLOCK_REALTIME));
grpc_timer_trace = 1; grpc_timer_trace.value = 1;
grpc_timer_check_trace = 1; grpc_timer_check_trace.value = 1;
memset(cb_called, 0, sizeof(cb_called)); memset(cb_called, 0, sizeof(cb_called));
grpc_timer_init( grpc_timer_init(

Loading…
Cancel
Save