From 2dd2e2c57ee6e6447ca4a2660ae22bd3bb5ee823 Mon Sep 17 00:00:00 2001 From: ed Date: Fri, 9 Jul 2021 17:01:11 +0200 Subject: [PATCH] discard logs in mpw --- copyparty/broker_mpw.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/copyparty/broker_mpw.py b/copyparty/broker_mpw.py index 6ca61bdb..979d6874 100644 --- a/copyparty/broker_mpw.py +++ b/copyparty/broker_mpw.py @@ -20,6 +20,8 @@ class MpWorker(object): self.args = args self.n = n + self.log = self._log_disabled if args.q and not args.lo else self._log_enabled + self.retpend = {} self.retpend_mutex = threading.Lock() self.mutex = threading.Lock() @@ -46,9 +48,12 @@ class MpWorker(object): # print('k') 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]]) + def _log_disabled(self, src, msg, c=0): + pass + def logw(self, msg, c=0): self.log("mp{}".format(self.n), msg, c)