Statistics
| Branch: | Tag: | Revision:

root / logic / utils.py @ 583bfaa0

History | View | Annotate | Download (3.7 kB)

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

    
30
# Utility functions
31

    
32
from synnefo.db.models import VirtualMachine
33
from synnefo.logic import credits
34

    
35
import synnefo.settings as settings
36

    
37
def id_from_instance_name(name):
38
    """Returns VirtualMachine's Django id, given a ganeti machine name.
39

40
    Strips the ganeti prefix atm. Needs a better name!
41

42
    """
43
    if not str(name).startswith(settings.BACKEND_PREFIX_ID):
44
        raise VirtualMachine.InvalidBackendIdError(str(name))
45
    ns = str(name).lstrip(settings.BACKEND_PREFIX_ID)
46
    if not ns.isdigit():
47
        raise VirtualMachine.InvalidBackendIdError(str(name))
48

    
49
    return int(ns)
50

    
51
def get_rsapi_state(vm):
52
    """Returns the API state for a virtual machine
53
    
54
    The API state for an instance of VirtualMachine is derived as follows:
55

56
    * If the deleted flag has been set, it is "DELETED".
57
    * Otherwise, it is a mapping of the last state reported by Ganeti
58
      (vm.operstate) through the RSAPI_STATE_FROM_OPER_STATE dictionary.
59
      
60
      The last state reported by Ganeti is set whenever Ganeti reports
61
      successful completion of an operation. If Ganeti says an OP_INSTANCE_STARTUP
62
      operation succeeded, vm.operstate is set to "STARTED".
63

64
    * To support any transitional states defined by the API (only REBOOT for the time
65
      being) this mapping is amended with information reported by Ganeti regarding
66
      any outstanding operation. If an OP_INSTANCE_STARTUP had succeeded previously
67
      and an OP_INSTANCE_REBOOT has been reported as in progress, the API state is
68
      "REBOOT".
69

70
    """
71
    try:
72
        r = VirtualMachine.RSAPI_STATE_FROM_OPER_STATE[vm.operstate]
73
    except KeyError:
74
        return "UNKNOWN"
75
    # A machine is DELETED if the deleted flag has been set
76
    if vm.deleted:
77
        return "DELETED"
78
    # A machine is in REBOOT if an OP_INSTANCE_REBOOT request is in progress
79
    if r == 'ACTIVE' and vm.backendopcode == 'OP_INSTANCE_REBOOT' and \
80
        vm.backendjobstatus in ('queued', 'waiting', 'running'):
81
        return "REBOOT"
82
    return r
83

    
84
def update_state(vm, new_operstate):
85
    """Wrapper around updates of the VirtualMachine.operstate field"""
86

    
87
    # Call charge() unconditionally before any change of
88
    # internal state.
89
    credits.charge(vm)
90
    vm.operstate = new_operstate