1 # Copyright 2015 Intel Corporation.
3 # Licensed under the Apache License, Version 2.0 (the "License");
4 # you may not use this file except in compliance with the License.
5 # You may obtain a copy of the License at
7 # http://www.apache.org/licenses/LICENSE-2.0
9 # Unless required by applicable law or agreed to in writing, software
10 # distributed under the License is distributed on an "AS IS" BASIS,
11 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 # See the License for the specific language governing permissions and
13 # limitations under the License.
15 """VSPERF VSwitch implementation using DPDK and vhost ports
19 from conf import settings
20 from vswitches.vswitch import IVSwitch
21 from src.ovs import VSwitchd, OFBridge
22 from src.dpdk import dpdk
24 _VSWITCHD_CONST_ARGS = ['--', '--log-file']
26 class OvsDpdkVhost(IVSwitch):
27 """VSwitch implementation using DPDK and vhost ports
29 Generic OVS wrapper functionality in src.ovs is maximally used. This
30 class wraps DPDK system configuration along with DPDK specific OVS
33 The method docstrings document only considerations specific to this
34 implementation. For generic information of the nature of the methods,
38 _logger = logging.getLogger()
41 vswitchd_args = ['--dpdk']
42 vswitchd_args += settings.getValue('VSWITCHD_DPDK_ARGS')
43 vswitchd_args += _VSWITCHD_CONST_ARGS
45 if settings.getValue('VNF').endswith('Cuse'):
46 self._logger.info("Inserting VHOST Cuse modules into kernel...")
47 dpdk.insert_vhost_modules()
49 self._vswitchd = VSwitchd(vswitchd_args=vswitchd_args,
51 r'EAL: Master l*core \d+ is ready')
55 """See IVswitch for general description
57 Activates DPDK kernel modules, ovsdb and vswitchd.
60 self._vswitchd.start()
63 """See IVswitch for general description
65 Kills ovsdb and vswitchd and removes DPDK kernel modules.
69 dpdk.remove_vhost_modules()
71 def add_switch(self, switch_name, params=None):
72 """See IVswitch for general description
74 bridge = OFBridge(switch_name)
76 bridge.create(['--', 'set', 'bridge', switch_name,
77 'datapath_type=netdev'])
79 bridge.create(['--', 'set', 'bridge', switch_name,
80 'datapath_type=netdev'] + params)
82 bridge.set_db_attribute('Open_vSwitch', '.',
83 'other_config:max-idle',
84 settings.getValue('VSWITCH_FLOW_TIMEOUT'))
86 if settings.getValue('VSWITCH_AFFINITIZATION_ON') == 1:
87 # Sets the PMD core mask to VSWITCH_PMD_CPU_MASK
88 # for CPU core affinitization
89 bridge.set_db_attribute('Open_vSwitch', '.',
90 'other_config:pmd-cpu-mask',
91 settings.getValue('VSWITCH_PMD_CPU_MASK'))
93 self._bridges[switch_name] = bridge
95 def del_switch(self, switch_name):
96 """See IVswitch for general description
98 bridge = self._bridges[switch_name]
99 self._bridges.pop(switch_name)
102 def add_phy_port(self, switch_name):
103 """See IVswitch for general description
105 Creates a port of type dpdk.
106 The new port is named dpdk<n> where n is an integer starting from 0.
108 bridge = self._bridges[switch_name]
109 dpdk_count = self._get_port_count(bridge, 'type=dpdk')
110 port_name = 'dpdk' + str(dpdk_count)
111 params = ['--', 'set', 'Interface', port_name, 'type=dpdk']
112 of_port = bridge.add_port(port_name, params)
114 return (port_name, of_port)
116 def add_vport(self, switch_name):
117 """See IVswitch for general description
119 Creates a port of type dpdkvhost
120 The new port is named dpdkvhost<n> where n is an integer starting
123 bridge = self._bridges[switch_name]
124 # Changed dpdkvhost to dpdkvhostuser to be able to run in Qemu 2.2
125 if settings.getValue('VNF').endswith('Cuse'):
126 vhost_count = self._get_port_count(bridge, 'type=dpdkvhostcuse')
127 port_name = 'dpdkvhostcuse' + str(vhost_count)
128 params = ['--', 'set', 'Interface', port_name, 'type=dpdkvhostcuse']
130 vhost_count = self._get_port_count(bridge, 'type=dpdkvhostuser')
131 port_name = 'dpdkvhostuser' + str(vhost_count)
132 params = ['--', 'set', 'Interface', port_name, 'type=dpdkvhostuser']
134 of_port = bridge.add_port(port_name, params)
136 return (port_name, of_port)
138 def get_ports(self, switch_name):
139 """See IVswitch for general description
141 bridge = self._bridges[switch_name]
142 ports = list(bridge.get_ports().items())
143 return [(name, of_port) for (name, (of_port, _)) in ports]
145 def del_port(self, switch_name, port_name):
146 """See IVswitch for general description
148 bridge = self._bridges[switch_name]
149 bridge.del_port(port_name)
151 def add_flow(self, switch_name, flow, cache='off'):
152 """See IVswitch for general description
154 bridge = self._bridges[switch_name]
155 bridge.add_flow(flow, cache=cache)
157 def del_flow(self, switch_name, flow=None):
158 """See IVswitch for general description
161 bridge = self._bridges[switch_name]
162 bridge.del_flow(flow)
164 def dump_flows(self, switch_name):
165 """See IVswitch for general description
167 bridge = self._bridges[switch_name]
171 def _get_port_count(bridge, param):
172 """Returns the number of ports having a certain parameter
174 :param bridge: The src.ovs.ofctl.OFBridge on which to operate
175 :param param: The parameter to search for
176 :returns: Count of matches
178 port_params = [c for (_, (_, c)) in list(bridge.get_ports().items())]
179 param_hits = [i for i in port_params if param in i]
180 return len(param_hits)