/freebsd-13-stable/contrib/xz/src/liblzma/common/ |
H A D | outqueue.c | 57 lzma_outq_init(lzma_outq *outq, const lzma_allocator *allocator, argument 68 if (outq->buf_size_max != buf_size_max 69 || outq->bufs_allocated != bufs_count) { 70 lzma_outq_end(outq, allocator); 77 outq->bufs = lzma_alloc(bufs_count * sizeof(lzma_outbuf), 79 outq->bufs_mem = lzma_alloc((size_t)(bufs_alloc_size), 82 if (outq->bufs == NULL || outq->bufs_mem == NULL) { 83 lzma_outq_end(outq, allocator); 89 // outq 101 lzma_outq_end(lzma_outq *outq, const lzma_allocator *allocator) argument 114 lzma_outq_get_buf(lzma_outq *outq) argument 136 lzma_outq_is_readable(const lzma_outq *outq) argument 147 lzma_outq_read(lzma_outq *restrict outq, uint8_t *restrict out, size_t *restrict out_pos, size_t out_size, lzma_vli *restrict unpadded_size, lzma_vli *restrict uncompressed_size) argument [all...] |
H A D | outqueue.h | 73 /// \param outq Pointer to an output queue. Before calling 74 /// this function the first time, *outq should 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); 117 /// \param outq Pointer to an output queue 134 extern lzma_ret lzma_outq_read(lzma_outq *restrict outq, 145 lzma_outq_has_buf(const lzma_outq *outq) argument 147 return outq 153 lzma_outq_is_empty(const lzma_outq *outq) argument [all...] |
H A D | stream_encoder_mt.c | 134 lzma_outq outq; member in struct:lzma_stream_coder_s 208 .compressed_size = thr->coder->outq.buf_size_max, 238 const size_t out_size = thr->coder->outq.buf_size_max; 519 if (!lzma_outq_has_buf(&coder->outq)) 544 coder->thr->outbuf = lzma_outq_get_buf(&coder->outq); 648 || !lzma_outq_has_buf(&coder->outq)) 649 && !lzma_outq_is_readable(&coder->outq) 707 ret = lzma_outq_read(&coder->outq, 760 if (lzma_outq_is_empty(&coder->outq)) { 847 lzma_outq_end(&coder->outq, allocato [all...] |
/freebsd-13-stable/sys/netgraph/bluetooth/drivers/h4/ |
H A D | ng_h4_var.h | 86 struct ifqueue outq; /* Queue of outgoing mbuf's */ member in struct:ng_h4_info 87 #define NG_H4_DEFAULTQLEN 12 /* XXX max number of mbuf's in outq */ 88 #define NG_H4_LOCK(sc) IF_LOCK(&sc->outq) 89 #define NG_H4_UNLOCK(sc) IF_UNLOCK(&sc->outq)
|
H A D | ng_h4.c | 177 mtx_init(&sc->outq.ifq_mtx, "ng_h4 node+queue", NULL, MTX_DEF); 178 IFQ_SET_MAXLEN(&sc->outq, NG_H4_DEFAULTQLEN); 190 mtx_destroy(&sc->outq.ifq_mtx); 207 mtx_destroy(&sc->outq.ifq_mtx); 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 [all...] |
/freebsd-13-stable/sys/netgraph/ |
H A D | ng_tty.c | 90 struct ifqueue outq; /* Queue of outgoing data */ member in struct:ngt_softc 91 size_t outqlen; /* Number of bytes in outq */ 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); 165 IFQ_SET_MAXLEN(&sc->outq, ifqmaxlen); 236 IF_DRAIN(&sc->outq); 237 mtx_destroy(&(sc)->outq.ifq_mtx); 328 IF_LOCK(&sc->outq); 329 if (_IF_QFULL(&sc->outq)) { [all...] |
/freebsd-13-stable/sys/dev/sound/midi/ |
H A D | midi.c | 112 struct mtx qlock; /* Protects inq, outq and flags */ 113 MIDIQ_HEAD(, char) inq, outq; member in struct:snd_midi 116 int hiwat; /* QLEN(outq)>High-water -> disable 347 MIDIQ_INIT(m->outq, buf, outqsize); 350 (outqsize && !MIDIQ_BUF(m->outq))) 382 if (MIDIQ_BUF(m->outq)) 383 free(MIDIQ_BUF(m->outq), M_MIDI); 595 used = MIN(size, MIDIQ_LEN(m->outq)); 598 MIDIQ_DEQ(m->outq, buf, used); 599 if (MIDIQ_EMPTY(m->outq)) { [all...] |
/freebsd-13-stable/sys/dev/pms/RefTisa/sallsdk/spc/ |
H A D | sassp.c | 289 bit8 inq, outq; local 344 outq = OUQ(fc->queueNum); 500 opCode, outq, 0); 605 bit8 inq = 0, outq = 0; local 633 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); 636 SA_DBG3(("saSSPStart: inq %d outq %d deviceId 0x%x\n", inq,outq,pDevice->DeviceMapIndex)); 772 SA_DBG2(("saSSPStart: did %d ioq %d / %d tag %d\n", pDevice->DeviceMapIndex, inq, outq, pRequest->HTag)); 773 circularOQ = &saRoot->outboundQueue[outq]; 1252 ret = mpiMsgProduceOQ(circularOQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, OPC_OUB_SSP_COMP, outq, (bit 1699 bit8 inq, outq; local [all...] |
H A D | sasmp.c | 79 bit8 i, inq, outq; local 106 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); 351 ret = mpiSMPCmd(agRoot, pMessage, OPC_INB_SMP_REQUEST, (agsaSMPCmd_t *)payload_ptr, inq, outq); 482 ret = mpiSMPCmd(agRoot, pMessage, OPC_INB_SMP_REQUEST, (agsaSMPCmd_t *)payload_ptr, inq, outq);
|
H A D | sasata.c | 85 bit8 inq = 0, outq = 0; local 99 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); 556 outq, 613 bit8 inq, outq; local 627 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); 825 ret = mpiMsgProduce(circularQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, OPC_INB_SATA_ABORT, outq, (bit8)circularQ->priority);
|
H A D | saioctlcmd.c | 83 bit8 inq, outq; local 106 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); 184 ret = mpiMsgProduce(circularQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, OPC_INB_FW_PROFILE, outq, (bit8)circularQ->priority); 236 bit8 inq, outq; local 272 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); 348 OPC_INB_FW_FLASH_UPDATE, outq, (bit8)circularQ->priority); 383 bit8 inq, outq; local 407 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); 484 ret = mpiMsgProduce(circularQ, (void *)pMessage, MPI_CATEGORY_SAS_SATA, OPC_INB_FLASH_OP_EXT, outq, (bit8)circularQ->priority); 3357 bit8 inq, outq; local [all...] |
H A D | sampicmd.c | 108 bit8 inq, outq; local 113 outq = (bit8)((queueNum & MPI_OB_NUM_MASK) >> MPI_OB_SHIFT); 115 SA_ASSERT((AGSA_MAX_OUTBOUND_Q > outq), "The OBQ Number is out of range."); 118 outq = saRoot->QueueConfig.numOutboundQueues -1; 119 SA_DBG1(("mpiBuildCmd, set OBQ to %d\n",outq)); 158 if (AGSA_RC_FAILURE == mpiMsgProduce(circularQ, (void *)pMessage, category, opcode, outq, (bit8)circularQ->priority)) 892 * \param outq outbound queue number 907 bit8 outq 937 if (AGSA_RC_FAILURE == mpiMsgProduce(circularQ, (void *)pIomb, MPI_CATEGORY_SAS_SATA, opcode, outq, (bit8)circularQ->priority))
|
H A D | saproto.h | 645 bit8 outq
|
/freebsd-13-stable/contrib/wpa/wpa_supplicant/ |
H A D | ctrl_iface_unix.c | 81 int sndbuf, outq; local 92 if (ioctl(sock, TIOCOUTQ, &outq) < 0) 93 outq = -1; 96 "CTRL-DEBUG: %s: sock=%d sndbuf=%d outq=%d send_len=%d", 97 title, sock, sndbuf, outq, (int) len); 286 int sndbuf, outq; local 291 ioctl(sock, TIOCOUTQ, &outq) < 0 || 292 sndbuf <= 0 || outq < 0) 294 return outq > sndbuf / 2;
|
/freebsd-13-stable/sys/netgraph/bluetooth/include/ |
H A D | ng_btsocket_rfcomm.h | 254 struct ng_bt_mbufq outq; /* outgoing queue */ member in struct:ng_btsocket_rfcomm_session
|
/freebsd-13-stable/usr.bin/bluetooth/btsockstat/ |
H A D | btsockstat.c | 539 s.outq.len,
|
/freebsd-13-stable/sys/contrib/openzfs/module/zfs/ |
H A D | dmu_send.c | 1740 bqueue_t *outq = &srta->q; local 1761 bqueue_enqueue(outq, range, range->sru.data.datablksz); 1768 bqueue_enqueue(outq, range, sizeof (*range)); 1865 enqueue_range(srta, outq, dn, blkid, 1876 enqueue_range(srta, outq, dn, blkid, 1, &bp, 1894 bqueue_enqueue_flush(outq, range, 1);
|
/freebsd-13-stable/sys/netgraph/bluetooth/socket/ |
H A D | ng_btsocket_rfcomm.c | 1057 NG_BT_MBUFQ_DRAIN(&s->outq); 1285 NG_BT_MBUFQ_INIT(&s->outq, ifqmaxlen); 1634 NG_BT_MBUFQ_DEQUEUE(&s->outq, m); 3006 NG_BT_MBUFQ_ENQUEUE(&s->outq, m); 3080 NG_BT_MBUFQ_ENQUEUE(&s->outq, m);
|
/freebsd-13-stable/contrib/unbound/iterator/ |
H A D | iterator.c | 2153 struct outbound_entry* outq; local 2600 outq = (*qstate->env->send_query)(&iq->qinfo_out, 2613 if(!outq) { 2623 outbound_list_insert(&iq->outlist, outq);
|