| /external/libmojo/mojo/edk/system/ |
| waiter_test_utils.cc | 13 waiter_.Init();
23 *result_ = waiter_.Wait(MOJO_DEADLINE_INDEFINITE, context_);
56 waiter_.Init();
58 *result_out_ = dispatcher_->AddAwakable(&waiter_, handle_signals_, context_,
64 *result_out_ = waiter_.Wait(deadline_, context_out_);
65 dispatcher_->RemoveAwakable(&waiter_, signals_state_out_);
|
| waiter_test_utils.h | 53 Waiter* waiter() { return &waiter_; }
60 Waiter waiter_; member in class:mojo::edk::test::SimpleWaiterThread
95 Waiter waiter_; member in class:mojo::edk::test::WaiterThread
|
| wait_set_dispatcher.cc | 42 : waiter_(new WaitSetDispatcher::Waiter(this)) {}
61 entry.second.dispatcher->RemoveAwakable(waiter_.get(), nullptr);
89 const MojoResult result = dispatcher->AddAwakable(waiter_.get(), signals,
121 dispatcher->RemoveAwakable(waiter_.get(), nullptr);
122 // At this point, it should not be possible for |waiter_| to be woken with
182 waiter_.get(), it->second.signals, d, nullptr);
|
| wait_set_dispatcher.h | 71 // Guards |is_closed_|, |waiting_dispatchers_|, and |waiter_|.
95 std::unique_ptr<Waiter> waiter_; member in class:mojo::edk::WaitSetDispatcher
|
| waiter_unittest.cc | 34 waiter_.Init();
57 Waiter* waiter() { return &waiter_; }
67 result = waiter_.Wait(deadline_, &context);
80 Waiter waiter_; // Thread-safe. member in class:mojo::edk::__anon25170::WaitingThread
|
| /external/libchrome/base/synchronization/ |
| waitable_event_watcher.h | 102 AsyncWaiter* waiter_ = nullptr; member in class:base::WaitableEventWatcher
|
| waitable_event_watcher_posix.cc | 157 waiter_ = new AsyncWaiter(SequencedTaskRunnerHandle::Get(), internal_callback,
159 event->Enqueue(waiter_);
207 if (kernel_->Dequeue(waiter_, cancel_flag_.get())) {
212 delete waiter_;
|
