|
|
|
@ -36,8 +36,8 @@ class RpcMethod; |
|
|
|
|
/// Wrapper that performs a blocking unary call
|
|
|
|
|
template <class InputMessage, class OutputMessage> |
|
|
|
|
Status BlockingUnaryCall(ChannelInterface* channel, const RpcMethod& method, |
|
|
|
|
grpc_impl::ClientContext* context, const InputMessage& request, |
|
|
|
|
OutputMessage* result) { |
|
|
|
|
grpc_impl::ClientContext* context, |
|
|
|
|
const InputMessage& request, OutputMessage* result) { |
|
|
|
|
return BlockingUnaryCallImpl<InputMessage, OutputMessage>( |
|
|
|
|
channel, method, context, request, result) |
|
|
|
|
.status(); |
|
|
|
@ -47,8 +47,8 @@ template <class InputMessage, class OutputMessage> |
|
|
|
|
class BlockingUnaryCallImpl { |
|
|
|
|
public: |
|
|
|
|
BlockingUnaryCallImpl(ChannelInterface* channel, const RpcMethod& method, |
|
|
|
|
grpc_impl::ClientContext* context, const InputMessage& request, |
|
|
|
|
OutputMessage* result) { |
|
|
|
|
grpc_impl::ClientContext* context, |
|
|
|
|
const InputMessage& request, OutputMessage* result) { |
|
|
|
|
CompletionQueue cq(grpc_completion_queue_attributes{ |
|
|
|
|
GRPC_CQ_CURRENT_VERSION, GRPC_CQ_PLUCK, GRPC_CQ_DEFAULT_POLLING, |
|
|
|
|
nullptr}); // Pluckable completion queue
|
|
|
|
|