Home
last modified time | relevance | path

Searched refs:msgq (Results 1 – 25 of 501) sorted by relevance

12345678910>>...21

/dports/multimedia/libv4l/linux-5.13-rc2/drivers/gpu/drm/nouveau/nvkm/falcon/
H A Dmsgq.c29 msgq->position = nvkm_falcon_rd32(msgq->qmgr->falcon, msgq->tail_reg); in nvkm_falcon_msgq_open()
38 nvkm_falcon_wr32(falcon, msgq->tail_reg, msgq->position); in nvkm_falcon_msgq_close()
46 u32 head = nvkm_falcon_rd32(msgq->qmgr->falcon, msgq->head_reg); in nvkm_falcon_msgq_empty()
47 u32 tail = nvkm_falcon_rd32(msgq->qmgr->falcon, msgq->tail_reg); in nvkm_falcon_msgq_empty()
60 msgq->position = msgq->offset; in nvkm_falcon_msgq_pop()
161 msgq->head_reg = falcon->func->msgq.head; in nvkm_falcon_msgq_recv_initmsg()
162 msgq->tail_reg = falcon->func->msgq.tail; in nvkm_falcon_msgq_recv_initmsg()
182 msgq->head_reg = func->msgq.head + index * func->msgq.stride; in nvkm_falcon_msgq_init()
183 msgq->tail_reg = func->msgq.tail + index * func->msgq.stride; in nvkm_falcon_msgq_init()
194 if (msgq) { in nvkm_falcon_msgq_del()
[all …]
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/gpu/drm/nouveau/nvkm/falcon/
H A Dmsgq.c29 msgq->position = nvkm_falcon_rd32(msgq->qmgr->falcon, msgq->tail_reg); in nvkm_falcon_msgq_open()
38 nvkm_falcon_wr32(falcon, msgq->tail_reg, msgq->position); in nvkm_falcon_msgq_close()
46 u32 head = nvkm_falcon_rd32(msgq->qmgr->falcon, msgq->head_reg); in nvkm_falcon_msgq_empty()
47 u32 tail = nvkm_falcon_rd32(msgq->qmgr->falcon, msgq->tail_reg); in nvkm_falcon_msgq_empty()
60 msgq->position = msgq->offset; in nvkm_falcon_msgq_pop()
161 msgq->head_reg = falcon->func->msgq.head; in nvkm_falcon_msgq_recv_initmsg()
162 msgq->tail_reg = falcon->func->msgq.tail; in nvkm_falcon_msgq_recv_initmsg()
182 msgq->head_reg = func->msgq.head + index * func->msgq.stride; in nvkm_falcon_msgq_init()
183 msgq->tail_reg = func->msgq.tail + index * func->msgq.stride; in nvkm_falcon_msgq_init()
194 if (msgq) { in nvkm_falcon_msgq_del()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/gpu/drm/nouveau/nvkm/falcon/
H A Dmsgq.c29 msgq->position = nvkm_falcon_rd32(msgq->qmgr->falcon, msgq->tail_reg); in nvkm_falcon_msgq_open()
38 nvkm_falcon_wr32(falcon, msgq->tail_reg, msgq->position); in nvkm_falcon_msgq_close()
46 u32 head = nvkm_falcon_rd32(msgq->qmgr->falcon, msgq->head_reg); in nvkm_falcon_msgq_empty()
47 u32 tail = nvkm_falcon_rd32(msgq->qmgr->falcon, msgq->tail_reg); in nvkm_falcon_msgq_empty()
60 msgq->position = msgq->offset; in nvkm_falcon_msgq_pop()
161 msgq->head_reg = falcon->func->msgq.head; in nvkm_falcon_msgq_recv_initmsg()
162 msgq->tail_reg = falcon->func->msgq.tail; in nvkm_falcon_msgq_recv_initmsg()
182 msgq->head_reg = func->msgq.head + index * func->msgq.stride; in nvkm_falcon_msgq_init()
183 msgq->tail_reg = func->msgq.tail + index * func->msgq.stride; in nvkm_falcon_msgq_init()
194 if (msgq) { in nvkm_falcon_msgq_del()
[all …]
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/scsi/arm/
H A Dmsgqueue.c26 if ((mq = msgq->free) != NULL) in mqe_alloc()
27 msgq->free = mq->next; in mqe_alloc()
41 mq->next = msgq->free; in mqe_free()
42 msgq->free = mq; in mqe_free()
55 msgq->qe = NULL; in msgqueue_initialise()
56 msgq->free = &msgq->entries[0]; in msgqueue_initialise()
59 msgq->entries[i].next = &msgq->entries[i + 1]; in msgqueue_initialise()
70 void msgqueue_free(MsgQueue_t *msgq) in msgqueue_free() argument
133 mqp = &msgq->qe; in msgqueue_addmsg()
154 mqe_free(msgq, mq); in msgqueue_flush()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/scsi/arm/
H A Dmsgqueue.c26 if ((mq = msgq->free) != NULL) in mqe_alloc()
27 msgq->free = mq->next; in mqe_alloc()
41 mq->next = msgq->free; in mqe_free()
42 msgq->free = mq; in mqe_free()
55 msgq->qe = NULL; in msgqueue_initialise()
56 msgq->free = &msgq->entries[0]; in msgqueue_initialise()
59 msgq->entries[i].next = &msgq->entries[i + 1]; in msgqueue_initialise()
70 void msgqueue_free(MsgQueue_t *msgq) in msgqueue_free() argument
133 mqp = &msgq->qe; in msgqueue_addmsg()
154 mqe_free(msgq, mq); in msgqueue_flush()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/scsi/arm/
H A Dmsgqueue.c26 if ((mq = msgq->free) != NULL) in mqe_alloc()
27 msgq->free = mq->next; in mqe_alloc()
41 mq->next = msgq->free; in mqe_free()
42 msgq->free = mq; in mqe_free()
55 msgq->qe = NULL; in msgqueue_initialise()
56 msgq->free = &msgq->entries[0]; in msgqueue_initialise()
59 msgq->entries[i].next = &msgq->entries[i + 1]; in msgqueue_initialise()
70 void msgqueue_free(MsgQueue_t *msgq) in msgqueue_free() argument
133 mqp = &msgq->qe; in msgqueue_addmsg()
154 mqe_free(msgq, mq); in msgqueue_flush()
[all …]
/dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/erts/emulator/test/driver_SUITE_data/
H A Dotp_9302_drv.c147 Otp9302MsgQ *msgq = adata->msgq; in enqueue_reply() local
150 if (msgq->mtx) in enqueue_reply()
152 if (msgq->end) in enqueue_reply()
155 msgq->end = msgq->start = adata; in enqueue_reply()
157 if (msgq->mtx) in enqueue_reply()
163 Otp9302MsgQ *msgq = adata->msgq; in dequeue_replies() local
164 if (msgq->mtx) in dequeue_replies()
171 msgq->start = msgq->start->next; in dequeue_replies()
175 msgq->start = msgq->end = NULL; in dequeue_replies()
176 if (msgq->mtx) in dequeue_replies()
[all …]
/dports/lang/erlang-runtime24/otp-OTP-24.1.7/erts/emulator/test/driver_SUITE_data/
H A Dotp_9302_drv.c147 Otp9302MsgQ *msgq = adata->msgq; in enqueue_reply() local
150 if (msgq->mtx) in enqueue_reply()
152 if (msgq->end) in enqueue_reply()
155 msgq->end = msgq->start = adata; in enqueue_reply()
157 if (msgq->mtx) in enqueue_reply()
163 Otp9302MsgQ *msgq = adata->msgq; in dequeue_replies() local
164 if (msgq->mtx) in dequeue_replies()
171 msgq->start = msgq->start->next; in dequeue_replies()
175 msgq->start = msgq->end = NULL; in dequeue_replies()
176 if (msgq->mtx) in dequeue_replies()
[all …]
/dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/erts/emulator/test/driver_SUITE_data/
H A Dotp_9302_drv.c147 Otp9302MsgQ *msgq = adata->msgq; in enqueue_reply() local
150 if (msgq->mtx) in enqueue_reply()
152 if (msgq->end) in enqueue_reply()
155 msgq->end = msgq->start = adata; in enqueue_reply()
157 if (msgq->mtx) in enqueue_reply()
163 Otp9302MsgQ *msgq = adata->msgq; in dequeue_replies() local
164 if (msgq->mtx) in dequeue_replies()
171 msgq->start = msgq->start->next; in dequeue_replies()
175 msgq->start = msgq->end = NULL; in dequeue_replies()
176 if (msgq->mtx) in dequeue_replies()
[all …]
/dports/lang/erlang-wx/otp-OTP-24.1.7/erts/emulator/test/driver_SUITE_data/
H A Dotp_9302_drv.c147 Otp9302MsgQ *msgq = adata->msgq; in enqueue_reply() local
150 if (msgq->mtx) in enqueue_reply()
152 if (msgq->end) in enqueue_reply()
155 msgq->end = msgq->start = adata; in enqueue_reply()
157 if (msgq->mtx) in enqueue_reply()
163 Otp9302MsgQ *msgq = adata->msgq; in dequeue_replies() local
164 if (msgq->mtx) in dequeue_replies()
171 msgq->start = msgq->start->next; in dequeue_replies()
175 msgq->start = msgq->end = NULL; in dequeue_replies()
176 if (msgq->mtx) in dequeue_replies()
[all …]
/dports/lang/erlang/otp-OTP-24.1.7/erts/emulator/test/driver_SUITE_data/
H A Dotp_9302_drv.c147 Otp9302MsgQ *msgq = adata->msgq; in enqueue_reply() local
150 if (msgq->mtx) in enqueue_reply()
152 if (msgq->end) in enqueue_reply()
155 msgq->end = msgq->start = adata; in enqueue_reply()
157 if (msgq->mtx) in enqueue_reply()
163 Otp9302MsgQ *msgq = adata->msgq; in dequeue_replies() local
164 if (msgq->mtx) in dequeue_replies()
171 msgq->start = msgq->start->next; in dequeue_replies()
175 msgq->start = msgq->end = NULL; in dequeue_replies()
176 if (msgq->mtx) in dequeue_replies()
[all …]
/dports/lang/erlang-java/otp-OTP-24.1.7/erts/emulator/test/driver_SUITE_data/
H A Dotp_9302_drv.c147 Otp9302MsgQ *msgq = adata->msgq; in enqueue_reply() local
150 if (msgq->mtx) in enqueue_reply()
152 if (msgq->end) in enqueue_reply()
155 msgq->end = msgq->start = adata; in enqueue_reply()
157 if (msgq->mtx) in enqueue_reply()
163 Otp9302MsgQ *msgq = adata->msgq; in dequeue_replies() local
164 if (msgq->mtx) in dequeue_replies()
171 msgq->start = msgq->start->next; in dequeue_replies()
175 msgq->start = msgq->end = NULL; in dequeue_replies()
176 if (msgq->mtx) in dequeue_replies()
[all …]
/dports/lang/erlang-runtime21/otp-OTP-21.3.8.24/erts/emulator/test/driver_SUITE_data/
H A Dotp_9302_drv.c147 Otp9302MsgQ *msgq = adata->msgq; in enqueue_reply() local
150 if (msgq->mtx) in enqueue_reply()
152 if (msgq->end) in enqueue_reply()
155 msgq->end = msgq->start = adata; in enqueue_reply()
157 if (msgq->mtx) in enqueue_reply()
163 Otp9302MsgQ *msgq = adata->msgq; in dequeue_replies() local
164 if (msgq->mtx) in dequeue_replies()
171 msgq->start = msgq->start->next; in dequeue_replies()
175 msgq->start = msgq->end = NULL; in dequeue_replies()
176 if (msgq->mtx) in dequeue_replies()
[all …]
/dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/net/ethernet/brocade/bna/
H A Dbfa_msgq.c307 cmdq->msgq = msgq; in bfa_msgq_cmdq_attach()
494 rspq->msgq = msgq; in bfa_msgq_rspq_attach()
522 bfa_nw_ioc_mbox_queue(msgq->ioc, &msgq->init_mb, NULL, NULL); in bfa_msgq_init()
559 bfa_wc_init(&msgq->init_wc, bfa_msgq_init, msgq); in bfa_msgq_notify()
599 msgq->rspq.addr.pa = pa; in bfa_msgq_memclaim()
605 msgq->ioc = ioc; in bfa_msgq_attach()
607 bfa_msgq_cmdq_attach(&msgq->cmdq, msgq); in bfa_msgq_attach()
608 bfa_msgq_rspq_attach(&msgq->rspq, msgq); in bfa_msgq_attach()
610 bfa_nw_ioc_mbox_regisr(msgq->ioc, BFI_MC_MSGQ, bfa_msgq_isr, msgq); in bfa_msgq_attach()
611 bfa_ioc_notify_init(&msgq->ioc_notify, bfa_msgq_notify, msgq); in bfa_msgq_attach()
[all …]
/dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/net/ethernet/brocade/bna/
H A Dbfa_msgq.c307 cmdq->msgq = msgq; in bfa_msgq_cmdq_attach()
494 rspq->msgq = msgq; in bfa_msgq_rspq_attach()
522 bfa_nw_ioc_mbox_queue(msgq->ioc, &msgq->init_mb, NULL, NULL); in bfa_msgq_init()
559 bfa_wc_init(&msgq->init_wc, bfa_msgq_init, msgq); in bfa_msgq_notify()
599 msgq->rspq.addr.pa = pa; in bfa_msgq_memclaim()
605 msgq->ioc = ioc; in bfa_msgq_attach()
607 bfa_msgq_cmdq_attach(&msgq->cmdq, msgq); in bfa_msgq_attach()
608 bfa_msgq_rspq_attach(&msgq->rspq, msgq); in bfa_msgq_attach()
610 bfa_nw_ioc_mbox_regisr(msgq->ioc, BFI_MC_MSGQ, bfa_msgq_isr, msgq); in bfa_msgq_attach()
611 bfa_ioc_notify_init(&msgq->ioc_notify, bfa_msgq_notify, msgq); in bfa_msgq_attach()
[all …]
/dports/multimedia/libv4l/linux-5.13-rc2/drivers/net/ethernet/brocade/bna/
H A Dbfa_msgq.c307 cmdq->msgq = msgq; in bfa_msgq_cmdq_attach()
494 rspq->msgq = msgq; in bfa_msgq_rspq_attach()
522 bfa_nw_ioc_mbox_queue(msgq->ioc, &msgq->init_mb, NULL, NULL); in bfa_msgq_init()
559 bfa_wc_init(&msgq->init_wc, bfa_msgq_init, msgq); in bfa_msgq_notify()
599 msgq->rspq.addr.pa = pa; in bfa_msgq_memclaim()
605 msgq->ioc = ioc; in bfa_msgq_attach()
607 bfa_msgq_cmdq_attach(&msgq->cmdq, msgq); in bfa_msgq_attach()
608 bfa_msgq_rspq_attach(&msgq->rspq, msgq); in bfa_msgq_attach()
610 bfa_nw_ioc_mbox_regisr(msgq->ioc, BFI_MC_MSGQ, bfa_msgq_isr, msgq); in bfa_msgq_attach()
611 bfa_ioc_notify_init(&msgq->ioc_notify, bfa_msgq_notify, msgq); in bfa_msgq_attach()
[all …]
/dports/editors/nvi2/nvi2-2.2.0/vi/
H A Dv_util.c46 msgq(sp, M_BERR, "195|Movement past the end-of-file"); in v_eof()
69 msgq(sp, M_BERR, "196|Movement past the end-of-line"); in v_eol()
82 msgq(sp, M_BERR, "197|No cursor movement made"); in v_nomove()
95 msgq(sp, M_BERR, "198|Already at the beginning of the file"); in v_sof()
109 msgq(sp, M_BERR, "200|Already in the first column"); in v_sol()
138 msgq(sp, M_ERR, in v_emsg()
142 msgq(sp, M_BERR, "209|The file is empty"); in v_emsg()
145 msgq(sp, M_BERR, "202|Already at end-of-file"); in v_emsg()
148 msgq(sp, M_BERR, "203|Already at end-of-line"); in v_emsg()
152 msgq(sp, in v_emsg()
[all …]
/dports/editors/vigor/vigor-0.016/vi/
H A Dv_util.c52 msgq(sp, M_BERR, "195|Movement past the end-of-file");
77 msgq(sp, M_BERR, "196|Movement past the end-of-line");
91 msgq(sp, M_BERR, "197|No cursor movement made");
106 msgq(sp, M_BERR, "198|Already at the beginning of the file");
121 msgq(sp, M_BERR, "200|Already in the first column");
155 msgq(sp, M_ERR,
159 msgq(sp, M_BERR, "209|The file is empty");
162 msgq(sp, M_BERR, "202|Already at end-of-file");
165 msgq(sp, M_BERR, "203|Already at end-of-line");
169 msgq(sp,
[all …]
/dports/lang/spidermonkey60/firefox-60.9.0/media/sphinxbase/src/libsphinxbase/util/
H A Dsbthread.c61 sbmsgq_t *msgq; member
231 sbmsgq_t *msgq; in sbmsgq_init() local
233 msgq = ckd_calloc(1, sizeof(*msgq)); in sbmsgq_init()
243 return msgq; in sbmsgq_init()
252 ckd_free(msgq); in sbmsgq_free()
367 sbmsgq_t *msgq; member
448 sbmsgq_t *msgq; in sbmsgq_init() local
450 msgq = ckd_calloc(1, sizeof(*msgq)); in sbmsgq_init()
463 return msgq; in sbmsgq_init()
473 ckd_free(msgq); in sbmsgq_free()
[all …]
/dports/www/firefox-legacy/firefox-52.8.0esr/media/sphinxbase/src/libsphinxbase/util/
H A Dsbthread.c61 sbmsgq_t *msgq; member
231 sbmsgq_t *msgq; in sbmsgq_init() local
233 msgq = ckd_calloc(1, sizeof(*msgq)); in sbmsgq_init()
243 return msgq; in sbmsgq_init()
252 ckd_free(msgq); in sbmsgq_free()
367 sbmsgq_t *msgq; member
448 sbmsgq_t *msgq; in sbmsgq_init() local
450 msgq = ckd_calloc(1, sizeof(*msgq)); in sbmsgq_init()
463 return msgq; in sbmsgq_init()
473 ckd_free(msgq); in sbmsgq_free()
[all …]
/dports/audio/sphinxbase/sphinxbase-0.8/src/libsphinxbase/util/
H A Dsbthread.c59 sbmsgq_t *msgq; member
229 sbmsgq_t *msgq; in sbmsgq_init() local
231 msgq = ckd_calloc(1, sizeof(*msgq)); in sbmsgq_init()
241 return msgq; in sbmsgq_init()
250 ckd_free(msgq); in sbmsgq_free()
365 sbmsgq_t *msgq; member
446 sbmsgq_t *msgq; in sbmsgq_init() local
448 msgq = ckd_calloc(1, sizeof(*msgq)); in sbmsgq_init()
461 return msgq; in sbmsgq_init()
471 ckd_free(msgq); in sbmsgq_free()
[all …]
/dports/mail/courier/courier-0.65.3/courier/
H A Dcdmsgq.h27 class msgq {
30 msgq *next, *prev; // Sorted by nextdel
31 msgq *nexthash, *prevhash; // Same hash bucket
45 msgq();
46 ~msgq();
48 static std::vector<msgq> queue;
49 static std::vector<msgq *> queuehashfirst, queuehashlast;
54 static void logmsgid(msgq *q);
55 static msgq *queuehead, *queuetail,
61 static msgq *findq(ino_t);
[all …]
H A Dcourierd.C175 struct msgq *p; in diskspacelow()
253 msgq::init(queuehi); in courierbmain()
307 msgq *mp; in courierbmain()
313 doscantmp=msgq::tmpscan(); in courierbmain()
333 for (mp=msgq::queuehead; mp && in courierbmain()
354 msgq::queuescan(); in courierbmain()
360 if ( msgq::queuehead && msgq::queuehead->nextsenddel in courierbmain()
413 clog_msg_int(msgq::inprogress); in courierbmain()
428 msgq::inprogress == 0) in courierbmain()
476 for (mp=msgq::queuehead; mp; in courierbmain()
[all …]
/dports/comms/gnuradio/gnuradio-3.8.4.0/gr-blocks/python/blocks/
H A Dqa_message.py41 self.msgq = gr.msg_queue()
44 self.msgq = None
75 self.msgq.insert_tail(gr.message(0))
76 self.assertEquals(1, self.msgq.count())
77 self.msgq.insert_tail(gr.message(1))
78 self.assertEquals(2, self.msgq.count())
79 msg0 = self.msgq.delete_head()
81 msg1 = self.msgq.delete_head()
83 self.assertEquals(0, self.msgq.count())
89 self.msgq.insert_tail(gr.message(0))
[all …]
H A Dqa_bin_statistics.py110 msgq = gr.msg_queue()
131 self.assertEqual(4, msgq.count())
133 m = parse_msg(msgq.delete_head())
142 msgq = gr.msg_queue()
159 self.assertEqual(1, msgq.count())
161 m = parse_msg(msgq.delete_head())
172 msgq = gr.msg_queue()
189 self.assertEqual(1, msgq.count())
191 m = parse_msg(msgq.delete_head())
204 msgq = gr.msg_queue()
[all …]

12345678910>>...21