| /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_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_;
|
| D | waitable_event_perftest.cc | 20 : event_(WaitableEvent::ResetPolicy::AUTOMATIC, in TraceWaitableEvent()
21 WaitableEvent::InitialState::NOT_SIGNALED), in TraceWaitableEvent()
55 WaitableEvent event_;
88 WaitableEvent stop_event_{WaitableEvent::ResetPolicy::MANUAL,
89 WaitableEvent::InitialState::NOT_SIGNALED};
|
| /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/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_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 …]
|
| D | thread_local_unittest.cc | 19 ThreadLocalTesterBase(TLPType* tlp, base::WaitableEvent* done) in ThreadLocalTesterBase()
27 base::WaitableEvent* done_;
32 SetThreadLocal(TLPType* tlp, base::WaitableEvent* done) in SetThreadLocal()
50 GetThreadLocal(TLPType* tlp, base::WaitableEvent* done) in GetThreadLocal()
81 base::WaitableEvent done(WaitableEvent::ResetPolicy::MANUAL, in TEST()
82 WaitableEvent::InitialState::NOT_SIGNALED); in TEST()
|
| D | thread.cc | 51 : id_event_(WaitableEvent::ResetPolicy::MANUAL, in Thread()
52 WaitableEvent::InitialState::NOT_SIGNALED), in Thread()
54 start_event_(WaitableEvent::ResetPolicy::MANUAL, in Thread()
55 WaitableEvent::InitialState::NOT_SIGNALED) { in Thread()
156 WaitableEvent done(WaitableEvent::ResetPolicy::AUTOMATIC, in FlushForTesting()
157 WaitableEvent::InitialState::NOT_SIGNALED); in FlushForTesting()
159 BindOnce(&WaitableEvent::Signal, Unretained(&done))); in FlushForTesting()
|
| D | platform_thread_unittest.cc | 28 TrivialThread() : run_event_(WaitableEvent::ResetPolicy::MANUAL, in TrivialThread()
29 WaitableEvent::InitialState::NOT_SIGNALED) {} in TrivialThread()
33 WaitableEvent& run_event() { return run_event_; } in run_event()
36 WaitableEvent run_event_;
102 termination_ready_(WaitableEvent::ResetPolicy::MANUAL, in FunctionTestThread()
103 WaitableEvent::InitialState::NOT_SIGNALED), in FunctionTestThread()
104 terminate_thread_(WaitableEvent::ResetPolicy::MANUAL, in FunctionTestThread()
105 WaitableEvent::InitialState::NOT_SIGNALED), in FunctionTestThread()
155 mutable WaitableEvent termination_ready_;
156 WaitableEvent terminate_thread_;
|
| /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/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 …]
|
| D | wait_set.h | 19 class WaitableEvent; variable
48 MojoResult AddEvent(base::WaitableEvent* event);
55 MojoResult RemoveEvent(base::WaitableEvent* event);
107 void Wait(base::WaitableEvent** ready_event,
|
| /external/libchrome/base/task_scheduler/ |
| 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/base/timer/ |
| D | timer_unittest.cc | 63 WaitableEvent* did_run = nullptr, in OneShotTimerTesterBase()
90 WaitableEvent* const did_run_;
103 WaitableEvent* did_run = nullptr, in OneShotTimerTester()
156 explicit RepeatingTimerTester(WaitableEvent* did_run, const TimeDelta& delay) in RepeatingTimerTester()
191 WaitableEvent* const did_run_;
205 WaitableEvent did_run_a(WaitableEvent::ResetPolicy::MANUAL, in RunTest_OneShotTimers()
206 WaitableEvent::InitialState::NOT_SIGNALED); in RunTest_OneShotTimers()
221 WaitableEvent did_run_a(WaitableEvent::ResetPolicy::MANUAL, in RunTest_OneShotTimers_Cancel()
222 WaitableEvent::InitialState::NOT_SIGNALED); in RunTest_OneShotTimers_Cancel()
260 WaitableEvent did_run_a(WaitableEvent::ResetPolicy::MANUAL, in RunTest_RepeatingTimer_Cancel()
[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_;
|
| /external/libchrome/mojo/public/cpp/system/tests/ |
| D | wait_set_unittest.cc | 259 base::WaitableEvent event(base::WaitableEvent::ResetPolicy::MANUAL, in TEST_F()
260 base::WaitableEvent::InitialState::SIGNALED); in TEST_F()
264 base::WaitableEvent* ready_event = nullptr; in TEST_F()
279 base::WaitableEvent event(base::WaitableEvent::ResetPolicy::MANUAL, in TEST_F()
280 base::WaitableEvent::InitialState::NOT_SIGNALED); in TEST_F()
286 base::WaitableEvent* ready_event = nullptr; in TEST_F()
299 [](base::WaitableEvent* event) { in TEST_F()
334 std::vector<std::unique_ptr<base::WaitableEvent>> events(kNumTestEvents); in TEST_F()
336 event_ptr = std::make_unique<base::WaitableEvent>( in TEST_F()
337 base::WaitableEvent::ResetPolicy::MANUAL, in TEST_F()
[all …]
|
| /external/libchrome/mojo/core/embedder/ |
| D | scoped_ipc_support.cc | 37 base::WaitableEvent shutdown_event( in ~ScopedIPCSupport()
38 base::WaitableEvent::ResetPolicy::MANUAL, in ~ScopedIPCSupport()
39 base::WaitableEvent::InitialState::NOT_SIGNALED); in ~ScopedIPCSupport()
40 ShutdownIPCSupport(base::Bind(&base::WaitableEvent::Signal, in ~ScopedIPCSupport()
|
| /external/libchrome/base/test/ |
| D | scoped_task_environment_unittest.cc | 123 WaitableEvent task_ran(WaitableEvent::ResetPolicy::MANUAL, in TEST_P()
124 WaitableEvent::InitialState::NOT_SIGNALED); in TEST_P()
126 BindOnce([](WaitableEvent* task_ran) { task_ran->Signal(); }, in TEST_P()
141 WaitableEvent task_ran(WaitableEvent::ResetPolicy::MANUAL, in TEST_P()
142 WaitableEvent::InitialState::NOT_SIGNALED); in TEST_P()
144 BindOnce([](WaitableEvent* task_ran) { task_ran->Signal(); }, in TEST_P()
|