| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_remote_worker.cc | 74 void GetStatusAsync(CallOptions* call_opts, const GetStatusRequest* request, in GetStatusAsync()
87 void DeleteWorkerSessionAsync(CallOptions* call_opts, in DeleteWorkerSessionAsync()
107 void RunGraphAsync(CallOptions* call_opts, const RunGraphRequest* request, in RunGraphAsync()
111 void RunGraphAsync(CallOptions* call_opts, RunGraphRequestWrapper* request, in RunGraphAsync()
130 void RecvBufAsync(CallOptions* call_opts, const RecvBufRequest* request, in RecvBufAsync()
176 void CompleteGroupAsync(CallOptions* call_opts, in CompleteGroupAsync()
184 void CompleteInstanceAsync(CallOptions* call_opts, in CompleteInstanceAsync()
198 void RecvTensorAsync(CallOptions* call_opts, const RecvTensorRequest* request, in RecvTensorAsync()
274 StatusCallback done, CallOptions* call_opts = nullptr, in IssueRequest()
283 CallOptions* call_opts = nullptr) { in IssueRequest()
|
| D | grpc_worker_service.cc | 244 CallOptions* call_opts = new CallOptions; in RunGraphHandler() local
270 CallOptions* call_opts = new CallOptions; in RecvTensorHandlerRaw() local
289 CallOptions* call_opts = new CallOptions; in RecvBufHandler() local
307 CallOptions* call_opts = new CallOptions; in CompleteGroupHandler() local
326 CallOptions* call_opts = new CallOptions; in CompleteInstanceHandler() local
|
| D | grpc_master_service.cc | 186 CallOptions* call_opts = new CallOptions; in RunStepHandler() local
260 CallOptions* call_opts = new CallOptions; in RunCallableHandler() local
|
| D | grpc_state.h | 88 Response* response, StatusCallback done, CallOptions* call_opts, in RPCState()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/coordination/ |
| D | grpc_coordination_client.cc | 74 void RegisterTaskAsync(CallOptions* call_opts, in RegisterTaskAsync()
95 void ShutdownTaskAsync(CallOptions* call_opts, in ShutdownTaskAsync()
116 void HeartbeatAsync(CallOptions* call_opts, const HeartbeatRequest* request, in HeartbeatAsync()
128 void ReportErrorToTaskAsync(CallOptions* call_opts, in ReportErrorToTaskAsync()
159 void GetKeyValueAsync(CallOptions* call_opts, in GetKeyValueAsync()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/coordination/ |
| D | coordination_service_agent_test.cc | 94 void HeartbeatAsync(CallOptions* call_opts, const HeartbeatRequest* request, in HeartbeatAsync()
99 void ReportErrorToTaskAsync(CallOptions* call_opts, in ReportErrorToTaskAsync()
278 WithArgs<0, 3>([](CallOptions* call_opts, StatusCallback done) { in TEST_F()
|
| D | coordination_service_agent.cc | 249 CallOptions call_opts; in Connect() local
287 CallOptions call_opts; in Connect() local
413 CallOptions call_opts; in Shutdown() local
523 auto call_opts = std::make_shared<CallOptions>(); in GetKeyValueAsync() local
|
| D | coordination_service.cc | 701 auto call_opts = std::make_shared<CallOptions>(); in ReportServiceErrorToTaskAsync() local
733 CallOptions call_opts; in PropagateError() local
|
| D | coordination_service_test.cc | 75 void ReportErrorToTaskAsync(CallOptions* call_opts, in ReportErrorToTaskAsync()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | remote_execute_node.cc | 55 auto call_opts = std::make_shared<CallOptions>(); in RunAsync() local
|
| D | eager_service_impl.cc | 463 CallOptions* call_opts, const RunComponentFunctionRequest* request, in RunComponentFunction()
550 Status EagerServiceImpl::ExecuteOp(CallOptions* call_opts, in ExecuteOp()
589 Status EagerServiceImpl::Enqueue(CallOptions* call_opts, in Enqueue()
|
| D | eager_service_impl_test.cc | 95 void EnqueueAsync(CallOptions* call_opts, const EnqueueRequest* request, in EnqueueAsync()
100 void RunComponentFunctionAsync(CallOptions* call_opts, in RunComponentFunctionAsync()
108 CallOptions* call_opts, in StreamingEnqueueAsync()
534 CallOptions call_opts; in TestFunction() local
627 CallOptions call_opts; in TestComponentFunction() local
|
| D | cluster_function_library_runtime.cc | 205 auto call_opts = std::make_shared<CallOptions>(); in Run() local
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | worker_interface.h | 220 CallOptions call_opts; in CallAndWaitWithOptions() local
|
| D | master_session.cc | 649 int64_t execution_count, PerStepState* pss, CallOptions* call_opts, in RunPartitionsHelper()
813 PerStepState* pss, CallOptions* call_opts, const RunStepRequestWrapper& req, in RunPartitions()
838 PerStepState* pss, CallOptions* call_opts, const RunCallableRequest& req, in RunPartitions()
1434 CallOptions call_opts; in DeleteWorkerSessions() member
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_client.cc | 192 CallOptions* call_opts, in StreamingEnqueueAsync()
|