diff options
Diffstat (limited to 'tupkg/server')
| -rwxr-xr-x | tupkg/server/tupkgs | 9 |
1 files changed, 8 insertions, 1 deletions
diff --git a/tupkg/server/tupkgs b/tupkg/server/tupkgs index ef010c94..4dd085b6 100755 --- a/tupkg/server/tupkgs +++ b/tupkg/server/tupkgs @@ -108,7 +108,14 @@ class ClientSocket(threading.Thread): def readFiles(self): for i in self.files: - i.fd.write(self.reliableRead(i.actual_size)) + count = 0 + while count != i.actual_size: + if count + 1024 > i.actual_size: + i.fd.write(self.reliableRead(i.actual_size - count)) + count += i.actual_size - count + else: + i.fd.write(self.reliableRead(1024)) + count += 1024 i.fd.flush() reply = {'numpkgs': len(self.files)} for i, v in enumerate(self.files): |