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 socket

class Proxy:
    """ Class for wrapping a shared resource object and getting
        notified when it's deleted
    """

def __init__(self, object, **kwargs):
        self.object = object
        self.on_delete = kwargs.get('on_delete', None)

def __del__(self):
        if self.on_delete:
            self.on_delete()

def __getattr__(self, name):
        return getattr(self.object, name)

def _get(self):
        return self.object

class ReferenceCounter:
    """ Class for tracking references to a shared resource
    """

def __init__(self, **kwargs):
        self.on_non_zero = kwargs['on_non_zero']
        self.on_zero = kwargs['on_zero']
        self.ref_count = 0

def get_count(self):
        return self.ref_count

def increment(self):
        if self.ref_count == 0:
            self.on_non_zero()
        self.ref_count = self.ref_count + 1

def decrement(self):
        if self.ref_count <= 0:
            raise Exception('Illegal operation: cannot decrement below zero')
        self.ref_count -= 1
        if self.ref_count == 0:
            self.on_zero()

class SocketManager:
    """ Class for managing sockets in servers that create/bind/listen
        before forking multiple child processes to accept()
        Sockets are managed at the process group level and referenced counted
        at the process level b/c that's really the only place to hook in
    """

def __init__(self, socket_config, **kwargs):
        self.logger = kwargs.get('logger', None)
        self.socket = None
        self.prepared = False
        self.socket_config = socket_config
        self.ref_ctr = ReferenceCounter(
            on_zero=self._close, on_non_zero=self._prepare_socket
            )

def __repr__(self):
        return '<%s at %s for %s>' % (self.__class__,
                                      id(self),
                                      self.socket_config.url)

def config(self):
        return self.socket_config

def is_prepared(self):
        return self.prepared

def get_socket(self):
        self.ref_ctr.increment()
        self._require_prepared()
        return Proxy(self.socket, on_delete=self.ref_ctr.decrement)

def get_socket_ref_count(self):
        self._require_prepared()
        return self.ref_ctr.get_count()

def _require_prepared(self):
        if not self.prepared:
            raise Exception('Socket has not been prepared')

def _prepare_socket(self):
        if not self.prepared:
            if self.logger:
                self.logger.info('Creating socket %s' % self.socket_config)
            self.socket = self.socket_config.create_and_bind()
            if self.socket_config.get_backlog():
                self.socket.listen(self.socket_config.get_backlog())
            else:
                self.socket.listen(socket.SOMAXCONN)
            self.prepared = True

def _close(self):
        self._require_prepared()
        if self.logger:
            self.logger.info('Closing socket %s' % self.socket_config)
        self.socket.close()
        self.prepared = False