Home
last modified time | relevance | path

Searched refs:fs (Results 1 – 23 of 23) sorted by relevance

/dpdk/drivers/net/cxgbe/
H A Dcxgbe_flow.c10 if ((fs)->mask.elem && ((fs)->val.elem != (__v))) \
113 fs->cap = 0; in cxgbe_fill_filter_region()
141 if (!fs->val.lport || fs->mask.lport != 0xffff) in cxgbe_fill_filter_region()
143 if (!fs->val.fport || fs->mask.fport != 0xffff) in cxgbe_fill_filter_region()
529 struct ch_filter_specification fs = f->fs; in cxgbe_validate_fidxondel() local
579 struct ch_filter_specification *fs = &flow->fs; in cxgbe_get_fidx() local
861 struct ch_filter_specification *fs = &flow->fs; in cxgbe_rtef_parse_actions() local
1113 struct ch_filter_specification *fs = &flow->fs; in __cxgbe_flow_create() local
1211 fs = &f->fs; in __cxgbe_flow_destroy()
1261 struct ch_filter_specification fs = flow->f->fs; in __cxgbe_flow_query() local
[all …]
H A Dcxgbe_filter.c76 (fs->val._field || fs->mask._field) in cxgbe_validate_filter()
350 f->fs.val.pf << 13 | f->fs.val.vf) << in hash_filter_ntuple()
620 f->fs = *fs; in cxgbe_set_hash_filter()
647 f->fs.eport, f->fs.dmac); in cxgbe_set_hash_filter()
1078 f->fs = *fs; in cxgbe_set_filter()
1109 if (f->fs.newvlan || f->fs.newdmac) { in cxgbe_set_filter()
1111 f->fs.eport, f->fs.dmac); in cxgbe_set_filter()
1137 f->fs.val.ovlan = fs->val.pf << 13 | fs->val.vf; in cxgbe_set_filter()
1138 f->fs.mask.ovlan = fs->mask.pf << 13 | fs->mask.vf; in cxgbe_set_filter()
1139 f->fs.val.ovlan_vld = fs->val.pfvf_vld; in cxgbe_set_filter()
[all …]
H A Dcxgbe_filter.h198 struct ch_filter_specification fs; member
261 struct ch_filter_specification *fs,
264 struct ch_filter_specification *fs,
273 struct ch_filter_specification *fs);
H A Dcxgbe_flow.h20 struct ch_filter_specification *fs, /* where to parse */
27 struct ch_filter_specification fs; /* temp, to create filter */ member
/dpdk/app/test-pmd/
H A Dnoisy_vnf.c97 struct fwd_stream *fs) in do_retry() argument
103 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in do_retry()
155 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, in pkt_burst_noisy_vnf()
157 inc_rx_burst_stats(fs, nb_rx); in pkt_burst_noisy_vnf()
160 fs->rx_packets += nb_rx; in pkt_burst_noisy_vnf()
164 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_noisy_vnf()
168 inc_tx_burst_stats(fs, nb_tx); in pkt_burst_noisy_vnf()
169 fs->tx_packets += nb_tx; in pkt_burst_noisy_vnf()
188 fs->tx_queue, tmp_pkts, in pkt_burst_noisy_vnf()
213 sent = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_noisy_vnf()
[all …]
H A Dmacswap.c52 pkt_burst_mac_swap(struct fwd_stream *fs) in pkt_burst_mac_swap() argument
66 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_mac_swap()
68 inc_rx_burst_stats(fs, nb_rx); in pkt_burst_mac_swap()
72 fs->rx_packets += nb_rx; in pkt_burst_mac_swap()
73 txp = &ports[fs->tx_port]; in pkt_burst_mac_swap()
77 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx); in pkt_burst_mac_swap()
85 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_mac_swap()
89 fs->tx_packets += nb_tx; in pkt_burst_mac_swap()
90 inc_tx_burst_stats(fs, nb_tx); in pkt_burst_mac_swap()
92 fs->fwd_dropped += (nb_rx - nb_tx); in pkt_burst_mac_swap()
[all …]
H A Diofwd.c46 pkt_burst_io_forward(struct fwd_stream *fs) in pkt_burst_io_forward() argument
59 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, in pkt_burst_io_forward()
61 inc_rx_burst_stats(fs, nb_rx); in pkt_burst_io_forward()
64 fs->rx_packets += nb_rx; in pkt_burst_io_forward()
66 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_io_forward()
71 if (unlikely(nb_tx < nb_rx) && fs->retry_enabled) { in pkt_burst_io_forward()
75 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_io_forward()
79 fs->tx_packets += nb_tx; in pkt_burst_io_forward()
80 inc_tx_burst_stats(fs, nb_tx); in pkt_burst_io_forward()
82 fs->fwd_dropped += (nb_rx - nb_tx); in pkt_burst_io_forward()
[all …]
H A Dmacfwd.c46 pkt_burst_mac_forward(struct fwd_stream *fs) in pkt_burst_mac_forward() argument
65 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_mac_forward()
67 inc_rx_burst_stats(fs, nb_rx); in pkt_burst_mac_forward()
71 fs->rx_packets += nb_rx; in pkt_burst_mac_forward()
72 txp = &ports[fs->tx_port]; in pkt_burst_mac_forward()
97 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx); in pkt_burst_mac_forward()
105 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_mac_forward()
110 fs->tx_packets += nb_tx; in pkt_burst_mac_forward()
111 inc_tx_burst_stats(fs, nb_tx); in pkt_burst_mac_forward()
113 fs->fwd_dropped += (nb_rx - nb_tx); in pkt_burst_mac_forward()
[all …]
H A Dieee1588fwd.c105 if (rte_eth_rx_burst(fs->rx_port, fs->rx_queue, &mb, 1) == 0) in ieee1588_packet_fwd()
108 fs->rx_packets += 1; in ieee1588_packet_fwd()
121 fs->rx_port); in ieee1588_packet_fwd()
125 fs->rx_port, eth_type, in ieee1588_packet_fwd()
134 fs->rx_port); in ieee1588_packet_fwd()
155 fs->rx_port, ptp_hdr->msg_id); in ieee1588_packet_fwd()
160 fs->rx_port); in ieee1588_packet_fwd()
169 fs->rx_port); in ieee1588_packet_fwd()
187 fs->tx_packets += 1; in ieee1588_packet_fwd()
188 if (rte_eth_tx_burst(fs->rx_port, fs->tx_queue, &mb, 1) == 0) { in ieee1588_packet_fwd()
[all …]
H A Dshared_rxq_fwd.c30 fc = fs->lcore; in forward_stream_get()
35 fsm[sm_id]->rx_queue == fs->rx_queue) in forward_stream_get()
50 if (fs != NULL) { in forward_sub_burst()
51 fs->rx_packets += nb_rx; in forward_sub_burst()
80 forward_sub_burst(fs, last_port, nb_sub_burst, in forward_shared_rxq()
89 forward_sub_burst(fs, last_port, nb_sub_burst, in forward_shared_rxq()
94 shared_rxq_fwd(struct fwd_stream *fs) in shared_rxq_fwd() argument
101 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in shared_rxq_fwd()
103 inc_rx_burst_stats(fs, nb_rx); in shared_rxq_fwd()
106 forward_shared_rxq(fs, nb_rx, pkts_burst); in shared_rxq_fwd()
[all …]
H A Dflowgen.c63 pkt_burst_flow_gen(struct fwd_stream *fs) in pkt_burst_flow_gen() argument
88 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_flow_gen()
90 inc_rx_burst_stats(fs, nb_rx); in pkt_burst_flow_gen()
91 fs->rx_packets += nb_rx; in pkt_burst_flow_gen()
97 vlan_tci = ports[fs->tx_port].tx_vlan_id; in pkt_burst_flow_gen()
170 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_pkt); in pkt_burst_flow_gen()
178 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_flow_gen()
182 fs->tx_packets += nb_tx; in pkt_burst_flow_gen()
184 inc_tx_burst_stats(fs, nb_tx); in pkt_burst_flow_gen()
192 fs->fwd_dropped += nb_dropped; in pkt_burst_flow_gen()
[all …]
H A D5tswap.c85 pkt_burst_5tuple_swap(struct fwd_stream *fs) in pkt_burst_5tuple_swap() argument
115 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_5tuple_swap()
117 inc_rx_burst_stats(fs, nb_rx); in pkt_burst_5tuple_swap()
121 fs->rx_packets += nb_rx; in pkt_burst_5tuple_swap()
122 txp = &ports[fs->tx_port]; in pkt_burst_5tuple_swap()
165 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_rx); in pkt_burst_5tuple_swap()
173 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_5tuple_swap()
177 fs->tx_packets += nb_tx; in pkt_burst_5tuple_swap()
178 inc_tx_burst_stats(fs, nb_tx); in pkt_burst_5tuple_swap()
180 fs->fwd_dropped += (nb_rx - nb_tx); in pkt_burst_5tuple_swap()
[all …]
H A Dtxonly.c275 fs->tx_port); in pkt_burst_prepare()
287 fs->ts_skew = skew; in pkt_burst_prepare()
297 fs->ts_skew = skew; in pkt_burst_prepare()
304 fs->ts_skew = skew; in pkt_burst_prepare()
346 txp = &ports[fs->tx_port]; in pkt_burst_transmit()
371 nb_pkt, fs))) { in pkt_burst_transmit()
387 nb_pkt, fs))) { in pkt_burst_transmit()
398 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, nb_pkt); in pkt_burst_transmit()
407 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_transmit()
411 fs->tx_packets += nb_tx; in pkt_burst_transmit()
[all …]
H A Dicmpecho.c273 reply_to_icmp_echo_rqsts(struct fwd_stream *fs) in reply_to_icmp_echo_rqsts() argument
302 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in reply_to_icmp_echo_rqsts()
304 inc_rx_burst_stats(fs, nb_rx); in reply_to_icmp_echo_rqsts()
308 fs->rx_packets += nb_rx; in reply_to_icmp_echo_rqsts()
486 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, pkts_burst, in reply_to_icmp_echo_rqsts()
496 nb_tx += rte_eth_tx_burst(fs->tx_port, in reply_to_icmp_echo_rqsts()
497 fs->tx_queue, in reply_to_icmp_echo_rqsts()
502 fs->tx_packets += nb_tx; in reply_to_icmp_echo_rqsts()
503 inc_tx_burst_stats(fs, nb_tx); in reply_to_icmp_echo_rqsts()
505 fs->fwd_dropped += (nb_replies - nb_tx); in reply_to_icmp_echo_rqsts()
[all …]
H A Drxonly.c46 pkt_burst_receive(struct fwd_stream *fs) in pkt_burst_receive() argument
58 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_receive()
60 inc_rx_burst_stats(fs, nb_rx); in pkt_burst_receive()
64 fs->rx_packets += nb_rx; in pkt_burst_receive()
68 get_end_cycles(fs, start_tsc); in pkt_burst_receive()
H A Dcsumonly.c846 nb_rx = rte_eth_rx_burst(fs->rx_port, fs->rx_queue, pkts_burst, in pkt_burst_checksum_forward()
848 inc_rx_burst_stats(fs, nb_rx); in pkt_burst_checksum_forward()
852 fs->rx_packets += nb_rx; in pkt_burst_checksum_forward()
861 txp = &ports[fs->tx_port]; in pkt_burst_checksum_forward()
1102 fs->gro_times = 0; in pkt_burst_checksum_forward()
1142 nb_prep = rte_eth_tx_prepare(fs->tx_port, fs->tx_queue, in pkt_burst_checksum_forward()
1149 nb_tx = rte_eth_tx_burst(fs->tx_port, fs->tx_queue, tx_pkts_burst, in pkt_burst_checksum_forward()
1159 nb_tx += rte_eth_tx_burst(fs->tx_port, fs->tx_queue, in pkt_burst_checksum_forward()
1163 fs->tx_packets += nb_tx; in pkt_burst_checksum_forward()
1169 inc_tx_burst_stats(fs, nb_tx); in pkt_burst_checksum_forward()
[all …]
H A Dtestpmd.c1931 if ((fs->rx_packets == 0) && (fs->tx_packets == 0) && in fwd_stream_stats_display()
1936 fwd_top_stats_border, fs->rx_port, fs->rx_queue, in fwd_stream_stats_display()
1937 fs->tx_port, fs->tx_queue, fwd_top_stats_border); in fwd_stream_stats_display()
1940 fs->rx_packets, fs->tx_packets, fs->fwd_dropped); in fwd_stream_stats_display()
1947 fs->rx_bad_ip_csum, fs->rx_bad_l4_csum, in fwd_stream_stats_display()
1997 ports_stats[fs->tx_port].tx_stream = fs; in fwd_stats_display()
1998 ports_stats[fs->rx_port].rx_stream = fs; in fwd_stats_display()
2001 ports_stats[fs->tx_port].tx_dropped += fs->fwd_dropped; in fwd_stats_display()
2003 ports_stats[fs->rx_port].rx_bad_ip_csum += fs->rx_bad_ip_csum; in fwd_stats_display()
2140 memset(&fs->rx_burst_stats, 0, sizeof(fs->rx_burst_stats)); in fwd_stats_reset()
[all …]
H A Dconfig.c3890 lc_id, fs->rx_port, fs->rx_queue); in fwd_stream_on_other_lcores()
4109 fs->rx_queue = rxq; in rss_fwd_config_setup()
4111 fs->tx_queue = rxq; in rss_fwd_config_setup()
4112 fs->peer_addr = fs->tx_port; in rss_fwd_config_setup()
4227 fs->peer_addr = fs->tx_port; in dcb_fwd_config_setup()
4295 fs->rx_queue = rxq; in icmp_echo_config_setup()
4296 fs->tx_port = fs->rx_port; in icmp_echo_config_setup()
4298 fs->peer_addr = fs->tx_port; in icmp_echo_config_setup()
4302 sm_id, fs->rx_port, fs->rx_queue, in icmp_echo_config_setup()
4398 fs->rx_port, fs->rx_queue, in pkt_fwd_config_display()
[all …]
H A Dtestpmd.h326 typedef void (*packet_fwd_t)(struct fwd_stream *fs);
843 get_end_cycles(struct fwd_stream *fs, uint64_t start_tsc) in get_end_cycles() argument
846 fs->core_cycles += rte_rdtsc() - start_tsc; in get_end_cycles()
850 inc_rx_burst_stats(struct fwd_stream *fs, uint16_t nb_rx) in inc_rx_burst_stats() argument
853 fs->rx_burst_stats.pkt_burst_spread[nb_rx]++; in inc_rx_burst_stats()
857 inc_tx_burst_stats(struct fwd_stream *fs, uint16_t nb_tx) in inc_tx_burst_stats() argument
860 fs->tx_burst_stats.pkt_burst_spread[nb_tx]++; in inc_tx_burst_stats()
/dpdk/examples/ntb/
H A Dntb_fwd.c425 struct ntb_fwd_stream fs; in start_iofwd_per_lcore() local
436 if (fs.tx_ntb) { in start_iofwd_per_lcore()
438 fs.qp_id, pkts_burst, in start_iofwd_per_lcore()
446 (void *)(size_t)fs.qp_id); in start_iofwd_per_lcore()
460 (void *)(size_t)fs.qp_id); in start_iofwd_per_lcore()
496 struct ntb_fwd_stream fs; in start_rxonly_per_lcore() local
537 struct ntb_fwd_stream fs; in start_txonly_per_lcore() local
665 struct ntb_fwd_stream *fs; in assign_stream_to_lcores() local
712 fs->tx_ntb ? "Eth" : "NTB", fs->rx_port, in assign_stream_to_lcores()
713 fs->tx_ntb ? "NTB" : "Eth", fs->tx_port, in assign_stream_to_lcores()
[all …]
/dpdk/
H A Dmeson.build21 if meson.version().version_compare('>=0.53') # fs module available
22 fs = import('fs') variable
23 developer_mode = fs.is_dir('.git')
/dpdk/doc/guides/cryptodevs/
H A Dbcmfs.rst80 */sys/bus/platform/devices/fs<version>/<dev_name>* path on the booted kernel.
/dpdk/doc/guides/prog_guide/
H A Denv_abstraction_layer.rst808 mkdir /sys/fs/cgroup/cpu/pkt_io
809 mkdir /sys/fs/cgroup/cpuset/pkt_io
811 echo $cpu > /sys/fs/cgroup/cpuset/cpuset.cpus
813 echo $t0 > /sys/fs/cgroup/cpu/pkt_io/tasks
814 echo $t0 > /sys/fs/cgroup/cpuset/pkt_io/tasks
816 echo $t1 > /sys/fs/cgroup/cpu/pkt_io/tasks
817 echo $t1 > /sys/fs/cgroup/cpuset/pkt_io/tasks
819 cd /sys/fs/cgroup/cpu/pkt_io