comparison mercurial/commandserver.py @ 29548:9da1adc18639

commandserver: drop old unixservice implementation

It's been superseded by unixforkingservice.

29547:300318b7d66d

from . import (
    encoding,
    error,
    util,
)

socketserver = util.socketserver

logfile = None

def log(*args):
    if not logfile:

    def createcmdserver(self, repo, conn, fin, fout):
        """Create new command server instance; called in the process that
        serves for the current connection"""
        return server(self.ui, repo, fin, fout)

class _requesthandler(socketserver.BaseRequestHandler):
    def handle(self):
        _serverequest(self.server.ui, self.server.repo, self.request,
                      self._createcmdserver)

    def _createcmdserver(self, repo, conn, fin, fout):
        ui = self.server.ui
        return server(ui, repo, fin, fout)

class unixservice(object):
    """
    Listens on unix domain socket and forks server per connection
    """
    def __init__(self, ui, repo, opts):
        self.ui = ui
        self.repo = repo
        self.address = opts['address']
        if not util.safehasattr(socketserver, 'UnixStreamServer'):
            raise error.Abort(_('unsupported platform'))
        if not self.address:
            raise error.Abort(_('no socket path specified with --address'))

    def init(self):
        class cls(socketserver.ForkingMixIn, socketserver.UnixStreamServer):
            ui = self.ui
            repo = self.repo
        self.server = cls(self.address, _requesthandler)
        self.ui.status(_('listening at %s\n') % self.address)
        self.ui.flush()  # avoid buffering of status message

    def _cleanup(self):
        os.unlink(self.address)

    def run(self):
        try:
            self.server.serve_forever()
        finally:
            self._cleanup()

class unixforkingservice(unixservice):
    def __init__(self, ui, repo, opts, handler=None):
        super(unixforkingservice, self).__init__(ui, repo, opts)
        self._servicehandler = handler or unixservicehandler(ui)
        self._sock = None
        self._oldsigchldhandler = None
        self._workerpids = set()  # updated by signal handler; do not iterate

29548:9da1adc18639

from . import (
    encoding,
    error,
    util,
)

logfile = None

def log(*args):
    if not logfile:

    def createcmdserver(self, repo, conn, fin, fout):
        """Create new command server instance; called in the process that
        serves for the current connection"""
        return server(self.ui, repo, fin, fout)

class unixforkingservice(object):
    """
    Listens on unix domain socket and forks server per connection
    """

    def __init__(self, ui, repo, opts, handler=None):
        self.ui = ui
        self.repo = repo
        self.address = opts['address']
        if not util.safehasattr(socket, 'AF_UNIX'):
            raise error.Abort(_('unsupported platform'))
        if not self.address:
            raise error.Abort(_('no socket path specified with --address'))
        self._servicehandler = handler or unixservicehandler(ui)
        self._sock = None
        self._oldsigchldhandler = None
        self._workerpids = set()  # updated by signal handler; do not iterate