summaryrefslogtreecommitdiffstats
path: root/cts/lab/CTSscenarios.py
diff options
context:
space:
mode:
Diffstat (limited to 'cts/lab/CTSscenarios.py')
-rw-r--r--cts/lab/CTSscenarios.py563
1 files changed, 0 insertions, 563 deletions
diff --git a/cts/lab/CTSscenarios.py b/cts/lab/CTSscenarios.py
deleted file mode 100644
index 37cb094..0000000
--- a/cts/lab/CTSscenarios.py
+++ /dev/null
@@ -1,563 +0,0 @@
-""" Test scenario classes for Pacemaker's Cluster Test Suite (CTS)
-"""
-
-__copyright__ = "Copyright 2000-2023 the Pacemaker project contributors"
-__license__ = "GNU General Public License version 2 or later (GPLv2+) WITHOUT ANY WARRANTY"
-
-import os
-import re
-import sys
-import time
-
-from cts.CTStests import CTSTest
-from cts.CTSaudits import ClusterAudit
-
-from pacemaker._cts.watcher import LogWatcher
-
-class ScenarioComponent(object):
-
- def __init__(self, Env):
- self.Env = Env
-
- def IsApplicable(self):
- '''Return True if the current ScenarioComponent is applicable
- in the given LabEnvironment given to the constructor.
- '''
-
- raise ValueError("Abstract Class member (IsApplicable)")
-
- def SetUp(self, CM):
- '''Set up the given ScenarioComponent'''
- raise ValueError("Abstract Class member (Setup)")
-
- def TearDown(self, CM):
- '''Tear down (undo) the given ScenarioComponent'''
- raise ValueError("Abstract Class member (Setup)")
-
-
-class Scenario(object):
- (
-'''The basic idea of a scenario is that of an ordered list of
-ScenarioComponent objects. Each ScenarioComponent is SetUp() in turn,
-and then after the tests have been run, they are torn down using TearDown()
-(in reverse order).
-
-A Scenario is applicable to a particular cluster manager iff each
-ScenarioComponent is applicable.
-
-A partially set up scenario is torn down if it fails during setup.
-''')
-
- def __init__(self, ClusterManager, Components, Audits, Tests):
-
- "Initialize the Scenario from the list of ScenarioComponents"
-
- self.ClusterManager = ClusterManager
- self.Components = Components
- self.Audits = Audits
- self.Tests = Tests
-
- self.BadNews = None
- self.TestSets = []
- self.Stats = {"success":0, "failure":0, "BadNews":0, "skipped":0}
- self.Sets = []
-
- #self.ns=CTS.NodeStatus(self.Env)
-
- for comp in Components:
- if not issubclass(comp.__class__, ScenarioComponent):
- raise ValueError("Init value must be subclass of ScenarioComponent")
-
- for audit in Audits:
- if not issubclass(audit.__class__, ClusterAudit):
- raise ValueError("Init value must be subclass of ClusterAudit")
-
- for test in Tests:
- if not issubclass(test.__class__, CTSTest):
- raise ValueError("Init value must be a subclass of CTSTest")
-
- def IsApplicable(self):
- (
-'''A Scenario IsApplicable() iff each of its ScenarioComponents IsApplicable()
-'''
- )
-
- for comp in self.Components:
- if not comp.IsApplicable():
- return None
- return True
-
- def SetUp(self):
- '''Set up the Scenario. Return TRUE on success.'''
-
- self.ClusterManager.prepare()
- self.audit() # Also detects remote/local log config
- self.ClusterManager.ns.wait_for_all_nodes(self.ClusterManager.Env["nodes"])
-
- self.audit()
- self.ClusterManager.install_support()
-
- self.BadNews = LogWatcher(self.ClusterManager.Env["LogFileName"],
- self.ClusterManager.templates.get_patterns("BadNews"),
- self.ClusterManager.Env["nodes"],
- self.ClusterManager.Env["LogWatcher"],
- "BadNews", 0)
- self.BadNews.set_watch() # Call after we've figured out what type of log watching to do in LogAudit
-
- j = 0
- while j < len(self.Components):
- if not self.Components[j].SetUp(self.ClusterManager):
- # OOPS! We failed. Tear partial setups down.
- self.audit()
- self.ClusterManager.log("Tearing down partial setup")
- self.TearDown(j)
- return None
- j = j + 1
-
- self.audit()
- return 1
-
- def TearDown(self, max=None):
-
- '''Tear Down the Scenario - in reverse order.'''
-
- if max == None:
- max = len(self.Components)-1
- j = max
- while j >= 0:
- self.Components[j].TearDown(self.ClusterManager)
- j = j - 1
-
- self.audit()
- self.ClusterManager.install_support("uninstall")
-
- def incr(self, name):
- '''Increment (or initialize) the value associated with the given name'''
- if not name in self.Stats:
- self.Stats[name] = 0
- self.Stats[name] = self.Stats[name]+1
-
- def run(self, Iterations):
- self.ClusterManager.oprofileStart()
- try:
- self.run_loop(Iterations)
- self.ClusterManager.oprofileStop()
- except:
- self.ClusterManager.oprofileStop()
- raise
-
- def run_loop(self, Iterations):
- raise ValueError("Abstract Class member (run_loop)")
-
- def run_test(self, test, testcount):
- nodechoice = self.ClusterManager.Env.random_node()
-
- ret = 1
- where = ""
- did_run = 0
-
- self.ClusterManager.instance_errorstoignore_clear()
- self.ClusterManager.log(("Running test %s" % test.name).ljust(35) + (" (%s) " % nodechoice).ljust(15) + "[" + ("%d" % testcount).rjust(3) + "]")
-
- starttime = test.set_timer()
- if not test.setup(nodechoice):
- self.ClusterManager.log("Setup failed")
- ret = 0
-
- elif not test.canrunnow(nodechoice):
- self.ClusterManager.log("Skipped")
- test.skipped()
-
- else:
- did_run = 1
- ret = test(nodechoice)
-
- if not test.teardown(nodechoice):
- self.ClusterManager.log("Teardown failed")
- if self.ClusterManager.Env["continue"]:
- answer = "Y"
- else:
- try:
- answer = input('Continue? [nY]')
- except EOFError as e:
- answer = "n"
- if answer and answer == "n":
- raise ValueError("Teardown of %s on %s failed" % (test.name, nodechoice))
- ret = 0
-
- stoptime = time.time()
- self.ClusterManager.oprofileSave(testcount)
-
- elapsed_time = stoptime - starttime
- test_time = stoptime - test.get_timer()
- if not test["min_time"]:
- test["elapsed_time"] = elapsed_time
- test["min_time"] = test_time
- test["max_time"] = test_time
- else:
- test["elapsed_time"] = test["elapsed_time"] + elapsed_time
- if test_time < test["min_time"]:
- test["min_time"] = test_time
- if test_time > test["max_time"]:
- test["max_time"] = test_time
-
- if ret:
- self.incr("success")
- test.log_timer()
- else:
- self.incr("failure")
- self.ClusterManager.statall()
- did_run = 1 # Force the test count to be incremented anyway so test extraction works
-
- self.audit(test.errorstoignore())
- return did_run
-
- def summarize(self):
- self.ClusterManager.log("****************")
- self.ClusterManager.log("Overall Results:" + repr(self.Stats))
- self.ClusterManager.log("****************")
-
- stat_filter = {
- "calls":0,
- "failure":0,
- "skipped":0,
- "auditfail":0,
- }
- self.ClusterManager.log("Test Summary")
- for test in self.Tests:
- for key in list(stat_filter.keys()):
- stat_filter[key] = test.Stats[key]
- self.ClusterManager.log(("Test %s: "%test.name).ljust(25) + " %s"%repr(stat_filter))
-
- self.ClusterManager.debug("Detailed Results")
- for test in self.Tests:
- self.ClusterManager.debug(("Test %s: "%test.name).ljust(25) + " %s"%repr(test.Stats))
-
- self.ClusterManager.log("<<<<<<<<<<<<<<<< TESTS COMPLETED")
-
- def audit(self, LocalIgnore=[]):
- errcount = 0
- ignorelist = []
- ignorelist.append("CTS:")
- ignorelist.extend(LocalIgnore)
- ignorelist.extend(self.ClusterManager.errorstoignore())
- ignorelist.extend(self.ClusterManager.instance_errorstoignore())
-
- # This makes sure everything is stabilized before starting...
- failed = 0
- for audit in self.Audits:
- if not audit():
- self.ClusterManager.log("Audit " + audit.name() + " FAILED.")
- failed += 1
- else:
- self.ClusterManager.debug("Audit " + audit.name() + " passed.")
-
- while errcount < 1000:
- match = None
- if self.BadNews:
- match = self.BadNews.look(0)
-
- if match:
- add_err = 1
- for ignore in ignorelist:
- if add_err == 1 and re.search(ignore, match):
- add_err = 0
- if add_err == 1:
- self.ClusterManager.log("BadNews: " + match)
- self.incr("BadNews")
- errcount = errcount + 1
- else:
- break
- else:
- if self.ClusterManager.Env["continue"]:
- answer = "Y"
- else:
- try:
- answer = input('Big problems. Continue? [nY]')
- except EOFError as e:
- answer = "n"
- if answer and answer == "n":
- self.ClusterManager.log("Shutting down.")
- self.summarize()
- self.TearDown()
- raise ValueError("Looks like we hit a BadNews jackpot!")
-
- if self.BadNews:
- self.BadNews.end()
- return failed
-
-
-class AllOnce(Scenario):
- '''Every Test Once''' # Accessable as __doc__
- def run_loop(self, Iterations):
- testcount = 1
- for test in self.Tests:
- self.run_test(test, testcount)
- testcount += 1
-
-
-class RandomTests(Scenario):
- '''Random Test Execution'''
- def run_loop(self, Iterations):
- testcount = 1
- while testcount <= Iterations:
- test = self.ClusterManager.Env.random_gen.choice(self.Tests)
- self.run_test(test, testcount)
- testcount += 1
-
-
-class BasicSanity(Scenario):
- '''Basic Cluster Sanity'''
- def run_loop(self, Iterations):
- testcount = 1
- while testcount <= Iterations:
- test = self.Environment.random_gen.choice(self.Tests)
- self.run_test(test, testcount)
- testcount += 1
-
-
-class Sequence(Scenario):
- '''Named Tests in Sequence'''
- def run_loop(self, Iterations):
- testcount = 1
- while testcount <= Iterations:
- for test in self.Tests:
- self.run_test(test, testcount)
- testcount += 1
-
-
-class Boot(Scenario):
- '''Start the Cluster'''
- def run_loop(self, Iterations):
- testcount = 0
-
-
-class BootCluster(ScenarioComponent):
- (
-'''BootCluster is the most basic of ScenarioComponents.
-This ScenarioComponent simply starts the cluster manager on all the nodes.
-It is fairly robust as it waits for all nodes to come up before starting
-as they might have been rebooted or crashed for some reason beforehand.
-''')
- def __init__(self, Env):
- pass
-
- def IsApplicable(self):
- '''BootCluster is so generic it is always Applicable'''
- return True
-
- def SetUp(self, CM):
- '''Basic Cluster Manager startup. Start everything'''
-
- CM.prepare()
-
- # Clear out the cobwebs ;-)
- CM.stopall(verbose=True, force=True)
-
- # Now start the Cluster Manager on all the nodes.
- CM.log("Starting Cluster Manager on all nodes.")
- return CM.startall(verbose=True, quick=True)
-
- def TearDown(self, CM, force=False):
- '''Set up the given ScenarioComponent'''
-
- # Stop the cluster manager everywhere
-
- CM.log("Stopping Cluster Manager on all nodes")
- return CM.stopall(verbose=True, force=force)
-
-
-class LeaveBooted(BootCluster):
- def TearDown(self, CM):
- '''Set up the given ScenarioComponent'''
-
- # Stop the cluster manager everywhere
-
- CM.log("Leaving Cluster running on all nodes")
- return 1
-
-
-class PingFest(ScenarioComponent):
- (
-'''PingFest does a flood ping to each node in the cluster from the test machine.
-
-If the LabEnvironment Parameter PingSize is set, it will be used as the size
-of ping packet requested (via the -s option). If it is not set, it defaults
-to 1024 bytes.
-
-According to the manual page for ping:
- Outputs packets as fast as they come back or one hundred times per
- second, whichever is more. For every ECHO_REQUEST sent a period ``.''
- is printed, while for every ECHO_REPLY received a backspace is printed.
- This provides a rapid display of how many packets are being dropped.
- Only the super-user may use this option. This can be very hard on a net-
- work and should be used with caution.
-''' )
-
- def __init__(self, Env):
- self.Env = Env
-
- def IsApplicable(self):
- '''PingFests are always applicable ;-)
- '''
-
- return True
-
- def SetUp(self, CM):
- '''Start the PingFest!'''
-
- self.PingSize = 1024
- if "PingSize" in list(CM.Env.keys()):
- self.PingSize = CM.Env["PingSize"]
-
- CM.log("Starting %d byte flood pings" % self.PingSize)
-
- self.PingPids = []
- for node in CM.Env["nodes"]:
- self.PingPids.append(self._pingchild(node))
-
- CM.log("Ping PIDs: " + repr(self.PingPids))
- return 1
-
- def TearDown(self, CM):
- '''Stop it right now! My ears are pinging!!'''
-
- for pid in self.PingPids:
- if pid != None:
- CM.log("Stopping ping process %d" % pid)
- os.kill(pid, signal.SIGKILL)
-
- def _pingchild(self, node):
-
- Args = ["ping", "-qfn", "-s", str(self.PingSize), node]
-
- sys.stdin.flush()
- sys.stdout.flush()
- sys.stderr.flush()
- pid = os.fork()
-
- if pid < 0:
- self.Env.log("Cannot fork ping child")
- return None
- if pid > 0:
- return pid
-
- # Otherwise, we're the child process.
-
- os.execvp("ping", Args)
- self.Env.log("Cannot execvp ping: " + repr(Args))
- sys.exit(1)
-
-
-class BasicSanityCheck(ScenarioComponent):
- (
-'''
-''')
-
- def IsApplicable(self):
- return self.Env["DoBSC"]
-
- def SetUp(self, CM):
-
- CM.prepare()
-
- # Clear out the cobwebs
- self.TearDown(CM)
-
- # Now start the Cluster Manager on all the nodes.
- CM.log("Starting Cluster Manager on BSC node(s).")
- return CM.startall()
-
- def TearDown(self, CM):
- CM.log("Stopping Cluster Manager on BSC node(s).")
- return CM.stopall()
-
-
-class Benchmark(ScenarioComponent):
- (
-'''
-''')
-
- def IsApplicable(self):
- return self.Env["benchmark"]
-
- def SetUp(self, CM):
-
- CM.prepare()
-
- # Clear out the cobwebs
- self.TearDown(CM, force=True)
-
- # Now start the Cluster Manager on all the nodes.
- CM.log("Starting Cluster Manager on all node(s).")
- return CM.startall()
-
- def TearDown(self, CM):
- CM.log("Stopping Cluster Manager on all node(s).")
- return CM.stopall()
-
-
-class RollingUpgrade(ScenarioComponent):
- (
-'''
-Test a rolling upgrade between two versions of the stack
-''')
-
- def __init__(self, Env):
- self.Env = Env
-
- def IsApplicable(self):
- if not self.Env["rpm-dir"]:
- return None
- if not self.Env["current-version"]:
- return None
- if not self.Env["previous-version"]:
- return None
-
- return True
-
- def install(self, node, version):
-
- target_dir = "/tmp/rpm-%s" % version
- src_dir = "%s/%s" % (self.CM.Env["rpm-dir"], version)
-
- self.CM.rsh(node, "mkdir -p %s" % target_dir)
- rc = self.CM.cp("%s/*.rpm %s:%s" % (src_dir, node, target_dir))
- self.CM.rsh(node, "rpm -Uvh --force %s/*.rpm" % (target_dir))
-
- return self.success()
-
- def upgrade(self, node):
- return self.install(node, self.CM.Env["current-version"])
-
- def downgrade(self, node):
- return self.install(node, self.CM.Env["previous-version"])
-
- def SetUp(self, CM):
- print(repr(self)+"prepare")
- CM.prepare()
-
- # Clear out the cobwebs
- CM.stopall(force=True)
-
- CM.log("Downgrading all nodes to %s." % self.Env["previous-version"])
-
- for node in self.Env["nodes"]:
- if not self.downgrade(node):
- CM.log("Couldn't downgrade %s" % node)
- return None
-
- return 1
-
- def TearDown(self, CM):
- # Stop everything
- CM.log("Stopping Cluster Manager on Upgrade nodes.")
- CM.stopall()
-
- CM.log("Upgrading all nodes to %s." % self.Env["current-version"])
- for node in self.Env["nodes"]:
- if not self.upgrade(node):
- CM.log("Couldn't upgrade %s" % node)
- return None
-
- return 1
generated by cgit v1.2.3 (git 2.39.1) at 2025-02-18 16:35:53 +0000