[Supervisor-checkins] r848 - in supervisor/trunk/src/supervisor: . tests
Mike Naberezny
mike at maintainable.com
Sun May 17 14:25:52 EDT 2009
Author: Mike Naberezny <mike at maintainable.com>
Date: Sun May 17 14:25:52 2009
New Revision: 848
Log:
supervisor.sendRemoteCommEvent() should set the return value to True.
Modified:
supervisor/trunk/src/supervisor/rpcinterface.py
supervisor/trunk/src/supervisor/tests/test_rpcinterfaces.py
Modified: supervisor/trunk/src/supervisor/rpcinterface.py
==============================================================================
--- supervisor/trunk/src/supervisor/rpcinterface.py (original)
+++ supervisor/trunk/src/supervisor/rpcinterface.py Sun May 17 14:25:52 2009
@@ -776,6 +776,7 @@
events.RemoteCommunicationEvent(type, data)
)
+ return True
def make_allfunc(processes, predicate, func, **extra_kwargs):
""" Return a closure representing a function that calls a
Modified: supervisor/trunk/src/supervisor/tests/test_rpcinterfaces.py
==============================================================================
--- supervisor/trunk/src/supervisor/tests/test_rpcinterfaces.py (original)
+++ supervisor/trunk/src/supervisor/tests/test_rpcinterfaces.py Sun May 17 14:25:52 2009
@@ -1592,11 +1592,12 @@
try:
events.callbacks[:] = [(events.RemoteCommunicationEvent, callback)]
- interface.sendRemoteCommEvent('foo', 'bar')
+ result = interface.sendRemoteCommEvent('foo', 'bar')
finally:
events.callbacks[:] = []
events.clear()
+ self.assertTrue(result)
self.assertEqual(len(L), 1)
event = L[0]
self.assertEqual(event.type, 'foo')
@@ -1614,11 +1615,12 @@
try:
events.callbacks[:] = [(events.RemoteCommunicationEvent, callback)]
- interface.sendRemoteCommEvent(u'fi\xed once', u'fi\xed twice')
+ result = interface.sendRemoteCommEvent(u'fi\xed once', u'fi\xed twice')
finally:
events.callbacks[:] = []
events.clear()
+ self.assertTrue(result)
self.assertEqual(len(L), 1)
event = L[0]
self.assertEqual(event.type, 'fi\xc3\xad once')
More information about the Supervisor-checkins
mailing list