Home
last modified time | relevance | path

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

/dragonfly/contrib/xz/src/liblzma/common/
HDoutqueue.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 …]
HDoutqueue.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()
HDstream_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 …]
/dragonfly/sys/netgraph7/bluetooth/drivers/h4/
HDng_h4.c174 sc->outq.ifq_maxlen = NG_H4_DEFAULTQLEN; in ng_h4_open()
592 IF_DEQUEUE(&sc->outq, m);
615 IF_PREPEND(&sc->outq, m);
640 if (!IF_QEMPTY(&sc->outq) && !callout_pending(&sc->timo))
735 IF_DRAIN(&sc->outq);
773 IF_DRAIN(&sc->outq);
805 if (IF_QFULL(&sc->outq)) {
810 IF_DROP(&sc->outq);
822 IF_ENQUEUE(&sc->outq, m);
823 qlen = IF_QLEN(&sc->outq);
[all …]
HDng_h4_var.h86 struct ifqueue outq; /* Queue of outgoing mbuf's */ member
/dragonfly/sys/dev/sound/midi/
HDmidi.c104 MIDIQ_HEAD(, char) inq, outq;
341 MIDIQ_INIT(m->outq, buf, outqsize); in midi_init()
344 (outqsize && !MIDIQ_BUF(m->outq))) in midi_init()
377 if (MIDIQ_BUF(m->outq)) in midi_init()
378 kfree(MIDIQ_BUF(m->outq), M_MIDI); in midi_init()
589 used = MIN(size, MIDIQ_LEN(m->outq)); in midi_out()
592 MIDIQ_DEQ(m->outq, buf, used); in midi_out()
593 if (MIDIQ_EMPTY(m->outq)) { in midi_out()
597 if (used && MIDIQ_AVAIL(m->outq) > m->hiwat) { in midi_out()
646 if (MIDIQ_SIZE(m->outq) == 0) in midi_open()
[all …]
/dragonfly/sys/netgraph7/tty/
HDng_tty.c90 struct ifqueue outq; /* Queue of outgoing data */ member
198 sc->outq.ifq_maxlen = MAX_MBUFQ; in ngt_open()
421 IF_DEQUEUE(&sc->outq, m); in ngt_start()
440 IF_PREPEND(&sc->outq, m); in ngt_start()
453 if (!IF_QEMPTY(&sc->outq) && !callout_pending(&sc->chand)) in ngt_start()
566 IF_DRAIN(&sc->outq); in ngt_shutdown()
591 if (IF_QFULL(&sc->outq)) { in ngt_rcvdata()
592 IF_DROP(&sc->outq); in ngt_rcvdata()
597 IF_ENQUEUE(&sc->outq, m); in ngt_rcvdata()
598 qlen = sc->outq.ifq_len; in ngt_rcvdata()
/dragonfly/sys/netgraph7/bluetooth/drivers/bt3c/
HDng_bt3c_pccard.c348 IF_DRAIN(&sc->outq); in ng_bt3c_disconnect()
395 IF_QLEN(&sc->outq), /* XXX */ in ng_bt3c_rcvmsg()
396 sc->outq.ifq_maxlen /* XXX */ in ng_bt3c_rcvmsg()
456 sc->outq.ifq_maxlen; in ng_bt3c_rcvmsg()
484 sc->outq.ifq_maxlen = ((ng_bt3c_node_qlen_ep *) in ng_bt3c_rcvmsg()
557 if (IF_QFULL(&sc->outq)) { in ng_bt3c_rcvdata()
561 IF_DROP(&sc->outq); in ng_bt3c_rcvdata()
566 IF_ENQUEUE(&sc->outq, m); in ng_bt3c_rcvdata()
668 sc->inq.ifq_maxlen = sc->outq.ifq_maxlen = BT3C_DEFAULTQLEN; in bt3c_pccard_attach()
737 IF_DRAIN(&sc->outq); in bt3c_pccard_detach()
[all …]
HDng_bt3c_var.h99 struct ifqueue outq; /* queue of outgoing mbuf's */ member
/dragonfly/contrib/wpa_supplicant/wpa_supplicant/
HDctrl_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()
/dragonfly/sys/netgraph7/bluetooth/include/
HDng_btsocket_rfcomm.h252 struct ng_bt_mbufq outq; /* outgoing queue */ member
/dragonfly/sys/netgraph7/bluetooth/socket/
HDng_btsocket_rfcomm.c1137 NG_BT_MBUFQ_DRAIN(&s->outq); in ng_btsocket_rfcomm_sessions_task()
1362 NG_BT_MBUFQ_INIT(&s->outq, ifqmaxlen); in ng_btsocket_rfcomm_session_create()
1712 NG_BT_MBUFQ_DEQUEUE(&s->outq, m); in ng_btsocket_rfcomm_session_send()
3092 NG_BT_MBUFQ_ENQUEUE(&s->outq, m); in ng_btsocket_rfcomm_send_command()
3166 NG_BT_MBUFQ_ENQUEUE(&s->outq, m); in ng_btsocket_rfcomm_send_uih()