sys/net/wg/if_wg.c

501

wg_queue_both(struct wg_queue *parallel, struct wg_queue *serial,

sys/net/wg/if_wg.c

517

lockmgr(&parallel->q_mtx, LK_EXCLUSIVE);

sys/net/wg/if_wg.c

518

if (parallel->q_len < MAX_QUEUED_PKT) {

sys/net/wg/if_wg.c

519

parallel->q_len++;

sys/net/wg/if_wg.c

520

STAILQ_INSERT_TAIL(&parallel->q_queue, pkt, p_parallel);

sys/net/wg/if_wg.c

522

lockmgr(&parallel->q_mtx, LK_RELEASE);

sys/net/wg/if_wg.c

531

lockmgr(&parallel->q_mtx, LK_RELEASE);

sys/net/wg/if_wg.c

558

wg_queue_dequeue_parallel(struct wg_queue *parallel)

sys/net/wg/if_wg.c

562

lockmgr(&parallel->q_mtx, LK_EXCLUSIVE);

sys/net/wg/if_wg.c

563

if (parallel->q_len > 0) {

sys/net/wg/if_wg.c

564

parallel->q_len--;

sys/net/wg/if_wg.c

565

pkt = STAILQ_FIRST(&parallel->q_queue);

sys/net/wg/if_wg.c

566

STAILQ_REMOVE_HEAD(&parallel->q_queue, p_parallel);

sys/net/wg/if_wg.c

568

lockmgr(&parallel->q_mtx, LK_RELEASE);

usr.bin/paste/paste.c

106

rval = parallel(argv);

usr.bin/paste/paste.c

52

static int parallel(char **);