Lines Matching +full:node +full:- +full:version

45 from node import Node, OtbrNode, HostNode
66     'version': ENV_THREAD_VERSION,
86         if os.getenv('NODE_TYPE', 'sim') == 'ncp-sim' and not self.SUPPORT_NCP:
96     The `topology` member of sub-class is used to create test topology.
108         logging.basicConfig(level=logging.DEBUG, format='%(asctime)s - %(levelname)s - %(message)s')
114     def skipTest(self, reason: Any) -> None:
128             for node in list(self.nodes.values()):
130                     node.destroy()
144         os.environ['LD_LIBRARY_PATH'] = '/tmp/thread-wireshark'
156             logging.info("Creating node %d: %r", i, params)
163                 nodeclass = Node
165             node = nodeclass(
170                 version=params['version'],
176             self.nodes[i] = node
178             if node.is_host:
246     def _set_up_active_dataset(self, node, params):  argument
272         node.set_active_dataset(**dataset)
291         for node in list(self.nodes.values()):
293                 node.stop()
297                 node.destroy()
334         Clean up node files in tmp directory
336 …    os.system(f"rm -f tmp/{PORT_OFFSET}_*.flash tmp/{PORT_OFFSET}_*.data tmp/{PORT_OFFSET}_*.swap")
355         for i, node in self.nodes.items():
356             ipaddrs = node.get_addrs()
358             if hasattr(node, 'get_ether_addrs'):
359                 ipaddrs += node.get_ether_addrs()
362             if not node.is_host:
363                 mleid = node.get_mleid()
373         for i, node in self.nodes.items():
374             if not node.is_host:
375                 test_info['rloc16s'][i] = '0x%04x' % node.get_addr16()
384         for i, node in self.nodes.items():
385             if node.is_host:
388             test_info['rlocs'][i] = node.get_rloc()
397         for i, node in self.nodes.items():
398             if node.is_host:
401             test_info['omrs'][i] = node.get_ip6_address(config.ADDRESS_TYPE.OMR)
410         for i, node in self.nodes.items():
411             if node.is_host:
414             test_info['duas'][i] = node.get_ip6_address(config.ADDRESS_TYPE.DUA)
416     def collect_leader_aloc(self, node):  argument
421         test_info['leader_aloc'] = self.nodes[node].get_addr_leader_aloc()
460         for i, node in self.nodes.items():
461             if not node.is_host:
462                 extaddr = node.get_addr64()
465             if node.is_host or node.is_otbr:
466                 ethaddr = node.get_ether_mac()
490     def _parse_params(self, params: Optional[dict]) -> dict:
494             # BBRs must not use thread version 1.1
495             version = params.get('version', '1.3')
496             assert version != '1.1', params
497             params['version'] = version
500             # Hosts must not specify thread version
501             assert params.get('version', '') == '', params
502             params['version'] = ''
504         # use 1.3 node for 1.2 tests
505         if params.get('version') == '1.2':
506             params['version'] = '1.3'
529 …f'docker network create --driver bridge --ipv6 --subnet {config.BACKBONE_PREFIX} -o "com.docker.ne…
538         # self.assure_run_ok("truncate --size 0 bbr.pcap && chmod 664 bbr.pcap", shell=True)
546 …self._dumpcap_proc = subprocess.Popen([dumpcap, '-i', config.BACKBONE_DOCKER_NETWORK_NAME, '-w', p…
573         self.assure_run_ok(f'{mergecap} -w {merged_pcap} {thread_pcap} {backbone_pcap}', shell=True)
583             timeout -= go_interval
587     def wait_node_state(self, node: Union[int, Node], state: str, timeout: int):  argument
588         node = self.nodes[node] if isinstance(node, int) else node
589         self.wait_until(lambda: node.get_state() == state, timeout)
600             timeout -= 1
603             raise Exception("Route between node %d and %d is not established" % (node1, node2))