| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 199 ::grpc::ServerCompletionQueue* notification_cq, void* tag,
229 ::grpc::ServerCompletionQueue* notification_cq,
247 ::grpc::ServerCompletionQueue* notification_cq);
259 ::grpc::ServerCompletionQueue* notification_cq, in NoPayloadAsyncRequest() argument
262 server, context, stream, call_cq, notification_cq, tag, in NoPayloadAsyncRequest()
264 IssueRequest(registered_method->server_tag(), nullptr, notification_cq); in NoPayloadAsyncRequest()
277 ::grpc::ServerCompletionQueue* notification_cq, in PayloadAsyncRequest() argument
280 server, context, stream, call_cq, notification_cq, tag, in PayloadAsyncRequest()
285 notification_cq); in PayloadAsyncRequest()
333 ::grpc::ServerCompletionQueue* notification_cq,
[all …]
|
| D | service_type.h | 130 ::grpc::ServerCompletionQueue* notification_cq, in RequestAsyncUnary() argument
137 notification_cq, tag, request); in RequestAsyncUnary()
143 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncClientStreaming() argument
146 notification_cq, tag); in RequestAsyncClientStreaming()
153 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncServerStreaming() argument
156 notification_cq, tag, request); in RequestAsyncServerStreaming()
162 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncBidiStreaming() argument
165 notification_cq, tag); in RequestAsyncBidiStreaming()
|
| D | async_generic_service.h | 75 ::grpc::ServerCompletionQueue* notification_cq, void* tag);
|
| /third_party/grpc/src/cpp/server/ |
| D | async_generic_service.cc | 28 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestCall() argument
29 server_->RequestAsyncGenericCall(ctx, reader_writer, call_cq, notification_cq, in RequestCall()
|
| D | server_cc.cc | 120 ServerCompletionQueue* notification_cq, void* tag, bool delete_on_finalize) in BaseAsyncRequest() argument
125 notification_cq_(notification_cq), in BaseAsyncRequest()
203 ServerCompletionQueue* notification_cq, void* tag, const char* name, in RegisteredAsyncRequest() argument
205 : BaseAsyncRequest(server, context, stream, call_cq, notification_cq, tag, in RegisteredAsyncRequest()
212 ServerCompletionQueue* notification_cq) { in IssueRequest() argument
218 payload, call_cq_->cq(), notification_cq->cq(), in IssueRequest()
225 ServerCompletionQueue* notification_cq, void* tag, bool delete_on_finalize) in GenericAsyncRequest() argument
226 : BaseAsyncRequest(server, context, stream, call_cq, notification_cq, tag, in GenericAsyncRequest()
229 GPR_ASSERT(notification_cq); in GenericAsyncRequest()
235 call_cq->cq(), notification_cq->cq(), in GenericAsyncRequest()
|
| /third_party/grpc/test/cpp/codegen/ |
| D | compiler_test_golden | 304 … ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
305 …grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
324 … ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
325 …::grpc::Service::RequestAsyncClientStreaming(1, context, reader, new_call_cq, notification_cq, tag…
344 … ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
345 …rvice::RequestAsyncServerStreaming(2, context, request, writer, new_call_cq, notification_cq, tag);
364 … ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
365 … ::grpc::Service::RequestAsyncBidiStreaming(3, context, stream, new_call_cq, notification_cq, tag);
619 … ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
620 …grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
[all …]
|
| /third_party/flatbuffers/tests/ |
| D | monster_test.grpc.fb.h | 168 … ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { in RequestStore() argument
169 …grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag); in RequestStore()
188 … ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { in RequestRetrieve() argument
189 …rvice::RequestAsyncServerStreaming(1, context, request, writer, new_call_cq, notification_cq, tag); in RequestRetrieve()
208 … ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { in RequestGetMaxHitPoint() argument
209 …::grpc::Service::RequestAsyncClientStreaming(2, context, reader, new_call_cq, notification_cq, tag… in RequestGetMaxHitPoint()
228 … ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { in RequestGetMinMaxHitPoints() argument
229 … ::grpc::Service::RequestAsyncBidiStreaming(3, context, stream, new_call_cq, notification_cq, tag); in RequestGetMinMaxHitPoints()
|