Synnefo » snf-ganeti

#

#

# Copyright (C) 2007 Google Inc.

#

# This program is free software; you can redistribute it and/or modify

# it under the terms of the GNU General Public License as published by

# the Free Software Foundation; either version 2 of the License, or

# (at your option) any later version.

#

# This program is distributed in the hope that it will be useful, but

# WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU

# General Public License for more details.

#

# You should have received a copy of the GNU General Public License

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA

# 02110-1301, USA.

"""Cluster environment related QA tests.

"""

from ganeti import utils

import qa_config

import qa_utils

from qa_utils import AssertEqual, StartSSH

def TestSshConnection():

  """Test SSH connection.

  """

  for node in qa_config.get('nodes'):

    AssertEqual(StartSSH(node['primary'], 'exit').wait(), 0)

def TestGanetiCommands():

  """Test availibility of Ganeti commands.

  """

  cmds = ( ['gnt-backup', '--version'],

           ['gnt-cluster', '--version'],

           ['gnt-debug', '--version'],

           ['gnt-instance', '--version'],

           ['gnt-job', '--version'],

           ['gnt-node', '--version'],

           ['gnt-os', '--version'],

           ['ganeti-masterd', '--version'],

           ['ganeti-noded', '--version'],

           ['ganeti-rapi', '--version'],

           ['ganeti-watcher', '--version'] )

  cmd = ' && '.join([utils.ShellQuoteArgs(i) for i in cmds])

  for node in qa_config.get('nodes'):

    AssertEqual(StartSSH(node['primary'], cmd).wait(), 0)

def TestIcmpPing():

  """ICMP ping each node.

  """

  nodes = qa_config.get('nodes')

  for node in nodes:

    check = []

    for i in nodes:

      check.append(i['primary'])

      if i.has_key('secondary'):

        check.append(i['secondary'])

    ping = lambda ip: utils.ShellQuoteArgs(['ping', '-w', '3', '-c', '1', ip])

    cmd = ' && '.join([ping(i) for i in check])

    AssertEqual(StartSSH(node['primary'], cmd).wait(), 0)