Lines Matching defs:wql
287 #define WQSPREV(wqs, wql) ((wait_queue_link_t)queue_prev( \
288 ((&(wqs)->wqs_setlinks == (queue_t)(wql)) ? \
289 (queue_t)(wql) : &(wql)->wql_setlinks)))
291 #define WQSNEXT(wqs, wql) ((wait_queue_link_t)queue_next( \
292 ((&(wqs)->wqs_setlinks == (queue_t)(wql)) ? \
293 (queue_t)(wql) : &(wql)->wql_setlinks)))
295 #define WAIT_QUEUE_SET_LINK_CHECK(wqs, wql) \
296 WQASSERT((((wql)->wql_type == WAIT_QUEUE_LINK) && \
297 ((wql)->wql_setqueue == (wqs)) && \
298 ((wql)->wql_queue->wq_type == _WAIT_QUEUE_inited) && \
299 (WQSNEXT((wqs), WQSPREV((wqs),(wql))) == (wql))), \
300 "wait queue set links corruption: wqs=%#x, wql=%#x", \
301 (wqs), (wql))
361 wait_queue_link_t wql = (wait_queue_link_t)wq_element;
363 if (wql->wql_setqueue == wq_set)
414 wait_queue_link_t wql)
451 wql->wql_queue = wq;
452 queue_enter(&wq->wq_queue, wql, wait_queue_link_t, wql_links);
453 wql->wql_setqueue = wq_set;
454 queue_enter(&wq_set->wqs_setlinks, wql, wait_queue_link_t, wql_setlinks);
455 wql->wql_type = WAIT_QUEUE_LINK;
478 wait_queue_link_t wql;
481 wql = (wait_queue_link_t) kalloc(sizeof(struct _wait_queue_link));
482 if (wql == WAIT_QUEUE_LINK_NULL)
485 ret = wait_queue_link_noalloc(wq, wq_set, wql);
487 kfree(wql, sizeof(struct _wait_queue_link));
502 wait_queue_link_t wql)
507 wql->wql_queue = WAIT_QUEUE_NULL;
508 queue_remove(&wq->wq_queue, wql, wait_queue_link_t, wql_links);
509 wql->wql_setqueue = WAIT_QUEUE_SET_NULL;
510 queue_remove(&wq_set->wqs_setlinks, wql, wait_queue_link_t, wql_setlinks);
511 wql->wql_type = WAIT_QUEUE_UNLINKED;
531 wait_queue_link_t wql;
546 wql = (wait_queue_link_t)wq_element;
548 if (wql->wql_setqueue == wq_set) {
550 wait_queue_unlink_locked(wq, wq_set, wql);
554 kfree(wql, sizeof(struct _wait_queue_link));
582 wait_queue_link_t wql;
606 wql = (wait_queue_link_t)wq_element;
607 wq_set = wql->wql_setqueue;
609 wait_queue_unlink_locked(wq, wq_set, wql);
636 wait_queue_link_t wql;
660 wql = (wait_queue_link_t)wq_element;
661 wq_set = wql->wql_setqueue;
663 wait_queue_unlink_locked(wq, wq_set, wql);
665 enqueue(links, &wql->wql_links);
673 wql = (wait_queue_link_t) dequeue(links);
674 kfree(wql, sizeof(struct _wait_queue_link));
694 wait_queue_link_t wql;
709 wql = (wait_queue_link_t)queue_first(q);
710 while (!queue_end(q, (queue_entry_t)wql)) {
711 WAIT_QUEUE_SET_LINK_CHECK(wq_set, wql);
712 wq = wql->wql_queue;
714 wait_queue_unlink_locked(wq, wq_set, wql);
716 wql = (wait_queue_link_t)queue_first(q);
751 wait_queue_link_t wql;
770 wql = (wait_queue_link_t)queue_first(q);
771 while (!queue_end(q, (queue_entry_t)wql)) {
772 WAIT_QUEUE_SET_LINK_CHECK(wq_set, wql);
773 wq = wql->wql_queue;
775 wait_queue_unlink_locked(wq, wq_set, wql);
777 enqueue(links, &wql->wql_links);
778 wql = (wait_queue_link_t)queue_first(q);
790 wql = (wait_queue_link_t) dequeue(links);
791 kfree(wql, sizeof(struct _wait_queue_link));
822 wait_queue_link_t wql = (wait_queue_link_t)wq_element;
823 wait_queue_set_t wq_set = wql->wql_setqueue;
826 wait_queue_unlink_locked(wq, wq_set, wql);
830 kfree(wql,sizeof(struct _wait_queue_link));
1003 wait_queue_link_t wql = (wait_queue_link_t)wq_element;
1009 set_queue = (wait_queue_t)wql->wql_setqueue;
1206 wait_queue_link_t wql = (wait_queue_link_t)wq_element;
1212 set_queue = (wait_queue_t)wql->wql_setqueue;
1323 wait_queue_link_t wql = (wait_queue_link_t)wq_element;
1326 set_queue = (wait_queue_t)wql->wql_setqueue;