Signed-off-by: Angus Salkeld <[email protected]>
---
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
[email protected]
https://lists.linux-foundation.org/mailman/listinfo/openais