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

123

/freebsd-current/contrib/bearssl/src/rsa/
H A Drsa_i15_priv.c41 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 Drsa_i31_priv.c41 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 Drsa_i32_priv.c36 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 Drsa_i62_priv.c43 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 Dixlen.h16 # 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 Dt-ixlen.sh23 4:��mq��
24 17:��mq��@sendmail.com
/freebsd-current/tests/sys/mqueue/
H A Dmqtest3.c32 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 Dmqtest2.c29 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 Dmqtest1.c18 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 Dmqtest4.c32 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 Dmqtest5.c35 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 Duipc_mqueue.c258 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 Dmqueue.cc32 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 Ddtstream.h253 * @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 Ddtstream.c106 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 Dtest_dn_sched.c39 if (q->mq.head)
40 dn_free_pkts(q->mq.head);
60 mq_append(&q->mq, m);
/freebsd-current/sys/netpfil/ipfw/
H A Ddn_sched_fq_codel.h60 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 Ddn_sched_prio.c132 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 Ddn_sched.h83 * 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 Dip_dn_private.h80 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 Ddn_sched_wf2q.c143 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 Doce_queue.c68 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 Dmq.c73 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 DMakefile17 SRCS+= aio.c mq.c sigev_thread.c timer.c
/freebsd-current/sys/sys/
H A Dmbuf.h1570 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...]

Completed in 207 milliseconds

123