Searched refs:outq (Results 1 – 8 of 8) sorted by relevance
/netbsd/external/public-domain/xz/dist/src/liblzma/common/ |
H A D | outqueue.c | 82 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 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()
|
H A 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() 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 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() 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 D | sequencer.c | 364 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 D | sequencervar.h | 100 struct sequencer_queue outq; /* output event queue */ member
|
/netbsd/sys/kern/ |
H A D | tty.c | 250 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 D | iterator.c | 2259 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()
|