| 30 |
30 |
from ganeti import errors
|
| 31 |
31 |
from ganeti import utils
|
| 32 |
32 |
from ganeti import constants
|
|
33 |
import logging
|
| 33 |
34 |
|
| 34 |
35 |
|
| 35 |
36 |
def _ComputeIpv4NumHosts(network_size):
|
| ... | ... | |
| 80 |
81 |
(address, network),
|
| 81 |
82 |
errors.ECODE_INVAL)
|
| 82 |
83 |
|
|
84 |
def Contains(self, address):
|
|
85 |
pass
|
|
86 |
|
|
87 |
def IsReserved(self, address):
|
|
88 |
pass
|
|
89 |
|
|
90 |
def Reserve(self, address, external):
|
|
91 |
pass
|
|
92 |
|
|
93 |
def Release(self, address, external):
|
|
94 |
pass
|
|
95 |
|
|
96 |
def GenerateFree(self):
|
|
97 |
pass
|
|
98 |
|
|
99 |
def GetStats(self):
|
|
100 |
pass
|
|
101 |
|
| 83 |
102 |
|
| 84 |
103 |
class GenericNetwork(object):
|
| 85 |
104 |
""" Base class for networks.
|
| ... | ... | |
| 145 |
164 |
return False
|
| 146 |
165 |
|
| 147 |
166 |
def IsReserved(self, address):
|
|
167 |
logging.info("Check if %s is reserved in network %s",
|
|
168 |
address, self.nobj.name)
|
| 148 |
169 |
return False
|
| 149 |
170 |
|
| 150 |
171 |
def Reserve(self, address, external):
|
| ... | ... | |
| 278 |
299 |
|
| 279 |
300 |
"""
|
| 280 |
301 |
if self.IsReserved(address):
|
| 281 |
|
raise errors.AddressPoolError("%s is already reserved" % address)
|
|
302 |
raise errors.NetworkError("%s is already reserved" % address)
|
| 282 |
303 |
self._Mark(address, external=external)
|
| 283 |
304 |
|
| 284 |
305 |
def Release(self, address, external=False):
|
| ... | ... | |
| 291 |
312 |
"""Returns the first available address.
|
| 292 |
313 |
|
| 293 |
314 |
"""
|
| 294 |
|
if self.IsFull():
|
| 295 |
|
raise errors.AddressPoolError("%s is full" % self.network)
|
|
315 |
if self._all_reservations.all():
|
|
316 |
raise errors.NetworkError("%s is full" % self.network)
|
| 296 |
317 |
|
| 297 |
|
idx = self.all_reservations.index(False)
|
|
318 |
idx = self._all_reservations.index(False)
|
| 298 |
319 |
address = str(self.network[idx])
|
| 299 |
320 |
self.Reserve(address)
|
| 300 |
321 |
return address
|
| ... | ... | |
| 302 |
323 |
def GenerateFree(self):
|
| 303 |
324 |
"""Returns the first free address of the network.
|
| 304 |
325 |
|
| 305 |
|
@raise errors.AddressPoolError: Pool is full
|
|
326 |
@raise errors.NetworkError: Pool is full
|
| 306 |
327 |
|
| 307 |
328 |
"""
|
| 308 |
329 |
idx = self._all_reservations.search(self.FREE, 1)
|