Statistics
| Branch: | Tag: | Revision:

root / scripts / gnt-os @ 2f79bd34

History | View | Annotate | Download (3.6 kB)

1
#!/usr/bin/python
2
#
3

    
4
# Copyright (C) 2006, 2007 Google Inc.
5
#
6
# This program is free software; you can redistribute it and/or modify
7
# it under the terms of the GNU General Public License as published by
8
# the Free Software Foundation; either version 2 of the License, or
9
# (at your option) any later version.
10
#
11
# This program is distributed in the hope that it will be useful, but
12
# WITHOUT ANY WARRANTY; without even the implied warranty of
13
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
14
# General Public License for more details.
15
#
16
# You should have received a copy of the GNU General Public License
17
# along with this program; if not, write to the Free Software
18
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
19
# 02110-1301, USA.
20

    
21

    
22
# pylint: disable-msg=W0401,W0614
23
# W0401: Wildcard import ganeti.cli
24
# W0614: Unused import %s from wildcard import (since we need cli)
25

    
26
import sys
27
from optparse import make_option
28

    
29
from ganeti.cli import *
30
from ganeti import opcodes
31
from ganeti import utils
32
from ganeti import constants
33

    
34

    
35
def ListOS(opts, args):
36
  """List the OSes existing on this node.
37

    
38
  """
39
  op = opcodes.OpDiagnoseOS(output_fields=["name", "valid"], names=[])
40
  result = SubmitOpCode(op)
41

    
42
  if not result:
43
    ToStderr("Can't get the OS list")
44
    return 1
45

    
46
  if not opts.no_headers:
47
    headers = {"name": "Name"}
48
  else:
49
    headers = None
50

    
51
  data = GenerateTable(separator=None, headers=headers, fields=["name"],
52
                       data=[[row[0]] for row in result if row[1]])
53

    
54
  for line in data:
55
    ToStdout(line)
56

    
57
  return 0
58

    
59

    
60
def DiagnoseOS(opts, args):
61
  """Analyse all OSes on this cluster.
62

    
63
  """
64
  op = opcodes.OpDiagnoseOS(output_fields=["name", "valid", "node_status"],
65
                            names=[])
66
  result = SubmitOpCode(op)
67

    
68
  if not result:
69
    ToStderr("Can't get the OS list")
70
    return 1
71

    
72
  has_bad = False
73

    
74
  for os_name, os_valid, node_data in result:
75
    nodes_valid = {}
76
    nodes_bad = {}
77
    nodes_hidden = {}
78
    for node_name, node_info in node_data.iteritems():
79
      nodes_hidden[node_name] = []
80
      if node_info: # at least one entry in the per-node list
81
        first_os_status, first_os_path = node_info.pop(0)
82
        first_os_msg = ("%s (path: %s)" %
83
                        (first_os_status, first_os_path))
84
        if first_os_status == constants.OS_VALID_STATUS:
85
          nodes_valid[node_name] = first_os_msg
86
        else:
87
          nodes_bad[node_name] = first_os_msg
88
        for hstatus, hpath in node_info:
89
          nodes_hidden[node_name].append("    [hidden] path: %s, status: %s" %
90
                                         (hpath, hstatus))
91
      else:
92
        nodes_bad[node_name] = "OS not found"
93

    
94
    if nodes_valid and not nodes_bad:
95
      status = "valid"
96
    elif not nodes_valid and nodes_bad:
97
      status = "invalid"
98
      has_bad = True
99
    else:
100
      status = "partial valid"
101
      has_bad = True
102

    
103
    def _OutputPerNodeOSStatus(msg_map):
104
      map_k = utils.NiceSort(msg_map.keys())
105
      for node_name in map_k:
106
        ToStdout("  Node: %s, status: %s", node_name, msg_map[node_name])
107
        for msg in nodes_hidden[node_name]:
108
          ToStdout(msg)
109

    
110
    ToStdout("OS: %s [global status: %s]", os_name, status)
111
    _OutputPerNodeOSStatus(nodes_valid)
112
    _OutputPerNodeOSStatus(nodes_bad)
113
    ToStdout("")
114

    
115
  return int(has_bad)
116

    
117

    
118
commands = {
119
  'list': (ListOS, ARGS_NONE, [DEBUG_OPT, NOHDR_OPT], "",
120
           "Lists all valid OSes on the master"),
121
  'diagnose': (DiagnoseOS, ARGS_NONE, [DEBUG_OPT], "",
122
               "Diagnose all OSes"),
123
  }
124

    
125
if __name__ == '__main__':
126
  sys.exit(GenericMain(commands))