| /external/tensorflow/tensorflow/core/nccl/ |
| D | collective_communicator.cc | 38 void StartAbort(const Status& s) override;
103 nccl_manager_.StartAbort(errors::Cancelled("op cancelled")); in Enqueue()
204 void NcclCommunicator::StartAbort(const Status& s) { in StartAbort() function in tensorflow::NcclCommunicator
205 nccl_manager_.StartAbort(s); in StartAbort()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | base_collective_executor.cc | 232 void BaseCollectiveExecutor::StartAbort(const Status& s) { in StartAbort() function in tensorflow::BaseCollectiveExecutor
250 cem_->GetParamResolver()->StartAbort(status); in StartAbort()
251 remote_access_->StartAbort(status); in StartAbort()
253 cem_->GetNcclCommunicator()->StartAbort(status); in StartAbort()
284 StartAbort(s); in ExecuteAsync()
299 StartAbort(status); in ExecuteAsync()
380 StartAbort(s); in CompleteParamsAsync()
396 StartAbort(status); in CompleteParamsAsync()
|
| 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.cc | 190 void RefCountedIntraProcessRendezvous::StartAbort(const Status& s) { in StartAbort() function in tensorflow::RefCountedIntraProcessRendezvous
191 local_.StartAbort(s); in StartAbort()
220 void PrivateIntraProcessRendezvous::StartAbort(const Status& s) { in StartAbort() function in tensorflow::PrivateIntraProcessRendezvous
221 local_.StartAbort(s); in StartAbort()
|
| D | rendezvous_mgr.h | 52 void StartAbort(const Status& status) override;
88 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 | 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 | collective_rma_local.h | 38 void StartAbort(const Status& s) override;
|
| D | buf_rendezvous.h | 51 void StartAbort(const Status& s);
|
| D | ring_alg.h | 48 void StartAbort(const Status& s);
|
| D | base_collective_executor.h | 110 void StartAbort(const Status& s) override TF_LOCKS_EXCLUDED(status_mu_);
|
| D | test_collective_executor_mgr.h | 67 void StartAbort(const Status& s) override {} in StartAbort() function
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | base_rendezvous_mgr.cc | 44 rendez->StartAbort(s); in StartAbortRendevous()
389 void BaseRemoteRendezvous::StartAbort(const Status& s) { in StartAbort() function in tensorflow::BaseRemoteRendezvous
400 local_->StartAbort(derived_status); in StartAbort()
416 call->StartAbort(derived_status); in StartAbort()
432 call->StartAbort(status_); in RegisterCall()
448 call->StartAbort( in RegisterCall()
462 call->StartAbort(errors::Cancelled("RecvFromRemoteAsync is cancelled.")); in RegisterCall()
|
| D | base_rendezvous_mgr.h | 147 void StartAbort(const Status& status) override;
253 virtual void StartAbort(const Status& s) = 0;
|
| D | collective_rma_distributed.h | 52 void StartAbort(const Status& s) override;
|
| D | collective_rma_distributed.cc | 294 void CollectiveRemoteAccessDistributed::StartAbort(const Status& s) { in StartAbort() function in tensorflow::CollectiveRemoteAccessDistributed
295 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 | 215 virtual void StartAbort(const Status& s) = 0;
306 virtual void StartAbort(const Status& s) = 0;
313 virtual void StartAbort(const Status& s) {} in StartAbort() function
423 virtual void StartAbort(const Status& s) = 0;
|
| D | rendezvous.cc | 167 void StartAbort(const Status& status) override { impl_.StartAbort(status); } in StartAbort() function in tensorflow::__anon47894ff80211::LocalRendezvousWrapper
|
| D | local_rendezvous.h | 52 void StartAbort(const Status& status);
|
| D | local_rendezvous.cc | 111 StartAbort(errors::Cancelled("LocalRendezvous deleted")); in ~LocalRendezvous()
357 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::__anonb2e52ef30111::DummyRendezvous
|