diff options
| author |  Craig Tiller <ctiller@google.com> | 2015-08-06 13:19:33 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2015-08-06 13:19:33 -0700 |
| commit | a3a7e5c0b24c196cd8e9a078cf531fc99ffa4e9e (patch) | |
| tree | 630af03f3dc2ebd08ba5c331280bbe5eec8b8838 /src/core/surface/completion_queue.c | |
| parent | 95bdfaa7a0b9244fdfcb81e439b085bd61df5648 (diff) | |
| parent | 2db17838e7f0de0603b53f043f1adf8043914aa2 (diff) | |
Merge github.com:grpc/grpc into y12kdm3
Diffstat (limited to 'src/core/surface/completion_queue.c')
| -rw-r--r-- | src/core/surface/completion_queue.c | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/core/surface/completion_queue.c b/src/core/surface/completion_queue.c index e6ff04ec0e..cb862ce94b 100644 --- a/src/core/surface/completion_queue.c +++ b/src/core/surface/completion_queue.c @@ -114,6 +114,11 @@ void grpc_cq_internal_unref(grpc_completion_queue *cc) { } void grpc_cq_begin_op(grpc_completion_queue *cc) { +#ifndef NDEBUG + gpr_mu_lock(GRPC_POLLSET_MU(&cc->pollset)); + GPR_ASSERT(!cc->shutdown_called); + gpr_mu_unlock(GRPC_POLLSET_MU(&cc->pollset)); +#endif gpr_ref(&cc->pending_events); } |