[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