| /Linux-v6.1/include/net/ |
| D | fq_impl.h | 36 idx = flow - fq->flows; in __fq_adjust_removal()
152 flow = &fq->flows[idx]; in fq_flow_classify()
160 tin->flows++; in fq_flow_classify()
173 struct fq_flow *cur = &fq->flows[i]; in fq_find_fattest_flow()
357 fq->flows = kvcalloc(fq->flows_cnt, sizeof(fq->flows[0]), GFP_KERNEL); in fq_init()
358 if (!fq->flows) in fq_init()
363 kvfree(fq->flows); in fq_init()
364 fq->flows = NULL; in fq_init()
369 fq_flow_init(&fq->flows[i]); in fq_init()
380 fq_flow_reset(fq, &fq->flows[i], free_func); in fq_reset()
[all …]
|
| D | fq.h | 57 u32 flows; member
69 struct fq_flow *flows; member
|
| /Linux-v6.1/drivers/crypto/allwinner/sun8i-ss/ |
| D | sun8i-ss-core.c | 74 ss->flows[flow].stat_req++; in sun8i_ss_run_task()
130 reinit_completion(&ss->flows[flow].complete); in sun8i_ss_run_task()
131 ss->flows[flow].status = 0; in sun8i_ss_run_task()
136 wait_for_completion_interruptible_timeout(&ss->flows[flow].complete, in sun8i_ss_run_task()
138 if (ss->flows[flow].status == 0) { in sun8i_ss_run_task()
157 ss->flows[flow].status = 1; in ss_irq_handler()
158 complete(&ss->flows[flow].complete); in ss_irq_handler()
453 seq_printf(seq, "Channel %d: nreq %lu\n", i, ss->flows[i].stat_req); in sun8i_ss_debugfs_show()
509 crypto_engine_exit(ss->flows[i].engine); in sun8i_ss_free_flows()
521 ss->flows = devm_kcalloc(ss->dev, MAXFLOW, sizeof(struct sun8i_ss_flow), in allocate_flows()
[all …]
|
| D | sun8i-ss-prng.c | 127 reinit_completion(&ss->flows[flow].complete); in sun8i_ss_prng_generate()
128 ss->flows[flow].status = 0; in sun8i_ss_prng_generate()
134 wait_for_completion_interruptible_timeout(&ss->flows[flow].complete, in sun8i_ss_prng_generate()
136 if (ss->flows[flow].status == 0) { in sun8i_ss_prng_generate()
|
| D | sun8i-ss-hash.c | 299 ss->flows[flow].stat_req++; in sun8i_ss_run_hash_task()
332 reinit_completion(&ss->flows[flow].complete); in sun8i_ss_run_hash_task()
333 ss->flows[flow].status = 0; in sun8i_ss_run_hash_task()
338 wait_for_completion_interruptible_timeout(&ss->flows[flow].complete, in sun8i_ss_run_hash_task()
340 if (ss->flows[flow].status == 0) { in sun8i_ss_run_hash_task()
416 engine = ss->flows[e].engine; in sun8i_ss_hash_digest()
514 result = ss->flows[rctx->flow].result; in sun8i_ss_hash_run()
515 pad = ss->flows[rctx->flow].pad; in sun8i_ss_hash_run()
|
| D | sun8i-ss-cipher.c | 125 struct sun8i_ss_flow *sf = &ss->flows[rctx->flow]; in sun8i_ss_setup_ivs()
186 struct sun8i_ss_flow *sf = &ss->flows[rctx->flow]; in sun8i_ss_cipher()
355 engine = op->ss->flows[e].engine; in sun8i_ss_skdecrypt()
376 engine = op->ss->flows[e].engine; in sun8i_ss_skencrypt()
|
| /Linux-v6.1/samples/bpf/ |
| D | do_hbm_test.sh | 78 flows=1
150 -f=*|--flows=*)
151 flows="${i#*=}"
278 while [ $flow_cnt -le $flows ] ; do
320 while [ $flow_cnt -le $flows ] ; do
346 iperf3 -c $host -p $port -i 0 -P $flows -f m -t $dur > iperf.$id
366 while [ $flow_cnt -le $flows ] ; do
386 while [ $flow_cnt -le $flows ] ; do
|
| /Linux-v6.1/net/sched/ |
| D | sch_fq_codel.c | 53 struct fq_codel_flow *flows; /* Flows table [flows_cnt] */ member
164 flow = &q->flows[idx]; in fq_codel_drop()
204 flow = &q->flows[idx]; in fq_codel_enqueue()
265 q->backlogs[flow - q->flows] -= qdisc_pkt_len(skb); in dequeue_func()
343 struct fq_codel_flow *flow = q->flows + i; in fq_codel_reset()
380 if (q->flows) in fq_codel_change()
456 kvfree(q->flows); in fq_codel_destroy()
488 if (!q->flows) { in fq_codel_init()
489 q->flows = kvcalloc(q->flows_cnt, in fq_codel_init()
492 if (!q->flows) { in fq_codel_init()
[all …]
|
| D | sch_fq_pie.c | 57 struct fq_pie_flow *flows; member
149 sel_flow = &q->flows[idx]; in fq_pie_qdisc_enqueue()
298 if (q->flows) { in fq_pie_change()
380 pie_calculate_probability(&q->p_params, &q->flows[idx].vars, in fq_pie_timer()
381 q->flows[idx].backlog); in fq_pie_timer()
421 q->flows = kvcalloc(q->flows_cnt, sizeof(struct fq_pie_flow), in fq_pie_init()
423 if (!q->flows) { in fq_pie_init()
428 struct fq_pie_flow *flow = q->flows + idx; in fq_pie_init()
512 struct fq_pie_flow *flow = q->flows + idx; in fq_pie_reset()
530 kvfree(q->flows); in fq_pie_destroy()
|
| D | sch_atm.c | 66 struct list_head flows; /* NB: "link" is also on this member
78 list_for_each_entry(flow, &p->flows, list) { in lookup_flow()
356 list_for_each_entry(flow, &p->flows, list) { in atm_tc_walk()
390 list_for_each_entry(flow, &p->flows, list) { in atm_tc_enqueue()
474 list_for_each_entry(flow, &p->flows, list) { in sch_atm_dequeue()
545 INIT_LIST_HEAD(&p->flows); in atm_tc_init()
548 list_add(&p->link.list, &p->flows); in atm_tc_init()
574 list_for_each_entry(flow, &p->flows, list) in atm_tc_reset()
584 list_for_each_entry(flow, &p->flows, list) { in atm_tc_destroy()
589 list_for_each_entry_safe(flow, tmp, &p->flows, list) { in atm_tc_destroy()
|
| D | sch_fq.c | 120 u32 flows; member
254 q->flows -= fcnt; in fq_gc()
304 if (q->flows >= (2U << q->fq_trees_log) && in fq_classify()
305 q->inactive_flows > q->flows/2) in fq_classify()
359 q->flows++; in fq_classify()
692 q->flows = 0; in fq_reset()
737 q->flows -= fcnt; in fq_rehash()
1020 st.flows = q->flows; in fq_dump_stats()
|
| D | sch_cake.c | 150 struct cake_flow flows[CAKE_QUEUES]; member
743 q->flows[reduced_hash].set)) { in cake_hash()
761 if (!q->flows[outer_hash + k].set) { in cake_hash()
776 if (!q->flows[outer_hash + k].set) { in cake_hash()
788 if (q->flows[outer_hash + k].set == CAKE_SET_BULK) { in cake_hash()
789 q->hosts[q->flows[reduced_hash].srchost].srchost_bulk_flow_count--; in cake_hash()
790 q->hosts[q->flows[reduced_hash].dsthost].dsthost_bulk_flow_count--; in cake_hash()
817 if (q->flows[reduced_hash].set == CAKE_SET_BULK) in cake_hash()
819 q->flows[reduced_hash].srchost = srchost_idx; in cake_hash()
840 if (q->flows[reduced_hash].set == CAKE_SET_BULK) in cake_hash()
[all …]
|
| /Linux-v6.1/drivers/dma/ti/ |
| D | k3-udma-glue.c | 83 struct k3_udma_glue_rx_flow *flows; member
641 struct k3_udma_glue_rx_flow *flow = &rx_chn->flows[flow_num]; in k3_udma_glue_release_rx_flow()
661 struct k3_udma_glue_rx_flow *flow = &rx_chn->flows[flow_idx]; in k3_udma_glue_cfg_rx_flow()
958 rx_chn->flows = devm_kcalloc(dev, rx_chn->flow_num, in k3_udma_glue_request_rx_chn_priv()
959 sizeof(*rx_chn->flows), GFP_KERNEL); in k3_udma_glue_request_rx_chn_priv()
960 if (!rx_chn->flows) { in k3_udma_glue_request_rx_chn_priv()
970 rx_chn->flows[i].udma_rflow_id = rx_chn->flow_id_base + i; in k3_udma_glue_request_rx_chn_priv()
1039 rx_chn->flows = devm_kcalloc(dev, rx_chn->flow_num, in k3_udma_glue_request_remote_rx_chn()
1040 sizeof(*rx_chn->flows), GFP_KERNEL); in k3_udma_glue_request_remote_rx_chn()
1041 if (!rx_chn->flows) { in k3_udma_glue_request_remote_rx_chn()
[all …]
|
| /Linux-v6.1/drivers/media/platform/amphion/ |
| D | vpu_dbg.c | 186 for (i = 0; i < ARRAY_SIZE(inst->flows); i++) { in vpu_dbg_instance()
187 u32 idx = (inst->flow_idx + i) % (ARRAY_SIZE(inst->flows)); in vpu_dbg_instance()
189 if (!inst->flows[idx]) in vpu_dbg_instance()
192 inst->flows[idx] >= VPU_MSG_ID_NOOP ? "M" : "C", in vpu_dbg_instance()
193 inst->flows[idx]); in vpu_dbg_instance()
485 inst->flows[inst->flow_idx] = flow; in vpu_inst_record_flow()
486 inst->flow_idx = (inst->flow_idx + 1) % (ARRAY_SIZE(inst->flows)); in vpu_inst_record_flow()
|
| /Linux-v6.1/drivers/infiniband/hw/hfi1/ |
| D | tid_rdma.c | 757 u32 generation = rcd->flows[flow_idx].generation; in kern_setup_hw_flow()
775 rcd->flows[flow_idx].generation = in kern_clear_hw_flow()
776 kern_flow_generation_next(rcd->flows[flow_idx].generation); in kern_clear_hw_flow()
804 rcd->flows[fs->index].generation = fs->generation; in hfi1_kern_setup_hw_flow()
853 rcd->flows[i].generation = mask_generation(get_random_u32()); in hfi1_kern_init_ctxt_generations()
1465 struct tid_rdma_flow *flow = &req->flows[req->setup_head]; in hfi1_kern_exp_rcv_setup()
1556 struct tid_rdma_flow *flow = &req->flows[req->clear_tail]; in hfi1_kern_exp_rcv_clear()
1612 kfree(req->flows); in hfi1_kern_exp_rcv_free_flows()
1613 req->flows = NULL; in hfi1_kern_exp_rcv_free_flows()
1634 struct tid_rdma_flow *flows; in hfi1_kern_exp_rcv_alloc_flows() local
[all …]
|
| /Linux-v6.1/Documentation/networking/ |
| D | nf_flowtable.rst | 33 specifies what flows are placed into the flowtable. Hence, packets follow the
34 classic IP forwarding path unless the user explicitly instruct flows to use this
111 You can identify offloaded flows through the [OFFLOAD] tag when listing your
130 instead the real device is sufficient for the flowtable to track your flows.
198 There is a workqueue that adds the flows to the hardware. Note that a few
202 You can identify hardware offloaded flows through the [HW_OFFLOAD] tag when
|
| D | scaling.rst | 31 of logical flows. Packets for each flow are steered to a separate receive
188 to the same CPU is CPU load imbalance if flows vary in packet rate.
194 Flow Limit is an optional RPS feature that prioritizes small flows
195 during CPU contention by dropping packets from large flows slightly
196 ahead of those from small flows. It is active only when an RPS or RFS
202 new packet is dropped. Packets from other flows are still only
206 even large flows maintain connectivity.
224 identification of large flows and fewer false positives. The default
261 flows to the CPUs where those flows are being processed. The flow hash
266 same CPU. Indeed, with many flows and few CPUs, it is very likely that
[all …]
|
| D | openvswitch.rst | 16 table" that userspace populates with "flows" that map from keys based
104 A wildcarded flow can represent a group of exact match flows. Each '1' bit
108 by reduce the number of new flows need to be processed by the user space program.
120 two possible approaches: reactively install flows as they miss the kernel
130 The behavior when using overlapping wildcarded flows is undefined. It is the
133 performs best-effort detection of overlapping wildcarded flows and may reject
146 future operations. The kernel is not required to index flows by the original
|
| /Linux-v6.1/Documentation/admin-guide/pm/ |
| D | system-wide.rst | 11 suspend-flows
|
| /Linux-v6.1/drivers/net/ethernet/mellanox/mlx5/core/ |
| D | en_rep.h | 177 struct list_head flows; member
202 struct list_head flows; member
|
| D | eswitch_offloads.c | 1220 struct mlx5_flow_handle **flows; in esw_add_fdb_peer_miss_rules() local
1236 flows = kvcalloc(nvports, sizeof(*flows), GFP_KERNEL); in esw_add_fdb_peer_miss_rules()
1237 if (!flows) { in esw_add_fdb_peer_miss_rules()
1257 flows[vport->index] = flow; in esw_add_fdb_peer_miss_rules()
1269 flows[vport->index] = flow; in esw_add_fdb_peer_miss_rules()
1283 flows[vport->index] = flow; in esw_add_fdb_peer_miss_rules()
1286 esw->fdb_table.offloads.peer_miss_rules = flows; in esw_add_fdb_peer_miss_rules()
1293 if (!flows[vport->index]) in esw_add_fdb_peer_miss_rules()
1295 mlx5_del_flow_rules(flows[vport->index]); in esw_add_fdb_peer_miss_rules()
1299 mlx5_del_flow_rules(flows[vport->index]); in esw_add_fdb_peer_miss_rules()
[all …]
|
| /Linux-v6.1/Documentation/userspace-api/media/mediactl/ |
| D | media-controller-model.rst | 26 by an entity flows from the entity's output to one or more entity
31 pads, either on the same entity or on different entities. Data flows
|
| /Linux-v6.1/net/core/ |
| D | pktgen.c | 415 struct flow_state *flows; member
2310 return !!(pkt_dev->flows[flow].flags & F_INIT); in f_seen()
2318 if (pkt_dev->flows[flow].count >= pkt_dev->lflow) { in f_pick()
2320 pkt_dev->flows[flow].count = 0; in f_pick()
2321 pkt_dev->flows[flow].flags = 0; in f_pick()
2330 if (pkt_dev->flows[flow].count > pkt_dev->lflow) { in f_pick()
2331 pkt_dev->flows[flow].count = 0; in f_pick()
2332 pkt_dev->flows[flow].flags = 0; in f_pick()
2347 struct xfrm_state *x = pkt_dev->flows[flow].x; in get_ipsec_sa()
2366 pkt_dev->flows[flow].x = x; in get_ipsec_sa()
[all …]
|
| /Linux-v6.1/Documentation/admin-guide/blockdev/drbd/ |
| D | figures.rst | 5 Data flows that Relate some functions, and write packets
|
| /Linux-v6.1/drivers/net/ethernet/mellanox/mlx5/core/en/ |
| D | tc_tun_encap.c | 284 list_for_each_entry(efi, &e->flows, list) { in mlx5e_take_all_encap_flows()
405 list_for_each_entry_safe(efi, tmp, &e->flows, list) { in mlx5e_tc_update_neigh_used_value()
450 WARN_ON(!list_empty(&e->flows)); in mlx5e_encap_dealloc()
467 WARN_ON(!list_empty(&d->flows)); in mlx5e_decap_dealloc()
839 INIT_LIST_HEAD(&e->flows); in mlx5e_attach_encap()
876 list_add(&flow->encaps[out_index].list, &e->flows); in mlx5e_attach_encap()
944 INIT_LIST_HEAD(&d->flows); in mlx5e_attach_decap()
967 list_add(&flow->l3_to_l2_reformat, &d->flows); in mlx5e_attach_decap()
|
