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
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
|
#! /usr/bin/python
# hhaim
import sys
import os
python_ver = 'python%s' % sys.version_info[0]
sys.path.append(os.path.join('external_libs', 'pyyaml-3.11', python_ver))
import yaml
import os.path
import os
import dpdk_nic_bind
import re
import argparse;
class map_driver(object):
args=None;
cfg_file='/etc/trex_cfg.yaml'
class DpdkSetup(Exception):
pass
class CIfMap:
def __init__(self, cfg_file):
self.m_cfg_file =cfg_file;
self.m_cfg_dict={};
self.m_devices={};
def dump_error (self,err):
s="""%s
From this TRex version a configuration file must exist in /etc/ folder "
The name of the configuration file should be /etc/trex_cfg.yaml "
The minimum configuration file should include something like this
- version : 2 # version 2 of the configuration file
interfaces : ["03:00.0","03:00.1","13:00.1","13:00.0"] # list of the interfaces to bind run ./dpdk_nic_bind.py --status to see the list
port_limit : 2 # number of ports to use valid is 2,4,6,8,10,12
example of already bind devices
$ ./dpdk_nic_bind.py --status
Network devices using DPDK-compatible driver
============================================
0000:03:00.0 '82599ES 10-Gigabit SFI/SFP+ Network Connection' drv=igb_uio unused=
0000:03:00.1 '82599ES 10-Gigabit SFI/SFP+ Network Connection' drv=igb_uio unused=
0000:13:00.0 '82599ES 10-Gigabit SFI/SFP+ Network Connection' drv=igb_uio unused=
0000:13:00.1 '82599ES 10-Gigabit SFI/SFP+ Network Connection' drv=igb_uio unused=
Network devices using kernel driver
===================================
0000:02:00.0 '82545EM Gigabit Ethernet Controller (Copper)' if=eth2 drv=e1000 unused=igb_uio *Active*
Other network devices
=====================
""" % (err);
return s;
def raise_error (self,err):
s= self.dump_error (err)
raise DpdkSetup(s)
def load_config_file (self):
fcfg=self.m_cfg_file
if not os.path.isfile(fcfg) :
self.raise_error ("There is no valid configuration file %s " % fcfg)
try:
stream = open(fcfg, 'r')
self.m_cfg_dict= yaml.load(stream)
except Exception as e:
print(e);
raise e
stream.close();
cfg_dict = self.m_cfg_dict[0]
if 'version' not in cfg_dict:
self.raise_error ("Configuration file %s is old, should include version field\n" % fcfg )
if int(cfg_dict['version'])<2 :
self.raise_error ("Configuration file %s is old, should include version field with value greater than 2\n" % fcfg)
if 'interfaces' not in self.m_cfg_dict[0]:
self.raise_error ("Configuration file %s is old, should include interfaces field even number of elemets" % fcfg)
if_list=self.m_cfg_dict[0]['interfaces']
l=len(if_list);
if (l>20):
self.raise_error ("Configuration file %s should include interfaces field with maximum of number of elemets" % (fcfg,l))
if ((l % 2)==1):
self.raise_error ("Configuration file %s should include even number of interfaces " % (fcfg,l))
if 'port_limit' in cfg_dict and cfg_dict['port_limit'] > len(if_list):
self.raise_error ('Error: port_limit should not be higher than number of interfaces in config file: %s\n' % fcfg)
def do_bind_one (self,key):
cmd='%s dpdk_nic_bind.py --bind=igb_uio %s ' % (sys.executable, key)
print(cmd)
res=os.system(cmd);
if res!=0:
raise DpdkSetup('')
def pci_name_to_full_name (self,pci_name):
c='[0-9A-Fa-f]';
sp='[:]'
s_short=c+c+sp+c+c+'[.]'+c;
s_full=c+c+c+c+sp+s_short
re_full = re.compile(s_full)
re_short = re.compile(s_short)
if re_short.match(pci_name):
return '0000:'+pci_name
if re_full.match(pci_name):
return pci_name
err=" %s is not a valid pci address \n" %pci_name;
raise DpdkSetup(err)
def run_dpdk_lspci (self):
dpdk_nic_bind.get_nic_details()
self.m_devices= dpdk_nic_bind.devices
def do_run (self):
self.load_config_file ()
self.run_dpdk_lspci ()
if_list=self.m_cfg_dict[0]['interfaces']
for obj in if_list:
key= self.pci_name_to_full_name (obj)
if key not in self.m_devices:
err=" %s does not exist " %key;
raise DpdkSetup(err)
if 'Driver_str' in self.m_devices[key]:
if self.m_devices[key]['Driver_str'] !='igb_uio' :
self.do_bind_one (key)
else:
self.do_bind_one (key)
def do_create (self):
print(" not supported yet !")
def parse_parent_cfg (parent_cfg):
l=parent_cfg.split(" ");
cfg_file='';
next=False;
for obj in l:
if next:
cfg_file=obj
next=False;
if obj == '--cfg':
next=True
return (cfg_file)
def process_options ():
parser = argparse.ArgumentParser(usage="""
Examples:
---------
To unbind the interfaces using the trex configuration file
dpdk_set_ports.py -l
To create a default file
dpdk_set_ports.py -c
To show status
dpdk_set_ports.py -s
""",
description=" unbind dpdk interfaces ",
epilog=" written by hhaim");
parser.add_argument("-l", "--load", action='store_true',
help=""" unbind the interfaces using the configuration file given """,
)
parser.add_argument("--cfg",
help=""" configuration file name """,
)
parser.add_argument("--parent",
help=""" parent configuration CLI, extract --cfg from it if given """,
)
parser.add_argument("-c", "--create", action='store_true',
help=""" try to create a configuration file. It is heuristic try to look into the file before """,
)
parser.add_argument("-s", "--show", action='store_true',
help=""" show the status """,
)
parser.add_argument('--version', action='version',
version="0.1" )
map_driver.args = parser.parse_args();
if map_driver.args.parent :
cfg = parse_parent_cfg (map_driver.args.parent)
if cfg != '':
map_driver.cfg_file = cfg;
if map_driver.args.cfg :
map_driver.cfg_file = map_driver.args.cfg;
def main ():
try:
process_options ()
if map_driver.args.show:
res=os.system('%s dpdk_nic_bind.py --status' % sys.executable);
return(res);
obj =CIfMap(map_driver.cfg_file);
if map_driver.args.create:
obj.do_create();
else:
obj.do_run();
except Exception as e:
print(e)
exit(-1)
main();
|
