atse/thermostat
1
0
Fork 0
forked from M-Labs/thermostat
Code Issues Pull Requests Activity

Simplify on_connect_btn_clicked

Browse Source 
Raise if OSError
This commit is contained in:
atse 2024-08-21 18:10:19 +08:00
parent 0dbed18ba1
commit b252dc6a44
1 changed files with 27 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
pytec/tec_qt.py
View File

@ -65,6 +65,7 @@ class MainWindow(QtWidgets.QMainWindow):
self.thermostat = Thermostat( self.thermostat = Thermostat(
self, self.report_refresh_spin.value() self, self.report_refresh_spin.value()
) )
self._connecting_task = None
def handle_connection_error(): def handle_connection_error():
self.info_box.display_info_box( self.info_box.display_info_box(
@ -240,38 +241,36 @@ class MainWindow(QtWidgets.QMainWindow):
@asyncSlot() @asyncSlot()
async def on_connect_btn_clicked(self): async def on_connect_btn_clicked(self):
host, port = ( if (self._connecting_task is None) and (not self.thermostat.connected()):
self.conn_menu.host_set_line.text(), self.status_lbl.setText("Connecting...")
self.conn_menu.port_set_spin.value(), self.connect_btn.setText("Stop")
) self.conn_menu.host_set_line.setEnabled(False)
self.conn_menu.port_set_spin.setEnabled(False)
self._connecting_task = None host = self.conn_menu.host_set_line.text()
try: port = self.conn_menu.port_set_spin.value()
if (self._connecting_task is None) or (not self.thermostat.connected()):
self.status_lbl.setText("Connecting...")
self.connect_btn.setText("Stop")
self.conn_menu.host_set_line.setEnabled(False)
self.conn_menu.port_set_spin.setEnabled(False)
try: self._connecting_task = asyncio.create_task(
self._connecting_task = asyncio.wait_for( asyncio.wait_for(
self.thermostat.start_session(host=host, port=port), timeout=5 self.thermostat.start_session(host=host, port=port), timeout=5
) )
await self._connecting_task )
except asyncio.TimeoutError:
return
await self._on_connection_changed(True)
else:
if self._connecting_task is not None:
self._connecting_task.cancel()
await self.bail()
# TODO: Remove asyncio.TimeoutError in Python 3.11
except (OSError, asyncio.TimeoutError):
try: try:
await self._connecting_task
except (OSError, asyncio.TimeoutError, asyncio.CancelledError) as exc:
await self.bail() await self.bail()
except ConnectionResetError: if isinstance(exc, asyncio.CancelledError):
pass return
raise
else:
await self._on_connection_changed(True)
finally:
self._connecting_task = None
elif self._connecting_task is not None:
self._connecting_task.cancel()
else:
await self.bail()
@asyncSlot() @asyncSlot()
async def bail(self): async def bail(self):