Statistics
| Branch: | Tag: | Revision:

root / snf-cyclades-app / synnefo / logic / reconciliation.py @ c414bc87

History | View | Annotate | Download (10.4 kB)

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

39
Reconcile the contents of the DB with the actual state of the
40
Ganeti backend.
41

42
Let D be the set of VMs in the DB, G the set of VMs in Ganeti.
43
RULES:
44
    R1. Stale servers in DB:
45
            For any v in D but not in G:
46
            Set deleted=True.
47
    R2. Orphan instances in Ganet:
48
            For any v in G with deleted=True in D:
49
            Issue OP_INSTANCE_DESTROY.
50
    R3. Unsynced operstate:
51
            For any v whose operating state differs between G and V:
52
            Set the operating state in D based on the state in G.
53
In the code, D, G are Python dicts mapping instance ids to operating state.
54
For D, the operating state is chosen from VirtualMachine.OPER_STATES.
55
For G, the operating state is True if the machine is up, False otherwise.
56

57
"""
58

    
59
import logging
60
import sys
61
import itertools
62

    
63
from django.core.management import setup_environ
64
try:
65
    from synnefo import settings
66
except ImportError:
67
    raise Exception("Cannot import settings, make sure PYTHONPATH contains "
68
                    "the parent directory of the Synnefo Django project.")
69
setup_environ(settings)
70

    
71

    
72
from datetime import datetime, timedelta
73

    
74
from synnefo.db.models import (VirtualMachine, pooled_rapi_client)
75
from synnefo.logic.rapi import GanetiApiError
76
from synnefo.logic.backend import get_ganeti_instances, get_backends
77
from synnefo.logic import utils
78

    
79

    
80
log = logging.getLogger()
81

    
82

    
83
def stale_servers_in_db(D, G):
84
    idD = set(D.keys())
85
    idG = set(G.keys())
86

    
87
    stale = set()
88
    for i in idD - idG:
89
        if D[i] == 'BUILD':
90
            vm = VirtualMachine.objects.get(id=i)
91
            # Check time to avoid many rapi calls
92
            if datetime.now() > vm.backendtime + timedelta(seconds=5):
93
                with pooled_rapi_client(vm) as c:
94
                    try:
95
                        job_status = c.GetJobStatus(vm.backendjobid)['status']
96
                        if job_status in ('queued', 'waiting', 'running'):
97
                            # Server is still building in Ganeti
98
                            continue
99
                        else:
100
                            c.GetInstance(utils.id_to_instance_name(i))
101
                            # Server has just been created in Ganeti
102
                            continue
103
                    except GanetiApiError:
104
                        stale.add(i)
105
        else:
106
            stale.add(i)
107

    
108
    return stale
109

    
110

    
111
def orphan_instances_in_ganeti(D, G):
112
    idD = set(D.keys())
113
    idG = set(G.keys())
114

    
115
    return idG - idD
116

    
117

    
118
def unsynced_operstate(D, G):
119
    unsynced = set()
120
    idD = set(D.keys())
121
    idG = set(G.keys())
122

    
123
    for i in idD & idG:
124
        if (G[i] and D[i] != 'STARTED' or
125
            not G[i] and D[i] not in ('BUILD', 'ERROR', 'STOPPED')):
126
            unsynced.add((i, D[i], G[i]))
127
        if not G[i] and D[i] == 'BUILD':
128
            vm = VirtualMachine.objects.get(id=i)
129
            # Check time to avoid many rapi calls
130
            if datetime.now() > vm.backendtime + timedelta(seconds=5):
131
                with pooled_rapi_client(vm) as c:
132
                    try:
133
                        job_info = c.GetJobStatus(job_id=vm.backendjobid)
134
                        if job_info['status'] == 'success':
135
                            unsynced.add((i, D[i], G[i]))
136
                    except GanetiApiError:
137
                        pass
138

    
139
    return unsynced
140

    
141

    
142
def instances_with_build_errors(D, G):
143
    failed = set()
144
    idD = set(D.keys())
145
    idG = set(G.keys())
146

    
147
    for i in idD & idG:
148
        if not G[i] and D[i] == 'BUILD':
149
            vm = VirtualMachine.objects.get(id=i)
150
            # Check time to avoid many rapi calls
151
            if datetime.now() > vm.backendtime + timedelta(seconds=5):
152
                with pooled_rapi_client(vm) as c:
153
                    try:
154
                        job_info = c.GetJobStatus(job_id=vm.backendjobid)
155
                        if job_info['status'] == 'error':
156
                            failed.add(i)
157
                    except GanetiApiError:
158
                        failed.add(i)
159

    
160
    return failed
161

    
162

    
163
def get_servers_from_db(backend=None):
164
    backends = get_backends(backend)
165
    vms = VirtualMachine.objects.filter(deleted=False, backend__in=backends)
166
    return dict(map(lambda x: (x.id, x.operstate), vms))
167

    
168

    
169
def get_instances_from_ganeti(backend=None):
170
    ganeti_instances = get_ganeti_instances(backend=backend, bulk=True)
171
    snf_instances = {}
172
    snf_nics = {}
173

    
174
    prefix = settings.BACKEND_PREFIX_ID
175
    for i in ganeti_instances:
176
        if i['name'].startswith(prefix):
177
            try:
178
                id = utils.id_from_instance_name(i['name'])
179
            except Exception:
180
                log.error("Ignoring instance with malformed name %s",
181
                              i['name'])
182
                continue
183

    
184
            if id in snf_instances:
185
                log.error("Ignoring instance with duplicate Synnefo id %s",
186
                    i['name'])
187
                continue
188

    
189
            snf_instances[id] = i['oper_state']
190
            snf_nics[id] = get_nics_from_instance(i)
191

    
192
    return snf_instances, snf_nics
193

    
194
#
195
# Nics
196
#
197
def get_nics_from_ganeti(backend=None):
198
    """Get network interfaces for each ganeti instance.
199

200
    """
201
    instances = get_ganeti_instances(backend=backend, bulk=True)
202
    prefix = settings.BACKEND_PREFIX_ID
203

    
204
    snf_instances_nics = {}
205
    for i in instances:
206
        if i['name'].startswith(prefix):
207
            try:
208
                id = utils.id_from_instance_name(i['name'])
209
            except Exception:
210
                log.error("Ignoring instance with malformed name %s",
211
                              i['name'])
212
                continue
213
            if id in snf_instances_nics:
214
                log.error("Ignoring instance with duplicate Synnefo id %s",
215
                    i['name'])
216
                continue
217

    
218
            snf_instances_nics[id] = get_nics_from_instance(i)
219

    
220
    return snf_instances_nics
221

    
222

    
223
def get_nics_from_instance(i):
224
    ips = zip(itertools.repeat('ipv4'), i['nic.ips'])
225
    macs = zip(itertools.repeat('mac'), i['nic.macs'])
226
    networks = zip(itertools.repeat('network'), i['nic.networks'])
227
    # modes = zip(itertools.repeat('mode'), i['nic.modes'])
228
    # links = zip(itertools.repeat('link'), i['nic.links'])
229
    # nics = zip(ips,macs,modes,networks,links)
230
    nics = zip(ips, macs, networks)
231
    nics = map(lambda x: dict(x), nics)
232
    nics = dict(enumerate(nics))
233
    return nics
234

    
235

    
236
def get_nics_from_db(backend=None):
237
    """Get network interfaces for each vm in DB.
238

239
    """
240
    backends = get_backends(backend)
241
    instances = VirtualMachine.objects.filter(deleted=False,
242
                                              backend__in=backends)
243
    instances_nics = {}
244
    for instance in instances:
245
        nics = {}
246
        for n in instance.nics.all():
247
            ipv4 = n.ipv4
248
            nic = {'mac':      n.mac,
249
                   'network':  n.network.backend_id,
250
                   'ipv4':     ipv4 if ipv4 != '' else None
251
                   }
252
            nics[n.index] = nic
253
        instances_nics[instance.id] = nics
254
    return instances_nics
255

    
256

    
257
def unsynced_nics(DBNics, GNics):
258
    """Find unsynced network interfaces between DB and Ganeti.
259

260
    @ rtype: dict; {instance_id: ganeti_nics}
261
    @ return Dictionary containing the instances ids that have unsynced network
262
    interfaces between DB and Ganeti and the network interfaces in Ganeti.
263

264
    """
265
    idD = set(DBNics.keys())
266
    idG = set(GNics.keys())
267

    
268
    unsynced = {}
269
    for i in idD & idG:
270
        nicsD = DBNics[i]
271
        nicsG = GNics[i]
272
        if len(nicsD) != len(nicsG):
273
            unsynced[i] = (nicsD, nicsG)
274
            continue
275
        for index in nicsG.keys():
276
            nicD = nicsD[index]
277
            nicG = nicsG[index]
278
            if nicD['ipv4'] != nicG['ipv4'] or \
279
               nicD['mac'] != nicG['mac'] or \
280
               nicD['network'] != nicG['network']:
281
                unsynced[i] = (nicsD, nicsG)
282
                break
283

    
284
    return unsynced
285

    
286
#
287
# Networks
288
#
289

    
290

    
291
def get_networks_from_ganeti(backend):
292
    prefix = settings.BACKEND_PREFIX_ID + 'net-'
293

    
294
    networks = {}
295
    with pooled_rapi_client(backend) as c:
296
        for net in c.GetNetworks(bulk=True):
297
            if net['name'].startswith(prefix):
298
                id = utils.id_from_network_name(net['name'])
299
                networks[id] = net
300

    
301
    return networks
302

    
303

    
304
def hanging_networks(backend, GNets):
305
    """Get networks that are not connected to all Nodegroups.
306

307
    """
308
    def get_network_groups(group_list):
309
        groups = set()
310
        for g in group_list:
311
            g_name = g.split('(')[0]
312
            groups.add(g_name)
313
        return groups
314

    
315
    with pooled_rapi_client(backend) as c:
316
        groups = set(c.GetGroups())
317

    
318
    hanging = {}
319
    for id, info in GNets.items():
320
        group_list = get_network_groups(info['group_list'])
321
        if group_list != groups:
322
            hanging[id] = groups - group_list
323
    return hanging
324

    
325

    
326
# Only for testing this module individually
327
def main():
328
    print get_instances_from_ganeti()
329

    
330

    
331
if __name__ == "__main__":
332
    sys.exit(main())