Searched refs:waiter (Results 1 - 5 of 5) sorted by relevance

/fuchsia/zircon/kernel/object/
H A Dchannel_dispatcher.cpp118 void ChannelDispatcher::RemoveWaiter(MessageWaiter* waiter) { argument
120 if (!waiter->InContainer()) {
123 waiters_.erase(*waiter);
132 // Remove waiter from list.
134 auto waiter = waiters_.pop_front(); local
135 waiter->Cancel(ZX_ERR_CANCELED);
150 // Remove waiter from list.
152 auto waiter = waiters_.pop_front(); local
153 waiter->Cancel(ZX_ERR_PEER_CLOSED);
208 auto waiter local
258 ResumeInterruptedCall(MessageWaiter* waiter, zx_time_t deadline, fbl::unique_ptr<MessagePacket>* reply) argument
[all...]
/fuchsia/zircon/third_party/ulib/musl/src/thread/
H A Dcnd_timedwait.c11 struct waiter { struct
12 struct waiter *prev, *next;
34 struct waiter node = {
39 /* Add our waiter node onto the condvar's list. We add the node to the
72 * This thread must therefore remove the waiter node from the
75 /* Access to cv object is valid because this waiter was not
77 * after seeing a LEAVING waiter without getting notified
82 /* Remove our waiter node from the list. */
94 /* It is possible that __private_cond_signal() saw our waiter node
114 * 1) If we do the unlock_requeue() below, a condvar waiter wil
[all...]
/fuchsia/zircon/third_party/ulib/musl/pthread/
H A Dpthread_cond_timedwait.c5 * struct waiter
14 * protected by the lock on the cv. Detached waiter lists are never
20 struct waiter { struct
21 struct waiter *prev, *next;
47 struct waiter node = {
53 /* Add our waiter node onto the condvar's list. We add the node to the
86 * This thread must therefore remove the waiter node from the
89 /* Access to cv object is valid because this waiter was not
91 * after seeing a LEAVING waiter without getting notified
96 /* Remove our waiter nod
[all...]
/fuchsia/zircon/kernel/object/include/object/
H A Dchannel_dispatcher.h51 zx_status_t ResumeInterruptedCall(MessageWaiter* waiter, zx_time_t deadline,
104 void RemoveWaiter(MessageWaiter* waiter);
/fuchsia/zircon/kernel/syscalls/
H A Dchannel.cpp384 auto waiter = ThreadDispatcher::GetCurrent()->GetMessageWaiter(); local
385 fbl::RefPtr<ChannelDispatcher> channel = waiter->get_channel();
390 status = channel->ResumeInterruptedCall(waiter, deadline, &reply);

Completed in 38 milliseconds