mirror of
https://github.com/9001/copyparty.git
synced 2025-08-18 09:22:31 -06:00
don't double-eof
This commit is contained in:
parent
524a3ba566
commit
6136b9bf9c
|
@ -192,7 +192,7 @@ class _Unrecv(object):
|
||||||
def recv_ex(self, nbytes):
|
def recv_ex(self, nbytes):
|
||||||
"""read an exact number of bytes"""
|
"""read an exact number of bytes"""
|
||||||
ret = self.recv(nbytes)
|
ret = self.recv(nbytes)
|
||||||
while len(ret) < nbytes:
|
while ret and len(ret) < nbytes:
|
||||||
buf = self.recv(nbytes - len(ret))
|
buf = self.recv(nbytes - len(ret))
|
||||||
if not buf:
|
if not buf:
|
||||||
break
|
break
|
||||||
|
@ -233,7 +233,7 @@ class _LUnrecv(object):
|
||||||
def recv_ex(self, nbytes):
|
def recv_ex(self, nbytes):
|
||||||
"""read an exact number of bytes"""
|
"""read an exact number of bytes"""
|
||||||
ret = self.recv(nbytes)
|
ret = self.recv(nbytes)
|
||||||
while len(ret) < nbytes:
|
while ret and len(ret) < nbytes:
|
||||||
buf = self.recv(nbytes - len(ret))
|
buf = self.recv(nbytes - len(ret))
|
||||||
if not buf:
|
if not buf:
|
||||||
break
|
break
|
||||||
|
|
Loading…
Reference in a new issue