diff options
| author |  Craig Tiller <ctiller@google.com> | 2015-05-12 17:00:30 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2015-05-12 17:00:30 -0700 |
| commit | 6c66c0f5ceb31c371890b59011064990720feca0 (patch) | |
| tree | 1446a4cbf0242c9eae7e1e7f063ab360feefcb43 /src/ruby/ext | |
| parent | e7da1d4e82ae95d4de65dea2185e4624f768a768 (diff) | |
Add accidentally deleted escape
Diffstat (limited to 'src/ruby/ext')
| -rw-r--r-- | src/ruby/ext/grpc/rb_completion_queue.c | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/ruby/ext/grpc/rb_completion_queue.c b/src/ruby/ext/grpc/rb_completion_queue.c index d83a20e5c3..fa4c566004 100644 --- a/src/ruby/ext/grpc/rb_completion_queue.c +++ b/src/ruby/ext/grpc/rb_completion_queue.c @@ -96,6 +96,7 @@ static void grpc_rb_completion_queue_shutdown_drain(grpc_completion_queue *cq) { rb_thread_call_without_gvl(grpc_rb_completion_queue_next_no_gil, (void *)&next_call, NULL, NULL); type = next_call.event.type; + if (type == GRPC_QUEUE_TIMEOUT) break; if (type != GRPC_QUEUE_SHUTDOWN) { ++drained; rb_warning("completion queue shutdown: %d undrained events", drained); |