|
@@ -247,10 +247,9 @@ class SubprocessTests(unittest.TestCase):
|
|
|
events.subscribe(events.ProcessStateEvent, lambda x: L.append(x))
|
|
|
result = instance.spawn()
|
|
|
self.assertEqual(result, None)
|
|
|
- self.assertEqual(instance.spawnerr,
|
|
|
- 'unknown error making dispatchers: EPERM')
|
|
|
- self.assertEqual(options.logger.data[0],
|
|
|
- "spawnerr: unknown error making dispatchers: EPERM")
|
|
|
+ msg = "unknown error making dispatchers for 'good': EPERM"
|
|
|
+ self.assertEqual(instance.spawnerr, msg)
|
|
|
+ self.assertEqual(options.logger.data[0], "spawnerr: %s" % msg)
|
|
|
self.assertTrue(instance.delay)
|
|
|
self.assertTrue(instance.backoff)
|
|
|
from supervisor.states import ProcessStates
|
|
@@ -275,10 +274,9 @@ class SubprocessTests(unittest.TestCase):
|
|
|
events.subscribe(events.ProcessStateEvent, lambda x: L.append(x))
|
|
|
result = instance.spawn()
|
|
|
self.assertEqual(result, None)
|
|
|
- self.assertEqual(instance.spawnerr,
|
|
|
- "unknown error making dispatchers: EISDIR")
|
|
|
- self.assertEqual(options.logger.data[0],
|
|
|
- "spawnerr: unknown error making dispatchers: EISDIR")
|
|
|
+ msg = "unknown error making dispatchers for 'cat': EISDIR"
|
|
|
+ self.assertEqual(instance.spawnerr, msg)
|
|
|
+ self.assertEqual(options.logger.data[0], "spawnerr: %s" % msg)
|
|
|
self.assertTrue(instance.delay)
|
|
|
self.assertTrue(instance.backoff)
|
|
|
from supervisor.states import ProcessStates
|
|
@@ -300,10 +298,9 @@ class SubprocessTests(unittest.TestCase):
|
|
|
events.subscribe(events.ProcessStateEvent, lambda x: L.append(x))
|
|
|
result = instance.spawn()
|
|
|
self.assertEqual(result, None)
|
|
|
- self.assertEqual(instance.spawnerr,
|
|
|
- "Too many processes in process table to spawn 'good'")
|
|
|
- self.assertEqual(options.logger.data[0],
|
|
|
- "spawnerr: Too many processes in process table to spawn 'good'")
|
|
|
+ msg = "Too many processes in process table to spawn 'good'"
|
|
|
+ self.assertEqual(instance.spawnerr, msg)
|
|
|
+ self.assertEqual(options.logger.data[0], "spawnerr: %s" % msg)
|
|
|
self.assertEqual(len(options.parent_pipes_closed), 6)
|
|
|
self.assertEqual(len(options.child_pipes_closed), 6)
|
|
|
self.assertTrue(instance.delay)
|
|
@@ -327,10 +324,9 @@ class SubprocessTests(unittest.TestCase):
|
|
|
events.subscribe(events.ProcessStateEvent, lambda x: L.append(x))
|
|
|
result = instance.spawn()
|
|
|
self.assertEqual(result, None)
|
|
|
- self.assertEqual(instance.spawnerr,
|
|
|
- 'unknown error during fork: EPERM')
|
|
|
- self.assertEqual(options.logger.data[0],
|
|
|
- "spawnerr: unknown error during fork: EPERM")
|
|
|
+ msg = "unknown error during fork for 'good': EPERM"
|
|
|
+ self.assertEqual(instance.spawnerr, msg)
|
|
|
+ self.assertEqual(options.logger.data[0], "spawnerr: %s" % msg)
|
|
|
self.assertEqual(len(options.parent_pipes_closed), 6)
|
|
|
self.assertEqual(len(options.child_pipes_closed), 6)
|
|
|
self.assertTrue(instance.delay)
|