/freebsd-current/contrib/bearssl/src/rsa/ |
H A D | rsa_i15_priv.c | 41 uint16_t *mp, *mq, *s1, *s2, *t1, *t2, *t3; local 91 mq = tmp; 92 if (((uintptr_t)mq & 2) == 0) { 93 mq ++; 99 br_i15_decode(mq, q, qlen); 104 t1 = mq + fwlen; 112 t2 = mq + 2 * fwlen; 113 br_i15_zero(t2, mq[0]); 114 br_i15_mulacc(t2, mq, t1); 125 t3 = mq [all...] |
H A D | rsa_i31_priv.c | 41 uint32_t *mp, *mq, *s1, *s2, *t1, *t2, *t3; local 92 mq = tmp; 93 br_i31_decode(mq, q, qlen); 98 t1 = mq + fwlen; 106 t2 = mq + 2 * fwlen; 107 br_i31_zero(t2, mq[0]); 108 br_i31_mulacc(t2, mq, t1); 119 t3 = mq + 4 * fwlen; 135 mp = mq + 2 * fwlen; 141 q0i = br_i31_ninv31(mq[ [all...] |
H A D | rsa_i32_priv.c | 36 uint32_t *mp, *mq, *s1, *s2, *t1, *t2, *t3; local 44 * The mp, mq, s1, s2, t1 and t2 buffers are large enough to 49 mq = tmp; 83 br_i32_decode(mq, q, qlen); 89 br_i32_mulacc(t2, mp, mq); 113 q0i = br_i32_ninv32(mq[1]); 114 br_i32_decode_reduce(s2, x, xlen, mq); 115 br_i32_modpow(s2, sk->dq, sk->dqlen, mq, q0i, t1, t2); 141 * We need mq, s2 and t2. We use the t3 buffer as destination. 147 br_i32_mulacc(t3, mq, t [all...] |
H A D | rsa_i62_priv.c | 43 uint32_t *mp, *mq, *s1, *s2, *t1, *t2, *t3; local 94 mq = (uint32_t *)tmp; 95 br_i31_decode(mq, q, qlen); 109 br_i31_zero(t2, mq[0]); 110 br_i31_mulacc(t2, mq, t1); 143 q0i = br_i31_ninv31(mq[1]); 145 br_i31_decode_reduce(s2, x, xlen, mq); 146 r &= br_i62_modpow_opt(s2, sk->dq, sk->dqlen, mq, q0i, 184 * We need mq, s2 and t2. We use the t3 buffer as destination. 188 * now, mq i [all...] |
/freebsd-current/contrib/sendmail/include/sm/ |
H A D | ixlen.h | 16 # define XLENDECL bool mq=false; \ 18 # define XLENRESET mq=false, xlen = 0 20 if (mq) { ++xlen; mq=false; } \ 21 else if (SM_IS_MQ(c)) mq=true; \
|
/freebsd-current/contrib/sendmail/libsm/ |
H A D | t-ixlen.sh | 23 4:��mq�� 24 17:��mq��@sendmail.com
|
/freebsd-current/tests/sys/mqueue/ |
H A D | mqtest3.c | 32 mqd_t mq; local 41 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr); 42 if (mq == (mqd_t)-1) 44 status = mq_getattr(mq, &attr); 54 mq_close(mq); 58 mq = mq_open(MQNAME, O_RDWR); 59 if (mq == (mqd_t)-1) 64 FD_SET(mq_getfd_np(mq), &set); 66 status = select(mq_getfd_np(mq) + 1, &set, NULL, 70 status = mq_receive(mq, bu [all...] |
H A D | mqtest2.c | 29 mqd_t mq; local 39 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr); 40 if (mq == (mqd_t)-1) 42 status = mq_getattr(mq, &attr); 51 mq_close(mq); 55 mq = mq_open(MQNAME, O_RDWR); 56 if (mq == (mqd_t)-1) 61 status = mq_receive(mq, buf, attr.mq_msgsize, &prio); 73 mq_close(mq); 87 status = mq_send(mq, bu [all...] |
H A D | mqtest1.c | 18 mqd_t mq; local 25 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr); 26 if (mq == (mqd_t)-1) 31 status = mq_getattr(mq, &attr2); 41 status = mq_notify(mq, &sigev); 44 status = mq_notify(mq, &sigev); 49 status = mq_notify(mq, NULL); 52 status = mq_close(mq);
|
H A D | mqtest4.c | 32 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); 54 mq_close(mq); 56 mq = mq_open(MQNAME, O_RDWR); 57 if (mq == (mqd_t)-1) 59 EV_SET(&kev, mq_getfd_np(mq), EVFILT_READ, EV_ADD, 0, 0, 0); 69 status = mq_receive(mq, buf, attr.mq_msgsize, &prio); 81 mq_close(mq); [all...] |
H A D | mqtest5.c | 35 mqd_t mq; local 52 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr); 53 if (mq == (mqd_t)-1) 55 status = mq_getattr(mq, &attr); 70 mq_close(mq); 71 mq = mq_open(MQNAME, O_RDWR | O_NONBLOCK); 72 if (mq == (mqd_t)-1) 77 status = mq_notify(mq, &sigev); 85 status = mq_receive(mq, buf, attr.mq_msgsize, &prio); 97 mq_close(mq); [all...] |
/freebsd-current/sys/kern/ |
H A D | uipc_mqueue.c | 258 static void mqueue_free(struct mqueue *mq); 259 static int mqueue_send(struct mqueue *mq, const char *msg_ptr, 262 static int mqueue_receive(struct mqueue *mq, char *msg_ptr, 265 static int _mqueue_send(struct mqueue *mq, struct mqueue_msg *msg, 267 static int _mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg, 269 static void mqueue_send_notification(struct mqueue *mq); 991 struct mqueue *mq; local 997 mq = mqueue_alloc(NULL); 998 if (mq == NULL) 1014 pn->mn_data = mq; 1344 struct mqueue *mq; local 1593 struct mqueue *mq; local 1617 mqueue_free(struct mqueue *mq) 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) argument 1757 _mqueue_send(struct mqueue *mq, struct mqueue_msg *msg, int timo) argument 1813 mqueue_send_notification(struct mqueue *mq) argument 1844 mqueue_receive(struct mqueue *mq, char *msg_ptr, size_t msg_len, unsigned *msg_prio, int waitok, const struct timespec *abs_timeout) argument 1914 _mqueue_recv(struct mqueue *mq, struct mqueue_msg **msg, int timo) argument 1990 notifier_remove(struct proc *p, struct mqueue *mq, int fd) argument 2014 struct mqueue *mq; local 2230 struct mqueue *mq; local 2281 struct mqueue *mq; local 2318 struct mqueue *mq; local 2356 struct mqueue *mq; local 2474 struct mqueue *mq; local 2505 struct mqueue *mq; local 2527 struct mqueue *mq = FPTOMQ(fp); local 2631 struct mqueue *mq = FPTOMQ(fp); local 2648 struct mqueue *mq = FPTOMQ(kn->kn_fp); local 2661 struct mqueue *mq = FPTOMQ(kn->kn_fp); local 2670 struct mqueue *mq = FPTOMQ(kn->kn_fp); local [all...] |
/freebsd-current/contrib/capsicum-test/ |
H A D | mqueue.cc | 32 int mq = mq_open_("/cap_mq", O_RDWR|O_CREAT, 0644, NULL); local 36 if (mq < 0 && errno == ENOSYS) { 39 EXPECT_OK(mq); 47 int cap_read_mq = dup(mq); 50 int cap_write_mq = dup(mq); 53 int cap_poll_mq = dup(mq); 56 EXPECT_OK(mq_close_(mq));
|
/freebsd-current/contrib/unbound/dnstap/ |
H A D | dtstream.h | 253 * @param mq: message queue. 255 void dt_msg_queue_delete(struct dt_msg_queue* mq); 261 * @param mq: message queue. 269 void dt_msg_queue_submit(struct dt_msg_queue* mq, void* buf, size_t len); 300 * @param mq: message queue to register. 304 struct dt_msg_queue* mq); 309 * @param mq: message queue. 312 struct dt_msg_queue* mq);
|
H A D | dtstream.c | 106 struct dt_msg_queue* mq = calloc(1, sizeof(*mq)); local 107 if(!mq) return NULL; 108 mq->maxsize = 1*1024*1024; /* set max size of buffer, per worker, 111 mq->wakeup_timer = comm_timer_create(base, mq_wakeup_cb, mq); 112 if(!mq->wakeup_timer) { 113 free(mq); 116 lock_basic_init(&mq->lock); 117 lock_protect(&mq 123 dt_msg_queue_clear(struct dt_msg_queue* mq) argument 139 dt_msg_queue_delete(struct dt_msg_queue* mq) argument 178 struct dt_msg_queue* mq = (struct dt_msg_queue*)arg; local 191 dt_msg_queue_start_timer(struct dt_msg_queue* mq, int wakeupnow) argument 230 dt_msg_queue_submit(struct dt_msg_queue* mq, void* buf, size_t len) argument 448 dt_io_thread_register_queue(struct dt_io_thread* dtio, struct dt_msg_queue* mq) argument 463 dt_io_thread_unregister_queue(struct dt_io_thread* dtio, struct dt_msg_queue* mq) argument 489 dt_msg_queue_pop(struct dt_msg_queue* mq, void** buf, size_t* len) argument 511 dtio_find_in_queue(struct dt_io_thread* dtio, struct dt_msg_queue* mq) argument [all...] |
/freebsd-current/sys/netpfil/ipfw/test/ |
H A D | test_dn_sched.c | 39 if (q->mq.head) 40 dn_free_pkts(q->mq.head); 60 mq_append(&q->mq, m);
|
/freebsd-current/sys/netpfil/ipfw/ |
H A D | dn_sched_fq_codel.h | 60 struct mq mq; /* list of packets */ member in struct:fq_codel_flow 141 next: m = q->mq.head; 144 q->mq.head = m->m_nextpkt;
|
H A D | dn_sched_prio.c | 132 if (q->mq.head == NULL) { 170 if (q->mq.head == NULL) 182 * can simply append q->mq.head to q2->... 185 oldq->mq.tail->m_nextpkt = q->mq.head; 186 oldq->mq.tail = q->mq.tail; 191 q->mq.tail = q->mq.head = NULL;
|
H A D | dn_sched.h | 83 * should internally check for (m != q->mq.head) 174 m = q->mq.head; 182 q->mq.head = m->m_nextpkt; 183 q->mq.count--;
|
H A D | ip_dn_private.h | 80 struct mq { /* a basic queue of packets*/ struct 188 struct mq mq; member in struct:delay_line 252 struct mq mq; /* packets queue */ member in struct:dn_queue 460 mq_append(struct mq *q, struct mbuf *m)
|
H A D | dn_sched_wf2q.c | 143 if (m != q->mq.head) { 146 if (m != q->mq.head) /* queue was already busy */ 251 if (q->mq.head == 0) { /* not backlogged any more. */ 255 uint64_t len = q->mq.head->m_pkthdr.len; 314 if (_q->mq.head != NULL) { 315 wf2qp_enqueue(_q->_si, _q, _q->mq.head);
|
/freebsd-current/sys/dev/oce/ |
H A D | oce_queue.c | 68 static void oce_mq_free(struct oce_mq *mq); 147 sc->mq = oce_mq_create(sc, sc->eq[0], 64); 148 if (!sc->mq) 188 if (sc->mq) 189 oce_mq_free(sc->mq); 634 struct oce_mq *mq = NULL; local 646 /* allocate the mq */ 647 mq = malloc(sizeof(struct oce_mq), M_DEVBUF, M_NOWAIT | M_ZERO); 648 if (!mq) { 653 mq 734 oce_mq_free(struct oce_mq *mq) argument 941 oce_start_mq(struct oce_mq *mq) argument [all...] |
/freebsd-current/lib/librt/ |
H A D | mq.c | 73 struct __mq *mq; local 76 mq = malloc(sizeof(struct __mq)); 77 if (mq == NULL) 80 mq->oshandle = __sys_kmq_open(name, oflag, mode, attr); 81 if (mq->oshandle != -1) { 82 mq->node = NULL; 83 return (mq); 86 free(mq);
|
H A D | Makefile | 17 SRCS+= aio.c mq.c sigev_thread.c timer.c
|
/freebsd-current/sys/sys/ |
H A D | mbuf.h | 1570 mbufq_init(struct mbufq *mq, int maxlen) argument 1573 STAILQ_INIT(&mq->mq_head); 1574 mq->mq_maxlen = maxlen; 1575 mq->mq_len = 0; 1579 mbufq_flush(struct mbufq *mq) argument 1583 m = STAILQ_FIRST(&mq->mq_head); 1584 STAILQ_INIT(&mq->mq_head); 1585 mq->mq_len = 0; 1590 mbufq_drain(struct mbufq *mq) argument 1594 n = mbufq_flush(mq); 1602 mbufq_first(const struct mbufq *mq) argument 1609 mbufq_last(const struct mbufq *mq) argument 1616 mbufq_empty(const struct mbufq *mq) argument 1622 mbufq_full(const struct mbufq *mq) argument 1629 mbufq_len(const struct mbufq *mq) argument 1636 mbufq_enqueue(struct mbufq *mq, struct mbuf *m) argument 1647 mbufq_dequeue(struct mbufq *mq) argument 1661 mbufq_prepend(struct mbufq *mq, struct mbuf *m) argument [all...] |