##// END OF EJS Templates
inotify: fix status . in repo.root
Brendan Cully -
r7393:92c952c4 default
parent child Browse files
Show More
@@ -1,123 +1,125 b''
1 1 # __init__.py - inotify-based status acceleration for Linux
2 2 #
3 3 # Copyright 2006, 2007, 2008 Bryan O'Sullivan <bos@serpentine.com>
4 4 # Copyright 2007, 2008 Brendan Cully <brendan@kublai.com>
5 5 #
6 6 # This software may be used and distributed according to the terms
7 7 # of the GNU General Public License, incorporated herein by reference.
8 8
9 9 '''inotify-based status acceleration for Linux systems
10 10 '''
11 11
12 12 # todo: socket permissions
13 13
14 14 from mercurial.i18n import _
15 15 from mercurial import cmdutil, util
16 16 import client, errno, os, server, socket
17 17 from weakref import proxy
18 18
19 19 def serve(ui, repo, **opts):
20 20 '''start an inotify server for this repository'''
21 21 timeout = opts.get('timeout')
22 22 if timeout:
23 23 timeout = float(timeout) * 1e3
24 24
25 25 class service:
26 26 def init(self):
27 27 try:
28 28 self.master = server.Master(ui, repo, timeout)
29 29 except server.AlreadyStartedException, inst:
30 30 raise util.Abort(str(inst))
31 31
32 32 def run(self):
33 33 try:
34 34 self.master.run()
35 35 finally:
36 36 self.master.shutdown()
37 37
38 38 service = service()
39 39 cmdutil.service(opts, initfn=service.init, runfn=service.run)
40 40
41 41 def reposetup(ui, repo):
42 42 if not repo.local():
43 43 return
44 44
45 45 # XXX: weakref until hg stops relying on __del__
46 46 repo = proxy(repo)
47 47
48 48 class inotifydirstate(repo.dirstate.__class__):
49 49 # Set to True if we're the inotify server, so we don't attempt
50 50 # to recurse.
51 51 inotifyserver = False
52 52
53 53 def status(self, match, ignored, clean, unknown=True):
54 54 files = match.files()
55 if '.' in files:
56 files = []
55 57 try:
56 58 if not ignored and not self.inotifyserver:
57 59 result = client.query(ui, repo, files, match, False,
58 60 clean, unknown)
59 61 if ui.config('inotify', 'debug'):
60 62 r2 = super(inotifydirstate, self).status(
61 63 match, False, clean, unknown)
62 64 for c,a,b in zip('LMARDUIC', result, r2):
63 65 for f in a:
64 66 if f not in b:
65 67 ui.warn('*** inotify: %s +%s\n' % (c, f))
66 68 for f in b:
67 69 if f not in a:
68 70 ui.warn('*** inotify: %s -%s\n' % (c, f))
69 71 result = r2
70 72
71 73 if result is not None:
72 74 return result
73 75 except (OSError, socket.error), err:
74 76 if err[0] == errno.ECONNREFUSED:
75 77 ui.warn(_('(found dead inotify server socket; '
76 78 'removing it)\n'))
77 79 os.unlink(repo.join('inotify.sock'))
78 80 if err[0] in (errno.ECONNREFUSED, errno.ENOENT) and \
79 81 ui.configbool('inotify', 'autostart', True):
80 82 query = None
81 83 ui.debug(_('(starting inotify server)\n'))
82 84 try:
83 85 try:
84 86 server.start(ui, repo)
85 87 query = client.query
86 88 except server.AlreadyStartedException, inst:
87 89 # another process may have started its own
88 90 # inotify server while this one was starting.
89 91 ui.debug(str(inst))
90 92 query = client.query
91 93 except Exception, inst:
92 94 ui.warn(_('could not start inotify server: '
93 95 '%s\n') % inst)
94 96 if query:
95 97 try:
96 98 return query(ui, repo, files or [], match,
97 99 ignored, clean, unknown)
98 100 except socket.error, err:
99 101 ui.warn(_('could not talk to new inotify '
100 102 'server: %s\n') % err[-1])
101 103 elif err[0] == errno.ENOENT:
102 104 ui.warn(_('(inotify server not running)\n'))
103 105 else:
104 106 ui.warn(_('failed to contact inotify server: %s\n')
105 107 % err[-1])
106 108 ui.print_exc()
107 109 # replace by old status function
108 110 self.status = super(inotifydirstate, self).status
109 111
110 112 return super(inotifydirstate, self).status(
111 113 match, ignored, clean, unknown)
112 114
113 115 repo.dirstate.__class__ = inotifydirstate
114 116
115 117 cmdtable = {
116 118 '^inserve':
117 119 (serve,
118 120 [('d', 'daemon', None, _('run server in background')),
119 121 ('', 'daemon-pipefds', '', _('used internally by daemon mode')),
120 122 ('t', 'idle-timeout', '', _('minutes to sit idle before exiting')),
121 123 ('', 'pid-file', '', _('name of file to write process ID to'))],
122 124 _('hg inserve [OPT]...')),
123 125 }
@@ -1,30 +1,38 b''
1 1 #!/bin/sh
2 2
3 3 "$TESTDIR/hghave" inotify || exit 80
4 4
5 5 hg init
6 6
7 7 touch a b c d e
8 8 mkdir dir
9 9 mkdir dir/bar
10 10 touch dir/x dir/y dir/bar/foo
11 11
12 12 hg ci -Am m
13 13
14 14 echo "[extensions]" >> $HGRCPATH
15 15 echo "inotify=" >> $HGRCPATH
16 16
17 17 echo % inserve
18 18 hg inserve -d --pid-file=hg.pid
19 19 cat hg.pid >> "$DAEMON_PIDS"
20 20
21 21 # let the daemon finish its stuff
22 22 sleep 1
23 23 # issue907
24 24 hg status
25 25 echo % clean
26 26 hg status -c
27 27 echo % all
28 28 hg status -A
29 29
30 echo '% path patterns'
31 echo x > dir/x
32 hg status .
33 hg status dir
34 cd dir
35 hg status .
36 cd ..
37
30 38 kill `cat hg.pid`
@@ -1,29 +1,34 b''
1 1 adding a
2 2 adding b
3 3 adding c
4 4 adding d
5 5 adding dir/bar/foo
6 6 adding dir/x
7 7 adding dir/y
8 8 adding e
9 9 % inserve
10 10 ? hg.pid
11 11 % clean
12 12 C a
13 13 C b
14 14 C c
15 15 C d
16 16 C dir/bar/foo
17 17 C dir/x
18 18 C dir/y
19 19 C e
20 20 % all
21 21 ? hg.pid
22 22 C a
23 23 C b
24 24 C c
25 25 C d
26 26 C dir/bar/foo
27 27 C dir/x
28 28 C dir/y
29 29 C e
30 % path patterns
31 M dir/x
32 ? hg.pid
33 M dir/x
34 M x
General Comments 0
You need to be logged in to leave comments. Login now