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

discard logs in mpw

Browse source
This commit is contained in:
ed 2021-07-09 17:01:11 +02:00
parent 6c3a976222
commit 2dd2e2c57e
1 changed files with 6 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
copyparty/broker_mpw.py
View file

@ -20,6 +20,8 @@ class MpWorker(object):
self.args = args self.args = args
self.n = n self.n = n
self.log = self._log_disabled if args.q and not args.lo else self._log_enabled
self.retpend = {} self.retpend = {}
self.retpend_mutex = threading.Lock() self.retpend_mutex = threading.Lock()
self.mutex = threading.Lock() self.mutex = threading.Lock()
@ -46,9 +48,12 @@ class MpWorker(object):
# print('k') # print('k')
pass pass
def log(self, src, msg, c=0): def _log_enabled(self, src, msg, c=0):
self.q_yield.put([0, "log", [src, msg, c]]) self.q_yield.put([0, "log", [src, msg, c]])
def _log_disabled(self, src, msg, c=0):
pass
def logw(self, msg, c=0): def logw(self, msg, c=0):
self.log("mp{}".format(self.n), msg, c) self.log("mp{}".format(self.n), msg, c)