diff options
author | 2015-04-14 14:01:39 -0700 | |
---|---|---|
committer | 2015-04-16 09:29:17 -0700 | |
commit | 15f9f95312666574a8a42c91e35fcd4b0aab5987 (patch) | |
tree | 5c6926815806d31ef9c8dde917051f1fc0c4707d /src | |
parent | 3beef68d391c6c3ac83ff149b3cf67ce25c3bb72 (diff) |
Use channel tags to call methods
Diffstat (limited to 'src')
-rw-r--r-- | src/cpp/client/channel.cc | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/cpp/client/channel.cc b/src/cpp/client/channel.cc index 5a39a3b801..7a9ba477f0 100644 --- a/src/cpp/client/channel.cc +++ b/src/cpp/client/channel.cc @@ -61,7 +61,12 @@ Channel::~Channel() { grpc_channel_destroy(c_channel_); } Call Channel::CreateCall(const RpcMethod& method, ClientContext* context, CompletionQueue* cq) { - auto c_call = grpc_channel_create_call(c_channel_, cq->cq(), method.name(), + auto c_call = method.channel_tag()? + grpc_channel_create_registered_call( + c_channel_, cq->cq(), + method.channel_tag(), context->RawDeadline()) : + + grpc_channel_create_call(c_channel_, cq->cq(), method.name(), context->authority().empty() ? target_.c_str() : context->authority().c_str(), |