code.grnet.gr Git - ganeti-local/blob - qa/qa_os.py

   1 #
   2 #
   3
   4 # Copyright (C) 2007, 2008, 2009, 2010, 2011 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 """OS related QA tests.
  23
  24 """
  25
  26 import os
  27 import os.path
  28
  29 from ganeti import utils
  30 from ganeti import constants
  31
  32 import qa_config
  33 import qa_utils
  34 import qa_error
  35
  36 from qa_utils import AssertCommand, AssertIn, AssertNotIn
  37
  38
  39 _TEMP_OS_NAME = "TEMP-Ganeti-QA-OS"
  40 _TEMP_OS_PATH = os.path.join(constants.OS_SEARCH_PATH[0], _TEMP_OS_NAME)
  41
  42 (_ALL_VALID,
  43  _ALL_INVALID,
  44  _PARTIALLY_VALID) = range(1, 4)
  45
  46
  47 def TestOsList():
  48   """gnt-os list"""
  49   AssertCommand(["gnt-os", "list"])
  50
  51
  52 def TestOsDiagnose():
  53   """gnt-os diagnose"""
  54   AssertCommand(["gnt-os", "diagnose"])
  55
  56
  57 def _TestOsModify(hvp_dict, fail=False):
  58   """gnt-os modify"""
  59   cmd = ["gnt-os", "modify"]
  60
  61   for hv_name, hv_params in hvp_dict.items():
  62     cmd.append("-H")
  63     options = []
  64     for key, value in hv_params.items():
  65       options.append("%s=%s" % (key, value))
  66     cmd.append("%s:%s" % (hv_name, ",".join(options)))
  67
  68   cmd.append(_TEMP_OS_NAME)
  69   AssertCommand(cmd, fail=fail)
  70
  71
  72 def _TestOsStates(os_name):
  73   """gnt-os modify, more stuff"""
  74   cmd = ["gnt-os", "modify"]
  75
  76   for param in ["hidden", "blacklisted"]:
  77     for val in ["yes", "no"]:
  78       new_cmd = cmd + ["--%s" % param, val, os_name]
  79       AssertCommand(new_cmd)
  80       # check that double-running the command is OK
  81       AssertCommand(new_cmd)
  82
  83
  84 def _SetupTempOs(node, dirname, valid):
  85   """Creates a temporary OS definition on the given node.
  86
  87   """
  88   sq = utils.ShellQuoteArgs
  89   parts = [sq(["rm", "-rf", dirname]),
  90            sq(["mkdir", "-p", dirname]),
  91            sq(["cd", dirname]),
  92            sq(["ln", "-fs", "/bin/true", "export"]),
  93            sq(["ln", "-fs", "/bin/true", "import"]),
  94            sq(["ln", "-fs", "/bin/true", "rename"])]
  95
  96   if valid:
  97     parts.append(sq(["ln", "-fs", "/bin/true", "create"]))
  98
  99   parts.append(sq(["echo", str(constants.OS_API_V10)]) +
 100                " >ganeti_api_version")
 101
 102   cmd = " && ".join(parts)
 103
 104   print qa_utils.FormatInfo("Setting up %s with %s OS definition" %
 105                             (node["primary"],
 106                              ["an invalid", "a valid"][int(valid)]))
 107
 108   AssertCommand(cmd, node=node)
 109
 110
 111 def _RemoveTempOs(node, dirname):
 112   """Removes a temporary OS definition.
 113
 114   """
 115   AssertCommand(["rm", "-rf", dirname], node=node)
 116
 117
 118 def _TestOs(mode, rapi_cb):
 119   """Generic function for OS definition testing
 120
 121   """
 122   master = qa_config.GetMasterNode()
 123
 124   name = _TEMP_OS_NAME
 125   dirname = _TEMP_OS_PATH
 126
 127   # Ensure OS is usable
 128   cmd = ["gnt-os", "modify", "--hidden=no", "--blacklisted=no", name]
 129   AssertCommand(cmd)
 130
 131   nodes = []
 132   try:
 133     for i, node in enumerate(qa_config.get("nodes")):
 134       nodes.append(node)
 135       if mode == _ALL_INVALID:
 136         valid = False
 137       elif mode == _ALL_VALID:
 138         valid = True
 139       elif mode == _PARTIALLY_VALID:
 140         valid = bool(i % 2)
 141       else:
 142         raise AssertionError("Unknown mode %s" % mode)
 143       _SetupTempOs(node, dirname, valid)
 144
 145     # TODO: Use Python 2.6's itertools.permutations
 146     for (hidden, blacklisted) in [(False, False), (True, False),
 147                                   (False, True), (True, True)]:
 148       # Change OS' visibility
 149       cmd = ["gnt-os", "modify", "--hidden", ["no", "yes"][int(hidden)],
 150              "--blacklisted", ["no", "yes"][int(blacklisted)], name]
 151       AssertCommand(cmd)
 152
 153       # Diagnose, checking exit status
 154       AssertCommand(["gnt-os", "diagnose"], fail=(mode != _ALL_VALID))
 155
 156       # Diagnose again, ignoring exit status
 157       output = qa_utils.GetCommandOutput(master["primary"],
 158                                          "gnt-os diagnose || :")
 159       for line in output.splitlines():
 160         if line.startswith("OS: %s [global status:" % name):
 161           break
 162       else:
 163         raise qa_error.Error("Didn't find OS '%s' in 'gnt-os diagnose'" % name)
 164
 165       # Check info for all
 166       cmd = ["gnt-os", "info"]
 167       output = qa_utils.GetCommandOutput(master["primary"],
 168                                          utils.ShellQuoteArgs(cmd))
 169       AssertIn("%s:" % name, output.splitlines())
 170
 171       # Check info for OS
 172       cmd = ["gnt-os", "info", name]
 173       output = qa_utils.GetCommandOutput(master["primary"],
 174                                          utils.ShellQuoteArgs(cmd)).splitlines()
 175       AssertIn("%s:" % name, output)
 176       for (field, value) in [("valid", mode == _ALL_VALID),
 177                              ("hidden", hidden),
 178                              ("blacklisted", blacklisted)]:
 179         AssertIn("  - %s: %s" % (field, value), output)
 180
 181       # Only valid OSes should be listed
 182       cmd = ["gnt-os", "list", "--no-headers"]
 183       output = qa_utils.GetCommandOutput(master["primary"],
 184                                          utils.ShellQuoteArgs(cmd))
 185       if mode == _ALL_VALID and not (hidden or blacklisted):
 186         assert_fn = AssertIn
 187       else:
 188         assert_fn = AssertNotIn
 189       assert_fn(name, output.splitlines())
 190
 191       # Check via RAPI
 192       if rapi_cb:
 193         assert_fn(name, rapi_cb())
 194   finally:
 195     for node in nodes:
 196       _RemoveTempOs(node, dirname)
 197
 198
 199 def TestOsValid(rapi_cb):
 200   """Testing valid OS definition"""
 201   return _TestOs(_ALL_VALID, rapi_cb)
 202
 203
 204 def TestOsInvalid(rapi_cb):
 205   """Testing invalid OS definition"""
 206   return _TestOs(_ALL_INVALID, rapi_cb)
 207
 208
 209 def TestOsPartiallyValid(rapi_cb):
 210   """Testing partially valid OS definition"""
 211   return _TestOs(_PARTIALLY_VALID, rapi_cb)
 212
 213
 214 def TestOsModifyValid():
 215   """Testing a valid os modify invocation"""
 216   hv_dict = {
 217     constants.HT_XEN_PVM: {
 218       constants.HV_ROOT_PATH: "/dev/sda5",
 219       },
 220     constants.HT_XEN_HVM: {
 221       constants.HV_ACPI: False,
 222       constants.HV_PAE: True,
 223       },
 224     }
 225
 226   return _TestOsModify(hv_dict)
 227
 228
 229 def TestOsModifyInvalid():
 230   """Testing an invalid os modify invocation"""
 231   hv_dict = {
 232     "blahblahblubb": {"bar": ""},
 233     }
 234
 235   return _TestOsModify(hv_dict, fail=True)
 236
 237
 238 def TestOsStatesNonExisting():
 239   """Testing OS states with non-existing OS"""
 240   AssertCommand(["test", "-e", _TEMP_OS_PATH], fail=True)
 241   return _TestOsStates(_TEMP_OS_NAME)