Home
last modified time | relevance | path

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

/src/contrib/xz/src/liblzma/common/
H A Doutqueue.c42 move_head_to_cache(lzma_outq *outq, const lzma_allocator *allocator) in move_head_to_cache() argument
44 assert(outq->head != NULL); in move_head_to_cache()
45 assert(outq->tail != NULL); in move_head_to_cache()
46 assert(outq->bufs_in_use > 0); in move_head_to_cache()
48 lzma_outbuf *buf = outq->head; in move_head_to_cache()
49 outq->head = buf->next; in move_head_to_cache()
50 if (outq->head == NULL) in move_head_to_cache()
51 outq->tail = NULL; in move_head_to_cache()
53 if (outq->cache != NULL && outq->cache->allocated != buf->allocated) in move_head_to_cache()
54 lzma_outq_clear_cache(outq, allocator); in move_head_to_cache()
[all …]
H A Doutqueue.h135 extern lzma_ret lzma_outq_init(lzma_outq *outq,
140 extern void lzma_outq_end(lzma_outq *outq, const lzma_allocator *allocator);
145 lzma_outq *outq, const lzma_allocator *allocator);
154 lzma_outq *outq, const lzma_allocator *allocator,
169 lzma_outq *outq, const lzma_allocator *allocator, size_t size);
177 extern lzma_outbuf *lzma_outq_get_buf(lzma_outq *outq, void *worker);
185 extern bool lzma_outq_is_readable(const lzma_outq *outq);
209 extern lzma_ret lzma_outq_read(lzma_outq *restrict outq,
225 extern void lzma_outq_enable_partial_output(lzma_outq *outq,
234 lzma_outq_has_buf(const lzma_outq *outq) in lzma_outq_has_buf() argument
[all …]
H A Dstream_decoder_mt.c206 lzma_outq outq; member
660 ret = lzma_outq_read(&coder->outq, allocator, in read_output_and_wait()
670 &coder->outq, in read_output_and_wait()
737 - coder->outq.mem_in_use in read_output_and_wait()
739 && lzma_outq_has_buf(&coder->outq) in read_output_and_wait()
756 if (lzma_outq_is_empty(&coder->outq)) { in read_output_and_wait()
776 if (lzma_outq_is_readable(&coder->outq)) { in read_output_and_wait()
815 assert(coder->thr->outbuf == coder->outq.head); in read_output_and_wait()
816 assert(coder->thr->outbuf == coder->outq.tail); in read_output_and_wait()
1219 if (!lzma_outq_is_empty(&coder->outq)) in stream_decode_mt()
[all …]
H A Dstream_encoder_mt.c151 lzma_outq outq; member
544 if (!lzma_outq_has_buf(&coder->outq)) in get_thread()
549 return_if_error(lzma_outq_prealloc_buf(&coder->outq, allocator, in get_thread()
581 coder->thr->outbuf = lzma_outq_get_buf(&coder->outq, NULL); in get_thread()
698 || !lzma_outq_has_buf(&coder->outq)) in wait_for_work()
699 && !lzma_outq_is_readable(&coder->outq) in wait_for_work()
756 ret = lzma_outq_read(&coder->outq, allocator, in stream_encode_mt()
812 if (lzma_outq_is_empty(&coder->outq)) { in stream_encode_mt()
898 lzma_outq_end(&coder->outq, allocator); in stream_encoder_mt_end()
1097 memzero(&coder->outq, sizeof(coder->outq)); in stream_encoder_mt_init()
[all …]
/src/sys/netgraph/
H A Dng_tty.c88 struct ifqueue outq; /* Queue of outgoing data */ member
138 #define NGTLOCK(sc) IF_LOCK(&sc->outq)
139 #define NGTUNLOCK(sc) IF_UNLOCK(&sc->outq)
162 mtx_init(&sc->outq.ifq_mtx, "ng_tty node+queue", NULL, MTX_DEF); in ngt_constructor()
163 IFQ_SET_MAXLEN(&sc->outq, ifqmaxlen); in ngt_constructor()
234 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()
[all …]
/src/sys/dev/sound/midi/
H A Dmidi.c71 MIDIQ_HEAD(, char) inq, outq;
134 MIDIQ_INIT(m->outq, obuf, outqsize); in midi_init()
156 free(MIDIQ_BUF(m->outq), M_MIDI); in midi_init()
180 free(MIDIQ_BUF(m->outq), M_MIDI); in midi_uninit()
239 used = min(size, MIDIQ_LEN(m->outq)); in midi_out()
241 MIDIQ_DEQ(m->outq, buf, used); in midi_out()
242 if (MIDIQ_EMPTY(m->outq)) { in midi_out()
246 if (used && MIDIQ_AVAIL(m->outq) > m->hiwat) { in midi_out()
279 if (MIDIQ_SIZE(m->outq) == 0) in midi_open()
434 while (MIDIQ_AVAIL(m->outq) == 0) { in midi_write()
[all …]
/src/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()
1251 …OQ(circularOQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, OPC_OUB_SSP_COMP, outq, (bit8)circularQ->p… in saSSPStart()
1254 …ret = mpiMsgProduce(circularQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, opCode, outq, (bit8)circul… in saSSPStart()
[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()
183 …e(circularQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, OPC_INB_FW_PROFILE, outq, (bit8)circularQ->p… 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()
483 …circularQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, OPC_INB_FLASH_OP_EXT, outq, (bit8)circularQ->p… in saFlashExtExecute()
3356 bit8 inq, outq; in saSendSMPIoctl() local
[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
/src/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()
/src/sys/netgraph/bluetooth/include/
H A Dng_btsocket_rfcomm.h253 struct ng_bt_mbufq outq; /* outgoing queue */ member
/src/sys/contrib/openzfs/module/zfs/
H A Ddmu_send.c1758 bqueue_t *outq = &srta->q; in send_reader_thread() local
1780 bqueue_enqueue(outq, range, range->sru.data.datablksz); in send_reader_thread()
1789 bqueue_enqueue(outq, range, sizeof (*range) + spill); in send_reader_thread()
1885 enqueue_range(srta, outq, dn, blkid, in send_reader_thread()
1896 enqueue_range(srta, outq, dn, blkid, 1, &bp, in send_reader_thread()
1914 bqueue_enqueue_flush(outq, range, 1); in send_reader_thread()
/src/usr.bin/bluetooth/btsockstat/
H A Dbtsockstat.c538 s.outq.len, in rfcommpr_s()
/src/sys/netgraph/bluetooth/socket/
H A Dng_btsocket_rfcomm.c1046 NG_BT_MBUFQ_DRAIN(&s->outq); in ng_btsocket_rfcomm_sessions_task()
1274 NG_BT_MBUFQ_INIT(&s->outq, ifqmaxlen); in ng_btsocket_rfcomm_session_create()
1623 NG_BT_MBUFQ_DEQUEUE(&s->outq, m); in ng_btsocket_rfcomm_session_send()
2995 NG_BT_MBUFQ_ENQUEUE(&s->outq, m); in ng_btsocket_rfcomm_send_command()
3069 NG_BT_MBUFQ_ENQUEUE(&s->outq, m); in ng_btsocket_rfcomm_send_uih()
/src/contrib/unbound/iterator/
H A Diterator.c2438 struct outbound_entry* outq; in processQueryTargets() local
3075 outq = (*qstate->env->send_query)(&iq->qinfo_out, in processQueryTargets()
3090 if(!outq) { in processQueryTargets()
3107 outbound_list_insert(&iq->outlist, outq); in processQueryTargets()