| /freebsd-src/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) dt_msg_queue_clear() argument
139 dt_msg_queue_delete(struct dt_msg_queue * mq) dt_msg_queue_delete() argument
178 struct dt_msg_queue* mq = (struct dt_msg_queue*)arg; mq_wakeup_cb() local
191 dt_msg_queue_start_timer(struct dt_msg_queue * mq,int wakeupnow) dt_msg_queue_start_timer() argument
230 dt_msg_queue_submit(struct dt_msg_queue * mq,void * buf,size_t len) dt_msg_queue_submit() argument
449 dt_io_thread_register_queue(struct dt_io_thread * dtio,struct dt_msg_queue * mq) dt_io_thread_register_queue() argument
464 dt_io_thread_unregister_queue(struct dt_io_thread * dtio,struct dt_msg_queue * mq) dt_io_thread_unregister_queue() argument
489 dt_msg_queue_pop(struct dt_msg_queue * mq,void ** buf,size_t * len) dt_msg_queue_pop() argument
512 dtio_find_in_queue(struct dt_io_thread * dtio,struct dt_msg_queue * mq) dtio_find_in_queue() argument
[all...] |
| /freebsd-src/sys/kern/ |
| H A D | uipc_mqueue.c | 991 struct mqueue *mq; in mqfs_create() local
1344 struct mqueue *mq; mqfs_read() local
1593 struct mqueue *mq; mqueue_alloc() local
1617 mqueue_free(struct mqueue * mq) mqueue_free() argument
1689 mqueue_send(struct mqueue * mq,const char * msg_ptr,size_t msg_len,unsigned msg_prio,int waitok,const struct timespec * abs_timeout) mqueue_send() argument
1757 _mqueue_send(struct mqueue * mq,struct mqueue_msg * msg,int timo) _mqueue_send() argument
1813 mqueue_send_notification(struct mqueue * mq) mqueue_send_notification() argument
1844 mqueue_receive(struct mqueue * mq,char * msg_ptr,size_t msg_len,unsigned * msg_prio,int waitok,const struct timespec * abs_timeout) mqueue_receive() argument
1914 _mqueue_recv(struct mqueue * mq,struct mqueue_msg ** msg,int timo) _mqueue_recv() argument
1990 notifier_remove(struct proc * p,struct mqueue * mq,int fd) notifier_remove() argument
2014 struct mqueue *mq; kern_kmq_open() local
2230 struct mqueue *mq; kern_kmq_setattr() local
2281 struct mqueue *mq; kern_kmq_timedreceive() local
2318 struct mqueue *mq; kern_kmq_timedsend() local
2356 struct mqueue *mq; kern_kmq_notify() local
2474 struct mqueue *mq; mqueue_fdclose() local
2505 struct mqueue *mq; mq_proc_exit() local
2527 struct mqueue *mq = FPTOMQ(fp); mqf_poll() local
2631 struct mqueue *mq = FPTOMQ(fp); mqf_kqfilter() local
2648 struct mqueue *mq = FPTOMQ(kn->kn_fp); filt_mqdetach() local
2661 struct mqueue *mq = FPTOMQ(kn->kn_fp); filt_mqread() local
2670 struct mqueue *mq = FPTOMQ(kn->kn_fp); filt_mqwrite() local
[all...] |
| /freebsd-src/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-src/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
|
| H A D | dn_sched_fq_pie.c | 106 struct mq mq; /* list of packets */ member
|
| /freebsd-src/contrib/capsicum-test/ |
| H A D | mqueue.cc | 32 int mq = mq_open_("/cap_mq", O_RDWR|O_CREAT, 0644, NULL); variable
|
| /freebsd-src/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_i31_priv.c | 41 uint32_t *mp, *mq, *s1, *s2, *t1, *t2, *t3; in br_rsa_i31_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_i62_priv.c | 43 uint32_t *mp, *mq, *s1, *s2, *t1, *t2, *t3; in br_rsa_i62_private() local
|
| /freebsd-src/sys/sys/ |
| H A D | mbuf.h | 1572 mbufq_init(struct mbufq * mq,int maxlen) mbufq_init() argument
1581 mbufq_flush(struct mbufq * mq) mbufq_flush() argument
1592 mbufq_drain(struct mbufq * mq) mbufq_drain() argument
1604 mbufq_first(const struct mbufq * mq) mbufq_first() argument
1611 mbufq_last(const struct mbufq * mq) mbufq_last() argument
1618 mbufq_empty(const struct mbufq * mq) mbufq_empty() argument
1624 mbufq_full(const struct mbufq * mq) mbufq_full() argument
1631 mbufq_len(const struct mbufq * mq) mbufq_len() argument
1638 mbufq_enqueue(struct mbufq * mq,struct mbuf * m) mbufq_enqueue() argument
1649 mbufq_dequeue(struct mbufq * mq) mbufq_dequeue() argument
1663 mbufq_prepend(struct mbufq * mq,struct mbuf * m) mbufq_prepend() argument
[all...] |
| /freebsd-src/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-src/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-src/sys/netinet/ |
| H A D | igmp.c | 545 igmp_dispatch_queue(struct mbufq *mq, int limit, const int loop) in igmp_dispatch_queue() argument
2384 struct mbufq *mq; igmp_initial_join() local
2687 igmp_v3_enqueue_group_record(struct mbufq * mq,struct in_multi * inm,const int is_state_change,const int is_group_query,const int is_source_query) igmp_v3_enqueue_group_record() argument
3048 igmp_v3_enqueue_filter_change(struct mbufq * mq,struct in_multi * inm) igmp_v3_enqueue_filter_change() argument
[all...] |
| /freebsd-src/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-src/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-src/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; icl_cxgbei_conn_transfer_setup() local
[all...] |
| /freebsd-src/lib/librt/ |
| H A D | mq.c | 73 struct __mq *mq; in __mq_open() local
|
| /freebsd-src/sys/netpfil/ipfw/nat64/ |
| H A D | nat64_translate.c | 537 struct mbufq *mq, struct mbuf *m, uint32_t mtu, uint16_t ip_id, in nat64_fragment6()
1231 struct mbufq mq; in nat64_do_handle_ip4() local
|