| /external/tensorflow/tensorflow/core/framework/ |
| D | cancellation_test.cc | 49 manager->StartCancel(); in TEST()
57 manager->StartCancel(); in TEST()
70 manager->StartCancel(); in TEST()
90 manager->StartCancel(); in TEST()
116 cm->StartCancel(); in TEST()
136 cm.StartCancel(); in TEST()
167 manager->StartCancel(); in TEST()
186 manager->StartCancel(); in TEST()
206 parent.StartCancel(); in TEST()
216 child.StartCancel(); in TEST()
[all …]
|
| D | cancellation.cc | 38 void CancellationManager::StartCancel() { in StartCancel() function in tensorflow::CancellationManager
72 child->StartCancel(); in StartCancel()
200 StartCancel(); in ~CancellationManager()
|
| D | rendezvous_test.cc | 164 cm->StartCancel(); in TEST_F()
177 cm->StartCancel(); in TEST_F()
199 cm->StartCancel(); in TEST_F()
217 cm->StartCancel(); in TEST_F()
|
| D | cancellation.h | 64 void StartCancel();
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | call_options_test.cc | 25 opts.StartCancel(); in TEST()
29 opts.StartCancel(); in TEST()
31 opts.StartCancel(); in TEST()
35 opts.StartCancel(); in TEST()
|
| D | call_options.h | 44 void StartCancel();
|
| D | cancellable_call.cc | 45 opts_.StartCancel(); in Cancel()
|
| D | worker.cc | 208 cm->StartCancel(); in DoRunGraph()
214 token, [cm]() { cm->StartCancel(); }); in DoRunGraph()
306 cm->StartCancel(); in DoPartialRunGraph()
316 [cm]() { cm->StartCancel(); }); in DoPartialRunGraph()
|
| D | call_options.cc | 24 void CallOptions::StartCancel() { in StartCancel() function in tensorflow::CallOptions
|
| D | master_session.cc | 539 void StartCancel() { in StartCancel() function in tensorflow::__anon4940402c0411::RunManyGraphs
599 call.opts.StartCancel(); in ReportBadStatus()
749 calls.StartCancel(); in RunPartitionsHelper()
753 cm->RegisterCallback(token, [&calls]() { calls.StartCancel(); }); in RunPartitionsHelper()
755 calls.StartCancel(); in RunPartitionsHelper()
2113 cancellation_manager_.StartCancel(); in Close()
2140 cancellation_manager_.StartCancel(); in GarbageCollect()
|
| D | collective_rma_distributed.cc | 252 abortion_cancel_mgr_.StartCancel(); in StartAbort()
|
| D | local_master.cc | 36 call_options->StartCancel(); in WaitForNotification()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | buf_rendezvous_test.cc | 282 cm_.StartCancel(); in TEST_F()
294 cm_.StartCancel(); in TEST_F()
320 cm_.StartCancel(); in TEST_F()
332 cm_.StartCancel(); in TEST_F()
377 cm_.StartCancel(); in TEST_F()
389 cm_.StartCancel(); in TEST_F()
|
| D | collective_rma_local_test.cc | 184 cm_->StartCancel(); in TEST_F()
198 cm_->StartCancel(); in TEST_F()
227 cm_->StartCancel(); in TEST_F()
241 cm_->StartCancel(); in TEST_F()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service_impl.h | 77 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in EnqueueHandler()
94 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in RunComponentFunctionHandler()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_worker_service.cc | 248 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in RunGraphHandler()
270 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in RecvTensorHandlerRaw()
289 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in RecvBufHandler()
307 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in CompleteGroupHandler()
326 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in CompleteInstanceHandler()
|
| D | rpc_rendezvous_mgr.cc | 111 opts_.StartCancel(); in StartAbort()
165 opts_.StartCancel(); in StartRTCall()
|
| D | grpc_master_service.cc | 196 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in RunStepHandler()
263 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in RunCallableHandler()
|
| D | rpc_rendezvous_mgr_test.cc | 205 cm->StartCancel(); in TEST_F()
230 cm->StartCancel(); in TEST_F()
|
| /external/protobuf/python/google/protobuf/ |
| D | service.py | 154 def StartCancel(self): member in RpcController
|
| /external/protobuf/src/google/protobuf/ |
| D | service.h | 231 virtual void StartCancel() = 0;
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/ |
| D | health_check_client.h | 82 static void StartCancel(void* arg, grpc_error* error);
|
| D | health_check_client.cc | 416 void HealthCheckClient::CallState::StartCancel(void* arg, in StartCancel() function in grpc_core::HealthCheckClient::CallState
434 GRPC_CLOSURE_CREATE(StartCancel, this, grpc_schedule_on_exec_ctx), in Cancel()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | remote_execute_node.cc | 58 token, [call_opts, response, done]() { call_opts->StartCancel(); }); in RunAsync()
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | iterator_ops.h | 88 ~State() { cancellation_manager_.StartCancel(); } in ~State()
|