def __init__(self, ip, password):
ConBase.__init__(self)
threading.Thread.__init__(self)
self.daemon = True
self.fifo = deque()
self.fifo_lock = threading.Lock()
# websocket.enableTrace(logging.root.getEffectiveLevel() < logging.INFO)
self.ws = websocket.WebSocketApp("ws://%s:8266" % ip,
on_message=self.on_message,
on_error=self.on_error,
on_close=self.on_close)
self.start()
self.timeout = 5.0
if b'Password:' in self.read(256, blocking=False):
self.ws.send(password + "\r")
if not b'WebREPL connected' in self.read(256, blocking=False):
raise ConError()
else:
raise ConError()
self.timeout = 1.0
logging.info("websocket connected to ws://%s:8266" % ip)
评论列表
文章目录