openstack/deb-python-eventlet
Code Issues Proposed changes

Slight improvements to hub.py

Browse Source
This commit is contained in:
Ryan Williams
2010-01-20 21:05:54 -05:00
parent 8cc6c1e1ec
commit 1a375b9e85
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
eventlet/hubs/hub.py
View File

@@ -125,11 +125,13 @@ class BaseHub(object):
def squelch_exception(self, fileno, exc_info): def squelch_exception(self, fileno, exc_info):
traceback.print_exception(*exc_info) traceback.print_exception(*exc_info)
print >>sys.stderr, "Removing descriptor: %r" % (fileno,) sys.stderr.write("Removing descriptor: %r\n" % (fileno,))
sys.stderr.flush()
try: try:
self.remove_descriptor(fileno) self.remove_descriptor(fileno)
except Exception, e: except Exception, e:
print >>sys.stderr, "Exception while removing descriptor! %r" % (e,) sys.stderr.write("Exception while removing descriptor! %r\n" % (e,))
sys.stderr.flush()
def wait(self, seconds=None): def wait(self, seconds=None):
raise NotImplementedError("Implement this in a subclass") raise NotImplementedError("Implement this in a subclass")
@@ -211,7 +213,8 @@ class BaseHub(object):
def squelch_observer_exception(self, observer, exc_info): def squelch_observer_exception(self, observer, exc_info):
traceback.print_exception(*exc_info) traceback.print_exception(*exc_info)
print >>sys.stderr, "Removing observer: %r" % (observer,) sys.stderr.write("Removing observer: %r\n" % (observer,))
sys.stderr.flush()
self.remove_observer(observer) self.remove_observer(observer)
def fire_observers(self, activity): def fire_observers(self, activity):
@@ -228,7 +231,8 @@ class BaseHub(object):
def _debug_squelch_timer_exception(self, timer, exc_info): def _debug_squelch_timer_exception(self, timer, exc_info):
traceback.print_exception(*exc_info) traceback.print_exception(*exc_info)
print >>sys.stderr, "Timer raised: %r" % (timer,) sys.stderr.write("Timer raised: %r\n" % (timer,))
sys.stderr.flush()
squelch_timer_exception = _silent_squelch_timer_exception squelch_timer_exception = _silent_squelch_timer_exception
@@ -305,7 +309,7 @@ class BaseHub(object):
return self.listeners[WRITE].values() return self.listeners[WRITE].values()
def get_timers_count(hub): def get_timers_count(hub):
return max(len(x) for x in [hub.timers, hub.next_timers]) return max(len(hub.timers), len(hub.next_timers))
def set_debug_listeners(self, value): def set_debug_listeners(self, value):
if value: if value: