52     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)
65         win32api.SetConsoleCtrlHandler(self.__disconnect, True)
68     def __connect(self, device):  argument
69         if self.__handle is not None:
72         self.__handle = paramiko.SSHClient()
73         self.__handle.set_missing_host_key_policy(paramiko.AutoAddPolicy())
75             self.log('Connecting to %s:%s with username=%s', self.ip, self.port, self.username)
76 …     self.__handle.connect(self.ip, port=self.port, username=self.username, password=self.password)
78             if not self.password:
79                 self.__handle.get_transport().auth_none(self.username)
84         self.__handle.get_transport().set_keepalive(self.KEEPALIVE_INTERVAL)
86 …      self.__stdin, self.__stdout, _ = self.__handle.exec_command(device + ' ' + str(self.node_id))
89         self.__stdout.channel.setblocking(0)
93         self.__stdout._set_mode('rb')
95     def __disconnect(self, dwCtrlType):  argument
96         if self.__handle is None:
100         self.send('exit\n')
101         self.__stdin.close()
102         self.__stdout.close()
103         self.__handle.close()
105     def close(self):  argument
110     def send(self, cmd):  argument
111         self.__stdin.write(cmd)
112         self.__stdin.flush()
114     def recv(self):  argument
118                 outputs.append(self.__stdout.read(1))
123     def log(self, fmt, *args):  argument
126             print('%d@%s - %s - %s' % (self.node_id, self.ip, time.strftime('%b %d %H:%M:%S'), msg))
135     def _connect(self):  argument
136         self.__lines = []
139         if self.__handle is None:
140             self.log('SSH connecting ...')
141 …  self.__handle = SSHHandle(self.ssh_ip, self.telnetPort, self.telnetUsername, self.telnetPassword,
142                                       self.device, self.node_id)
144         self.log('connected to %s successfully', self.telnetIp)
147     def _disconnect(self):  argument
151     def _parseConnectionParams(self, params):  argument
156         prefix, self.ssh_ip = discovery_add.split('@')
157         self.tag, self.node_id = prefix.split('_')
158         self.node_id = int(self.node_id)
160         ipaddress.ip_address(self.ssh_ip)
164 …  self.device = '/'.join([config['ot_path'], ot_subpath[self.tag], 'examples/apps/cli/ot-cli-ftd'])
166         self.connectType = 'ip'
167         self.telnetIp = self.port = discovery_add
170         self.telnetPort = ssh['port']
171         self.telnetUsername = ssh['username']
172         self.telnetPassword = ssh['password']
174     def _cliReadLine(self):  argument
175         if len(self.__lines) > 1:
176             return self.__lines.pop(0)
179         if len(self.__lines) != 0:
180             tail = self.__lines.pop()
182         tail += self.__handle.recv()
184         self.__lines += self._lineSepX.split(tail)
185         if len(self.__lines) > 1:
186             return self.__lines.pop(0)
190     def _cliWriteLine(self, line):  argument
191         self.__handle.send(line + '\n')
193     def _onCommissionStart(self):  argument
196     def _onCommissionStop(self):  argument