@@ -43,6 +43,8 @@ def set_interface(iface):
43
43
SOCK_STREAM = const (1 )
44
44
AF_INET = const (2 )
45
45
46
+ MAX_PACKET = const (4000 )
47
+
46
48
# pylint: disable=too-many-arguments, unused-argument
47
49
def getaddrinfo (host , port , family = 0 , socktype = 0 , proto = 0 , flags = 0 ):
48
50
"""Given a hostname and a port name, return a 'socket.getaddrinfo'
@@ -85,7 +87,7 @@ def readline(self):
85
87
#print("Socket readline")
86
88
while b'\r \n ' not in self ._buffer :
87
89
# 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 )
89
91
if avail :
90
92
self ._buffer += _the_interface .socket_read (self ._socknum , avail )
91
93
firstline , self ._buffer = self ._buffer .split (b'\r \n ' , 1 )
@@ -98,7 +100,7 @@ def read(self, size=0):
98
100
#print("Socket read", size)
99
101
if size == 0 : # read as much as we can at the moment
100
102
while True :
101
- avail = min (_the_interface .socket_available (self ._socknum ), 4000 )
103
+ avail = min (_the_interface .socket_available (self ._socknum ), MAX_PACKET )
102
104
if avail :
103
105
self ._buffer += _the_interface .socket_read (self ._socknum , avail )
104
106
else :
@@ -114,7 +116,7 @@ def read(self, size=0):
114
116
received = []
115
117
while to_read > 0 :
116
118
#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 )
118
120
if avail :
119
121
stamp = time .monotonic ()
120
122
recv = _the_interface .socket_read (self ._socknum , min (to_read , avail ))
@@ -137,8 +139,6 @@ def read(self, size=0):
137
139
return ret
138
140
139
141
def settimeout (self , value ):
140
- """Set the receiving timeout, in seconds. If set to zero, we
141
- fully block until data is ready"""
142
142
self ._timeout = value
143
143
144
144
def close (self ):
0 commit comments