Home
last modified time | relevance | path

Searched refs:SetCancelCallback (Results 1 – 12 of 12) sorted by relevance

/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()
475 opts->SetCancelCallback( in GrpcRecvTensorAsync()
Dgrpc_master_service.cc196 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in RunStepHandler()
264 call->SetCancelCallback([call_opts]() { call_opts->StartCancel(); }); in RunCallableHandler()
Dgrpc_state.h87 call_opts_->SetCancelCallback([this]() { context_->TryCancel(); }); in StartCall()
Dgrpc_call.h180 void SetCancelCallback(std::function<void()> callback) { in SetCancelCallback() function
/external/tensorflow/tensorflow/core/distributed_runtime/
Dcall_options_test.cc27 opts.SetCancelCallback([&num_calls]() { num_calls++; }); in TEST()
Dcall_options.h60 void SetCancelCallback(CancelFunction cancel_func);
Dcall_options.cc34 void CallOptions::SetCancelCallback(CancelFunction cancel_func) { in SetCancelCallback() function in tensorflow::CallOptions
Dworker.cc208 opts->SetCancelCallback([this, cm, step_id]() { in DoRunGraph()
300 opts->SetCancelCallback([this, cm, step_id]() { in DoPartialRunGraph()
Dcollective_rma_distributed_test.cc87 opts->SetCancelCallback([this]() { in RecvBufAsync()
Dmaster_session.cc693 call_opts->SetCancelCallback([&calls]() { calls.StartCancel(); }); in RunPartitionsHelper()
/external/tensorflow/tensorflow/contrib/gdr/
Dgdr_worker.cc76 opts->SetCancelCallback([this, step_id]() { AbortStep(step_id); }); in GrpcRecvTensorAsync()
/external/libchrome/mojo/core/
Dtrap_unittest.cc54 context->SetCancelCallback( in CreateContextWithCancel()
70 void SetCancelCallback(base::OnceClosure cancel_callback) { in SetCancelCallback() function in mojo::core::__anon696ef0640111::TriggerHelper::NotificationContext