lib/barrelfish/waitset.c

107     ws->pending = ws->polled = ws->idle = ws->waiting = NULL;
118     // FIXME: do we want to support cancelling all the pending events/channels?
119     if (ws->pending || ws->waiting_threads) {
172 /// Returns a channel with a pending event on the given waitset matching
201     // check a pending queue for matching event
202     for (chan = ws->pending; chan;) {
208         if (chan == ws->pending)
268         dequeue(&ws->pending, chan);
303 /// Wake up other thread if there's more pending events
306     if (ws->pending && ws->waiting_threads) {
315  * \brief Get next pending event
317  * Check if there is a pending event that matches current thread and return it.
318  * Pending events are in a pending queue and in a waiting queue.
319  * A pending event then will be removed from a pending/waiting queue and become
322  * If there's no pending event, block this thread.
323  * If there's a pending event but it doesn't match our thread, don't remove it
324  * from a pending queue and wake up a matching thread.
359         chan = ws->pending; // check a pending queue
365                 dequeue(&ws->pending, chan);
382                         dequeue(&ws->pending, chan);
417  * \brief Check if there is an event pending on given waitset
424  * \returns LIB_ERR_NO_EVENT if nothing is pending
530  * Check if there is any pending activity on some channel, or deferred
533  * Do not wait!  In case of no pending events, return err LIB_ERR_NO_EVENT.
544     // are there any pending events on the waitset?
758         dequeue(&ws->pending, chan);
817         dequeue(&ws->pending, chan);
818         enqueue(&new_ws->pending, chan);
838  * Marks the given channel as having a pending event, causing some future call
853     // no-op if already pending
867     // else mark channel pending and move to end of pending event queue
868     enqueue(&ws->pending, chan);
885  * Marks the given channel as having a pending event, causing some future call
930     // mark channel pending and place on end of pending event queue
932     enqueue(&ws->pending, chan);
934     //     ws->pending = chan;