Commit 9bd87a12 authored by Alex Pyrgiotis's avatar Alex Pyrgiotis
Browse files

cyclades: Add validate function for IP actions

Use this function to verify that an IP can be deleted. The rationale
behind getting the delete check out of the `delete_floating_ip` action
is to make it easy for other apps to import it.
parent dd0718f5
......@@ -14,6 +14,7 @@
# along with this program. If not, see <>.
import logging
import functools
from snf_django.lib.api import faults
from django.db import transaction
......@@ -23,6 +24,64 @@ from synnefo.db.models import (IPPoolTable, IPAddress, Network)
log = logging.getLogger(__name__)
def validate_ip_action(ip, action, silent=True):
"""Check if an action can apply on an IP address.
ip: The target IP address.
action: The name of the action (in capital letters).
silent: If set to True, suppress exceptions.
A `(success, message)` tuple. `success` is a boolean value that
shows if the action can apply on an IP, and `message` explains
why the action cannot apply on an IP.
If an action can apply on an IP, this function will always return
`(True, None)`.
faults.Conflict: When the action cannot apply on an ip due to a
faults.BadRequest: When the action is unknown/malformed.
def fail(e=Exception, msg=""):
if silent:
return False, msg
raise e(msg)
if action == "DELETE":
if ip.nic:
# This is safe, you also need for_update to attach floating IP to
# instance.
server = ip.nic.machine
if server is None:
msg = ("IP '%s' is used by port '%s'" % (, ip.nic_id))
msg = ("IP '%s' is used by server '%s'" %
(, ip.nic.machine_id))
return fail(faults.Conflict, msg)
elif action == "REASSIGN":
return fail(faults.BadRequest, "Unknown action: {}.".format(action))
return True, None
def ip_command(action):
"""Common wrapper for IP commands."""
def decorator(func):
def wrapper(ip, *args, **kwargs):
validate_ip_action(ip, action, silent=False)
return func(ip, *args, **kwargs)
return wrapper
return decorator
def allocate_ip_from_pools(pool_rows, userid, address=None, floating_ip=False):
"""Try to allocate a value from a number of pools.
......@@ -91,7 +150,6 @@ def allocate_public_ip(userid, floating_ip=False, backend=None, networks=None):
be used.
ip_pool_rows = IPPoolTable.objects.select_for_update()\
......@@ -183,20 +241,8 @@ def get_free_floating_ip(userid, network=None):
raise faults.Conflict(msg)
def delete_floating_ip(floating_ip):
if floating_ip.nic:
# This is safe, you also need for_update to attach floating IP to
# instance.
server = floating_ip.nic.machine
if server is None:
msg = ("Floating IP '%s' is used by port '%s'" %
(, floating_ip.nic_id))
msg = ("Floating IP '%s' is used by server '%s'" %
(, floating_ip.nic.machine_id))
raise faults.Conflict(msg)
# Lock network to prevent deadlock
......@@ -214,7 +260,7 @@ def delete_floating_ip(floating_ip):
def reassign_floating_ip(floating_ip, project):
action_fields = {"to_project": project,
"from_project": floating_ip.project}
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment