Searched defs:call_opts (Results 1 – 11 of 11) sorted by relevance
/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() 175 void CompleteGroupAsync(CallOptions* call_opts, in CompleteGroupAsync() 183 void CompleteInstanceAsync(CallOptions* call_opts, in CompleteInstanceAsync() 197 void RecvTensorAsync(CallOptions* call_opts, const RecvTensorRequest* request, in RecvTensorAsync() 273 StatusCallback done, CallOptions* call_opts = nullptr, in IssueRequest() 282 CallOptions* call_opts = nullptr) { in IssueRequest()
|
D | grpc_worker_service.cc | 243 CallOptions* call_opts = new CallOptions; in RunGraphHandler() local 269 CallOptions* call_opts = new CallOptions; in RecvTensorHandlerRaw() local 288 CallOptions* call_opts = new CallOptions; in RecvBufHandler() local 306 CallOptions* call_opts = new CallOptions; in CompleteGroupHandler() local 325 CallOptions* call_opts = new CallOptions; in CompleteInstanceHandler() local
|
D | grpc_master_service.cc | 186 CallOptions* call_opts = new CallOptions; in RunStepHandler() local 258 CallOptions* call_opts = new CallOptions; in RunCallableHandler() local
|
D | grpc_state.h | 94 Response* response, StatusCallback done, CallOptions* call_opts, in RPCState()
|
/external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
D | remote_execute_node.cc | 54 auto call_opts = std::make_shared<CallOptions>(); in RunAsync() local
|
D | eager_service_impl.cc | 429 CallOptions* call_opts, const RunComponentFunctionRequest* request, in RunComponentFunction() 510 Status EagerServiceImpl::ExecuteOp(CallOptions* call_opts, in ExecuteOp() 549 Status EagerServiceImpl::Enqueue(CallOptions* call_opts, in Enqueue()
|
D | eager_service_impl_test.cc | 90 void EnqueueAsync(CallOptions* call_opts, const EnqueueRequest* request, in EnqueueAsync() 95 void RunComponentFunctionAsync(CallOptions* call_opts, in RunComponentFunctionAsync() 102 void StreamingEnqueueAsync(CallOptions* call_opts, in StreamingEnqueueAsync() 528 CallOptions call_opts; in TestFunction() local 621 CallOptions call_opts; in TestComponentFunction() local
|
D | cluster_function_library_runtime.cc | 206 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 | 645 int64 execution_count, PerStepState* pss, CallOptions* call_opts, in RunPartitionsHelper() 809 PerStepState* pss, CallOptions* call_opts, const RunStepRequestWrapper& req, in RunPartitions() 834 PerStepState* pss, CallOptions* call_opts, const RunCallableRequest& req, in RunPartitions() 1417 CallOptions call_opts; in DeleteWorkerSessions() member
|
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
D | grpc_eager_client.cc | 182 void StreamingEnqueueAsync(CallOptions* call_opts, in StreamingEnqueueAsync()
|