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

   1 #
   2 #
   3
   4 # Copyright (C) 2007, 2010, 2011, 2012 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 """Cluster environment related QA tests.
  23
  24 """
  25
  26 from ganeti import utils
  27
  28 import qa_config
  29
  30 from qa_utils import AssertCommand
  31
  32
  33 def TestSshConnection():
  34   """Test SSH connection.
  35
  36   """
  37   for node in qa_config.get("nodes"):
  38     AssertCommand("exit", node=node)
  39
  40
  41 def TestGanetiCommands():
  42   """Test availibility of Ganeti commands.
  43
  44   """
  45   cmds = (["gnt-backup", "--version"],
  46           ["gnt-cluster", "--version"],
  47           ["gnt-debug", "--version"],
  48           ["gnt-instance", "--version"],
  49           ["gnt-job", "--version"],
  50           ["gnt-node", "--version"],
  51           ["gnt-os", "--version"],
  52           ["ganeti-masterd", "--version"],
  53           ["ganeti-noded", "--version"],
  54           ["ganeti-rapi", "--version"],
  55           ["ganeti-watcher", "--version"],
  56           ["ganeti-confd", "--version"],
  57           ["ganeti-queryd", "--version"],
  58           )
  59
  60   cmd = " && ".join([utils.ShellQuoteArgs(i) for i in cmds])
  61
  62   for node in qa_config.get("nodes"):
  63     AssertCommand(cmd, node=node)
  64
  65
  66 def TestIcmpPing():
  67   """ICMP ping each node.
  68
  69   """
  70   nodes = qa_config.get("nodes")
  71
  72   pingprimary = pingsecondary = "fping"
  73   if qa_config.get("primary_ip_version") == 6:
  74     pingprimary = "fping6"
  75
  76   pricmd = [pingprimary, "-e"]
  77   seccmd = [pingsecondary, "-e"]
  78   for i in nodes:
  79     pricmd.append(i.primary)
  80     if i.secondary:
  81       seccmd.append(i.secondary)
  82
  83   pristr = utils.ShellQuoteArgs(pricmd)
  84   if seccmd:
  85     cmdall = "%s && %s" % (pristr, utils.ShellQuoteArgs(seccmd))
  86   else:
  87     cmdall = pristr
  88
  89   for node in nodes:
  90     AssertCommand(cmdall, node=node)