Home
last modified time | relevance | path

Searched refs:AwaitWithTimeout (Results 1 – 25 of 27) sorted by relevance

12

/external/tensorflow/tensorflow/compiler/xla/pjrt/distributed/
Dservice.cc114 if (!mu_.AwaitWithTimeout( in Connect()
184 if (!mu_.AwaitWithTimeout(absl::Condition(&all_nodes_shutting_down), in Shutdown()
229 if (!mu_.AwaitWithTimeout(absl::Condition(&all_topologies_present), in EnumerateDevices()
Dkey_value_store.cc31 if (!mu_.AwaitWithTimeout(absl::Condition(&key_is_present), timeout)) { in Get()
/external/tensorflow/tensorflow/compiler/xla/python/tpu_driver/
Dpod_tpu_driver.cc54 absl::optional<xla::Status> AwaitWithTimeout(
72 absl::optional<xla::Status> AwaitWithTimeout( in AwaitWithTimeout() function in tpu_driver::__anon2989b0910111::ErrorEvent
101 absl::optional<xla::Status> AwaitWithTimeout( in AwaitWithTimeout() function in tpu_driver::__anon2989b0910111::CombinedEvent
105 auto status = event->AwaitWithTimeout(duration); in AwaitWithTimeout()
746 auto status = mu_.AwaitWithTimeout(absl::Condition(&done), duration); in WaitForEvent()
761 return underlying_event->AwaitWithTimeout(duration); in WaitForEvent()
947 absl::optional<xla::Status> PodEvent::AwaitWithTimeout( in AwaitWithTimeout() function in tpu_driver::__anon2989b0910111::PodEvent
Dgrpc_tpu_driver.cc55 absl::optional<xla::Status> AwaitWithTimeout(
74 absl::optional<xla::Status> AwaitWithTimeout( in AwaitWithTimeout() function in tpu_driver::__anond0091eda0111::ErrorEvent
128 auto opt_status = OnReady()->AwaitWithTimeout(absl::Hours(1)); in program_shape()
450 absl::optional<Status> GrpcEvent::AwaitWithTimeout(absl::Duration duration) { in AwaitWithTimeout() function in tpu_driver::__anond0091eda0111::GrpcEvent
599 if (events_mutex_.AwaitWithTimeout(absl::Condition(&done), duration)) { in WaitForEvent()
Dtpu_driver.h57 virtual absl::optional<xla::Status> AwaitWithTimeout(
Drecording_tpu_driver.cc57 absl::optional<xla::Status> AwaitWithTimeout( in AwaitWithTimeout() function in tpu_driver::__anon041ad06b0111::RecordingEvent
59 return shared_event_->AwaitWithTimeout(duration); in AwaitWithTimeout()
Ddirect_tpu_driver.cc76 absl::optional<xla::Status> AwaitWithTimeout( in AwaitWithTimeout() function in tpu_driver::__anon66f609e90111::DirectEvent
/external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/
Dmutex_test.cc236 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
249 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
265 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(4)), in TestTime()
278 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
293 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
308 !cxt->mu.AwaitWithTimeout(false_cond, absl::Milliseconds(500)), in TestTime()
323 ABSL_RAW_CHECK(cxt->mu.AwaitWithTimeout(g0ge2, absl::Seconds(100)), in TestTime()
1415 : mu.AwaitWithTimeout(cond, params.wait_timeout);
Dmutex.h348 bool AwaitWithTimeout(const Condition &cond, absl::Duration timeout);
Dmutex.cc1548 bool Mutex::AwaitWithTimeout(const Condition &cond, absl::Duration timeout) { in AwaitWithTimeout() function in absl::Mutex
/external/abseil-cpp/absl/synchronization/
Dmutex_test.cc235 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
248 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
264 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(4)), in TestTime()
277 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
292 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
307 !cxt->mu.AwaitWithTimeout(false_cond, absl::Milliseconds(500)), in TestTime()
322 ABSL_RAW_CHECK(cxt->mu.AwaitWithTimeout(g0ge2, absl::Seconds(100)), in TestTime()
1414 : mu.AwaitWithTimeout(cond, params.wait_timeout);
Dmutex.h349 bool AwaitWithTimeout(const Condition &cond, absl::Duration timeout);
Dmutex.cc1547 bool Mutex::AwaitWithTimeout(const Condition &cond, absl::Duration timeout) { in AwaitWithTimeout() function in absl::Mutex
/external/webrtc/third_party/abseil-cpp/absl/synchronization/
Dmutex_test.cc235 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
248 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
264 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(4)), in TestTime()
277 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
292 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
307 !cxt->mu.AwaitWithTimeout(false_cond, absl::Milliseconds(500)), in TestTime()
322 ABSL_RAW_CHECK(cxt->mu.AwaitWithTimeout(g0ge2, absl::Seconds(100)), in TestTime()
1414 : mu.AwaitWithTimeout(cond, params.wait_timeout);
Dmutex.h349 bool AwaitWithTimeout(const Condition &cond, absl::Duration timeout);
/external/libtextclassifier/abseil-cpp/absl/synchronization/
Dmutex_test.cc236 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
249 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
265 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(4)), in TestTime()
278 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
293 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
308 !cxt->mu.AwaitWithTimeout(false_cond, absl::Milliseconds(500)), in TestTime()
323 ABSL_RAW_CHECK(cxt->mu.AwaitWithTimeout(g0ge2, absl::Seconds(100)), in TestTime()
1415 : mu.AwaitWithTimeout(cond, params.wait_timeout);
Dmutex.h348 bool AwaitWithTimeout(const Condition &cond, absl::Duration timeout);
/external/openscreen/third_party/abseil/src/absl/synchronization/
Dmutex_test.cc236 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
249 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
265 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(4)), in TestTime()
278 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
293 ABSL_RAW_CHECK(!cxt->mu.AwaitWithTimeout(false_cond, absl::Seconds(1)), in TestTime()
308 !cxt->mu.AwaitWithTimeout(false_cond, absl::Milliseconds(500)), in TestTime()
323 ABSL_RAW_CHECK(cxt->mu.AwaitWithTimeout(g0ge2, absl::Seconds(100)), in TestTime()
1445 : mu.AwaitWithTimeout(cond, params.wait_timeout);
Dmutex.h340 bool AwaitWithTimeout(const Condition &cond, absl::Duration timeout);
Dmutex.cc1548 bool Mutex::AwaitWithTimeout(const Condition &cond, absl::Duration timeout) { in AwaitWithTimeout() function in absl::Mutex
/external/abseil-cpp/absl/synchronization/internal/
Dmutex_nonprod.cc220 bool Mutex::AwaitWithTimeout(const Condition& cond, absl::Duration timeout) { in AwaitWithTimeout() function in absl::Mutex
/external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/internal/
Dmutex_nonprod.cc225 bool Mutex::AwaitWithTimeout(const Condition& cond, absl::Duration timeout) { in AwaitWithTimeout() function in absl::Mutex
/external/webrtc/third_party/abseil-cpp/absl/synchronization/internal/
Dmutex_nonprod.cc220 bool Mutex::AwaitWithTimeout(const Condition& cond, absl::Duration timeout) { in AwaitWithTimeout() function in absl::Mutex
/external/tensorflow/tensorflow/compiler/xla/python/tpu_driver/client/
Dtpu_client.cc604 opt_status = event->AwaitWithTimeout(kWarnExecutionDelay); in WaitForExecuteEvent()
/external/tensorflow/tensorflow/compiler/xla/pjrt/
Dpjrt_stream_executor_client.cc2020 if (!mu.AwaitWithTimeout(absl::Condition(&done_running), in Execute()

12