Mirrored_Repos/python-kasa
1
0
Fork 0
mirror of https://github.com/python-kasa/python-kasa.git synced 2025-04-27 09:06:24 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Set TCP_NODELAY to avoid needless buffering (#554)

Browse Source
This commit is contained in:
J. Nick Koston 2023-11-27 09:25:49 -06:00 committed by GitHub
parent e98252ff17
commit d3c2861e4a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
kasa/protocol.py
View File

@ -13,6 +13,7 @@ import asyncio
import contextlib import contextlib
import errno import errno
import logging import logging
import socket
import struct import struct
from abc import ABC, abstractmethod from abc import ABC, abstractmethod
from pprint import pformat as pf from pprint import pformat as pf
@ -107,6 +108,12 @@ class TPLinkSmartHomeProtocol(TPLinkProtocol):
task = asyncio.open_connection(self.host, self.port) task = asyncio.open_connection(self.host, self.port)
async with asyncio_timeout(timeout): async with asyncio_timeout(timeout):
self.reader, self.writer = await task self.reader, self.writer = await task
sock: socket.socket = self.writer.get_extra_info("socket")
# Ensure our packets get sent without delay as we do all
# our writes in a single go and we do not want any buffering
# which would needlessly delay the request or risk overloading
# the buffer on the device
sock.setsockopt(socket.IPPROTO_TCP, socket.TCP_NODELAY, 1)
async def _execute_query(self, request: str) -> Dict: async def _execute_query(self, request: str) -> Dict:
"""Execute a query on the device and wait for the response.""" """Execute a query on the device and wait for the response."""