external/aurweb
0
0
Fork 0
mirror of https://gitlab.archlinux.org/archlinux/aurweb.git synced 2025-02-03 10:43:03 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

added support for multiple files in the client and made the file reading less memory intensive for the server (poorly, mind you)

Browse source
This commit is contained in:
jchu 2004-09-02 21:15:10 +00:00
parent 2423a686d6
commit a4710414e0
2 changed files with 17 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
tupkg/client/tupkg
View file

@ -121,14 +121,16 @@ def main(argv=None):
usage() usage()
return 1 return 1
files = []
for i in argv[1:]:
try: try:
fil = ClientFile(argv[1]) files.append(ClientFile(i))
except IOError, err: except IOError, err:
print "Error: " + err.strerror + ": '" + err.filename + "'" print "Error: " + err.strerror + ": '" + err.filename + "'"
usage() usage()
return 1 return 1
cs = ClientSocket([fil], 'localhost', 1034, "bfinch@example.net", "B0b") cs = ClientSocket(files, 'localhost', 1034, "bfinch@example.net", "B0b")
cs.connect() cs.connect()
if not cs.auth(): if not cs.auth():

9
tupkg/server/tupkgs
View file

@ -108,7 +108,14 @@ class ClientSocket(threading.Thread):
def readFiles(self): def readFiles(self):
for i in self.files: 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() i.fd.flush()
reply = {'numpkgs': len(self.files)} reply = {'numpkgs': len(self.files)}
for i, v in enumerate(self.files): for i, v in enumerate(self.files):