Statistics
| Branch: | Tag: | Revision:

root / snf-cyclades-app / synnefo / logic / networks.py @ ff5edb80

History | View | Annotate | Download (6.5 kB)

1
# Copyright 2011-2014 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 functools import wraps
35
from django.db import transaction
36
from django.conf import settings
37

    
38
from snf_django.lib.api import faults
39
from synnefo.api import util
40
from synnefo import quotas
41
from synnefo.db.models import Network, Backend
42
from synnefo.db.utils import validate_mac
43
from synnefo.db.pools import EmptyPool
44
from synnefo.logic import backend as backend_mod
45
from synnefo.logic import utils
46

    
47
from logging import getLogger
48
log = getLogger(__name__)
49

    
50

    
51
def validate_network_action(network, action):
52
    if network.deleted:
53
        raise faults.BadRequest("Network has been deleted.")
54

    
55

    
56
def network_command(action):
57
    def decorator(func):
58
        @wraps(func)
59
        @transaction.commit_on_success()
60
        def wrapper(network, *args, **kwargs):
61
            validate_network_action(network, action)
62
            return func(network, *args, **kwargs)
63
        return wrapper
64
    return decorator
65

    
66

    
67
@transaction.commit_on_success
68
def create(userid, name, flavor, link=None, mac_prefix=None, mode=None,
69
           floating_ip_pool=False, tags=None, public=False, drained=False,
70
           project=None):
71
    if flavor is None:
72
        raise faults.BadRequest("Missing request parameter 'type'")
73
    elif flavor not in Network.FLAVORS.keys():
74
        raise faults.BadRequest("Invalid network type '%s'" % flavor)
75

    
76
    if mac_prefix is not None and flavor == "MAC_FILTERED":
77
        raise faults.BadRequest("Cannot override MAC_FILTERED mac-prefix")
78
    if link is not None and flavor == "PHYSICAL_VLAN":
79
        raise faults.BadRequest("Cannot override PHYSICAL_VLAN link")
80

    
81
    utils.check_name_length(name, Network.NETWORK_NAME_LENGTH, "Network name "
82
                            "is too long")
83

    
84
    try:
85
        fmode, flink, fmac_prefix, ftags = util.values_from_flavor(flavor)
86
    except EmptyPool:
87
        log.error("Failed to allocate resources for network of type: %s",
88
                  flavor)
89
        msg = "Failed to allocate resources for network."
90
        raise faults.ServiceUnavailable(msg)
91

    
92
    mode = mode or fmode
93
    link = link or flink
94
    mac_prefix = mac_prefix or fmac_prefix
95
    tags = tags or ftags
96

    
97
    validate_mac(mac_prefix + "0:00:00:00")
98

    
99
    # Check that given link is unique!
100
    if (link is not None and flavor == "IP_LESS_ROUTED" and
101
       Network.objects.filter(deleted=False, mode=mode, link=link).exists()):
102
        msg = "Link '%s' is already used." % link
103
        raise faults.BadRequest(msg)
104

    
105
    if project is None:
106
        project = userid
107

    
108
    network = Network.objects.create(
109
        name=name,
110
        userid=userid,
111
        project=project,
112
        flavor=flavor,
113
        mode=mode,
114
        link=link,
115
        mac_prefix=mac_prefix,
116
        tags=tags,
117
        public=public,
118
        external_router=public,
119
        floating_ip_pool=floating_ip_pool,
120
        action='CREATE',
121
        state='ACTIVE',
122
        drained=drained)
123

    
124
    if link is None:
125
        network.link = "%slink-%d" % (settings.BACKEND_PREFIX_ID, network.id)
126
        network.save()
127

    
128
    # Issue commission to Quotaholder and accept it since at the end of
129
    # this transaction the Network object will be created in the DB.
130
    # Note: the following call does a commit!
131
    if not public:
132
        quotas.issue_and_accept_commission(network)
133

    
134
    return network
135

    
136

    
137
def create_network_in_backends(network):
138
    job_ids = []
139
    for bend in Backend.objects.filter(offline=False):
140
        network.create_backend_network(bend)
141
        jobs = backend_mod.create_network(network=network, backend=bend,
142
                                          connect=True)
143
        job_ids.extend(jobs)
144
    return job_ids
145

    
146

    
147
@network_command("RENAME")
148
def rename(network, name):
149
    network.name = name
150
    network.save()
151
    return network
152

    
153

    
154
@network_command("DESTROY")
155
def delete(network):
156
    if network.nics.exists():
157
        raise faults.Conflict("Cannot delete network. There are ports still"
158
                              " configured on network network %s" % network.id)
159
    if network.ips.filter(deleted=False, floating_ip=True).exists():
160
        msg = "Cannot delete netowrk. Network has allocated floating IPs."
161
        raise faults.Conflict(msg)
162

    
163
    network.action = "DESTROY"
164
    # Mark network as drained to prevent automatic allocation of
165
    # public/floating IPs while the network is being deleted
166
    if network.public:
167
        network.drained = True
168
    network.save()
169

    
170
    # Delete network to all backends that exists
171
    for bnet in network.backend_networks.exclude(operstate="DELETED"):
172
        backend_mod.delete_network(network, bnet.backend)
173
    else:
174
        # If network does not exist in any backend, update the network state
175
        backend_mod.update_network_state(network)
176
    return network
177

    
178

    
179
@network_command("REASSIGN")
180
def reassign(network, project):
181
    action_fields = {"to_project": project, "from_project": network.project}
182
    network.project = project
183
    network.save()
184
    quotas.issue_and_accept_commission(network, action="REASSIGN",
185
                                       action_fields=action_fields)
186
    return network