kamp/python-broadlink
1
0
Fork 0
mirror of https://github.com/mjg59/python-broadlink.git synced 2024-11-22 23:17:47 +01:00
Code

Expose retry_intvl option

Browse Source
This commit is contained in:
Felipe Martins Diel 2021-01-11 00:04:00 -03:00
parent 0d80cf99b8
commit 6af6cff36d
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
broadlink/device.py
View File

@ -262,7 +262,7 @@ class device:
"""Return device type."""
return self.type
def send_packet(self, command: int, payload: bytes) -> bytes:
def send_packet(self, command: int, payload: bytes, retry_intvl: float = 1.0) -> bytes:
"""Send a packet to the device."""
self.count = ((self.count + 1) | 0x8000) & 0xFFFF
packet = bytearray(0x38)
@ -315,11 +315,11 @@ class device:
while True:
time_left = timeout - (time.time() - start_time)
conn.settimeout(min(5, time_left))
conn.settimeout(min(retry_intvl, time_left))
conn.sendto(packet, self.host)
try:
resp, _ = conn.recvfrom(2048)
resp = conn.recvfrom(2048)[0]
break
except socket.timeout:
if (time.time() - start_time) > timeout:

10
broadlink/remote.py
View File

@ -13,10 +13,10 @@ class rm(device):
device.__init__(self, *args, **kwargs)
self.type = "RM2"
def _send(self, command: int, data: bytes = b'') -> bytes:
def _send(self, command: int, data: bytes = b'', retry_intvl: float = 1.0) -> bytes:
"""Send a packet to the device."""
packet = struct.pack("<I", command) + data
resp = self.send_packet(0x6A, packet)
resp = self.send_packet(0x6A, packet, retry_intvl=retry_intvl)
check_error(resp[0x22:0x24])
payload = self.decrypt(resp[0x38:])
return payload[0x4:]
@ -27,7 +27,7 @@ class rm(device):
def send_data(self, data: bytes) -> None:
"""Send a code to the device."""
self._send(0x2, data)
self._send(0x2, data=data, retry_intvl=5)
def enter_learning(self) -> None:
"""Enter infrared learning mode."""
@ -71,10 +71,10 @@ class rm4(rm):
device.__init__(self, *args, **kwargs)
self.type = "RM4"
def _send(self, command: int, data: bytes = b'') -> bytes:
def _send(self, command: int, data: bytes = b'', retry_intvl: float = 1.0) -> bytes:
"""Send a packet to the device."""
packet = struct.pack("<HI", len(data) + 4, command) + data
resp = self.send_packet(0x6A, packet)
resp = self.send_packet(0x6A, packet, retry_intvl=retry_intvl)
check_error(resp[0x22:0x24])
payload = self.decrypt(resp[0x38:])
p_len = struct.unpack("<H", payload[:0x2])[0]