Lines Matching refs:parallel
505 wg_queue_both(struct wg_queue *parallel, struct wg_queue *serial, in wg_queue_both() argument
521 lockmgr(¶llel->q_mtx, LK_EXCLUSIVE); in wg_queue_both()
522 if (parallel->q_len < MAX_QUEUED_PKT) { in wg_queue_both()
523 parallel->q_len++; in wg_queue_both()
524 STAILQ_INSERT_TAIL(¶llel->q_queue, pkt, p_parallel); in wg_queue_both()
526 lockmgr(¶llel->q_mtx, LK_RELEASE); in wg_queue_both()
535 lockmgr(¶llel->q_mtx, LK_RELEASE); in wg_queue_both()
562 wg_queue_dequeue_parallel(struct wg_queue *parallel) in wg_queue_dequeue_parallel() argument
566 lockmgr(¶llel->q_mtx, LK_EXCLUSIVE); in wg_queue_dequeue_parallel()
567 if (parallel->q_len > 0) { in wg_queue_dequeue_parallel()
568 parallel->q_len--; in wg_queue_dequeue_parallel()
569 pkt = STAILQ_FIRST(¶llel->q_queue); in wg_queue_dequeue_parallel()
570 STAILQ_REMOVE_HEAD(¶llel->q_queue, p_parallel); in wg_queue_dequeue_parallel()
572 lockmgr(¶llel->q_mtx, LK_RELEASE); in wg_queue_dequeue_parallel()