Searched refs:mq (Results 1 - 25 of 36) sorted by relevance

12

/freebsd-10-stable/tests/sys/mqueue/
H A Dmqtest3.c33 mqd_t mq; local
42 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr);
43 if (mq == (mqd_t)-1)
45 status = mq_getattr(mq, &attr);
55 mq_close(mq);
59 mq = mq_open(MQNAME, O_RDWR);
60 if (mq == (mqd_t)-1)
65 FD_SET(__mq_oshandle(mq), &set);
67 status = select(__mq_oshandle(mq)+1, &set, NULL, NULL, NULL);
70 status = mq_receive(mq, bu
[all...]
H A Dmqtest2.c30 mqd_t mq; local
40 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr);
41 if (mq == (mqd_t)-1)
43 status = mq_getattr(mq, &attr);
52 mq_close(mq);
56 mq = mq_open(MQNAME, O_RDWR);
57 if (mq == (mqd_t)-1)
62 status = mq_receive(mq, buf, attr.mq_msgsize, &prio);
74 mq_close(mq);
88 status = mq_send(mq, bu
[all...]
H A Dmqtest1.c19 mqd_t mq; local
26 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr);
27 if (mq == (mqd_t)-1)
32 status = mq_getattr(mq, &attr2);
42 status = mq_notify(mq, &sigev);
45 status = mq_notify(mq, &sigev);
50 status = mq_notify(mq, NULL);
53 status = mq_close(mq);
H A Dmqtest4.c33 mqd_t mq; local
43 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr);
44 if (mq == (mqd_t) -1)
46 status = mq_getattr(mq, &attr);
55 mq_close(mq);
57 mq = mq_open(MQNAME, O_RDWR);
58 if (mq == (mqd_t)-1)
60 EV_SET(&kev, __mq_oshandle(mq), EVFILT_READ, EV_ADD, 0, 0, 0);
70 status = mq_receive(mq, buf, attr.mq_msgsize, &prio);
82 mq_close(mq);
[all...]
H A Dmqtest5.c36 mqd_t mq; local
53 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr);
54 if (mq == (mqd_t)-1)
56 status = mq_getattr(mq, &attr);
71 mq_close(mq);
72 mq = mq_open(MQNAME, O_RDWR | O_NONBLOCK);
73 if (mq == (mqd_t)-1)
78 status = mq_notify(mq, &sigev);
86 status = mq_receive(mq, buf, attr.mq_msgsize, &prio);
98 mq_close(mq);
[all...]
/freebsd-10-stable/sys/kern/
H A Duipc_mqueue.c247 static void mqueue_free(struct mqueue *mq);
248 static int mqueue_send(struct mqueue *mq, const char *msg_ptr,
251 static int mqueue_receive(struct mqueue *mq, char *msg_ptr,
254 static int _mqueue_send(struct mqueue *mq, struct mqueue_msg *msg,
256 static int _mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg,
258 static void mqueue_send_notification(struct mqueue *mq);
980 struct mqueue *mq; local
986 mq = mqueue_alloc(NULL);
987 if (mq == NULL)
1005 pn->mn_data = mq;
1337 struct mqueue *mq; local
1588 struct mqueue *mq; local
1612 mqueue_free(struct mqueue *mq) argument
1684 mqueue_send(struct mqueue *mq, const char *msg_ptr, size_t msg_len, unsigned msg_prio, int waitok, const struct timespec *abs_timeout) argument
1753 _mqueue_send(struct mqueue *mq, struct mqueue_msg *msg, int timo) argument
1809 mqueue_send_notification(struct mqueue *mq) argument
1840 mqueue_receive(struct mqueue *mq, char *msg_ptr, size_t msg_len, unsigned *msg_prio, int waitok, const struct timespec *abs_timeout) argument
1911 _mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg, int timo) argument
1987 notifier_remove(struct proc *p, struct mqueue *mq, int fd) argument
2011 struct mqueue *mq; local
2207 struct mqueue *mq; local
2256 struct mqueue *mq; local
2282 struct mqueue *mq; local
2312 struct mqueue *mq; local
2431 struct mqueue *mq; local
2459 struct mqueue *mq; local
2510 struct mqueue *mq = FPTOMQ(fp); local
2615 struct mqueue *mq = FPTOMQ(fp); local
2632 struct mqueue *mq = FPTOMQ(kn->kn_fp); local
2645 struct mqueue *mq = FPTOMQ(kn->kn_fp); local
2654 struct mqueue *mq = FPTOMQ(kn->kn_fp); local
2795 struct mqueue *mq; local
2825 struct mqueue *mq; local
[all...]
/freebsd-10-stable/sys/netpfil/ipfw/test/
H A Dtest_dn_sched.c35 if (q->mq.head)
36 dn_free_pkts(q->mq.head);
56 mq_append(&q->mq, m);
H A Ddn_test.h161 mq_append(struct mq *q, struct mbuf *m)
/freebsd-10-stable/sys/dev/oce/
H A Doce_queue.c67 static void oce_mq_free(struct oce_mq *mq);
147 sc->mq = oce_mq_create(sc, sc->eq[0], 64);
148 if (!sc->mq)
186 if (sc->mq)
187 oce_mq_free(sc->mq);
662 struct oce_mq *mq = NULL; local
675 /* allocate the mq */
676 mq = malloc(sizeof(struct oce_mq), M_DEVBUF, M_NOWAIT | M_ZERO);
677 if (!mq) {
682 mq
768 oce_mq_free(struct oce_mq *mq) argument
983 oce_start_mq(struct oce_mq *mq) argument
[all...]
/freebsd-10-stable/lib/librt/
H A DMakefile17 SRCS+= aio.c mq.c sigev_thread.c timer.c
H A Dmq.c86 struct __mq *mq; local
89 mq = malloc(sizeof(struct __mq));
90 if (mq == NULL)
93 mq->oshandle = __sys_kmq_open(name, oflag, mode, attr);
94 if (mq->oshandle != -1) {
95 mq->node = NULL;
96 return (mq);
99 free(mq);
/freebsd-10-stable/sys/netpfil/ipfw/
H A Ddn_sched_fq_codel.h62 struct mq mq; /* list of packets */ member in struct:fq_codel_flow
141 struct mbuf *m = q->mq.head;
145 q->mq.head = m->m_nextpkt;
H A Ddn_sched_prio.c131 if (q->mq.head == NULL) {
169 if (q->mq.head == NULL)
181 * can simply append q->mq.head to q2->...
184 oldq->mq.tail->m_nextpkt = q->mq.head;
185 oldq->mq.tail = q->mq.tail;
190 q->mq.tail = q->mq.head = NULL;
H A Dip_dn_private.h88 struct mq { /* a basic queue of packets*/ struct
163 struct mq pending;
193 struct mq mq; member in struct:delay_line
257 struct mq mq; /* packets queue */ member in struct:dn_queue
441 mq_append(struct mq *q, struct mbuf *m)
H A Ddn_sched.h81 * should internally check for (m != q->mq.head)
169 struct mbuf *m = q->mq.head;
177 q->mq.head = m->m_nextpkt;
H A Ddn_sched_wf2q.c142 if (m != q->mq.head) {
145 if (m != q->mq.head) /* queue was already busy */
247 if (q->mq.head == 0) { /* not backlogged any more. */
251 uint64_t len = q->mq.head->m_pkthdr.len;
310 if (_q->mq.head != NULL) {
311 wf2qp_enqueue(_q->_si, _q, _q->mq.head);
337 if (q->mq.head == NULL) {
H A Ddn_sched_rr.c156 if (m != q->mq.head) {
159 if (m != q->mq.head)
185 struct mbuf *m = rrq->q.mq.head;
265 if (_q->mq.head != NULL) {
H A Dip_dn_io.c263 mq_append(struct mq *q, struct mbuf *m)
507 mq_append(&q->mq, m);
528 transmit_event(struct mq *q, struct delay_line *dline, uint64_t now)
534 while ((m = dline->mq.head) != NULL) {
538 dline->mq.head = m->m_nextpkt;
576 serve_sched(struct mq *q, struct dn_sch_inst *si, uint64_t now)
578 struct mq def_q;
581 int delay_line_idle = (si->dline.mq.head == NULL);
607 mq_append(&si->dline.mq, m);
640 struct mq
[all...]
H A Ddn_aqm_codel.c192 struct mbuf *m = q->mq.head;
196 q->mq.head = m->m_nextpkt;
264 mq_append(&q->mq, m);
H A Ddn_sched_fifo.c95 dn_free_pkts(q->mq.head);
H A Ddn_sched_fq_pie.c109 struct mq mq; /* list of packets */ member in struct:fq_pie_flow
341 struct mbuf *m = q->mq.head;
345 q->mq.head = m->m_nextpkt;
747 mq_append(&q->mq, m);
764 struct mbuf *m = q->mq.head;
768 q->mq.head = m->m_nextpkt;
H A Ddn_aqm_pie.c331 struct mbuf *m = q->mq.head;
335 q->mq.head = m->m_nextpkt;
554 mq_append(&q->mq, m);
H A Ddn_sched_fq_codel.c156 struct mbuf *m = q->mq.head;
160 q->mq.head = m->m_nextpkt;
196 mq_append(&q->mq, m);
H A Ddn_sched_qfq.c520 if (cl->_q.mq.head == NULL) {
526 len = cl->_q.mq.head->m_pkthdr.len;
652 if (m != _q->mq.head) {
656 if (m != _q->mq.head)
/freebsd-10-stable/contrib/gcc/config/rs6000/
H A Ddarwin-fallback.c277 uint32_t mq; member in struct:gcc_mcontext32

Completed in 225 milliseconds

12