view hgext/inotify/__init__.py @ 7830:55bd03e2e13c

test-identify: require no-outer-repo

The test expects "There is no Mercurial repository here (.hg not found)"

# __init__.py - inotify-based status acceleration for Linux
#
# Copyright 2006, 2007, 2008 Bryan O'Sullivan <[e-mail]>
# Copyright 2007, 2008 Brendan Cully <[e-mail]>
#
# This software may be used and distributed according to the terms
# of the GNU General Public License, incorporated herein by reference.

'''inotify-based status acceleration for Linux systems
'''

# todo: socket permissions

from mercurial.i18n import _
from mercurial import cmdutil, util
import client, errno, os, server, socket
from weakref import proxy

def serve(ui, repo, **opts):
    '''start an inotify server for this repository'''
    timeout = opts.get('timeout')
    if timeout:
        timeout = float(timeout) * 1e3

    class service:
        def init(self):
            try:
                self.master = server.Master(ui, repo, timeout)
            except server.AlreadyStartedException, inst:
                raise util.Abort(str(inst))

        def run(self):
            try:
                self.master.run()
            finally:
                self.master.shutdown()

    service = service()
    cmdutil.service(opts, initfn=service.init, runfn=service.run)

def reposetup(ui, repo):
    if not hasattr(repo, 'dirstate'):
        return

    # XXX: weakref until hg stops relying on __del__
    repo = proxy(repo)

    class inotifydirstate(repo.dirstate.__class__):
        # Set to True if we're the inotify server, so we don't attempt
        # to recurse.
        inotifyserver = False

        def status(self, match, ignored, clean, unknown=True):
            files = match.files()
            if '.' in files:
                files = []
            try:
                if not ignored and not self.inotifyserver:
                    result = client.query(ui, repo, files, match, False,
                                          clean, unknown)
                    if ui.config('inotify', 'debug'):
                        r2 = super(inotifydirstate, self).status(
                            match, False, clean, unknown)
                        for c,a,b in zip('LMARDUIC', result, r2):
                            for f in a:
                                if f not in b:
                                    ui.warn('*** inotify: %s +%s\n' % (c, f))
                            for f in b:
                                if f not in a:
                                    ui.warn('*** inotify: %s -%s\n' % (c, f))
                        result = r2

                    if result is not None:
                        return result
            except (OSError, socket.error), err:
                autostart = ui.configbool('inotify', 'autostart', True)

                if err[0] == errno.ECONNREFUSED:
                    ui.warn(_('(found dead inotify server socket; '
                                   'removing it)\n'))
                    os.unlink(repo.join('inotify.sock'))
                if err[0] in (errno.ECONNREFUSED, errno.ENOENT) and autostart:
                    query = None
                    ui.debug(_('(starting inotify server)\n'))
                    try:
                        try:
                            server.start(ui, repo)
                            query = client.query
                        except server.AlreadyStartedException, inst:
                            # another process may have started its own
                            # inotify server while this one was starting.
                            ui.debug(str(inst))
                            query = client.query
                    except Exception, inst:
                        ui.warn(_('could not start inotify server: '
                                       '%s\n') % inst)
                    if query:
                        try:
                            return query(ui, repo, files or [], match,
                                         ignored, clean, unknown)
                        except socket.error, err:
                            ui.warn(_('could not talk to new inotify '
                                           'server: %s\n') % err[-1])
                elif err[0] in (errno.ECONNREFUSED, errno.ENOENT):
                    # silently ignore normal errors if autostart is False
                    ui.debug(_('(inotify server not running)\n'))
                else:
                    ui.warn(_('failed to contact inotify server: %s\n')
                             % err[-1])
                ui.print_exc()
                # replace by old status function
                self.status = super(inotifydirstate, self).status

            return super(inotifydirstate, self).status(
                match, ignored, clean, unknown)

    repo.dirstate.__class__ = inotifydirstate

cmdtable = {
    '^inserve':
    (serve,
     [('d', 'daemon', None, _('run server in background')),
      ('', 'daemon-pipefds', '', _('used internally by daemon mode')),
      ('t', 'idle-timeout', '', _('minutes to sit idle before exiting')),
      ('', 'pid-file', '', _('name of file to write process ID to'))],
     _('hg inserve [OPT]...')),
    }