| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_remote_worker.cc | 77 IssueRequest(request, response, getstatus_, std::move(done), call_opts, in GetStatusAsync()
84 IssueRequest(request, response, createworkersession_, std::move(done)); in CreateWorkerSessionAsync()
91 IssueRequest(request, response, deleteworkersession_, std::move(done), in DeleteWorkerSessionAsync()
98 IssueRequest(request, response, registergraph_, std::move(done)); in RegisterGraphAsync()
104 IssueRequest(request, response, deregistergraph_, std::move(done)); in DeregisterGraphAsync()
109 IssueRequest(request, response, rungraph_, std::move(done), call_opts); in RunGraphAsync()
114 IssueRequest(&request->ToProto(), get_proto_from_wrapper(response), in RunGraphAsync()
121 IssueRequest(request, response, cleanupgraph_, std::move(done)); in CleanupGraphAsync()
127 IssueRequest(request, response, cleanupall_, std::move(done)); in CleanupAllAsync()
172 IssueRequest(request, response, recvbuf_, callback, call_opts); in RecvBufAsync()
[all …]
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 176 void IssueRequest(void* registered_method, grpc_byte_buffer** payload,
188 IssueRequest(registered_method, nullptr, notification_cq); in NoPayloadAsyncRequest()
212 IssueRequest(registered_method, payload_.bbuf_ptr(), notification_cq); in PayloadAsyncRequest()
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | server_interface.h | 244 void IssueRequest(void* registered_method, grpc_byte_buffer** payload,
262 IssueRequest(registered_method->server_tag(), nullptr, notification_cq); in NoPayloadAsyncRequest()
282 IssueRequest(registered_method->server_tag(), payload_.bbuf_ptr(), in PayloadAsyncRequest()
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | server_interface.h | 244 void IssueRequest(void* registered_method, grpc_byte_buffer** payload,
262 IssueRequest(registered_method->server_tag(), nullptr, notification_cq); in NoPayloadAsyncRequest()
282 IssueRequest(registered_method->server_tag(), payload_.bbuf_ptr(), in PayloadAsyncRequest()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | collective_param_resolver_distributed_test.cc | 218 IssueRequest(task_name, device_name, group_size); in IssueRequests()
223 void IssueRequest(const string& task_name, const string& device_name, in IssueRequest() function in tensorflow::__anondb24ef490111::DeviceResDistTest
352 IssueRequest(task_name, device_name, num_workers * num_devices); in TEST_F()
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_cc.cc | 712 void ServerInterface::RegisteredAsyncRequest::IssueRequest( in IssueRequest() function in grpc::ServerInterface::RegisteredAsyncRequest
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/server/ |
| D | server_cc.cc | 210 void ServerInterface::RegisteredAsyncRequest::IssueRequest( in IssueRequest() function in grpc::ServerInterface::RegisteredAsyncRequest
|