2 Copyright (c) 2017 SONATA-NFV and Paderborn University
5 Licensed under the Apache License, Version 2.0 (the "License");
6 you may not use this file except in compliance with the License.
7 You may obtain a copy of the License at
9 http://www.apache.org/licenses/LICENSE-2.0
11 Unless required by applicable law or agreed to in writing, software
12 distributed under the License is distributed on an "AS IS" BASIS,
13 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 See the License for the specific language governing permissions and
15 limitations under the License.
17 Neither the name of the SONATA-NFV, Paderborn University
18 nor the names of its contributors may be used to endorse or promote
19 products derived from this software without specific prior written
22 This work has been performed in the framework of the SONATA project,
23 funded by the European Commission under Grant number 671517 through
24 the Horizon 2020 and 5G-PPP programmes. The authors would like to
25 acknowledge the contributions of their colleagues of the SONATA
26 partner consortium (www.sonata-nfv.eu).
32 lock
= threading
.Lock()
37 def __init__(self
, name
, ip_address
=None, mac_address
=None, floating_ip
=None):
40 self
.id = str(uuid
.uuid4())
41 self
.template_name
= name
43 ip_address is structured like 10.0.0.1/24
45 self
.ip_address
= ip_address
46 self
.mac_address
= mac_address
47 self
.floating_ip
= floating_ip
50 def set_name(self
, name
):
54 :param name: New port name.
60 # Delete old interface name
63 if intf_names
[self
.intf_name
][0] == self
.id and intf_names
[self
.intf_name
][1] is False:
64 del intf_names
[self
.intf_name
]
68 # Create new interface name
69 self
.create_intf_name()
71 def create_intf_name(self
):
73 Creates the interface name, while using the first 4 letters of the port name, the specification, if it is an
74 'in' / 'out' port or something else, and a counter value if the name is already used. The counter starts
75 for each name at 0 and can go up to 999. After creating the name each port will post its interface name
76 into the global dictionary and adding his full name. Thus each port can determine if his desired interface
77 name is already used and choose the next one.
79 split_name
= self
.name
.split(':')
80 if len(split_name
) >= 3:
81 if split_name
[2] == 'input' or split_name
[2] == 'in':
82 self
.intf_name
= split_name
[0][:4] + '-' + \
84 elif split_name
[2] == 'output' or split_name
[2] == 'out':
85 self
.intf_name
= split_name
[0][:4] + '-' + \
88 self
.intf_name
= split_name
[0][:4] + '-' + \
91 self
.intf_name
= self
.name
[:9]
97 intf_len
= len(self
.intf_name
)
98 self
.intf_name
= self
.intf_name
+ '-' + str(counter
)[:4]
99 while self
.intf_name
in intf_names
and counter
< 999 and not intf_names
[self
.intf_name
][0] == self
.id:
101 self
.intf_name
= self
.intf_name
[:intf_len
] + '-' + str(counter
)[:4]
104 logging
.ERROR("Port %s could not create unique interface name (%s)", self
.name
, self
.intf_name
)
109 if self
.intf_name
in intf_names
and intf_names
[self
.intf_name
][0] == self
.id:
112 intf_names
[self
.intf_name
] = [self
.id, updated
]
115 def get_short_id(self
):
117 Gets a shortened ID which only contains first 6 characters.
119 :return: The first 6 characters of the UUID.
122 return str(self
.id)[:6]
124 def create_port_dict(self
, compute
):
126 Creates the port description dictionary.
128 :param compute: Requires the compute resource to determine the used network.
129 :type compute: :class:`heat.compute`
130 :return: Returns the description dictionary.
134 port_dict
["admin_state_up"] = True # TODO is it always true?
135 port_dict
["device_id"] = "257614cc-e178-4c92-9c61-3b28d40eca44" # TODO find real values
136 port_dict
["device_owner"] = "" # TODO do we have such things?
137 net
= compute
.find_network_by_name_or_id(self
.net_name
)
138 port_dict
["fixed_ips"] = [
140 "ip_address": self
.ip_address
.rsplit('/', 1)[0] if self
.ip_address
is not None else "",
141 "subnet_id": net
.subnet_id
if net
is not None else ""
144 port_dict
["id"] = self
.id
145 port_dict
["mac_address"] = self
.mac_address
146 port_dict
["name"] = self
.name
147 port_dict
["network_id"] = net
.id if net
is not None else ""
148 port_dict
["status"] = "ACTIVE" # TODO do we support inactive port?
149 port_dict
["tenant_id"] = "abcdefghijklmnopqrstuvwxyz123456" # TODO find real tenant_id
152 def compare_attributes(self
, other
):
154 Does NOT compare ip_address because this function only exists to check if we can
155 update the IP address without any changes
157 :param other: The port to compare with
158 :type other: :class:`heat.resources.port`
159 :return: True if the attributes are the same, else False.
165 if self
.name
== other
.name
and self
.floating_ip
== other
.floating_ip
and \
166 self
.net_name
== other
.net_name
:
170 def __eq__(self
, other
):
174 if self
.name
== other
.name
and self
.ip_address
== other
.ip_address
and \
175 self
.mac_address
== other
.mac_address
and \
176 self
.floating_ip
== other
.floating_ip
and \
177 self
.net_name
== other
.net_name
:
182 return hash((self
.name
,
192 if self
.intf_name
in intf_names
and intf_names
[self
.intf_name
][0] == self
.id:
193 if intf_names
[self
.intf_name
][1] is False:
194 del intf_names
[self
.intf_name
]
196 intf_names
[self
.intf_name
][1] = False