| /freebsd-12-stable/contrib/xz/src/liblzma/common/ |
| D | outqueue.c | 57 lzma_outq_init(lzma_outq *outq, const lzma_allocator *allocator, in lzma_outq_init() argument
68 if (outq->buf_size_max != buf_size_max in lzma_outq_init()
69 || outq->bufs_allocated != bufs_count) { in lzma_outq_init()
70 lzma_outq_end(outq, allocator); in lzma_outq_init()
77 outq->bufs = lzma_alloc(bufs_count * sizeof(lzma_outbuf), in lzma_outq_init()
79 outq->bufs_mem = lzma_alloc((size_t)(bufs_alloc_size), in lzma_outq_init()
82 if (outq->bufs == NULL || outq->bufs_mem == NULL) { in lzma_outq_init()
83 lzma_outq_end(outq, allocator); in lzma_outq_init()
90 outq->buf_size_max = (size_t)(buf_size_max); in lzma_outq_init()
91 outq->bufs_allocated = bufs_count; in lzma_outq_init()
[all …]
|
| D | outqueue.h | 91 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()
|
| D | stream_encoder_mt.c | 134 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()
763 if (lzma_outq_is_empty(&coder->outq)) { in stream_encode_mt()
850 lzma_outq_end(&coder->outq, allocator); in stream_encoder_mt_end()
[all …]
|
| /freebsd-12-stable/sys/netgraph/ |
| D | ng_tty.c | 90 struct ifqueue outq; /* Queue of outgoing data */ member
140 #define NGTLOCK(sc) IF_LOCK(&sc->outq)
141 #define NGTUNLOCK(sc) IF_UNLOCK(&sc->outq)
164 mtx_init(&sc->outq.ifq_mtx, "ng_tty node+queue", NULL, MTX_DEF); in ngt_constructor()
165 IFQ_SET_MAXLEN(&sc->outq, ifqmaxlen); in ngt_constructor()
236 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()
[all …]
|
| /freebsd-12-stable/sys/netgraph/bluetooth/drivers/h4/ |
| D | ng_h4.c | 177 mtx_init(&sc->outq.ifq_mtx, "ng_h4 node+queue", NULL, MTX_DEF); in ng_h4_open()
178 IFQ_SET_MAXLEN(&sc->outq, NG_H4_DEFAULTQLEN); in ng_h4_open()
190 mtx_destroy(&sc->outq.ifq_mtx); in ng_h4_open()
207 mtx_destroy(&sc->outq.ifq_mtx); in ng_h4_open()
586 IF_DEQUEUE(&sc->outq, m);
609 IF_PREPEND(&sc->outq, m);
633 if (!IFQ_IS_EMPTY(&sc->outq) && !callout_pending(&sc->timo))
727 _IF_DRAIN(&sc->outq);
765 _IF_DRAIN(&sc->outq);
768 mtx_destroy(&sc->outq.ifq_mtx);
[all …]
|
| D | ng_h4_var.h | 86 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-12-stable/sys/dev/sound/midi/ |
| D | midi.c | 113 MIDIQ_HEAD(, char) inq, outq;
348 MIDIQ_INIT(m->outq, buf, outqsize); in midi_init()
351 (outqsize && !MIDIQ_BUF(m->outq))) in midi_init()
383 if (MIDIQ_BUF(m->outq)) in midi_init()
384 free(MIDIQ_BUF(m->outq), M_MIDI); in midi_init()
598 used = MIN(size, MIDIQ_LEN(m->outq)); in midi_out()
601 MIDIQ_DEQ(m->outq, buf, used); in midi_out()
602 if (MIDIQ_EMPTY(m->outq)) { in midi_out()
606 if (used && MIDIQ_AVAIL(m->outq) > m->hiwat) { in midi_out()
651 if (MIDIQ_SIZE(m->outq) == 0) in midi_open()
[all …]
|
| /freebsd-12-stable/sys/netgraph/bluetooth/drivers/bt3c/ |
| D | ng_bt3c_pccard.c | 351 IF_DRAIN(&sc->outq); in ng_bt3c_disconnect()
398 _IF_QLEN(&sc->outq), /* XXX */ in ng_bt3c_rcvmsg()
399 sc->outq.ifq_maxlen /* XXX */ in ng_bt3c_rcvmsg()
459 sc->outq.ifq_maxlen; in ng_bt3c_rcvmsg()
487 sc->outq.ifq_maxlen = ((ng_bt3c_node_qlen_ep *) in ng_bt3c_rcvmsg()
560 IF_LOCK(&sc->outq); in ng_bt3c_rcvdata()
561 if (_IF_QFULL(&sc->outq)) { in ng_bt3c_rcvdata()
569 _IF_ENQUEUE(&sc->outq, m); in ng_bt3c_rcvdata()
570 IF_UNLOCK(&sc->outq); in ng_bt3c_rcvdata()
671 sc->inq.ifq_maxlen = sc->outq.ifq_maxlen = BT3C_DEFAULTQLEN; in bt3c_pccard_attach()
[all …]
|
| D | ng_bt3c_var.h | 101 struct ifqueue outq; /* queue of outgoing mbuf's */ member
|
| /freebsd-12-stable/sys/dev/pms/RefTisa/sallsdk/spc/ |
| D | sassp.c | 289 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()
1252 …OQ(circularOQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, OPC_OUB_SSP_COMP, outq, (bit8)circularQ->p… in saSSPStart()
1255 …ret = mpiMsgProduce(circularQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, opCode, outq, (bit8)circul… in saSSPStart()
[all …]
|
| D | sasata.c | 85 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()
|
| D | sasmp.c | 79 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()
|
| D | saioctlcmd.c | 83 bit8 inq, outq; in saFwProfile() local
106 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); in saFwProfile()
184 …e(circularQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, OPC_INB_FW_PROFILE, outq, (bit8)circularQ->p… 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()
484 …circularQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, OPC_INB_FLASH_OP_EXT, outq, (bit8)circularQ->p… in saFlashExtExecute()
3357 bit8 inq, outq; in saSendSMPIoctl() local
[all …]
|
| D | sampicmd.c | 108 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()
|
| D | saproto.h | 645 bit8 outq
|
| /freebsd-12-stable/contrib/wpa/wpa_supplicant/ |
| D | ctrl_iface_unix.c | 81 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-12-stable/sys/netgraph/bluetooth/include/ |
| D | ng_btsocket_rfcomm.h | 254 struct ng_bt_mbufq outq; /* outgoing queue */ member
|
| /freebsd-12-stable/usr.bin/bluetooth/btsockstat/ |
| D | btsockstat.c | 539 s.outq.len, in rfcommpr_s()
|
| /freebsd-12-stable/sys/netgraph/bluetooth/socket/ |
| D | ng_btsocket_rfcomm.c | 1056 NG_BT_MBUFQ_DRAIN(&s->outq); in ng_btsocket_rfcomm_sessions_task()
1284 NG_BT_MBUFQ_INIT(&s->outq, ifqmaxlen); in ng_btsocket_rfcomm_session_create()
1633 NG_BT_MBUFQ_DEQUEUE(&s->outq, m); in ng_btsocket_rfcomm_session_send()
3007 NG_BT_MBUFQ_ENQUEUE(&s->outq, m); in ng_btsocket_rfcomm_send_command()
3081 NG_BT_MBUFQ_ENQUEUE(&s->outq, m); in ng_btsocket_rfcomm_send_uih()
|
| /freebsd-12-stable/contrib/unbound/iterator/ |
| D | iterator.c | 2338 struct outbound_entry* outq; in processQueryTargets() local
2906 outq = (*qstate->env->send_query)(&iq->qinfo_out, in processQueryTargets()
2921 if(!outq) { in processQueryTargets()
2938 outbound_list_insert(&iq->outlist, outq); in processQueryTargets()
|