diff --git a/extra/resources/Dummy b/extra/resources/Dummy index da5253faea..2410c4d320 100644 --- a/extra/resources/Dummy +++ b/extra/resources/Dummy @@ -1,195 +1,207 @@ #!/bin/sh # # # Dummy OCF RA. Does nothing but wait a few seconds, can be # configured to fail occassionally. # # Copyright (c) 2004 SUSE LINUX AG, Lars Marowsky-Brée # All Rights Reserved. # # This program is free software; you can redistribute it and/or modify # it under the terms of version 2 of the GNU General Public License as # published by the Free Software Foundation. # # This program is distributed in the hope that it would be useful, but # WITHOUT ANY WARRANTY; without even the implied warranty of # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. # # Further, this software is distributed without any warranty that it is # free of the rightful claim of any third person regarding infringement # or the like. Any license provided herein, whether implied or # otherwise, applies only to this software file. Patent licenses, if # any, provided herein do not apply to combinations of this program with # other software, or any other product whatsoever. # # You should have received a copy of the GNU General Public License # along with this program; if not, write the Free Software Foundation, # Inc., 59 Temple Place - Suite 330, Boston MA 02111-1307, USA. # ####################################################################### # Initialization: : ${OCF_FUNCTIONS=${OCF_ROOT}/resource.d/heartbeat/.ocf-shellfuncs} . ${OCF_FUNCTIONS} : ${__OCF_ACTION=$1} ####################################################################### meta_data() { cat < 1.0 This is a Dummy Resource Agent. It does absolutely nothing except keep track of whether its running or not. Its purpose in life is for testing and to serve as a template for RA writers. NB: Please pay attention to the timeouts specified in the actions section below. They should be meaningful for the kind of resource the agent manages. They should be the minimum advised timeouts, but they shouldn't/cannot cover _all_ possible resource instances. So, try to be neither overly generous nor too stingy, but moderate. The minimum timeouts should never be below 10 seconds. Example stateless resource agent Location to store the resource state in. State file Fake attribute that can be changed to cause a reload Fake attribute that can be changed to cause a reload + + +Number of seconds to sleep during operations. This can be used to test how +the cluster reacts to operation timeouts. + +Operation sleep duration in seconds. + + + END } ####################################################################### # don't exit on TERM, to test that lrmd makes sure that we do exit trap sigterm_handler TERM sigterm_handler() { ocf_log info "They use TERM to bring us down. No such luck." return } dummy_usage() { cat < 0:\n" + " sys.exit(0)\n" + " sys.exit(-1)\n" + "if __name__ == \"__main__\":\n" + " main()\n") + + os.system("cat <<-END >>/usr/sbin/lrmd_dummy_daemon\n%s\nEND" % (dummy_daemon)) + os.system("cat <<-END >>/lib/systemd/system/lrmd_dummy_daemon.service\n%s\nEND" % (dummy_service_file)) + os.system("chmod u+x /usr/sbin/lrmd_dummy_daemon") + + os.system("cat <<-END >>/usr/sbin/fence_dummy_monitor\n%s\nEND" % (dummy_fence_agent)) + os.system("chmod 711 /usr/sbin/fence_dummy_monitor") + + os.system("cp /usr/share/pacemaker/tests/cts/LSBDummy /etc/init.d/LSBDummy") + + os.system("systemctl daemon-reload") + + def cleanup_test_environment(self): + os.system("rm -f /lib/systemd/system/lrmd_dummy_daemon.service") + os.system("rm -f /usr/sbin/lrmd_dummy_daemon") + os.system("rm -f /usr/sbin/fence_dummy_monitor") + os.system("rm -f /etc/init.d/LSBDummy") + os.system("systemctl daemon-reload") + + ### These are tests that should apply to all resource classes ### + def build_generic_tests(self): + rsc_classes = self.rsc_classes + common_cmds = self.common_cmds + + ### register/unregister tests ### + for rsc in rsc_classes: + test = self.new_test("generic_registration_%s" % (rsc), "Simple resource registration test for %s standard" % (rsc)) + test.add_cmd(common_cmds["%s_reg_line" % (rsc)] + " " + common_cmds["%s_reg_event" % (rsc)]) + test.add_cmd(common_cmds["%s_unreg_line" % (rsc)] + " " + common_cmds["%s_unreg_event" % (rsc)]) + + ### start/stop tests ### + for rsc in rsc_classes: + test = self.new_test("generic_start_stop_%s" % (rsc), "Simple start and stop test for %s standard" % (rsc)) + test.add_cmd(common_cmds["%s_reg_line" % (rsc)] + " " + common_cmds["%s_reg_event" % (rsc)]) + test.add_cmd(common_cmds["%s_start_line" % (rsc)] + " " + common_cmds["%s_start_event" % (rsc)]) + test.add_cmd(common_cmds["%s_stop_line" % (rsc)] + " " + common_cmds["%s_stop_event" % (rsc)]) + test.add_cmd(common_cmds["%s_unreg_line" % (rsc)] + " " + common_cmds["%s_unreg_event" % (rsc)]) + + ### monitor cancel test ### + for rsc in rsc_classes: + test = self.new_test("generic_monitor_cancel_%s" % (rsc), "Simple monitor cancel test for %s standard" % (rsc)) + test.add_cmd(common_cmds["%s_reg_line" % (rsc)] + " " + common_cmds["%s_reg_event" % (rsc)]) + test.add_cmd(common_cmds["%s_start_line" % (rsc)] + " " + common_cmds["%s_start_event" % (rsc)]) + test.add_cmd(common_cmds["%s_monitor_line" % (rsc)] + " " + common_cmds["%s_monitor_event" % (rsc)]) + test.add_cmd(common_cmds["%s_monitor_event" % (rsc)]) ### If this fails, that means the monitor may not be getting rescheduled #### + test.add_cmd(common_cmds["%s_monitor_event" % (rsc)]) ### If this fails, that means the monitor may not be getting rescheduled #### + test.add_cmd(common_cmds["%s_cancel_line" % (rsc)] + " " + common_cmds["%s_cancel_event" % (rsc)]) + test.add_expected_fail_cmd(common_cmds["%s_monitor_event" % (rsc)]) ### If this happens the monitor did not actually cancel correctly. ### + test.add_expected_fail_cmd(common_cmds["%s_monitor_event" % (rsc)]) ### If this happens the monitor did not actually cancel correctly. ### + test.add_cmd(common_cmds["%s_stop_line" % (rsc)] + " " + common_cmds["%s_stop_event" % (rsc)]) + test.add_cmd(common_cmds["%s_unreg_line" % (rsc)] + " " + common_cmds["%s_unreg_event" % (rsc)]) + + ### These are complex tests that involve managing multiple resouces of different types ### + def build_multi_rsc_tests(self): + common_cmds = self.common_cmds + # do not use service and systemd at the same time, it is the same resource. + rsc_classes = ["ocf", "lsb", "stonith", "service"] + + ### register start monitor stop unregister resources of each type at the same time. ### + test = self.new_test("multi_rsc_start_stop_all", "Start, monitor, and stop resources of multiple types and classes") + for rsc in rsc_classes: + test.add_cmd(common_cmds["%s_reg_line" % (rsc)] + " " + common_cmds["%s_reg_event" % (rsc)]) + for rsc in rsc_classes: + test.add_cmd(common_cmds["%s_start_line" % (rsc)] + " " + common_cmds["%s_start_event" % (rsc)]) + for rsc in rsc_classes: + test.add_cmd(common_cmds["%s_monitor_line" % (rsc)] + " " + common_cmds["%s_monitor_event" % (rsc)]) + for rsc in rsc_classes: + test.add_cmd(common_cmds["%s_monitor_event" % (rsc)]) ### If this fails, that means the monitor is not being rescheduled #### + for rsc in rsc_classes: + test.add_cmd(common_cmds["%s_cancel_line" % (rsc)] + " " + common_cmds["%s_cancel_event" % (rsc)]) + for rsc in rsc_classes: + test.add_cmd(common_cmds["%s_stop_line" % (rsc)] + " " + common_cmds["%s_stop_event" % (rsc)]) + for rsc in rsc_classes: + test.add_cmd(common_cmds["%s_unreg_line" % (rsc)] + " " + common_cmds["%s_unreg_event" % (rsc)]) + + ### These are tests related to how the lrmd handles failures. ### + def build_negative_tests(self): + + ### start timeout test ### + test = self.new_test("start_timeout", "Force start timeout to occur, verify start failure.") + test.add_cmd("-c register_rsc -r \"test_rsc\" -C \"ocf\" -P \"pacemaker\" -T \"Dummy\" -t 1000 " + "-l \"NEW_EVENT event_type:register rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + test.add_cmd("-c exec -r \"test_rsc\" -a \"start\" -k \"op_sleep\" -v \"3\" -t 1000 -w") + test.add_cmd("-l " + "\"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:unknown error op_status:Timed Out\" -t 3000") + test.add_cmd("-c exec -r test_rsc -a stop -t 1000" + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:stop rc:ok op_status:complete\" ") + test.add_cmd("-c unregister_rsc -r test_rsc -t 1000 " + "-l \"NEW_EVENT event_type:unregister rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + + ### monitor fail for ocf resources ### + test = self.new_test("monitor_fail_ocf", "Force ocf monitor to fail, verify failure is reported.") + test.add_cmd("-c register_rsc -r \"test_rsc\" -C \"ocf\" -P \"pacemaker\" -T \"Dummy\" -t 1000 " + "-l \"NEW_EVENT event_type:register rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + test.add_cmd("-c exec -r \"test_rsc\" -a \"start\" -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:ok op_status:complete\" ") + test.add_cmd("-c exec -r \"test_rsc\" -a \"start\" -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:ok op_status:complete\" ") + test.add_cmd("-c exec -r \"test_rsc\" -a \"monitor\" -i \"100\" -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:ok op_status:complete\" ") + test.add_cmd("-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:ok op_status:complete\" -t 2000") + test.add_cmd("-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:ok op_status:complete\" -t 2000") + test.add_sys_cmd("rm", "-f /var/run/Dummy-test_rsc.state") + test.add_cmd("-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:not running op_status:complete\" -t 2000") + test.add_cmd("-c cancel -r \"test_rsc\" -a \"monitor\" -i \"100\" -t \"1000\" " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:not running op_status:Cancelled\" ") + test.add_expected_fail_cmd("-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:not running op_status:complete\" -t 1000") + test.add_expected_fail_cmd("-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:ok op_status:complete\" -t 1000") + test.add_cmd("-c unregister_rsc -r \"test_rsc\" -t 1000 " + "-l \"NEW_EVENT event_type:unregister rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + + ### monitor fail for systemd resource ### + test = self.new_test("monitor_fail_systemd", "Force systemd monitor to fial, verify failure is reported..") + test.add_cmd("-c register_rsc -r \"test_rsc\" -C systemd -T lrmd_dummy_daemon -t 1000 " + "-l \"NEW_EVENT event_type:register rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + test.add_cmd("-c exec -r \"test_rsc\" -a \"start\" -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:ok op_status:complete\" ") + test.add_cmd("-c exec -r \"test_rsc\" -a \"start\" -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:ok op_status:complete\" ") + test.add_cmd("-c exec -r \"test_rsc\" -a \"monitor\" -i \"100\" -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:ok op_status:complete\" ") + test.add_cmd("-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:ok op_status:complete\" -t 2000") + test.add_cmd("-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:ok op_status:complete\" -t 2000") + test.add_sys_cmd("killall", "-q -9 lrmd_dummy_daemon") + test.add_cmd("-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:not running op_status:complete\" -t 2000") + test.add_cmd("-c cancel -r \"test_rsc\" -a \"monitor\" -i \"100\" -t \"1000\" " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:not running op_status:Cancelled\" ") + test.add_expected_fail_cmd("-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:not running op_status:complete\" -t 1000") + test.add_expected_fail_cmd("-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:ok op_status:complete\" -t 1000") + test.add_cmd("-c unregister_rsc -r \"test_rsc\" -t 1000 " + "-l \"NEW_EVENT event_type:unregister rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + + ### Cancel non-existent operation on a resource ### + test = self.new_test("cancel_non_existent_op", "Attempt to cancel the wrong monitor operation, verify expected failure") + test.add_cmd("-c register_rsc -r \"test_rsc\" -C \"ocf\" -P \"pacemaker\" -T \"Dummy\" -t 1000 " + "-l \"NEW_EVENT event_type:register rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + test.add_cmd("-c exec -r \"test_rsc\" -a \"start\" -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:ok op_status:complete\" ") + test.add_cmd("-c exec -r \"test_rsc\" -a \"start\" -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:ok op_status:complete\" ") + test.add_cmd("-c exec -r \"test_rsc\" -a \"monitor\" -i \"100\" -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:ok op_status:complete\" ") + test.add_cmd("-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:ok op_status:complete\" -t 2000") + test.add_expected_fail_cmd("-c cancel -r test_rsc -a \"monitor\" -i 1234 -t \"1000\" " ### interval is wrong, should fail + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:not running op_status:Cancelled\" ") + test.add_expected_fail_cmd("-c cancel -r test_rsc -a stop -i 100 -t \"1000\" " ### action name is wrong, should fail + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:not running op_status:Cancelled\" ") + test.add_cmd("-c unregister_rsc -r \"test_rsc\" -t 1000 " + "-l \"NEW_EVENT event_type:unregister rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + + ### Attempt to invoke non-existent rsc id ### + test = self.new_test("invoke_non_existent_rsc", "Attempt to perform operations on a non-existent rsc id.") + test.add_expected_fail_cmd("-c exec -r \"test_rsc\" -a \"start\" -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:unknown error op_status:complete\" ") + test.add_expected_fail_cmd("-c exec -r test_rsc -a stop -t 1000" + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:stop rc:ok op_status:complete\" ") + test.add_expected_fail_cmd("-c exec -r test_rsc -a monitor -i 1000 -t 1000" + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:monitor rc:ok op_status:complete\" ") + test.add_expected_fail_cmd("-c cancel -r test_rsc -a start -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:ok op_status:Cancelled\" ") + test.add_expected_fail_cmd("-c unregister_rsc -r \"test_rsc\" -t 1000 " + "-l \"NEW_EVENT event_type:unregister rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + + ### Register and start a resource that doesn't exist, systemd ### + test = self.new_test("start_uninstalled_systemd", "Register uninstalled systemd agent, try to start, verify expected failure") + test.add_cmd("-c register_rsc -r \"test_rsc\" -C systemd -T this_is_fake1234 -t 1000 " + "-l \"NEW_EVENT event_type:register rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + test.add_cmd("-c exec -r \"test_rsc\" -a \"start\" -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:unknown error op_status:complete\" ") + test.add_cmd("-c unregister_rsc -r \"test_rsc\" -t 1000 " + "-l \"NEW_EVENT event_type:unregister rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + + ### Register and start a resource that doesn't exist, ocf ### + test = self.new_test("start_uninstalled_ocf", "Register uninstalled ocf agent, try to start, verify expected failure.") + test.add_cmd("-c register_rsc -r \"test_rsc\" -C ocf -P pacemaker -T this_is_fake1234 -t 1000 " + "-l \"NEW_EVENT event_type:register rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + test.add_cmd("-c exec -r \"test_rsc\" -a \"start\" -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:not installed op_status:complete\" ") + test.add_cmd("-c unregister_rsc -r \"test_rsc\" -t 1000 " + "-l \"NEW_EVENT event_type:unregister rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + + ### Register ocf with non-existent provider ### + test = self.new_test("start_ocf_bad_provider", "Register ocf agent with a non-existent provider, verify expected failure.") + test.add_cmd("-c register_rsc -r \"test_rsc\" -C ocf -P pancakes -T Dummy -t 1000 " + "-l \"NEW_EVENT event_type:register rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + test.add_cmd("-c exec -r \"test_rsc\" -a \"start\" -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:not installed op_status:complete\" ") + test.add_cmd("-c unregister_rsc -r \"test_rsc\" -t 1000 " + "-l \"NEW_EVENT event_type:unregister rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + + ### Register ocf with empty provider field ### + test = self.new_test("start_ocf_no_provider", "Register ocf agent with a no provider, verify expected failure.") + test.add_expected_fail_cmd("-c register_rsc -r \"test_rsc\" -C ocf -T Dummy -t 1000 " + "-l \"NEW_EVENT event_type:register rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + test.add_expected_fail_cmd("-c exec -r \"test_rsc\" -a \"start\" -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:ok op_status:Error\" ") + test.add_expected_fail_cmd("-c unregister_rsc -r \"test_rsc\" -t 1000 " + "-l \"NEW_EVENT event_type:unregister rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + + ### These are tests that target specific cases ### + def build_custom_tests(self): + ### start delay then stop test ### + test = self.new_test("start_delay", "Verify start delay works as expected.") + test.add_cmd("-c register_rsc -r test_rsc -P pacemaker -C ocf -T Dummy " + "-l \"NEW_EVENT event_type:register rsc_id:test_rsc action:none rc:ok op_status:complete\" -t 1000") + test.add_cmd("-c exec -r test_rsc -s 2000 -a start -w -t 1000") + test.add_expected_fail_cmd("-l " + "\"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:ok op_status:complete\" -t 1000") + test.add_cmd("-l " + "\"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:ok op_status:complete\" -t 3000") + test.add_cmd("-c exec -r test_rsc -a stop -t 1000" + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:stop rc:ok op_status:complete\" ") + test.add_cmd("-c unregister_rsc -r test_rsc -t 1000 " + "-l \"NEW_EVENT event_type:unregister rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + + ### start delay, but cancel before it gets a chance to start. ### + test = self.new_test("start_delay_cancel", "Using start_delay, start a rsc, but cancel the start op before execution.") + test.add_cmd("-c register_rsc -r test_rsc -P pacemaker -C ocf -T Dummy " + "-l \"NEW_EVENT event_type:register rsc_id:test_rsc action:none rc:ok op_status:complete\" -t 1000") + test.add_cmd("-c exec -r test_rsc -s 2000 -a start -w -t 1000") + test.add_cmd("-c cancel -r test_rsc -a start -t 1000 " + "-l \"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:ok op_status:Cancelled\" ") + test.add_expected_fail_cmd("-l " + "\"NEW_EVENT event_type:exec_complete rsc_id:test_rsc action:start rc:ok op_status:complete\" -t 3000") + test.add_cmd("-c unregister_rsc -r test_rsc -t 1000 " + "-l \"NEW_EVENT event_type:unregister rsc_id:test_rsc action:none rc:ok op_status:complete\" ") + + ### Register a bunch of resources, verify we can get info on them ### + test = self.new_test("verify_get_rsc_info", "Register multiple resources, verify retrieval of rsc info.") + test.add_cmd("-c register_rsc -r rsc1 -C systemd -T lrmd_dummy_daemon -t 1000 ") + test.add_cmd("-c register_rsc -r rsc2 -C ocf -T Dummy -P pacemaker -t 1000 ") + test.add_cmd("-c get_rsc_info -r rsc1 ") + test.add_cmd("-c get_rsc_info -r rsc2 ") + test.add_cmd("-c unregister_rsc -r rsc2 -t 1000 ") + test.add_expected_fail_cmd("-c get_rsc_info -r rsc2 ") + test.add_cmd("-c get_rsc_info -r rsc1 ") + test.add_cmd("-c unregister_rsc -r rsc1 -t 1000 ") + test.add_expected_fail_cmd("-c get_rsc_info -r rsc1 ") + + ### get metadata ### + test = self.new_test("get_ocf_metadata", "Retrieve metadata for a resource") + test.add_cmd_check_stdout("-c metadata -C \"ocf\" -P \"pacemaker\" -T \"Dummy\"" + ,"resource-agent name=\"Dummy\"") + test.add_cmd("-c metadata -C \"ocf\" -P \"pacemaker\" -T \"Stateful\"") + test.add_expected_fail_cmd("-c metadata -P \"pacemaker\" -T \"Stateful\"") + test.add_expected_fail_cmd("-c metadata -C \"ocf\" -P \"pacemaker\" -T \"fake_agent\"") + + ### get metadata ### + test = self.new_test("get_lsb_metadata", "Retrieve metadata for a resource") + test.add_cmd_check_stdout("-c metadata -C \"lsb\" -T \"LSBDummy\"" + ,"resource-agent name=\"LSBDummy\"") + + ### get stonith metadata ### + test = self.new_test("get_stonith_metadata", "Retrieve stonith metadata for a resource") + test.add_cmd_check_stdout("-c metadata -C \"stonith\" -P \"pacemaker\" -T \"fence_dummy_monitor\"", + "resource-agent name=\"fence_dummy_monitor\"") + + ### get ocf providers ### + test = self.new_test("list_ocf_providers", "Retrieve list of available resource providers, verifies pacemaker is a provider.") + test.add_cmd_check_stdout("-c list_ocf_providers ", "pacemaker") + test.add_cmd_check_stdout("-c list_ocf_providers -T ping", "pacemaker") + + ### Verify agents only exist in their lists ### + test = self.new_test("verify_agent_lists", "Verify the agent lists contain the right data.") + test.add_cmd_check_stdout("-c list_agents ", "Stateful") ### ocf ### + test.add_cmd_check_stdout("-c list_agents -C ocf", "Stateful") + test.add_cmd_check_stdout("-c list_agents -C lsb", "", "Stateful") ### should not exist + test.add_cmd_check_stdout("-c list_agents -C systemd", "", "Stateful") ### should not exist + test.add_cmd_check_stdout("-c list_agents -C service", "", "Stateful") ### should not exist + test.add_cmd_check_stdout("-c list_agents -C stonith", "", "Stateful") ### should not exist + + test.add_cmd_check_stdout("-c list_agents ", "LSBDummy") ### init.d ### + test.add_cmd_check_stdout("-c list_agents -C lsb", "LSBDummy") + test.add_cmd_check_stdout("-c list_agents -C service", "LSBDummy") + test.add_cmd_check_stdout("-c list_agents -C ocf", "", "LSBDummy") ### should not exist + test.add_cmd_check_stdout("-c list_agents -C systemd", "", "LSBDummy") ### should not exist + test.add_cmd_check_stdout("-c list_agents -C stonith", "", "LSBDummy") ### should not exist + + test.add_cmd_check_stdout("-c list_agents ", "lrmd_dummy_daemon") ### systemd ### + test.add_cmd_check_stdout("-c list_agents -C systemd", "lrmd_dummy_daemon") + test.add_cmd_check_stdout("-c list_agents -C service", "lrmd_dummy_daemon") + test.add_cmd_check_stdout("-c list_agents -C lsb", "", "lrmd_dummy_daemon") ### should not exist + test.add_cmd_check_stdout("-c list_agents -C ocf", "", "lrmd_dummy_daemon") ### should not exist + test.add_cmd_check_stdout("-c list_agents -C stonith", "", "lrmd_dummy_daemon") ### should not exist + + test.add_cmd_check_stdout("-c list_agents -C stonith", "fence_dummy_monitor") ### stonith ### + test.add_cmd_check_stdout("-c list_agents ", "fence_dummy_monitor") + test.add_cmd_check_stdout("-c list_agents -C lsb", "", "fence_dummy_monitor") ### should not exist + test.add_cmd_check_stdout("-c list_agents -C service", "", "fence_dummy_monitor") ### should not exist + test.add_cmd_check_stdout("-c list_agents -C systemd", "", "fence_dummy_monitor") ### should not exist + test.add_cmd_check_stdout("-c list_agents -C ocf", "", "fence_dummy_monitor") ### should not exist + + def print_list(self): + print "\n==== %d TESTS FOUND ====" % (len(self.tests)) + print "%35s - %s" % ("TEST NAME", "TEST DESCRIPTION") + print "%35s - %s" % ("--------------------", "--------------------") + for test in self.tests: + print "%35s - %s" % (test.name, test.description) + print "==== END OF LIST ====\n" + + def run_single(self, name): + for test in self.tests: + if test.name == name: + test.run() + break; + + def run_tests_matching(self, pattern): + for test in self.tests: + if test.name.count(pattern) != 0: + test.run() + + def run_tests(self): + for test in self.tests: + test.run() + + def print_results(self): + failures = 0; + success = 0; + print "\n\n======= FINAL RESULTS ==========" + print "\n--- FAILURE RESULTS:" + for test in self.tests: + if test.executed == 0: + continue + + if test.get_exitcode() != 0: + failures = failures + 1 + test.print_result(" ") + else: + success = success + 1 + + if failures == 0: + print " None" + + print "\n--- TOTALS\n Pass:%d\n Fail:%d\n" % (success, failures) + +class TestOptions: + def __init__(self): + self.options = {} + self.options['list-tests'] = 0 + self.options['run-all'] = 1 + self.options['run-only'] = "" + self.options['run-only-pattern'] = "" + self.options['verbose'] = 0 + self.options['invalid-arg'] = "" + self.options['show-usage'] = 0 + + def build_options(self, argv): + args = argv[1:] + skip = 0 + for i in range(0, len(args)): + if skip: + skip = 0 + continue + elif args[i] == "-h" or args[i] == "--help": + self.options['show-usage'] = 1 + elif args[i] == "-l" or args[i] == "--list-tests": + self.options['list-tests'] = 1 + elif args[i] == "-V" or args[i] == "--verbose": + self.options['verbose'] = 1 + elif args[i] == "-r" or args[i] == "--run-only": + self.options['run-only'] = args[i+1] + skip = 1 + elif args[i] == "-p" or args[i] == "--run-only-pattern": + self.options['run-only-pattern'] = args[i+1] + skip = 1 + + def show_usage(self): + print "usage: " + sys.argv[0] + " [options]" + print "If no options are provided, all tests will run" + print "Options:" + print "\t [--help | -h] Show usage" + print "\t [--list-tests | -l] Print out all registered tests." + print "\t [--run-only | -r 'testname'] Run a specific test" + print "\t [--verbose | -V] Verbose output" + print "\t [--run-only-pattern | -p 'string'] Run only tests containing the string value" + print "\n\tExample: Run only the test 'start_top'" + print "\t\t python ./regression.py --run-only start_stop" + print "\n\tExample: Run only the tests with the string 'systemd' present in them" + print "\t\t python ./regression.py --run-only-pattern systemd" + + +def main(argv): + lrmd_loc = argv[0].replace("regression.py", "lrmd") + test_loc = argv[0].replace("regression.py", "lrmd_test") + + o = TestOptions() + o.build_options(argv) + + tests = Tests(lrmd_loc, test_loc, o.options['verbose']) + + tests.build_generic_tests() + tests.build_multi_rsc_tests() + tests.build_negative_tests() + tests.build_custom_tests() + + tests.setup_test_environment() + + print "Starting ..." + + if o.options['list-tests']: + tests.print_list() + elif o.options['show-usage']: + o.show_usage() + elif o.options['run-only-pattern'] != "": + tests.run_tests_matching(o.options['run-only-pattern']) + tests.print_results() + elif o.options['run-only'] != "": + tests.run_single(o.options['run-only']) + tests.print_results() + else: + tests.run_tests() + tests.print_results() + + tests.cleanup_test_environment() + +if __name__=="__main__": + main(sys.argv)