Revision 9d1e6480

b/snf-cyclades-app/synnefo/api/management/commands/floating-ip-release.py
1
# Copyright 2012 GRNET S.A. All rights reserved.
2
#
3
# Redistribution and use in source and binary forms, with or
4
# without modification, are permitted provided that the following
5
# conditions are met:
6
#
7
#   1. Redistributions of source code must retain the above
8
#      copyright notice, this list of conditions and the following
9
#      disclaimer.
10
#
11
#   2. Redistributions in binary form must reproduce the above
12
#      copyright notice, this list of conditions and the following
13
#      disclaimer in the documentation and/or other materials
14
#      provided with the distribution.
15
#
16
# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
17
# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
18
# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
19
# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
20
# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
21
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
22
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
23
# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
24
# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25
# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
26
# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
27
# POSSIBILITY OF SUCH DAMAGE.
28
#
29
# The views and conclusions contained in the software and
30
# documentation are those of the authors and should not be
31
# interpreted as representing official policies, either expressed
32
# or implied, of GRNET S.A.
33

  
34
from optparse import make_option
35

  
36
from django.db import transaction
37
from django.core.management.base import BaseCommand, CommandError
38

  
39
from synnefo.management.common import get_floating_ip_by_address
40
from synnefo import quotas
41

  
42
class Command(BaseCommand):
43
    can_import_settings = True
44
    output_transaction = True
45

  
46
    help = "Release a floating IP"
47

  
48
    @transaction.commit_on_success
49
    def handle(self, *args, **options):
50
        if not args:
51
            raise CommandError("Please provide a floating-ip address")
52

  
53
        address = args[0]
54

  
55
        floating_ip = get_floating_ip_by_address(address, for_update=True)
56
        if floating_ip.nic:
57
            # This is safe, you also need for_update to attach floating IP to
58
            # instance.
59
            msg = "Floating IP '%s' is attached to instance." % floating_ip.id
60
            raise CommandError(msg)
61

  
62
        # Return the address of the floating IP back to pool
63
        floating_ip.release_address()
64
        # And mark the floating IP as deleted
65
        floating_ip.deleted = True
66
        floating_ip.save()
67
        # Release quota for floating IP
68
        quotas.issue_and_accept_commission(floating_ip, delete=True)
69
        transaction.commit()
70
        # Delete the floating IP from DB
71
        floating_ip.delete()
72

  
73
        self.stdout.write("Deleted floating IP '%s'.\n" % address)
b/snf-cyclades-app/synnefo/api/util.py
270 270
        objects = IPAddress.objects
271 271
        if for_update:
272 272
            objects = objects.select_for_update()
273
        return objects.get(id=floating_ip_id, floating_ip=True, userid=userid,
274
                           deleted=False)
273
        if not userid:
274
            return objects.get(id=floating_ip_id, floating_ip=True,
275
                               deleted=False)
276
        else:
277
            return objects.get(id=floating_ip_id, floating_ip=True,
278
                               userid=userid, deleted=False)
275 279
    except IPAddress.DoesNotExist:
276 280
        raise faults.ItemNotFound("Floating IP %s does not exist." %
277 281
                                  floating_ip_id)
b/snf-cyclades-app/synnefo/management/common.py
32 32
# or implied, of GRNET S.A.
33 33

  
34 34
from django.core.management import CommandError
35
from synnefo.db.models import Backend, VirtualMachine, Network, Flavor, Subnet
35
from synnefo.db.models import (Backend, VirtualMachine, Network,
36
                               Flavor, IPAddress)
36 37
from functools import wraps
37 38

  
38 39
from snf_django.lib.api import faults
......
149 150
                           " available flavor IDs." % flavor_id)
150 151

  
151 152

  
153
def get_floating_ip_by_address(address, for_update=False):
154
    try:
155
        objects = IPAddress.objects
156
        if for_update:
157
            objects = objects.select_for_update()
158
        return objects.get(floating_ip=True, address=address, deleted=False)
159
    except IPAddress.DoesNotExist:
160
        raise CommandError("Floating IP does not exist.")
161

  
162

  
152 163
def check_backend_credentials(clustername, port, username, password):
153 164
    try:
154 165
        client = GanetiRapiClient(clustername, port, username, password)

Also available in: Unified diff