/external/libchrome/base/synchronization/ |
D | waitable_event_unittest.cc | 20 WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL, in TEST() 21 WaitableEvent::InitialState::NOT_SIGNALED); in TEST() 39 WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL, in TEST() 40 WaitableEvent::InitialState::SIGNALED); in TEST() 58 WaitableEvent event(WaitableEvent::ResetPolicy::AUTOMATIC, in TEST() 59 WaitableEvent::InitialState::NOT_SIGNALED); in TEST() 80 WaitableEvent event(WaitableEvent::ResetPolicy::AUTOMATIC, in TEST() 81 WaitableEvent::InitialState::SIGNALED); in TEST() 93 WaitableEvent* ev[5]; in TEST() 95 ev[i] = new WaitableEvent(WaitableEvent::ResetPolicy::AUTOMATIC, in TEST() [all …]
|
D | waitable_event_watcher_unittest.cc | 32 void QuitWhenSignaled(WaitableEvent* event) { in QuitWhenSignaled() 39 void OnWaitableEventSignaled(WaitableEvent* object) { in OnWaitableEventSignaled() 57 WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL, in TEST_P() 58 WaitableEvent::InitialState::NOT_SIGNALED); in TEST_P() 74 WaitableEvent event(WaitableEvent::ResetPolicy::AUTOMATIC, in TEST_P() 75 WaitableEvent::InitialState::NOT_SIGNALED); in TEST_P() 93 WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL, in TEST_P() 94 WaitableEvent::InitialState::NOT_SIGNALED); in TEST_P() 108 WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL, in TEST_P() 109 WaitableEvent::InitialState::NOT_SIGNALED); in TEST_P() [all …]
|
D | waitable_event_posix.cc | 45 WaitableEvent::WaitableEvent(ResetPolicy reset_policy, in WaitableEvent() function in base::WaitableEvent 49 WaitableEvent::~WaitableEvent() = default; 51 void WaitableEvent::Reset() { in Reset() 56 void WaitableEvent::Signal() { in Signal() 73 bool WaitableEvent::IsSignaled() { in IsSignaled() 89 class SyncWaiter : public WaitableEvent::Waiter { 94 bool Fire(WaitableEvent* signaling_event) override { in Fire() 112 WaitableEvent* signaling_event() const { in signaling_event() 148 WaitableEvent* signaling_event_; // The WaitableEvent which woke us 153 void WaitableEvent::Wait() { in Wait() [all …]
|
D | waitable_event.h | 54 class BASE_EXPORT WaitableEvent { 67 WaitableEvent(ResetPolicy reset_policy = ResetPolicy::MANUAL, 74 explicit WaitableEvent(win::ScopedHandle event_handle); 77 ~WaitableEvent(); 128 static size_t WaitMany(WaitableEvent** waitables, size_t count); 150 virtual bool Fire(WaitableEvent* signaling_event) = 0; 262 typedef std::pair<WaitableEvent*, size_t> WaiterAndIndex; 279 DISALLOW_COPY_AND_ASSIGN(WaitableEvent);
|
D | waitable_event_watcher.h | 35 class WaitableEvent; variable 79 using EventCallback = OnceCallback<void(WaitableEvent*)>; 92 bool StartWatching(WaitableEvent* event, 117 WaitableEvent* event_ = nullptr; 129 scoped_refptr<WaitableEvent::ReceiveRight> receive_right_; 148 scoped_refptr<WaitableEvent::WaitableEventKernel> kernel_;
|
/external/libchrome/mojo/public/cpp/bindings/tests/ |
D | sync_handle_registry_unittest.cc | 34 base::WaitableEvent e(base::WaitableEvent::ResetPolicy::MANUAL, in TEST_F() 35 base::WaitableEvent::InitialState::SIGNALED); in TEST_F() 58 base::WaitableEvent e(base::WaitableEvent::ResetPolicy::MANUAL, in TEST_F() 59 base::WaitableEvent::InitialState::SIGNALED); in TEST_F() 65 [](base::WaitableEvent* e, const base::Closure& other_callback, in TEST_F() 100 auto e = std::make_unique<base::WaitableEvent>( in TEST_F() 101 base::WaitableEvent::ResetPolicy::MANUAL, in TEST_F() 102 base::WaitableEvent::InitialState::SIGNALED); in TEST_F() 106 [](std::unique_ptr<base::WaitableEvent>* e, in TEST_F() 115 base::WaitableEvent nested_event( in TEST_F() [all …]
|
/external/libchrome/base/task_scheduler/ |
D | scheduler_worker_pool_impl_unittest.cc | 71 void WaitWithoutBlockingObserver(WaitableEvent* event) { in WaitWithoutBlockingObserver() 226 WaitableEvent event; in TEST_P() 260 WaitableEvent event; in TEST_P() 287 WaitableEvent task_running; in TEST_P() 290 [](WaitableEvent* task_running) { in TEST_P() 345 WaitableEvent task_running; in TEST_P() 348 [](WaitableEvent* task_running) { in TEST_P() 380 WaitableEvent* task_running, in TaskPostedBeforeStart() 381 WaitableEvent* barrier) { in TaskPostedBeforeStart() 394 WaitableEvent task_1_running; in TEST_F() [all …]
|
D | scheduler_single_thread_task_runner_manager_unittest.cc | 202 WaitableEvent task_has_started; in TEST_F() 203 WaitableEvent task_can_continue; in TEST_F() 212 [](WaitableEvent* task_has_started, in TEST_F() 213 WaitableEvent* task_can_continue) { in TEST_F() 274 WaitableEvent waitable_event_background; in TEST_P() 277 BindOnce(&WaitableEvent::Signal, Unretained(&waitable_event_background))); in TEST_P() 282 WaitableEvent waitable_event_normal; in TEST_P() 285 BindOnce(&WaitableEvent::Signal, Unretained(&waitable_event_normal))); in TEST_P() 353 WaitableEvent task_ran(WaitableEvent::ResetPolicy::AUTOMATIC, in TEST_P() 354 WaitableEvent::InitialState::NOT_SIGNALED); in TEST_P() [all …]
|
D | scheduler_worker_pool_unittest.cc | 237 WaitableEvent task_ran(WaitableEvent::ResetPolicy::AUTOMATIC, in TEST_P() 238 WaitableEvent::InitialState::NOT_SIGNALED); in TEST_P() 246 FROM_HERE, BindOnce(&WaitableEvent::Signal, Unretained(&task_ran))); in TEST_P() 253 FROM_HERE, BindOnce(&WaitableEvent::Signal, Unretained(&task_ran)), in TEST_P() 279 WaitableEvent task_ran; in TEST_P() 284 WaitableEvent* task_ran) { in TEST_P() 294 WaitableEvent task_1_running; in TEST_P() 295 WaitableEvent task_2_running; in TEST_P() 301 FROM_HERE, BindOnce(&WaitableEvent::Signal, Unretained(&task_1_running))); in TEST_P() 303 FROM_HERE, BindOnce(&WaitableEvent::Signal, Unretained(&task_2_running))); in TEST_P()
|
/external/libchrome/ipc/ |
D | ipc_sync_channel_unittest.cc | 36 using base::WaitableEvent; 49 new WaitableEvent(base::WaitableEvent::ResetPolicy::AUTOMATIC, in Worker() 50 base::WaitableEvent::InitialState::NOT_SIGNALED)), in Worker() 52 new WaitableEvent(base::WaitableEvent::ResetPolicy::AUTOMATIC, in Worker() 53 base::WaitableEvent::InitialState::NOT_SIGNALED)), in Worker() 59 shutdown_event_(base::WaitableEvent::ResetPolicy::MANUAL, in Worker() 60 base::WaitableEvent::InitialState::NOT_SIGNALED), in Worker() 66 new WaitableEvent(base::WaitableEvent::ResetPolicy::AUTOMATIC, in Worker() 67 base::WaitableEvent::InitialState::NOT_SIGNALED)), in Worker() 69 new WaitableEvent(base::WaitableEvent::ResetPolicy::AUTOMATIC, in Worker() [all …]
|
D | ipc_sync_channel.h | 27 class WaitableEvent; variable 89 base::WaitableEvent* shutdown_event); in COMPONENT_EXPORT() 97 base::WaitableEvent* shutdown_event); in COMPONENT_EXPORT() 106 base::WaitableEvent* shutdown_event); in COMPONENT_EXPORT() 147 base::WaitableEvent* shutdown_event); in COMPONENT_EXPORT() 159 base::WaitableEvent* GetSendDoneEvent(); in COMPONENT_EXPORT() 163 base::WaitableEvent* GetDispatchEvent(); in COMPONENT_EXPORT() 172 base::WaitableEvent* shutdown_event() { return shutdown_event_; } in COMPONENT_EXPORT() 187 base::WaitableEvent* event); in COMPONENT_EXPORT() 205 void OnShutdownEventSignaled(base::WaitableEvent* event); in COMPONENT_EXPORT() [all …]
|
D | ipc_sync_channel.cc | 30 using base::WaitableEvent; 42 base::LazyInstance<std::unique_ptr<base::WaitableEvent>>::Leaky 110 void Run(WaitableEvent* event) { in Run() 127 base::WaitableEvent* const event_; 257 base::WaitableEvent* dispatch_event() { return &dispatch_event_; } in dispatch_event() 286 dispatch_event_(base::WaitableEvent::ResetPolicy::MANUAL, in ReceivedSyncMsgQueue() 287 base::WaitableEvent::InitialState::NOT_SIGNALED), in ReceivedSyncMsgQueue() 330 base::WaitableEvent dispatch_event_; 360 WaitableEvent* shutdown_event) in SyncContext() 368 base::WaitableEvent* event) { in OnSendDoneEventSignaled() [all …]
|
/external/libchrome/base/threading/ |
D | simple_thread_unittest.cc | 39 : started_(WaitableEvent::ResetPolicy::MANUAL, in ControlledRunner() 40 WaitableEvent::InitialState::NOT_SIGNALED), in ControlledRunner() 41 released_(WaitableEvent::ResetPolicy::MANUAL, in ControlledRunner() 42 WaitableEvent::InitialState::NOT_SIGNALED), in ControlledRunner() 43 done_(WaitableEvent::ResetPolicy::MANUAL, in ControlledRunner() 44 WaitableEvent::InitialState::NOT_SIGNALED) {} in ControlledRunner() 62 WaitableEvent started_; 63 WaitableEvent released_; 64 WaitableEvent done_; 71 explicit WaitEventRunner(WaitableEvent* event) : event_(event) { } in WaitEventRunner() [all …]
|
D | thread_perftest.cc | 42 : done_(WaitableEvent::ResetPolicy::AUTOMATIC, in ThreadPerfTest() 43 WaitableEvent::InitialState::NOT_SIGNALED) {} in ThreadPerfTest() 55 void TimeOnThread(base::ThreadTicks* ticks, base::WaitableEvent* done) { in TimeOnThread() 61 base::WaitableEvent done(WaitableEvent::ResetPolicy::AUTOMATIC, in ThreadNow() 62 WaitableEvent::InitialState::NOT_SIGNALED); in ThreadNow() 121 base::WaitableEvent done_; 186 WaitableEvent::ResetPolicy::AUTOMATIC, in Init() 187 WaitableEvent::InitialState::NOT_SIGNALED)); in Init() 227 typedef EventPerfTest<base::WaitableEvent> WaitableEventThreadPerfTest; 235 ConditionVariableEvent(WaitableEvent::ResetPolicy reset_policy, in ConditionVariableEvent() [all …]
|
D | thread_unittest.cc | 133 base::WaitableEvent* event) { in ReturnThreadId() 158 base::WaitableEvent event(base::WaitableEvent::ResetPolicy::AUTOMATIC, in TEST_F() 159 base::WaitableEvent::InitialState::NOT_SIGNALED); in TEST_F() 162 base::BindOnce(&base::WaitableEvent::Signal, base::Unretained(&event))); in TEST_F() 191 base::WaitableEvent block_event( in TEST_F() 192 base::WaitableEvent::ResetPolicy::AUTOMATIC, in TEST_F() 193 base::WaitableEvent::InitialState::NOT_SIGNALED); in TEST_F() 195 base::BindOnce(&base::WaitableEvent::Wait, in TEST_F() 307 base::WaitableEvent event(base::WaitableEvent::ResetPolicy::MANUAL, in TEST_F() 308 base::WaitableEvent::InitialState::NOT_SIGNALED); in TEST_F() [all …]
|
/external/libchrome/base/profiler/ |
D | stack_sampling_profiler_unittest.cc | 100 using TargetFunction = const void* (*)(WaitableEvent*, 101 WaitableEvent*, 131 WaitableEvent* thread_started_event, 132 WaitableEvent* finish_event, 137 static const void* CallWithAlloca(WaitableEvent* thread_started_event, 138 WaitableEvent* finish_event, 144 WaitableEvent* thread_started_event, 145 WaitableEvent* finish_event, 152 WaitableEvent* thread_started_event; 153 WaitableEvent* finish_event; [all …]
|
/external/perfetto/include/perfetto/ext/base/ |
D | waitable_event.h | 28 class WaitableEvent { 30 WaitableEvent(); 31 ~WaitableEvent(); 32 WaitableEvent(const WaitableEvent&) = delete; 33 WaitableEvent operator=(const WaitableEvent&) = delete;
|
/external/libchrome/mojo/core/ |
D | trap_unittest.cc | 158 base::WaitableEvent wait(base::WaitableEvent::ResetPolicy::MANUAL, in TEST_F() 159 base::WaitableEvent::InitialState::NOT_SIGNALED); in TEST_F() 221 base::WaitableEvent wait(base::WaitableEvent::ResetPolicy::MANUAL, in TEST_F() 222 base::WaitableEvent::InitialState::NOT_SIGNALED); in TEST_F() 247 base::WaitableEvent wait(base::WaitableEvent::ResetPolicy::MANUAL, in TEST_F() 248 base::WaitableEvent::InitialState::NOT_SIGNALED); in TEST_F() 295 base::WaitableEvent wait(base::WaitableEvent::ResetPolicy::MANUAL, in TEST_F() 296 base::WaitableEvent::InitialState::NOT_SIGNALED); in TEST_F() 359 base::WaitableEvent wait(base::WaitableEvent::ResetPolicy::MANUAL, in TEST_F() 360 base::WaitableEvent::InitialState::NOT_SIGNALED); in TEST_F() [all …]
|
/external/perfetto/src/base/ |
D | waitable_event.cc | 22 WaitableEvent::WaitableEvent() = default; 23 WaitableEvent::~WaitableEvent() = default; 25 void WaitableEvent::Wait() { in Wait() 30 void WaitableEvent::Notify() { in Notify()
|
/external/angle/src/libANGLE/ |
D | WorkerThread.cpp | 26 WaitableEvent::WaitableEvent() = default; 27 WaitableEvent::~WaitableEvent() = default; 39 class SingleThreadedWaitableEvent final : public WaitableEvent 59 std::shared_ptr<WaitableEvent> postWorkerTask(std::shared_ptr<Closure> task) override; 65 std::shared_ptr<WaitableEvent> SingleThreadedWorkerPool::postWorkerTask( in postWorkerTask() 80 class AsyncWaitableEvent final : public WaitableEvent 137 std::shared_ptr<WaitableEvent> postWorkerTask(std::shared_ptr<Closure> task) override; 154 std::shared_ptr<WaitableEvent> AsyncWorkerPool::postWorkerTask(std::shared_ptr<Closure> task) in postWorkerTask() 217 class DelegateWaitableEvent final : public WaitableEvent 262 std::shared_ptr<WaitableEvent> postWorkerTask(std::shared_ptr<Closure> task) override; [all …]
|
D | WorkerThread.h | 35 class WaitableEvent : angle::NonCopyable 38 WaitableEvent(); 39 virtual ~WaitableEvent(); 49 static void WaitMany(std::array<std::shared_ptr<WaitableEvent>, Count> *waitables) in WaitMany() argument 63 class WaitableEventDone final : public WaitableEvent 79 static std::shared_ptr<WaitableEvent> PostWorkerTask(std::shared_ptr<WorkerThreadPool> pool, 89 virtual std::shared_ptr<WaitableEvent> postWorkerTask(std::shared_ptr<Closure> task) = 0;
|
/external/libchrome/base/memory/ |
D | weak_ptr_unittest.cc | 94 WaitableEvent completion(WaitableEvent::ResetPolicy::MANUAL, in CreateArrowFromTarget() 95 WaitableEvent::InitialState::NOT_SIGNALED); in CreateArrowFromTarget() 103 WaitableEvent completion(WaitableEvent::ResetPolicy::MANUAL, in CreateArrowFromArrow() 104 WaitableEvent::InitialState::NOT_SIGNALED); in CreateArrowFromArrow() 112 WaitableEvent completion(WaitableEvent::ResetPolicy::MANUAL, in DeleteTarget() 113 WaitableEvent::InitialState::NOT_SIGNALED); in DeleteTarget() 121 WaitableEvent completion(WaitableEvent::ResetPolicy::MANUAL, in CopyAndAssignArrow() 122 WaitableEvent::InitialState::NOT_SIGNALED); in CopyAndAssignArrow() 130 WaitableEvent completion(WaitableEvent::ResetPolicy::MANUAL, in CopyAndAssignArrowBase() 131 WaitableEvent::InitialState::NOT_SIGNALED); in CopyAndAssignArrowBase() [all …]
|
/external/libchrome/base/message_loop/ |
D | message_loop_perftest.cc | 50 static std::unique_ptr<PostingThread> Create(WaitableEvent* start_event, in Create() 92 PostingThread(WaitableEvent* start_event, std::unique_ptr<Action> delegate) in PostingThread() 94 thread_started_(WaitableEvent::ResetPolicy::MANUAL, in PostingThread() 95 WaitableEvent::InitialState::NOT_SIGNALED), in PostingThread() 110 WaitableEvent* const start_event_; 111 WaitableEvent thread_started_; 123 run_posting_threads_(WaitableEvent::ResetPolicy::MANUAL, in MessageLoopPerfTest() 124 WaitableEvent::InitialState::NOT_SIGNALED) {} in MessageLoopPerfTest() 220 WaitableEvent run_posting_threads_;
|
/external/libchrome/mojo/public/cpp/system/ |
D | wait_set.cc | 26 : handle_event_(base::WaitableEvent::ResetPolicy::MANUAL, in State() 27 base::WaitableEvent::InitialState::NOT_SIGNALED) { in State() 39 MojoResult AddEvent(base::WaitableEvent* event) { in AddEvent() 46 MojoResult RemoveEvent(base::WaitableEvent* event) { in RemoveEvent() 131 void Wait(base::WaitableEvent** ready_event, in Wait() 191 base::StackVector<base::WaitableEvent*, 4> events; in Wait() 203 size_t index = base::WaitableEvent::WaitMany(events.container().data(), in Wait() 321 std::set<base::WaitableEvent*> user_events_; 324 base::WaitableEvent handle_event_; 340 MojoResult WaitSet::AddEvent(base::WaitableEvent* event) { in AddEvent() [all …]
|
/external/libchrome/base/ |
D | sync_socket_unittest.cc | 26 started_event_(WaitableEvent::ResetPolicy::MANUAL, in HangingReceiveThread() 27 WaitableEvent::InitialState::NOT_SIGNALED), in HangingReceiveThread() 28 done_event_(WaitableEvent::ResetPolicy::MANUAL, in HangingReceiveThread() 29 WaitableEvent::InitialState::NOT_SIGNALED) { in HangingReceiveThread() 55 WaitableEvent* started_event() { return &started_event_; } in started_event() 56 WaitableEvent* done_event() { return &done_event_; } in done_event() 62 WaitableEvent started_event_; 63 WaitableEvent done_event_;
|