Check that hubs are empty in tearDown. You have to run nosetests with -s to see these messages
This commit is contained in:
@@ -5,6 +5,8 @@ import errno
|
|||||||
import unittest
|
import unittest
|
||||||
import warnings
|
import warnings
|
||||||
|
|
||||||
|
from eventlet import debug, hubs
|
||||||
|
|
||||||
# convenience for importers
|
# convenience for importers
|
||||||
main = unittest.main
|
main = unittest.main
|
||||||
|
|
||||||
@@ -106,6 +108,15 @@ class LimitedTestCase(unittest.TestCase):
|
|||||||
|
|
||||||
def tearDown(self):
|
def tearDown(self):
|
||||||
self.timer.cancel()
|
self.timer.cancel()
|
||||||
|
try:
|
||||||
|
hub = hubs.get_hub()
|
||||||
|
num_readers = len(hub.get_readers())
|
||||||
|
num_writers = len(hub.get_writers())
|
||||||
|
assert num_readers == num_writers == 0
|
||||||
|
except AssertionError, e:
|
||||||
|
print "ERROR: Hub not empty"
|
||||||
|
print debug.format_hub_timers()
|
||||||
|
print debug.format_hub_listeners()
|
||||||
|
|
||||||
|
|
||||||
def verify_hub_empty():
|
def verify_hub_empty():
|
||||||
@@ -113,7 +124,7 @@ def verify_hub_empty():
|
|||||||
hub = hubs.get_hub()
|
hub = hubs.get_hub()
|
||||||
num_readers = len(hub.get_readers())
|
num_readers = len(hub.get_readers())
|
||||||
num_writers = len(hub.get_writers())
|
num_writers = len(hub.get_writers())
|
||||||
num_timers = len(hub.get_timers_count())
|
num_timers = hub.get_timers_count()
|
||||||
assert num_readers == 0 and num_writers == 0, "Readers: %s Writers: %s" % (num_readers, num_writers)
|
assert num_readers == 0 and num_writers == 0, "Readers: %s Writers: %s" % (num_readers, num_writers)
|
||||||
|
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user