- def check_tcp (self, options):
- # we just need to create a sliver object nothing else
- test_sliver=TestSliver(self,
- TestNode(self, TestSite(self,self.plc_spec['sites'][0]),
- self.plc_spec['sites'][0]['nodes'][0]),
- TestSlice(self,TestSite(self,self.plc_spec['sites'][0]),
- self.plc_spec['slices']))
- return test_sliver.do_check_tcp(self.plc_spec['tcp_param'],options)
+ def gather_logs (self):
+ utils.header("WARNING - Incomplete logs gathering TestPlc.gather_logs")
+
+
+ def check_tcp (self):
+ specs = self.plc_spec['tcp_test']
+ overall=True
+ for spec in specs:
+ utils.header ("WARNING : xxx check_tcp is underway, spec=%r"%spec)
+ port = spec['port']
+ # locate specs
+ (s_site,s_node) = self.locate_node(spec['server_node'])
+ s_slice = self.locate_slice (spec['server_slice'])
+ # build objects
+ s_test_site = TestSite (self, s_site)
+ s_test_node = TestNode (self, s_test_site,s_node)
+ # xxx the slice site is assumed to be the node site - mhh
+ s_test_slice = TestSlice (self, s_test_site, s_slice)
+ s_test_sliver = TestSliver (self, s_test_node, s_test_slice)
+ if not s_test_sliver.run_tcp_server(port):
+ overall=False
+ break
+
+ # idem for the client side
+ (c_site,c_node) = self.locate_node(spec['server_node'])
+ c_slice = self.locate_slice (spec['server_slice'])
+ # build objects
+ c_test_site = TestSite (self, c_site)
+ c_test_node = TestNode (self, c_test_site,c_node)
+ # xxx the slice site is assumed to be the node site - mhh
+ c_test_slice = TestSlice (self, c_test_site, c_slice)
+ c_test_sliver = TestSliver (self, c_test_node, c_test_slice)
+ if not c_test_sliver.run_tcp_client(s_test_node.name(),port):
+ overall=False
+
+ return overall