Searched refs:IssueRequest (Results 1 – 4 of 4) sorted by relevance
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_remote_worker.cc | 76 IssueRequest(request, response, getstatus_, std::move(done)); in GetStatusAsync()
82 IssueRequest(request, response, createworkersession_, std::move(done)); in CreateWorkerSessionAsync()
89 IssueRequest(request, response, deleteworkersession_, std::move(done), in DeleteWorkerSessionAsync()
96 IssueRequest(request, response, registergraph_, std::move(done)); in RegisterGraphAsync()
102 IssueRequest(request, response, deregistergraph_, std::move(done)); in DeregisterGraphAsync()
107 IssueRequest(request, response, rungraph_, std::move(done), call_opts); in RunGraphAsync()
112 IssueRequest(&request->ToProto(), get_proto_from_wrapper(response), in RunGraphAsync()
119 IssueRequest(request, response, cleanupgraph_, std::move(done)); in CleanupGraphAsync()
125 IssueRequest(request, response, cleanupall_, std::move(done)); in CleanupAllAsync()
167 IssueRequest(request, response, recvbuf_, *cb_to_use, 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/tensorflow/tensorflow/core/distributed_runtime/ |
| D | collective_param_resolver_distributed_test.cc | 216 IssueRequest(num_workers, num_devices, idx); in IssueRequests()
222 void IssueRequest(int num_workers, int num_devices, int idx) { in IssueRequest() function in tensorflow::__anonc2f8b6eb0111::DeviceResDistTest
|
| /external/grpc-grpc/src/cpp/server/ |
| D | server_cc.cc | 712 void ServerInterface::RegisteredAsyncRequest::IssueRequest( in IssueRequest() function in grpc::ServerInterface::RegisteredAsyncRequest
|