diff options
| author |  Yuxuan Li <yuxuanli@google.com> | 2017-05-03 23:29:17 -0700 |
|---|---|---|
| committer | Yuxuan Li <yuxuanli@google.com> | 2017-05-03 23:29:17 -0700 |
| commit | f8365cd87b5e76dbc050c0c2647e2875a07bca68 (patch) | |
| tree | 753ea2aa7bab0246be5712e43e1e4d00632abe43 /src/core/lib/surface/completion_queue.c | |
| parent | 28efff3e1e3d969f343bd1075039ce25d7834682 (diff) | |
clean up, fix minor issue
Diffstat (limited to 'src/core/lib/surface/completion_queue.c')
| -rw-r--r-- | src/core/lib/surface/completion_queue.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/core/lib/surface/completion_queue.c b/src/core/lib/surface/completion_queue.c index bfdd7f22fd..346ea18d5a 100644 --- a/src/core/lib/surface/completion_queue.c +++ b/src/core/lib/surface/completion_queue.c @@ -227,7 +227,7 @@ struct grpc_completion_queue { /* TODO: sreek - This will no longer be needed. Use polling_type set */ int is_non_listening_server_cq; int num_pluckers; - gpr_atm num_poll; + gpr_atm num_polls; plucker pluckers[GRPC_MAX_COMPLETION_QUEUE_PLUCKERS]; grpc_closure pollset_shutdown_done; @@ -293,7 +293,7 @@ grpc_completion_queue *grpc_completion_queue_create_internal( cc->is_server_cq = 0; cc->is_non_listening_server_cq = 0; cc->num_pluckers = 0; - gpr_atm_no_barrier_store(&cc->num_poll, 0); + gpr_atm_no_barrier_store(&cc->num_polls, 0); gpr_atm_no_barrier_store(&cc->things_queued_ever, 0); #ifndef NDEBUG cc->outstanding_tag_count = 0; @@ -311,7 +311,7 @@ grpc_cq_completion_type grpc_get_cq_completion_type(grpc_completion_queue *cc) { } gpr_atm grpc_get_cq_poll_num(grpc_completion_queue *cc) { - return gpr_atm_no_barrier_load(&cc->num_poll); + return gpr_atm_no_barrier_load(&cc->num_polls); } #ifdef GRPC_CQ_REF_COUNT_DEBUG @@ -598,7 +598,7 @@ grpc_event grpc_completion_queue_next(grpc_completion_queue *cc, gpr_mu_lock(cc->mu); continue; } else { - cc->num_poll++; + gpr_atm_no_barrier_fetch_add(&cc->num_polls, 1); grpc_error *err = cc->poller_vtable->work(&exec_ctx, POLLSET_FROM_CQ(cc), NULL, now, iteration_deadline); if (err != GRPC_ERROR_NONE) { @@ -791,7 +791,7 @@ grpc_event grpc_completion_queue_pluck(grpc_completion_queue *cc, void *tag, grpc_exec_ctx_flush(&exec_ctx); gpr_mu_lock(cc->mu); } else { - gpr_atm_no_barrier_fetch_add(&cc->num_poll, 1); + gpr_atm_no_barrier_fetch_add(&cc->num_polls, 1); grpc_error *err = cc->poller_vtable->work( &exec_ctx, POLLSET_FROM_CQ(cc), &worker, now, iteration_deadline); if (err != GRPC_ERROR_NONE) { |