Home
last modified time | relevance | path

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

/freebsd-14.2/contrib/xz/src/liblzma/common/
H A Doutqueue.c52 outq->tail = NULL; in move_head_to_cache()
54 if (outq->cache != NULL && outq->cache->allocated != buf->allocated) in move_head_to_cache()
58 outq->cache = buf; in move_head_to_cache()
60 --outq->bufs_in_use; in move_head_to_cache()
153 assert(outq->bufs_in_use < outq->bufs_limit); in lzma_outq_prealloc_buf()
157 if (outq->cache != NULL && outq->cache->allocated == size) in lzma_outq_prealloc_buf()
186 assert(outq->bufs_in_use < outq->bufs_limit); in lzma_outq_get_buf()
187 assert(outq->bufs_in_use < outq->bufs_allocated); in lzma_outq_get_buf()
202 outq->tail = buf; in lzma_outq_get_buf()
226 return outq->read_pos < outq->head->pos || outq->head->finished; in lzma_outq_is_readable()
[all …]
H A Doutqueue.h133 extern lzma_ret lzma_outq_init(lzma_outq *outq,
143 lzma_outq *outq, const lzma_allocator *allocator);
152 lzma_outq *outq, const lzma_allocator *allocator,
167 lzma_outq *outq, const lzma_allocator *allocator, size_t size);
183 extern bool lzma_outq_is_readable(const lzma_outq *outq);
206 extern lzma_ret lzma_outq_read(lzma_outq *restrict outq,
222 extern void lzma_outq_enable_partial_output(lzma_outq *outq,
231 lzma_outq_has_buf(const lzma_outq *outq) in lzma_outq_has_buf() argument
233 return outq->bufs_in_use < outq->bufs_limit; in lzma_outq_has_buf()
239 lzma_outq_is_empty(const lzma_outq *outq) in lzma_outq_is_empty() argument
[all …]
H A Dstream_decoder_mt.c224 lzma_outq outq; member
688 &coder->outq, in read_output_and_wait()
755 - coder->outq.mem_in_use in read_output_and_wait()
757 && lzma_outq_has_buf(&coder->outq) in read_output_and_wait()
1448 &coder->outq, allocator, in stream_decode_mt()
1495 &coder->outq, coder->thr); in stream_decode_mt()
1589 if (!lzma_outq_is_empty(&coder->outq)) in stream_decode_mt()
1652 if (!lzma_outq_is_empty(&coder->outq)) in stream_decode_mt()
1802 lzma_outq_end(&coder->outq, allocator); in stream_decoder_mt_end()
1847 + coder->outq.mem_allocated; in stream_decoder_mt_memconfig()
[all …]
H A Dstream_encoder_mt.c152 lzma_outq outq; member
545 if (!lzma_outq_has_buf(&coder->outq)) in get_thread()
550 return_if_error(lzma_outq_prealloc_buf(&coder->outq, allocator, in get_thread()
582 coder->thr->outbuf = lzma_outq_get_buf(&coder->outq, NULL); in get_thread()
699 || !lzma_outq_has_buf(&coder->outq)) in wait_for_work()
700 && !lzma_outq_is_readable(&coder->outq) in wait_for_work()
758 ret = lzma_outq_read(&coder->outq, allocator, in stream_encode_mt()
814 if (lzma_outq_is_empty(&coder->outq)) { in stream_encode_mt()
901 lzma_outq_end(&coder->outq, allocator); in stream_encoder_mt_end()
1100 memzero(&coder->outq, sizeof(coder->outq)); in stream_encoder_mt_init()
[all …]
/freebsd-14.2/sys/netgraph/
H A Dng_tty.c234 IF_DRAIN(&sc->outq); in ngt_shutdown()
235 mtx_destroy(&(sc)->outq.ifq_mtx); in ngt_shutdown()
326 IF_LOCK(&sc->outq); in ngt_rcvdata()
327 if (_IF_QFULL(&sc->outq)) { in ngt_rcvdata()
328 IF_UNLOCK(&sc->outq); in ngt_rcvdata()
333 _IF_ENQUEUE(&sc->outq, m); in ngt_rcvdata()
335 IF_UNLOCK(&sc->outq); in ngt_rcvdata()
357 IF_DEQUEUE(&sc->outq, m); in ngt_getc_inject()
378 IF_PREPEND(&sc->outq, m); in ngt_getc_inject()
382 IF_LOCK(&sc->outq); in ngt_getc_inject()
[all …]
/freebsd-14.2/sys/dev/sound/midi/
H A Dmidi.c107 MIDIQ_HEAD(, char) inq, outq;
360 MIDIQ_INIT(m->outq, buf, outqsize); in midi_init()
394 if (MIDIQ_BUF(m->outq)) in midi_init()
395 free(MIDIQ_BUF(m->outq), M_MIDI); in midi_init()
610 MIDIQ_DEQ(m->outq, buf, used); in midi_out()
611 if (MIDIQ_EMPTY(m->outq)) { in midi_out()
659 if (MIDIQ_SIZE(m->outq) == 0) in midi_open()
877 MIDIQ_ENQ(m->outq, buf, used); in midi_write()
1103 if (MIDIQ_SIZE(m->outq) == 0) in midisynth_open()
1252 MIDIQ_ENQ(m->outq, buf, used); in midisynth_writeraw()
[all …]
/freebsd-14.2/sys/dev/pms/RefTisa/sallsdk/spc/
H A Dsassp.c288 bit8 inq, outq; in saFastSSPPrepare() local
343 outq = OUQ(fc->queueNum); in saFastSSPPrepare()
499 opCode, outq, 0); in saFastSSPPrepare()
604 bit8 inq = 0, outq = 0; in saSSPStart() local
632 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saSSPStart()
635 SA_DBG3(("saSSPStart: inq %d outq %d deviceId 0x%x\n", inq,outq,pDevice->DeviceMapIndex)); in saSSPStart()
771 …SA_DBG2(("saSSPStart: did %d ioq %d / %d tag %d\n", pDevice->DeviceMapIndex, inq, outq, pRequest->… in saSSPStart()
772 circularOQ = &saRoot->outboundQueue[outq]; in saSSPStart()
1652 saRoot->interruptVecIndexBitMap[0] |= (1 << outq); in saSSPStart()
1698 bit8 inq, outq; in saSSPAbort() local
[all …]
H A Dsasata.c84 bit8 inq = 0, outq = 0; in saSATAStart() local
98 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saSATAStart()
555 outq, in saSATAStart()
612 bit8 inq, outq; in saSATAAbort() local
626 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saSATAAbort()
824 …ret = mpiMsgProduce(circularQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, OPC_INB_SATA_ABORT, outq, … in saSATAAbort()
H A Dsasmp.c78 bit8 i, inq, outq; in saSMPStart() local
105 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saSMPStart()
350 … ret = mpiSMPCmd(agRoot, pMessage, OPC_INB_SMP_REQUEST, (agsaSMPCmd_t *)payload_ptr, inq, outq); in saSMPStart()
481 … ret = mpiSMPCmd(agRoot, pMessage, OPC_INB_SMP_REQUEST, (agsaSMPCmd_t *)payload_ptr, inq, outq); in saSMPStart()
H A Dsaioctlcmd.c82 bit8 inq, outq; in saFwProfile() local
105 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saFwProfile()
235 bit8 inq, outq; in saFwFlashUpdate() local
271 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saFwFlashUpdate()
347 OPC_INB_FW_FLASH_UPDATE, outq, (bit8)circularQ->priority); in saFwFlashUpdate()
382 bit8 inq, outq; in saFlashExtExecute() local
406 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saFlashExtExecute()
3356 bit8 inq, outq; in saSendSMPIoctl() local
3399 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saSendSMPIoctl()
3551 ret = mpiSMPCmd(agRoot, pMessage, OPC_INB_SMP_REQUEST, (agsaSMPCmd_t *)payload_ptr, inq, outq); in saSendSMPIoctl()
[all …]
H A Dsampicmd.c107 bit8 inq, outq; in mpiBuildCmd() local
112 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in mpiBuildCmd()
114 SA_ASSERT((AGSA_MAX_OUTBOUND_Q > outq), "The OBQ Number is out of range."); in mpiBuildCmd()
117 outq = saRoot->QueueConfig.numOutboundQueues -1; in mpiBuildCmd()
118 SA_DBG1(("mpiBuildCmd, set OBQ to %d\n",outq)); in mpiBuildCmd()
157 …if (AGSA_RC_FAILURE == mpiMsgProduce(circularQ, (void *)pMessage, category, opcode, outq, (bit8)ci… in mpiBuildCmd()
906 bit8 outq in mpiSMPCmd() argument
936 …== mpiMsgProduce(circularQ, (void *)pIomb, MPI_CATEGORY_SAS_SATA, opcode, outq, (bit8)circularQ->p… in mpiSMPCmd()
H A Dsaproto.h644 bit8 outq
/freebsd-14.2/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()
299 int sndbuf, outq; in wpas_ctrl_iface_throttle() local
304 ioctl(sock, TIOCOUTQ, &outq) < 0 || in wpas_ctrl_iface_throttle()
305 sndbuf <= 0 || outq < 0) in wpas_ctrl_iface_throttle()
307 return outq > sndbuf / 2; in wpas_ctrl_iface_throttle()
/freebsd-14.2/sys/netgraph/bluetooth/include/
H A Dng_btsocket_rfcomm.h253 struct ng_bt_mbufq outq; /* outgoing queue */ member
/freebsd-14.2/sys/contrib/openzfs/module/zfs/
H A Ddmu_send.c1758 bqueue_t *outq = &srta->q; in send_reader_thread() local
1779 bqueue_enqueue(outq, range, range->sru.data.datablksz); in send_reader_thread()
1786 bqueue_enqueue(outq, range, sizeof (*range)); in send_reader_thread()
1882 enqueue_range(srta, outq, dn, blkid, in send_reader_thread()
1893 enqueue_range(srta, outq, dn, blkid, 1, &bp, in send_reader_thread()
1911 bqueue_enqueue_flush(outq, range, 1); in send_reader_thread()
/freebsd-14.2/usr.bin/bluetooth/btsockstat/
H A Dbtsockstat.c538 s.outq.len, in rfcommpr_s()
/freebsd-14.2/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-14.2/contrib/unbound/iterator/
H A Diterator.c2444 struct outbound_entry* outq; in processQueryTargets() local
3082 outq = (*qstate->env->send_query)(&iq->qinfo_out, in processQueryTargets()
3097 if(!outq) { in processQueryTargets()
3114 outbound_list_insert(&iq->outlist, outq); in processQueryTargets()