Home
last modified time | relevance | path

Searched refs:flows (Results 1 – 25 of 68) sorted by relevance

123

/linux/include/net/
H A Dfq_impl.h36 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()
361 fq->flows = kvzalloc_objs(fq->flows[0], fq->flows_cnt); in fq_init()
362 if (!fq->flows) in fq_init()
367 kvfree(fq->flows); in fq_init()
368 fq->flows = NULL; in fq_init()
373 fq_flow_init(&fq->flows[i]); in fq_init()
384 fq_flow_reset(fq, &fq->flows[i], free_func); in fq_reset()
[all …]
H A Dfq.h57 u32 flows; member
69 struct fq_flow *flows; member
/linux/samples/bpf/
H A Ddo_hbm_test.sh18 echo " [-f=<#flows>|--flows=<#flows>] [-h] [-i=<id>|--id=<id >]"
34 echo " -f or --flows number of concurrent flows (default=1)"
38 echo " -l do not limit flows using loopback"
78 flows=1
150 -f=*|--flows=*)
151 flows="${i#*=}"
278 while [ $flow_cnt -le $flows ] ; d
[all...]
/linux/net/sched/
H A Dsch_fq_codel.c53 struct fq_codel_flow *flows; /* Flows table [flows_cnt] */ member
164 flow = &q->flows[idx]; in fq_codel_drop()
205 flow = &q->flows[idx]; in fq_codel_enqueue()
266 q->backlogs[flow - q->flows] -= qdisc_pkt_len(skb); in dequeue_func()
342 struct fq_codel_flow *flow = q->flows + i; in fq_codel_reset()
380 if (q->flows) in fq_codel_change()
466 kvfree(q->flows); in fq_codel_destroy()
498 if (!q->flows) { in fq_codel_init()
499 q->flows = kvzalloc_objs(struct fq_codel_flow, q->flows_cnt); in fq_codel_init()
500 if (!q->flows) { in fq_codel_init()
[all …]
H A Dsch_fq_pie.c58 struct fq_pie_flow *flows; member
152 sel_flow = &q->flows[idx]; in fq_pie_qdisc_enqueue()
307 if (q->flows) { in fq_pie_change()
403 &q->flows[q->flows_cursor].vars, in fq_pie_timer()
404 q->flows[q->flows_cursor].backlog); in fq_pie_timer()
451 q->flows = kvzalloc_objs(struct fq_pie_flow, q->flows_cnt); in fq_pie_init()
452 if (!q->flows) { in fq_pie_init()
457 struct fq_pie_flow *flow = q->flows + idx; in fq_pie_init()
542 struct fq_pie_flow *flow = q->flows + idx; in fq_pie_reset()
560 kvfree(q->flows); in fq_pie_destroy()
H A Dsch_cake.c152 struct cake_flow flows[CAKE_QUEUES]; member
800 q->flows[reduced_hash].set)) { in cake_hash()
818 if (!q->flows[outer_hash + k].set) { in cake_hash()
833 if (!q->flows[outer_hash + k].set) { in cake_hash()
848 if (q->flows[outer_hash + k].set == CAKE_SET_BULK) { in cake_hash()
849 cake_dec_srchost_bulk_flow_count(q, &q->flows[outer_hash + k], flow_mode); in cake_hash()
850 cake_dec_dsthost_bulk_flow_count(q, &q->flows[outer_hash + k], flow_mode); in cake_hash()
875 q->flows[reduced_hash].srchost = srchost_idx; in cake_hash()
877 if (q->flows[reduced_hash].set == CAKE_SET_BULK) in cake_hash()
878 cake_inc_srchost_bulk_flow_count(q, &q->flows[reduced_hash], flow_mode); in cake_hash()
[all …]
H A Dsch_fq.c143 u32 flows; member
295 q->flows -= fcnt; in fq_gc()
325 if (q->flows != q->inactive_flows + q->throttled_flows) in fq_fastpath_check()
456 q->flows++; in fq_classify()
833 q->flows = 0; in fq_reset()
878 q->flows -= fcnt; in fq_rehash()
1305 st.flows = q->flows; in fq_dump_stats()
/linux/drivers/crypto/allwinner/sun8i-ss/
H A Dsun8i-ss-prng.c134 reinit_completion(&ss->flows[flow].complete); in sun8i_ss_prng_generate()
135 ss->flows[flow].status = 0; in sun8i_ss_prng_generate()
141 wait_for_completion_interruptible_timeout(&ss->flows[flow].complete, in sun8i_ss_prng_generate()
143 if (ss->flows[flow].status == 0) { in sun8i_ss_prng_generate()
H A Dsun8i-ss-hash.c295 ss->flows[flow].stat_req++; in sun8i_ss_run_hash_task()
328 reinit_completion(&ss->flows[flow].complete); in sun8i_ss_run_hash_task()
329 ss->flows[flow].status = 0; in sun8i_ss_run_hash_task()
334 wait_for_completion_interruptible_timeout(&ss->flows[flow].complete, in sun8i_ss_run_hash_task()
336 if (ss->flows[flow].status == 0) { in sun8i_ss_run_hash_task()
412 engine = ss->flows[e].engine; in sun8i_ss_hash_digest()
511 result = ss->flows[rctx->flow].result; in sun8i_ss_hash_run()
512 pad = ss->flows[rctx->flow].pad; in sun8i_ss_hash_run()
/linux/drivers/infiniband/hw/hfi1/
H A Dtid_rdma.c757 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/Documentation/networking/
H A Dnf_flowtable.rst33 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
H A Dopenvswitch.rst16 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
H A Dpktgen.rst97 flows: 0 flowlen: 0
112 flows: 0
286 pgset "flows 1"
391 flows
/linux/Documentation/userspace-api/media/mediactl/
H A Dmedia-controller-model.rst26 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/drivers/net/ethernet/mellanox/mlx5/core/
H A Den_rep.h183 struct list_head flows; member
208 struct list_head flows; member
H A Deswitch_offloads.c1189 struct mlx5_flow_handle **flows; in esw_add_fdb_peer_miss_rules() local
1207 flows = kvzalloc_objs(*flows, peer_esw->total_vports); in esw_add_fdb_peer_miss_rules()
1208 if (!flows) { in esw_add_fdb_peer_miss_rules()
1229 flows[peer_vport->index] = flow; in esw_add_fdb_peer_miss_rules()
1241 flows[peer_vport->index] = flow; in esw_add_fdb_peer_miss_rules()
1254 flows[peer_vport->index] = flow; in esw_add_fdb_peer_miss_rules()
1269 flows[peer_vport->index] = flow; in esw_add_fdb_peer_miss_rules()
1280 esw->fdb_table.offloads.peer_miss_rules[pfindex] = flows; in esw_add_fdb_peer_miss_rules()
1288 if (!flows[peer_vport->index]) in esw_add_fdb_peer_miss_rules()
1290 mlx5_del_flow_rules(flows[peer_vport->index]); in esw_add_fdb_peer_miss_rules()
[all …]
/linux/Documentation/admin-guide/pm/
H A Dsystem-wide.rst11 suspend-flows
H A Dsuspend-flows.rst25 The kernel code flows associated with the suspend and resume transitions for
27 significant differences between the :ref:`suspend-to-idle <s2idle>` code flows
28 and the code flows related to the :ref:`suspend-to-RAM <s2ram>` and
35 available. Apart from that, the suspend and resume code flows for these sleep
/linux/Documentation/admin-guide/blockdev/drbd/
H A Dfigures.rst5 Data flows that Relate some functions, and write packets
/linux/net/mctp/test/
H A Droute-test.c987 struct mctp_flow *flows[2]; in mctp_test_packet_flow()
1011 flows[0] = skb_ext_find(tx_skbs[0], SKB_EXT_MCTP); in mctp_test_fragment_flow()
1012 KUNIT_ASSERT_NOT_ERR_OR_NULL(test, flows[0]); in mctp_test_fragment_flow() local
1013 KUNIT_ASSERT_NOT_ERR_OR_NULL(test, flows[0]->key); in mctp_test_fragment_flow()
1014 KUNIT_ASSERT_PTR_EQ(test, flows[0]->key->sk, sock->sk); in mctp_test_fragment_flow()
1016 flows[1] = skb_ext_find(tx_skbs[1], SKB_EXT_MCTP); in mctp_test_fragment_flow()
1017 KUNIT_ASSERT_NOT_ERR_OR_NULL(test, flows[1]); in mctp_test_fragment_flow()
1018 KUNIT_ASSERT_PTR_EQ(test, flows[1]->key, flows[0]->key); in mctp_test_fragment_flow()
/linux/drivers/net/ethernet/ti/
H A Dam65-cpsw-nuss.c515 flow = &rx_chn->flows[id]; in am65_cpsw_destroy_rxq()
575 flow = &rx_chn->flows[id]; in am65_cpsw_create_rxq()
791 am65_cpsw_put_page(&rx_chn->flows[flow_id], page, false); in am65_cpsw_nuss_rx_cleanup()
2358 struct am65_cpsw_rx_flow *flows; in am65_cpsw_nuss_remove_rx_chns() local
2362 flows = rx_chn->flows; in am65_cpsw_nuss_remove_rx_chns()
2365 if (!(flows[i].irq < 0)) in am65_cpsw_nuss_remove_rx_chns()
2366 devm_free_irq(dev, flows[i].irq, &flows[i]); in am65_cpsw_nuss_remove_rx_chns()
2367 netif_napi_del(&flows[i].napi_rx); in am65_cpsw_nuss_remove_rx_chns()
2398 flow = &rx_chn->flows[i]; in am65_cpsw_nuss_init_rx_chns()
2446 flow = &rx_chn->flows[i]; in am65_cpsw_nuss_init_rx_chns()
[all …]
/linux/drivers/net/ethernet/mellanox/mlx5/core/en/
H A Dtc_tun_encap.c300 list_for_each_entry(efi, &e->flows, list) { in mlx5e_take_all_encap_flows()
421 list_for_each_entry_safe(efi, tmp, &e->flows, list) { in mlx5e_tc_update_neigh_used_value()
466 WARN_ON(!list_empty(&e->flows)); in mlx5e_encap_dealloc()
483 WARN_ON(!list_empty(&d->flows)); in mlx5e_decap_dealloc()
889 INIT_LIST_HEAD(&e->flows); in mlx5e_attach_encap()
923 list_add(&flow->encaps[out_index].list, &e->flows); in mlx5e_attach_encap()
988 INIT_LIST_HEAD(&d->flows); in mlx5e_attach_decap()
1011 list_add(&flow->l3_to_l2_reformat, &d->flows); in mlx5e_attach_decap()
/linux/net/ethtool/
H A Drss.c755 struct nlattr *flows[ETHTOOL_A_FLOW_MAX + 1]; in ethnl_set_rss_fields() local
768 ret = nla_parse_nested(flows, ARRAY_SIZE(ethnl_rss_flows_policy) - 1, in ethnl_set_rss_fields()
779 if (!flows[i]) in ethnl_set_rss_fields()
782 fields.data = nla_get_u32(flows[i]); in ethnl_set_rss_fields()
787 NL_SET_ERR_MSG_ATTR(info->extack, flows[i], in ethnl_set_rss_fields()
/linux/drivers/cache/
H A DKconfig40 These drivers implement cache management for flows where it is necessary
/linux/net/dccp/ccids/
H A DKconfig

123