| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | ring_reducer.cc | 130 StartAbort(s); in ContinueAfterInputCopy()
218 StartAbort(s); in RunAsyncParts()
239 StartAbort(s); in RunAsyncParts()
254 StartAbort(s); in RunAsyncParts()
269 StartAbort(s); in RunAsyncParts()
|
| D | buf_rendezvous_test.cc | 159 br_->StartAbort(errors::Internal("Falling sky detected")); in TEST_F()
169 br_->StartAbort(errors::Internal("Falling sky detected")); in TEST_F()
173 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 | 213 void BaseCollectiveExecutor::StartAbort(const Status& s) { in StartAbort() function in tensorflow::BaseCollectiveExecutor
215 remote_access_->StartAbort(s); in StartAbort()
232 remote_access_->buf_rendezvous()->StartAbort(s); in ExecuteAsync()
|
| D | rendezvous_mgr.cc | 156 void IntraProcessRendezvous::StartAbort(const Status& s) { in StartAbort() function in tensorflow::IntraProcessRendezvous
158 local_->StartAbort(s); in StartAbort()
|
| D | ring_gatherer.cc | 182 StartAbort(s); in RunAsyncParts()
210 StartAbort(s); in RunAsyncParts()
|
| D | rendezvous_mgr.h | 56 void StartAbort(const Status& status) override;
|
| D | buf_rendezvous.h | 47 void StartAbort(const Status& s);
|
| D | collective_rma_local.h | 37 void StartAbort(const Status& s) override;
|
| D | ring_alg.h | 52 void StartAbort(const Status& s);
|
| D | executor.h | 206 error_rendez->StartAbort( in WhenDone()
|
| D | base_collective_executor.h | 108 void StartAbort(const Status& s) override;
|
| D | buf_rendezvous.cc | 32 void BufRendezvous::StartAbort(const Status& s) { in StartAbort() function in tensorflow::BufRendezvous
|
| 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 | 39 rendez->StartAbort(s); in StartAbortRendevous()
364 void BaseRemoteRendezvous::StartAbort(const Status& s) { in StartAbort() function in tensorflow::BaseRemoteRendezvous
366 local_->StartAbort(s); in StartAbort()
373 call->StartAbort(s); in StartAbort()
383 call->StartAbort(status_); in RegisterCall()
|
| D | base_rendezvous_mgr.h | 138 void StartAbort(const Status& status) override;
229 virtual void StartAbort(const Status& s) = 0;
|
| D | collective_rma_distributed.cc | 181 void CollectiveRemoteAccessDistributed::StartAbort(const Status& s) { in StartAbort() function in tensorflow::CollectiveRemoteAccessDistributed
182 CollectiveRemoteAccessLocal::StartAbort(s); in StartAbort()
|
| D | collective_rma_distributed.h | 43 void StartAbort(const Status& s) override;
|
| D | collective_rma_distributed_test.cc | 95 buf_rendezvous_.StartAbort(errors::Internal("Cancelled")); in RecvBufAsync()
347 rma_->StartAbort(errors::Internal("Deliberate Failure")); in TEST_F()
|
| /external/tensorflow/tensorflow/contrib/gdr/ |
| D | gdr_collective_executor_mgr.cc | 137 void StartAbort(const Status& s) override { in StartAbort() function in tensorflow::__anonf551392e0111::CollectiveRemoteAccessDistributed
138 CollectiveRemoteAccessLocal::StartAbort(s); in StartAbort()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | rendezvous_test.cc | 239 rendez_->StartAbort(errors::Aborted("")); // abort in TEST_F()
255 rendez_->StartAbort(errors::Aborted("")); // abort in TEST_F()
266 rendez_->StartAbort(errors::Aborted("")); in TEST_F()
|
| D | collective.h | 259 virtual void StartAbort(const Status& s) {} in StartAbort() function
336 virtual void StartAbort(const Status& s) = 0;
|
| D | rendezvous.cc | 238 void StartAbort(const Status& status) override { in StartAbort() function in tensorflow::LocalRendezvousImpl
300 StartAbort(errors::Cancelled("LocalRendezvousImpl deleted")); in ~LocalRendezvousImpl()
|
| D | rendezvous.h | 121 virtual void StartAbort(const Status& status) = 0;
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | sendrecv_ops_test.cc | 39 void StartAbort(const Status& status) override {} in StartAbort() function in tensorflow::__anon9e3a346e0111::DummyRendezvous
|