forked from indymedia/epicyon
clear
parent
dac81b5509
commit
55fa512d54
4
inbox.py
4
inbox.py
|
@ -972,7 +972,7 @@ def inboxAfterCapabilities(session,keyId: str,handle: str,messageJson: {}, \
|
||||||
def restoreQueueItems(baseDir: str,queue: []) -> None:
|
def restoreQueueItems(baseDir: str,queue: []) -> None:
|
||||||
"""Checks the queue for each account and appends filenames
|
"""Checks the queue for each account and appends filenames
|
||||||
"""
|
"""
|
||||||
queue=[]
|
queue.clear()
|
||||||
for subdir,dirs,files in os.walk(baseDir+'/accounts'):
|
for subdir,dirs,files in os.walk(baseDir+'/accounts'):
|
||||||
for account in dirs:
|
for account in dirs:
|
||||||
queueDir=baseDir+'/accounts/'+account+'/queue'
|
queueDir=baseDir+'/accounts/'+account+'/queue'
|
||||||
|
@ -1018,7 +1018,7 @@ def runInboxQueue(projectVersion: str, \
|
||||||
itemReadFailed=0
|
itemReadFailed=0
|
||||||
|
|
||||||
while True:
|
while True:
|
||||||
time.sleep(1)
|
time.sleep(1)
|
||||||
if len(queue)>0:
|
if len(queue)>0:
|
||||||
currTime=int(time.time())
|
currTime=int(time.time())
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue