Home
last modified time | relevance | path

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

/netbsd-src/external/public-domain/xz/dist/src/liblzma/common/
H A Doutqueue.c57 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 …]
H A Doutqueue.h91 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()
H A Dstream_encoder_mt.c134 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()
760 if (lzma_outq_is_empty(&coder->outq)) { in stream_encode_mt()
847 lzma_outq_end(&coder->outq, allocator); in stream_encoder_mt_end()
[all …]
/netbsd-src/sys/dev/
H A Dsequencer.c364 SEQ_QINIT(&sc->outq); in sequenceropen()
413 DPRINTFN(3, ("seq_drain: %p, len=%d\n", sc, SEQ_QLEN(&sc->outq))); in seq_drain()
416 while (!SEQ_QEMPTY(&sc->outq) && !error) in seq_drain()
437 if (SEQ_QLEN(&sc->outq) >= sc->lowat) { in seq_timeout()
455 struct sequencer_queue *q = &sc->outq; in seq_startoutput()
676 q = &sc->outq; in sequencerwrite()
901 if ((sc->flags&FWRITE) && SEQ_QLEN(&sc->outq) < sc->lowat) in sequencerpoll()
973 if (SEQ_QLEN(&sc->outq) >= sc->lowat) { in filt_sequencerwrite()
H A Dsequencervar.h100 struct sequencer_queue outq; /* output event queue */ member
/netbsd-src/sys/kern/
H A Dtty.c246 struct clist rawq, canq, outq; in tty_set_qsize() local
251 clalloc(&outq, newsize, 0); in tty_set_qsize()
259 clfree(&outq); in tty_set_qsize()
270 tp->t_outq = outq; in tty_set_qsize()
/netbsd-src/external/bsd/unbound/dist/iterator/
H A Diterator.c2338 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()