Home
last modified time | relevance | path

Searched refs:outq (Results 1 – 19 of 19) sorted by relevance

/freebsd-13.1/contrib/xz/src/liblzma/common/
H A Doutqueue.c82 if (outq->bufs == NULL || outq->bufs_mem == NULL) { in lzma_outq_init()
104 outq->bufs = NULL; in lzma_outq_end()
117 assert(outq->bufs_used < outq->bufs_allocated); in lzma_outq_get_buf()
120 lzma_outbuf *buf = &outq->bufs[outq->bufs_pos]; in lzma_outq_get_buf()
121 buf->buf = outq->bufs_mem + outq->bufs_pos * outq->buf_size_max; in lzma_outq_get_buf()
126 if (++outq->bufs_pos == outq->bufs_allocated) in lzma_outq_get_buf()
129 ++outq->bufs_used; in lzma_outq_get_buf()
138 uint32_t i = outq->bufs_pos - outq->bufs_used; in lzma_outq_is_readable()
139 if (outq->bufs_pos < outq->bufs_used) in lzma_outq_is_readable()
157 uint32_t i = outq->bufs_pos - outq->bufs_used; in lzma_outq_read()
[all …]
H A Doutqueue.h91 lzma_outq *outq, const lzma_allocator *allocator,
96 extern void lzma_outq_end(lzma_outq *outq, const lzma_allocator *allocator);
104 extern lzma_outbuf *lzma_outq_get_buf(lzma_outq *outq);
112 extern bool lzma_outq_is_readable(const lzma_outq *outq);
134 extern lzma_ret lzma_outq_read(lzma_outq *restrict outq,
145 lzma_outq_has_buf(const lzma_outq *outq) in lzma_outq_has_buf() argument
147 return outq->bufs_used < outq->bufs_allocated; in lzma_outq_has_buf()
153 lzma_outq_is_empty(const lzma_outq *outq) in lzma_outq_is_empty() argument
155 return outq->bufs_used == 0; in lzma_outq_is_empty()
H A Dstream_encoder_mt.c134 lzma_outq outq; member
208 .compressed_size = thr->coder->outq.buf_size_max, in worker_encode()
238 const size_t out_size = thr->coder->outq.buf_size_max; in worker_encode()
519 if (!lzma_outq_has_buf(&coder->outq)) in get_thread()
544 coder->thr->outbuf = lzma_outq_get_buf(&coder->outq); in get_thread()
648 || !lzma_outq_has_buf(&coder->outq)) in wait_for_work()
649 && !lzma_outq_is_readable(&coder->outq) in wait_for_work()
707 ret = lzma_outq_read(&coder->outq, in stream_encode_mt()
760 if (lzma_outq_is_empty(&coder->outq)) { in stream_encode_mt()
847 lzma_outq_end(&coder->outq, allocator); in stream_encoder_mt_end()
[all …]
/freebsd-13.1/sys/netgraph/
H A Dng_tty.c236 IF_DRAIN(&sc->outq); in ngt_shutdown()
237 mtx_destroy(&(sc)->outq.ifq_mtx); in ngt_shutdown()
328 IF_LOCK(&sc->outq); in ngt_rcvdata()
329 if (_IF_QFULL(&sc->outq)) { in ngt_rcvdata()
330 IF_UNLOCK(&sc->outq); in ngt_rcvdata()
335 _IF_ENQUEUE(&sc->outq, m); in ngt_rcvdata()
337 IF_UNLOCK(&sc->outq); in ngt_rcvdata()
359 IF_DEQUEUE(&sc->outq, m); in ngt_getc_inject()
380 IF_PREPEND(&sc->outq, m); in ngt_getc_inject()
384 IF_LOCK(&sc->outq); in ngt_getc_inject()
[all …]
/freebsd-13.1/sys/netgraph/bluetooth/drivers/h4/
H A Dng_h4.c586 IF_DEQUEUE(&sc->outq, m);
609 IF_PREPEND(&sc->outq, m);
727 _IF_DRAIN(&sc->outq);
765 _IF_DRAIN(&sc->outq);
798 if (_IF_QFULL(&sc->outq)) {
814 _IF_ENQUEUE(&sc->outq, m);
815 qlen = _IF_QLEN(&sc->outq);
866 _IF_QLEN(&sc->outq),
867 sc->outq.ifq_maxlen,
881 _IF_DRAIN(&sc->outq);
[all …]
H A Dng_h4_var.h86 struct ifqueue outq; /* Queue of outgoing mbuf's */ member
88 #define NG_H4_LOCK(sc) IF_LOCK(&sc->outq)
89 #define NG_H4_UNLOCK(sc) IF_UNLOCK(&sc->outq)
/freebsd-13.1/sys/dev/sound/midi/
H A Dmidi.c113 MIDIQ_HEAD(, char) inq, outq;
347 MIDIQ_INIT(m->outq, buf, outqsize); in midi_init()
382 if (MIDIQ_BUF(m->outq)) in midi_init()
383 free(MIDIQ_BUF(m->outq), M_MIDI); in midi_init()
598 MIDIQ_DEQ(m->outq, buf, used); in midi_out()
599 if (MIDIQ_EMPTY(m->outq)) { in midi_out()
647 if (MIDIQ_SIZE(m->outq) == 0) in midi_open()
865 MIDIQ_ENQ(m->outq, buf, used); in midi_write()
1095 if (MIDIQ_SIZE(m->outq) == 0) in midisynth_open()
1244 MIDIQ_ENQ(m->outq, buf, used); in midisynth_writeraw()
[all …]
/freebsd-13.1/sys/dev/pms/RefTisa/sallsdk/spc/
H A Dsassp.c289 bit8 inq, outq; in saFastSSPPrepare() local
344 outq = OUQ(fc->queueNum); in saFastSSPPrepare()
500 opCode, outq, 0); in saFastSSPPrepare()
605 bit8 inq = 0, outq = 0; in saSSPStart() local
633 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saSSPStart()
636 SA_DBG3(("saSSPStart: inq %d outq %d deviceId 0x%x\n", inq,outq,pDevice->DeviceMapIndex)); in saSSPStart()
772 …SA_DBG2(("saSSPStart: did %d ioq %d / %d tag %d\n", pDevice->DeviceMapIndex, inq, outq, pRequest->… in saSSPStart()
773 circularOQ = &saRoot->outboundQueue[outq]; in saSSPStart()
1653 saRoot->interruptVecIndexBitMap[0] |= (1 << outq); in saSSPStart()
1699 bit8 inq, outq; in saSSPAbort() local
[all …]
H A Dsasata.c85 bit8 inq = 0, outq = 0; in saSATAStart() local
99 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saSATAStart()
556 outq, in saSATAStart()
613 bit8 inq, outq; in saSATAAbort() local
627 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saSATAAbort()
825 …ret = mpiMsgProduce(circularQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, OPC_INB_SATA_ABORT, outq, … in saSATAAbort()
H A Dsasmp.c79 bit8 i, inq, outq; in saSMPStart() local
106 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saSMPStart()
351 … ret = mpiSMPCmd(agRoot, pMessage, OPC_INB_SMP_REQUEST, (agsaSMPCmd_t *)payload_ptr, inq, outq); in saSMPStart()
482 … ret = mpiSMPCmd(agRoot, pMessage, OPC_INB_SMP_REQUEST, (agsaSMPCmd_t *)payload_ptr, inq, outq); in saSMPStart()
H A Dsaioctlcmd.c83 bit8 inq, outq; in saFwProfile() local
106 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saFwProfile()
236 bit8 inq, outq; in saFwFlashUpdate() local
272 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saFwFlashUpdate()
348 OPC_INB_FW_FLASH_UPDATE, outq, (bit8)circularQ->priority); in saFwFlashUpdate()
383 bit8 inq, outq; in saFlashExtExecute() local
407 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saFlashExtExecute()
3357 bit8 inq, outq; in saSendSMPIoctl() local
3400 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saSendSMPIoctl()
3552 ret = mpiSMPCmd(agRoot, pMessage, OPC_INB_SMP_REQUEST, (agsaSMPCmd_t *)payload_ptr, inq, outq); in saSendSMPIoctl()
[all …]
H A Dsampicmd.c108 bit8 inq, outq; in mpiBuildCmd() local
113 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in mpiBuildCmd()
115 SA_ASSERT((AGSA_MAX_OUTBOUND_Q > outq), "The OBQ Number is out of range."); in mpiBuildCmd()
118 outq = saRoot->QueueConfig.numOutboundQueues -1; in mpiBuildCmd()
119 SA_DBG1(("mpiBuildCmd, set OBQ to %d\n",outq)); in mpiBuildCmd()
158 …if (AGSA_RC_FAILURE == mpiMsgProduce(circularQ, (void *)pMessage, category, opcode, outq, (bit8)ci… in mpiBuildCmd()
907 bit8 outq in mpiSMPCmd() argument
937 …== mpiMsgProduce(circularQ, (void *)pIomb, MPI_CATEGORY_SAS_SATA, opcode, outq, (bit8)circularQ->p… in mpiSMPCmd()
H A Dsaproto.h645 bit8 outq
/freebsd-13.1/contrib/wpa/wpa_supplicant/
H A Dctrl_iface_unix.c81 int sndbuf, outq; in wpas_ctrl_sock_debug() local
92 if (ioctl(sock, TIOCOUTQ, &outq) < 0) in wpas_ctrl_sock_debug()
93 outq = -1; in wpas_ctrl_sock_debug()
97 title, sock, sndbuf, outq, (int) len); in wpas_ctrl_sock_debug()
296 int sndbuf, outq; in wpas_ctrl_iface_throttle() local
301 ioctl(sock, TIOCOUTQ, &outq) < 0 || in wpas_ctrl_iface_throttle()
302 sndbuf <= 0 || outq < 0) in wpas_ctrl_iface_throttle()
304 return outq > sndbuf / 2; in wpas_ctrl_iface_throttle()
/freebsd-13.1/sys/netgraph/bluetooth/include/
H A Dng_btsocket_rfcomm.h254 struct ng_bt_mbufq outq; /* outgoing queue */ member
/freebsd-13.1/sys/contrib/openzfs/module/zfs/
H A Ddmu_send.c1753 bqueue_t *outq = &srta->q; in send_reader_thread() local
1774 bqueue_enqueue(outq, range, range->sru.data.datablksz); in send_reader_thread()
1781 bqueue_enqueue(outq, range, sizeof (*range)); in send_reader_thread()
1878 enqueue_range(srta, outq, dn, blkid, in send_reader_thread()
1889 enqueue_range(srta, outq, dn, blkid, 1, &bp, in send_reader_thread()
1907 bqueue_enqueue_flush(outq, range, 1); in send_reader_thread()
/freebsd-13.1/usr.bin/bluetooth/btsockstat/
H A Dbtsockstat.c539 s.outq.len, in rfcommpr_s()
/freebsd-13.1/sys/netgraph/bluetooth/socket/
H A Dng_btsocket_rfcomm.c1057 NG_BT_MBUFQ_DRAIN(&s->outq); in ng_btsocket_rfcomm_sessions_task()
1285 NG_BT_MBUFQ_INIT(&s->outq, ifqmaxlen); in ng_btsocket_rfcomm_session_create()
1634 NG_BT_MBUFQ_DEQUEUE(&s->outq, m); in ng_btsocket_rfcomm_session_send()
3006 NG_BT_MBUFQ_ENQUEUE(&s->outq, m); in ng_btsocket_rfcomm_send_command()
3080 NG_BT_MBUFQ_ENQUEUE(&s->outq, m); in ng_btsocket_rfcomm_send_uih()
/freebsd-13.1/contrib/unbound/iterator/
H A Diterator.c2181 struct outbound_entry* outq; in processQueryTargets() local
2635 outq = (*qstate->env->send_query)(&iq->qinfo_out, in processQueryTargets()
2649 if(!outq) { in processQueryTargets()
2666 outbound_list_insert(&iq->outlist, outq); in processQueryTargets()