diff options
| author |  Craig Tiller <craig.tiller@gmail.com> | 2015-02-11 20:34:33 -0800 |
|---|---|---|
| committer | Craig Tiller <craig.tiller@gmail.com> | 2015-02-11 20:34:33 -0800 |
| commit | 504bd331aba5817c2753c4f447f40cc83fa4d907 (patch) | |
| tree | a109bb943793a758f505041508c2d06864856f10 /src/cpp/client | |
| parent | 4dd70173bdf0754a039ddf634080e2fbf29d86e7 (diff) | |
Make sure we get a close before stopping the server
Diffstat (limited to 'src/cpp/client')
| -rw-r--r-- | src/cpp/client/client_unary_call.cc | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/cpp/client/client_unary_call.cc b/src/cpp/client/client_unary_call.cc index 6825398612..30bf2d0fc2 100644 --- a/src/cpp/client/client_unary_call.cc +++ b/src/cpp/client/client_unary_call.cc @@ -36,6 +36,7 @@ #include <grpc++/channel_interface.h> #include <grpc++/completion_queue.h> #include <grpc++/status.h> +#include <grpc/support/log.h> namespace grpc { @@ -54,7 +55,7 @@ Status BlockingUnaryCall(ChannelInterface *channel, const RpcMethod &method, buf.AddClientSendClose(); buf.AddClientRecvStatus(nullptr, &status); // TODO metadata call.PerformOps(&buf); - cq.Pluck(&buf); + GPR_ASSERT(cq.Pluck(&buf)); return status; } |