diff options
| author |  Yang Gao <yangg@google.com> | 2015-02-18 00:45:53 -0800 |
|---|---|---|
| committer | Yang Gao <yangg@google.com> | 2015-02-18 00:45:53 -0800 |
| commit | 2b7f537546280823ff20fe1020767c3235761418 (patch) | |
| tree | d6e86ca404b18aeafa9c3eb3553f933557f5c876 /src/cpp/client | |
| parent | 1ece67cba24c9872ae8fbd2218c57bac8ff9794d (diff) | |
Add metadata test with rpc. Adding/fixing things to make it work
Diffstat (limited to 'src/cpp/client')
| -rw-r--r-- | src/cpp/client/client_unary_call.cc | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/cpp/client/client_unary_call.cc b/src/cpp/client/client_unary_call.cc index 284af33b43..03a0326128 100644 --- a/src/cpp/client/client_unary_call.cc +++ b/src/cpp/client/client_unary_call.cc @@ -52,10 +52,10 @@ Status BlockingUnaryCall(ChannelInterface *channel, const RpcMethod &method, Status status; buf.AddSendInitialMetadata(context); buf.AddSendMessage(request); - buf.AddRecvInitialMetadata(&context->recv_initial_metadata_); + buf.AddRecvInitialMetadata(context); buf.AddRecvMessage(result); buf.AddClientSendClose(); - buf.AddClientRecvStatus(&context->trailing_metadata_, &status); + buf.AddClientRecvStatus(context, &status); call.PerformOps(&buf); GPR_ASSERT((cq.Pluck(&buf) && buf.got_message) || !status.IsOk()); return status; @@ -79,10 +79,10 @@ void AsyncUnaryCall(ChannelInterface *channel, const RpcMethod &method, Call call(channel->CreateCall(method, context, cq)); buf->AddSendInitialMetadata(context); buf->AddSendMessage(request); - buf->AddRecvInitialMetadata(&context->recv_initial_metadata_); + buf->AddRecvInitialMetadata(context); buf->AddRecvMessage(result); buf->AddClientSendClose(); - buf->AddClientRecvStatus(&context->trailing_metadata_, status); + buf->AddClientRecvStatus(context, status); call.PerformOps(buf); } |