aboutsummaryrefslogtreecommitdiffstats
path: root/samples/vnf_samples/nsut/prox/prox-baremetal-4.yaml
blob: 0b09860526b1715be4e8929b7839c6b1a1042cf2 (plain) 
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

# Copyright (c) 2016-2017 Intel Corporation
#
# 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.
#
#;

nodes:
-
    name: "tg_0"
    role: TrafficGen
    ip: 1.1.1.1
    user: "root"
    ssh_port: "22"
    password: "r00t"
    interfaces:
        xe0:
            vpci: "0000:05:00.0"
            local_mac: "68:05:ca:30:3d:50"
            driver: "i40e"
            local_ip: "152.16.100.19"
            netmask: "255.255.255.0"
            dpdk_port_num: 0
        xe1:
            vpci: "0000:05:00.1"
            local_mac: "68:05:ca:30:3d:51"
            driver: "i40e"
            local_ip: "152.16.40.19"
            netmask: "255.255.255.0"
            dpdk_port_num: 1
        xe2:
            vpci: "0000:05:00.2"
            local_mac: "68:05:ca:30:3d:52"
            driver: "i40e"
            local_ip: "192.16.100.11"
            netmask: "255.255.255.0"
            dpdk_port_num: 2
        xe3:
            vpci: "0000:05:00.3"
            local_mac: "68:05:ca:30:3d:53"
            driver: "i40e"
            local_ip: "192.16.40.11"
            netmask: "255.255.255.0"
            dpdk_port_num: 3
-
    name: "vnf_0"
    role: VNF
    ip: 1.1.1.2
    user: "root"
    ssh_port: "22"
    password: "r00t"
    interfaces:
        xe0:
            vpci: "0000:05:00.0"
            local_mac: "68:05:ca:30:3c:68"
            driver: "i40e"
            local_ip: "152.16.100.21"
            netmask: "255.255.255.0"
            dpdk_port_num: 0
        xe1:
            vpci: "0000:05:00.1"
            local_mac: "68:05:ca:30:3c:69"
            driver: "i40e"
            local_ip: "152.16.40.21"
            netmask: "255.255.255.0"
            dpdk_port_num: 1
        xe2:
            vpci: "0000:05:00.2"
            local_mac: "68:05:ca:30:3c:6a"
            driver: "i40e"
            local_ip: "192.16.100.22"
            netmask: "255.255.255.0"
            dpdk_port_num: 2
        xe3:
            vpci: "0000:05:00.3"
            local_mac: "68:05:ca:30:3c:6b"
            driver: "i40e"
            local_ip: "192.16.40.22"
            netmask: "255.255.255.0"
            dpdk_port_num: 3
    routing_table:
    - network: "152.16.100.20"
      netmask: "255.255.255.0"
      gateway: "152.16.100.20"
      if: "xe0"
    - network: "152.16.40.20"
      netmask: "255.255.255.0"
      gateway: "152.16.40.20"
      if: "xe1"
    - network: "192.16.100.20"
      netmask: "255.255.255.0"
      gateway: "192.16.100.20"
      if: "xe2"
    - network: "192.16.40.20"
      netmask: "255.255.255.0"
      gateway: "192.16.40.20"
      if: "xe3"
    nd_route_tbl:
    - network: "0064:ff9b:0:0:0:0:9810:6414"
      netmask: "112"
      gateway: "0064:ff9b:0:0:0:0:9810:6414"
      if: "xe0"
    - network: "0064:ff9b:0:0:0:0:9810:2814"
      netmask: "112"
      gateway: "0064:ff9b:0:0:0:0:9810:2814"
      if: "xe1"
    - network: "0064:ff9b:0:0:0:0:C010:6414"
      netmask: "112"
      gateway: "0064:ff9b:0:0:0:0:C010:6414"
      if: "xe2"
    - network: "0064:ff9b:0:0:0:0:C010:2814"
      netmask: "112"
      gateway: "0064:ff9b:0:0:0:0:C010:2814"
      if: "xe3"
;" def __init__(self, timeout=10): """Initialise logger. :param timeout: Timeout to be used for each command :returns: None """ self.logger = logging.getLogger(__name__) self.timeout = timeout # helpers def run_vsctl(self, args, check_error=False): """Run ``ovs-vsctl`` with supplied arguments. :param args: Arguments to pass to ``ovs-vsctl`` :param check_error: Throw exception on error :return: None """ cmd = ['sudo', _OVS_VSCTL_BIN, '--timeout', str(self.timeout)] + args return tasks.run_task( cmd, self.logger, 'Running ovs-vsctl...', check_error) def run_appctl(self, args, check_error=False): """Run ``ovs-appctl`` with supplied arguments. :param args: Arguments to pass to ``ovs-appctl`` :param check_error: Throw exception on error :return: None """ cmd = ['sudo', _OVS_APPCTL_BIN, '--timeout', str(self.timeout)] + args return tasks.run_task( cmd, self.logger, 'Running ovs-appctl...', check_error) # datapath management def add_br(self, br_name=_OVS_BRIDGE_NAME, params=None): """Add datapath. :param br_name: Name of bridge :return: Instance of :class OFBridge: """ if params is None: params = [] self.logger.debug('add bridge') self.run_vsctl(['add-br', br_name]+params) return OFBridge(br_name, self.timeout) def del_br(self, br_name=_OVS_BRIDGE_NAME): """Delete datapath. :param br_name: Name of bridge :return: None """ self.logger.debug('delete bridge') self.run_vsctl(['del-br', br_name]) # Route and ARP functions def add_route(self, network, destination): """Add route to tunneling routing table. :param network: Network :param destination: Gateway :return: None """ self.logger.debug('add ovs/route') self.run_appctl(['ovs/route/add', network, destination]) def set_tunnel_arp(self, ip_addr, mac_addr, br_name=_OVS_BRIDGE_NAME): """Add OVS arp entry for tunneling :param ip: IP of bridge :param mac_addr: MAC address of the bridge :param br_name: Name of the bridge :return: None """ self.logger.debug('tnl/arp/set') self.run_appctl(['tnl/arp/set', br_name, ip_addr, mac_addr]) class OFBridge(OFBase): """Control a bridge instance using ``ovs-vsctl`` and ``ovs-ofctl``. """ def __init__(self, br_name=_OVS_BRIDGE_NAME, timeout=10): """Initialise bridge. :param br_name: Bridge name :param timeout: Timeout to be used for each command :returns: None """ super(OFBridge, self).__init__(timeout) self.br_name = br_name self._ports = {} self._cache_file = None # context manager def __enter__(self): """Create datapath :returns: self """ return self def __exit__(self, type_, value, traceback): """Remove datapath. """ if not traceback: self.destroy() # helpers def run_ofctl(self, args, check_error=False, timeout=None): """Run ``ovs-ofctl`` with supplied arguments. :param args: Arguments to pass to ``ovs-ofctl`` :param check_error: Throw exception on error :return: None """ tmp_timeout = self.timeout if timeout == None else timeout cmd = ['sudo', _OVS_OFCTL_BIN, '-O', 'OpenFlow13', '--timeout', str(tmp_timeout)] + args return tasks.run_task( cmd, self.logger, 'Running ovs-ofctl...', check_error) def create(self, params=None): """Create bridge. """ if params is None: params = [] self.logger.debug('create bridge') self.add_br(self.br_name, params=params) def destroy(self): """Destroy bridge. """ self.logger.debug('destroy bridge') self.del_br(self.br_name) def reset(self): """Reset bridge. """ self.logger.debug('reset bridge') self.destroy() self.create() # port management def add_port(self, port_name, params): """Add port to bridge. :param port_name: Name of port :param params: Additional list of parameters to add-port :return: OpenFlow port number for the port """ self.logger.debug('add port') self.run_vsctl(['add-port', self.br_name, port_name]+params) # This is how port number allocation works currently # This possibly will not work correctly if there are port deletions # in between of_port = len(self._ports) + 1 self._ports[port_name] = (of_port, params) return of_port def del_port(self, port_name): """Remove port from bridge. :param port_name: Name of port :return: None """ self.logger.debug('delete port') self.run_vsctl(['del-port', self.br_name, port_name]) self._ports.pop(port_name) def set_db_attribute(self, table_name, record, column, value): """Set database attribute. :param table_name: Name of table :param record: Name of record :param column: Name of column :param value: Value to set :return: None """ self.logger.debug('set attribute') self.run_vsctl(['set', table_name, record, '%s=%s' % (column, value)]) def get_ports(self): """Get the ports of this bridge Structure of the returned ports dictionary is 'portname': (openflow_port_number, extra_parameters) Example: ports = { 'dpdkport0': (1, ['--', 'set', 'Interface', 'dpdkport0', 'type=dpdk']), 'dpdkvhostport0': (2, ['--', 'set', 'Interface', 'dpdkvhostport0', 'type=dpdkvhost']) } :return: Dictionary of ports """ return self._ports def clear_db_attribute(self, table_name, record, column): """Clear database attribute. :param table_name: Name of table :param record: Name of record :param column: Name of column :return: None """ self.logger.debug('clear attribute') self.run_vsctl(['clear', table_name, record, column]) # flow mangement def add_flow(self, flow, cache='off'): """Add flow to bridge. :param flow: Flow description as a dictionary For flow dictionary structure, see function flow_key :return: None """ # insert flows from cache into OVS if needed if cache == 'flush': if self._cache_file == None: self.logger.error('flow cache flush called, but nothing is cached') return self.logger.debug('flows cached in %s will be added to the bridge', _CACHE_FILE_NAME) self._cache_file.close() self._cache_file = None self.run_ofctl(['add-flows', self.br_name, _CACHE_FILE_NAME], timeout=600) return if not flow.get('actions'): self.logger.error('add flow requires actions') return _flow_key = flow_key(flow) self.logger.debug('key : %s', _flow_key) # insert flow to the cache or OVS if cache == 'on': # create and open cache file if needed if self._cache_file == None: self._cache_file = open(_CACHE_FILE_NAME, 'w') self._cache_file.write(_flow_key + '\n') else: self.run_ofctl(['add-flow', self.br_name, _flow_key]) def del_flow(self, flow): """Delete flow from bridge. :param flow: Flow description as a dictionary For flow dictionary structure, see function flow_key flow=None will delete all flows :return: None """ self.logger.debug('delete flow') _flow_key = flow_key(flow) self.logger.debug('key : %s', _flow_key) self.run_ofctl(['del-flows', self.br_name, _flow_key]) def del_flows(self): """Delete all flows from bridge. """ self.logger.debug('delete flows') self.run_ofctl(['del-flows', self.br_name]) def dump_flows(self): """Dump all flows from bridge. """ self.logger.debug('dump flows') self.run_ofctl(['dump-flows', self.br_name], timeout=120) # # helper functions # def flow_key(flow): """Model a flow key string for ``ovs-ofctl``. Syntax taken from ``ovs-ofctl`` manpages: http://openvswitch.org/cgi-bin/ovsman.cgi?page=utilities%2Fovs-ofctl.8 Example flow dictionary: flow = { 'in_port': '1', 'idle_timeout': '0', 'actions': ['output:3'] } :param flow: Flow description as a dictionary :return: String :rtype: str """ _flow_add_key = string.Template('${fields},action=${actions}') _flow_del_key = string.Template('${fields}') field_params = [] user_params = (x for x in list(flow.items()) if x[0] != 'actions') for (key, default) in user_params: field_params.append('%(field)s=%(value)s' % {'field': key, 'value': default}) field_params_str = ','.join(field_params) _flow_key_param = { 'fields': field_params_str, } # no actions == delete key if 'actions' in flow: _flow_key_param['actions'] = ','.join(flow['actions']) flow_str = _flow_add_key.substitute(_flow_key_param) else: flow_str = _flow_del_key.substitute(_flow_key_param) return flow_str def flow_match(flow_dump, flow_src): """ Compares two flows :param flow_dump: string - a string with flow obtained by ovs-ofctl dump-flows :param flow_src: string - a string with flow obtained by call of flow_key() :return: boolean """ # perform unifications on both source and destination flows flow_dump = flow_dump.replace('actions=', 'action=') flow_src = flow_src.replace('actions=', 'action=') # split flow strings into lists of comparable elements flow_dump_list = re.findall(r"[\w.:=()]+", flow_dump) flow_src_list = re.findall(r"[\w.:=()]+", flow_src) # check if all items from source flow are present in dump flow flow_src_ctrl = list(flow_src_list) for rule in flow_src_list: if rule in flow_dump_list: flow_src_ctrl.remove(rule) return True if not len(flow_src_ctrl) else False