|
|
@@ -141,7 +141,7 @@ class DummyOptions:
|
|
|
def get_pid(self):
|
|
|
import os
|
|
|
return os.getpid()
|
|
|
-
|
|
|
+
|
|
|
def check_execv_args(self, filename, argv, st):
|
|
|
if filename == '/bad/filename':
|
|
|
from supervisor.options import NotFound
|
|
|
@@ -265,7 +265,7 @@ class DummyLogger:
|
|
|
if kw:
|
|
|
msg = msg % kw
|
|
|
self.data.append(msg)
|
|
|
-
|
|
|
+
|
|
|
def reopen(self):
|
|
|
self.reopened = True
|
|
|
def close(self):
|
|
|
@@ -348,7 +348,7 @@ class DummySocketManager:
|
|
|
|
|
|
def get_socket(self):
|
|
|
return DummySocket(self._config.fd)
|
|
|
-
|
|
|
+
|
|
|
class DummyProcess:
|
|
|
# Initial state; overridden by instance variables
|
|
|
pid = 0 # Subprocess pid; 0 when not running
|
|
|
@@ -545,7 +545,7 @@ def makeExecutable(file, substitutions=None):
|
|
|
import os
|
|
|
import sys
|
|
|
import tempfile
|
|
|
-
|
|
|
+
|
|
|
if substitutions is None:
|
|
|
substitutions = {}
|
|
|
data = open(file).read()
|
|
|
@@ -554,7 +554,7 @@ def makeExecutable(file, substitutions=None):
|
|
|
substitutions['PYTHON'] = sys.executable
|
|
|
for key in substitutions.keys():
|
|
|
data = data.replace('<<%s>>' % key.upper(), substitutions[key])
|
|
|
-
|
|
|
+
|
|
|
tmpnam = tempfile.mktemp(prefix=last)
|
|
|
f = open(tmpnam, 'w')
|
|
|
f.write(data)
|
|
|
@@ -636,7 +636,7 @@ class DummyRequest:
|
|
|
|
|
|
def get_server_url(self):
|
|
|
return 'http://example.com'
|
|
|
-
|
|
|
+
|
|
|
|
|
|
class DummyRPCInterfaceFactory:
|
|
|
def __init__(self, supervisord, **config):
|
|
|
@@ -803,9 +803,9 @@ class DummySupervisorRPCNamespace:
|
|
|
raise Fault(xmlrpc.Faults.NOT_RUNNING, 'NOT_RUNNING')
|
|
|
if name == 'FAILED':
|
|
|
raise Fault(xmlrpc.Faults.FAILED, 'FAILED')
|
|
|
-
|
|
|
+
|
|
|
return True
|
|
|
-
|
|
|
+
|
|
|
def stopAllProcesses(self):
|
|
|
from supervisor import xmlrpc
|
|
|
return [
|
|
|
@@ -936,15 +936,15 @@ class DummyProcessGroup:
|
|
|
|
|
|
def stop_all(self):
|
|
|
self.all_stopped = True
|
|
|
-
|
|
|
+
|
|
|
def get_unstopped_processes(self):
|
|
|
return self.unstopped_processes
|
|
|
|
|
|
def get_dispatchers(self):
|
|
|
return self.dispatchers
|
|
|
-
|
|
|
+
|
|
|
class DummyFCGIProcessGroup(DummyProcessGroup):
|
|
|
-
|
|
|
+
|
|
|
def __init__(self, config):
|
|
|
DummyProcessGroup.__init__(self, config)
|
|
|
self.socket_manager = DummySocketManager(config.socket_config)
|
|
|
@@ -1012,7 +1012,7 @@ class DummyDispatcher:
|
|
|
if self.flush_error:
|
|
|
raise OSError(self.flush_error)
|
|
|
self.flushed = True
|
|
|
-
|
|
|
+
|
|
|
class DummyStream:
|
|
|
def __init__(self, error=None):
|
|
|
self.error = error
|
|
|
@@ -1033,7 +1033,7 @@ class DummyStream:
|
|
|
pass
|
|
|
def tell(self):
|
|
|
return len(self.written)
|
|
|
-
|
|
|
+
|
|
|
class DummyEvent:
|
|
|
def __init__(self, serial='abc'):
|
|
|
if serial is not None:
|
|
|
@@ -1041,7 +1041,7 @@ class DummyEvent:
|
|
|
|
|
|
def __str__(self):
|
|
|
return 'dummy event'
|
|
|
-
|
|
|
+
|
|
|
def dummy_handler(event, result):
|
|
|
pass
|
|
|
|
Jason R. Coombs