| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_master_service_impl.h | 135 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestCreateSession() argument
137 new_call_cq, notification_cq, tag); in RequestCreateSession()
143 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestExtendSession() argument
145 new_call_cq, notification_cq, tag); in RequestExtendSession()
151 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestPartialRunSetup() argument
153 new_call_cq, notification_cq, tag); in RequestPartialRunSetup()
159 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestRunStep() argument
161 new_call_cq, notification_cq, tag); in RequestRunStep()
167 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestCloseSession() argument
169 new_call_cq, notification_cq, tag); in RequestCloseSession()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | server_interface.h | 197 ::grpc::ServerCompletionQueue* notification_cq, void* tag,
227 ::grpc::ServerCompletionQueue* notification_cq,
245 ::grpc::ServerCompletionQueue* notification_cq);
257 ::grpc::ServerCompletionQueue* notification_cq, in NoPayloadAsyncRequest() argument
260 server, context, stream, call_cq, notification_cq, tag, in NoPayloadAsyncRequest()
262 IssueRequest(registered_method->server_tag(), nullptr, notification_cq); in NoPayloadAsyncRequest()
275 ::grpc::ServerCompletionQueue* notification_cq, in PayloadAsyncRequest() argument
278 server, context, stream, call_cq, notification_cq, tag, in PayloadAsyncRequest()
283 notification_cq); in PayloadAsyncRequest()
331 ::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);
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 197 ::grpc::ServerCompletionQueue* notification_cq, void* tag,
227 ::grpc::ServerCompletionQueue* notification_cq,
245 ::grpc::ServerCompletionQueue* notification_cq);
257 ::grpc::ServerCompletionQueue* notification_cq, in NoPayloadAsyncRequest() argument
260 server, context, stream, call_cq, notification_cq, tag, in NoPayloadAsyncRequest()
262 IssueRequest(registered_method->server_tag(), nullptr, notification_cq); in NoPayloadAsyncRequest()
275 ::grpc::ServerCompletionQueue* notification_cq, in PayloadAsyncRequest() argument
278 server, context, stream, call_cq, notification_cq, tag, in PayloadAsyncRequest()
283 notification_cq); in PayloadAsyncRequest()
331 ::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);
|
| /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/rust/crates/grpcio-sys/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()
|
| /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/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()
|
| /external/tensorflow/tensorflow/core/tpu/kernels/ |
| D | tpu_compilation_cache_grpc.h | 170 ::grpc::ServerCompletionQueue* notification_cq, void* tag) { in RequestGetTpuProgram() argument
172 new_call_cq, notification_cq, tag); in RequestGetTpuProgram()
|