Gecko [ tsuru-no-tsurugi.tokyo ]

Name	Size	Permission	Date
__pycache__	[ DIR ]	drwxr-xr-x	2025-02-27 19:58
medusa	[ DIR ]	drwxr-xr-x	2025-02-27 19:58
scripts	[ DIR ]	drwxr-xr-x	2025-02-27 19:58
skel	[ DIR ]	drwxr-xr-x	2025-02-27 19:58
tests	[ DIR ]	drwxr-xr-x	2025-02-27 19:58
ui	[ DIR ]	drwxr-xr-x	2025-02-27 19:58
__init__.py	20 B	-rw-r--r--	2019-04-06 06:19
childutils.py	2.5 KB	-rw-r--r--	2019-04-06 06:19
compat.py	3.66 KB	-rw-r--r--	2019-09-17 02:23
confecho.py	205 B	-rw-r--r--	2019-04-06 06:19
datatypes.py	12.93 KB	-rw-r--r--	2019-04-06 06:19
dispatchers.py	18.64 KB	-rw-r--r--	2019-04-06 06:19
events.py	7.07 KB	-rw-r--r--	2019-04-06 06:19
http.py	30.86 KB	-rw-r--r--	2019-11-28 04:11
http_client.py	6.87 KB	-rw-r--r--	2019-05-23 05:31
loggers.py	12.68 KB	-rw-r--r--	2019-10-20 02:06
options.py	85.4 KB	-rw-r--r--	2020-04-10 05:49
pidproxy.py	1.84 KB	-rw-r--r--	2020-09-11 19:59
poller.py	6.55 KB	-rw-r--r--	2019-04-06 06:19
process.py	37.2 KB	-rw-r--r--	2019-04-06 06:57
rpcinterface.py	36.46 KB	-rw-r--r--	2020-04-10 05:59
socket_manager.py	3.02 KB	-rw-r--r--	2020-08-07 05:02
states.py	1.62 KB	-rw-r--r--	2018-02-16 02:36
supervisorctl.py	53.4 KB	-rw-r--r--	2020-09-11 19:59
supervisord.py	14.25 KB	-rw-r--r--	2020-09-11 19:59
templating.py	45.98 KB	-rw-r--r--	2019-09-17 02:23
version.txt	6 B	-rw-r--r--	2020-08-21 02:03
web.py	23.71 KB	-rw-r--r--	2020-04-28 04:19
xmlrpc.py	21.03 KB	-rw-r--r--	2019-09-17 02:23

Rename

import sys
import time

from supervisor.compat import xmlrpclib
from supervisor.compat import long
from supervisor.compat import as_string

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(as_string(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' % (as_string(PEventListenerDispatcher.RESULT_TOKEN_START),
                               str(resultlen),
                               data)
        stdout.write(result)
        stdout.flush()

listener = EventListenerProtocol()