Cleaning up some ampoule outputs.
This commit is contained in:
parent
2481a9b493
commit
d5c1d35406
2 changed files with 1 additions and 5 deletions
|
|
@ -11,7 +11,6 @@ class AMPChild(amp.AMP):
|
||||||
def connectionLost(self, reason):
|
def connectionLost(self, reason):
|
||||||
amp.AMP.connectionLost(self, reason)
|
amp.AMP.connectionLost(self, reason)
|
||||||
from twisted.internet import reactor
|
from twisted.internet import reactor
|
||||||
print "connectionLost called", reason
|
|
||||||
try:
|
try:
|
||||||
reactor.stop()
|
reactor.stop()
|
||||||
except error.ReactorNotRunning:
|
except error.ReactorNotRunning:
|
||||||
|
|
@ -29,9 +28,6 @@ class AMPChild(amp.AMP):
|
||||||
import os
|
import os
|
||||||
os._exit(-1)
|
os._exit(-1)
|
||||||
|
|
||||||
def processEnded(self, *args, **kwargs):
|
|
||||||
print "processEnded called", args, kwargs
|
|
||||||
|
|
||||||
def shutdown(self):
|
def shutdown(self):
|
||||||
"""
|
"""
|
||||||
This method is needed to shutdown the child gently without
|
This method is needed to shutdown the child gently without
|
||||||
|
|
|
||||||
|
|
@ -134,7 +134,7 @@ class ProcessPool(object):
|
||||||
Adds the newly created child process to the pool.
|
Adds the newly created child process to the pool.
|
||||||
"""
|
"""
|
||||||
def restart(child, reason):
|
def restart(child, reason):
|
||||||
log.msg("FATAL: Restarting after %s" % (reason,))
|
#log.msg("FATAL: Restarting after %s" % (reason,))
|
||||||
self._pruneProcess(child)
|
self._pruneProcess(child)
|
||||||
return self.startAWorker()
|
return self.startAWorker()
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue