@@ -91,7 +91,9 @@ def notification_handler(self, _characteristic: BleakGATTCharacteristic, data: b
9191 Console .log_rx (pkt .ptype , len (data ))
9292 self ._server .broadcast (ClientNotificationEpacketReceived (pkt ))
9393
94- async def create_connection (self , request : GatewayRequestConnectionRequest , dev : BLEDevice , queue : asyncio .Queue ):
94+ async def create_connection_internal (
95+ self , request : GatewayRequestConnectionRequest , dev : BLEDevice , queue : asyncio .Queue
96+ ):
9597 Console .log_info (f"{ dev } : Initiating connection" )
9698 async with BleakClient (dev , timeout = request .timeout_ms / 1000 ) as client :
9799 # Modified from bleak example code
@@ -147,6 +149,12 @@ async def create_connection(self, request: GatewayRequestConnectionRequest, dev:
147149 self ._tasks .pop (request .infuse_id )
148150 Console .log_info (f"{ dev } : Terminating connection" )
149151
152+ async def create_connection (self , request : GatewayRequestConnectionRequest , dev : BLEDevice , queue : asyncio .Queue ):
153+ try :
154+ await self .create_connection_internal (request , dev , queue )
155+ except TimeoutError as e :
156+ Console .log_info (f"Timeout: { str (e )} " )
157+
150158 def datagram_received (self , data : bytes , addr : tuple [str | Any , int ]):
151159 loop = asyncio .get_event_loop ()
152160 request = GatewayRequest .from_json (json .loads (data .decode ("utf-8" )))
0 commit comments