diff options
| author |  Yang Gao <yangg@google.com> | 2017-07-31 07:37:31 -0700 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2017-07-31 07:37:31 -0700 |
| commit | f787594e688cb59fe207bb3199b9cb4cfa0c87ca (patch) | |
| tree | 34bef80126ff38ebf98307f1c866e3b9e72d95b2 /src/core/ext | |
| parent | 025ca9e4b24befd239f7b043846eb0bb177b6ead (diff) | |
| parent | 097cbfc94fc96f079d7be8d0dcbcb9b282484bbd (diff) | |
Merge pull request #11703 from yang-g/cq_shutdown
Allow adding events to cq after shutdown is called.
Diffstat (limited to 'src/core/ext')
| -rw-r--r-- | src/core/ext/filters/client_channel/channel_connectivity.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/core/ext/filters/client_channel/channel_connectivity.c b/src/core/ext/filters/client_channel/channel_connectivity.c index c3dca14305..b83c95275f 100644 --- a/src/core/ext/filters/client_channel/channel_connectivity.c +++ b/src/core/ext/filters/client_channel/channel_connectivity.c @@ -208,7 +208,7 @@ void grpc_channel_watch_connectivity_state( 7, (channel, (int)last_observed_state, deadline.tv_sec, deadline.tv_nsec, (int)deadline.clock_type, cq, tag)); - grpc_cq_begin_op(cq, tag); + GPR_ASSERT(grpc_cq_begin_op(cq, tag)); gpr_mu_init(&w->mu); GRPC_CLOSURE_INIT(&w->on_complete, watch_complete, w, |