|
@@ -783,7 +783,7 @@ class DefaultControllerPlugin(ControllerPluginBase):
|
|
supervisor = self.ctl.get_supervisor()
|
|
supervisor = self.ctl.get_supervisor()
|
|
for name in names:
|
|
for name in names:
|
|
try:
|
|
try:
|
|
- supervisor.addProcess(name)
|
|
|
|
|
|
+ supervisor.addProcessGroup(name)
|
|
except xmlrpclib.Fault, e:
|
|
except xmlrpclib.Fault, e:
|
|
if e.faultCode == xmlrpc.Faults.SHUTDOWN_STATE:
|
|
if e.faultCode == xmlrpc.Faults.SHUTDOWN_STATE:
|
|
self.ctl.output('ERROR: shutting down')
|
|
self.ctl.output('ERROR: shutting down')
|
|
@@ -807,7 +807,7 @@ class DefaultControllerPlugin(ControllerPluginBase):
|
|
supervisor = self.ctl.get_supervisor()
|
|
supervisor = self.ctl.get_supervisor()
|
|
for name in names:
|
|
for name in names:
|
|
try:
|
|
try:
|
|
- result = supervisor.removeProcess(name)
|
|
|
|
|
|
+ result = supervisor.removeProcessGroup(name)
|
|
except xmlrpclib.Fault, e:
|
|
except xmlrpclib.Fault, e:
|
|
if e.faultCode == xmlrpc.Faults.STILL_RUNNING:
|
|
if e.faultCode == xmlrpc.Faults.STILL_RUNNING:
|
|
self.ctl.output('ERROR: process/group still running: %s'
|
|
self.ctl.output('ERROR: process/group still running: %s'
|