##// END OF EJS Templates
cleanup per review by @fperez...
MinRK -
Show More
@@ -321,7 +321,7 b' class IPClusterEngines(BaseParallelApplication):'
321 )
321 )
322 return launcher
322 return launcher
323
323
324 def engines_started_okay(self):
324 def engines_started_ok(self):
325 self.log.info("Engines appear to have started successfully")
325 self.log.info("Engines appear to have started successfully")
326 self.early_shutdown = 0
326 self.early_shutdown = 0
327
327
@@ -330,7 +330,7 b' class IPClusterEngines(BaseParallelApplication):'
330 self.engine_launcher.start(self.n)
330 self.engine_launcher.start(self.n)
331 self.engine_launcher.on_stop(self.engines_stopped_early)
331 self.engine_launcher.on_stop(self.engines_stopped_early)
332 if self.early_shutdown:
332 if self.early_shutdown:
333 ioloop.DelayedCallback(self.engines_started_okay, self.early_shutdown*1000, self.loop).start()
333 ioloop.DelayedCallback(self.engines_started_ok, self.early_shutdown*1000, self.loop).start()
334
334
335 def engines_stopped_early(self, r):
335 def engines_stopped_early(self, r):
336 if self.early_shutdown and not self._stopping:
336 if self.early_shutdown and not self._stopping:
@@ -214,7 +214,7 b' class EngineFactory(RegistrationFactory):'
214
214
215 def abort(self):
215 def abort(self):
216 self.log.fatal("Registration timed out after %.1f seconds"%self.timeout)
216 self.log.fatal("Registration timed out after %.1f seconds"%self.timeout)
217 if '127' in self.url:
217 if self.url.startswith('127.'):
218 self.log.fatal("""
218 self.log.fatal("""
219 If the controller and engines are not on the same machine,
219 If the controller and engines are not on the same machine,
220 you will have to instruct the controller to listen on an external IP (in ipcontroller_config.py):
220 you will have to instruct the controller to listen on an external IP (in ipcontroller_config.py):
General Comments 0
You need to be logged in to leave comments. Login now