Searched refs:waiter_ (Results 1 – 7 of 7) sorted by relevance
| /external/libmojo/mojo/edk/system/ |
| D | waiter_test_utils.cc | 13 waiter_.Init(); in SimpleWaiterThread()
23 *result_ = waiter_.Wait(MOJO_DEADLINE_INDEFINITE, context_); in Run()
56 waiter_.Init(); in Run()
58 *result_out_ = dispatcher_->AddAwakable(&waiter_, handle_signals_, context_, in Run()
64 *result_out_ = waiter_.Wait(deadline_, context_out_); in Run()
65 dispatcher_->RemoveAwakable(&waiter_, signals_state_out_); in Run()
|
| D | waiter_test_utils.h | 53 Waiter* waiter() { return &waiter_; } in waiter()
60 Waiter waiter_; variable
95 Waiter waiter_; variable
|
| D | wait_set_dispatcher.cc | 42 : waiter_(new WaitSetDispatcher::Waiter(this)) {} in WaitSetDispatcher()
61 entry.second.dispatcher->RemoveAwakable(waiter_.get(), nullptr); in Close()
89 const MojoResult result = dispatcher->AddAwakable(waiter_.get(), signals, in AddWaitingDispatcher()
121 dispatcher->RemoveAwakable(waiter_.get(), nullptr); in RemoveWaitingDispatcher()
182 waiter_.get(), it->second.signals, d, nullptr); in GetReadyDispatchers()
|
| D | waiter_unittest.cc | 34 waiter_.Init(); in WaitingThread()
57 Waiter* waiter() { return &waiter_; } in waiter()
67 result = waiter_.Wait(deadline_, &context); in Run()
80 Waiter waiter_; // Thread-safe. member in mojo::edk::__anon318e51650111::WaitingThread
|
| D | wait_set_dispatcher.h | 95 std::unique_ptr<Waiter> waiter_; variable
|
| /external/libchrome/base/synchronization/ |
| D | waitable_event_watcher_posix.cc | 113 waiter_(NULL), in WaitableEventWatcher()
170 waiter_ = new AsyncWaiter(current_ml, internal_callback_, cancel_flag_.get()); in StartWatching()
171 event->Enqueue(waiter_); in StartWatching()
224 if (kernel_->Dequeue(waiter_, cancel_flag_.get())) { in StopWatching()
229 delete waiter_; in StopWatching()
|
| D | waitable_event_watcher.h | 103 AsyncWaiter* waiter_;
|