diff options
author | Craig Tiller <ctiller@google.com> | 2015-05-04 14:53:51 -0700 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2015-05-04 14:53:51 -0700 |
commit | 64be9f7a30a4bcb9ce3647f11ba9e06994aa3bb7 (patch) | |
tree | 42a4af35a2fe0f3a79573ff37130fd6b74c55cb9 /src/cpp/client/client_context.cc | |
parent | c112d146a2dcc5e90d5f5cca10f55f212f9492c6 (diff) |
C Core API cleanup.
Simplify grpc_event into something that can be non-heap allocated.
Deprecate grpc_event_finish.
Remove grpc_op_error - use an int as this is more idiomatic C style.
Diffstat (limited to 'src/cpp/client/client_context.cc')
-rw-r--r-- | src/cpp/client/client_context.cc | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/src/cpp/client/client_context.cc b/src/cpp/client/client_context.cc index 70c9cb4c3b..f38a694734 100644 --- a/src/cpp/client/client_context.cc +++ b/src/cpp/client/client_context.cc @@ -49,15 +49,11 @@ ClientContext::~ClientContext() { grpc_call_destroy(call_); } if (cq_) { - grpc_completion_queue_shutdown(cq_); // Drain cq_. - grpc_event* ev; - grpc_completion_type t; - do { - ev = grpc_completion_queue_next(cq_, gpr_inf_future); - t = ev->type; - grpc_event_finish(ev); - } while (t != GRPC_QUEUE_SHUTDOWN); + grpc_completion_queue_shutdown(cq_); + while (grpc_completion_queue_next(cq_, gpr_inf_future).type != + GRPC_QUEUE_SHUTDOWN) + ; grpc_completion_queue_destroy(cq_); } } |