| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 198 ::grpc::CompletionQueue* call_cq,
228 ::grpc::CompletionQueue* call_cq,
258 ::grpc::CompletionQueue* call_cq, in NoPayloadAsyncRequest() argument
262 server, context, stream, call_cq, notification_cq, tag, in NoPayloadAsyncRequest()
276 ::grpc::CompletionQueue* call_cq, in PayloadAsyncRequest() argument
280 server, context, stream, call_cq, notification_cq, tag, in PayloadAsyncRequest()
332 ::grpc::CompletionQueue* call_cq,
346 ::grpc::CompletionQueue* call_cq, in RequestAsyncCall() argument
350 new PayloadAsyncRequest<Message>(method, this, context, stream, call_cq, in RequestAsyncCall()
357 ::grpc::CompletionQueue* call_cq, in RequestAsyncCall() argument
[all …]
|
| D | service_type.h | 129 ::grpc::CompletionQueue* call_cq, in RequestAsyncUnary() argument
136 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncUnary()
142 ::grpc::CompletionQueue* call_cq, in RequestAsyncClientStreaming() argument
145 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncClientStreaming()
152 ::grpc::CompletionQueue* call_cq, in RequestAsyncServerStreaming() argument
155 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncServerStreaming()
161 ::grpc::CompletionQueue* call_cq, in RequestAsyncBidiStreaming() argument
164 server_->RequestAsyncCall(methods_[idx].get(), context, stream, call_cq, in RequestAsyncBidiStreaming()
|
| D | async_generic_service.h | 74 ::grpc::CompletionQueue* call_cq,
|
| /third_party/grpc/src/cpp/server/ |
| D | async_generic_service.cc | 27 ::grpc::CompletionQueue* call_cq, in RequestCall() argument
29 server_->RequestAsyncGenericCall(ctx, reader_writer, call_cq, notification_cq, in RequestCall()
|
| D | server_cc.cc | 119 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in BaseAsyncRequest() argument
124 call_cq_(call_cq), in BaseAsyncRequest()
202 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in RegisteredAsyncRequest() argument
205 : BaseAsyncRequest(server, context, stream, call_cq, notification_cq, tag, in RegisteredAsyncRequest()
224 internal::ServerAsyncStreamingInterface* stream, CompletionQueue* call_cq, in GenericAsyncRequest() argument
226 : BaseAsyncRequest(server, context, stream, call_cq, notification_cq, tag, in GenericAsyncRequest()
230 GPR_ASSERT(call_cq); in GenericAsyncRequest()
235 call_cq->cq(), notification_cq->cq(), in GenericAsyncRequest()
|
| /third_party/grpc/src/core/lib/surface/ |
| D | server.cc | 69 RequestedCall(void* tag_arg, grpc_completion_queue* call_cq, in RequestedCall()
74 cq_bound_to_call(call_cq), in RequestedCall()
81 RequestedCall(void* tag_arg, grpc_completion_queue* call_cq, in RequestedCall()
87 cq_bound_to_call(call_cq), in RequestedCall()
|