aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/cpp/client/client_context.cc
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2015-05-04 14:53:51 -0700
committerGravatar Craig Tiller <ctiller@google.com>2015-05-04 14:53:51 -0700
commit64be9f7a30a4bcb9ce3647f11ba9e06994aa3bb7 (patch)
tree42a4af35a2fe0f3a79573ff37130fd6b74c55cb9 /src/cpp/client/client_context.cc
parentc112d146a2dcc5e90d5f5cca10f55f212f9492c6 (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.cc12
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_);
}
}