From c533da91292484fb303bd3633a90c701e02db6ad Mon Sep 17 00:00:00 2001 From: ed Date: Fri, 4 Jun 2021 19:00:24 +0200 Subject: [PATCH] fix single-threaded mtag --- copyparty/up2k.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/copyparty/up2k.py b/copyparty/up2k.py index a3bd3713..06087b2d 100644 --- a/copyparty/up2k.py +++ b/copyparty/up2k.py @@ -552,9 +552,10 @@ class Up2k(object): last_write = time.time() n_buf = 0 - self._stop_mpool(mpool) - with self.mutex: - n_add += len(self._flush_mpool(c3)) + if mpool: + self._stop_mpool(mpool) + with self.mutex: + n_add += len(self._flush_mpool(c3)) conn.commit() c3.close()