tyler.durden/powerline
1
0
Fork 0
mirror of https://github.com/powerline/powerline.git synced 2025-07-23 22:05:43 +02:00
Code Issues Packages Projects Releases Wiki Activity

Use only get/set_update_value functions to access update_value

Browse Source 
Also rename .skip to .crashed
This commit is contained in:
ZyX 2014-02-22 18:01:23 +04:00
parent 725ff69be0
commit 66a2087474
1 changed files with 17 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
powerline/lib/threaded.py
View File

@ -37,7 +37,7 @@ class ThreadedSegment(MultiRunnedThread):
def __init__(self): def __init__(self):
super(ThreadedSegment, self).__init__() super(ThreadedSegment, self).__init__()
self.run_once = True self.run_once = True
self.skip = False self.crashed = False
self.crashed_value = None self.crashed_value = None
self.update_value = None self.update_value = None
self.updated = False self.updated = False
@ -59,31 +59,34 @@ class ThreadedSegment(MultiRunnedThread):
update_value = self.get_update_value(True) update_value = self.get_update_value(True)
self.updated = True self.updated = True
else: else:
update_value = self.update_value update_value = self.get_update_value()
if self.skip: if self.crashed:
return self.crashed_value return self.crashed_value
return self.render(update_value, update_first=update_first, pl=pl, **kwargs) return self.render(update_value, update_first=update_first, pl=pl, **kwargs)
def set_update_value(self):
try:
self.update_value = self.update(self.update_value)
except Exception as e:
self.exception('Exception while updating: {0}', str(e))
self.crashed = True
except KeyboardInterrupt:
self.warn('Caught keyboard interrupt while updating')
self.crashed = True
else:
self.crashed = False
def get_update_value(self, update=False): def get_update_value(self, update=False):
if update: if update:
self.update_value = self.update(self.update_value) self.set_update_value()
return self.update_value return self.update_value
def run(self): def run(self):
while not self.shutdown_event.is_set(): while not self.shutdown_event.is_set():
start_time = monotonic() start_time = monotonic()
try: self.set_update_value()
self.update_value = self.update(self.update_value)
except Exception as e:
self.exception('Exception while updating: {0}', str(e))
self.skip = True
except KeyboardInterrupt:
self.warn('Caught keyboard interrupt while updating')
self.skip = True
else:
self.skip = False
self.shutdown_event.wait(max(self.interval - (monotonic() - start_time), self.min_sleep_time)) self.shutdown_event.wait(max(self.interval - (monotonic() - start_time), self.min_sleep_time))
def shutdown(self): def shutdown(self):