diff options
| author |  Craig Tiller <ctiller@google.com> | 2016-02-25 07:16:24 -0800 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2016-02-25 07:16:24 -0800 |
| commit | a3f344201051082f806bd31c02a6d0754a2754ea (patch) | |
| tree | 200ff21cbb3c9f988be5fd25810369b5f6de707c /src/core/surface/completion_queue.c | |
| parent | 1a969c86f4ccc048bedb26c0ac24e2788f88343f (diff) | |
| parent | c46beaaa29af84f676bde9d013a85dffed1d58c9 (diff) | |
Merge branch 'hide-the-pollset-set' into cleaner-posix2
Diffstat (limited to 'src/core/surface/completion_queue.c')
| -rw-r--r-- | src/core/surface/completion_queue.c | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/core/surface/completion_queue.c b/src/core/surface/completion_queue.c index d0659c7e52..41449fb4a6 100644 --- a/src/core/surface/completion_queue.c +++ b/src/core/surface/completion_queue.c @@ -339,9 +339,10 @@ grpc_event grpc_completion_queue_next(grpc_completion_queue *cc, grpc_exec_ctx_flush(&exec_ctx); gpr_mu_lock(&cc->mu); continue; + } else { + grpc_pollset_work(&exec_ctx, POLLSET_FROM_CQ(cc), &worker, now, + iteration_deadline); } - grpc_pollset_work(&exec_ctx, POLLSET_FROM_CQ(cc), &worker, now, - iteration_deadline); } GRPC_SURFACE_TRACE_RETURNED_EVENT(cc, &ret); GRPC_CQ_INTERNAL_UNREF(cc, "next"); @@ -456,9 +457,10 @@ grpc_event grpc_completion_queue_pluck(grpc_completion_queue *cc, void *tag, grpc_exec_ctx_flush(&exec_ctx); gpr_mu_lock(&cc->mu); continue; + } else { + grpc_pollset_work(&exec_ctx, POLLSET_FROM_CQ(cc), &worker, now, + iteration_deadline); } - grpc_pollset_work(&exec_ctx, POLLSET_FROM_CQ(cc), &worker, now, - iteration_deadline); del_plucker(cc, tag, &worker); } done: |