Home
last modified time | relevance | path

Searched refs:HasBeenNotified (Results 1 – 15 of 15) sorted by relevance

/external/tensorflow/tensorflow/core/platform/default/
Dnotification.h41 assert(!HasBeenNotified()); in Notify()
46 bool HasBeenNotified() const { in HasBeenNotified() function
51 if (!HasBeenNotified()) { in WaitForNotification()
53 while (!HasBeenNotified()) { in WaitForNotification()
63 bool notified = HasBeenNotified(); in WaitForNotificationWithTimeout()
67 notified = HasBeenNotified(); in WaitForNotificationWithTimeout()
/external/tensorflow/tensorflow/core/kernels/batching_util/
Dshared_batch_scheduler_test.cc61 while (!stop->HasBeenNotified()) { in CreateFakeClockAdvancerThread()
231 EXPECT_FALSE(first_batch_processed.HasBeenNotified()); in TEST()
240 EXPECT_FALSE(second_batch_processed.HasBeenNotified()); in TEST()
248 EXPECT_FALSE(third_batch_processed.HasBeenNotified()); in TEST()
352 if (!queue_0_first_batch_scheduled.HasBeenNotified()) { in TEST()
355 } else if (!queue_0_second_batch_scheduled.HasBeenNotified()) { in TEST()
401 EXPECT_FALSE(queue_0_second_batch_scheduled.HasBeenNotified()); in TEST()
415 if (!processing.HasBeenNotified()) { in TEST()
470 if (!queue_0_processing.HasBeenNotified()) { in TEST()
585 EXPECT_FALSE(queue_destroyed.HasBeenNotified()); in TEST()
Dperiodic_function.cc62 if (!stop_thread_.HasBeenNotified()) { in NotifyStop()
74 while (!stop_thread_.HasBeenNotified()) { in RunLoop()
Dbatch_scheduler_test.cc111 EXPECT_FALSE(deleted.HasBeenNotified()); in TEST()
Dadaptive_shared_batch_scheduler_test.cc60 while (!stop->HasBeenNotified()) { in CreateFakeClockAdvancerThread()
117 ASSERT_TRUE(finish_processing.HasBeenNotified()); in TEST()
Dserial_device_batch_scheduler_test.cc60 while (!stop->HasBeenNotified()) { in CreateFakeClockAdvancerThread()
114 ASSERT_TRUE(finish_processing.HasBeenNotified()); in TEST()
Dbatch_scheduler.h265 return const_cast<Notification*>(&closed_)->HasBeenNotified(); in IsClosed()
/external/tensorflow/tensorflow/core/common_runtime/gpu/
Dgpu_allocator_retry_test.cc146 } while (!notifier_.HasBeenNotified()); in LaunchConsumerThreads()
/external/tensorflow/tensorflow/core/profiler/internal/
Dtraceme_recorder_test.cc113 while (!stop.HasBeenNotified()) { in TEST()
/external/tensorflow/tensorflow/core/distributed_runtime/
Dmaster_test.cc317 while (!extend_done.HasBeenNotified()) { in TEST_F()
335 while (!extend_done.HasBeenNotified()) { in TEST_F()
/external/tensorflow/tensorflow/cc/training/
Dcoordinator_test.cc49 EXPECT_FALSE(done.HasBeenNotified()); in TEST()
/external/tensorflow/tensorflow/core/kernels/data/
Dparallel_map_iterator.cc323 if ((*it)->notification.HasBeenNotified() && in ShouldWait()
/external/tensorflow/tensorflow/core/debug/
Ddebug_grpc_io_utils_test.cc221 if (this_count == kSends - 1 && !all_done.HasBeenNotified()) { in TEST_F()
/external/tensorflow/tensorflow/core/common_runtime/
Ddirect_session.cc1669 if (!executors_done.HasBeenNotified()) { in ~RunState()
Ddirect_session_test.cc1502 ASSERT_TRUE(CancellationMgrPollingOp::notification.HasBeenNotified()); in TEST()