Home
last modified time | relevance | path

Searched refs:self (Results 1 – 25 of 692) sorted by relevance

12345678910>>...28

/openthread-latest/tools/harness-thci/
DOpenThread_WpanCtl.py60 def __init__(self, **kwargs): argument
67 self.UIStatusMsg = ''
68 self.mac = kwargs.get('EUI')
69 self.handle = None
70 self.AutoDUTEnable = False
71 self._is_net = False # whether device is through ser2net
72 …self.logStatus = {'stop': 'stop', 'running': 'running', 'pauseReq': 'pauseReq', 'paused': 'paused'}
73 self.logThreadStatus = self.logStatus['stop']
75 …self.connectType = (kwargs.get('Param5')).strip().lower() if kwargs.get('Param5') is not None else…
77 (self.prompt, self.wpan_cmd_prefix,
[all …]
DOpenThread.py117 def wrapped_api_func(self, *args, **kwargs): argument
124 ret = func(self, *args, **kwargs)
125 self.log("%s returns %r", callstr, ret)
128 self.log("FUNC %s failed: %s", func_name, str(ex))
171 def comm_func(self, *args, **kwargs): argument
172 self._onCommissionStart()
174 return func(self, *args, **kwargs)
176 self._onCommissionStop()
183 def __init__(self, code, msg): argument
185 self.code = code
[all …]
DOpenThread_BR.py66 def __init__(self, ip, port, username, password): argument
67 self.ip = ip
68 self.port = int(port)
69 self.username = username
70 self.password = password
71 self.__handle = None
73 self.__connect()
75 def __connect(self): argument
78 self.close()
80 self.__handle = paramiko.SSHClient()
[all …]
/openthread-latest/tests/scripts/thread-cert/
Dmle.py116 def __init__(self, address): argument
117 self._address = address
120 def address(self): argument
121 return self._address
123 def __eq__(self, other): argument
124 common.expect_the_same_class(self, other)
126 return self.address == other.address
128 def __repr__(self): argument
129 return "SourceAddress(address={})".format(hex(self._address))
134 def parse(self, data, message_info): argument
[all …]
Dsimulator.py53 def __init__(self): argument
54 self._nodes = {}
55 self.commissioning_messages = {}
56 …self._payload_parse_factory = mesh_cop.MeshCopCommandFactory(mesh_cop.create_default_mesh_cop_tlv_…
57 self._mesh_cop_msg_set = mesh_cop.create_mesh_cop_message_type_set()
59 def __del__(self): argument
60 self._nodes = None
62 def add_node(self, node): argument
63 self._nodes[node.nodeid] = node
64 self.commissioning_messages[node.nodeid] = []
[all …]
Dnode.py67 def __init__(self, nodeid: int, backbone_network: str, **kwargs): argument
68 self.verbose = int(float(os.getenv('VERBOSE', 0)))
71 self.backbone_network = backbone_network
73 self._docker_name = config.OTBR_DOCKER_NAME_PREFIX + str(nodeid)
74 self._prepare_ot_rcp_sim(nodeid)
75 self._launch_docker()
78 self.destroy()
81 def _prepare_ot_rcp_sim(self, nodeid: int): argument
82 … self._socat_proc = subprocess.Popen(['socat', '-d', '-d', 'pty,raw,echo=0', 'pty,raw,echo=0'],
87 line = self._socat_proc.stderr.readline().decode('ascii').strip()
[all …]
Dnetwork_data.py53 def __init__(self, stable): argument
54 self._stable = stable
57 def stable(self): argument
58 return self._stable
63 def parse(self, data, message_info): argument
75 factory = self._get_factory(_type)
87 def __init__(self, border_router_16, prf): argument
88 self._border_router_16 = border_router_16
89 self._prf = prf
92 def border_router_16(self): argument
[all …]
Dv1_2_test_multicast_listener_registration.py123 …def _bootstrap(self, bbr_1_enable_backbone_router=True, turn_on_bbr_2=True, turn_on_router_1_1=Tru… argument
131 self.nodes[BBR_1].set_router_selection_jitter(ROUTER_SELECTION_JITTER)
132 self.nodes[BBR_1].set_bbr_registration_jitter(BBR_REGISTRATION_JITTER)
134 … self.nodes[BBR_1].set_backbone_router(seqno=1, reg_delay=REREG_DELAY, mlr_timeout=MLR_TIMEOUT)
135 self.nodes[BBR_1].start()
137 self.simulator.go(WAIT_TIME * 2)
138 self.assertEqual(self.nodes[BBR_1].get_state(), 'leader')
141 self.nodes[BBR_1].enable_backbone_router()
143 self.simulator.go(WAIT_TIME)
144 self.assertEqual(self.nodes[BBR_1].get_backbone_router_state(), 'Primary')
[all …]
Dmesh_cop.py109 def __init__(self, channel_page, channel): argument
110 self._channel_page = channel_page
111 self._channel = channel
114 def channel_page(self): argument
115 return self._channel_page
118 def channel(self): argument
119 return self._channel
121 def __eq__(self, other): argument
122 common.expect_the_same_class(self, other)
124 return (self._channel_page == other._channel_page and self._channel == other.__channel)
[all …]
Dtest_service.py75 def hasAloc(self, node_id, service_id): argument
76 for addr in self.nodes[node_id].get_ip6_address(config.ADDRESS_TYPE.ALOC):
84 def pingFromAll(self, addr): argument
85 for n in list(self.nodes.values()):
86 self.assertTrue(n.ping(addr))
88 def failToPingFromAll(self, addr): argument
89 for n in list(self.nodes.values()):
90 self.assertFalse(n.ping(addr, timeout=3))
92 def test(self): argument
93 self.nodes[LEADER].start()
[all …]
Dtest_srp_register_services_diff_lease.py69 def test(self): argument
70 server = self.nodes[SERVER]
71 client = self.nodes[CLIENT]
77 self.simulator.go(config.LEADER_STARTUP_DELAY)
78 self.assertEqual(server.get_state(), 'leader')
81 self.simulator.go(config.ROUTER_STARTUP_DELAY)
82 self.assertEqual(client.get_state(), 'router')
87 self.simulator.go(15)
99 self.simulator.go(5)
101 self.check_services_on_client(client, 1)
[all …]
Dipv6.py118 def parse(self, data, message_info): argument
146 def to_bytes(self): argument
154 def __len__(self): argument
169 def type(self): argument
180 def __init__(self, next_header, hdr_ext_len=0): argument
181 self.next_header = next_header
182 self.hdr_ext_len = hdr_ext_len
188 def __init__(self, header): argument
189 self.header = header
192 def checksum(self): argument
[all …]
Dcoap.py66 def __init__(self, delta, length): argument
67 self._delta = delta
68 self._length = length
71 def delta(self): argument
72 return self._delta
75 def length(self): argument
76 return self._length
79 def is_payload_marker(self): argument
80 return self.delta == 0xF and self.length == 0xF
108 def __init__(self, _type, value): argument
[all …]
Dlowpan.py47 def __init__(self, tf, nh, hlim, cid, sac, sam, m, dac, dam): argument
48 self._tf = tf
49 self._nh = nh
50 self._hlim = hlim
51 self._cid = cid
52 self._sac = sac
53 self._sam = sam
54 self._m = m
55 self._dac = dac
56 self._dam = dam
[all …]
Dnetwork_diag.py61 def __init__(self, addresses: List[ipaddress.IPv6Address]): argument
62 self._addresses = addresses
65 def addresses(self): argument
66 return self._addresses
68 def __eq__(self, other): argument
69 common.expect_the_same_class(self, other)
70 return self.addresses == other.addresses
72 def __repr__(self): argument
78 def parse(self, data, message_info): argument
87 def __init__(self, counters: List[int]): argument
[all …]
/openthread-latest/tests/toranj/cli/
Dcli.py73 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
[all …]
/openthread-latest/tools/harness-automation/autothreadharness/
Dopen_thread_controller.py52 def __init__(self, port, log=False): argument
58 super(OpenThreadController, self).__init__()
59 self.port = port
60 self.handle = None
61 self.lines = []
62 self._log = log
63 self._is_net = False
64 self._init()
66 def _init(self): argument
67 self._connect()
[all …]
Dpdu_controller.py53 def open(self, **params): argument
57 def reboot(self, **params): argument
61 def close(self): argument
69 def open(self, **params): argument
72 def reboot(self, **params): argument
75 def close(self): argument
81 def __init__(self): argument
82 self.tn = None
84 def __del__(self): argument
85 self.close()
[all …]
/openthread-latest/tools/tcat_ble_client/dataset/
Ddataset_entries.py28 def __init__(self, type: MeshcopTlvType): argument
29 self.type = type
30 self.length = None
31 self.maxlen = None
33 def print_content(self, indent: int = 0, excluded_fields: List[str] = []): argument
36 for attr_name in dir(self):
38 value = getattr(self, attr_name)
45 def to_tlv(self) -> TLV: argument
49 def set_from_tlv(self, tlv: TLV): argument
53 def set(self, args: List[str]): argument
[all …]
/openthread-latest/tools/harness-simulation/harness/Thread_Harness/THCI/
DOpenThread_Sim.py52 def __init__(self, ip, port, username, password, device, node_id): argument
53 self.ip = ip
54 self.port = int(port)
55 self.username = username
56 self.password = password
57 self.node_id = node_id
58 self.__handle = None
59 self.__stdin = None
60 self.__stdout = None
62 self.__connect(device)
[all …]
/openthread-latest/tools/cp-caps/
Drcp_caps_test.py51 def __init__(self): argument
52 self.__dut = self.__connect_dut()
53 self.__ref = self.__connect_reference_device()
55 def test_diag_commands(self): argument
57 self.__dut.factory_reset()
58 self.__ref.factory_reset()
60 ret = self.__dut.is_command_supported('diag start')
65 self.__dut.diag_start()
66 self.__ref.diag_start()
68 self.__test_diag_channel()
[all …]
/openthread-latest/tests/toranj/ncp/
Dwpan.py323 def __init__(self, radios=None, verbose=_VERBOSE): argument
329 self._index = index
330 self._interface_name = self._INTFC_NAME_PREFIX + str(index)
331 self._verbose = verbose
333 …ncp_socket_path = 'system:{}{} {} --time-speed={}'.format(self._OT_NCP_FTD, '' if radios is None e…
334 index, self._SPEED_UP_FACTOR)
336 cmd = self._WPANTUND + \
338 ' -o Config:TUN:InterfaceName {}'.format(self._interface_name) + \
343 self._tund_log_file = open(self._TUND_LOG_FNAME + str(index) + '.log', 'wb')
345 self._tund_log_file = None
[all …]
/openthread-latest/third_party/mbedtls/repo/scripts/mbedtls_dev/
Dmacro_collector.py14 def __init__(self, filename: str, line_number: Union[int, str]) -> None: argument
16 super(ReadFileLineException, self).__init__(message)
17 self.filename = filename
18 self.line_number = line_number
40 def __init__(self, filename: str, binary: bool = False) -> None: argument
41 self.filename = filename
42 self.file = None #type: Optional[IO[str]]
43 self.line_number = 'entry' #type: Union[int, str]
44 self.generator = None #type: Optional[Iterable[Tuple[int, str]]]
45 self.binary = binary
[all …]
Dbignum_core.py40 def __init__(self, input_hex: str, descr: str, count: int) -> None: argument
41 self.input_hex = input_hex
42 self.number_description = descr
43 self.shift_count = count
44 self.result = bignum_common.hex_to_int(input_hex) >> count
46 def arguments(self) -> List[str]: argument
47 return ['"{}"'.format(self.input_hex),
48 str(self.shift_count),
49 '"{:0{}x}"'.format(self.result, len(self.input_hex))]
51 def description(self) -> str: argument
[all …]
/openthread-latest/tools/otci/otci/
Dotci.py54 def __init__(self, otcmd: OTCommandHandler): argument
60 self.__otcmd: OTCommandHandler = otcmd
61 self.__logger = logging.getLogger(name=str(self))
63 def __repr__(self): argument
65 return repr(self.__otcmd)
67 …def wait(self, duration: float, expect_line: Optional[Union[str, Pattern, Collection[Any]]] = None… argument
74 self.log('info', "wait for %.3f seconds", duration)
76 self.__otcmd.wait(duration)
81 output = self.__otcmd.wait(1)
91 def close(self): argument
[all …]

12345678910>>...28