From 5adddb8bc3fec1f0258659ca11a4f13f36210fa0 Mon Sep 17 00:00:00 2001 From: drebs Date: Tue, 4 Aug 2015 17:07:56 -0300 Subject: [feat] add running state method to enc/dec pools --- client/src/leap/soledad/client/encdecpool.py | 7 +++++++ 1 file changed, 7 insertions(+) (limited to 'client/src/leap/soledad') diff --git a/client/src/leap/soledad/client/encdecpool.py b/client/src/leap/soledad/client/encdecpool.py index a0154929..b8805e12 100644 --- a/client/src/leap/soledad/client/encdecpool.py +++ b/client/src/leap/soledad/client/encdecpool.py @@ -67,17 +67,24 @@ class SyncEncryptDecryptPool(object): self._sync_db = sync_db self._pool = None self._delayed_call = None + self._started = False def start(self): self._create_pool() + self._started = True def stop(self): + self._started = False self._destroy_pool() # maybe cancel the next delayed call if self._delayed_call \ and not self._delayed_call.called: self._delayed_call.cancel() + @property + def running(self): + return self._started + def _create_pool(self): self._pool = multiprocessing.Pool(self.WORKERS) -- cgit v1.2.3