net/hw/iou-zcrx.py

11 def _get_current_settings(cfg):
12     output = ethtool(f"-g {cfg.ifname}", json=True)[0]
16 def _get_combined_channels(cfg):
17     output = ethtool(f"-l {cfg.ifname}").stdout
22 def _create_rss_ctx(cfg, chan):
23     output = ethtool(f"-X {cfg.ifname} context new start {chan} equal 1").stdout
26     return (ctx_id, defer(ethtool, f"-X {cfg.ifname} delete context {ctx_id}"))
29 def _set_flow_rule(cfg, port, chan):
30     output = ethtool(f"-N {cfg.ifname} flow-type tcp6 dst-port {port} action {chan}").stdout
35 def _set_flow_rule_rss(cfg, port, ctx_id):
36     output = ethtool(f"-N {cfg.ifname} flow-type tcp6 dst-port {port} context {ctx_id}").stdout
41 def test_zcrx(cfg) -> None:
42     cfg.require_ipver('6')
44     combined_chans = _get_combined_channels(cfg)
47     (rx_ring, hds_thresh) = _get_current_settings(cfg)
50     ethtool(f"-G {cfg.ifname} tcp-data-split on")
51     defer(ethtool, f"-G {cfg.ifname} tcp-data-split auto")
53     ethtool(f"-G {cfg.ifname} hds-thresh 0")
54     defer(ethtool, f"-G {cfg.ifname} hds-thresh {hds_thresh}")
56     ethtool(f"-G {cfg.ifname} rx 64")
57     defer(ethtool, f"-G {cfg.ifname} rx {rx_ring}")
59     ethtool(f"-X {cfg.ifname} equal {combined_chans - 1}")
60     defer(ethtool, f"-X {cfg.ifname} default")
62     flow_rule_id = _set_flow_rule(cfg, port, combined_chans - 1)
63     defer(ethtool, f"-N {cfg.ifname} delete {flow_rule_id}")
65     rx_cmd = f"{cfg.bin_local} -s -p {port} -i {cfg.ifname} -q {combined_chans - 1}"
66     tx_cmd = f"{cfg.bin_remote} -c -h {cfg.addr_v['6']} -p {port} -l 12840"
69         cmd(tx_cmd, host=cfg.remote)
72 def test_zcrx_oneshot(cfg) -> None:
73     cfg.require_ipver('6')
75     combined_chans = _get_combined_channels(cfg)
78     (rx_ring, hds_thresh) = _get_current_settings(cfg)
81     ethtool(f"-G {cfg.ifname} tcp-data-split on")
82     defer(ethtool, f"-G {cfg.ifname} tcp-data-split auto")
84     ethtool(f"-G {cfg.ifname} hds-thresh 0")
85     defer(ethtool, f"-G {cfg.ifname} hds-thresh {hds_thresh}")
87     ethtool(f"-G {cfg.ifname} rx 64")
88     defer(ethtool, f"-G {cfg.ifname} rx {rx_ring}")
90     ethtool(f"-X {cfg.ifname} equal {combined_chans - 1}")
91     defer(ethtool, f"-X {cfg.ifname} default")
93     flow_rule_id = _set_flow_rule(cfg, port, combined_chans - 1)
94     defer(ethtool, f"-N {cfg.ifname} delete {flow_rule_id}")
96     rx_cmd = f"{cfg.bin_local} -s -p {port} -i {cfg.ifname} -q {combined_chans - 1} -o 4"
97     tx_cmd = f"{cfg.bin_remote} -c -h {cfg.addr_v['6']} -p {port} -l 4096 -z 16384"
100         cmd(tx_cmd, host=cfg.remote)
103 def test_zcrx_rss(cfg) -> None:
104     cfg.require_ipver('6')
106     combined_chans = _get_combined_channels(cfg)
109     (rx_ring, hds_thresh) = _get_current_settings(cfg)
112     ethtool(f"-G {cfg.ifname} tcp-data-split on")
113     defer(ethtool, f"-G {cfg.ifname} tcp-data-split auto")
115     ethtool(f"-G {cfg.ifname} hds-thresh 0")
116     defer(ethtool, f"-G {cfg.ifname} hds-thresh {hds_thresh}")
118     ethtool(f"-G {cfg.ifname} rx 64")
119     defer(ethtool, f"-G {cfg.ifname} rx {rx_ring}")
121     ethtool(f"-X {cfg.ifname} equal {combined_chans - 1}")
122     defer(ethtool, f"-X {cfg.ifname} default")
124     (ctx_id, delete_ctx) = _create_rss_ctx(cfg, combined_chans - 1)
125     flow_rule_id = _set_flow_rule_rss(cfg, port, ctx_id)
126     defer(ethtool, f"-N {cfg.ifname} delete {flow_rule_id}")
128     rx_cmd = f"{cfg.bin_local} -s -p {port} -i {cfg.ifname} -q {combined_chans - 1}"
129     tx_cmd = f"{cfg.bin_remote} -c -h {cfg.addr_v['6']} -p {port} -l 12840"
132         cmd(tx_cmd, host=cfg.remote)
136     with NetDrvEpEnv(__file__) as cfg:
137         cfg.bin_local = path.abspath(path.dirname(__file__) + "/../../../drivers/net/hw/iou-zcrx")
138         cfg.bin_remote = cfg.remote.deploy(cfg.bin_local)
140         ksft_run(globs=globals(), case_pfx={"test_"}, args=(cfg, ))