| /external/tensorflow/tensorflow/core/nccl/ |
| D | collective_communicator.cc | 34 void StartAbort(const Status& s) override;
91 nccl_manager_.StartAbort(errors::Cancelled("op cancelled")); in Enqueue()
201 void NcclCommunicator::StartAbort(const Status& s) { in StartAbort() function in tensorflow::NcclCommunicator
202 nccl_manager_.StartAbort(s); in StartAbort()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | base_collective_executor.cc | 226 void BaseCollectiveExecutor::StartAbort(const Status& s) { in StartAbort() function in tensorflow::BaseCollectiveExecutor
244 cem_->GetParamResolver()->StartAbort(status); in StartAbort()
245 remote_access_->StartAbort(status); in StartAbort()
247 cem_->GetNcclCommunicator()->StartAbort(status); in StartAbort()
278 StartAbort(s); in ExecuteAsync()
293 StartAbort(status); in ExecuteAsync()
367 StartAbort(s); in CompleteParamsAsync()
383 StartAbort(status); in CompleteParamsAsync()
|
| D | rendezvous_mgr.cc | 173 void RefCountedIntraProcessRendezvous::StartAbort(const Status& s) { in StartAbort() function in tensorflow::RefCountedIntraProcessRendezvous
174 local_.StartAbort(s); in StartAbort()
199 void PrivateIntraProcessRendezvous::StartAbort(const Status& s) { in StartAbort() function in tensorflow::PrivateIntraProcessRendezvous
200 local_.StartAbort(s); in StartAbort()
|
| D | ring_reducer.cc | 148 StartAbort(s); in ContinueAfterInputCopy()
241 StartAbort(s); in RunAsyncParts()
262 StartAbort(s); in RunAsyncParts()
277 StartAbort(s); in RunAsyncParts()
293 StartAbort(s); in RunAsyncParts()
|
| D | rendezvous_mgr.h | 52 void StartAbort(const Status& status) override;
81 void StartAbort(const Status& status) override;
|
| D | collective_rma_local.cc | 22 void CollectiveRemoteAccessLocal::StartAbort(const Status& s) { in StartAbort() function in tensorflow::CollectiveRemoteAccessLocal
23 buf_rendezvous_.StartAbort(s); in StartAbort()
|
| D | ring_gatherer.cc | 191 StartAbort(s); in RunAsyncParts()
220 StartAbort(s); in RunAsyncParts()
|
| D | collective_param_resolver_local_test.cc | 340 prl_->StartAbort(Status(error::ABORTED, "__aborted__")); in TEST_F()
390 prl_->StartAbort(Status(error::ABORTED, "__aborted__")); in TEST_F()
420 prl_->StartAbort(Status(error::ABORTED, "__aborted__")); in TEST_F()
491 prl_->StartAbort(Status(error::ABORTED, "__aborted__")); in TEST_F()
|
| D | collective_rma_local.h | 38 void StartAbort(const Status& s) override;
|
| D | buf_rendezvous_test.cc | 211 br_->StartAbort(errors::Internal("Falling sky detected")); in TEST_F()
221 br_->StartAbort(errors::Internal("Falling sky detected")); in TEST_F()
225 br_->StartAbort(errors::Internal("Falling sky detected")); in TEST_F()
|
| D | buf_rendezvous.h | 51 void StartAbort(const Status& s);
|
| D | ring_alg.h | 54 void StartAbort(const Status& s);
|
| D | test_collective_executor_mgr.h | 59 void StartAbort(const Status& s) override { return; } in StartAbort() function
|
| D | base_collective_executor.h | 111 void StartAbort(const Status& s) override TF_LOCKS_EXCLUDED(status_mu_);
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | base_rendezvous_mgr.cc | 42 rendez->StartAbort(s); in StartAbortRendevous()
375 void BaseRemoteRendezvous::StartAbort(const Status& s) { in StartAbort() function in tensorflow::BaseRemoteRendezvous
386 local_->StartAbort(derived_status); in StartAbort()
393 entry.first->StartAbort(derived_status); in StartAbort()
409 call->StartAbort(status_); in RegisterCall()
418 call->StartAbort( in RegisterCall()
425 call->StartAbort(errors::Cancelled("RecvFromRemoteAsync is cancelled.")); in RegisterCall()
|
| D | base_rendezvous_mgr.h | 135 void StartAbort(const Status& status) override;
229 virtual void StartAbort(const Status& s) = 0;
|
| D | collective_rma_distributed.h | 52 void StartAbort(const Status& s) override;
|
| D | collective_rma_distributed.cc | 250 void CollectiveRemoteAccessDistributed::StartAbort(const Status& s) { in StartAbort() function in tensorflow::CollectiveRemoteAccessDistributed
251 CollectiveRemoteAccessLocal::StartAbort(s); in StartAbort()
|
| D | collective_param_resolver_distributed.h | 51 void StartAbort(const Status& s) override;
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | collective.h | 200 virtual void StartAbort(const Status& s) = 0;
291 virtual void StartAbort(const Status& s) = 0;
298 virtual void StartAbort(const Status& s) {} in StartAbort() function
394 virtual void StartAbort(const Status& s) = 0;
|
| D | rendezvous.cc | 166 void StartAbort(const Status& status) override { impl_.StartAbort(status); } in StartAbort() function in tensorflow::__anon913b3c930211::LocalRendezvousWrapper
|
| D | local_rendezvous.h | 51 void StartAbort(const Status& status);
|
| D | local_rendezvous.cc | 101 StartAbort(errors::Cancelled("LocalRendezvous deleted")); in ~LocalRendezvous()
314 void LocalRendezvous::StartAbort(const Status& status) { in StartAbort() function in tensorflow::LocalRendezvous
|
| D | rendezvous_test.cc | 361 rendez_->StartAbort(errors::Aborted("")); // abort in TEST_F()
377 rendez_->StartAbort(errors::Aborted("")); // abort in TEST_F()
388 rendez_->StartAbort(errors::Aborted("")); in TEST_F()
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | sendrecv_ops_test.cc | 39 void StartAbort(const Status& status) override {} in StartAbort() function in tensorflow::__anon9e3a346e0111::DummyRendezvous
|