1 # Copyright 2015-2017 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 """VSwitch controller for Physical to Tunnel Endpoint to Physical deployment
20 from core.vswitch_controller import IVswitchController
21 from vswitches.utils import add_ports_to_flow
22 from conf import settings as S
23 from tools import tasks
29 class VswitchControllerOP2P(IVswitchController):
30 """VSwitch controller for OP2P deployment scenario.
33 _vswitch_class: The vSwitch class to be used.
34 _vswitch: The vSwitch object controlled by this controller
35 _deployment_scenario: A string describing the scenario to set-up in the
38 def __init__(self, vswitch_class, traffic, tunnel_operation=None):
39 """Initializes up the prerequisites for the OP2P deployment scenario.
41 :vswitch_class: the vSwitch class to be used.
43 self._logger = logging.getLogger(__name__)
44 self._vswitch_class = vswitch_class
45 self._vswitch = vswitch_class()
46 self._deployment_scenario = "OP2P"
47 self._traffic = traffic.copy()
48 self._tunnel_operation = tunnel_operation
49 self._logger.debug('Creation using %s', str(self._vswitch_class))
52 """ Sets up the switch for overlay P2P (tunnel encap or decap)
54 self._logger.debug('Setting up %s', str(self._tunnel_operation))
55 if self._tunnel_operation == "encapsulation":
58 if str(S.getValue('VSWITCH')).endswith('Vanilla'):
59 self._setup_decap_vanilla()
63 def _setup_encap(self):
64 """ Sets up the switch for overlay P2P encapsulation test
66 Create 2 bridges br0 (integration bridge) and br-ext and a VXLAN port
69 self._logger.debug('Setup using %s', str(self._vswitch_class))
73 bridge = S.getValue('TUNNEL_INTEGRATION_BRIDGE')
74 bridge_ext = S.getValue('TUNNEL_EXTERNAL_BRIDGE')
75 bridge_ext_ip = S.getValue('TUNNEL_EXTERNAL_BRIDGE_IP')
76 tg_port2_mac = S.getValue('TRAFFICGEN_PORT2_MAC')
77 vtep_ip2 = S.getValue('VTEP_IP2')
78 self._vswitch.add_switch(bridge)
80 tasks.run_task(['sudo', 'ip', 'addr', 'add',
81 S.getValue('VTEP_IP1'), 'dev', bridge],
82 self._logger, 'Assign ' +
83 S.getValue('VTEP_IP1') + ' to ' + bridge,
85 tasks.run_task(['sudo', 'ip', 'link', 'set', 'dev', bridge, 'up'],
86 self._logger, 'Bring up ' + bridge, False)
88 tunnel_type = self._traffic['tunnel_type']
90 self._vswitch.add_switch(bridge_ext)
91 (_, phy1_number) = self._vswitch.add_phy_port(bridge)
92 (_, phy2_number) = self._vswitch.add_tunnel_port(bridge,
95 self._vswitch.add_phy_port(bridge_ext)
97 tasks.run_task(['sudo', 'ip', 'addr', 'add',
99 'dev', bridge_ext], self._logger, 'Assign ' +
100 bridge_ext_ip + ' to ' + bridge_ext)
102 tasks.run_task(['sudo', 'ip', 'link', 'set', 'dev', bridge_ext,
104 'Set ' + bridge_ext + 'status to up')
106 self._vswitch.add_route(bridge,
107 S.getValue('VTEP_IP2_SUBNET'),
110 if str(S.getValue('VSWITCH')).endswith('Vanilla'):
111 tasks.run_task(['sudo', 'arp', '-s', vtep_ip2, tg_port2_mac],
113 'Set ' + bridge_ext + ' status to up')
115 self._vswitch.set_tunnel_arp(vtep_ip2,
119 # Test is unidirectional for now
120 self._vswitch.del_flow(bridge)
121 flow1 = add_ports_to_flow(_FLOW_TEMPLATE, phy1_number,
123 self._vswitch.add_flow(bridge, flow1)
129 def _setup_decap(self):
130 """ Sets up the switch for overlay P2P decapsulation test
132 self._logger.debug('Setup using %s', str(self._vswitch_class))
135 self._vswitch.start()
136 bridge = S.getValue('TUNNEL_INTEGRATION_BRIDGE')
137 bridge_ext = S.getValue('TUNNEL_EXTERNAL_BRIDGE')
138 bridge_ext_ip = S.getValue('TUNNEL_EXTERNAL_BRIDGE_IP')
139 tgen_ip1 = S.getValue('TRAFFICGEN_PORT1_IP')
140 self._vswitch.add_switch(bridge)
142 tasks.run_task(['sudo', 'ip', 'addr', 'add',
143 S.getValue('VTEP_IP1'), 'dev', bridge],
144 self._logger, 'Assign ' +
145 S.getValue('VTEP_IP1') + ' to ' + bridge, False)
146 tasks.run_task(['sudo', 'ip', 'link', 'set', 'dev', bridge, 'up'],
147 self._logger, 'Bring up ' + bridge, False)
149 tunnel_type = self._traffic['tunnel_type']
151 self._vswitch.add_switch(bridge_ext)
152 self._vswitch.add_phy_port(bridge)
153 (_, phy2_number) = self._vswitch.add_phy_port(bridge_ext)
154 if tunnel_type == "vxlan":
155 vxlan_vni = 'options:key=' + S.getValue('VXLAN_VNI')
156 (_, phy3_number) = self._vswitch.add_tunnel_port(bridge_ext,
161 (_, phy3_number) = self._vswitch.add_tunnel_port(bridge_ext,
164 tasks.run_task(['sudo', 'ip', 'addr', 'add',
167 self._logger, 'Assign ' +
169 + ' to ' + bridge_ext)
171 tasks.run_task(['sudo', 'ip', 'link', 'set', 'dev', bridge_ext,
174 'Set ' + bridge_ext + ' status to up')
176 self._vswitch.set_tunnel_arp(tgen_ip1,
177 S.getValue('TRAFFICGEN_PORT1_MAC'),
179 # Test is unidirectional for now
180 self._vswitch.del_flow(bridge_ext)
181 flow1 = add_ports_to_flow(_FLOW_TEMPLATE, phy3_number,
183 self._vswitch.add_flow(bridge_ext, flow1)
189 def _setup_decap_vanilla(self):
190 """ Sets up the switch for overlay P2P decapsulation test
192 self._logger.debug('Setup decap vanilla %s', str(self._vswitch_class))
195 self._vswitch.start()
196 bridge = S.getValue('TUNNEL_INTEGRATION_BRIDGE')
197 bridge_ext = S.getValue('TUNNEL_EXTERNAL_BRIDGE')
198 bridge_ext_ip = S.getValue('TUNNEL_EXTERNAL_BRIDGE_IP')
199 tgen_ip1 = S.getValue('TRAFFICGEN_PORT1_IP')
200 self._vswitch.add_switch(bridge)
202 tasks.run_task(['sudo', 'ip', 'addr', 'add',
203 S.getValue('TUNNEL_INT_BRIDGE_IP'), 'dev', bridge],
204 self._logger, 'Assign ' +
205 S.getValue('TUNNEL_INT_BRIDGE_IP') + ' to ' + bridge, False)
206 tasks.run_task(['sudo', 'ip', 'link', 'set', 'dev', bridge, 'up'],
207 self._logger, 'Bring up ' + bridge, False)
209 tunnel_type = self._traffic['tunnel_type']
211 self._vswitch.add_switch(bridge_ext)
212 self._vswitch.add_phy_port(bridge_ext)
213 (_, phy2_number) = self._vswitch.add_phy_port(bridge)
215 if tunnel_type == "vxlan":
216 vxlan_vni = 'options:key=' + S.getValue('VXLAN_VNI')
217 self._vswitch.add_tunnel_port(bridge, tgen_ip1, tunnel_type,
220 self._vswitch.add_tunnel_port(bridge, tgen_ip1, tunnel_type)
222 tasks.run_task(['sudo', 'ip', 'addr', 'add',
225 self._logger, 'Assign ' +
227 + ' to ' + bridge_ext)
229 tasks.run_task(['sudo', 'ip', 'link', 'set', 'dev', bridge_ext,
232 'Set ' + bridge_ext + ' status to up')
234 tg_port2_mac = S.getValue('TRAFFICGEN_PORT2_MAC')
235 vtep_ip2 = S.getValue('TRAFFICGEN_PORT2_IP')
237 self._vswitch.set_tunnel_arp(vtep_ip2,
241 self._vswitch.add_route(bridge,
242 S.getValue('VTEP_IP2_SUBNET'),
246 tasks.run_task(['sudo', 'arp', '-s', vtep_ip2, tg_port2_mac],
248 'Set ' + bridge_ext + ' status to up')
251 # Test is unidirectional for now
252 self._vswitch.del_flow(bridge_ext)
254 flow1 = add_ports_to_flow(_FLOW_TEMPLATE, phy2_number, 'LOCAL')
255 self._vswitch.add_flow(bridge_ext, flow1)
262 """Tears down the switch created in setup().
264 self._logger.debug('Stop using %s', str(self._vswitch_class))
270 def __exit__(self, type_, value, traceback):
273 def get_vswitch(self):
274 """See IVswitchController for description
278 def get_ports_info(self):
279 """See IVswitchController for description
281 self._logger.debug('get_ports_info for bridges: %s, %s',
282 S.getValue('TUNNEL_INTEGRATION_BRIDGE'),
283 S.getValue('TUNNEL_EXTERNAL_BRIDGE'))
284 return self._vswitch.get_ports(
285 S.getValue('TUNNEL_INTEGRATION_BRIDGE')) +\
286 self._vswitch.get_ports(
287 S.getValue('TUNNEL_EXTERNAL_BRIDGE'))
289 def dump_vswitch_flows(self):
290 """See IVswitchController for description
292 self._vswitch.dump_flows(S.getValue('TUNNEL_INTEGRATION_BRIDGE'))
293 self._vswitch.dump_flows(S.getValue('TUNNEL_EXTERNAL_BRIDGE'))