提交 202a6afa authored 作者: blu's avatar blu

ota updater revise

上级 1e0e5f44
...@@ -142,19 +142,20 @@ class OTAClient: ...@@ -142,19 +142,20 @@ class OTAClient:
self.client.username_pw_set(username=self.username, password=self.password) self.client.username_pw_set(username=self.username, password=self.password)
self.client.on_connect = self.on_connect self.client.on_connect = self.on_connect
self.client.on_message = self.on_message self.client.on_message = self.on_message
self.client.connect_async(self.host, self.port, 30)
#self.client.loop_start() #self.client.loop_start()
#self.client.connect_async(self.host, self.port, 30)
def run(self): def run(self):
retry = 0 retry = 0
while retry < 3: while retry < 3:
try: try:
self.client.connect_async(self.host, self.port, 30)
self.client.loop_forever() self.client.loop_forever()
except Exception as e: except Exception as e:
logger.error("updater network failure - failed to connect mqtt host: {}".format(str(e))) logger.error("updater network failure - failed to connect mqtt host: {}".format(str(e)))
# NOTE: reset network and evdaemon # NOTE: reset network and evdaemon
if retry < 2: if retry < 2:
os.system("systemctl restart networking; systemctl restart evdaemon") os.system("systemctl restart networking")
else: else:
# we don't force restart component in the last round. since network recover may need a small delay # we don't force restart component in the last round. since network recover may need a small delay
time.sleep(10) time.sleep(10)
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论