mj-saunders
/
epicyon
forked from indymedia/epicyon
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

More verbose cleardown of inbox queue

main
Bob Mottram 2020-01-27 22:12:39 +00:00
parent 25b22b206b
commit 80735f3b61
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
daemon.py
View File

@ -691,16 +691,19 @@ class PubServer(BaseHTTPRequestHandler):
if len(self.server.inboxQueue)>=self.server.maxQueueLength: if len(self.server.inboxQueue)>=self.server.maxQueueLength:
print('Inbox queue is full ('+str(self.server.maxQueueLength)+' items). Removing oldest items.') print('Inbox queue is full ('+str(self.server.maxQueueLength)+' items). Removing oldest items.')
cleardownStartTime=time.time() cleardownStartTime=time.time()
removals=0
while len(self.server.inboxQueue) >= self.server.maxQueueLength-4: while len(self.server.inboxQueue) >= self.server.maxQueueLength-4:
queueFilename=self.server.inboxQueue[0] queueFilename=self.server.inboxQueue[0]
if os.path.isfile(queueFilename): if os.path.isfile(queueFilename):
try: try:
os.remove(queueFilename) os.remove(queueFilename)
removals+=1
except: except:
print('WARN: unable to remove inbox queue file '+queueFilename)
pass pass
self.server.inboxQueue.pop(0) self.server.inboxQueue.pop(0)
timeDiff=str(int((time.time()-cleardownStartTime)*1000)) timeDiff=str(int((time.time()-cleardownStartTime)*1000))
print('Inbox cleardown took '+timeDiff+' mS') print('Inbox cleardown took '+timeDiff+' mS. Removed '+str(removals)+' items.')
def _updateInboxQueue(self,nickname: str,messageJson: {}, \ def _updateInboxQueue(self,nickname: str,messageJson: {}, \
messageBytes: str) -> int: messageBytes: str) -> int: