CoCalc -- iou-zcrx.py

GitHub Repository: torvalds/linux
Path: blob/master/tools/testing/selftests/drivers/net/hw/iou-zcrx.py
²⁶²⁹⁵ views
1
#!/usr/bin/env python3
2
# SPDX-License-Identifier: GPL-2.0
3

4
import re
5
from os import path
6
from lib.py import ksft_run, ksft_exit, KsftSkipEx
7
from lib.py import NetDrvEpEnv
8
from lib.py import bkg, cmd, defer, ethtool, rand_port, wait_port_listen
9

10

11
def _get_current_settings(cfg):
12
    output = ethtool(f"-g {cfg.ifname}", json=True)[0]
13
    return (output['rx'], output['hds-thresh'])
14

15

16
def _get_combined_channels(cfg):
17
    output = ethtool(f"-l {cfg.ifname}").stdout
18
    values = re.findall(r'Combined:\s+(\d+)', output)
19
    return int(values[1])
20

21

22
def _create_rss_ctx(cfg, chan):
23
    output = ethtool(f"-X {cfg.ifname} context new start {chan} equal 1").stdout
24
    values = re.search(r'New RSS context is (\d+)', output).group(1)
25
    ctx_id = int(values)
26
    return (ctx_id, defer(ethtool, f"-X {cfg.ifname} delete context {ctx_id}"))
27

28

29
def _set_flow_rule(cfg, port, chan):
30
    output = ethtool(f"-N {cfg.ifname} flow-type tcp6 dst-port {port} action {chan}").stdout
31
    values = re.search(r'ID (\d+)', output).group(1)
32
    return int(values)
33

34

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
37
    values = re.search(r'ID (\d+)', output).group(1)
38
    return int(values)
39

40

41
def test_zcrx(cfg) -> None:
42
    cfg.require_ipver('6')
43

44
    combined_chans = _get_combined_channels(cfg)
45
    if combined_chans < 2:
46
        raise KsftSkipEx('at least 2 combined channels required')
47
    (rx_ring, hds_thresh) = _get_current_settings(cfg)
48
    port = rand_port()
49

50
    ethtool(f"-G {cfg.ifname} tcp-data-split on")
51
    defer(ethtool, f"-G {cfg.ifname} tcp-data-split auto")
52

53
    ethtool(f"-G {cfg.ifname} hds-thresh 0")
54
    defer(ethtool, f"-G {cfg.ifname} hds-thresh {hds_thresh}")
55

56
    ethtool(f"-G {cfg.ifname} rx 64")
57
    defer(ethtool, f"-G {cfg.ifname} rx {rx_ring}")
58

59
    ethtool(f"-X {cfg.ifname} equal {combined_chans - 1}")
60
    defer(ethtool, f"-X {cfg.ifname} default")
61

62
    flow_rule_id = _set_flow_rule(cfg, port, combined_chans - 1)
63
    defer(ethtool, f"-N {cfg.ifname} delete {flow_rule_id}")
64

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"
67
    with bkg(rx_cmd, exit_wait=True):
68
        wait_port_listen(port, proto="tcp")
69
        cmd(tx_cmd, host=cfg.remote)
70

71

72
def test_zcrx_oneshot(cfg) -> None:
73
    cfg.require_ipver('6')
74

75
    combined_chans = _get_combined_channels(cfg)
76
    if combined_chans < 2:
77
        raise KsftSkipEx('at least 2 combined channels required')
78
    (rx_ring, hds_thresh) = _get_current_settings(cfg)
79
    port = rand_port()
80

81
    ethtool(f"-G {cfg.ifname} tcp-data-split on")
82
    defer(ethtool, f"-G {cfg.ifname} tcp-data-split auto")
83

84
    ethtool(f"-G {cfg.ifname} hds-thresh 0")
85
    defer(ethtool, f"-G {cfg.ifname} hds-thresh {hds_thresh}")
86

87
    ethtool(f"-G {cfg.ifname} rx 64")
88
    defer(ethtool, f"-G {cfg.ifname} rx {rx_ring}")
89

90
    ethtool(f"-X {cfg.ifname} equal {combined_chans - 1}")
91
    defer(ethtool, f"-X {cfg.ifname} default")
92

93
    flow_rule_id = _set_flow_rule(cfg, port, combined_chans - 1)
94
    defer(ethtool, f"-N {cfg.ifname} delete {flow_rule_id}")
95

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"
98
    with bkg(rx_cmd, exit_wait=True):
99
        wait_port_listen(port, proto="tcp")
100
        cmd(tx_cmd, host=cfg.remote)
101

102

103
def test_zcrx_rss(cfg) -> None:
104
    cfg.require_ipver('6')
105

106
    combined_chans = _get_combined_channels(cfg)
107
    if combined_chans < 2:
108
        raise KsftSkipEx('at least 2 combined channels required')
109
    (rx_ring, hds_thresh) = _get_current_settings(cfg)
110
    port = rand_port()
111

112
    ethtool(f"-G {cfg.ifname} tcp-data-split on")
113
    defer(ethtool, f"-G {cfg.ifname} tcp-data-split auto")
114

115
    ethtool(f"-G {cfg.ifname} hds-thresh 0")
116
    defer(ethtool, f"-G {cfg.ifname} hds-thresh {hds_thresh}")
117

118
    ethtool(f"-G {cfg.ifname} rx 64")
119
    defer(ethtool, f"-G {cfg.ifname} rx {rx_ring}")
120

121
    ethtool(f"-X {cfg.ifname} equal {combined_chans - 1}")
122
    defer(ethtool, f"-X {cfg.ifname} default")
123

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}")
127

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"
130
    with bkg(rx_cmd, exit_wait=True):
131
        wait_port_listen(port, proto="tcp")
132
        cmd(tx_cmd, host=cfg.remote)
133

134

135
def main() -> None:
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)
139

140
        ksft_run(globs=globals(), case_pfx={"test_"}, args=(cfg, ))
141
    ksft_exit()
142

143

144
if __name__ == "__main__":
145
    main()
146

147
Product

Resources

Company
