Signed-off-by: Angus Salkeld <asalk...@redhat.com> --- cts/agents/cpg_test_agent.c | 11 ++++++++--- cts/corotests.py | 7 +++++++ 2 files changed, 15 insertions(+), 3 deletions(-)
diff --git a/cts/agents/cpg_test_agent.c b/cts/agents/cpg_test_agent.c index 5922a19..542dcf2 100644 --- a/cts/agents/cpg_test_agent.c +++ b/cts/agents/cpg_test_agent.c @@ -711,7 +711,9 @@ static void do_command (int sock, char* func, char*args[], int num_args) } else if (strcmp ("cfg_shutdown", func) == 0) { - corosync_cfg_try_shutdown (cfg_handle, COROSYNC_CFG_SHUTDOWN_FLAG_REQUEST); + syslog (LOG_INFO,"%s calling %s() called!", __func__, func); + result = corosync_cfg_try_shutdown (cfg_handle, COROSYNC_CFG_SHUTDOWN_FLAG_REQUEST); + syslog (LOG_INFO,"%s() returned %d!", func, result); } else if (strcmp ("cfg_initialize",func) == 0) { int retry_count = 0; @@ -729,10 +731,13 @@ static void do_command (int sock, char* func, char*args[], int num_args) retry_count++; result = corosync_cfg_initialize (&cfg_handle, &cfg_callbacks); } + syslog (LOG_INFO,"corosync_cfg_initialize() == %d", result); - corosync_cfg_fd_get (cfg_handle, &cfg_fd); + result = corosync_cfg_fd_get (cfg_handle, &cfg_fd); + syslog (LOG_INFO,"corosync_cfg_fd_get() == %d", result); - corosync_cfg_state_track (cfg_handle, 0, ¬ification_buffer); + result = corosync_cfg_state_track (cfg_handle, 0, ¬ification_buffer); + syslog (LOG_INFO,"corosync_cfg_state_track() == %d", result); qb_loop_poll_add (ta_poll_handle_get(), QB_LOOP_MED, diff --git a/cts/corotests.py b/cts/corotests.py index 9d43601..c956611 100644 --- a/cts/corotests.py +++ b/cts/corotests.py @@ -1093,6 +1093,9 @@ class GenStopAllBeekhof(CoroTest): CoroTest.__init__(self,cm) self.name="GenStopAllBeekhof" self.need_all_up = True + self.config['logging/logger_subsys[1]/subsys'] = 'CFG' + self.config['logging/logger_subsys[1]/debug'] = 'on' + self.config['logging/logger_subsys[1]/tags'] = 'trace1|enter|leave' def __call__(self, node): '''Perform the 'GenStopAllBeekhof' test. ''' @@ -1101,7 +1104,11 @@ class GenStopAllBeekhof(CoroTest): stopping = int(time.time()) for n in self.CM.Env["nodes"]: self.CM.cpg_agent[n].pcmk_test() + + for n in self.CM.Env["nodes"]: self.CM.cpg_agent[n].msg_blaster(10000) + + for n in self.CM.Env["nodes"]: self.CM.cpg_agent[n].cfg_shutdown() self.CM.ShouldBeStatus[n] = "down" -- 1.7.3.1 _______________________________________________ Openais mailing list Openais@lists.linux-foundation.org https://lists.linux-foundation.org/mailman/listinfo/openais