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

Remove inactive follower threads

main2
Bob Mottram 2019-11-04 11:19:25 +00:00
parent 06025845cb
commit 3e896ee09b
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
daemon.py
View File

@ -468,6 +468,14 @@ class PubServer(BaseHTTPRequestHandler):
createSession(self.server.domain,self.server.port,self.server.useTor) createSession(self.server.domain,self.server.port,self.server.useTor)
if self.server.debug: if self.server.debug:
print('DEBUG: sending c2s post to followers') print('DEBUG: sending c2s post to followers')
# remove inactive threads
inactiveFollowerThreads=[]
for th in self.server.followersThreads:
if not th.is_alive():
inactiveFollowerThreads.append(th)
for th in inactiveFollowerThreads:
self.server.followersThreads.remove(th)
# create a thread to send the post to followers
followersThread= \ followersThread= \
sendToFollowersThread(self.server.session, \ sendToFollowersThread(self.server.session, \
self.server.baseDir, \ self.server.baseDir, \
@ -486,6 +494,10 @@ class PubServer(BaseHTTPRequestHandler):
# retain up to 10 threads # retain up to 10 threads
if len(self.server.followersThreads)>10: if len(self.server.followersThreads)>10:
for i in range(2): for i in range(2):
# kill the thread if it is still alive
if self.server.followersThreads[0].is_alive():
self.server.followersThreads[0].kill()
# remove it from the list
self.server.followersThreads.pop(0) self.server.followersThreads.pop(0)
if self.server.debug: if self.server.debug:
print('DEBUG: handle any unfollow requests') print('DEBUG: handle any unfollow requests')