diff options
| author |  Craig Tiller <ctiller@google.com> | 2017-11-01 15:36:13 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2017-11-01 15:36:13 -0700 |
| commit | c60659ad023d01f8d0f6ad0f87fefbd3740002d0 (patch) | |
| tree | db3aed566315b2bf38fc28c678a7a32f20d7b773 /src/core/lib/iomgr/lockfree_event.cc | |
| parent | e098d2eb5bfa58376a60b49989cb66c59b420755 (diff) | |
Review feedback
Diffstat (limited to 'src/core/lib/iomgr/lockfree_event.cc')
| -rw-r--r-- | src/core/lib/iomgr/lockfree_event.cc | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/src/core/lib/iomgr/lockfree_event.cc b/src/core/lib/iomgr/lockfree_event.cc index 549747b34b..d1273beee3 100644 --- a/src/core/lib/iomgr/lockfree_event.cc +++ b/src/core/lib/iomgr/lockfree_event.cc @@ -70,7 +70,7 @@ void LockfreeEvent::NotifyOn(grpc_exec_ctx *exec_ctx, grpc_closure *closure) { while (true) { gpr_atm curr = gpr_atm_no_barrier_load(&state_); if (GRPC_TRACER_ON(grpc_polling_trace)) { - gpr_log(GPR_ERROR, "lfev_notify_on: %p curr=%p closure=%p", this, + gpr_log(GPR_ERROR, "LockfreeEvent::NotifyOn: %p curr=%p closure=%p", this, (void *)curr, closure); } switch (curr) { @@ -120,7 +120,8 @@ void LockfreeEvent::NotifyOn(grpc_exec_ctx *exec_ctx, grpc_closure *closure) { /* There is already a closure!. This indicates a bug in the code */ gpr_log(GPR_ERROR, - "notify_on called with a previous callback still pending"); + "LockfreeEvent::NotifyOn: notify_on called with a previous " + "callback still pending"); abort(); } } @@ -136,8 +137,8 @@ bool LockfreeEvent::SetShutdown(grpc_exec_ctx *exec_ctx, while (true) { gpr_atm curr = gpr_atm_no_barrier_load(&state_); if (GRPC_TRACER_ON(grpc_polling_trace)) { - gpr_log(GPR_ERROR, "lfev_set_shutdown: %p curr=%p err=%s", &state_, - (void *)curr, grpc_error_string(shutdown_err)); + gpr_log(GPR_ERROR, "LockfreeEvent::SetShutdown: %p curr=%p err=%s", + &state_, (void *)curr, grpc_error_string(shutdown_err)); } switch (curr) { case kClosureReady: @@ -185,7 +186,8 @@ void LockfreeEvent::SetReady(grpc_exec_ctx *exec_ctx) { gpr_atm curr = gpr_atm_no_barrier_load(&state_); if (GRPC_TRACER_ON(grpc_polling_trace)) { - gpr_log(GPR_ERROR, "lfev_set_ready: %p curr=%p", &state_, (void *)curr); + gpr_log(GPR_ERROR, "LockfreeEvent::SetReady: %p curr=%p", &state_, + (void *)curr); } switch (curr) { |