52     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()
68         if not self._log:
71         self.start()
73     def __del__(self):  argument
74         self.close()
76     def close(self):  argument
77         if self.is_alive():
78             self.viewing = False
79             self.join()
81         self._close()
83     def __enter__(self):  argument
84         return self
86     def __exit__(self, type, value, traceback):  argument
87         self.close()
89     def _close(self):  argument
90         if self.handle:
91             self.handle.close()
92             self.handle = None
94     def _connect(self):  argument
95         logger.debug('My port is %s', self.port)
96         if self.port.startswith('NET'):
97             portnum = settings.SER2NET_PORTBASE + int(self.port.split('NET')[1])
100             self.handle = socket.create_connection(address)
101             self.handle.setblocking(0)
102             self._is_net = True
103         elif ':' in self.port:
104             host, port = self.port.split(':')
105             self.handle = socket.create_connection((host, port))
106             self.handle.setblocking(0)
107             self._is_net = True
109             self.handle = serial.Serial(self.port, 115200, timeout=0, xonxoff=True)
110             self._is_net = False
112     def _read(self, size=512):  argument
113         if self._is_net:
114             return self.handle.recv(size)
116             return self.handle.read(size)
118     def _write(self, data):  argument
119         if self._is_net:
120             self.handle.sendall(data)
122             self.handle.write(data)
124     def _expect(self, expected, times=50):  argument
131         logger.debug('[%s] Expecting [%s]', self.port, expected)
137             line = self._readline()
150     def _readline(self):  argument
156         if len(self.lines) > 1:
157             return self.lines.pop(0)
160         if len(self.lines):
161             tail = self.lines.pop()
164             tail += self._read()
169         self.lines += linesepx.split(tail)
170         if len(self.lines) > 1:
171             return self.lines.pop(0)
173     def _sendline(self, line):  argument
179         self.lines = []
181             self._read()
186         self._write(line + '\r\n')
191     def _req(self, req):  argument
203         self._log and self.pause()
210                 self._sendline(req)
211                 self._expect(req)
217                     line = self._readline()
229                 self.close()
230                 self._init()
232         self._log and self.resume()
235     def run(self):  argument
238         self.viewing = True
239         while self.viewing and self._lock.acquire():
241                 line = self._readline()
246             self._lock.release()
249     def is_started(self):  argument
255         state = self._req('state')[0]
258     def start(self):  argument
261         self._req('ifconfig up')
262         self._req('thread start')
264     def stop(self):  argument
267         self._req('thread stop')
268         self._req('ifconfig down')
270     def reset(self):  argument
274         self._log and self.pause()
275         self._sendline('reset')
276         self._read()
277         self._log and self.resume()
279     def resume(self):  argument
281         self._lock.release()
283     def pause(self):  argument
285         self._lock.acquire()
288     def networkname(self):  argument
290         return self._req('networkname')[0]
293     def networkname(self, value):  argument
294         self._req('networkname %s' % value)
297     def mode(self):  argument
299         return self._req('mode')[0]
302     def mode(self, value):  argument
303         self._req('mode %s' % value)
306     def mac(self):  argument
308         return self._req('extaddr')[0]
311     def addrs(self):  argument
313         return self._req('ipaddr')
316     def short_addr(self):  argument
318         return self._req('rloc16')[0]
321     def channel(self):  argument
323         return int(self._req('channel')[0])
326     def channel(self, value):  argument
327         self._req('channel %d' % value)
330     def panid(self):  argument
332         return self._req('panid')[0]
335     def panid(self, value):  argument
336         self._req('panid %s' % value)
339     def extpanid(self):  argument
341         return self._req('extpanid')[0]
344     def extpanid(self, value):  argument
345         self._req('extpanid %s' % value)
348     def child_timeout(self):  argument
350         return self._req('childtimeout')[0]
353     def child_timeout(self, value):  argument
354         self._req('childtimeout %d' % value)
357     def version(self):  argument
359         return self._req('version')[0]
361     def add_prefix(self, prefix, flags, prf):  argument
369         self._req('prefix add %s %s %s' % (prefix, flags, prf))
371         self._req('netdata register')
373     def remove_prefix(self, prefix):  argument
376         self._req('prefix remove %s' % prefix)
378         self._req('netdata register')
380     def enable_denylist(self):  argument
382         self._req('denylist enable')
384     def add_denylist(self, mac):  argument
386         self._req('denylist add %s' % mac)