/freebsd-10-stable/tests/sys/mqueue/ |
H A D | mqtest3.c | 33 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 D | mqtest2.c | 30 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 D | mqtest1.c | 19 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 D | mqtest4.c | 33 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 D | mqtest5.c | 36 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 D | uipc_mqueue.c | 247 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 D | test_dn_sched.c | 35 if (q->mq.head) 36 dn_free_pkts(q->mq.head); 56 mq_append(&q->mq, m);
|
H A D | dn_test.h | 161 mq_append(struct mq *q, struct mbuf *m)
|
/freebsd-10-stable/sys/dev/oce/ |
H A D | oce_queue.c | 67 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 D | Makefile | 17 SRCS+= aio.c mq.c sigev_thread.c timer.c
|
H A D | mq.c | 86 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 D | dn_sched_fq_codel.h | 62 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 D | dn_sched_prio.c | 131 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 D | ip_dn_private.h | 88 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 D | dn_sched.h | 81 * should internally check for (m != q->mq.head) 169 struct mbuf *m = q->mq.head; 177 q->mq.head = m->m_nextpkt;
|
H A D | dn_sched_wf2q.c | 142 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 D | dn_sched_rr.c | 156 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 D | ip_dn_io.c | 263 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 D | dn_aqm_codel.c | 192 struct mbuf *m = q->mq.head; 196 q->mq.head = m->m_nextpkt; 264 mq_append(&q->mq, m);
|
H A D | dn_sched_fifo.c | 95 dn_free_pkts(q->mq.head);
|
H A D | dn_sched_fq_pie.c | 109 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 D | dn_aqm_pie.c | 331 struct mbuf *m = q->mq.head; 335 q->mq.head = m->m_nextpkt; 554 mq_append(&q->mq, m);
|
H A D | dn_sched_fq_codel.c | 156 struct mbuf *m = q->mq.head; 160 q->mq.head = m->m_nextpkt; 196 mq_append(&q->mq, m);
|
H A D | dn_sched_qfq.c | 520 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 D | darwin-fallback.c | 277 uint32_t mq; member in struct:gcc_mcontext32
|