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, &notification_buffer);
+               result = corosync_cfg_state_track (cfg_handle, 0, 
&notification_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

Reply via email to