mirrors/copyparty
1
0
Fork 0
mirror of https://github.com/9001/copyparty.git synced 2025-08-17 17:12:13 -06:00
Code Issues Actions Packages Projects Releases Wiki Activity

parallel socket shutdown

Browse source
This commit is contained in:
ed 2022-08-31 08:38:34 +02:00
parent 558bfa4e1e
commit bc6234e032
1 changed files with 7 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
copyparty/httpsrv.py
View file

@ -278,12 +278,12 @@ class HttpSrv(object):
except: except:
pass pass
thrs = []
clients = list(self.clients) clients = list(self.clients)
for cli in clients: for cli in clients:
try: t = threading.Thread(target=cli.shutdown)
cli.shutdown() thrs.append(t)
except: t.start()
pass
if self.tp_q: if self.tp_q:
self.stop_threads(self.tp_nthr) self.stop_threads(self.tp_nthr)
@ -292,6 +292,9 @@ class HttpSrv(object):
if self.tp_q.empty(): if self.tp_q.empty():
break break
for t in thrs:
t.join()
self.log(self.name, "ok bye") self.log(self.name, "ok bye")
def thr_client(self, sck: socket.socket, addr: tuple[str, int]) -> None: def thr_client(self, sck: socket.socket, addr: tuple[str, int]) -> None: