# HG changeset patch # User Nicolas Dumazet # Date 1246206454 -32400 # Node ID 206f7f4c5c2a9ff02231421c3ce708eac0581154 # Parent b789ea382fc0def1f171c69cf1961737e1f38d7d inotify: client: no repo use diff -r b789ea382fc0 -r 206f7f4c5c2a hgext/inotify/__init__.py --- a/hgext/inotify/__init__.py Mon Jun 29 01:09:33 2009 +0900 +++ b/hgext/inotify/__init__.py Mon Jun 29 01:27:34 2009 +0900 @@ -25,7 +25,8 @@ class service(object): def init(self): try: - self.master = server.master(ui, repo, timeout) + self.master = server.master(ui, repo.dirstate, + repo.root, timeout) except server.AlreadyStartedException, inst: raise util.Abort(str(inst)) diff -r b789ea382fc0 -r 206f7f4c5c2a hgext/inotify/client.py --- a/hgext/inotify/client.py Mon Jun 29 01:09:33 2009 +0900 +++ b/hgext/inotify/client.py Mon Jun 29 01:27:34 2009 +0900 @@ -29,12 +29,12 @@ if err[0] == errno.ECONNREFUSED: self.ui.warn(_('(found dead inotify server socket; ' 'removing it)\n')) - os.unlink(self.repo.join('inotify.sock')) + os.unlink(os.path.join(self.root, '.hg', 'inotify.sock')) if err[0] in (errno.ECONNREFUSED, errno.ENOENT) and autostart: self.ui.debug(_('(starting inotify server)\n')) try: try: - server.start(self.ui, self.repo) + server.start(self.ui, self.dirstate, self.root) except server.AlreadyStartedException, inst: # another process may have started its own # inotify server while this one was starting. @@ -64,11 +64,12 @@ class client(object): def __init__(self, ui, repo): self.ui = ui - self.repo = repo + self.dirstate = repo.dirstate + self.root = repo.root self.sock = socket.socket(socket.AF_UNIX) def _connect(self): - sockpath = self.repo.join('inotify.sock') + sockpath = os.path.join(self.root, '.hg', 'inotify.sock') try: self.sock.connect(sockpath) except socket.error, err: diff -r b789ea382fc0 -r 206f7f4c5c2a hgext/inotify/server.py --- a/hgext/inotify/server.py Mon Jun 29 01:09:33 2009 +0900 +++ b/hgext/inotify/server.py Mon Jun 29 01:27:34 2009 +0900 @@ -807,10 +807,10 @@ raise class master(object): - def __init__(self, ui, repo, timeout=None): + def __init__(self, ui, dirstate, root, timeout=None): self.ui = ui - self.repowatcher = repowatcher(ui, repo.dirstate, repo.root) - self.server = server(ui, repo.root, self.repowatcher, timeout) + self.repowatcher = repowatcher(ui, dirstate, root) + self.server = server(ui, root, self.repowatcher, timeout) def shutdown(self): for obj in pollable.instances.itervalues(): @@ -823,7 +823,7 @@ sys.exit(0) pollable.run() -def start(ui, repo): +def start(ui, dirstate, root): def closefds(ignore): # (from python bug #1177468) # close all inherited file descriptors @@ -844,7 +844,7 @@ except OSError: pass - m = master(ui, repo) + m = master(ui, dirstate, root) sys.stdout.flush() sys.stderr.flush()