Gecko [ goons4good.org ]

Name	Size	Permission	Date
medusa	[ DIR ]	drwxr-xr-x	2024-07-29 10:18
scripts	[ DIR ]	drwxr-xr-x	2024-07-29 10:18
skel	[ DIR ]	drwxr-xr-x	2024-07-29 10:18
tests	[ DIR ]	drwxr-xr-x	2024-07-29 10:18
ui	[ DIR ]	drwxr-xr-x	2024-07-29 10:18
childutils.py	2.38 KB	-rw-r--r--	2020-03-10 20:45
childutils.pyc	4.26 KB	-rw-r--r--	2020-03-10 20:45
childutils.pyo	4.26 KB	-rw-r--r--	2020-03-10 20:45
confecho.py	154 B	-rw-r--r--	2020-03-10 20:45
confecho.pyc	485 B	-rw-r--r--	2020-03-10 20:45
confecho.pyo	485 B	-rw-r--r--	2020-03-10 20:45
datatypes.py	12.89 KB	-rw-r--r--	2020-03-10 20:45
datatypes.pyc	17.6 KB	-rw-r--r--	2020-03-10 20:45
datatypes.pyo	17.55 KB	-rw-r--r--	2020-03-10 20:45
dispatchers.py	17.5 KB	-rw-r--r--	2020-03-10 20:45
dispatchers.pyc	15.7 KB	-rw-r--r--	2020-03-10 20:45
dispatchers.pyo	15.7 KB	-rw-r--r--	2020-03-10 20:45
events.py	6.58 KB	-rw-r--r--	2020-03-10 20:45
events.pyc	13 KB	-rw-r--r--	2020-03-10 20:45
events.pyo	13 KB	-rw-r--r--	2020-03-10 20:45
http.py	30.28 KB	-rw-r--r--	2020-03-10 20:45
http.pyc	26.31 KB	-rw-r--r--	2020-03-10 20:45
http.pyo	26.31 KB	-rw-r--r--	2020-03-10 20:45
http_client.py	5.95 KB	-rw-r--r--	2020-03-10 20:45
http_client.pyc	8.42 KB	-rw-r--r--	2020-03-10 20:45
http_client.pyo	8.42 KB	-rw-r--r--	2020-03-10 20:45
loggers.py	10.28 KB	-rw-r--r--	2020-03-10 20:45
loggers.pyc	15.04 KB	-rw-r--r--	2020-03-10 20:45
loggers.pyo	14.95 KB	-rw-r--r--	2020-03-10 20:45
options.py	82.66 KB	-rw-r--r--	2020-03-10 20:45
options.pyc	69.29 KB	-rw-r--r--	2020-03-10 20:45
options.pyo	69.29 KB	-rw-r--r--	2020-03-10 20:45
pidproxy.py	1.84 KB	-rw-r--r--	2020-03-10 20:45
pidproxy.pyc	2.92 KB	-rw-r--r--	2020-03-10 20:45
pidproxy.pyo	2.92 KB	-rw-r--r--	2020-03-10 20:45
poller.py	6.54 KB	-rw-r--r--	2020-03-10 20:45
poller.pyc	10.18 KB	-rw-r--r--	2020-03-10 20:45
poller.pyo	10.18 KB	-rw-r--r--	2020-03-10 20:45
process.py	35.4 KB	-rw-r--r--	2020-03-10 20:45
process.pyc	28.68 KB	-rw-r--r--	2020-03-10 20:45
process.pyo	28.68 KB	-rw-r--r--	2020-03-10 20:45
rpcinterface.py	34.71 KB	-rw-r--r--	2020-03-10 20:45
rpcinterface.pyc	29.7 KB	-rw-r--r--	2020-03-10 20:45
rpcinterface.pyo	29.7 KB	-rw-r--r--	2020-03-10 20:45
socket_manager.py	3.04 KB	-rw-r--r--	2020-03-10 20:45
socket_manager.pyc	5.35 KB	-rw-r--r--	2020-03-10 20:45
socket_manager.pyo	5.35 KB	-rw-r--r--	2020-03-10 20:45
states.py	1.62 KB	-rw-r--r--	2020-03-10 20:45
states.pyc	2.23 KB	-rw-r--r--	2020-03-10 20:45
states.pyo	2.23 KB	-rw-r--r--	2020-03-10 20:45
supervisorctl.py	47.77 KB	-rw-r--r--	2020-03-10 20:45
supervisorctl.pyc	43.63 KB	-rw-r--r--	2020-03-10 20:45
supervisorctl.pyo	43.63 KB	-rw-r--r--	2020-03-10 20:45
supervisord.py	14.04 KB	-rw-r--r--	2020-03-10 20:45
supervisord.pyc	12.43 KB	-rw-r--r--	2020-03-10 20:45
supervisord.pyo	12.32 KB	-rw-r--r--	2020-03-10 20:45
version.txt	5 B	-rw-r--r--	2020-03-10 20:45
web.py	22.99 KB	-rw-r--r--	2020-03-10 20:45
web.pyc	18.87 KB	-rw-r--r--	2020-03-10 20:45
web.pyo	18.87 KB	-rw-r--r--	2020-03-10 20:45
xmlrpc.py	21.63 KB	-rw-r--r--	2020-03-10 20:45
xmlrpc.pyc	20.9 KB	-rw-r--r--	2020-03-10 20:45
xmlrpc.pyo	20.9 KB	-rw-r--r--	2020-03-10 20:45

Rename

import sys
import time
import xmlrpclib
from supervisor.xmlrpc import SupervisorTransport
from supervisor.events import ProcessCommunicationEvent
from supervisor.dispatchers import PEventListenerDispatcher

def getRPCTransport(env):
    u = env.get('SUPERVISOR_USERNAME', '')
    p = env.get('SUPERVISOR_PASSWORD', '')
    return SupervisorTransport(u, p, env['SUPERVISOR_SERVER_URL'])

def getRPCInterface(env):
    # dumbass ServerProxy won't allow us to pass in a non-HTTP url,
    # so we fake the url we pass into it and always use the transport's
    # 'serverurl' to figure out what to attach to
    return xmlrpclib.ServerProxy('http://127.0.0.1', getRPCTransport(env))

def get_headers(line):
    return dict([ x.split(':') for x in line.split() ])

def eventdata(payload):
    headerinfo, data = payload.split('\n', 1)
    headers = get_headers(headerinfo)
    return headers, data

def get_asctime(now=None):
    if now is None: # for testing
        now = time.time() # pragma: no cover
    msecs = (now - long(now)) * 1000
    part1 = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime(now))
    asctime = '%s,%03d' % (part1, msecs)
    return asctime

class ProcessCommunicationsProtocol:
    def send(self, msg, fp=sys.stdout):
        fp.write(ProcessCommunicationEvent.BEGIN_TOKEN)
        fp.write(msg)
        fp.write(ProcessCommunicationEvent.END_TOKEN)
        fp.flush()

def stdout(self, msg):
        return self.send(msg, sys.stdout)

def stderr(self, msg):
        return self.send(msg, sys.stderr)

pcomm = ProcessCommunicationsProtocol()

class EventListenerProtocol:
    def wait(self, stdin=sys.stdin, stdout=sys.stdout):
        self.ready(stdout)
        line = stdin.readline()
        headers = get_headers(line)
        payload = stdin.read(int(headers['len']))
        return headers, payload

def ready(self, stdout=sys.stdout):
        stdout.write(PEventListenerDispatcher.READY_FOR_EVENTS_TOKEN)
        stdout.flush()

def ok(self, stdout=sys.stdout):
        self.send('OK', stdout)

def fail(self, stdout=sys.stdout):
        self.send('FAIL', stdout)

def send(self, data, stdout=sys.stdout):
        resultlen = len(data)
        result = '%s%s\n%s' % (PEventListenerDispatcher.RESULT_TOKEN_START,
                               str(resultlen),
                               data)
        stdout.write(result)
        stdout.flush()

listener = EventListenerProtocol()