| /linux/sound/core/seq/oss/ |
| A D | seq_oss_readq.c | 48 q->qlen = 0; in snd_seq_oss_readq_new()
76 if (q->qlen) { in snd_seq_oss_readq_clear()
77 q->qlen = 0; in snd_seq_oss_readq_clear()
146 if (q->qlen >= q->maxlen - 1) { in snd_seq_oss_readq_put_event()
153 q->qlen++; in snd_seq_oss_readq_put_event()
171 if (q->qlen == 0) in snd_seq_oss_readq_pick()
184 (q->qlen > 0 || q->head == q->tail), in snd_seq_oss_readq_wait()
195 if (q->qlen > 0) { in snd_seq_oss_readq_free()
197 q->qlen--; in snd_seq_oss_readq_free()
209 return q->qlen; in snd_seq_oss_readq_poll()
[all …]
|
| /linux/net/sched/ |
| A D | sch_sfq.c | 207 int qlen = slot->qlen; in sfq_link() local
210 n = q->dep[qlen].next; in sfq_link()
310 sch->q.qlen--; in sfq_drop()
350 sfq_index x, qlen; in sfq_enqueue() local
464 qlen = slot->qlen; in sfq_enqueue()
469 if (qlen != slot->qlen) { in sfq_enqueue()
502 sch->q.qlen--; in sfq_dequeue()
549 if (!slot->qlen) in sfq_rehash()
689 qlen = sch->q.qlen; in sfq_change()
697 qdisc_tree_reduce_backlog(sch, qlen - sch->q.qlen, dropped); in sfq_change()
[all …]
|
| A D | sch_sfb.c | 133 b[hash].qlen++; in increment_one_qlen()
162 b[hash].qlen--; in decrement_one_qlen()
205 if (qlen < b->qlen) in sfb_compute_qlen()
206 qlen = b->qlen; in sfb_compute_qlen()
214 return qlen; in sfb_compute_qlen()
333 if (b->qlen == 0) in sfb_enqueue()
338 minqlen = b->qlen; in sfb_enqueue()
366 if (b->qlen == 0) in sfb_enqueue()
405 sch->q.qlen++; in sfb_enqueue()
434 sch->q.qlen--; in sfb_dequeue()
[all …]
|
| A D | sch_codel.c | 101 if (q->stats.drop_count && sch->q.qlen) { in codel_qdisc_dequeue()
138 unsigned int qlen, dropped = 0; in codel_change() local
175 qlen = sch->q.qlen; in codel_change()
176 while (sch->q.qlen > sch->limit) { in codel_change()
183 qdisc_tree_reduce_backlog(sch, qlen - sch->q.qlen, dropped); in codel_change()
|
| A D | sch_skbprio.c | 82 if (sch->q.qlen < sch->limit) { in skbprio_enqueue()
94 sch->q.qlen++; in skbprio_enqueue()
125 BUG_ON(sch->q.qlen != 1); in skbprio_enqueue()
148 sch->q.qlen--; in skbprio_dequeue()
157 BUG_ON(sch->q.qlen); in skbprio_dequeue()
217 sch->q.qlen = 0; in skbprio_reset()
258 q->qstats[cl - 1].qlen) < 0) in skbprio_dump_class_stats()
|
| A D | sch_choke.c | 130 --sch->q.qlen; in choke_drop_by_idx()
221 q->vars.qavg = red_calc_qavg(p, &q->vars, sch->q.qlen); in choke_enqueue()
268 if (sch->q.qlen < q->limit) { in choke_enqueue()
271 ++sch->q.qlen; in choke_enqueue()
298 --sch->q.qlen; in choke_dequeue()
318 sch->q.qlen = 0; in choke_reset()
383 unsigned int oqlen = sch->q.qlen, tail = 0; in choke_change()
398 --sch->q.qlen; in choke_change()
401 qdisc_tree_reduce_backlog(sch, oqlen - sch->q.qlen, dropped); in choke_change()
|
| A D | sch_drr.c | 260 __u32 qlen = qdisc_qlen_sum(cl->qdisc); in drr_dump_class_stats() local
265 if (qlen) in drr_dump_class_stats()
270 gnet_stats_copy_queue(d, cl_q->cpu_qstats, &cl_q->qstats, qlen) < 0) in drr_dump_class_stats()
355 first = !cl->qdisc->q.qlen; in drr_enqueue()
371 sch->q.qlen++; in drr_enqueue()
398 if (cl->qdisc->q.qlen == 0) in drr_dequeue()
404 sch->q.qlen--; in drr_dequeue()
439 if (cl->qdisc->q.qlen) in drr_reset_qdisc()
445 sch->q.qlen = 0; in drr_reset_qdisc()
|
| A D | sch_hhf.c | 362 sch->q.qlen--; in hhf_drop()
402 if (++sch->q.qlen <= sch->limit) in hhf_enqueue()
445 sch->q.qlen--; in hhf_dequeue()
513 unsigned int qlen, prev_backlog; in hhf_change() local
563 qlen = sch->q.qlen; in hhf_change()
565 while (sch->q.qlen > sch->limit) { in hhf_change()
570 qdisc_tree_reduce_backlog(sch, qlen - sch->q.qlen, in hhf_change()
|
| A D | sch_fq_pie.c | 48 u32 qlen; member
183 sch->q.qlen++; in fq_pie_qdisc_enqueue()
189 sel_flow->qlen = 0; in fq_pie_qdisc_enqueue()
192 sel_flow->qlen++; in fq_pie_qdisc_enqueue()
256 sch->q.qlen--; in fq_pie_qdisc_dequeue()
269 flow->qlen--; in fq_pie_qdisc_dequeue()
355 while (sch->q.qlen > sch->limit) { in fq_pie_change()
525 sch->q.qlen = 0; in fq_pie_reset()
|
| A D | sch_fq_codel.c | 180 sch->q.qlen -= i; in fq_codel_drop()
217 if (++sch->q.qlen <= sch->limit && !memory_limited) in fq_codel_enqueue()
221 prev_qlen = sch->q.qlen; in fq_codel_enqueue()
232 prev_qlen -= sch->q.qlen; in fq_codel_enqueue()
267 sch->q.qlen--; in dequeue_func()
320 if (q->cstats.drop_count && sch->q.qlen) { in fq_codel_dequeue()
350 sch->q.qlen = 0; in fq_codel_reset()
439 while (sch->q.qlen > sch->limit || in fq_codel_change()
666 qs.qlen++; in fq_codel_dump_class_stats()
674 if (gnet_stats_copy_queue(d, NULL, &qs, qs.qlen) < 0) in fq_codel_dump_class_stats()
|
| /linux/include/net/ |
| A D | sch_generic.h | 68 __u32 qlen; member
533 __u32 qlen = q->qstats.qlen; in qdisc_qlen_sum() local
538 qlen += per_cpu_ptr(q->cpu_qstats, i)->qlen; in qdisc_qlen_sum()
540 qlen += q->q.qlen; in qdisc_qlen_sum()
543 return qlen; in qdisc_qlen_sum()
960 *qlen = qstats.qlen + qdisc_qlen(sch); in qdisc_qstats_qlen_backlog()
985 qh->qlen = 0; in qdisc_skb_head_init()
1001 qh->qlen++; in __qdisc_enqueue_tail()
1019 qh->qlen++; in __qdisc_enqueue_head()
1028 qh->qlen--; in __qdisc_dequeue_head()
[all …]
|
| A D | request_sock.h | 160 int qlen; /* # of pending (TCP_SYN_RECV) reqs */ member
178 atomic_t qlen; member
220 atomic_dec(&queue->qlen); in reqsk_queue_removed()
226 atomic_inc(&queue->qlen); in reqsk_queue_added()
231 return atomic_read(&queue->qlen); in reqsk_queue_len()
|
| /linux/sound/core/seq/ |
| A D | seq_midi_event.c | 50 int qlen; member
141 dev->qlen = 0; in reset_encode()
200 dev->qlen = status_event[dev->type].qlen; in snd_midi_event_encode_byte()
202 if (dev->qlen > 0) { in snd_midi_event_encode_byte()
206 dev->qlen--; in snd_midi_event_encode_byte()
210 dev->qlen = status_event[dev->type].qlen - 1; in snd_midi_event_encode_byte()
320 int qlen; in snd_midi_event_decode() local
331 qlen = status_event[type].qlen + 1; in snd_midi_event_decode()
336 qlen = status_event[type].qlen; in snd_midi_event_decode()
338 if (count < qlen) in snd_midi_event_decode()
[all …]
|
| /linux/include/trace/events/ |
| A D | rcu.h | 516 TP_ARGS(rcuname, rhp, qlen),
522 __field(long, qlen)
529 __entry->qlen = qlen;
534 __entry->qlen)
574 long qlen),
582 __field(long, qlen)
589 __entry->qlen = qlen;
594 __entry->qlen)
608 TP_ARGS(rcuname, qlen, blimit),
612 __field(long, qlen)
[all …]
|
| /linux/drivers/md/ |
| A D | dm-ps-queue-length.c | 39 atomic_t qlen; /* the number of in-flight I/Os */ member
100 DMEMIT("%d ", atomic_read(&pi->qlen)); in ql_status()
152 atomic_set(&pi->qlen, 0); in ql_add_path()
203 (atomic_read(&pi->qlen) < atomic_read(&best->qlen))) in ql_select_path()
206 if (!atomic_read(&best->qlen)) in ql_select_path()
227 atomic_inc(&pi->qlen); in ql_start_io()
237 atomic_dec(&pi->qlen); in ql_end_io()
|
| /linux/drivers/usb/gadget/legacy/ |
| A D | gmidi.c | 52 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()
|
| A D | printer.c | 51 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
|
| A D | zero.c | 66 .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/drivers/crypto/cavium/cpt/ |
| A D | cptvf_main.c | 99 pqinfo->qlen = 0; in free_pending_queues()
112 pqinfo->qlen = qlen; in alloc_pending_queues()
114 size = (qlen * sizeof(struct pending_entry)); in alloc_pending_queues()
147 ret = alloc_pending_queues(&cptvf->pqinfo, qlen, nr_queues); in init_pending_queues()
205 u32 qlen) in alloc_command_queues() argument
215 cptvf->qsize = min(qlen, cqinfo->qchunksize) * in alloc_command_queues()
218 q_size = qlen * cqinfo->cmd_size; in alloc_command_queues()
279 static int init_command_queues(struct cpt_vf *cptvf, u32 qlen) in init_command_queues() argument
286 qlen); in init_command_queues()
326 ret = init_command_queues(cptvf, qlen); in cptvf_sw_init()
[all …]
|
| /linux/drivers/usb/gadget/function/ |
| A D | f_loopback.c | 34 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()
|
| /linux/net/core/ |
| A D | gen_stats.c | 348 qstats->qlen += qcpu->backlog; in gnet_stats_add_queue_cpu()
363 qstats->qlen += q->qlen; in gnet_stats_add_queue()
389 struct gnet_stats_queue *q, __u32 qlen) in gnet_stats_copy_queue() argument
394 qstats.qlen = qlen; in gnet_stats_copy_queue()
398 d->tc_stats.qlen = qstats.qlen; in gnet_stats_copy_queue()
|
| A D | request_sock.c | 41 queue->fastopenq.qlen = 0; in reqsk_queue_alloc()
101 fastopenq->qlen--; in reqsk_fastopen_remove()
129 fastopenq->qlen++; in reqsk_fastopen_remove()
|
| /linux/drivers/nfc/st-nci/ |
| A D | ndlc.c | 94 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/drivers/crypto/marvell/octeontx/ |
| A D | otx_cptvf_main.c | 88 queue->qlen = 0; in free_pending_queues()
102 size = (qlen * sizeof(struct otx_cpt_pending_entry)); in alloc_pending_queues()
114 queue->qlen = qlen; in alloc_pending_queues()
127 static int init_pending_queues(struct otx_cptvf *cptvf, u32 qlen, in init_pending_queues() argument
136 ret = alloc_pending_queues(&cptvf->pqinfo, qlen, num_queues); in init_pending_queues()
189 u32 qlen) in alloc_command_queues() argument
200 cptvf->qsize = min(qlen, cqinfo->qchunksize) * in alloc_command_queues()
203 q_size = qlen * OTX_CPT_INST_SIZE; in alloc_command_queues()
271 ret = alloc_command_queues(cptvf, &cptvf->cqinfo, qlen); in init_command_queues()
310 ret = init_command_queues(cptvf, qlen); in cptvf_sw_init()
[all …]
|
| /linux/net/kcm/ |
| A D | kcmproc.c | 119 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()
|