| /external/tensorflow/tensorflow/compiler/xla/pjrt/distributed/ |
| D | service.cc | 114 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()
|
| D | key_value_store.cc | 31 if (!mu_.AwaitWithTimeout(absl::Condition(&key_is_present), timeout)) { in Get()
|
| /external/tensorflow/tensorflow/compiler/xla/python/tpu_driver/ |
| D | pod_tpu_driver.cc | 54 absl::optional<xla::Status> AwaitWithTimeout(
72 absl::optional<xla::Status> AwaitWithTimeout( in AwaitWithTimeout() function in tpu_driver::__anon6b014a980111::ErrorEvent
101 absl::optional<xla::Status> AwaitWithTimeout( in AwaitWithTimeout() function in tpu_driver::__anon6b014a980111::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::__anon6b014a980111::PodEvent
|
| D | grpc_tpu_driver.cc | 55 absl::optional<xla::Status> AwaitWithTimeout(
74 absl::optional<xla::Status> AwaitWithTimeout( in AwaitWithTimeout() function in tpu_driver::__anon4073f9c10111::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::__anon4073f9c10111::GrpcEvent
599 if (events_mutex_.AwaitWithTimeout(absl::Condition(&done), duration)) { in WaitForEvent()
|
| D | tpu_driver.h | 57 virtual absl::optional<xla::Status> AwaitWithTimeout(
|
| D | recording_tpu_driver.cc | 57 absl::optional<xla::Status> AwaitWithTimeout( in AwaitWithTimeout() function in tpu_driver::__anone63593b20111::RecordingEvent
59 return shared_event_->AwaitWithTimeout(duration); in AwaitWithTimeout()
|
| D | direct_tpu_driver.cc | 76 absl::optional<xla::Status> AwaitWithTimeout( in AwaitWithTimeout() function in tpu_driver::__anon9d833a900111::DirectEvent
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/ |
| D | mutex_test.cc | 236 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);
|
| D | mutex.h | 348 bool AwaitWithTimeout(const Condition &cond, absl::Duration timeout);
|
| /external/abseil-cpp/absl/synchronization/ |
| D | mutex_test.cc | 235 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);
|
| D | mutex.h | 349 bool AwaitWithTimeout(const Condition &cond, absl::Duration timeout);
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/ |
| D | mutex_test.cc | 235 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);
|
| D | mutex.h | 349 bool AwaitWithTimeout(const Condition &cond, absl::Duration timeout);
|
| D | mutex.cc | 1547 bool Mutex::AwaitWithTimeout(const Condition &cond, absl::Duration timeout) { in AwaitWithTimeout() function in absl::Mutex
|
| /external/libtextclassifier/abseil-cpp/absl/synchronization/ |
| D | mutex_test.cc | 236 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);
|
| D | mutex.h | 348 bool AwaitWithTimeout(const Condition &cond, absl::Duration timeout);
|
| /external/openscreen/third_party/abseil/src/absl/synchronization/ |
| D | mutex_test.cc | 236 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);
|
| D | mutex.h | 340 bool AwaitWithTimeout(const Condition &cond, absl::Duration timeout);
|
| /external/angle/third_party/abseil-cpp/absl/synchronization/ |
| D | mutex_test.cc | 236 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);
|
| D | mutex.h | 340 bool AwaitWithTimeout(const Condition &cond, absl::Duration timeout);
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | mutex_nonprod.cc | 225 bool Mutex::AwaitWithTimeout(const Condition& cond, absl::Duration timeout) { in AwaitWithTimeout() function in absl::Mutex
|
| /external/webrtc/third_party/abseil-cpp/absl/synchronization/internal/ |
| D | mutex_nonprod.cc | 220 bool Mutex::AwaitWithTimeout(const Condition& cond, absl::Duration timeout) { in AwaitWithTimeout() function in absl::Mutex
|
| /external/abseil-cpp/absl/synchronization/internal/ |
| D | mutex_nonprod.cc | 220 bool Mutex::AwaitWithTimeout(const Condition& cond, absl::Duration timeout) { in AwaitWithTimeout() function in absl::Mutex
|
| /external/tensorflow/tensorflow/compiler/xla/python/tpu_driver/client/ |
| D | tpu_client.cc | 604 opt_status = event->AwaitWithTimeout(kWarnExecutionDelay); in WaitForExecuteEvent()
|
| /external/tensorflow/tensorflow/compiler/xla/pjrt/ |
| D | pjrt_stream_executor_client.cc | 2020 if (!mu.AwaitWithTimeout(absl::Condition(&done_running), in Execute()
|