fix single-threaded mtag

This commit is contained in:
ed 2021-06-04 19:00:24 +02:00
parent 5cba31a814
commit c533da9129

View file

@ -552,6 +552,7 @@ class Up2k(object):
last_write = time.time() last_write = time.time()
n_buf = 0 n_buf = 0
if mpool:
self._stop_mpool(mpool) self._stop_mpool(mpool)
with self.mutex: with self.mutex:
n_add += len(self._flush_mpool(c3)) n_add += len(self._flush_mpool(c3))