From 7b0deacfb2e4cece0221c7563b97d3e76bdac8f2 Mon Sep 17 00:00:00 2001 From: lxnay Date: Sat, 14 Mar 2009 15:33:14 +0000 Subject: [PATCH] Entropy/Cache: - add is_started method to EntropyCacher class git-svn-id: http://svn.sabayonlinux.org/projects/entropy/trunk@3159 cd1c1023-2f26-0410-ae45-c471fc1f0318 --- libraries/entropy/cache.py | 28 ++++++++++++++++------------ 1 file changed, 16 insertions(+), 12 deletions(-) diff --git a/libraries/entropy/cache.py b/libraries/entropy/cache.py index 5b2f02ffe..80c7dfbff 100644 --- a/libraries/entropy/cache.py +++ b/libraries/entropy/cache.py @@ -62,6 +62,22 @@ class EntropyCacher(Singleton): continue self.__alive = True + def is_started(self): + return self.__alive + + def stop(self): + if not self.__alive: return + if self.__CacheBuffer and self.__alive: + wd = 20 + while self.__CacheBuffer.is_filled() and wd: + wd -= 1 + time.sleep(0.5) + self.__CacheBuffer.clear() + if self.__CacheWriter != None: + self.__CacheWriter.kill() + self.__CacheWriter.join() + self.__alive = False + def sync(self, wait = False): if not self.__alive: return wd = 10 @@ -83,15 +99,3 @@ class EntropyCacher(Singleton): if not l_o: return return l_o(key) - def stop(self): - if not self.__alive: return - if self.__CacheBuffer and self.__alive: - wd = 20 - while self.__CacheBuffer.is_filled() and wd: - wd -= 1 - time.sleep(0.5) - self.__CacheBuffer.clear() - if self.__CacheWriter != None: - self.__CacheWriter.kill() - self.__CacheWriter.join() - self.__alive = False