sablink/entropy
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

entropy.cache: EntropyCacher improvements

Browse Source 
this is an optimized version of EntropyCacher.
This commit is contained in:
Fabio Erculiani
2009-04-17 22:26:33 +02:00
parent 49d4ab9f73
commit 351cb904a8
1 changed files with 14 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
libraries/entropy/cache.py
View File

@@ -94,6 +94,8 @@ class EntropyCacher(Singleton):
@return None
"""
with self.__cache_lock:
self.__cache_buffer.clear()
self.__cache_writer = TimeScheduled(1, self.__cacher)
self.__cache_writer.set_delay_before(True)
self.__cache_writer.start()
@@ -121,18 +123,19 @@ class EntropyCacher(Singleton):
@return None
"""
if not self.__alive:
return
if self.__cache_buffer and self.__alive:
watch_dog = 20
while self.__cache_buffer.is_filled() and watch_dog:
watch_dog -= 1
time.sleep(0.5)
self.__alive = False
watch_dog = 20
while self.__cache_buffer.is_filled() and (watch_dog > 0):
watch_dog -= 1
time.sleep(0.5)
with self.__cache_lock:
self.__cache_buffer.clear()
if self.__cache_writer != None:
self.__cache_writer.kill()
self.__cache_writer.join()
self.__alive = False
self.__cache_writer = None
def sync(self, wait = False):
"""
@@ -146,7 +149,9 @@ class EntropyCacher(Singleton):
if not self.__alive:
return
watch_dog = 10
while self.__cache_buffer.is_filled() and ((watch_dog > 0) or wait):
while self.__cache_buffer.is_filled() and ((watch_dog > 0) or wait) \
and self.__alive:
if not wait:
watch_dog -= 1
time.sleep(0.5)