| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 151 CompletionQueue* call_cq, void* tag,
171 CompletionQueue* call_cq, void* tag);
185 CompletionQueue* call_cq, in NoPayloadAsyncRequest() argument
187 : RegisteredAsyncRequest(server, context, stream, call_cq, tag) { in NoPayloadAsyncRequest()
200 CompletionQueue* call_cq, in PayloadAsyncRequest() argument
203 : RegisteredAsyncRequest(server, context, stream, call_cq, tag), in PayloadAsyncRequest()
208 call_cq_(call_cq), in PayloadAsyncRequest()
257 CompletionQueue* call_cq,
271 CompletionQueue* call_cq, in RequestAsyncCall() argument
276 stream, call_cq, notification_cq, tag, in RequestAsyncCall()
[all …]
|
| D | service_type.h | 94 CompletionQueue* call_cq, in RequestAsyncUnary() argument
100 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncUnary()
105 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in RequestAsyncClientStreaming() argument
108 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncClientStreaming()
114 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in RequestAsyncServerStreaming() argument
117 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncServerStreaming()
122 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in RequestAsyncBidiStreaming() argument
125 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncBidiStreaming()
|
| D | async_generic_service.h | 71 CompletionQueue* call_cq,
|
| /external/grpc-grpc/src/cpp/server/ |
| D | async_generic_service.cc | 27 CompletionQueue* call_cq, ServerCompletionQueue* notification_cq, in RequestCall() argument
29 server_->RequestAsyncGenericCall(ctx, reader_writer, call_cq, notification_cq, in RequestCall()
|
| D | server_cc.cc | 672 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in BaseAsyncRequest() argument
677 call_cq_(call_cq), in BaseAsyncRequest()
708 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in RegisteredAsyncRequest() argument
710 : BaseAsyncRequest(server, context, stream, call_cq, tag, true) {} in RegisteredAsyncRequest()
724 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in GenericAsyncRequest() argument
726 : BaseAsyncRequest(server, context, stream, call_cq, tag, in GenericAsyncRequest()
730 GPR_ASSERT(call_cq); in GenericAsyncRequest()
733 context->client_metadata_.arr(), call_cq->cq(), in GenericAsyncRequest()
|