Statistics
| Branch: | Tag: | Revision:

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

History | View | Annotate | Download (6 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 import common
41

    
42

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

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

    
53

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

    
58
    option_list = BaseCommand.option_list + (
59
        make_option('--jobs',
60
            action='store_true',
61
            dest='jobs',
62
            default=False,
63
            help="Show non-archived jobs concerning server."),
64
        make_option('--uuids',
65
            action='store_true',
66
            dest='use_uuids',
67
            default=False,
68
            help="Display UUIDs instead of user emails"),
69
    )
70

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

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

    
77
        try:
78
            image = common.get_image(vm.imageid, vm.userid)['name']
79
        except:
80
            image = vm.imageid
81

    
82
        sep = '-' * 80 + '\n'
83
        labels = ('name', 'owner', 'flavor', 'image', 'state', 'backend',
84
                  'deleted', 'action', 'backendjobid', 'backendopcode',
85
                  'backendjobstatus', 'backend_time')
86

    
87
        user = vm.userid
88
        if options['use_uuids'] is False:
89
            ucache = common.UUIDCache()
90
            user = ucache.get_user(vm.userid)
91

    
92
        fields = (vm.name, user, vm.flavor.name, image,
93
                  common.format_vm_state(vm), str(vm.backend),
94
                  str(vm.deleted), str(vm.action), str(vm.backendjobid),
95
                  str(vm.backendopcode), str(vm.backendjobstatus),
96
                  str(vm.backendtime))
97

    
98
        self.stdout.write(sep)
99
        self.stdout.write('State of Server in DB\n')
100
        self.stdout.write(sep)
101
        for l, f in zip(labels, fields):
102
            self.stdout.write(l.ljust(18) + ': ' + f.ljust(20) + '\n')
103
        self.stdout.write('\n')
104
        for nic in vm.nics.all():
105
            self.stdout.write("nic/%d: IPv4: %s, MAC: %s, IPv6:%s,  Network: %s\n"\
106
                              % (nic.index, nic.ipv4, nic.mac, nic.ipv6,  nic.network))
107

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

    
130
        if not options['jobs']:
131
            return
132

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