mirror of
https://github.com/kovidgoyal/calibre.git
synced 2025-07-09 03:04:10 -04:00
...
This commit is contained in:
parent
3967a1ebc1
commit
68aabb6394
@ -196,7 +196,7 @@ class SocketFile(object): # {{{
|
|||||||
|
|
||||||
def readline(self, size=-1, maxsize=sys.maxsize):
|
def readline(self, size=-1, maxsize=sys.maxsize):
|
||||||
buf = self._rbuf
|
buf = self._rbuf
|
||||||
buf.seek(0, 2) # seek end
|
buf.seek(0, os.SEEK_END)
|
||||||
if buf.tell() > 0:
|
if buf.tell() > 0:
|
||||||
# check if we already have it in our buffer
|
# check if we already have it in our buffer
|
||||||
buf.seek(0)
|
buf.seek(0)
|
||||||
@ -232,7 +232,7 @@ class SocketFile(object): # {{{
|
|||||||
buffers.append(data)
|
buffers.append(data)
|
||||||
return b''.join(buffers)
|
return b''.join(buffers)
|
||||||
|
|
||||||
buf.seek(0, 2) # seek end
|
buf.seek(0, os.SEEK_END)
|
||||||
self._rbuf = BytesIO() # reset _rbuf. we consume it via buf.
|
self._rbuf = BytesIO() # reset _rbuf. we consume it via buf.
|
||||||
while True:
|
while True:
|
||||||
data = self.recv(self._rbufsize)
|
data = self.recv(self._rbufsize)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user