Home
last modified time | relevance | path

Searched refs:wi_ (Results 1 – 6 of 6) sorted by relevance

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Drpc_rendezvous_mgr.cc60 RpcRecvTensorCall() : wi_(nullptr), dst_device_(nullptr) {} in RpcRecvTensorCall()
65 wi_ = wi; in Init()
78 DCHECK_EQ(static_cast<WorkerInterface*>(nullptr), wi_) in Reset()
98 CHECK_EQ(static_cast<WorkerInterface*>(nullptr), wi_) in ~RpcRecvTensorCall()
120 DCHECK_NE(static_cast<WorkerInterface*>(nullptr), wi_) in ReleaseWorker()
122 worker_cache->ReleaseWorker(src_worker_, wi_); in ReleaseWorker()
123 wi_ = nullptr; in ReleaseWorker()
152 wi_->RecvTensorAsync(&opts_, &req_, &resp_, std::move(cb)); in StartRTCall()
173 WorkerInterface* wi_; // Not owned. member in tensorflow::__anona9090a8f0111::RpcRecvTensorCall
/external/tensorflow/tensorflow/core/distributed_runtime/
Dcancellable_call.h36 wi_(wc_->GetOrCreateWorker(remote_worker_)) {} in CancellableCall()
38 virtual ~CancellableCall() { wc_->ReleaseWorker(remote_worker_, wi_); } in ~CancellableCall()
56 WorkerInterface* const wi_; // Owned by wc_, must be released. variable
Dremote_device_test.cc39 WorkerInterface* wi_; member in tensorflow::RemoteDeviceTest
59 wi_ = worker_cache_->GetOrCreateWorker(remote_name_); in RemoteDeviceTest()
63 worker_cache_->ReleaseWorker(remote_name_, wi_); in ~RemoteDeviceTest()
Dcollective_param_resolver_distributed.cc49 wi_->CompleteGroupAsync(&opts_, &req_, &resp_, done); in IssueCall()
82 wi_->CompleteInstanceAsync(&opts_, &req_, &resp_, done); in IssueCall()
Dcollective_rma_distributed.cc60 wi_->RecvBufAsync(&opts_, &req_, &resp_, done); in IssueCall()
/external/ImageMagick/PerlMagick/t/reference/write/filter/
DRadialBlur.miff43 …�<0�<8�;;�=>�=<�85�74�F:�^M�_N�XN�KB�HH�:I�1H�9O�>X�Cd�Lm�Us�Pk�Le�Lc�U]bF<wi_�������������ë�Ȳ����…