| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | rendezvous_mgr.cc | 166 void RefCountedIntraProcessRendezvous::StartAbort(const Status& s) { in StartAbort() function in tensorflow::RefCountedIntraProcessRendezvous
167 local_.StartAbort(s); in StartAbort()
192 void PrivateIntraProcessRendezvous::StartAbort(const Status& s) { in StartAbort() function in tensorflow::PrivateIntraProcessRendezvous
193 local_.StartAbort(s); in StartAbort()
|
| D | ring_reducer.cc | 149 StartAbort(s); in ContinueAfterInputCopy()
242 StartAbort(s); in RunAsyncParts()
263 StartAbort(s); in RunAsyncParts()
279 StartAbort(s); in RunAsyncParts()
295 StartAbort(s); in RunAsyncParts()
|
| D | rendezvous_mgr.h | 52 void StartAbort(const Status& status) override;
81 void StartAbort(const Status& status) override;
|
| D | buf_rendezvous_test.cc | 195 br_->StartAbort(errors::Internal("Falling sky detected")); in TEST_F()
205 br_->StartAbort(errors::Internal("Falling sky detected")); in TEST_F()
209 br_->StartAbort(errors::Internal("Falling sky detected")); in TEST_F()
|
| 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 | base_collective_executor.cc | 216 void BaseCollectiveExecutor::StartAbort(const Status& s) { in StartAbort() function in tensorflow::BaseCollectiveExecutor
218 remote_access_->StartAbort(s); in StartAbort()
235 remote_access_->buf_rendezvous()->StartAbort(s); in ExecuteAsync()
|
| D | ring_gatherer.cc | 192 StartAbort(s); in RunAsyncParts()
221 StartAbort(s); in RunAsyncParts()
|
| D | buf_rendezvous.h | 50 void StartAbort(const Status& s);
|
| D | ring_alg.h | 53 void StartAbort(const Status& s);
|
| D | collective_rma_local.h | 41 void StartAbort(const Status& s) override;
|
| D | base_collective_executor.h | 109 void StartAbort(const Status& s) override;
|
| D | executor.h | 224 error_rendez->StartAbort( in WhenDone()
|
| D | ring_alg.cc | 271 void RingAlg::StartAbort(const Status& s) { in StartAbort() function in tensorflow::RingAlg
289 col_ctx_->col_exec->StartAbort(s); in StartAbort()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | base_rendezvous_mgr.cc | 41 rendez->StartAbort(s); in StartAbortRendevous()
391 void BaseRemoteRendezvous::StartAbort(const Status& s) { in StartAbort() function in tensorflow::BaseRemoteRendezvous
399 local_->StartAbort(derived_status); in StartAbort()
407 entry.first->StartAbort(derived_status); in StartAbort()
426 call->StartAbort(captured_status); in RegisterCall()
439 call->StartAbort(errors::Cancelled("RecvFromRemoteAsync is cancelled.")); in RegisterCall()
445 call->StartAbort(errors::Cancelled("RecvFromRemoteAsync is cancelled.")); in RegisterCall()
|
| D | base_rendezvous_mgr.h | 138 void StartAbort(const Status& status) override;
236 virtual void StartAbort(const Status& s) = 0;
|
| D | collective_rma_distributed.cc | 183 void CollectiveRemoteAccessDistributed::StartAbort(const Status& s) { in StartAbort() function in tensorflow::CollectiveRemoteAccessDistributed
184 CollectiveRemoteAccessLocal::StartAbort(s); in StartAbort()
|
| D | collective_rma_distributed.h | 45 void StartAbort(const Status& s) override;
|
| D | collective_rma_distributed_test.cc | 97 buf_rendezvous_.StartAbort(errors::Internal("Cancelled")); in RecvBufAsync()
364 rma_->StartAbort(errors::Internal("Deliberate Failure")); in TEST_F()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | rendezvous.cc | 166 void StartAbort(const Status& status) override { impl_.StartAbort(status); } in StartAbort() function in tensorflow::__anon91e37a3e0211::LocalRendezvousWrapper
|
| D | local_rendezvous.h | 47 void StartAbort(const Status& status);
|
| D | local_rendezvous.cc | 100 StartAbort(errors::Cancelled("LocalRendezvous deleted")); in ~LocalRendezvous()
278 void LocalRendezvous::StartAbort(const Status& status) { in StartAbort() function in tensorflow::LocalRendezvous
|
| D | rendezvous.h | 115 virtual void StartAbort(const Status& status) = 0;
|
| D | collective.h | 275 virtual void StartAbort(const Status& s) {} in StartAbort() function
352 virtual void StartAbort(const Status& s) = 0;
|
| 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::__anon2172b4f90111::DummyRendezvous
|