Statistics
| Branch: | Tag: | Revision:

root / snf-cyclades-app / synnefo / api / management / commands / server-inspect.py @ 8283d6c1

History | View | Annotate | Download (6.3 kB)

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 datetime import datetime
35
from optparse import make_option
36
from django.core.management.base import BaseCommand, CommandError
37

    
38
from synnefo.lib.utils import merge_time
39
from synnefo.logic.rapi import GanetiApiError
40
from synnefo.management.common import Omit
41
from synnefo.management import common
42

    
43

    
44
# Fields to print from a gnt-instance info
45
GANETI_INSTANCE_FIELDS = ('name', 'oper_state', 'admin_state', 'status',
46
                          'pnode', 'snode', 'network_port', 'disk_template',
47
                          'disk_usage', 'oper_ram', 'oper_vcpus', 'mtime',
48
                          'nic.ips', 'nic.macs', 'nic.networks', 'nic.modes')
49

    
50
# Fields to print from a gnt-job info
51
GANETI_JOB_FIELDS = ('id', 'status', 'summary', 'opresult', 'opstatus',
52
                     'oplog', 'start_ts', 'end_ts')
53

    
54

    
55
class Command(BaseCommand):
56
    help = "Inspect a server on DB and Ganeti"
57
    args = "<server ID>"
58

    
59
    option_list = BaseCommand.option_list + (
60
        make_option('--jobs',
61
            action='store_true',
62
            dest='jobs',
63
            default=False,
64
            help="Show non-archived jobs concerning server."),
65
        make_option('--displayname',
66
            action='store_true',
67
            dest='displayname',
68
            default=False,
69
            help="Display both uuid and display name"),
70
    )
71

    
72
    def handle(self, *args, **options):
73
        if len(args) != 1:
74
            raise CommandError("Please provide a server ID")
75

    
76
        vm = common.get_vm(args[0])
77

    
78
        displayname = options['displayname']
79

    
80
        ucache = common.UserCache()
81

    
82
        try:
83
            image = common.get_image(vm.imageid, vm.userid)['name']
84
        except:
85
            image = vm.imageid
86

    
87
        sep = '-' * 80 + '\n'
88
        labels = filter(lambda x: x is not Omit,
89
                        ['name', 'owner_uuid',
90
                         'owner_name' if displayname else Omit,
91
                         'flavor', 'image', 'state', 'backend', 'deleted',
92
                         'action', 'backendjobid', 'backendopcode',
93
                         'backendjobstatus', 'backend_time'])
94

    
95
        uuid = vm.userid
96
        if displayname:
97
            dname = ucache.get_name(uuid)
98

    
99
        fields = filter(lambda x: x is not Omit,
100
                        [vm.name, uuid, dname if displayname else Omit,
101
                         vm.flavor.name, image, common.format_vm_state(vm),
102
                         str(vm.backend), str(vm.deleted), str(vm.action),
103
                         str(vm.backendjobid), str(vm.backendopcode),
104
                         str(vm.backendjobstatus), str(vm.backendtime)])
105

    
106
        self.stdout.write(sep)
107
        self.stdout.write('State of Server in DB\n')
108
        self.stdout.write(sep)
109
        for l, f in zip(labels, fields):
110
            self.stdout.write(l.ljust(18) + ': ' + f.ljust(20) + '\n')
111
        self.stdout.write('\n')
112
        for nic in vm.nics.all():
113
            self.stdout.write("nic/%d: IPv4: %s, MAC: %s, IPv6:%s,  Network: %s\n"\
114
                              % (nic.index, nic.ipv4, nic.mac, nic.ipv6,  nic.network))
115

    
116
        client = vm.get_client()
117
        try:
118
            g_vm = client.GetInstance(vm.backend_vm_id)
119
            self.stdout.write('\n')
120
            self.stdout.write(sep)
121
            self.stdout.write('State of Server in Ganeti\n')
122
            self.stdout.write(sep)
123
            for i in GANETI_INSTANCE_FIELDS:
124
                try:
125
                    value = g_vm[i]
126
                    if i.find('time') != -1:
127
                        value = datetime.fromtimestamp(value)
128
                    self.stdout.write(i.ljust(14) + ': ' + str(value) + '\n')
129
                except KeyError:
130
                    pass
131
        except GanetiApiError as e:
132
            if e.code == 404:
133
                self.stdout.write('Server does not exist in backend %s\n' %
134
                                  vm.backend.clustername)
135
            else:
136
                raise e
137

    
138
        if not options['jobs']:
139
            return
140

    
141
        self.stdout.write('\n')
142
        self.stdout.write(sep)
143
        self.stdout.write('Non-archived jobs concerning Server in Ganeti\n')
144
        self.stdout.write(sep)
145
        jobs = client.GetJobs()
146
        for j in jobs:
147
            info = client.GetJobStatus(j)
148
            summary = ' '.join(info['summary'])
149
            if summary.startswith("INSTANCE") and \
150
               summary.find(vm.backend_vm_id) != -1:
151
                for i in GANETI_JOB_FIELDS:
152
                    value = info[i]
153
                    if i.find('_ts') != -1:
154
                        value = merge_time(value)
155
                    try:
156
                        self.stdout.write(i.ljust(14) + ': ' + str(value) +\
157
                                          '\n')
158
                    except KeyError:
159
                        pass
160
                self.stdout.write('\n' + sep)
161
        # Return the RAPI client to pool
162
        vm.put_client(client)