Home
last modified time | relevance | path

Searched refs:cancel_mgr (Results 1 – 10 of 10) sorted by relevance

/external/tensorflow/tensorflow/core/distributed_runtime/
Dcollective_param_resolver_distributed.cc28 CancellationManager* cancel_mgr, in CompleteGroupCall() argument
30 : CancellableCall(cancel_mgr, remote_worker, wc) { in CompleteGroupCall()
51 bool is_source, CancellationManager* cancel_mgr, in CompleteInstanceCall() argument
53 : CancellableCall(cancel_mgr, remote_worker, wc) { in CompleteInstanceCall()
96 const string& device, CollectiveParams* cp, CancellationManager* cancel_mgr, in CompleteParamsAsync() argument
100 CompleteGroupDistributed(device, cp, cancel_mgr, in CompleteParamsAsync()
101 [this, device, cp, cancel_mgr, done]( in CompleteParamsAsync()
105 cancel_mgr, done); in CompleteParamsAsync()
114 CancellationManager* cancel_mgr, const StatusCallback& done) { in CompleteGroupAsync() argument
123 cp.instance.device_names[0], &cp, cancel_mgr, in CompleteGroupAsync()
[all …]
Dcollective_param_resolver_distributed.h35 CancellationManager* cancel_mgr,
40 CancellationManager* cancel_mgr,
45 CancellationManager* cancel_mgr,
63 CancellationManager* cancel_mgr,
81 CancellationManager* cancel_mgr,
Dcancellable_call.h30 CancellableCall(CancellationManager* cancel_mgr, const string& remote_worker, in CancellableCall() argument
32 : cancel_mgr_(cancel_mgr), in CancellableCall()
Dcollective_rma_distributed.cc41 CancellationManager* cancel_mgr, WorkerCacheInterface* wc) in RecvBufCall() argument
42 : CancellableCall(cancel_mgr, peer_task, wc) { in RecvBufCall()
/external/tensorflow/tensorflow/core/framework/
Dcollective.h160 CancellationManager* cancel_mgr,
167 CancellationManager* cancel_mgr,
174 CancellationManager* cancel_mgr,
270 CancellationManager* cancel_mgr, in CompleteParamsAsync() argument
/external/tensorflow/tensorflow/core/common_runtime/
Dcollective_param_resolver_local.h48 CancellationManager* cancel_mgr,
53 CancellationManager* cancel_mgr,
58 CancellationManager* cancel_mgr,
Dbase_collective_executor.cc277 const string& device, CollectiveParams* cp, CancellationManager* cancel_mgr, in CompleteParamsAsync() argument
280 cem_->GetParamResolver()->CompleteParamsAsync(device, cp, cancel_mgr, done); in CompleteParamsAsync()
Dbase_collective_executor.h114 CancellationManager* cancel_mgr,
Dcollective_param_resolver_local.cc50 CancellationManager* cancel_mgr, const StatusCallback& done) { in CompleteGroupAsync() argument
585 const string& device, CollectiveParams* cp, CancellationManager* cancel_mgr, in CompleteParamsAsync() argument
602 CancellationManager* cancel_mgr, const StatusCallback& done) { in CompleteInstanceAsync() argument
/external/tensorflow/tensorflow/contrib/gdr/
Dgdr_collective_executor_mgr.cc42 CancellationManager* cancel_mgr, WorkerCacheInterface* wc) in RecvBufCall() argument
43 : CancellableCall(cancel_mgr, peer_task, wc) { in RecvBufCall()