Home
last modified time | relevance | path

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

/netbsd/external/public-domain/xz/dist/src/liblzma/common/
H A Doutqueue.c82 if (outq->bufs == NULL || outq->bufs_mem == NULL) { in lzma_outq_init()
104 outq->bufs = NULL; in lzma_outq_end()
117 assert(outq->bufs_used < outq->bufs_allocated); in lzma_outq_get_buf()
120 lzma_outbuf *buf = &outq->bufs[outq->bufs_pos]; in lzma_outq_get_buf()
121 buf->buf = outq->bufs_mem + outq->bufs_pos * outq->buf_size_max; in lzma_outq_get_buf()
126 if (++outq->bufs_pos == outq->bufs_allocated) in lzma_outq_get_buf()
129 ++outq->bufs_used; in lzma_outq_get_buf()
138 uint32_t i = outq->bufs_pos - outq->bufs_used; in lzma_outq_is_readable()
139 if (outq->bufs_pos < outq->bufs_used) in lzma_outq_is_readable()
157 uint32_t i = outq->bufs_pos - outq->bufs_used; in lzma_outq_read()
[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/external/bsd/wpa/dist/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()
286 int sndbuf, outq; in wpas_ctrl_iface_throttle() local
291 ioctl(sock, TIOCOUTQ, &outq) < 0 || in wpas_ctrl_iface_throttle()
292 sndbuf <= 0 || outq < 0) in wpas_ctrl_iface_throttle()
294 return outq > sndbuf / 2; in wpas_ctrl_iface_throttle()
/netbsd/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/sys/kern/
H A Dtty.c250 struct clist rawq, canq, outq; in tty_set_qsize() local
255 clalloc(&outq, newsize, 0); in tty_set_qsize()
263 clfree(&outq); in tty_set_qsize()
274 tp->t_outq = outq; in tty_set_qsize()
/netbsd/external/bsd/unbound/dist/iterator/
H A Diterator.c2259 struct outbound_entry* outq; in processQueryTargets() local
2782 outq = (*qstate->env->send_query)(&iq->qinfo_out, in processQueryTargets()
2796 if(!outq) { in processQueryTargets()
2813 outbound_list_insert(&iq->outlist, outq); in processQueryTargets()