| /external/libchrome/base/synchronization/ |
| waitable_event_unittest.cc | 20 WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL,
21 WaitableEvent::InitialState::NOT_SIGNALED);
39 WaitableEvent event(WaitableEvent::ResetPolicy::MANUAL,
40 WaitableEvent::InitialState::SIGNALED);
58 WaitableEvent event(WaitableEvent::ResetPolicy::AUTOMATIC,
59 WaitableEvent::InitialState::NOT_SIGNALED);
80 WaitableEvent event(WaitableEvent::ResetPolicy::AUTOMATIC
[all...] |
| waitable_event_watcher.h | 35 class WaitableEvent;
37 // This class provides a way to wait on a WaitableEvent asynchronously.
39 // Each instance of this object can be waiting on a single WaitableEvent. When
47 // void DoStuffWhenSignaled(WaitableEvent *waitable_event) {
52 // void OnWaitableEventSignaled(WaitableEvent* waitable_event) {
66 // safe way to stop watching an automatic reset WaitableEvent without possibly
69 // NOTE: you /are/ allowed to delete the WaitableEvent while still waiting on
71 // right after, the callback may be called with deleted WaitableEvent pointer.
79 using EventCallback = OnceCallback<void(WaitableEvent*)>;
92 bool StartWatching(WaitableEvent* event
[all...] |
| waitable_event_posix.cc | 20 // A WaitableEvent on POSIX is implemented as a wait-list. Currently we don't
25 // The WaitableEvent maintains a list of waiters, protected by a lock. Each
45 WaitableEvent::WaitableEvent(ResetPolicy reset_policy,
49 WaitableEvent::~WaitableEvent() = default;
51 void WaitableEvent::Reset() {
56 void WaitableEvent::Signal() {
73 bool WaitableEvent::IsSignaled() {
89 class SyncWaiter : public WaitableEvent::Waiter
[all...] |
| waitable_event.h | 39 // A WaitableEvent can be a useful thread synchronization tool when you want to
44 // Use a WaitableEvent when you would otherwise use a Lock+ConditionVariable to
46 // WaitableEvent in conjunction with a Lock to wait for a more complex state
48 // be using a ConditionVariable instead of a WaitableEvent.
54 class BASE_EXPORT WaitableEvent {
56 // Indicates whether a WaitableEvent should automatically reset the event
61 // Indicates whether a new WaitableEvent should start in a signaled state or
65 // Constructs a WaitableEvent with policy and initial state as detailed in
67 WaitableEvent(ResetPolicy reset_policy = ResetPolicy::MANUAL,
71 // Create a WaitableEvent from an Event HANDLE which has already bee
[all...] |
| waitable_event_watcher_posix.cc | 61 class AsyncWaiter : public WaitableEvent::Waiter {
70 bool Fire(WaitableEvent* event) override {
75 // We are removed from the wait-list by the WaitableEvent itself. It only
100 WaitableEvent* event) {
126 WaitableEvent* event,
143 WaitableEvent::WaitableEventKernel* kernel = event->kernel_.get();
173 // The WaitableEvent may have been deleted too.
|
| waitable_event_perftest.cc | 20 : event_(WaitableEvent::ResetPolicy::AUTOMATIC,
21 WaitableEvent::InitialState::NOT_SIGNALED),
55 WaitableEvent event_;
88 WaitableEvent stop_event_{WaitableEvent::ResetPolicy::MANUAL,
89 WaitableEvent::InitialState::NOT_SIGNALED};
|
| /external/libchrome/mojo/public/cpp/system/ |
| wait_set.h | 19 class WaitableEvent;
48 MojoResult AddEvent(base::WaitableEvent* event);
55 MojoResult RemoveEvent(base::WaitableEvent* event);
107 void Wait(base::WaitableEvent** ready_event,
|
| wait_set.cc | 26 : handle_event_(base::WaitableEvent::ResetPolicy::MANUAL,
27 base::WaitableEvent::InitialState::NOT_SIGNALED) {
39 MojoResult AddEvent(base::WaitableEvent* event) {
46 MojoResult RemoveEvent(base::WaitableEvent* event) {
131 void Wait(base::WaitableEvent** ready_event,
191 base::StackVector<base::WaitableEvent*, 4> events;
203 size_t index = base::WaitableEvent::WaitMany(events.container().data(),
321 std::set<base::WaitableEvent*> user_events_;
324 base::WaitableEvent handle_event_;
327 // to guard against event starvation, as base::WaitableEvent::WaitMany give
[all...] |
| /external/libchrome/base/test/android/ |
| java_handler_thread_helpers.h | 16 class WaitableEvent;
29 static void ThrowExceptionAndAbort(WaitableEvent* event);
|
| /external/libchrome/base/threading/ |
| simple_thread_unittest.cc | 39 : started_(WaitableEvent::ResetPolicy::MANUAL,
40 WaitableEvent::InitialState::NOT_SIGNALED),
41 released_(WaitableEvent::ResetPolicy::MANUAL,
42 WaitableEvent::InitialState::NOT_SIGNALED),
43 done_(WaitableEvent::ResetPolicy::MANUAL,
44 WaitableEvent::InitialState::NOT_SIGNALED) {}
62 WaitableEvent started_;
63 WaitableEvent released_;
64 WaitableEvent done_;
71 explicit WaitEventRunner(WaitableEvent* event) : event_(event) {
[all...] |
| thread_unittest.cc | 133 base::WaitableEvent* event) {
158 base::WaitableEvent event(base::WaitableEvent::ResetPolicy::AUTOMATIC,
159 base::WaitableEvent::InitialState::NOT_SIGNALED);
162 base::BindOnce(&base::WaitableEvent::Signal, base::Unretained(&event)));
191 base::WaitableEvent block_event(
192 base::WaitableEvent::ResetPolicy::AUTOMATIC,
193 base::WaitableEvent::InitialState::NOT_SIGNALED);
195 base::BindOnce(&base::WaitableEvent::Wait,
307 base::WaitableEvent event(base::WaitableEvent::ResetPolicy::MANUAL
[all...] |
| thread_local_unittest.cc | 19 ThreadLocalTesterBase(TLPType* tlp, base::WaitableEvent* done)
27 base::WaitableEvent* done_;
32 SetThreadLocal(TLPType* tlp, base::WaitableEvent* done)
50 GetThreadLocal(TLPType* tlp, base::WaitableEvent* done)
81 base::WaitableEvent done(WaitableEvent::ResetPolicy::MANUAL,
82 WaitableEvent::InitialState::NOT_SIGNALED);
|
| /external/libchrome/mojo/core/embedder/ |
| scoped_ipc_support.cc | 37 base::WaitableEvent shutdown_event(
38 base::WaitableEvent::ResetPolicy::MANUAL,
39 base::WaitableEvent::InitialState::NOT_SIGNALED);
40 ShutdownIPCSupport(base::Bind(&base::WaitableEvent::Signal,
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| sync_handle_registry_unittest.cc | 34 base::WaitableEvent e(base::WaitableEvent::ResetPolicy::MANUAL,
35 base::WaitableEvent::InitialState::SIGNALED);
58 base::WaitableEvent e(base::WaitableEvent::ResetPolicy::MANUAL,
59 base::WaitableEvent::InitialState::SIGNALED);
65 [](base::WaitableEvent* e, const base::Closure& other_callback,
100 auto e = std::make_unique<base::WaitableEvent>(
101 base::WaitableEvent::ResetPolicy::MANUAL,
102 base::WaitableEvent::InitialState::SIGNALED)
[all...] |
| /external/libchrome/ipc/ |
| ipc_sync_channel.h | 27 class WaitableEvent;
89 base::WaitableEvent* shutdown_event);
97 base::WaitableEvent* shutdown_event);
106 base::WaitableEvent* shutdown_event);
147 base::WaitableEvent* shutdown_event);
159 base::WaitableEvent* GetSendDoneEvent();
163 base::WaitableEvent* GetDispatchEvent();
172 base::WaitableEvent* shutdown_event() { return shutdown_event_; }
187 base::WaitableEvent* event);
205 void OnShutdownEventSignaled(base::WaitableEvent* event)
[all...] |
| ipc_sync_channel_unittest.cc | 36 using base::WaitableEvent;
49 new WaitableEvent(base::WaitableEvent::ResetPolicy::AUTOMATIC,
50 base::WaitableEvent::InitialState::NOT_SIGNALED)),
52 new WaitableEvent(base::WaitableEvent::ResetPolicy::AUTOMATIC,
53 base::WaitableEvent::InitialState::NOT_SIGNALED)),
59 shutdown_event_(base::WaitableEvent::ResetPolicy::MANUAL,
60 base::WaitableEvent::InitialState::NOT_SIGNALED),
66 new WaitableEvent(base::WaitableEvent::ResetPolicy::AUTOMATIC
[all...] |
| ipc_sync_message.h | 22 class WaitableEvent;
97 PendingSyncMsg(int id, MessageReplyDeserializer* d, base::WaitableEvent* e)
102 base::WaitableEvent* done_event;
|
| ipc_sync_message_filter.h | 24 class WaitableEvent;
61 explicit SyncMessageFilter(base::WaitableEvent* shutdown_event);
94 base::WaitableEvent* const shutdown_event_;
|
| ipc_sync_channel.cc | 30 using base::WaitableEvent;
42 base::LazyInstance<std::unique_ptr<base::WaitableEvent>>::Leaky
69 // thread. Every such operation has a corresponding WaitableEvent to be
110 void Run(WaitableEvent* event) {
127 base::WaitableEvent* const event_;
257 base::WaitableEvent* dispatch_event() { return &dispatch_event_; }
286 dispatch_event_(base::WaitableEvent::ResetPolicy::MANUAL,
287 base::WaitableEvent::InitialState::NOT_SIGNALED),
330 base::WaitableEvent dispatch_event_;
360 WaitableEvent* shutdown_event
[all...] |
| /external/libchrome/mojo/public/cpp/bindings/ |
| sync_handle_registry.h | 43 // Registers a |base::WaitableEvent| which can be used to wake up
47 void RegisterEvent(base::WaitableEvent* event, const base::Closure& callback);
50 void UnregisterEvent(base::WaitableEvent* event,
64 using EventMap = std::map<base::WaitableEvent*, EventCallbackList>;
|
| sync_event_watcher.h | 20 // SyncEventWatcher supports waiting on a base::WaitableEvent to signal while
27 SyncEventWatcher(base::WaitableEvent* event, const base::Closure& callback);
53 base::WaitableEvent* const event_;
|
| /external/libchrome/base/ |
| sync_socket_unittest.cc | 26 started_event_(WaitableEvent::ResetPolicy::MANUAL,
27 WaitableEvent::InitialState::NOT_SIGNALED),
28 done_event_(WaitableEvent::ResetPolicy::MANUAL,
29 WaitableEvent::InitialState::NOT_SIGNALED) {
55 WaitableEvent* started_event() { return &started_event_; }
56 WaitableEvent* done_event() { return &done_event_; }
62 WaitableEvent started_event_;
63 WaitableEvent done_event_;
|
| /external/libchrome/base/message_loop/ |
| message_pump_default.h | 36 WaitableEvent event_;
|
| /external/libchrome/base/task_scheduler/ |
| scheduler_worker_pool_unittest.cc | 237 WaitableEvent task_ran(WaitableEvent::ResetPolicy::AUTOMATIC,
238 WaitableEvent::InitialState::NOT_SIGNALED);
246 FROM_HERE, BindOnce(&WaitableEvent::Signal, Unretained(&task_ran)));
253 FROM_HERE, BindOnce(&WaitableEvent::Signal, Unretained(&task_ran)),
279 WaitableEvent task_ran;
284 WaitableEvent* task_ran) {
294 WaitableEvent task_1_running;
295 WaitableEvent task_2_running;
301 FROM_HERE, BindOnce(&WaitableEvent::Signal, Unretained(&task_1_running)))
[all...] |
| /external/libchrome/base/memory/ |
| weak_ptr_unittest.cc | 94 WaitableEvent completion(WaitableEvent::ResetPolicy::MANUAL,
95 WaitableEvent::InitialState::NOT_SIGNALED);
103 WaitableEvent completion(WaitableEvent::ResetPolicy::MANUAL,
104 WaitableEvent::InitialState::NOT_SIGNALED);
112 WaitableEvent completion(WaitableEvent::ResetPolicy::MANUAL,
113 WaitableEvent::InitialState::NOT_SIGNALED);
121 WaitableEvent completion(WaitableEvent::ResetPolicy::MANUAL
[all...] |
