@@ -43,6 +43,8 @@ def set_interface(iface):
4343SOCK_STREAM = const (1 )
4444AF_INET = const (2 )
4545
46+ MAX_PACKET = const (4000 )
47+
4648# pylint: disable=too-many-arguments, unused-argument
4749def getaddrinfo (host , port , family = 0 , socktype = 0 , proto = 0 , flags = 0 ):
4850 """Given a hostname and a port name, return a 'socket.getaddrinfo'
@@ -85,7 +87,7 @@ def readline(self):
8587 #print("Socket readline")
8688 while b'\r \n ' not in self ._buffer :
8789 # there's no line already in there, read some more
88- avail = min (_the_interface .socket_available (self ._socknum ), 4000 )
90+ avail = min (_the_interface .socket_available (self ._socknum ), MAX_PACKET )
8991 if avail :
9092 self ._buffer += _the_interface .socket_read (self ._socknum , avail )
9193 firstline , self ._buffer = self ._buffer .split (b'\r \n ' , 1 )
@@ -98,7 +100,7 @@ def read(self, size=0):
98100 #print("Socket read", size)
99101 if size == 0 : # read as much as we can at the moment
100102 while True :
101- avail = min (_the_interface .socket_available (self ._socknum ), 4000 )
103+ avail = min (_the_interface .socket_available (self ._socknum ), MAX_PACKET )
102104 if avail :
103105 self ._buffer += _the_interface .socket_read (self ._socknum , avail )
104106 else :
@@ -114,7 +116,7 @@ def read(self, size=0):
114116 received = []
115117 while to_read > 0 :
116118 #print("Bytes to read:", to_read)
117- avail = min (_the_interface .socket_available (self ._socknum ), 4000 )
119+ avail = min (_the_interface .socket_available (self ._socknum ), MAX_PACKET )
118120 if avail :
119121 stamp = time .monotonic ()
120122 recv = _the_interface .socket_read (self ._socknum , min (to_read , avail ))
@@ -137,8 +139,7 @@ def read(self, size=0):
137139 return ret
138140
139141 def settimeout (self , value ):
140- """Set the receiving timeout, in seconds. If set to zero, we
141- fully block until data is ready"""
142+ """Set the read timeout for sockets, if value is 0 it will block"""
142143 self ._timeout = value
143144
144145 def close (self ):
0 commit comments