1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
|
# Copyright (c) 2022 Cisco and/or its affiliates.
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at:
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
"""
This module exists to start testpmd on topology nodes.
"""
from robot.libraries.BuiltIn import BuiltIn
from resources.libraries.python.Constants import Constants
from resources.libraries.python.CpuUtils import CpuUtils
from resources.libraries.python.DpdkUtil import DpdkUtil
from resources.libraries.python.ssh import exec_cmd_no_error
from resources.libraries.python.topology import NodeType, Topology
class TestpmdTest:
"""
This class start testpmd on topology nodes and check if properly started.
"""
@staticmethod
def start_testpmd_on_all_duts(
nodes, topology_info, phy_cores, rx_queues=None, jumbo_frames=False,
rxd=None, txd=None, nic_rxq_size=None, nic_txq_size=None):
"""
Start the testpmd with M worker threads and rxqueues N and jumbo
support frames on/off on all DUTs.
:param nodes: All the nodes info from the topology file.
:param topology_info: All the info from the topology file.
:param phy_cores: Number of physical cores to use.
:param rx_queues: Number of RX queues.
:param jumbo_frames: Jumbo frames on/off.
:param rxd: Number of RX descriptors.
:param txd: Number of TX descriptors.
:param nic_rxq_size: RX queue size.
:param nic_txq_size: TX queue size.
:type nodes: dict
:type topology_info: dict
:type phy_cores: int
:type rx_queues: int
:type jumbo_frames: bool
:type rxd: int
:type txd: int
:type nic_rxq_size: int
:type nic_txq_size: int
:raises RuntimeError: If bash return code is not 0.
"""
cpu_count_int = dp_count_int = int(phy_cores)
dp_cores = cpu_count_int+1
for node in nodes:
if u"DUT" in node:
compute_resource_info = CpuUtils.get_affinity_vswitch(
nodes, node, phy_cores, rx_queues=rx_queues,
rxd=rxd, txd=txd
)
if dp_count_int > 1:
BuiltIn().set_tags('MTHREAD')
else:
BuiltIn().set_tags('STHREAD')
BuiltIn().set_tags(
f"{dp_count_int}T{cpu_count_int}C"
)
cpu_dp = compute_resource_info[u"cpu_dp"]
rxq_count_int = compute_resource_info[u"rxq_count_int"]
if1 = topology_info[f"{node}_pf1"][0]
if2 = topology_info[f"{node}_pf2"][0]
TestpmdTest.start_testpmd(
nodes[node], if1=if1, if2=if2, lcores_list=cpu_dp,
nb_cores=dp_count_int, queue_nums=rxq_count_int,
jumbo_frames=jumbo_frames, rxq_size=nic_rxq_size,
txq_size=nic_txq_size
)
for node in nodes:
if u"DUT" in node:
for i in range(3):
try:
TestpmdTest.check_testpmd(nodes[node])
break
except RuntimeError:
TestpmdTest.start_testpmd(
nodes[node], if1=if1, if2=if2,
lcores_list=cpu_dp, nb_cores=dp_count_int,
queue_nums=rxq_count_int,
jumbo_frames=jumbo_frames,
rxq_size=nic_rxq_size, txq_size=nic_txq_size
)
else:
message = f"Failed to start testpmd at node {node}"
raise RuntimeError(message)
@staticmethod
def start_testpmd(
node, if1, if2, lcores_list, nb_cores, queue_nums,
jumbo_frames, rxq_size=1024, txq_size=1024):
"""
Execute the testpmd on the DUT node.
:param node: DUT node.
:param if1: The test link interface 1.
:param if2: The test link interface 2.
:param lcores_list: The DPDK run cores.
:param nb_cores: The cores number for the forwarding.
:param queue_nums: The queues number for the NIC.
:param jumbo_frames: Indication if the jumbo frames are used (True) or
not (False).
:param rxq_size: RXQ size. Default=1024.
:param txq_size: TXQ size. Default=1024.
:type node: dict
:type if1: str
:type if2: str
:type lcores_list: str
:type nb_cores: int
:type queue_nums: str
:type jumbo_frames: bool
:type rxq_size: int
:type txq_size: int
:raises RuntimeError: If the script "run_testpmd.sh" fails.
"""
if node[u"type"] == NodeType.DUT:
if_pci0 = Topology.get_interface_pci_addr(node, if1)
if_pci1 = Topology.get_interface_pci_addr(node, if2)
pmd_max_pkt_len = u"9200" if jumbo_frames else u"1518"
testpmd_args = DpdkUtil.get_testpmd_args(
eal_corelist=f"1,{lcores_list}",
eal_driver=False,
eal_pci_whitelist0=if_pci0,
eal_pci_whitelist1=if_pci1,
eal_in_memory=True,
pmd_num_mbufs=32768,
pmd_fwd_mode=u"io",
pmd_nb_ports=u"2",
pmd_portmask=u"0x3",
pmd_max_pkt_len=pmd_max_pkt_len,
pmd_mbuf_size=u"16384",
pmd_rxd=rxq_size,
pmd_txd=txq_size,
pmd_rxq=queue_nums,
pmd_txq=queue_nums,
pmd_nb_cores=nb_cores,
pmd_disable_link_check=False,
pmd_auto_start=True,
pmd_numa=True
)
command = f"{Constants.REMOTE_FW_DIR}/{Constants.RESOURCES_LIB_SH}"\
f"/entry/run_testpmd.sh \"{testpmd_args}\""
message = f"Failed to execute testpmd at node {node['host']}"
exec_cmd_no_error(node, command, timeout=1800, message=message)
@staticmethod
def check_testpmd(node):
"""
Execute the testpmd check on the DUT node.
:param node: DUT node.
:type node: dict
:raises RuntimeError: If the script "check_testpmd.sh" fails.
"""
if node[u"type"] == NodeType.DUT:
command = f"{Constants.REMOTE_FW_DIR}/{Constants.RESOURCES_LIB_SH}"\
f"/entry/check_testpmd.sh"
message = "Testpmd not started properly"
exec_cmd_no_error(node, command, timeout=1800, message=message)
|
