/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...] |