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
|
# Copyright 2013 Mellanox Technologies, Ltd
#
# 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.
from networking_mlnx._i18n import _LI
from oslo_log import log as logging
from networking_mlnx.eswitchd.common import constants
LOG = logging.getLogger(__name__)
class eSwitchDB(object):
def __init__(self, pf, vfs):
self.port_table = {}
self.port_policy = {}
self.vfs = vfs
self.pf = pf
def create_port(self, port_name, port_type):
self.port_table.update({port_name: {'type': port_type,
'vnic': None,
'state': None,
'alias': None,
'device_id': None}})
def plug_nic(self, port_name):
self.port_table[port_name]['state'] = constants.VPORT_STATE_ATTACHED
LOG.info(_LI("port table:"), self.port_table)
def get_port_state(self, dev):
state = None
dev = self.port_table.get(dev)
if dev:
state = dev.get('state')
return state
def get_attached_vnics(self):
vnics = {}
for port in self.port_table.values():
vnic_mac = port['vnic']
state = port['state']
if vnic_mac and state == constants.VPORT_STATE_ATTACHED:
device_id = self.port_policy[vnic_mac]['device_id']
vnics[vnic_mac] = {'mac': vnic_mac, 'device_id': device_id}
return vnics
def get_port_policy_matrix(self):
table_matrix = [['VNIC_MAC', 'VLAN', 'DEV', 'DEVICE_ID']]
for vnic_mac, port_policy in self.port_policy.items():
table_matrix.append([vnic_mac, port_policy['vlan'],
port_policy['dev'], port_policy['device_id']])
return table_matrix
def get_port_table(self):
return self.port_table
def get_port_table_matrix(self):
table_matrix = [['PORT_NAME', 'TYPE', 'VNIC', 'STATE', 'ALIAS',
'DEVICE_ID']]
for port_name, port_data in self.port_table.items():
table_matrix.append([port_name, port_data['type'],
port_data['vnic'],
port_data['state'], port_data['alias'],
port_data['device_id']])
return table_matrix
def create_vnic(self, vnic_mac):
if not self.vnic_exists(vnic_mac):
self.port_policy.update({vnic_mac: {'vlan': None,
'dev': None,
'device_id': None,
'port_id': None}})
def get_dev_for_vnic(self, vnic_mac):
dev = None
if vnic_mac in self.port_policy:
if 'dev' in self.port_policy[vnic_mac]:
dev = self.port_policy[vnic_mac]['dev']
return dev
def vnic_exists(self, vnic_mac):
if vnic_mac in self.port_policy:
return True
else:
return False
def attach_vnic(self, port_name, device_id, vnic_mac, dev_name=None):
self.port_table[port_name]['vnic'] = vnic_mac
self.port_table[port_name]['alias'] = dev_name
self.port_table[port_name]['state'] = constants.VPORT_STATE_PENDING
self.port_table[port_name]['device_id'] = device_id
dev = self.get_dev_for_vnic(vnic_mac)
if not dev and vnic_mac != constants.INVALID_MAC:
if vnic_mac in self.port_policy:
vnic_mac_entry = self.port_policy[vnic_mac]
vnic_mac_entry['dev'] = port_name
vnic_mac_entry['device_id'] = device_id
vnic_mac_entry.setdefault('vlan', None)
else:
self.port_policy.update({vnic_mac: {'vlan': None,
'dev': port_name,
'device_id': device_id,
}})
return True
return False
def detach_vnic(self, vnic_mac):
dev = self.get_dev_for_vnic(vnic_mac)
if dev:
self.port_table[dev]['vnic'] = None
self.port_table[dev]['alias'] = None
self.port_table[dev]['state'] = constants.VPORT_STATE_UNPLUGGED
self.port_table[dev]['device_id'] = None
return dev
def port_release(self, vnic_mac):
try:
dev = self.get_dev_for_vnic(vnic_mac)
vnic = self.port_policy.pop(vnic_mac)
self.port_table[dev]['state'] = None
vnic['type'] = self.port_table[vnic['dev']]['type']
return vnic
except KeyError:
return
except IndexError:
return
def set_vlan(self, vnic_mac, vlan):
if not self.vnic_exists(vnic_mac):
self.create_vnic(vnic_mac)
self.port_policy[vnic_mac]['vlan'] = vlan
|
