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

/freebsd-10-stable/contrib/xz/src/liblzma/common/
H A Doutqueue.c57 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 Doutqueue.h73 /// \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 Dstream_encoder_mt.c134 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-10-stable/sys/netgraph/bluetooth/drivers/h4/
H A Dng_h4_var.h84 struct ifqueue outq; /* Queue of outgoing mbuf's */ member in struct:ng_h4_info
85 #define NG_H4_DEFAULTQLEN 12 /* XXX max number of mbuf's in outq */
86 #define NG_H4_LOCK(sc) IF_LOCK(&sc->outq)
87 #define NG_H4_UNLOCK(sc) IF_UNLOCK(&sc->outq)
H A Dng_h4.c175 mtx_init(&sc->outq.ifq_mtx, "ng_h4 node+queue", NULL, MTX_DEF);
176 IFQ_SET_MAXLEN(&sc->outq, NG_H4_DEFAULTQLEN);
188 mtx_destroy(&sc->outq.ifq_mtx);
205 mtx_destroy(&sc->outq.ifq_mtx);
584 IF_DEQUEUE(&sc->outq, m);
607 IF_PREPEND(&sc->outq, m);
631 if (!IFQ_IS_EMPTY(&sc->outq) && !callout_pending(&sc->timo))
725 _IF_DRAIN(&sc->outq);
763 _IF_DRAIN(&sc->outq);
766 mtx_destroy(&sc->outq
[all...]
/freebsd-10-stable/sys/netgraph/
H A Dng_tty.c90 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-10-stable/sys/dev/sound/midi/
H A Dmidi.c111 struct mtx qlock; /* Protects inq, outq and flags */
112 MIDIQ_HEAD(, char) inq, outq; member in struct:snd_midi
115 int hiwat; /* QLEN(outq)>High-water -> disable
353 MIDIQ_INIT(m->outq, buf, outqsize);
356 (outqsize && !MIDIQ_BUF(m->outq)))
388 if (MIDIQ_BUF(m->outq))
389 free(MIDIQ_BUF(m->outq), M_MIDI);
599 used = MIN(size, MIDIQ_LEN(m->outq));
602 MIDIQ_DEQ(m->outq, buf, used);
603 if (MIDIQ_EMPTY(m->outq)) {
[all...]
/freebsd-10-stable/sys/netgraph/bluetooth/drivers/bt3c/
H A Dng_bt3c_pccard.c349 IF_DRAIN(&sc->outq);
396 _IF_QLEN(&sc->outq), /* XXX */
397 sc->outq.ifq_maxlen /* XXX */
457 sc->outq.ifq_maxlen;
485 sc->outq.ifq_maxlen = ((ng_bt3c_node_qlen_ep *)
558 IF_LOCK(&sc->outq);
559 if (_IF_QFULL(&sc->outq)) {
563 _IF_DROP(&sc->outq);
568 _IF_ENQUEUE(&sc->outq, m);
569 IF_UNLOCK(&sc->outq);
[all...]
H A Dng_bt3c_var.h99 struct ifqueue outq; /* queue of outgoing mbuf's */ member in struct:bt3c_softc
/freebsd-10-stable/sys/dev/pms/RefTisa/sallsdk/spc/
H A Dsassp.c289 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 Dsasmp.c79 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 Dsasata.c85 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 Dsaioctlcmd.c83 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 Dsampicmd.c108 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 Dsaproto.h645 bit8 outq
/freebsd-10-stable/sys/netgraph/bluetooth/include/
H A Dng_btsocket_rfcomm.h252 struct ng_bt_mbufq outq; /* outgoing queue */ member in struct:ng_btsocket_rfcomm_session
/freebsd-10-stable/usr.bin/bluetooth/btsockstat/
H A Dbtsockstat.c536 s.outq.len,
/freebsd-10-stable/sys/netgraph/bluetooth/socket/
H A Dng_btsocket_rfcomm.c1054 NG_BT_MBUFQ_DRAIN(&s->outq);
1284 NG_BT_MBUFQ_INIT(&s->outq, ifqmaxlen);
1651 NG_BT_MBUFQ_DEQUEUE(&s->outq, m);
3025 NG_BT_MBUFQ_ENQUEUE(&s->outq, m);
3099 NG_BT_MBUFQ_ENQUEUE(&s->outq, m);
/freebsd-10-stable/contrib/unbound/iterator/
H A Diterator.c1802 struct outbound_entry* outq; local
2090 outq = (*qstate->env->send_query)(
2097 if(!outq) {
2105 outbound_list_insert(&iq->outlist, outq);

Completed in 135 milliseconds