Home
last modified time | relevance | path

Searched refs:WaitableEvent (Results 1 – 25 of 121) sorted by relevance

12345

/external/libchrome/base/synchronization/
Dwaitable_event_unittest.cc20 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 …]
Dwaitable_event_watcher_unittest.cc32 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 …]
Dwaitable_event_posix.cc45 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 …]
Dwaitable_event.h54 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);
Dwaitable_event_watcher.h35 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/
Dsync_handle_registry_unittest.cc34 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/
Dscheduler_worker_pool_impl_unittest.cc71 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 …]
Dscheduler_single_thread_task_runner_manager_unittest.cc202 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 …]
Dscheduler_worker_pool_unittest.cc237 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/
Dipc_sync_channel_unittest.cc36 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 …]
Dipc_sync_channel.h27 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 …]
Dipc_sync_channel.cc30 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/
Dsimple_thread_unittest.cc39 : 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 …]
Dthread_perftest.cc42 : 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 …]
Dthread_unittest.cc133 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/
Dstack_sampling_profiler_unittest.cc100 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/
Dwaitable_event.h28 class WaitableEvent {
30 WaitableEvent();
31 ~WaitableEvent();
32 WaitableEvent(const WaitableEvent&) = delete;
33 WaitableEvent operator=(const WaitableEvent&) = delete;
/external/libchrome/mojo/core/
Dtrap_unittest.cc158 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/
Dwaitable_event.cc22 WaitableEvent::WaitableEvent() = default;
23 WaitableEvent::~WaitableEvent() = default;
25 void WaitableEvent::Wait() { in Wait()
30 void WaitableEvent::Notify() { in Notify()
/external/angle/src/libANGLE/
DWorkerThread.cpp26 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 …]
DWorkerThread.h35 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/
Dweak_ptr_unittest.cc94 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/
Dmessage_loop_perftest.cc50 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/
Dwait_set.cc26 : 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/
Dsync_socket_unittest.cc26 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_;

12345