x/timmy
Code Issues Proposed changes

Fix accidentally removed try-finally, fix non-conditional queue.put

Browse Source
This commit is contained in:
f3flight 2016-05-03 23:00:36 +00:00
parent 765ef00022
commit 06deaa1ed8
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
timmy/nodes.py
View File

@ -501,8 +501,10 @@ class Nodes(object):
'odir': odir, 'odir': odir,
'fake': fake}, 'fake': fake},
key=key)) key=key))
self.nodes = tools.run_batch(run_items, 100, dict_result=True) try:
lock.unlock() self.nodes = tools.run_batch(run_items, 100, dict_result=True)
finally:
lock.unlock()
def calculate_log_size(self, timeout=15): def calculate_log_size(self, timeout=15):
total_size = 0 total_size = 0

4
timmy/tools.py
View File

@ -67,7 +67,9 @@ class SemaphoreProcess(Process):
def run(self): def run(self):
try: try:
self.queue.put_nowait(self.target(**self.args)) result = self.target(**self.args)
if self.queue:
self.queue.put_nowait(result)
finally: finally:
logging.debug('finished call: %s' % self.target) logging.debug('finished call: %s' % self.target)
self.semaphore.release() self.semaphore.release()