| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_master_service_impl.h | 133 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestCreateSession() argument
135 new_call_cq, notification_cq, tag); in RequestCreateSession()
141 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestExtendSession() argument
143 new_call_cq, notification_cq, tag); in RequestExtendSession()
149 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestPartialRunSetup() argument
151 new_call_cq, notification_cq, tag); in RequestPartialRunSetup()
157 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestRunStep() argument
159 new_call_cq, notification_cq, tag); in RequestRunStep()
165 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestCloseSession() argument
167 new_call_cq, notification_cq, tag); in RequestCloseSession()
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service.h | 115 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestCreateContext() argument
117 new_call_cq, notification_cq, tag); in RequestCreateContext()
123 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestEnqueue() argument
125 new_call_cq, notification_cq, tag); in RequestEnqueue()
131 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestWaitQueueDone() argument
133 new_call_cq, notification_cq, tag); in RequestWaitQueueDone()
139 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestKeepAlive() argument
141 new_call_cq, notification_cq, tag); in RequestKeepAlive()
147 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestCloseContext() argument
149 new_call_cq, notification_cq, tag); in RequestCloseContext()
[all …]
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 177 ServerCompletionQueue* notification_cq);
186 ServerCompletionQueue* notification_cq, void* tag) in NoPayloadAsyncRequest() argument
188 IssueRequest(registered_method, nullptr, notification_cq); in NoPayloadAsyncRequest()
201 ServerCompletionQueue* notification_cq, void* tag, in PayloadAsyncRequest() argument
209 notification_cq_(notification_cq), in PayloadAsyncRequest()
212 IssueRequest(registered_method, payload_.bbuf_ptr(), notification_cq); in PayloadAsyncRequest()
258 ServerCompletionQueue* notification_cq, void* tag,
272 ServerCompletionQueue* notification_cq, void* tag, in RequestAsyncCall() argument
276 stream, call_cq, notification_cq, tag, in RequestAsyncCall()
284 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncCall() argument
[all …]
|
| D | service_type.h | 95 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncUnary() argument
101 notification_cq, tag, request); in RequestAsyncUnary()
106 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncClientStreaming() argument
109 notification_cq, tag); in RequestAsyncClientStreaming()
115 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncServerStreaming() argument
118 notification_cq, tag, request); in RequestAsyncServerStreaming()
123 ServerCompletionQueue* notification_cq, void* tag) { in RequestAsyncBidiStreaming() argument
126 notification_cq, tag); in RequestAsyncBidiStreaming()
|
| D | async_generic_service.h | 72 ServerCompletionQueue* notification_cq, void* tag);
|
| /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 | 714 ServerCompletionQueue* notification_cq) { in IssueRequest() argument
719 call_cq_->cq(), notification_cq->cq(), this)); in IssueRequest()
725 ServerCompletionQueue* notification_cq, void* tag, bool delete_on_finalize) in GenericAsyncRequest() argument
729 GPR_ASSERT(notification_cq); in GenericAsyncRequest()
734 notification_cq->cq(), this)); in GenericAsyncRequest()
|
| /external/grpc-grpc/test/cpp/codegen/ |
| D | compiler_test_golden | 245 … ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
246 …grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
265 … ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
266 …::grpc::Service::RequestAsyncClientStreaming(1, context, reader, new_call_cq, notification_cq, tag…
285 … ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
286 …rvice::RequestAsyncServerStreaming(2, context, request, writer, new_call_cq, notification_cq, tag);
305 … ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
306 … ::grpc::Service::RequestAsyncBidiStreaming(3, context, stream, new_call_cq, notification_cq, tag);
394 … ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
395 …grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
[all …]
|
| /external/tensorflow/tensorflow/contrib/verbs/ |
| D | grpc_verbs_service_impl.h | 70 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestGetRemoteAddress() argument
72 new_call_cq, notification_cq, tag); in RequestGetRemoteAddress()
|
| /external/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()
|