Home
last modified time | relevance | path

Searched refs:mq (Results 1 – 25 of 71) sorted by relevance

123

/freebsd/contrib/bearssl/src/rsa/
H A Drsa_i15_priv.c41 uint16_t *mp, *mq, *s1, *s2, *t1, *t2, *t3; in br_rsa_i15_private() local
91 mq = tmp; in br_rsa_i15_private()
92 if (((uintptr_t)mq & 2) == 0) { in br_rsa_i15_private()
93 mq ++; in br_rsa_i15_private()
99 br_i15_decode(mq, q, qlen); in br_rsa_i15_private()
104 t1 = mq + fwlen; in br_rsa_i15_private()
112 t2 = mq + 2 * fwlen; in br_rsa_i15_private()
113 br_i15_zero(t2, mq[0]); in br_rsa_i15_private()
114 br_i15_mulacc(t2, mq, t1); in br_rsa_i15_private()
125 t3 = mq + 4 * fwlen; in br_rsa_i15_private()
[all …]
H A Drsa_i31_priv.c41 uint32_t *mp, *mq, *s1, *s2, *t1, *t2, *t3; in br_rsa_i31_private() local
92 mq = tmp; in br_rsa_i31_private()
93 br_i31_decode(mq, q, qlen); in br_rsa_i31_private()
98 t1 = mq + fwlen; in br_rsa_i31_private()
106 t2 = mq + 2 * fwlen; in br_rsa_i31_private()
107 br_i31_zero(t2, mq[0]); in br_rsa_i31_private()
108 br_i31_mulacc(t2, mq, t1); in br_rsa_i31_private()
119 t3 = mq + 4 * fwlen; in br_rsa_i31_private()
135 mp = mq + 2 * fwlen; in br_rsa_i31_private()
141 q0i = br_i31_ninv31(mq[1]); in br_rsa_i31_private()
[all …]
H A Drsa_i62_priv.c43 uint32_t *mp, *mq, *s1, *s2, *t1, *t2, *t3; in br_rsa_i62_private() local
94 mq = (uint32_t *)tmp; in br_rsa_i62_private()
95 br_i31_decode(mq, q, qlen); in br_rsa_i62_private()
109 br_i31_zero(t2, mq[0]); in br_rsa_i62_private()
110 br_i31_mulacc(t2, mq, t1); in br_rsa_i62_private()
143 q0i = br_i31_ninv31(mq[1]); in br_rsa_i62_private()
145 br_i31_decode_reduce(s2, x, xlen, mq); in br_rsa_i62_private()
146 r &= br_i62_modpow_opt(s2, sk->dq, sk->dqlen, mq, q0i, in br_rsa_i62_private()
192 br_i31_mulacc(t3, mq, t2); in br_rsa_i62_private()
H A Drsa_i32_priv.c36 uint32_t *mp, *mq, *s1, *s2, *t1, *t2, *t3; in br_rsa_i32_private() local
49 mq = tmp; in br_rsa_i32_private()
83 br_i32_decode(mq, q, qlen); in br_rsa_i32_private()
89 br_i32_mulacc(t2, mp, mq); in br_rsa_i32_private()
113 q0i = br_i32_ninv32(mq[1]); in br_rsa_i32_private()
114 br_i32_decode_reduce(s2, x, xlen, mq); in br_rsa_i32_private()
115 br_i32_modpow(s2, sk->dq, sk->dqlen, mq, q0i, t1, t2); in br_rsa_i32_private()
147 br_i32_mulacc(t3, mq, t2); in br_rsa_i32_private()
/freebsd/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; in mqfs_create() local
997 mq = mqueue_alloc(NULL); in mqfs_create()
998 if (mq == NULL) in mqfs_create()
1014 pn->mn_data = mq; in mqfs_create()
[all …]
/freebsd/tests/sys/mqueue/
H A Dmqtest3.c32 mqd_t mq; in main() local
41 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr); in main()
42 if (mq == (mqd_t)-1) in main()
44 status = mq_getattr(mq, &attr); in main()
54 mq_close(mq); in main()
58 mq = mq_open(MQNAME, O_RDWR); in main()
59 if (mq == (mqd_t)-1) in main()
64 FD_SET(mq_getfd_np(mq), &set); in main()
66 status = select(mq_getfd_np(mq) + 1, &set, NULL, in main()
70 status = mq_receive(mq, buf, attr.mq_msgsize, &prio); in main()
[all …]
H A Dmqtest4.c32 mqd_t mq; in main() local
42 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr); in main()
43 if (mq == (mqd_t) -1) in main()
45 status = mq_getattr(mq, &attr); in main()
54 mq_close(mq); in main()
56 mq = mq_open(MQNAME, O_RDWR); in main()
57 if (mq == (mqd_t)-1) in main()
59 EV_SET(&kev, mq_getfd_np(mq), EVFILT_READ, EV_ADD, 0, 0, 0); in main()
69 status = mq_receive(mq, buf, attr.mq_msgsize, &prio); in main()
81 mq_close(mq); in main()
[all …]
H A Dmqtest2.c29 mqd_t mq; in main() local
39 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr); in main()
40 if (mq == (mqd_t)-1) in main()
42 status = mq_getattr(mq, &attr); in main()
51 mq_close(mq); in main()
55 mq = mq_open(MQNAME, O_RDWR); in main()
56 if (mq == (mqd_t)-1) in main()
61 status = mq_receive(mq, buf, attr.mq_msgsize, &prio); in main()
73 mq_close(mq); in main()
87 status = mq_send(mq, buf, attr.mq_msgsize, PRIO); in main()
[all …]
H A Dmqtest5.c35 mqd_t mq; in main() local
52 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr); in main()
53 if (mq == (mqd_t)-1) in main()
55 status = mq_getattr(mq, &attr); in main()
70 mq_close(mq); in main()
71 mq = mq_open(MQNAME, O_RDWR | O_NONBLOCK); in main()
72 if (mq == (mqd_t)-1) in main()
77 status = mq_notify(mq, &sigev); in main()
85 status = mq_receive(mq, buf, attr.mq_msgsize, &prio); in main()
97 mq_close(mq); in main()
[all …]
H A Dmqtest1.c18 mqd_t mq; in main() local
25 mq = mq_open(MQNAME, O_CREAT | O_RDWR | O_EXCL, 0666, &attr); in main()
26 if (mq == (mqd_t)-1) in main()
31 status = mq_getattr(mq, &attr2); in main()
41 status = mq_notify(mq, &sigev); in main()
44 status = mq_notify(mq, &sigev); in main()
49 status = mq_notify(mq, NULL); in main()
52 status = mq_close(mq); in main()
/freebsd/contrib/unbound/dnstap/
H A Ddtstream.c106 struct dt_msg_queue* mq = calloc(1, sizeof(*mq)); in dt_msg_queue_create() local
107 if(!mq) return NULL; in dt_msg_queue_create()
108 mq->maxsize = 1*1024*1024; /* set max size of buffer, per worker, in dt_msg_queue_create()
111 mq->wakeup_timer = comm_timer_create(base, mq_wakeup_cb, mq); in dt_msg_queue_create()
112 if(!mq->wakeup_timer) { in dt_msg_queue_create()
113 free(mq); in dt_msg_queue_create()
116 lock_basic_init(&mq->lock); in dt_msg_queue_create()
117 lock_protect(&mq->lock, mq, sizeof(*mq)); in dt_msg_queue_create()
118 return mq; in dt_msg_queue_create()
123 dt_msg_queue_clear(struct dt_msg_queue* mq) in dt_msg_queue_clear() argument
[all …]
H A Ddtstream.h255 void dt_msg_queue_delete(struct dt_msg_queue* mq);
269 void dt_msg_queue_submit(struct dt_msg_queue* mq, void* buf, size_t len);
304 struct dt_msg_queue* mq);
312 struct dt_msg_queue* mq);
/freebsd/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); in oce_queue_init_all()
148 if (!sc->mq) in oce_queue_init_all()
188 if (sc->mq) in oce_queue_release_all()
189 oce_mq_free(sc->mq); in oce_queue_release_all()
634 struct oce_mq *mq = NULL; in oce_mq_create() local
647 mq = malloc(sizeof(struct oce_mq), M_DEVBUF, M_NOWAIT | M_ZERO); in oce_mq_create()
648 if (!mq) { in oce_mq_create()
653 mq->parent = sc; in oce_mq_create()
655 mq->ring = oce_create_ring_buffer(sc, q_len, sizeof(struct oce_mbx)); in oce_mq_create()
[all …]
/freebsd/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/contrib/capsicum-test/
H A Dmqueue.cc32 int mq = mq_open_("/cap_mq", O_RDWR|O_CREAT, 0644, NULL); variable
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/sys/netpfil/ipfw/
H A Ddn_sched_prio.c132 if (q->mq.head == NULL) { in prio_dequeue()
170 if (q->mq.head == NULL) in prio_new_queue()
185 oldq->mq.tail->m_nextpkt = q->mq.head; in prio_new_queue()
186 oldq->mq.tail = q->mq.tail; in prio_new_queue()
191 q->mq.tail = q->mq.head = NULL; in prio_new_queue()
H A Ddn_sched_fq_codel.h60 struct mq mq; /* list of packets */ member
141 next: m = q->mq.head; in fq_codel_extract_head()
144 q->mq.head = m->m_nextpkt; in fq_codel_extract_head()
H A Dip_dn_private.h80 struct mq { /* a basic queue of packets*/ struct
188 struct mq mq; member
252 struct mq mq; /* packets queue */ member
460 mq_append(struct mq *q, struct mbuf *m) in mq_append()
H A Ddn_sched_wf2q.c143 if (m != q->mq.head) { in wf2qp_enqueue()
146 if (m != q->mq.head) /* queue was already busy */ in wf2qp_enqueue()
251 if (q->mq.head == 0) { /* not backlogged any more. */ in wf2qp_dequeue()
255 uint64_t len = q->mq.head->m_pkthdr.len; in wf2qp_dequeue()
314 if (_q->mq.head != NULL) { in wf2qp_new_queue()
315 wf2qp_enqueue(_q->_si, _q, _q->mq.head); in wf2qp_new_queue()
H A Dip_dn_io.c253 mq_append(struct mq *q, struct mbuf *m) in mq_append()
539 mq_append(&q->mq, m); in dn_enqueue()
560 transmit_event(struct mq *q, struct delay_line *dline, uint64_t now) in transmit_event()
566 while ((m = dline->mq.head) != NULL) { in transmit_event()
570 dline->mq.head = m->m_nextpkt; in transmit_event()
571 dline->mq.count--; in transmit_event()
613 serve_sched(struct mq *q, struct dn_sch_inst *si, uint64_t now) in serve_sched()
615 struct mq def_q; in serve_sched()
618 int delay_line_idle = (si->dline.mq.head == NULL); in serve_sched()
647 mq_append(&si->dline.mq, m); in serve_sched()
[all …]
/freebsd/sys/sys/
H A Dmbuf.h1574 mbufq_init(struct mbufq *mq, int maxlen) in mbufq_init() argument
1577 STAILQ_INIT(&mq->mq_head); in mbufq_init()
1578 mq->mq_maxlen = maxlen; in mbufq_init()
1579 mq->mq_len = 0; in mbufq_init()
1583 mbufq_flush(struct mbufq *mq) in mbufq_flush() argument
1587 m = STAILQ_FIRST(&mq->mq_head); in mbufq_flush()
1588 STAILQ_INIT(&mq->mq_head); in mbufq_flush()
1589 mq->mq_len = 0; in mbufq_flush()
1594 mbufq_drain(struct mbufq *mq) in mbufq_drain() argument
1598 n = mbufq_flush(mq); in mbufq_drain()
[all …]
/freebsd/lib/librt/
H A Dmq.c73 struct __mq *mq;
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; in __mq_open()
83 return (mq); in __mq_open()
86 free(mq); in __mq_open()
85 struct __mq *mq; __mq_open() local
/freebsd/sys/dev/ocs_fc/
H A Docs_hw_queues.c72 hw_mq_t *mq = NULL; in ocs_hw_init_queues() local
256 mq = hw_new_mq(cq, len); in ocs_hw_init_queues()
257 if (mq == NULL) { in ocs_hw_init_queues()
505 hw_mq_t *mq = ocs_malloc(hw->os, sizeof(*mq), OCS_M_ZERO | OCS_M_NOWAIT); in hw_new_mq() local
507 if (mq != NULL) { in hw_new_mq()
508 mq->cq = cq; in hw_new_mq()
509 mq->type = SLI_QTYPE_MQ; in hw_new_mq()
510 mq->instance = cq->eq->hw->mq_count++; in hw_new_mq()
511 mq->entry_count = entry_count; in hw_new_mq()
512 mq->entry_size = OCS_HW_MQ_DEPTH; in hw_new_mq()
[all …]
/freebsd/sys/netpfil/ipfw/test/
H A Dtest_dn_sched.c39 if (q->mq.head) in dn_delete_queue()
40 dn_free_pkts(q->mq.head); in dn_delete_queue()
60 mq_append(&q->mq, m); in dn_enqueue()
H A Dmain.c141 struct mq *mq = (struct mq *)si; in default_enqueue() local
145 if (mq->head == NULL) in default_enqueue()
146 mq->head = m; in default_enqueue()
148 mq->tail->m_nextpkt = m; in default_enqueue()
149 mq->tail = m; in default_enqueue()
156 struct mq *mq = (struct mq *)si; in default_dequeue() local
159 if ((m = mq->head)) { in default_dequeue()
160 m = mq->head; in default_dequeue()
161 mq->head = m->m_nextpkt; in default_dequeue()

123