| /freebsd/contrib/unbound/dnstap/ |
| H A D | dtstream.c | 106 struct dt_msg_queue* mq = calloc(1, sizeof(*mq)); in dt_msg_queue_create() local
123 dt_msg_queue_clear(struct dt_msg_queue* mq) in dt_msg_queue_clear()
139 dt_msg_queue_delete(struct dt_msg_queue* mq) in dt_msg_queue_delete()
178 struct dt_msg_queue* mq = (struct dt_msg_queue*)arg; in mq_wakeup_cb() local
188 dt_msg_queue_start_timer(struct dt_msg_queue* mq, int wakeupnow) in dt_msg_queue_start_timer()
235 dt_msg_queue_submit(struct dt_msg_queue* mq, void* buf, size_t len) in dt_msg_queue_submit()
455 struct dt_msg_queue* mq) in dt_io_thread_register_queue()
470 struct dt_msg_queue* mq) in dt_io_thread_unregister_queue()
495 static int dt_msg_queue_pop(struct dt_msg_queue* mq, void** buf, in dt_msg_queue_pop()
518 struct dt_msg_queue* mq) in dtio_find_in_queue()
|
| /freebsd/sys/kern/ |
| H A D | uipc_mqueue.c | 992 struct mqueue *mq; in mqfs_create() local
1345 struct mqueue *mq; in mqfs_read() local
1594 struct mqueue *mq; in mqueue_alloc() local
1618 mqueue_free(struct mqueue *mq) in mqueue_free()
1690 mqueue_send(struct mqueue *mq, const char *msg_ptr, in mqueue_send()
1758 _mqueue_send(struct mqueue *mq, struct mqueue_msg *msg, int timo) in _mqueue_send()
1814 mqueue_send_notification(struct mqueue *mq) in mqueue_send_notification()
1845 mqueue_receive(struct mqueue *mq, char *msg_ptr, in mqueue_receive()
1915 _mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg, int timo) in _mqueue_recv()
1991 notifier_remove(struct proc *p, struct mqueue *mq, int fd) in notifier_remove()
[all …]
|
| /freebsd/tests/sys/mqueue/ |
| H A D | mqtest1.c | 18 mqd_t mq; in main() local
|
| H A D | mqtest2.c | 29 mqd_t mq; in main() local
|
| H A D | mqtest3.c | 32 mqd_t mq; in main() local
|
| H A D | mqtest4.c | 32 mqd_t mq; in main() local
|
| H A D | mqtest5.c | 35 mqd_t mq; in main() local
|
| /freebsd/sys/netpfil/ipfw/ |
| H A D | ip_dn_private.h | 80 struct mq { /* a basic queue of packets*/ struct
81 struct mbuf *head, *tail;
82 int count;
188 struct mq mq; member
252 struct mq mq; /* packets queue */ member
|
| H A D | dn_sched_fq_codel.h | 60 struct mq mq; /* list of packets */ member
|
| /freebsd/contrib/capsicum-test/ |
| H A D | mqueue.cc | 32 int mq = mq_open_("/cap_mq", O_RDWR|O_CREAT, 0644, NULL); variable
|
| /freebsd/contrib/bearssl/src/rsa/ |
| H A D | rsa_i32_priv.c | 36 uint32_t *mp, *mq, *s1, *s2, *t1, *t2, *t3; in br_rsa_i32_private() local
|
| H A D | rsa_i15_priv.c | 41 uint16_t *mp, *mq, *s1, *s2, *t1, *t2, *t3; in br_rsa_i15_private() local
|
| H A D | rsa_i31_priv.c | 41 uint32_t *mp, *mq, *s1, *s2, *t1, *t2, *t3; in br_rsa_i31_private() local
|
| H A D | rsa_i62_priv.c | 43 uint32_t *mp, *mq, *s1, *s2, *t1, *t2, *t3; in br_rsa_i62_private() local
|
| /freebsd/sys/sys/ |
| H A D | mbuf.h | 1579 mbufq_init(struct mbufq *mq, int maxlen) in mbufq_init()
1588 mbufq_flush(struct mbufq *mq) in mbufq_flush()
1599 mbufq_drain(struct mbufq *mq) in mbufq_drain()
1611 mbufq_first(const struct mbufq *mq) in mbufq_first()
1618 mbufq_last(const struct mbufq *mq) in mbufq_last()
1625 mbufq_empty(const struct mbufq *mq) in mbufq_empty()
1631 mbufq_full(const struct mbufq *mq) in mbufq_full()
1638 mbufq_len(const struct mbufq *mq) in mbufq_len()
1645 mbufq_enqueue(struct mbufq *mq, struct mbuf *m) in mbufq_enqueue()
1656 mbufq_dequeue(struct mbufq *mq) in mbufq_dequeue()
[all …]
|
| /freebsd/sys/dev/oce/ |
| H A D | oce_queue.c | 634 struct oce_mq *mq = NULL; in oce_mq_create() local
734 oce_mq_free(struct oce_mq *mq) in oce_mq_free()
941 oce_start_mq(struct oce_mq *mq) in oce_start_mq()
|
| /freebsd/sys/netinet6/ |
| H A D | mld6.c | 419 mld_dispatch_queue(struct mbufq *mq, int limit) in mld_dispatch_queue()
1948 struct mbufq *mq; in mld_initial_join() local
2278 mld_v2_enqueue_group_record(struct mbufq *mq, struct in6_multi *inm, in mld_v2_enqueue_group_record()
2663 mld_v2_enqueue_filter_change(struct mbufq *mq, struct in6_multi *inm) in mld_v2_enqueue_filter_change()
|
| /freebsd/sys/netinet/ |
| H A D | igmp.c | 556 igmp_dispatch_queue(struct mbufq *mq, int limit, const int loop) in igmp_dispatch_queue()
2396 struct mbufq *mq; in igmp_initial_join() local
2699 igmp_v3_enqueue_group_record(struct mbufq *mq, struct in_multi *inm, in igmp_v3_enqueue_group_record()
3060 igmp_v3_enqueue_filter_change(struct mbufq *mq, struct in_multi *inm) in igmp_v3_enqueue_filter_change()
|
| /freebsd/sys/dev/qcom_ess_edma/ |
| H A D | qcom_ess_edma_rx.c | 329 struct mbufq *mq) in qcom_ess_edma_rx_ring_complete()
|
| H A D | qcom_ess_edma_gmac.c | 439 int rx_queue, struct mbufq *mq) in qcom_ess_edma_gmac_receive_frames()
|
| /freebsd/sys/dev/ocs_fc/ |
| H A D | ocs_hw_queues.c | 72 hw_mq_t *mq = NULL; in ocs_hw_init_queues() local
505 hw_mq_t *mq = ocs_malloc(hw->os, sizeof(*mq), OCS_M_ZERO | OCS_M_NOWAIT); in hw_new_mq() local
826 hw_del_mq(hw_mq_t *mq) in hw_del_mq()
895 hw_mq_t *mq; in hw_queue_dump() local
|
| H A D | ocs_ddump.c | 557 hw_mq_t *mq; in hw_queue_ddump() local
|
| /freebsd/sys/netpfil/ipfw/test/ |
| H A D | main.c | 141 struct mq *mq = (struct mq *)si; in default_enqueue() local
156 struct mq *mq = (struct mq *)si; in default_dequeue() local
|
| /freebsd/sys/dev/cxgbe/cxgbei/ |
| H A D | icl_cxgbei.c | 439 struct mbufq mq; in icl_cxgbei_tx_main() local
1418 struct mbufq mq; in icl_cxgbei_conn_task_setup() local
1581 struct mbufq mq; in icl_cxgbei_conn_transfer_setup() local
|
| /freebsd/lib/librt/ |
| H A D | mq.c | 85 struct __mq *mq; __mq_open() local
|