Home
last modified time | relevance | path

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

123456

/Linux-v4.19/sound/core/seq/oss/
Dseq_oss_readq.c61 q->qlen = 0; in snd_seq_oss_readq_new()
89 if (q->qlen) { in snd_seq_oss_readq_clear()
90 q->qlen = 0; in snd_seq_oss_readq_clear()
159 if (q->qlen >= q->maxlen - 1) { in snd_seq_oss_readq_put_event()
166 q->qlen++; in snd_seq_oss_readq_put_event()
184 if (q->qlen == 0) in snd_seq_oss_readq_pick()
197 (q->qlen > 0 || q->head == q->tail), in snd_seq_oss_readq_wait()
208 if (q->qlen > 0) { in snd_seq_oss_readq_free()
210 q->qlen--; in snd_seq_oss_readq_free()
222 return q->qlen; in snd_seq_oss_readq_poll()
[all …]
/Linux-v4.19/net/sched/
Dsch_sfq.c107 sfq_index qlen; /* number of skbs in skblist */ member
211 int qlen = slot->qlen; in sfq_link() local
213 p = qlen + SFQ_MAX_FLOWS; in sfq_link()
214 n = q->dep[qlen].next; in sfq_link()
219 q->dep[qlen].next = x; /* sfq_dep_head(q, p)->next = x */ in sfq_link()
239 d = q->slots[x].qlen--; in sfq_dec()
252 d = ++q->slots[x].qlen; in sfq_inc()
314 sch->q.qlen--; in sfq_drop()
354 sfq_index x, qlen; in sfq_enqueue() local
428 if (slot->qlen >= q->maxdepth) { in sfq_enqueue()
[all …]
Dsch_sfb.c44 u16 qlen; /* length of virtual queue */ member
136 if (b[hash].qlen < 0xFFFF) in increment_one_qlen()
137 b[hash].qlen++; in increment_one_qlen()
165 if (b[hash].qlen > 0) in decrement_one_qlen()
166 b[hash].qlen--; in decrement_one_qlen()
205 u32 qlen = 0, prob = 0, totalpm = 0; in sfb_compute_qlen() local
209 if (qlen < b->qlen) in sfb_compute_qlen()
210 qlen = b->qlen; in sfb_compute_qlen()
218 return qlen; in sfb_compute_qlen()
296 if (unlikely(sch->q.qlen >= q->limit)) { in sfb_enqueue()
[all …]
Dsch_mq.c138 __u32 qlen = 0; in mq_dump() local
140 sch->q.qlen = 0; in mq_dump()
154 qlen = qdisc_qlen_sum(qdisc); in mq_dump()
160 &qdisc->qstats, qlen); in mq_dump()
162 sch->q.qlen += qdisc->q.qlen; in mq_dump()
165 sch->qstats.qlen += qdisc->qstats.qlen; in mq_dump()
246 gnet_stats_copy_queue(d, NULL, &sch->qstats, sch->q.qlen) < 0) in mq_dump_class_stats()
Dsch_pie.c189 unsigned int qlen, dropped = 0; in pie_change() local
234 qlen = sch->q.qlen; in pie_change()
235 while (sch->q.qlen > sch->limit) { in pie_change()
242 qdisc_tree_reduce_backlog(sch, qlen - sch->q.qlen, dropped); in pie_change()
252 int qlen = sch->qstats.backlog; /* current queue size in bytes */ in pie_process_dequeue() local
258 if (qlen >= QUEUE_THRESHOLD && q->vars.dq_count == DQCOUNT_INVALID) { in pie_process_dequeue()
297 if (qlen < QUEUE_THRESHOLD) in pie_process_dequeue()
317 u32 qlen = sch->qstats.backlog; /* queue size in bytes */ in calculate_probability() local
328 qdelay = (qlen << PIE_SCALE) / q->vars.avg_dq_rate; in calculate_probability()
335 if (qdelay == 0 && qlen != 0) in calculate_probability()
[all …]
Dsch_drr.c55 unsigned int len = cl->qdisc->q.qlen; in drr_purge_queue()
272 __u32 qlen = cl->qdisc->q.qlen; in drr_dump_class_stats() local
276 if (qlen) in drr_dump_class_stats()
282 gnet_stats_copy_queue(d, NULL, &cl->qdisc->qstats, qlen) < 0) in drr_dump_class_stats()
374 if (cl->qdisc->q.qlen == 1) { in drr_enqueue()
380 sch->q.qlen++; in drr_enqueue()
407 if (cl->qdisc->q.qlen == 0) in drr_dequeue()
413 sch->q.qlen--; in drr_dequeue()
448 if (cl->qdisc->q.qlen) in drr_reset_qdisc()
454 sch->q.qlen = 0; in drr_reset_qdisc()
Dsch_skbprio.c86 if (sch->q.qlen < sch->limit) { in skbprio_enqueue()
98 sch->q.qlen++; in skbprio_enqueue()
129 BUG_ON(sch->q.qlen != 1); in skbprio_enqueue()
152 sch->q.qlen--; in skbprio_dequeue()
161 BUG_ON(sch->q.qlen); in skbprio_dequeue()
218 sch->q.qlen = 0; in skbprio_reset()
259 q->qstats[cl - 1].qlen) < 0) in skbprio_dump_class_stats()
Dsch_codel.c101 if (q->stats.drop_count && sch->q.qlen) { in codel_qdisc_dequeue()
138 unsigned int qlen, dropped = 0; in codel_change() local
174 qlen = sch->q.qlen; in codel_change()
175 while (sch->q.qlen > sch->limit) { in codel_change()
182 qdisc_tree_reduce_backlog(sch, qlen - sch->q.qlen, dropped); in codel_change()
Dsch_choke.c134 --sch->q.qlen; in choke_drop_by_idx()
231 q->vars.qavg = red_calc_qavg(p, &q->vars, sch->q.qlen); in choke_enqueue()
278 if (sch->q.qlen < q->limit) { in choke_enqueue()
281 ++sch->q.qlen; in choke_enqueue()
308 --sch->q.qlen; in choke_dequeue()
328 sch->q.qlen = 0; in choke_reset()
390 unsigned int oqlen = sch->q.qlen, tail = 0; in choke_change()
405 --sch->q.qlen; in choke_change()
408 qdisc_tree_reduce_backlog(sch, oqlen - sch->q.qlen, dropped); in choke_change()
Dsch_mqprio.c394 sch->q.qlen = 0; in mqprio_dump()
408 __u32 qlen = qdisc_qlen_sum(qdisc); in mqprio_dump() local
415 &qdisc->qstats, qlen); in mqprio_dump()
417 sch->q.qlen += qdisc->q.qlen; in mqprio_dump()
516 __u32 qlen = 0; in mqprio_dump_class_stats() local
542 qlen = qdisc_qlen_sum(qdisc); in mqprio_dump_class_stats()
548 qlen); in mqprio_dump_class_stats()
556 gnet_stats_copy_queue(d, NULL, &qstats, qlen) < 0) in mqprio_dump_class_stats()
565 &sch->qstats, sch->q.qlen) < 0) in mqprio_dump_class_stats()
Dsch_hhf.c361 sch->q.qlen--; in hhf_drop()
401 if (++sch->q.qlen <= sch->limit) in hhf_enqueue()
444 sch->q.qlen--; in hhf_dequeue()
512 unsigned int qlen, prev_backlog; in hhf_change() local
561 qlen = sch->q.qlen; in hhf_change()
563 while (sch->q.qlen > sch->limit) { in hhf_change()
568 qdisc_tree_reduce_backlog(sch, qlen - sch->q.qlen, in hhf_change()
Dsch_multiq.c90 sch->q.qlen++; in multiq_enqueue()
120 sch->q.qlen--; in multiq_dequeue()
166 sch->q.qlen = 0; in multiq_reset()
205 qdisc_tree_reduce_backlog(child, child->q.qlen, in multiq_tune()
229 old->q.qlen, in multiq_tune()
347 gnet_stats_copy_queue(d, NULL, &cl_q->qstats, cl_q->q.qlen) < 0) in multiq_dump_class_stats()
/Linux-v4.19/include/trace/events/
Drcu.h475 long qlen),
477 TP_ARGS(rcuname, rhp, qlen_lazy, qlen),
484 __field(long, qlen)
492 __entry->qlen = qlen;
497 __entry->qlen_lazy, __entry->qlen)
511 long qlen_lazy, long qlen),
513 TP_ARGS(rcuname, rhp, offset, qlen_lazy, qlen),
520 __field(long, qlen)
528 __entry->qlen = qlen;
533 __entry->qlen_lazy, __entry->qlen)
[all …]
/Linux-v4.19/sound/core/seq/
Dseq_midi_event.c63 int qlen; member
154 dev->qlen = 0; in reset_encode()
213 dev->qlen = status_event[dev->type].qlen; in snd_midi_event_encode_byte()
215 if (dev->qlen > 0) { in snd_midi_event_encode_byte()
219 dev->qlen--; in snd_midi_event_encode_byte()
223 dev->qlen = status_event[dev->type].qlen - 1; in snd_midi_event_encode_byte()
227 if (dev->qlen == 0) { in snd_midi_event_encode_byte()
333 int qlen; in snd_midi_event_decode() local
344 qlen = status_event[type].qlen + 1; in snd_midi_event_decode()
349 qlen = status_event[type].qlen; in snd_midi_event_decode()
[all …]
/Linux-v4.19/drivers/md/
Ddm-queue-length.c39 atomic_t qlen; /* the number of in-flight I/Os */ member
100 DMEMIT("%d ", atomic_read(&pi->qlen)); in ql_status()
149 atomic_set(&pi->qlen, 0); in ql_add_path()
200 (atomic_read(&pi->qlen) < atomic_read(&best->qlen))) in ql_select_path()
203 if (!atomic_read(&best->qlen)) in ql_select_path()
224 atomic_inc(&pi->qlen); in ql_start_io()
234 atomic_dec(&pi->qlen); in ql_end_io()
/Linux-v4.19/net/core/
Dgen_stats.c259 qstats->qlen = 0; in __gnet_stats_copy_queue_cpu()
270 __u32 qlen) in __gnet_stats_copy_queue() argument
275 qstats->qlen = q->qlen; in __gnet_stats_copy_queue()
282 qstats->qlen = qlen; in __gnet_stats_copy_queue()
303 struct gnet_stats_queue *q, __u32 qlen) in gnet_stats_copy_queue() argument
307 __gnet_stats_copy_queue(&qstats, cpu_q, q, qlen); in gnet_stats_copy_queue()
311 d->tc_stats.qlen = qstats.qlen; in gnet_stats_copy_queue()
Drequest_sock.c45 queue->fastopenq.qlen = 0; in reqsk_queue_alloc()
105 fastopenq->qlen--; in reqsk_fastopen_remove()
133 fastopenq->qlen++; in reqsk_fastopen_remove()
/Linux-v4.19/include/net/
Dsch_generic.h50 __u32 qlen; member
389 return this_cpu_ptr(q->cpu_qstats)->qlen; in qdisc_qlen_cpu()
394 return q->q.qlen; in qdisc_qlen()
399 __u32 qlen = q->qstats.qlen; in qdisc_qlen_sum() local
404 qlen += per_cpu_ptr(q->cpu_qstats, i)->qlen; in qdisc_qlen_sum()
406 qlen += q->q.qlen; in qdisc_qlen_sum()
409 return qlen; in qdisc_qlen_sum()
637 if (q->q.qlen) { in qdisc_all_tx_empty()
781 this_cpu_inc(sch->cpu_qstats->qlen); in qdisc_qstats_cpu_qlen_inc()
786 this_cpu_dec(sch->cpu_qstats->qlen); in qdisc_qstats_cpu_qlen_dec()
[all …]
Drequest_sock.h151 int qlen; /* # of pending (TCP_SYN_RECV) reqs */ member
169 atomic_t qlen; member
211 atomic_dec(&queue->qlen); in reqsk_queue_removed()
217 atomic_inc(&queue->qlen); in reqsk_queue_added()
222 return atomic_read(&queue->qlen); in reqsk_queue_len()
/Linux-v4.19/drivers/usb/gadget/legacy/
Dgmidi.c52 static unsigned int qlen = 32; variable
53 module_param(qlen, uint, S_IRUGO);
54 MODULE_PARM_DESC(qlen, "USB read and write request queue length");
156 midi_opts->qlen = qlen; in midi_bind()
Dzero.c66 .qlen = GZERO_QLEN,
254 module_param_named(qlen, gzero_options.qlen, uint, S_IRUGO|S_IWUSR);
255 MODULE_PARM_DESC(qlen, "depth of loopback queue");
313 lb_opts->qlen = gzero_options.qlen; in zero_bind()
/Linux-v4.19/drivers/usb/gadget/function/
Df_loopback.c34 unsigned qlen; member
323 for (i = 0; i < loop->qlen && result == 0; i++) { in alloc_requests()
441 loop->qlen = lb_opts->qlen; in loopback_alloc()
442 if (!loop->qlen) in loopback_alloc()
443 loop->qlen = 32; in loopback_alloc()
479 result = sprintf(page, "%d\n", opts->qlen); in f_lb_opts_qlen_show()
502 opts->qlen = num; in f_lb_opts_qlen_store()
509 CONFIGFS_ATTR(f_lb_opts_, qlen);
579 lb_opts->qlen = GZERO_QLEN; in loopback_alloc_instance()
Dg_zero.h24 unsigned qlen; member
53 unsigned qlen; member
/Linux-v4.19/drivers/crypto/cavium/cpt/
Dcptvf_main.c102 pqinfo->qlen = 0; in free_pending_queues()
106 static int alloc_pending_queues(struct pending_qinfo *pqinfo, u32 qlen, in alloc_pending_queues() argument
115 pqinfo->qlen = qlen; in alloc_pending_queues()
117 size = (qlen * sizeof(struct pending_entry)); in alloc_pending_queues()
142 static int init_pending_queues(struct cpt_vf *cptvf, u32 qlen, u32 nr_queues) in init_pending_queues() argument
150 ret = alloc_pending_queues(&cptvf->pqinfo, qlen, nr_queues); in init_pending_queues()
208 u32 qlen) in alloc_command_queues() argument
218 cptvf->qsize = min(qlen, cqinfo->qchunksize) * in alloc_command_queues()
221 q_size = qlen * cqinfo->cmd_size; in alloc_command_queues()
281 static int init_command_queues(struct cpt_vf *cptvf, u32 qlen) in init_command_queues() argument
[all …]
/Linux-v4.19/drivers/nfc/st-nci/
Dndlc.c105 if (ndlc->send_q.qlen) in llt_ndlc_send_queue()
107 ndlc->send_q.qlen, ndlc->ack_pending_q.qlen); in llt_ndlc_send_queue()
109 while (ndlc->send_q.qlen) { in llt_ndlc_send_queue()
164 if (ndlc->rcv_q.qlen) in llt_ndlc_rcv_queue()
165 pr_debug("rcvQlen=%d\n", ndlc->rcv_q.qlen); in llt_ndlc_rcv_queue()

123456