Home
last modified time | relevance | path

Searched refs:StartCancel (Results 1 – 24 of 24) sorted by relevance

/external/tensorflow/tensorflow/core/distributed_runtime/
Dcall_options_test.cc25 opts.StartCancel(); in TEST()
29 opts.StartCancel(); in TEST()
31 opts.StartCancel(); in TEST()
35 opts.StartCancel(); in TEST()
Dworker.cc209 cm->StartCancel(); in DoRunGraph()
215 token, [cm]() { cm->StartCancel(); }); in DoRunGraph()
301 cm->StartCancel(); in DoPartialRunGraph()
311 [cm]() { cm->StartCancel(); }); in DoPartialRunGraph()
Dcall_options.h44 void StartCancel();
Dcall_options.cc24 void CallOptions::StartCancel() { in StartCancel() function in tensorflow::CallOptions
Dcancellable_call.h44 token, [this, token]() { opts_.StartCancel(); }); in Start()
Dcollective_rma_distributed.cc183 cancel_mgr_.StartCancel(); in StartAbort()
Dmaster_session.cc524 void StartCancel() { in StartCancel() function in tensorflow::RunManyGraphs
547 call.opts.StartCancel(); in ReportBadStatus()
693 call_opts->SetCancelCallback([&calls]() { calls.StartCancel(); }); in RunPartitionsHelper()
696 cm->RegisterCallback(token, [&calls]() { calls.StartCancel(); }); in RunPartitionsHelper()
698 calls.StartCancel(); in RunPartitionsHelper()
2014 cancellation_manager_.StartCancel(); in Close()
2041 cancellation_manager_.StartCancel(); in GarbageCollect()
Dlocal_master.cc36 call_options->StartCancel(); in WaitForNotification()
/external/tensorflow/tensorflow/core/framework/
Dcancellation_test.cc45 manager->StartCancel(); in TEST()
53 manager->StartCancel(); in TEST()
66 manager->StartCancel(); in TEST()
86 manager->StartCancel(); in TEST()
111 cm->StartCancel(); in TEST()
138 manager->StartCancel(); in TEST()
157 manager->StartCancel(); in TEST()
Dcancellation.cc36 void CancellationManager::StartCancel() { in StartCancel() function in tensorflow::CancellationManager
110 StartCancel(); in ~CancellationManager()
Dcancellation.h54 void StartCancel();
/external/tensorflow/tensorflow/core/util/rpc/
Dcall_container.h79 void StartCancel();
137 StartCancel(); in CallContainer()
153 StartCancel(); in CallContainer()
167 void CallContainer<Call>::StartCancel() { in StartCancel() function
169 call.StartCancel(); in StartCancel()
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_worker_service.cc231 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in RunGraphHandler()
266 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in RecvTensorHandlerRaw()
296 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in RecvBufHandler()
314 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in CompleteGroupHandler()
333 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in CompleteInstanceHandler()
Dgrpc_rpc_factory.cc47 void StartCancel() { call_opts_.StartCancel(); } in StartCancel() function in tensorflow::internal::GrpcCall
Dgrpc_master_service.cc196 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in RunStepHandler()
264 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in RunCallableHandler()
Drpc_rendezvous_mgr.cc110 opts_.StartCancel(); in StartAbort()
/external/protobuf/python/google/protobuf/
Dservice.py154 def StartCancel(self): member in RpcController
/external/protobuf/src/google/protobuf/
Dservice.h230 virtual void StartCancel() = 0;
/external/tensorflow/tensorflow/contrib/gdr/
Dgdr_collective_executor_mgr.cc139 cancel_mgr_.StartCancel(); in StartAbort()
Dgdr_rendezvous_mgr.cc90 opts_.StartCancel(); in StartAbort()
/external/tensorflow/tensorflow/core/kernels/data/
Dmap_defun_op.cc103 token, [c_mgr]() { c_mgr->StartCancel(); }); in ComputeAsync()
/external/tensorflow/tensorflow/core/common_runtime/
Ddirect_session.cc591 step_cancellation_manager.StartCancel(); in RunInternal()
1631 cancellation_manager_->StartCancel(); in Close()
1697 cm->StartCancel(); in WaitForNotification()
Dexecutor.cc2234 cancellation_manager_->StartCancel(); in NodeDone()
2503 cancellation_manager_->StartCancel(); in Finish()
/external/protobuf/src/google/protobuf/compiler/cpp/
Dcpp_unittest.cc1235 void StartCancel() { in StartCancel() function in google::protobuf::compiler::cpp::cpp_unittest::GeneratedServiceTest::MockController