Signed-off-by: Angus Salkeld <[email protected]>
---
cts/corotests.py | 11 +++++++++--
1 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/cts/corotests.py b/cts/corotests.py
index e56a699..9d43601 100644
--- a/cts/corotests.py
+++ b/cts/corotests.py
@@ -405,7 +405,6 @@ class CpgMsgOrderBase(CoroTest):
ret = CoroTest.setup(self, node)
for n in self.CM.Env["nodes"]:
- self.total_num_msgs = self.total_num_msgs + self.num_msgs_per_node
self.CM.cpg_agent[n].clean_start()
self.CM.cpg_agent[n].cpg_join(self.name)
self.CM.cpg_agent[n].record_messages()
@@ -420,6 +419,10 @@ class CpgMsgOrderBase(CoroTest):
def wait_and_validate_order(self):
msgs = {}
+ self.total_num_msgs = 0
+ for n in self.CM.Env["nodes"]:
+ self.total_num_msgs = self.total_num_msgs + self.num_msgs_per_node
+
for n in self.CM.Env["nodes"]:
msgs[n] = []
stopped = False
@@ -427,7 +430,11 @@ class CpgMsgOrderBase(CoroTest):
while len(msgs[n]) < self.total_num_msgs and waited < 360:
- msg = self.CM.cpg_agent[n].read_messages(50)
+ try:
+ msg = self.CM.cpg_agent[n].read_messages(50)
+ except:
+ return self.failure('connection to test cpg_agent failed.')
+
if not msg == None:
msgl = msg.split(";")
--
1.7.3.1
_______________________________________________
Openais mailing list
[email protected]
https://lists.linux-foundation.org/mailman/listinfo/openais
