|
@@ -1797,7 +1797,10 @@ class EventListenerPoolTests(ProcessGroupBaseTests):
|
|
|
self.assertEqual(process1.listener_state, EventListenerStates.READY)
|
|
|
self.assertEqual(pool.event_buffer, [event])
|
|
|
self.assertEqual(options.logger.data[0],
|
|
|
- 'rebuffering event abc for pool whatever (bufsize 0)')
|
|
|
+ 'epipe occurred while sending event abc to listener '
|
|
|
+ 'process1, listener state unchanged')
|
|
|
+ self.assertEqual(options.logger.data[1],
|
|
|
+ 'rebuffering event abc for pool whatever (bufsize 0)')
|
|
|
|
|
|
def test__acceptEvent_attaches_pool_serial_and_serial(self):
|
|
|
from supervisor.process import GlobalSerial
|