Home
last modified time | relevance | path

Searched refs:qstats (Results 1 – 25 of 41) sorted by relevance

12

/linux/samples/bpf/
H A Dhbm.c163 struct hbm_queue_stats qstats = {0}; in run_bpf_prog() local
189 qstats.rate = rate; in run_bpf_prog()
190 qstats.stats = stats_flag ? 1 : 0; in run_bpf_prog()
191 qstats.loopback = loopback_flag ? 1 : 0; in run_bpf_prog()
192 qstats.no_cn = no_cn_flag ? 1 : 0; in run_bpf_prog()
193 if (bpf_map_update_elem(queue_stats_fd, &key, &qstats, BPF_ANY)) { in run_bpf_prog()
224 bpf_map_lookup_elem(queue_stats_fd, &key, &qstats); in run_bpf_prog()
232 last_cg_tx_bytes = qstats.bytes_total; in run_bpf_prog()
253 bpf_map_lookup_elem(queue_stats_fd, &key, &qstats); in run_bpf_prog()
254 new_cg_tx_bytes = qstats in run_bpf_prog()
[all...]
/linux/net/core/
H A Dgen_stats.c339 static void gnet_stats_add_queue_cpu(struct gnet_stats_queue *qstats,
347 qstats->qlen += READ_ONCE(qcpu->qlen); in gnet_stats_add_queue_cpu()
348 qstats->backlog += READ_ONCE(qcpu->backlog); in gnet_stats_add_queue_cpu()
349 qstats->drops += READ_ONCE(qcpu->drops); in gnet_stats_add_queue_cpu()
350 qstats->requeues += READ_ONCE(qcpu->requeues); in gnet_stats_add_queue_cpu()
351 qstats->overlimits += READ_ONCE(qcpu->overlimits); in gnet_stats_add_queue_cpu()
355 void gnet_stats_add_queue(struct gnet_stats_queue *qstats,
360 gnet_stats_add_queue_cpu(qstats, cpu); in gnet_stats_add_queue()
362 qstats->qlen += READ_ONCE(q->qlen); in gnet_stats_add_queue()
363 qstats in gnet_stats_add_queue()
340 gnet_stats_add_queue_cpu(struct gnet_stats_queue * qstats,const struct gnet_stats_queue __percpu * q) gnet_stats_add_queue_cpu() argument
356 gnet_stats_add_queue(struct gnet_stats_queue * qstats,const struct gnet_stats_queue __percpu * cpu,const struct gnet_stats_queue * q) gnet_stats_add_queue() argument
391 struct gnet_stats_queue qstats = {0}; gnet_stats_copy_queue() local
[all...]
/linux/net/sched/
H A Dsch_skbprio.c35 struct gnet_stats_queue qstats[SKBPRIO_MAX_PRIORITY]; member
87 q->qstats[prio].backlog += qdisc_pkt_len(skb); in skbprio_enqueue()
103 q->qstats[prio].drops++; in skbprio_enqueue()
104 q->qstats[prio].overlimits++; in skbprio_enqueue()
110 q->qstats[prio].backlog += qdisc_pkt_len(skb); in skbprio_enqueue()
119 q->qstats[lp].backlog -= qdisc_pkt_len(to_drop); in skbprio_enqueue()
120 q->qstats[lp].drops++; in skbprio_enqueue()
121 q->qstats[lp].overlimits++; in skbprio_enqueue()
152 q->qstats[q->highest_prio].backlog -= qdisc_pkt_len(skb); in skbprio_dequeue()
188 memset(&q->qstats, in skbprio_init()
[all...]
H A Dsch_gred.c118 return sch->qstats.backlog; in gred_backlog()
182 if (likely(sch->qstats.backlog + qdisc_pkt_len(skb) <= in gred_enqueue()
279 if (!sch->qstats.backlog) in gred_dequeue()
348 opt->set.qstats = &sch->qstats; in gred_offload()
386 table->tab[i]->backlog += hw_stats->stats.qstats[i].backlog; in gred_offload_dump_stats()
390 sch->qstats.qlen += hw_stats->stats.qstats[i].qlen; in gred_offload_dump_stats()
391 qstats_backlog_add(sch, hw_stats->stats.qstats[i].backlog); in gred_offload_dump_stats()
392 __qdisc_qstats_drop(sch, hw_stats->stats.qstats[ in gred_offload_dump_stats()
[all...]
H A Dsch_mq.c41 .qstats = &sch->qstats, in mq_offload_stats()
146 struct gnet_stats_queue qstats = { 0 }; in mq_dump_common()
165 gnet_stats_add_queue(&qstats, qdisc->cpu_qstats, in mq_dump_common()
166 &qdisc->qstats); in mq_dump_common()
176 WRITE_ONCE(sch->qstats.qlen, qstats.qlen); in mq_dump()
177 WRITE_ONCE(sch->qstats.backlog, qstats.backlog); in mq_dump()
178 WRITE_ONCE(sch->qstats in mq_dump()
[all...]
H A Dsch_fifo.c22 if (likely(sch->qstats.backlog + qdisc_pkt_len(skb) <= in bfifo_enqueue()
49 prev_backlog = sch->qstats.backlog; in pfifo_tail_enqueue()
55 qdisc_tree_reduce_backlog(sch, 0, prev_backlog - sch->qstats.backlog); in pfifo_tail_enqueue()
95 qopt.stats.qstats = &sch->qstats; in fifo_offload_dump()
H A Dsch_mqprio.c557 struct gnet_stats_queue qstats = { 0 }; in mqprio_dump()
577 gnet_stats_add_queue(&qstats, qdisc->cpu_qstats, in mqprio_dump()
578 &qdisc->qstats); in mqprio_dump()
588 WRITE_ONCE(sch->qstats.qlen, qstats.qlen); in mqprio_dump()
589 WRITE_ONCE(sch->qstats.backlog, qstats.backlog); in mqprio_dump()
590 WRITE_ONCE(sch->qstats.drops, qstats.drops); in mqprio_dump()
591 WRITE_ONCE(sch->qstats in mqprio_dump()
668 struct gnet_stats_queue qstats = {0}; mqprio_dump_class_stats() local
[all...]
H A Dsch_ets.c45 struct gnet_stats_queue qstats; member
132 qopt.replace_params.qstats = &sch->qstats; in ets_offload_change()
196 qopt.stats.qstats = &sch->qstats; in ets_offload_dump()
438 cl->qstats.drops++; in ets_qdisc_enqueue()
694 memset(&q->classes[i].qstats, 0, sizeof(q->classes[i].qstats)); in ets_qdisc_change()
H A Dsch_prio.c156 opt.replace_params.qstats = &sch->qstats; in prio_offload()
254 .qstats = &sch->qstats, in prio_dump_offload()
H A Dsch_tbf.c158 qopt.replace_params.qstats = &sch->qstats; in tbf_offload_change()
187 qopt.stats.qstats = &sch->qstats;
H A Dsch_red.c81 child->qstats.backlog); in red_enqueue()
214 opt.set.qstats = &sch->qstats; in red_offload()
411 .stats.qstats = &sch->qstats, in red_dump_offload_stats()
H A Dsch_fq_codel.c222 prev_backlog = sch->qstats.backlog; in fq_codel_enqueue()
235 prev_backlog -= sch->qstats.backlog; in fq_codel_enqueue()
306 skb = codel_dequeue(sch, &sch->qstats.backlog, &q->cparams, in fq_codel_dequeue()
H A Dsch_drr.c22 struct gnet_stats_queue qstats; member
275 gnet_stats_copy_queue(d, cl_q->cpu_qstats, &cl_q->qstats, qlen) < 0) in drr_dump_class_stats()
355 cl->qstats.drops++; in drr_enqueue()
H A Dbpf_qdisc.c65 case offsetof(struct Qdisc, qstats) ... offsetofend(struct Qdisc, qstats) - 1: in bpf_qdisc_qdisc_access()
66 *end = offsetofend(struct Qdisc, qstats); in bpf_qdisc_qdisc_access()
H A Dsch_codel.c64 skb = codel_dequeue(sch, &sch->qstats.backlog, &q->params, &q->vars, in codel_qdisc_dequeue()
H A Dsch_pie.c99 if (!pie_drop_early(sch, &q->params, &q->vars, sch->qstats.backlog, in pie_qdisc_enqueue()
434 pie_calculate_probability(&q->params, &q->vars, sch->qstats.backlog); in pie_timer()
531 pie_process_dequeue(skb, &q->params, &q->vars, sch->qstats.backlog); in pie_qdisc_dequeue()
H A Dsch_plug.c92 if (likely(sch->qstats.backlog + skb->len <= q->limit)) { in plug_enqueue()
/linux/drivers/net/ethernet/broadcom/bnx2x/
H A Dbnx2x_stats.c952 struct bnx2x_eth_q_stats *qstats = in bnx2x_storm_stats_update() local
976 qstats->total_bytes_received_hi = in bnx2x_storm_stats_update()
977 qstats->total_broadcast_bytes_received_hi; in bnx2x_storm_stats_update()
978 qstats->total_bytes_received_lo = in bnx2x_storm_stats_update()
979 qstats->total_broadcast_bytes_received_lo; in bnx2x_storm_stats_update()
981 ADD_64(qstats->total_bytes_received_hi, in bnx2x_storm_stats_update()
982 qstats->total_multicast_bytes_received_hi, in bnx2x_storm_stats_update()
983 qstats->total_bytes_received_lo, in bnx2x_storm_stats_update()
984 qstats->total_multicast_bytes_received_lo); in bnx2x_storm_stats_update()
986 ADD_64(qstats->total_bytes_received_hi, in bnx2x_storm_stats_update()
[all …]
H A Dbnx2x_stats.h437 ADD_EXTEND_64(qstats->t##_hi, qstats->t##_lo, diff); \
452 ADD_EXTEND_64(qstats->t##_hi, qstats->t##_lo, diff); \
465 ADD_EXTEND_64(qstats->t##_hi, qstats->t##_lo, diff); \
470 qstats->t##_lo = qstats_old->t##_lo + le32_to_cpu(s.lo); \
471 qstats->t##_hi = qstats_old->t##_hi + le32_to_cpu(s.hi) \
472 + ((qstats->t##_lo < qstats_old->t##_lo) ? 1 : 0); \
477 qstats_old->f = qstats->f; \
482 ADD_64(estats->s##_hi, qstats->s##_hi, \
483 estats->s##_lo, qstats->s##_lo); \
486 qstats_old->s##_hi_old = qstats->s##_hi; \
[all …]
/linux/include/net/
H A Dsch_generic.h125 /* Note : we only change qstats.backlog in fast path. */
126 struct gnet_stats_queue qstats; member
562 __u32 qlen = q->qstats.qlen; in qdisc_skb_cb()
984 WRITE_ONCE(sch->qstats.backlog, sch->qstats.backlog - val); in qdisc_qstats_cpu_qlen_inc()
1001 WRITE_ONCE(sch->qstats.backlog, sch->qstats.backlog + val);
1033 WRITE_ONCE(sch->qstats.drops, sch->qstats.drops + count);
1036 static inline void qstats_drop_inc(struct gnet_stats_queue *qstats) in qdisc_qstats_qlen_backlog()
1002 qstats_drop_inc(struct gnet_stats_queue * qstats) qstats_drop_inc() argument
1007 qstats_overlimit_inc(struct gnet_stats_queue * qstats) qstats_overlimit_inc() argument
1037 struct gnet_stats_queue qstats = { 0 }; qdisc_qstats_qlen_backlog() local
[all...]
H A Dpkt_cls.h826 struct gnet_stats_queue *qstats; member
903 struct gnet_stats_queue *qstats; member
942 struct gnet_stats_queue *qstats; member
948 struct gnet_stats_queue qstats[MAX_DPs]; member
975 struct gnet_stats_queue *qstats; member
1016 struct gnet_stats_queue *qstats; member
1045 struct gnet_stats_queue *qstats; member
H A Dgen_stats.h63 void gnet_stats_add_queue(struct gnet_stats_queue *qstats,
/linux/Documentation/networking/
H A Dgen_stats.rst26 struct gnet_stats_queue qstats;
33 mystruct->qstats.backlog += skb->pkt_len;
50 gnet_stats_copy_queue(&dump, &mystruct->qstats) < 0 ||
/linux/drivers/net/ethernet/netronome/nfp/abm/
H A Dqdisc.c462 struct gnet_stats_queue *qstats) in nfp_abm_stats_calculate() argument
466 qstats->qlen += new->backlog_pkts - old->backlog_pkts; in nfp_abm_stats_calculate()
467 qstats->backlog += new->backlog_bytes - old->backlog_bytes; in nfp_abm_stats_calculate()
468 qstats->overlimits += new->overlimits - old->overlimits; in nfp_abm_stats_calculate()
469 qstats->drops += new->drops - old->drops; in nfp_abm_stats_calculate()
503 &stats->bstats[i], &stats->qstats[i]); in nfp_abm_gred_stats()
654 stats->bstats, stats->qstats); in nfp_abm_red_stats()
811 stats->bstats, stats->qstats); in nfp_abm_mq_stats()
/linux/drivers/net/ethernet/mellanox/mlxsw/
H A Dspectrum_qdisc.c571 stats_ptr->qstats->drops += drops; in mlxsw_sp_qdisc_update_stats()
572 stats_ptr->qstats->backlog += mlxsw_sp_cells_bytes(mlxsw_sp, backlog); in mlxsw_sp_qdisc_update_stats()
748 struct gnet_stats_queue *qstats) in mlxsw_sp_qdisc_leaf_unoffload() argument
754 qstats->backlog -= backlog; in mlxsw_sp_qdisc_leaf_unoffload()
765 mlxsw_sp_qdisc_leaf_unoffload(mlxsw_sp_port, mlxsw_sp_qdisc, p->qstats); in mlxsw_sp_qdisc_red_unoffload()
817 stats_ptr->qstats->overlimits += overlimits; in mlxsw_sp_qdisc_get_red_stats()
1058 mlxsw_sp_qdisc_leaf_unoffload(mlxsw_sp_port, mlxsw_sp_qdisc, p->qstats); in mlxsw_sp_qdisc_tbf_unoffload()
1419 struct gnet_stats_queue *qstats) in __mlxsw_sp_qdisc_ets_unoffload() argument
1425 qstats->backlog -= backlog; in __mlxsw_sp_qdisc_ets_unoffload()
1436 p->qstats); in mlxsw_sp_qdisc_prio_unoffload()
[all …]

12