HomeSort by relevance Sort by last modified time
    Searched refs:StartCancel (Results 1 - 24 of 24) sorted by null

  /external/tensorflow/tensorflow/core/distributed_runtime/
call_options_test.cc 25 opts.StartCancel();
29 opts.StartCancel();
31 opts.StartCancel();
35 opts.StartCancel();
call_options.h 40 // The caller may call StartCancel() anytime as long as this
44 void StartCancel();
call_options.cc 24 void CallOptions::StartCancel() {
28 // that ClearCancelCallback() does not race with StartCancel().
cancellable_call.h 44 token, [this, token]() { opts_.StartCancel(); });
worker.cc 209 cm->StartCancel();
215 token, [cm]() { cm->StartCancel(); });
301 cm->StartCancel();
311 [cm]() { cm->StartCancel(); });
collective_rma_distributed.cc 183 cancel_mgr_.StartCancel();
local_master.cc 36 call_options->StartCancel();
master_session.cc 524 void StartCancel() {
547 call.opts.StartCancel();
693 call_opts->SetCancelCallback([&calls]() { calls.StartCancel(); });
696 cm->RegisterCallback(token, [&calls]() { calls.StartCancel(); });
698 calls.StartCancel();
    [all...]
  /external/tensorflow/tensorflow/core/util/rpc/
call_container.h 79 void StartCancel();
137 StartCancel();
153 StartCancel();
167 void CallContainer<Call>::StartCancel() {
169 call.StartCancel();
  /external/tensorflow/tensorflow/core/framework/
cancellation_test.cc 45 manager->StartCancel();
53 manager->StartCancel();
66 manager->StartCancel();
86 manager->StartCancel();
111 cm->StartCancel();
138 manager->StartCancel();
157 manager->StartCancel();
cancellation.h 54 void StartCancel();
56 // Returns true iff StartCancel() has been called.
133 // This method is guaranteed to return true if StartCancel has not been
cancellation.cc 36 void CancellationManager::StartCancel() {
88 // execution of any currently pending callbacks in StartCancel.
110 StartCancel();
  /external/protobuf/python/google/protobuf/
service.py 154 def StartCancel(self):
  /external/protobuf/src/google/protobuf/
service.h 230 virtual void StartCancel() = 0;
  /external/tensorflow/tensorflow/core/distributed_runtime/rpc/
grpc_master_service.cc 196 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); });
264 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); });
grpc_rpc_factory.cc 47 void StartCancel() { call_opts_.StartCancel(); }
grpc_worker_service.cc 231 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); });
266 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); });
296 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); });
314 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); });
333 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); });
rpc_rendezvous_mgr.cc 110 opts_.StartCancel();
  /external/tensorflow/tensorflow/contrib/gdr/
gdr_collective_executor_mgr.cc 139 cancel_mgr_.StartCancel();
gdr_rendezvous_mgr.cc 90 opts_.StartCancel();
  /external/tensorflow/tensorflow/core/kernels/data/
map_defun_op.cc 103 token, [c_mgr]() { c_mgr->StartCancel(); });
  /external/tensorflow/tensorflow/core/common_runtime/
direct_session.cc 591 step_cancellation_manager.StartCancel();
    [all...]
executor.cc     [all...]
  /external/protobuf/src/google/protobuf/compiler/cpp/
cpp_unittest.cc     [all...]

Completed in 1071 milliseconds