Home
last modified time | relevance | path

Searched refs:qlen (Results 1 – 25 of 128) sorted by relevance

123456

/linux/sound/core/seq/oss/
H A Dseq_oss_readq.c42 q->qlen = 0; in snd_seq_oss_readq_new()
68 if (q->qlen) { in snd_seq_oss_readq_delete()
69 q->qlen = 0;
139 if (q->qlen >= q->maxlen - 1)
144 q->qlen++; in snd_seq_oss_readq_put_event()
175 if (q->qlen == 0) in snd_seq_oss_readq_wait()
188 (q->qlen > 0 || q->head == q->tail), in snd_seq_oss_readq_free()
199 if (q->qlen > 0) {
201 q->qlen--; in snd_seq_oss_readq_poll()
213 return q->qlen; in snd_seq_oss_readq_put_timestamp()
[all...]
/linux/net/sched/
H A Dsch_sfq.c97 sfq_index qlen; /* number of skbs in skblist */ member
200 int qlen = slot->qlen; in sfq_link() local
202 p = qlen + SFQ_MAX_FLOWS; in sfq_link()
203 n = q->dep[qlen].next; in sfq_link()
208 q->dep[qlen].next = x; /* sfq_dep_head(q, p)->next = x */ in sfq_link()
228 d = q->slots[x].qlen; in sfq_dec()
229 WRITE_ONCE(q->slots[x].qlen, d - 1); in sfq_dec()
242 d = q->slots[x].qlen + 1; in sfq_inc()
243 WRITE_ONCE(q->slots[x].qlen, d); in sfq_inc()
348 sfq_index x, qlen; in sfq_enqueue() local
[all …]
H A Dsch_sfb.c40 u16 qlen; /* length of virtual queue */ member
132 if (b[hash].qlen < 0xFFFF) in increment_one_qlen()
133 WRITE_ONCE(b[hash].qlen, b[hash].qlen + 1); in increment_one_qlen()
161 if (b[hash].qlen > 0) in decrement_one_qlen()
162 WRITE_ONCE(b[hash].qlen, b[hash].qlen - 1); in decrement_one_qlen()
201 u32 qlen = 0, prob = 0, totalpm = 0; in sfb_compute_qlen() local
205 u32 b_qlen = READ_ONCE(b->qlen); in sfb_compute_qlen()
208 if (qlen < b_qlen) in sfb_compute_qlen()
209 qlen = b_qlen; in sfb_compute_qlen()
217 return qlen; in sfb_compute_qlen()
[all …]
H A Dsch_mqprio.c561 unsigned int qlen = 0; in mqprio_dump() local
579 qlen += qdisc_qlen_lockless(qdisc); in mqprio_dump()
588 WRITE_ONCE(sch->qstats.qlen, qstats.qlen); in mqprio_dump()
594 WRITE_ONCE(sch->q.qlen, qlen); in mqprio_dump()
685 u32 qlen = 0; in mqprio_dump_class_stats() local
700 qlen += qdisc_qlen_lockless(qdisc); in mqprio_dump_class_stats()
703 qlen = qlen + qstats.qlen; in mqprio_dump_class_stats()
706 gnet_stats_copy_queue(d, NULL, &qstats, qlen) < 0) in mqprio_dump_class_stats()
H A Dsch_choke.c220 q->vars.qavg = red_calc_qavg(p, &q->vars, sch->q.qlen); in choke_enqueue()
271 if (sch->q.qlen < q->limit) { in choke_enqueue()
384 unsigned int oqlen = sch->q.qlen, tail = 0; in choke_change()
402 qdisc_tree_reduce_backlog(sch, oqlen - sch->q.qlen, dropped); in choke_change()
H A Dsch_skbprio.c84 if (sch->q.qlen < READ_ONCE(sch->limit)) { in skbprio_enqueue()
254 q->qstats[cl - 1].qlen) < 0) in skbprio_dump_class_stats()
H A Dsch_fq.c86 int qlen; /* number of packets in flow queue */ member
306 * 2) FQ qlen == 0 OR
323 if (sch->q.qlen != 0) { in fq_fastpath_check()
335 if (q->internal.qlen >= 8) in fq_fastpath_check()
631 if (unlikely(f->qlen >= q->flow_plimit)) { in fq_check_throttled()
646 if (f->qlen == 0) in fq_dequeue()
650 f->qlen++; in fq_dequeue()
717 if (!sch->q.qlen) in fq_dequeue()
722 q->internal.qlen--; in fq_dequeue()
776 if (--f->qlen in fq_dequeue()
[all...]
H A Dsch_fq_codel.c181 WRITE_ONCE(sch->q.qlen, sch->q.qlen - i); in fq_codel_drop()
219 if (sch->q.qlen <= sch->limit && !memory_limited) in fq_codel_enqueue()
223 prev_qlen = sch->q.qlen; in fq_codel_enqueue()
234 prev_qlen -= sch->q.qlen; in fq_codel_enqueue()
358 sch->q.qlen++; in fq_codel_peek()
482 while (sch->q.qlen > sch->limit || in fq_codel_change()
716 qs.qlen++; in fq_codel_dump_class_stats()
724 if (gnet_stats_copy_queue(d, NULL, &qs, qs.qlen) < 0) in fq_codel_dump_class_stats()
H A Dsch_drr.c265 __u32 qlen = qdisc_qlen_sum(cl->qdisc); in drr_dump_class_stats() local
270 if (qlen) in drr_dump_class_stats()
275 gnet_stats_copy_queue(d, cl_q->cpu_qstats, &cl_q->qstats, qlen) < 0) in drr_dump_class_stats()
394 if (cl->qdisc->q.qlen == 0) in drr_dequeue()
435 if (cl->qdisc->q.qlen) in drr_reset_qdisc()
/linux/sound/core/seq/
H A Dseq_midi_event.c50 int qlen; member
141 dev->qlen = 0; in reset_encode()
193 dev->qlen = status_event[dev->type].qlen; in snd_midi_event_encode_byte()
195 if (dev->qlen > 0) { in snd_midi_event_encode_byte()
199 dev->qlen--; in snd_midi_event_encode_byte()
203 dev->qlen = status_event[dev->type].qlen - 1; in snd_midi_event_encode_byte()
207 if (dev->qlen == 0) { in snd_midi_event_encode_byte()
312 int qlen; in snd_midi_event_decode() local
323 qlen = status_event[type].qlen + 1; in snd_midi_event_decode()
328 qlen = status_event[type].qlen; in snd_midi_event_decode()
[all …]
/linux/drivers/md/
H A Ddm-ps-queue-length.c40 atomic_t qlen; /* the number of in-flight I/Os */ member
101 DMEMIT("%d ", atomic_read(&pi->qlen)); in ql_status()
153 atomic_set(&pi->qlen, 0); in ql_add_path()
204 (atomic_read(&pi->qlen) < atomic_read(&best->qlen))) in ql_select_path()
207 if (!atomic_read(&best->qlen)) in ql_select_path()
228 atomic_inc(&pi->qlen); in ql_start_io()
238 atomic_dec(&pi->qlen); in ql_end_io()
/linux/include/net/
H A Dsch_generic.h65 __u32 qlen; member
197 return !READ_ONCE(qdisc->q.qlen); in qdisc_is_empty()
543 return q->q.qlen; in qdisc_qlen()
548 return READ_ONCE(q->q.qlen); in qdisc_qlen_lockless()
553 WRITE_ONCE(q->q.qlen, q->q.qlen + 1); in qdisc_qlen_inc()
558 WRITE_ONCE(q->q.qlen, q->q.qlen - 1); in qdisc_qlen_dec()
563 __u32 qlen = q->qstats.qlen; in qdisc_qlen_sum() local
568 qlen += READ_ONCE(per_cpu_ptr(q->cpu_qstats, i)->qlen); in qdisc_qlen_sum()
570 qlen += qdisc_qlen_lockless(q); in qdisc_qlen_sum()
573 return qlen; in qdisc_qlen_sum()
[all …]
/linux/drivers/usb/gadget/legacy/
H A Dgmidi.c53 static unsigned int qlen = 32; variable
54 module_param(qlen, uint, S_IRUGO);
55 MODULE_PARM_DESC(qlen, "USB read and write request queue length");
157 midi_opts->qlen = qlen; in midi_bind()
H A Dprinter.c51 static unsigned qlen = 10; variable
52 module_param(qlen, uint, S_IRUGO|S_IWUSR);
53 MODULE_PARM_DESC(qlen, "The number of 8k buffers to use per endpoint");
55 #define QLEN qlen
H A Dzero.c66 .qlen = GZERO_QLEN,
263 module_param_named(qlen, gzero_options.qlen, uint, S_IRUGO|S_IWUSR);
264 MODULE_PARM_DESC(qlen, "depth of loopback queue");
322 lb_opts->qlen = gzero_options.qlen; in zero_bind()
/linux/include/trace/events/
H A Drcu.h514 TP_PROTO(const char *rcuname, struct rcu_head *rhp, long qlen),
516 TP_ARGS(rcuname, rhp, qlen),
522 __field(long, qlen)
529 __entry->qlen = qlen;
534 __entry->qlen)
573 TP_PROTO(const char *rcuname, long qlen, long blimit),
575 TP_ARGS(rcuname, qlen, blimit),
579 __field(long, qlen)
585 __entry->qlen = qlen;
590 __entry->rcuname, __entry->qlen, __entry->blimit)
/linux/drivers/usb/gadget/function/
H A Df_loopback.c34 unsigned qlen; member
321 for (i = 0; i < loop->qlen && result == 0; i++) { in alloc_requests()
439 loop->qlen = lb_opts->qlen; in loopback_alloc()
440 if (!loop->qlen) in loopback_alloc()
441 loop->qlen = 32; in loopback_alloc()
477 result = sprintf(page, "%d\n", opts->qlen); in f_lb_opts_qlen_show()
500 opts->qlen = num; in f_lb_opts_qlen_store()
507 CONFIGFS_ATTR(f_lb_opts_, qlen);
577 lb_opts->qlen = GZERO_QLEN; in loopback_alloc_instance()
/linux/drivers/nfc/st-nci/
H A Dndlc.c94 if (ndlc->send_q.qlen) in llt_ndlc_send_queue()
96 ndlc->send_q.qlen, ndlc->ack_pending_q.qlen); in llt_ndlc_send_queue()
98 while (ndlc->send_q.qlen) { in llt_ndlc_send_queue()
153 if (ndlc->rcv_q.qlen) in llt_ndlc_rcv_queue()
154 pr_debug("rcvQlen=%d\n", ndlc->rcv_q.qlen); in llt_ndlc_rcv_queue()
/linux/tools/testing/selftests/net/tcp_ao/lib/
H A Drepair.c42 static void test_sock_checkpoint_queue(int sk, int queue, int qlen, in test_sock_checkpoint_queue() argument
56 if (!qlen) { in test_sock_checkpoint_queue()
61 q->buf = malloc(qlen); in test_sock_checkpoint_queue()
64 ret = recv(sk, q->buf, qlen, MSG_PEEK | MSG_DONTWAIT); in test_sock_checkpoint_queue()
65 if (ret != qlen) in test_sock_checkpoint_queue()
66 test_error("recv(%d): %d", qlen, ret); in test_sock_checkpoint_queue()
/linux/net/kcm/
H A Dkcmproc.c119 kcm->sk.sk_receive_queue.qlen, in kcm_format_sock()
121 kcm->sk.sk_write_queue.qlen, in kcm_format_sock()
149 psock->sk->sk_receive_queue.qlen, in kcm_format_psock()
151 psock->sk->sk_write_queue.qlen, in kcm_format_psock()
167 if (psock->sk->sk_receive_queue.qlen) { in kcm_format_psock()
/linux/tools/testing/selftests/net/
H A Dtfo.c48 unsigned long qlen = 32; in run_server() local
66 if (setsockopt(fd, SOL_TCP, TCP_FASTOPEN, &qlen, sizeof(qlen)) < 0) in run_server()
/linux/net/nfc/hci/
H A Dllc_shdlc.c322 if (shdlc->send_q.qlen == 0) { in llc_shdlc_rcv_s_frame()
462 if (shdlc->rcv_q.qlen) in llc_shdlc_handle_rcv_queue()
463 pr_debug("rcvQlen=%d\n", shdlc->rcv_q.qlen); in llc_shdlc_handle_rcv_queue()
518 if (shdlc->send_q.qlen) in llc_shdlc_handle_send_queue()
520 shdlc->send_q.qlen, shdlc->ns, shdlc->dnr, in llc_shdlc_handle_send_queue()
523 shdlc->ack_pending_q.qlen); in llc_shdlc_handle_send_queue()
525 while (shdlc->send_q.qlen && shdlc->ack_pending_q.qlen < shdlc->w && in llc_shdlc_handle_send_queue()
/linux/drivers/net/wireless/broadcom/brcm80211/include/
H A Dbrcmu_utils.h78 return pq->q[prec].skblist.qlen; in pktq_plen()
83 return pq->q[prec].max - pq->q[prec].skblist.qlen; in pktq_pavail()
88 return pq->q[prec].skblist.qlen >= pq->q[prec].max; in pktq_pfull()
/linux/drivers/net/ethernet/intel/i40e/
H A Di40e_lan_hmc.h25 u16 qlen; member
65 u16 qlen; member
/linux/drivers/crypto/cavium/nitrox/
H A Dnitrox_reqmgr.c266 static inline bool cmdq_full(struct nitrox_cmdq *cmdq, int qlen) in cmdq_full() argument
268 if (atomic_inc_return(&cmdq->pending_count) > qlen) { in cmdq_full()
310 cmdq->write_idx = incr_index(idx, 1, ndev->qlen); in post_se_instr()
331 if (unlikely(cmdq_full(cmdq, ndev->qlen))) { in post_backlog_cmds()
357 if (unlikely(cmdq_full(cmdq, ndev->qlen))) { in nitrox_enqueue_request()

123456