GitHub/Anki
1
0
Fork 0
mirror of https://github.com/ankitects/anki.git synced 2025-11-09 14:17:13 -05:00
Code Issues Projects Releases Packages 1 Wiki Activity Actions

use a constant for chunk size

Browse source
This commit is contained in:
Damien Elmes 2010-02-18 17:36:54 +09:00
parent 7bc81c81bb
commit 7c8e612704
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
anki/sync.py
View file

@ -39,6 +39,7 @@ from hooks import runHook
if simplejson.__version__ < "1.7.3": if simplejson.__version__ < "1.7.3":
raise "SimpleJSON must be 1.7.3 or later." raise "SimpleJSON must be 1.7.3 or later."
CHUNK_SIZE = 32768
MIME_BOUNDARY = "Anki-sync-boundary" MIME_BOUNDARY = "Anki-sync-boundary"
# live # live
SYNC_URL = "http://anki.ichi2.net/sync/" SYNC_URL = "http://anki.ichi2.net/sync/"
@ -47,6 +48,7 @@ SYNC_HOST = "anki.ichi2.net"; SYNC_PORT = 80
#SYNC_URL = "http://localhost:8001/sync/" #SYNC_URL = "http://localhost:8001/sync/"
#SYNC_HOST = "localhost"; SYNC_PORT = 8001 #SYNC_HOST = "localhost"; SYNC_PORT = 8001
KEYS = ("models", "facts", "cards", "media") KEYS = ("models", "facts", "cards", "media")
########################################################################## ##########################################################################
@ -72,7 +74,7 @@ def incrementalSend(self, strOrFile):
while 1: while 1:
if sendProgressHook: if sendProgressHook:
sendProgressHook(cnt) sendProgressHook(cnt)
data = strOrFile.read(32768) data = strOrFile.read(CHUNK_SIZE)
cnt += len(data) cnt += len(data)
if not data: if not data:
break break
@ -965,7 +967,7 @@ and cards.id in %s""" % ids2str([c[0] for c in cards])))
# data # data
comp = zlib.compressobj() comp = zlib.compressobj()
while 1: while 1:
data = src.read(32768) data = src.read(CHUNK_SIZE)
if not data: if not data:
tmp.write(comp.flush()) tmp.write(comp.flush())
break break
@ -1004,12 +1006,12 @@ and cards.id in %s""" % ids2str([c[0] for c in cards])))
decomp = zlib.decompressobj() decomp = zlib.decompressobj()
cnt = 0 cnt = 0
while 1: while 1:
data = src.read(32768) data = src.read(CHUNK_SIZE)
if not data: if not data:
tmp.write(decomp.flush()) tmp.write(decomp.flush())
break break
tmp.write(decomp.decompress(data)) tmp.write(decomp.decompress(data))
cnt += 32768 cnt += CHUNK_SIZE
runHook("fullSyncProgress", "fromServer", cnt) runHook("fullSyncProgress", "fromServer", cnt)
src.close() src.close()
tmp.close() tmp.close()