Home
last modified time | relevance | path

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

12

/external/libchrome/base/synchronization/
Dwaitable_event_unittest.cc18 WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL, in TEST()
19 WaitableEvent::InitialState::NOT_SIGNALED); in TEST()
37 WaitableEvent event(WaitableEvent::ResetPolicy::AUTOMATIC, in TEST()
38 WaitableEvent::InitialState::NOT_SIGNALED); in TEST()
59 WaitableEvent* ev[5]; in TEST()
61 ev[i] = new WaitableEvent(WaitableEvent::ResetPolicy::AUTOMATIC, in TEST()
62 WaitableEvent::InitialState::NOT_SIGNALED); in TEST()
66 EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 3u); in TEST()
69 EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 3u); in TEST()
72 EXPECT_EQ(WaitableEvent::WaitMany(ev, 5), 4u); in TEST()
[all …]
Dwaitable_event_posix.cc42 WaitableEvent::WaitableEvent(ResetPolicy reset_policy, in WaitableEvent() function in base::WaitableEvent
46 WaitableEvent::~WaitableEvent() = default;
48 void WaitableEvent::Reset() { in Reset()
53 void WaitableEvent::Signal() { in Signal()
70 bool WaitableEvent::IsSignaled() { in IsSignaled()
86 class SyncWaiter : public WaitableEvent::Waiter {
95 bool Fire(WaitableEvent* signaling_event) override { in Fire()
113 WaitableEvent* signaling_event() const { in signaling_event()
149 WaitableEvent* signaling_event_; // The WaitableEvent which woke us
154 void WaitableEvent::Wait() { in Wait()
[all …]
Dwaitable_event.h44 class BASE_EXPORT WaitableEvent {
57 WaitableEvent(ResetPolicy reset_policy, InitialState initial_state);
63 explicit WaitableEvent(win::ScopedHandle event_handle);
66 ~WaitableEvent();
109 static size_t WaitMany(WaitableEvent** waitables, size_t count);
131 virtual bool Fire(WaitableEvent* signaling_event) = 0;
174 typedef std::pair<WaitableEvent*, size_t> WaiterAndIndex;
191 DISALLOW_COPY_AND_ASSIGN(WaitableEvent);
Dwaitable_event_watcher.h24 class WaitableEvent; variable
68 typedef Callback<void(WaitableEvent*)> EventCallback;
74 bool StartWatching(WaitableEvent* event, const EventCallback& callback);
87 WaitableEvent* GetWatchedEvent();
105 scoped_refptr<WaitableEvent::WaitableEventKernel> kernel_;
108 WaitableEvent* event_;
Dwaitable_event_watcher_posix.cc60 class AsyncWaiter : public WaitableEvent::Waiter {
69 bool Fire(WaitableEvent* event) override { in Fire()
100 WaitableEvent* event) { in AsyncCallbackHelper()
126 WaitableEvent* event, in StartWatching()
150 WaitableEvent::WaitableEventKernel* kernel = event->kernel_.get(); in StartWatching()
251 WaitableEvent* WaitableEventWatcher::GetWatchedEvent() { in GetWatchedEvent()
/external/libchrome/base/threading/
Dworker_pool_unittest.cc31 test_event_(WaitableEvent::ResetPolicy::AUTOMATIC, in PostTaskAndReplyTester()
32 WaitableEvent::InitialState::NOT_SIGNALED) {} in PostTaskAndReplyTester()
66 WaitableEvent test_event_;
75 WaitableEvent test_event(WaitableEvent::ResetPolicy::AUTOMATIC, in TEST_F()
76 WaitableEvent::InitialState::NOT_SIGNALED); in TEST_F()
77 WaitableEvent long_test_event(WaitableEvent::ResetPolicy::AUTOMATIC, in TEST_F()
78 WaitableEvent::InitialState::NOT_SIGNALED); in TEST_F()
81 base::Bind(&WaitableEvent::Signal, in TEST_F()
85 base::Bind(&WaitableEvent::Signal, in TEST_F()
Dsimple_thread_unittest.cc29 explicit WaitEventRunner(WaitableEvent* event) : event_(event) { } in WaitEventRunner()
38 WaitableEvent* event_;
56 int total, WaitableEvent* event) in VerifyPoolRunner()
70 WaitableEvent* event_;
98 WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL, in TEST()
99 WaitableEvent::InitialState::NOT_SIGNALED); in TEST()
112 WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL, in TEST()
113 WaitableEvent::InitialState::NOT_SIGNALED); in TEST()
157 WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL, in TEST()
158 WaitableEvent::InitialState::NOT_SIGNALED); in TEST()
Dthread_local_unittest.cc19 ThreadLocalTesterBase(TLPType* tlp, base::WaitableEvent* done) in ThreadLocalTesterBase()
27 base::WaitableEvent* done_;
32 SetThreadLocal(TLPType* tlp, base::WaitableEvent* done) in SetThreadLocal()
52 GetThreadLocal(TLPType* tlp, base::WaitableEvent* done) in GetThreadLocal()
85 base::WaitableEvent done(WaitableEvent::ResetPolicy::MANUAL, in TEST()
86 WaitableEvent::InitialState::NOT_SIGNALED); in TEST()
Dplatform_thread_unittest.cc30 TrivialThread() : run_event_(WaitableEvent::ResetPolicy::MANUAL, in TrivialThread()
31 WaitableEvent::InitialState::NOT_SIGNALED) {} in TrivialThread()
35 WaitableEvent& run_event() { return run_event_; } in run_event()
38 WaitableEvent run_event_;
104 termination_ready_(WaitableEvent::ResetPolicy::MANUAL, in FunctionTestThread()
105 WaitableEvent::InitialState::NOT_SIGNALED), in FunctionTestThread()
106 terminate_thread_(WaitableEvent::ResetPolicy::MANUAL, in FunctionTestThread()
107 WaitableEvent::InitialState::NOT_SIGNALED), in FunctionTestThread()
157 mutable WaitableEvent termination_ready_;
158 WaitableEvent terminate_thread_;
Dsimple_thread.cc18 event_(WaitableEvent::ResetPolicy::MANUAL, in SimpleThread()
19 WaitableEvent::InitialState::NOT_SIGNALED), in SimpleThread()
29 event_(WaitableEvent::ResetPolicy::MANUAL, in SimpleThread()
30 WaitableEvent::InitialState::NOT_SIGNALED), in SimpleThread()
105 dry_(WaitableEvent::ResetPolicy::MANUAL, in DelegateSimpleThreadPool()
106 WaitableEvent::InitialState::NOT_SIGNALED) {} in DelegateSimpleThreadPool()
Dthread.cc69 id_event_(WaitableEvent::ResetPolicy::MANUAL, in Thread()
70 WaitableEvent::InitialState::NOT_SIGNALED), in Thread()
74 start_event_(WaitableEvent::ResetPolicy::MANUAL, in Thread()
75 WaitableEvent::InitialState::NOT_SIGNALED) { in Thread()
Dworker_pool_posix_unittest.cc77 base::WaitableEvent* start;
99 start_(WaitableEvent::ResetPolicy::MANUAL, in PosixDynamicThreadPoolTest()
100 WaitableEvent::InitialState::NOT_SIGNALED) {} in PosixDynamicThreadPoolTest()
149 base::WaitableEvent start_;
Dthread_unittest.cc111 base::WaitableEvent* event) { in ReturnThreadId()
212 base::WaitableEvent event(base::WaitableEvent::ResetPolicy::AUTOMATIC, in TEST_F()
213 base::WaitableEvent::InitialState::NOT_SIGNALED); in TEST_F()
/external/libmojo/base/android/
Djava_handler_thread.cc35 base::WaitableEvent initialize_event( in Start()
36 WaitableEvent::ResetPolicy::AUTOMATIC, in Start()
37 WaitableEvent::InitialState::NOT_SIGNALED); in Start()
50 base::WaitableEvent shutdown_event(WaitableEvent::ResetPolicy::AUTOMATIC, in Stop()
51 WaitableEvent::InitialState::NOT_SIGNALED); in Stop()
67 reinterpret_cast<base::WaitableEvent*>(event)->Signal(); in InitializeThread()
74 reinterpret_cast<base::WaitableEvent*>(event)->Signal(); in StopThread()
Dapplication_status_listener_unittest.cc46 event_(WaitableEvent::ResetPolicy::AUTOMATIC, in MultiThreadedTest()
47 WaitableEvent::InitialState::NOT_SIGNALED), in MultiThreadedTest()
94 base::WaitableEvent event_;
/external/libchrome/base/memory/
Dweak_ptr_unittest.cc72 WaitableEvent completion(WaitableEvent::ResetPolicy::MANUAL, in CreateArrowFromTarget()
73 WaitableEvent::InitialState::NOT_SIGNALED); in CreateArrowFromTarget()
81 WaitableEvent completion(WaitableEvent::ResetPolicy::MANUAL, in CreateArrowFromArrow()
82 WaitableEvent::InitialState::NOT_SIGNALED); in CreateArrowFromArrow()
90 WaitableEvent completion(WaitableEvent::ResetPolicy::MANUAL, in DeleteTarget()
91 WaitableEvent::InitialState::NOT_SIGNALED); in DeleteTarget()
99 WaitableEvent completion(WaitableEvent::ResetPolicy::MANUAL, in CopyAndAssignArrow()
100 WaitableEvent::InitialState::NOT_SIGNALED); in CopyAndAssignArrow()
108 WaitableEvent completion(WaitableEvent::ResetPolicy::MANUAL, in CopyAndAssignArrowBase()
109 WaitableEvent::InitialState::NOT_SIGNALED); in CopyAndAssignArrowBase()
[all …]
/external/libchrome/base/test/
Dtest_io_thread.cc13 void PostTaskAndWaitHelper(base::WaitableEvent* event, in PostTaskAndWaitHelper()
59 base::WaitableEvent event(WaitableEvent::ResetPolicy::AUTOMATIC, in PostTaskAndWait()
60 WaitableEvent::InitialState::NOT_SIGNALED); in PostTaskAndWait()
/external/libchrome/base/task_scheduler/
Dscheduler_lock_unittest.cc59 lock_acquire_event_(WaitableEvent::ResetPolicy::AUTOMATIC, in BasicLockAcquireAndWaitThread()
60 WaitableEvent::InitialState::NOT_SIGNALED), in BasicLockAcquireAndWaitThread()
61 main_thread_continue_event_(WaitableEvent::ResetPolicy::AUTOMATIC, in BasicLockAcquireAndWaitThread()
62 WaitableEvent::InitialState::NOT_SIGNALED) { in BasicLockAcquireAndWaitThread()
82 WaitableEvent lock_acquire_event_;
83 WaitableEvent main_thread_continue_event_;
/external/libchrome/base/trace_event/
Dtrace_event_unittest.cc67 WaitableEvent* flush_complete_event,
100 WaitableEvent flush_complete_event( in CancelTrace()
101 WaitableEvent::ResetPolicy::AUTOMATIC, in CancelTrace()
102 WaitableEvent::InitialState::NOT_SIGNALED); in CancelTrace()
109 WaitableEvent flush_complete_event( in EndTraceAndFlush()
110 WaitableEvent::ResetPolicy::AUTOMATIC, in EndTraceAndFlush()
111 WaitableEvent::InitialState::NOT_SIGNALED); in EndTraceAndFlush()
119 WaitableEvent flush_complete_event( in EndTraceAndFlushInThreadWithMessageLoop()
120 WaitableEvent::ResetPolicy::AUTOMATIC, in EndTraceAndFlushInThreadWithMessageLoop()
121 WaitableEvent::InitialState::NOT_SIGNALED); in EndTraceAndFlushInThreadWithMessageLoop()
[all …]
/external/libmojo/base/trace_event/
Dtrace_event_android.cc81 void NoOpOutputCallback(WaitableEvent* complete_event, in NoOpOutputCallback()
89 WaitableEvent* complete_event) { in EndChromeTracing()
131 WaitableEvent complete_event(WaitableEvent::ResetPolicy::AUTOMATIC, in StopATrace()
132 WaitableEvent::InitialState::NOT_SIGNALED); in StopATrace()
/external/libchrome/base/posix/
Dunix_domain_socket_linux_unittest.cc55 WaitableEvent event(WaitableEvent::ResetPolicy::AUTOMATIC, in TEST()
56 WaitableEvent::InitialState::NOT_SIGNALED); in TEST()
58 FROM_HERE, Bind(&WaitableEvent::Signal, Unretained(&event))); in TEST()
/external/libchrome/sandbox/linux/seccomp-bpf-helpers/
Dsyscall_parameters_restrictions_unittests.cc133 void SchedGetParamThread(base::WaitableEvent* thread_run) { in SchedGetParamThread()
160 base::WaitableEvent thread_run( in BPF_TEST_C()
161 base::WaitableEvent::ResetPolicy::MANUAL, in BPF_TEST_C()
162 base::WaitableEvent::InitialState::NOT_SIGNALED); in BPF_TEST_C()
/external/libchrome/base/mac/
Dmach_port_broker_unittest.cc26 event_(base::WaitableEvent::ResetPolicy::MANUAL, in MachPortBrokerTest()
27 base::WaitableEvent::InitialState::NOT_SIGNALED), in MachPortBrokerTest()
60 WaitableEvent event_;
/external/libchrome/base/message_loop/
Dmessage_pump_default.cc21 event_(WaitableEvent::ResetPolicy::AUTOMATIC, in MessagePumpDefault()
22 WaitableEvent::InitialState::NOT_SIGNALED) {} in MessagePumpDefault()
/external/libchrome/base/
Dsync_socket.h144 WaitableEvent shutdown_event_;
145 WaitableEvent file_operation_;

12