@@ -111,11 +111,12 @@ def readline(self):
111
111
gc .collect ()
112
112
return firstline
113
113
114
- def read (self , size = 0 ):
115
- """Read up to 'size' bytes from the socket, this may be buffered internally!
116
- If 'size' isnt specified, return everything in the buffer."""
117
- #print("Socket read", size)
118
- if size == 0 : # read as much as we can at the moment
114
+ def recv (self , bufsize = 0 ):
115
+ """Reads some bytes from the connected remote address.
116
+ :param int bufsize: maximum number of bytes to receive
117
+ """
118
+ #print("Socket read", bufsize)
119
+ if bufsize == 0 : # read as much as we can at the moment
119
120
while True :
120
121
avail = self .available ()
121
122
if avail :
@@ -129,7 +130,7 @@ def read(self, size=0):
129
130
return ret
130
131
stamp = time .monotonic ()
131
132
132
- to_read = size - len (self ._buffer )
133
+ to_read = bufsize - len (self ._buffer )
133
134
received = []
134
135
while to_read > 0 :
135
136
#print("Bytes to read:", to_read)
@@ -146,15 +147,22 @@ def read(self, size=0):
146
147
self ._buffer += b'' .join (received )
147
148
148
149
ret = None
149
- if len (self ._buffer ) == size :
150
+ if len (self ._buffer ) == bufsize :
150
151
ret = self ._buffer
151
152
self ._buffer = b''
152
153
else :
153
- ret = self ._buffer [:size ]
154
- self ._buffer = self ._buffer [size :]
154
+ ret = self ._buffer [:bufsize ]
155
+ self ._buffer = self ._buffer [bufsize :]
155
156
gc .collect ()
156
157
return ret
157
158
159
+ def read (self , size = 0 ):
160
+ """Read up to 'size' bytes from the socket, this may be buffered internally!
161
+ If 'size' isnt specified, return everything in the buffer.
162
+ NOTE: This method is deprecated and will be removed.
163
+ """
164
+ return self .recv (size )
165
+
158
166
def settimeout (self , value ):
159
167
"""Set the read timeout for sockets, if value is 0 it will block"""
160
168
self ._timeout = value
0 commit comments