73     def __init__(self, error_code, message):  argument
74         self._error_code = error_code
75         self._message = message
78     def error_code(self):  argument
79         return self._error_code
82     def message(self):  argument
83         return self._message
115     def __init__(self, radios='', index=None, verbose=_VERBOSE):  argument
122         self._index = index
123         self._verbose = verbose
128             log_file_name = self._LOG_FNAME + str(index) + '.log'
133         if self._verbose:
136         self._cli_process = pexpect.popen_spawn.PopenSpawn(cmd)
137         Node._all_nodes.add(self)
139     def __del__(self):  argument
140         self._finalize()
142     def __repr__(self):  argument
146     def index(self):  argument
147         return self._index
152     def cli(self, *args):  argument
161         if self._verbose:
164         self._cli_process.send(cmd + '\n')
165         index = self._cli_process.expect(['(.*)Done\r\n', '.*Error (\d+):(.*)\r\n'])
169                 line for line in self._cli_process.match.group(1).decode().splitlines()
170                 if not self._is_ot_logg_line(line) if not line.strip().endswith(cmd)
173             if self._verbose:
185             match = self._cli_process.match
187             if self._verbose:
191     def _is_ot_logg_line(self, line):  argument
194     def _cli_no_output(self, cmd, *args):  argument
195         outputs = self.cli(cmd, *args)
198     def _cli_single_output(self, cmd, *args, expected_outputs=None):  argument
199         outputs = self.cli(cmd, *args)
204     def _finalize(self):  argument
205         if self._cli_process.proc.poll() is None:
206             if self._verbose:
208             self._cli_process.send('exit\n')
209             self._cli_process.wait()
214     def get_state(self):  argument
215 …return self._cli_single_output('state', expected_outputs=['detached', 'child', 'router', 'leader',…
217     def get_version(self):  argument
218         return self._cli_single_output('version')
220     def get_channel(self):  argument
221         return self._cli_single_output('channel')
223     def set_channel(self, channel):  argument
224         self._cli_no_output('channel', channel)
226     def get_csl_config(self):  argument
227         outputs = self.cli('csl')
234     def set_csl_period(self, period):  argument
235         self._cli_no_output('csl period', period)
237     def get_ext_addr(self):  argument
238         return self._cli_single_output('extaddr')
240     def set_ext_addr(self, ext_addr):  argument
241         self._cli_no_output('extaddr', ext_addr)
243     def get_ext_panid(self):  argument
244         return self._cli_single_output('extpanid')
246     def set_ext_panid(self, ext_panid):  argument
247         self._cli_no_output('extpanid', ext_panid)
249     def get_mode(self):  argument
250         return self._cli_single_output('mode')
252     def set_mode(self, mode):  argument
253         self._cli_no_output('mode', mode)
255     def get_network_key(self):  argument
256         return self._cli_single_output('networkkey')
258     def set_network_key(self, networkkey):  argument
259         self._cli_no_output('networkkey', networkkey)
261     def get_network_name(self):  argument
262         return self._cli_single_output('networkname')
264     def set_network_name(self, network_name):  argument
265         self._cli_no_output('networkname', network_name)
267     def get_panid(self):  argument
268         return self._cli_single_output('panid')
270     def set_panid(self, panid):  argument
271         self._cli_no_output('panid', panid)
273     def get_router_upgrade_threshold(self):  argument
274         return self._cli_single_output('routerupgradethreshold')
276     def set_router_upgrade_threshold(self, threshold):  argument
277         self._cli_no_output('routerupgradethreshold', threshold)
279     def get_router_selection_jitter(self):  argument
280         return self._cli_single_output('routerselectionjitter')
282     def set_router_selection_jitter(self, jitter):  argument
283         self._cli_no_output('routerselectionjitter', jitter)
285     def get_router_eligible(self):  argument
286         return self._cli_single_output('routereligible')
288     def set_router_eligible(self, enable):  argument
289         self._cli_no_output('routereligible', enable)
291     def get_context_reuse_delay(self):  argument
292         return self._cli_single_output('contextreusedelay')
294     def set_context_reuse_delay(self, delay):  argument
295         self._cli_no_output('contextreusedelay', delay)
297     def interface_up(self):  argument
298         self._cli_no_output('ifconfig up')
300     def interface_down(self):  argument
301         self._cli_no_output('ifconfig down')
303     def get_interface_state(self):  argument
304         return self._cli_single_output('ifconfig')
306     def thread_start(self):  argument
307         self._cli_no_output('thread start')
309     def thread_stop(self):  argument
310         self._cli_no_output('thread stop')
312     def get_rloc16(self):  argument
313         return self._cli_single_output('rloc16')
315     def get_ip_addrs(self, verbose=None):  argument
316         return self.cli('ipaddr', verbose)
318     def add_ip_addr(self, address):  argument
319         self._cli_no_output('ipaddr add', address)
321     def remove_ip_addr(self, address):  argument
322         self._cli_no_output('ipaddr del', address)
324     def get_mleid_ip_addr(self):  argument
325         return self._cli_single_output('ipaddr mleid')
327     def get_linklocal_ip_addr(self):  argument
328         return self._cli_single_output('ipaddr linklocal')
330     def get_rloc_ip_addr(self):  argument
331         return self._cli_single_output('ipaddr rloc')
333     def get_mesh_local_prefix(self):  argument
334         return self._cli_single_output('prefix meshlocal')
336     def get_ip_maddrs(self):  argument
337         return self.cli('ipmaddr')
339     def add_ip_maddr(self, maddr):  argument
340         return self._cli_no_output('ipmaddr add', maddr)
342     def get_leader_weight(self):  argument
343         return self._cli_single_output('leaderweight')
345     def set_leader_weight(self, weight):  argument
346         self._cli_no_output('leaderweight', weight)
348     def get_pollperiod(self):  argument
349         return self._cli_single_output('pollperiod')
351     def set_pollperiod(self, period):  argument
352         self._cli_no_output('pollperiod', period)
354     def get_partition_id(self):  argument
355         return self._cli_single_output('partitionid')
357     def get_nexthop(self, rloc16):  argument
358         return self._cli_single_output('nexthop', rloc16)
360     def get_parent_info(self):  argument
361         outputs = self.cli('parent')
368     def get_child_table(self):  argument
369         return Node.parse_table(self.cli('child table'))
371     def get_neighbor_table(self):  argument
372         return Node.parse_table(self.cli('neighbor table'))
374     def get_router_table(self):  argument
375         return Node.parse_table(self.cli('router table'))
377     def get_eidcache(self):  argument
378         return self.cli('eidcache')
380     def get_vendor_name(self):  argument
381         return self._cli_single_output('vendor name')
383     def set_vendor_name(self, name):  argument
384         self._cli_no_output('vendor name', name)
386     def get_vendor_model(self):  argument
387         return self._cli_single_output('vendor model')
389     def set_vendor_model(self, model):  argument
390         self._cli_no_output('vendor model', model)
392     def get_vendor_sw_version(self):  argument
393         return self._cli_single_output('vendor swversion')
395     def set_vendor_sw_version(self, version):  argument
396         return self._cli_no_output('vendor swversion', version)
398     def get_vendor_app_url(self):  argument
399         return self._cli_single_output('vendor appurl')
401     def set_vendor_app_url(self, url):  argument
402         return self._cli_no_output('vendor appurl', url)
407     def get_netdata(self, rloc16=None):  argument
408         outputs = self.cli('netdata show', rloc16)
427     def get_netdata_prefixes(self):  argument
428         return self.get_netdata()['prefixes']
430     def get_netdata_routes(self):  argument
431         return self.get_netdata()['routes']
433     def get_netdata_services(self):  argument
434         return self.get_netdata()['services']
436     def get_netdata_contexts(self):  argument
437         return self.get_netdata()['contexts']
439     def get_netdata_versions(self):  argument
440         leaderdata = Node.parse_list(self.cli('leaderdata'))
443     def get_netdata_length(self):  argument
444         return self._cli_single_output('netdata length')
446     def add_prefix(self, prefix, flags=None, prf=None):  argument
447         return self._cli_no_output('prefix add', prefix, flags, prf)
449     def add_route(self, prefix, flags=None, prf=None):  argument
450         return self._cli_no_output('route add', prefix, flags, prf)
452     def remove_prefix(self, prefix):  argument
453         return self._cli_no_output('prefix remove', prefix)
455     def register_netdata(self):  argument
456         self._cli_no_output('netdata register')
458     def get_netdata_full(self):  argument
459         return self._cli_single_output('netdata full')
461     def reset_netdata_full(self):  argument
462         self._cli_no_output('netdata full reset')
467     def ping(self, address, size=0, count=1, verify_success=True):  argument
468         outputs = self.cli('ping', address, size, count)
475     def get_mle_counter(self):  argument
476         return self.cli('counters mle')
478     def get_ip_counters(self):  argument
479         return Node.parse_list(self.cli('counters ip'))
481     def get_br_counter_unicast_outbound_packets(self):  argument
482         outputs = self.cli('counters br')
495     def get_mle_adv_imax(self):  argument
496         return self._cli_single_output('mleadvimax')
501     def ba_get_state(self):  argument
502         return self._cli_single_output('ba state')
504     def ba_get_port(self):  argument
505         return self._cli_single_output('ba port')
507     def ba_is_ephemeral_key_active(self):  argument
508         return self._cli_single_output('ba ephemeralkey')
510     def ba_set_ephemeral_key(self, keystring, timeout=None, port=None):  argument
511         self._cli_no_output('ba ephemeralkey set', keystring, timeout, port)
513     def ba_clear_ephemeral_key(self):  argument
514         self._cli_no_output('ba ephemeralkey clear')
519     def udp_open(self):  argument
520         self._cli_no_output('udp open')
522     def udp_close(self):  argument
523         self._cli_no_output('udp close')
525     def udp_bind(self, address, port):  argument
526         self._cli_no_output('udp bind', address, port)
528     def udp_send(self, address, port, text):  argument
529         self._cli_no_output('udp send', address, port, '-t', text)
534     def multiradio_get_radios(self):  argument
535         return self._cli_single_output('multiradio')
537     def multiradio_get_neighbor_list(self):  argument
538         return self.cli('multiradio neighbor list')
543     def srp_client_start(self, server_address, server_port):  argument
544         self._cli_no_output('srp client start', server_address, server_port)
546     def srp_client_stop(self):  argument
547         self._cli_no_output('srp client stop')
549     def srp_client_get_state(self):  argument
550         return self._cli_single_output('srp client state', expected_outputs=['Enabled', 'Disabled'])
552     def srp_client_get_auto_start_mode(self):  argument
553 …   return self._cli_single_output('srp client autostart', expected_outputs=['Enabled', 'Disabled'])
555     def srp_client_enable_auto_start_mode(self):  argument
556         self._cli_no_output('srp client autostart enable')
558     def srp_client_disable_auto_start_mode(self):  argument
559         self._cli_no_output('srp client autostart disable')
561     def srp_client_get_server_address(self):  argument
562         return self._cli_single_output('srp client server address')
564     def srp_client_get_server_port(self):  argument
565         return self._cli_single_output('srp client server port')
567     def srp_client_get_host_state(self):  argument
568         return self._cli_single_output('srp client host state')
570     def srp_client_set_host_name(self, name):  argument
571         self._cli_no_output('srp client host name', name)
573     def srp_client_get_host_name(self):  argument
574         return self._cli_single_output('srp client host name')
576     def srp_client_remove_host(self, remove_key=False, send_unreg_to_server=False):  argument
577         self._cli_no_output('srp client host remove', int(remove_key), int(send_unreg_to_server))
579     def srp_client_clear_host(self):  argument
580         self._cli_no_output('srp client host clear')
582     def srp_client_enable_auto_host_address(self):  argument
583         self._cli_no_output('srp client host address auto')
585     def srp_client_set_host_address(self, *addrs):  argument
586         self._cli_no_output('srp client host address', *addrs)
588     def srp_client_get_host_address(self):  argument
589         return self.cli('srp client host address')
591     def srp_client_add_service(self,  argument
600         txt_record = "".join(self._encode_txt_entry(entry) for entry in txt_entries)
601 …self._cli_no_output('srp client service add', instance_name, service_name, port, priority, weight,…
604     def srp_client_remove_service(self, instance_name, service_name):  argument
605         self._cli_no_output('srp client service remove', instance_name, service_name)
607     def srp_client_clear_service(self, instance_name, service_name):  argument
608         self._cli_no_output('srp client service clear', instance_name, service_name)
610     def srp_client_get_services(self):  argument
611         outputs = self.cli('srp client service')
612         return [self._parse_srp_client_service(line) for line in outputs]
614     def _encode_txt_entry(self, entry):  argument
624     def _parse_srp_client_service(self, line):  argument
648     def srp_server_get_state(self):  argument
649 …return self._cli_single_output('srp server state', expected_outputs=['disabled', 'running', 'stopp…
651     def srp_server_get_addr_mode(self):  argument
652 …     return self._cli_single_output('srp server addrmode', expected_outputs=['unicast', 'anycast'])
654     def srp_server_set_addr_mode(self, mode):  argument
655         self._cli_no_output('srp server addrmode', mode)
657     def srp_server_get_anycast_seq_num(self):  argument
658         return self._cli_single_output('srp server seqnum')
660     def srp_server_set_anycast_seq_num(self, seqnum):  argument
661         self._cli_no_output('srp server seqnum', seqnum)
663     def srp_server_enable(self):  argument
664         self._cli_no_output('srp server enable')
666     def srp_server_disable(self):  argument
667         self._cli_no_output('srp server disable')
669     def srp_server_auto_enable(self):  argument
670         self._cli_no_output('srp server auto enable')
672     def srp_server_auto_disable(self):  argument
673         self._cli_no_output('srp server auto disable')
675     def srp_server_set_lease(self, min_lease, max_lease, min_key_lease, max_key_lease):  argument
676         self._cli_no_output('srp server lease', min_lease, max_lease, min_key_lease, max_key_lease)
678     def srp_server_get_hosts(self):  argument
690         outputs = self.cli('srp server host')
706     def srp_server_get_host(self, host_name):  argument
712         for host in self.srp_server_get_hosts():
716     def srp_server_get_services(self):  argument
740         outputs = self.cli('srp server service')
767     def srp_server_get_service(self, instance_name, service_name):  argument
774         for service in self.srp_server_get_services():
781     def br_init(self, if_inex, is_running):  argument
782         self._cli_no_output('br init', if_inex, is_running)
784     def br_enable(self):  argument
785         self._cli_no_output('br enable')
787     def br_disable(self):  argument
788         self._cli_no_output('br disable')
790     def br_get_state(self):  argument
791         return self._cli_single_output('br state')
793     def br_get_favored_omrprefix(self):  argument
794         return self._cli_single_output('br omrprefix favored')
796     def br_get_local_omrprefix(self):  argument
797         return self._cli_single_output('br omrprefix local')
799     def br_get_favored_onlinkprefix(self):  argument
800         return self._cli_single_output('br onlinkprefix favored')
802     def br_get_local_onlinkprefix(self):  argument
803         return self._cli_single_output('br onlinkprefix local')
805     def br_set_test_local_onlinkprefix(self, prefix):  argument
806         self._cli_no_output('br onlinkprefix test', prefix)
808     def br_get_routeprf(self):  argument
809         return self._cli_single_output('br routeprf')
811     def br_set_routeprf(self, prf):  argument
812         self._cli_no_output('br routeprf', prf)
814     def br_clear_routeprf(self):  argument
815         self._cli_no_output('br routeprf clear')
817     def br_get_routers(self):  argument
818         return self.cli('br routers')
820     def br_get_peer_brs(self):  argument
821         return self.cli('br peers')
823     def br_count_peers(self):  argument
824         return self._cli_single_output('br peers count')
829     def form(self, network_name=None, network_key=None, channel=None, panid=0x1234, xpanid=None):  argument
830         self._cli_no_output('dataset init new')
831         self._cli_no_output('dataset panid', panid)
833             self._cli_no_output('dataset networkname', network_name)
835             self._cli_no_output('dataset networkkey', network_key)
837             self._cli_no_output('dataset channel', channel)
839             self._cli_no_output('dataset extpanid', xpanid)
840         self._cli_no_output('dataset commit active')
841         self.set_mode('rdn')
842         self.interface_up()
843         self.thread_start()
844         verify_within(_check_node_is_leader, self._WAIT_TIME, arg=self)
846     def join(self, node, type=JOIN_TYPE_ROUTER):  argument
847         self._cli_no_output('dataset clear')
848         self._cli_no_output('dataset networkname', node.get_network_name())
849         self._cli_no_output('dataset networkkey', node.get_network_key())
850         self._cli_no_output('dataset channel', node.get_channel())
851         self._cli_no_output('dataset panid', node.get_panid())
852         self._cli_no_output('dataset commit active')
854             self.set_mode('rn')
856             self.set_mode('-')
858             self.set_mode('rdn')
859             self.set_router_eligible('disable')
861             self.set_mode('rdn')
862             self.set_router_selection_jitter(1)
863         self.interface_up()
864         self.thread_start()
866             verify_within(_check_node_is_router, self._WAIT_TIME, arg=self)
868             verify_within(_check_node_is_child, self._WAIT_TIME, arg=self)
870     def allowlist_node(self, node):  argument
872         self._cli_no_output('macfilter addr add', node.get_ext_addr())
873         self._cli_no_output('macfilter addr allowlist')
875     def un_allowlist_node(self, node):  argument
877         self._cli_no_output('macfilter addr remove', node.get_ext_addr())
879     def set_macfilter_lqi_to_node(self, node, lqi):  argument
880         self._cli_no_output('macfilter rss add-lqi', node.get_ext_addr(), lqi)
885     def nodeidfilter_clear(self, node):  argument
886         self._cli_no_output('nodeidfilter clear')
888     def nodeidfilter_allow(self, node):  argument
889         self._cli_no_output('nodeidfilter allow', node.index)
891     def nodeidfilter_deny(self, node):  argument
892         self._cli_no_output('nodeidfilter deny', node.index)