##// END OF EJS Templates
revset: lower weight for _intlist function...
Durham Goode -
r22451:186fd062 default
parent child Browse files
Show More
@@ -1,27 +1,28
1 all()
1 all()
2 draft()
2 draft()
3 ::tip
3 ::tip
4 draft() and ::tip
4 draft() and ::tip
5 ::tip and draft()
5 ::tip and draft()
6 0::tip
6 0::tip
7 roots(0::tip)
7 roots(0::tip)
8 author(lmoscovicz)
8 author(lmoscovicz)
9 author(mpm)
9 author(mpm)
10 author(lmoscovicz) or author(mpm)
10 author(lmoscovicz) or author(mpm)
11 author(mpm) or author(lmoscovicz)
11 author(mpm) or author(lmoscovicz)
12 tip:0
12 tip:0
13 max(tip:0)
13 max(tip:0)
14 min(0:tip)
14 min(0:tip)
15 0::
15 0::
16 min(0::)
16 min(0::)
17 roots((tip~100::) - (tip~100::tip))
17 roots((tip~100::) - (tip~100::tip))
18 ::p1(p1(tip))::
18 ::p1(p1(tip))::
19 public()
19 public()
20 :10000 and public()
20 :10000 and public()
21 draft()
21 draft()
22 :10000 and draft()
22 :10000 and draft()
23 max(::(tip~20) - obsolete())
23 max(::(tip~20) - obsolete())
24 roots((0:tip)::)
24 roots((0:tip)::)
25 (not public() - obsolete())
25 (not public() - obsolete())
26 (_intlist('20000\x0020001')) and merge()
26 parents(20000)
27 parents(20000)
27 (20000::) - (20000)
28 (20000::) - (20000)
@@ -1,2850 +1,2850
1 # revset.py - revision set queries for mercurial
1 # revset.py - revision set queries for mercurial
2 #
2 #
3 # Copyright 2010 Matt Mackall <mpm@selenic.com>
3 # Copyright 2010 Matt Mackall <mpm@selenic.com>
4 #
4 #
5 # This software may be used and distributed according to the terms of the
5 # This software may be used and distributed according to the terms of the
6 # GNU General Public License version 2 or any later version.
6 # GNU General Public License version 2 or any later version.
7
7
8 import re
8 import re
9 import parser, util, error, discovery, hbisect, phases
9 import parser, util, error, discovery, hbisect, phases
10 import node
10 import node
11 import heapq
11 import heapq
12 import match as matchmod
12 import match as matchmod
13 import ancestor as ancestormod
13 import ancestor as ancestormod
14 from i18n import _
14 from i18n import _
15 import encoding
15 import encoding
16 import obsolete as obsmod
16 import obsolete as obsmod
17 import pathutil
17 import pathutil
18 import repoview
18 import repoview
19
19
20 def _revancestors(repo, revs, followfirst):
20 def _revancestors(repo, revs, followfirst):
21 """Like revlog.ancestors(), but supports followfirst."""
21 """Like revlog.ancestors(), but supports followfirst."""
22 cut = followfirst and 1 or None
22 cut = followfirst and 1 or None
23 cl = repo.changelog
23 cl = repo.changelog
24
24
25 def iterate():
25 def iterate():
26 revqueue, revsnode = None, None
26 revqueue, revsnode = None, None
27 h = []
27 h = []
28
28
29 revs.descending()
29 revs.descending()
30 revqueue = util.deque(revs)
30 revqueue = util.deque(revs)
31 if revqueue:
31 if revqueue:
32 revsnode = revqueue.popleft()
32 revsnode = revqueue.popleft()
33 heapq.heappush(h, -revsnode)
33 heapq.heappush(h, -revsnode)
34
34
35 seen = set([node.nullrev])
35 seen = set([node.nullrev])
36 while h:
36 while h:
37 current = -heapq.heappop(h)
37 current = -heapq.heappop(h)
38 if current not in seen:
38 if current not in seen:
39 if revsnode and current == revsnode:
39 if revsnode and current == revsnode:
40 if revqueue:
40 if revqueue:
41 revsnode = revqueue.popleft()
41 revsnode = revqueue.popleft()
42 heapq.heappush(h, -revsnode)
42 heapq.heappush(h, -revsnode)
43 seen.add(current)
43 seen.add(current)
44 yield current
44 yield current
45 for parent in cl.parentrevs(current)[:cut]:
45 for parent in cl.parentrevs(current)[:cut]:
46 if parent != node.nullrev:
46 if parent != node.nullrev:
47 heapq.heappush(h, -parent)
47 heapq.heappush(h, -parent)
48
48
49 return _descgeneratorset(iterate())
49 return _descgeneratorset(iterate())
50
50
51 def _revdescendants(repo, revs, followfirst):
51 def _revdescendants(repo, revs, followfirst):
52 """Like revlog.descendants() but supports followfirst."""
52 """Like revlog.descendants() but supports followfirst."""
53 cut = followfirst and 1 or None
53 cut = followfirst and 1 or None
54
54
55 def iterate():
55 def iterate():
56 cl = repo.changelog
56 cl = repo.changelog
57 first = min(revs)
57 first = min(revs)
58 nullrev = node.nullrev
58 nullrev = node.nullrev
59 if first == nullrev:
59 if first == nullrev:
60 # Are there nodes with a null first parent and a non-null
60 # Are there nodes with a null first parent and a non-null
61 # second one? Maybe. Do we care? Probably not.
61 # second one? Maybe. Do we care? Probably not.
62 for i in cl:
62 for i in cl:
63 yield i
63 yield i
64 else:
64 else:
65 seen = set(revs)
65 seen = set(revs)
66 for i in cl.revs(first + 1):
66 for i in cl.revs(first + 1):
67 for x in cl.parentrevs(i)[:cut]:
67 for x in cl.parentrevs(i)[:cut]:
68 if x != nullrev and x in seen:
68 if x != nullrev and x in seen:
69 seen.add(i)
69 seen.add(i)
70 yield i
70 yield i
71 break
71 break
72
72
73 return _ascgeneratorset(iterate())
73 return _ascgeneratorset(iterate())
74
74
75 def _revsbetween(repo, roots, heads):
75 def _revsbetween(repo, roots, heads):
76 """Return all paths between roots and heads, inclusive of both endpoint
76 """Return all paths between roots and heads, inclusive of both endpoint
77 sets."""
77 sets."""
78 if not roots:
78 if not roots:
79 return baseset([])
79 return baseset([])
80 parentrevs = repo.changelog.parentrevs
80 parentrevs = repo.changelog.parentrevs
81 visit = baseset(heads)
81 visit = baseset(heads)
82 reachable = set()
82 reachable = set()
83 seen = {}
83 seen = {}
84 minroot = min(roots)
84 minroot = min(roots)
85 roots = set(roots)
85 roots = set(roots)
86 # open-code the post-order traversal due to the tiny size of
86 # open-code the post-order traversal due to the tiny size of
87 # sys.getrecursionlimit()
87 # sys.getrecursionlimit()
88 while visit:
88 while visit:
89 rev = visit.pop()
89 rev = visit.pop()
90 if rev in roots:
90 if rev in roots:
91 reachable.add(rev)
91 reachable.add(rev)
92 parents = parentrevs(rev)
92 parents = parentrevs(rev)
93 seen[rev] = parents
93 seen[rev] = parents
94 for parent in parents:
94 for parent in parents:
95 if parent >= minroot and parent not in seen:
95 if parent >= minroot and parent not in seen:
96 visit.append(parent)
96 visit.append(parent)
97 if not reachable:
97 if not reachable:
98 return baseset([])
98 return baseset([])
99 for rev in sorted(seen):
99 for rev in sorted(seen):
100 for parent in seen[rev]:
100 for parent in seen[rev]:
101 if parent in reachable:
101 if parent in reachable:
102 reachable.add(rev)
102 reachable.add(rev)
103 return baseset(sorted(reachable))
103 return baseset(sorted(reachable))
104
104
105 elements = {
105 elements = {
106 "(": (20, ("group", 1, ")"), ("func", 1, ")")),
106 "(": (20, ("group", 1, ")"), ("func", 1, ")")),
107 "~": (18, None, ("ancestor", 18)),
107 "~": (18, None, ("ancestor", 18)),
108 "^": (18, None, ("parent", 18), ("parentpost", 18)),
108 "^": (18, None, ("parent", 18), ("parentpost", 18)),
109 "-": (5, ("negate", 19), ("minus", 5)),
109 "-": (5, ("negate", 19), ("minus", 5)),
110 "::": (17, ("dagrangepre", 17), ("dagrange", 17),
110 "::": (17, ("dagrangepre", 17), ("dagrange", 17),
111 ("dagrangepost", 17)),
111 ("dagrangepost", 17)),
112 "..": (17, ("dagrangepre", 17), ("dagrange", 17),
112 "..": (17, ("dagrangepre", 17), ("dagrange", 17),
113 ("dagrangepost", 17)),
113 ("dagrangepost", 17)),
114 ":": (15, ("rangepre", 15), ("range", 15), ("rangepost", 15)),
114 ":": (15, ("rangepre", 15), ("range", 15), ("rangepost", 15)),
115 "not": (10, ("not", 10)),
115 "not": (10, ("not", 10)),
116 "!": (10, ("not", 10)),
116 "!": (10, ("not", 10)),
117 "and": (5, None, ("and", 5)),
117 "and": (5, None, ("and", 5)),
118 "&": (5, None, ("and", 5)),
118 "&": (5, None, ("and", 5)),
119 "or": (4, None, ("or", 4)),
119 "or": (4, None, ("or", 4)),
120 "|": (4, None, ("or", 4)),
120 "|": (4, None, ("or", 4)),
121 "+": (4, None, ("or", 4)),
121 "+": (4, None, ("or", 4)),
122 ",": (2, None, ("list", 2)),
122 ",": (2, None, ("list", 2)),
123 ")": (0, None, None),
123 ")": (0, None, None),
124 "symbol": (0, ("symbol",), None),
124 "symbol": (0, ("symbol",), None),
125 "string": (0, ("string",), None),
125 "string": (0, ("string",), None),
126 "end": (0, None, None),
126 "end": (0, None, None),
127 }
127 }
128
128
129 keywords = set(['and', 'or', 'not'])
129 keywords = set(['and', 'or', 'not'])
130
130
131 def tokenize(program, lookup=None):
131 def tokenize(program, lookup=None):
132 '''
132 '''
133 Parse a revset statement into a stream of tokens
133 Parse a revset statement into a stream of tokens
134
134
135 Check that @ is a valid unquoted token character (issue3686):
135 Check that @ is a valid unquoted token character (issue3686):
136 >>> list(tokenize("@::"))
136 >>> list(tokenize("@::"))
137 [('symbol', '@', 0), ('::', None, 1), ('end', None, 3)]
137 [('symbol', '@', 0), ('::', None, 1), ('end', None, 3)]
138
138
139 '''
139 '''
140
140
141 pos, l = 0, len(program)
141 pos, l = 0, len(program)
142 while pos < l:
142 while pos < l:
143 c = program[pos]
143 c = program[pos]
144 if c.isspace(): # skip inter-token whitespace
144 if c.isspace(): # skip inter-token whitespace
145 pass
145 pass
146 elif c == ':' and program[pos:pos + 2] == '::': # look ahead carefully
146 elif c == ':' and program[pos:pos + 2] == '::': # look ahead carefully
147 yield ('::', None, pos)
147 yield ('::', None, pos)
148 pos += 1 # skip ahead
148 pos += 1 # skip ahead
149 elif c == '.' and program[pos:pos + 2] == '..': # look ahead carefully
149 elif c == '.' and program[pos:pos + 2] == '..': # look ahead carefully
150 yield ('..', None, pos)
150 yield ('..', None, pos)
151 pos += 1 # skip ahead
151 pos += 1 # skip ahead
152 elif c in "():,-|&+!~^": # handle simple operators
152 elif c in "():,-|&+!~^": # handle simple operators
153 yield (c, None, pos)
153 yield (c, None, pos)
154 elif (c in '"\'' or c == 'r' and
154 elif (c in '"\'' or c == 'r' and
155 program[pos:pos + 2] in ("r'", 'r"')): # handle quoted strings
155 program[pos:pos + 2] in ("r'", 'r"')): # handle quoted strings
156 if c == 'r':
156 if c == 'r':
157 pos += 1
157 pos += 1
158 c = program[pos]
158 c = program[pos]
159 decode = lambda x: x
159 decode = lambda x: x
160 else:
160 else:
161 decode = lambda x: x.decode('string-escape')
161 decode = lambda x: x.decode('string-escape')
162 pos += 1
162 pos += 1
163 s = pos
163 s = pos
164 while pos < l: # find closing quote
164 while pos < l: # find closing quote
165 d = program[pos]
165 d = program[pos]
166 if d == '\\': # skip over escaped characters
166 if d == '\\': # skip over escaped characters
167 pos += 2
167 pos += 2
168 continue
168 continue
169 if d == c:
169 if d == c:
170 yield ('string', decode(program[s:pos]), s)
170 yield ('string', decode(program[s:pos]), s)
171 break
171 break
172 pos += 1
172 pos += 1
173 else:
173 else:
174 raise error.ParseError(_("unterminated string"), s)
174 raise error.ParseError(_("unterminated string"), s)
175 # gather up a symbol/keyword
175 # gather up a symbol/keyword
176 elif c.isalnum() or c in '._@' or ord(c) > 127:
176 elif c.isalnum() or c in '._@' or ord(c) > 127:
177 s = pos
177 s = pos
178 pos += 1
178 pos += 1
179 while pos < l: # find end of symbol
179 while pos < l: # find end of symbol
180 d = program[pos]
180 d = program[pos]
181 if not (d.isalnum() or d in "-._/@" or ord(d) > 127):
181 if not (d.isalnum() or d in "-._/@" or ord(d) > 127):
182 break
182 break
183 if d == '.' and program[pos - 1] == '.': # special case for ..
183 if d == '.' and program[pos - 1] == '.': # special case for ..
184 pos -= 1
184 pos -= 1
185 break
185 break
186 pos += 1
186 pos += 1
187 sym = program[s:pos]
187 sym = program[s:pos]
188 if sym in keywords: # operator keywords
188 if sym in keywords: # operator keywords
189 yield (sym, None, s)
189 yield (sym, None, s)
190 elif '-' in sym:
190 elif '-' in sym:
191 # some jerk gave us foo-bar-baz, try to check if it's a symbol
191 # some jerk gave us foo-bar-baz, try to check if it's a symbol
192 if lookup and lookup(sym):
192 if lookup and lookup(sym):
193 # looks like a real symbol
193 # looks like a real symbol
194 yield ('symbol', sym, s)
194 yield ('symbol', sym, s)
195 else:
195 else:
196 # looks like an expression
196 # looks like an expression
197 parts = sym.split('-')
197 parts = sym.split('-')
198 for p in parts[:-1]:
198 for p in parts[:-1]:
199 if p: # possible consecutive -
199 if p: # possible consecutive -
200 yield ('symbol', p, s)
200 yield ('symbol', p, s)
201 s += len(p)
201 s += len(p)
202 yield ('-', None, pos)
202 yield ('-', None, pos)
203 s += 1
203 s += 1
204 if parts[-1]: # possible trailing -
204 if parts[-1]: # possible trailing -
205 yield ('symbol', parts[-1], s)
205 yield ('symbol', parts[-1], s)
206 else:
206 else:
207 yield ('symbol', sym, s)
207 yield ('symbol', sym, s)
208 pos -= 1
208 pos -= 1
209 else:
209 else:
210 raise error.ParseError(_("syntax error"), pos)
210 raise error.ParseError(_("syntax error"), pos)
211 pos += 1
211 pos += 1
212 yield ('end', None, pos)
212 yield ('end', None, pos)
213
213
214 # helpers
214 # helpers
215
215
216 def getstring(x, err):
216 def getstring(x, err):
217 if x and (x[0] == 'string' or x[0] == 'symbol'):
217 if x and (x[0] == 'string' or x[0] == 'symbol'):
218 return x[1]
218 return x[1]
219 raise error.ParseError(err)
219 raise error.ParseError(err)
220
220
221 def getlist(x):
221 def getlist(x):
222 if not x:
222 if not x:
223 return []
223 return []
224 if x[0] == 'list':
224 if x[0] == 'list':
225 return getlist(x[1]) + [x[2]]
225 return getlist(x[1]) + [x[2]]
226 return [x]
226 return [x]
227
227
228 def getargs(x, min, max, err):
228 def getargs(x, min, max, err):
229 l = getlist(x)
229 l = getlist(x)
230 if len(l) < min or (max >= 0 and len(l) > max):
230 if len(l) < min or (max >= 0 and len(l) > max):
231 raise error.ParseError(err)
231 raise error.ParseError(err)
232 return l
232 return l
233
233
234 def getset(repo, subset, x):
234 def getset(repo, subset, x):
235 if not x:
235 if not x:
236 raise error.ParseError(_("missing argument"))
236 raise error.ParseError(_("missing argument"))
237 s = methods[x[0]](repo, subset, *x[1:])
237 s = methods[x[0]](repo, subset, *x[1:])
238 if util.safehasattr(s, 'set'):
238 if util.safehasattr(s, 'set'):
239 return s
239 return s
240 return baseset(s)
240 return baseset(s)
241
241
242 def _getrevsource(repo, r):
242 def _getrevsource(repo, r):
243 extra = repo[r].extra()
243 extra = repo[r].extra()
244 for label in ('source', 'transplant_source', 'rebase_source'):
244 for label in ('source', 'transplant_source', 'rebase_source'):
245 if label in extra:
245 if label in extra:
246 try:
246 try:
247 return repo[extra[label]].rev()
247 return repo[extra[label]].rev()
248 except error.RepoLookupError:
248 except error.RepoLookupError:
249 pass
249 pass
250 return None
250 return None
251
251
252 # operator methods
252 # operator methods
253
253
254 def stringset(repo, subset, x):
254 def stringset(repo, subset, x):
255 x = repo[x].rev()
255 x = repo[x].rev()
256 if x == -1 and len(subset) == len(repo):
256 if x == -1 and len(subset) == len(repo):
257 return baseset([-1])
257 return baseset([-1])
258 if len(subset) == len(repo) or x in subset:
258 if len(subset) == len(repo) or x in subset:
259 return baseset([x])
259 return baseset([x])
260 return baseset([])
260 return baseset([])
261
261
262 def symbolset(repo, subset, x):
262 def symbolset(repo, subset, x):
263 if x in symbols:
263 if x in symbols:
264 raise error.ParseError(_("can't use %s here") % x)
264 raise error.ParseError(_("can't use %s here") % x)
265 return stringset(repo, subset, x)
265 return stringset(repo, subset, x)
266
266
267 def rangeset(repo, subset, x, y):
267 def rangeset(repo, subset, x, y):
268 cl = baseset(repo.changelog)
268 cl = baseset(repo.changelog)
269 m = getset(repo, cl, x)
269 m = getset(repo, cl, x)
270 n = getset(repo, cl, y)
270 n = getset(repo, cl, y)
271
271
272 if not m or not n:
272 if not m or not n:
273 return baseset([])
273 return baseset([])
274 m, n = m[0], n[-1]
274 m, n = m[0], n[-1]
275
275
276 if m < n:
276 if m < n:
277 r = spanset(repo, m, n + 1)
277 r = spanset(repo, m, n + 1)
278 else:
278 else:
279 r = spanset(repo, m, n - 1)
279 r = spanset(repo, m, n - 1)
280 return r & subset
280 return r & subset
281
281
282 def dagrange(repo, subset, x, y):
282 def dagrange(repo, subset, x, y):
283 r = spanset(repo)
283 r = spanset(repo)
284 xs = _revsbetween(repo, getset(repo, r, x), getset(repo, r, y))
284 xs = _revsbetween(repo, getset(repo, r, x), getset(repo, r, y))
285 s = subset.set()
285 s = subset.set()
286 return xs.filter(s.__contains__)
286 return xs.filter(s.__contains__)
287
287
288 def andset(repo, subset, x, y):
288 def andset(repo, subset, x, y):
289 return getset(repo, getset(repo, subset, x), y)
289 return getset(repo, getset(repo, subset, x), y)
290
290
291 def orset(repo, subset, x, y):
291 def orset(repo, subset, x, y):
292 xl = getset(repo, subset, x)
292 xl = getset(repo, subset, x)
293 yl = getset(repo, subset - xl, y)
293 yl = getset(repo, subset - xl, y)
294 return xl + yl
294 return xl + yl
295
295
296 def notset(repo, subset, x):
296 def notset(repo, subset, x):
297 return subset - getset(repo, subset, x)
297 return subset - getset(repo, subset, x)
298
298
299 def listset(repo, subset, a, b):
299 def listset(repo, subset, a, b):
300 raise error.ParseError(_("can't use a list in this context"))
300 raise error.ParseError(_("can't use a list in this context"))
301
301
302 def func(repo, subset, a, b):
302 def func(repo, subset, a, b):
303 if a[0] == 'symbol' and a[1] in symbols:
303 if a[0] == 'symbol' and a[1] in symbols:
304 return symbols[a[1]](repo, subset, b)
304 return symbols[a[1]](repo, subset, b)
305 raise error.ParseError(_("not a function: %s") % a[1])
305 raise error.ParseError(_("not a function: %s") % a[1])
306
306
307 # functions
307 # functions
308
308
309 def adds(repo, subset, x):
309 def adds(repo, subset, x):
310 """``adds(pattern)``
310 """``adds(pattern)``
311 Changesets that add a file matching pattern.
311 Changesets that add a file matching pattern.
312
312
313 The pattern without explicit kind like ``glob:`` is expected to be
313 The pattern without explicit kind like ``glob:`` is expected to be
314 relative to the current directory and match against a file or a
314 relative to the current directory and match against a file or a
315 directory.
315 directory.
316 """
316 """
317 # i18n: "adds" is a keyword
317 # i18n: "adds" is a keyword
318 pat = getstring(x, _("adds requires a pattern"))
318 pat = getstring(x, _("adds requires a pattern"))
319 return checkstatus(repo, subset, pat, 1)
319 return checkstatus(repo, subset, pat, 1)
320
320
321 def ancestor(repo, subset, x):
321 def ancestor(repo, subset, x):
322 """``ancestor(*changeset)``
322 """``ancestor(*changeset)``
323 A greatest common ancestor of the changesets.
323 A greatest common ancestor of the changesets.
324
324
325 Accepts 0 or more changesets.
325 Accepts 0 or more changesets.
326 Will return empty list when passed no args.
326 Will return empty list when passed no args.
327 Greatest common ancestor of a single changeset is that changeset.
327 Greatest common ancestor of a single changeset is that changeset.
328 """
328 """
329 # i18n: "ancestor" is a keyword
329 # i18n: "ancestor" is a keyword
330 l = getlist(x)
330 l = getlist(x)
331 rl = spanset(repo)
331 rl = spanset(repo)
332 anc = None
332 anc = None
333
333
334 # (getset(repo, rl, i) for i in l) generates a list of lists
334 # (getset(repo, rl, i) for i in l) generates a list of lists
335 for revs in (getset(repo, rl, i) for i in l):
335 for revs in (getset(repo, rl, i) for i in l):
336 for r in revs:
336 for r in revs:
337 if anc is None:
337 if anc is None:
338 anc = repo[r]
338 anc = repo[r]
339 else:
339 else:
340 anc = anc.ancestor(repo[r])
340 anc = anc.ancestor(repo[r])
341
341
342 if anc is not None and anc.rev() in subset:
342 if anc is not None and anc.rev() in subset:
343 return baseset([anc.rev()])
343 return baseset([anc.rev()])
344 return baseset([])
344 return baseset([])
345
345
346 def _ancestors(repo, subset, x, followfirst=False):
346 def _ancestors(repo, subset, x, followfirst=False):
347 args = getset(repo, spanset(repo), x)
347 args = getset(repo, spanset(repo), x)
348 if not args:
348 if not args:
349 return baseset([])
349 return baseset([])
350 s = _revancestors(repo, args, followfirst)
350 s = _revancestors(repo, args, followfirst)
351 return subset.filter(s.__contains__)
351 return subset.filter(s.__contains__)
352
352
353 def ancestors(repo, subset, x):
353 def ancestors(repo, subset, x):
354 """``ancestors(set)``
354 """``ancestors(set)``
355 Changesets that are ancestors of a changeset in set.
355 Changesets that are ancestors of a changeset in set.
356 """
356 """
357 return _ancestors(repo, subset, x)
357 return _ancestors(repo, subset, x)
358
358
359 def _firstancestors(repo, subset, x):
359 def _firstancestors(repo, subset, x):
360 # ``_firstancestors(set)``
360 # ``_firstancestors(set)``
361 # Like ``ancestors(set)`` but follows only the first parents.
361 # Like ``ancestors(set)`` but follows only the first parents.
362 return _ancestors(repo, subset, x, followfirst=True)
362 return _ancestors(repo, subset, x, followfirst=True)
363
363
364 def ancestorspec(repo, subset, x, n):
364 def ancestorspec(repo, subset, x, n):
365 """``set~n``
365 """``set~n``
366 Changesets that are the Nth ancestor (first parents only) of a changeset
366 Changesets that are the Nth ancestor (first parents only) of a changeset
367 in set.
367 in set.
368 """
368 """
369 try:
369 try:
370 n = int(n[1])
370 n = int(n[1])
371 except (TypeError, ValueError):
371 except (TypeError, ValueError):
372 raise error.ParseError(_("~ expects a number"))
372 raise error.ParseError(_("~ expects a number"))
373 ps = set()
373 ps = set()
374 cl = repo.changelog
374 cl = repo.changelog
375 for r in getset(repo, baseset(cl), x):
375 for r in getset(repo, baseset(cl), x):
376 for i in range(n):
376 for i in range(n):
377 r = cl.parentrevs(r)[0]
377 r = cl.parentrevs(r)[0]
378 ps.add(r)
378 ps.add(r)
379 return subset.filter(ps.__contains__)
379 return subset.filter(ps.__contains__)
380
380
381 def author(repo, subset, x):
381 def author(repo, subset, x):
382 """``author(string)``
382 """``author(string)``
383 Alias for ``user(string)``.
383 Alias for ``user(string)``.
384 """
384 """
385 # i18n: "author" is a keyword
385 # i18n: "author" is a keyword
386 n = encoding.lower(getstring(x, _("author requires a string")))
386 n = encoding.lower(getstring(x, _("author requires a string")))
387 kind, pattern, matcher = _substringmatcher(n)
387 kind, pattern, matcher = _substringmatcher(n)
388 return subset.filter(lambda x: matcher(encoding.lower(repo[x].user())))
388 return subset.filter(lambda x: matcher(encoding.lower(repo[x].user())))
389
389
390 def only(repo, subset, x):
390 def only(repo, subset, x):
391 """``only(set, [set])``
391 """``only(set, [set])``
392 Changesets that are ancestors of the first set that are not ancestors
392 Changesets that are ancestors of the first set that are not ancestors
393 of any other head in the repo. If a second set is specified, the result
393 of any other head in the repo. If a second set is specified, the result
394 is ancestors of the first set that are not ancestors of the second set
394 is ancestors of the first set that are not ancestors of the second set
395 (i.e. ::<set1> - ::<set2>).
395 (i.e. ::<set1> - ::<set2>).
396 """
396 """
397 cl = repo.changelog
397 cl = repo.changelog
398 # i18n: "only" is a keyword
398 # i18n: "only" is a keyword
399 args = getargs(x, 1, 2, _('only takes one or two arguments'))
399 args = getargs(x, 1, 2, _('only takes one or two arguments'))
400 include = getset(repo, spanset(repo), args[0]).set()
400 include = getset(repo, spanset(repo), args[0]).set()
401 if len(args) == 1:
401 if len(args) == 1:
402 if len(include) == 0:
402 if len(include) == 0:
403 return baseset([])
403 return baseset([])
404
404
405 descendants = set(_revdescendants(repo, include, False))
405 descendants = set(_revdescendants(repo, include, False))
406 exclude = [rev for rev in cl.headrevs()
406 exclude = [rev for rev in cl.headrevs()
407 if not rev in descendants and not rev in include]
407 if not rev in descendants and not rev in include]
408 else:
408 else:
409 exclude = getset(repo, spanset(repo), args[1])
409 exclude = getset(repo, spanset(repo), args[1])
410
410
411 results = set(ancestormod.missingancestors(include, exclude, cl.parentrevs))
411 results = set(ancestormod.missingancestors(include, exclude, cl.parentrevs))
412 return lazyset(subset, results.__contains__)
412 return lazyset(subset, results.__contains__)
413
413
414 def bisect(repo, subset, x):
414 def bisect(repo, subset, x):
415 """``bisect(string)``
415 """``bisect(string)``
416 Changesets marked in the specified bisect status:
416 Changesets marked in the specified bisect status:
417
417
418 - ``good``, ``bad``, ``skip``: csets explicitly marked as good/bad/skip
418 - ``good``, ``bad``, ``skip``: csets explicitly marked as good/bad/skip
419 - ``goods``, ``bads`` : csets topologically good/bad
419 - ``goods``, ``bads`` : csets topologically good/bad
420 - ``range`` : csets taking part in the bisection
420 - ``range`` : csets taking part in the bisection
421 - ``pruned`` : csets that are goods, bads or skipped
421 - ``pruned`` : csets that are goods, bads or skipped
422 - ``untested`` : csets whose fate is yet unknown
422 - ``untested`` : csets whose fate is yet unknown
423 - ``ignored`` : csets ignored due to DAG topology
423 - ``ignored`` : csets ignored due to DAG topology
424 - ``current`` : the cset currently being bisected
424 - ``current`` : the cset currently being bisected
425 """
425 """
426 # i18n: "bisect" is a keyword
426 # i18n: "bisect" is a keyword
427 status = getstring(x, _("bisect requires a string")).lower()
427 status = getstring(x, _("bisect requires a string")).lower()
428 state = set(hbisect.get(repo, status))
428 state = set(hbisect.get(repo, status))
429 return subset.filter(state.__contains__)
429 return subset.filter(state.__contains__)
430
430
431 # Backward-compatibility
431 # Backward-compatibility
432 # - no help entry so that we do not advertise it any more
432 # - no help entry so that we do not advertise it any more
433 def bisected(repo, subset, x):
433 def bisected(repo, subset, x):
434 return bisect(repo, subset, x)
434 return bisect(repo, subset, x)
435
435
436 def bookmark(repo, subset, x):
436 def bookmark(repo, subset, x):
437 """``bookmark([name])``
437 """``bookmark([name])``
438 The named bookmark or all bookmarks.
438 The named bookmark or all bookmarks.
439
439
440 If `name` starts with `re:`, the remainder of the name is treated as
440 If `name` starts with `re:`, the remainder of the name is treated as
441 a regular expression. To match a bookmark that actually starts with `re:`,
441 a regular expression. To match a bookmark that actually starts with `re:`,
442 use the prefix `literal:`.
442 use the prefix `literal:`.
443 """
443 """
444 # i18n: "bookmark" is a keyword
444 # i18n: "bookmark" is a keyword
445 args = getargs(x, 0, 1, _('bookmark takes one or no arguments'))
445 args = getargs(x, 0, 1, _('bookmark takes one or no arguments'))
446 if args:
446 if args:
447 bm = getstring(args[0],
447 bm = getstring(args[0],
448 # i18n: "bookmark" is a keyword
448 # i18n: "bookmark" is a keyword
449 _('the argument to bookmark must be a string'))
449 _('the argument to bookmark must be a string'))
450 kind, pattern, matcher = _stringmatcher(bm)
450 kind, pattern, matcher = _stringmatcher(bm)
451 if kind == 'literal':
451 if kind == 'literal':
452 bmrev = repo._bookmarks.get(pattern, None)
452 bmrev = repo._bookmarks.get(pattern, None)
453 if not bmrev:
453 if not bmrev:
454 raise util.Abort(_("bookmark '%s' does not exist") % bm)
454 raise util.Abort(_("bookmark '%s' does not exist") % bm)
455 bmrev = repo[bmrev].rev()
455 bmrev = repo[bmrev].rev()
456 return subset.filter(lambda r: r == bmrev)
456 return subset.filter(lambda r: r == bmrev)
457 else:
457 else:
458 matchrevs = set()
458 matchrevs = set()
459 for name, bmrev in repo._bookmarks.iteritems():
459 for name, bmrev in repo._bookmarks.iteritems():
460 if matcher(name):
460 if matcher(name):
461 matchrevs.add(bmrev)
461 matchrevs.add(bmrev)
462 if not matchrevs:
462 if not matchrevs:
463 raise util.Abort(_("no bookmarks exist that match '%s'")
463 raise util.Abort(_("no bookmarks exist that match '%s'")
464 % pattern)
464 % pattern)
465 bmrevs = set()
465 bmrevs = set()
466 for bmrev in matchrevs:
466 for bmrev in matchrevs:
467 bmrevs.add(repo[bmrev].rev())
467 bmrevs.add(repo[bmrev].rev())
468 return subset & bmrevs
468 return subset & bmrevs
469
469
470 bms = set([repo[r].rev()
470 bms = set([repo[r].rev()
471 for r in repo._bookmarks.values()])
471 for r in repo._bookmarks.values()])
472 return subset.filter(bms.__contains__)
472 return subset.filter(bms.__contains__)
473
473
474 def branch(repo, subset, x):
474 def branch(repo, subset, x):
475 """``branch(string or set)``
475 """``branch(string or set)``
476 All changesets belonging to the given branch or the branches of the given
476 All changesets belonging to the given branch or the branches of the given
477 changesets.
477 changesets.
478
478
479 If `string` starts with `re:`, the remainder of the name is treated as
479 If `string` starts with `re:`, the remainder of the name is treated as
480 a regular expression. To match a branch that actually starts with `re:`,
480 a regular expression. To match a branch that actually starts with `re:`,
481 use the prefix `literal:`.
481 use the prefix `literal:`.
482 """
482 """
483 try:
483 try:
484 b = getstring(x, '')
484 b = getstring(x, '')
485 except error.ParseError:
485 except error.ParseError:
486 # not a string, but another revspec, e.g. tip()
486 # not a string, but another revspec, e.g. tip()
487 pass
487 pass
488 else:
488 else:
489 kind, pattern, matcher = _stringmatcher(b)
489 kind, pattern, matcher = _stringmatcher(b)
490 if kind == 'literal':
490 if kind == 'literal':
491 # note: falls through to the revspec case if no branch with
491 # note: falls through to the revspec case if no branch with
492 # this name exists
492 # this name exists
493 if pattern in repo.branchmap():
493 if pattern in repo.branchmap():
494 return subset.filter(lambda r: matcher(repo[r].branch()))
494 return subset.filter(lambda r: matcher(repo[r].branch()))
495 else:
495 else:
496 return subset.filter(lambda r: matcher(repo[r].branch()))
496 return subset.filter(lambda r: matcher(repo[r].branch()))
497
497
498 s = getset(repo, spanset(repo), x)
498 s = getset(repo, spanset(repo), x)
499 b = set()
499 b = set()
500 for r in s:
500 for r in s:
501 b.add(repo[r].branch())
501 b.add(repo[r].branch())
502 s = s.set()
502 s = s.set()
503 return subset.filter(lambda r: r in s or repo[r].branch() in b)
503 return subset.filter(lambda r: r in s or repo[r].branch() in b)
504
504
505 def bumped(repo, subset, x):
505 def bumped(repo, subset, x):
506 """``bumped()``
506 """``bumped()``
507 Mutable changesets marked as successors of public changesets.
507 Mutable changesets marked as successors of public changesets.
508
508
509 Only non-public and non-obsolete changesets can be `bumped`.
509 Only non-public and non-obsolete changesets can be `bumped`.
510 """
510 """
511 # i18n: "bumped" is a keyword
511 # i18n: "bumped" is a keyword
512 getargs(x, 0, 0, _("bumped takes no arguments"))
512 getargs(x, 0, 0, _("bumped takes no arguments"))
513 bumped = obsmod.getrevs(repo, 'bumped')
513 bumped = obsmod.getrevs(repo, 'bumped')
514 return subset & bumped
514 return subset & bumped
515
515
516 def bundle(repo, subset, x):
516 def bundle(repo, subset, x):
517 """``bundle()``
517 """``bundle()``
518 Changesets in the bundle.
518 Changesets in the bundle.
519
519
520 Bundle must be specified by the -R option."""
520 Bundle must be specified by the -R option."""
521
521
522 try:
522 try:
523 bundlerevs = repo.changelog.bundlerevs
523 bundlerevs = repo.changelog.bundlerevs
524 except AttributeError:
524 except AttributeError:
525 raise util.Abort(_("no bundle provided - specify with -R"))
525 raise util.Abort(_("no bundle provided - specify with -R"))
526 return subset & bundlerevs
526 return subset & bundlerevs
527
527
528 def checkstatus(repo, subset, pat, field):
528 def checkstatus(repo, subset, pat, field):
529 hasset = matchmod.patkind(pat) == 'set'
529 hasset = matchmod.patkind(pat) == 'set'
530
530
531 def matches(x):
531 def matches(x):
532 m = None
532 m = None
533 fname = None
533 fname = None
534 c = repo[x]
534 c = repo[x]
535 if not m or hasset:
535 if not m or hasset:
536 m = matchmod.match(repo.root, repo.getcwd(), [pat], ctx=c)
536 m = matchmod.match(repo.root, repo.getcwd(), [pat], ctx=c)
537 if not m.anypats() and len(m.files()) == 1:
537 if not m.anypats() and len(m.files()) == 1:
538 fname = m.files()[0]
538 fname = m.files()[0]
539 if fname is not None:
539 if fname is not None:
540 if fname not in c.files():
540 if fname not in c.files():
541 return False
541 return False
542 else:
542 else:
543 for f in c.files():
543 for f in c.files():
544 if m(f):
544 if m(f):
545 break
545 break
546 else:
546 else:
547 return False
547 return False
548 files = repo.status(c.p1().node(), c.node())[field]
548 files = repo.status(c.p1().node(), c.node())[field]
549 if fname is not None:
549 if fname is not None:
550 if fname in files:
550 if fname in files:
551 return True
551 return True
552 else:
552 else:
553 for f in files:
553 for f in files:
554 if m(f):
554 if m(f):
555 return True
555 return True
556
556
557 return subset.filter(matches)
557 return subset.filter(matches)
558
558
559 def _children(repo, narrow, parentset):
559 def _children(repo, narrow, parentset):
560 cs = set()
560 cs = set()
561 if not parentset:
561 if not parentset:
562 return baseset(cs)
562 return baseset(cs)
563 pr = repo.changelog.parentrevs
563 pr = repo.changelog.parentrevs
564 minrev = min(parentset)
564 minrev = min(parentset)
565 for r in narrow:
565 for r in narrow:
566 if r <= minrev:
566 if r <= minrev:
567 continue
567 continue
568 for p in pr(r):
568 for p in pr(r):
569 if p in parentset:
569 if p in parentset:
570 cs.add(r)
570 cs.add(r)
571 return baseset(cs)
571 return baseset(cs)
572
572
573 def children(repo, subset, x):
573 def children(repo, subset, x):
574 """``children(set)``
574 """``children(set)``
575 Child changesets of changesets in set.
575 Child changesets of changesets in set.
576 """
576 """
577 s = getset(repo, baseset(repo), x).set()
577 s = getset(repo, baseset(repo), x).set()
578 cs = _children(repo, subset, s)
578 cs = _children(repo, subset, s)
579 return subset & cs
579 return subset & cs
580
580
581 def closed(repo, subset, x):
581 def closed(repo, subset, x):
582 """``closed()``
582 """``closed()``
583 Changeset is closed.
583 Changeset is closed.
584 """
584 """
585 # i18n: "closed" is a keyword
585 # i18n: "closed" is a keyword
586 getargs(x, 0, 0, _("closed takes no arguments"))
586 getargs(x, 0, 0, _("closed takes no arguments"))
587 return subset.filter(lambda r: repo[r].closesbranch())
587 return subset.filter(lambda r: repo[r].closesbranch())
588
588
589 def contains(repo, subset, x):
589 def contains(repo, subset, x):
590 """``contains(pattern)``
590 """``contains(pattern)``
591 The revision's manifest contains a file matching pattern (but might not
591 The revision's manifest contains a file matching pattern (but might not
592 modify it). See :hg:`help patterns` for information about file patterns.
592 modify it). See :hg:`help patterns` for information about file patterns.
593
593
594 The pattern without explicit kind like ``glob:`` is expected to be
594 The pattern without explicit kind like ``glob:`` is expected to be
595 relative to the current directory and match against a file exactly
595 relative to the current directory and match against a file exactly
596 for efficiency.
596 for efficiency.
597 """
597 """
598 # i18n: "contains" is a keyword
598 # i18n: "contains" is a keyword
599 pat = getstring(x, _("contains requires a pattern"))
599 pat = getstring(x, _("contains requires a pattern"))
600
600
601 def matches(x):
601 def matches(x):
602 if not matchmod.patkind(pat):
602 if not matchmod.patkind(pat):
603 pats = pathutil.canonpath(repo.root, repo.getcwd(), pat)
603 pats = pathutil.canonpath(repo.root, repo.getcwd(), pat)
604 if pats in repo[x]:
604 if pats in repo[x]:
605 return True
605 return True
606 else:
606 else:
607 c = repo[x]
607 c = repo[x]
608 m = matchmod.match(repo.root, repo.getcwd(), [pat], ctx=c)
608 m = matchmod.match(repo.root, repo.getcwd(), [pat], ctx=c)
609 for f in c.manifest():
609 for f in c.manifest():
610 if m(f):
610 if m(f):
611 return True
611 return True
612 return False
612 return False
613
613
614 return subset.filter(matches)
614 return subset.filter(matches)
615
615
616 def converted(repo, subset, x):
616 def converted(repo, subset, x):
617 """``converted([id])``
617 """``converted([id])``
618 Changesets converted from the given identifier in the old repository if
618 Changesets converted from the given identifier in the old repository if
619 present, or all converted changesets if no identifier is specified.
619 present, or all converted changesets if no identifier is specified.
620 """
620 """
621
621
622 # There is exactly no chance of resolving the revision, so do a simple
622 # There is exactly no chance of resolving the revision, so do a simple
623 # string compare and hope for the best
623 # string compare and hope for the best
624
624
625 rev = None
625 rev = None
626 # i18n: "converted" is a keyword
626 # i18n: "converted" is a keyword
627 l = getargs(x, 0, 1, _('converted takes one or no arguments'))
627 l = getargs(x, 0, 1, _('converted takes one or no arguments'))
628 if l:
628 if l:
629 # i18n: "converted" is a keyword
629 # i18n: "converted" is a keyword
630 rev = getstring(l[0], _('converted requires a revision'))
630 rev = getstring(l[0], _('converted requires a revision'))
631
631
632 def _matchvalue(r):
632 def _matchvalue(r):
633 source = repo[r].extra().get('convert_revision', None)
633 source = repo[r].extra().get('convert_revision', None)
634 return source is not None and (rev is None or source.startswith(rev))
634 return source is not None and (rev is None or source.startswith(rev))
635
635
636 return subset.filter(lambda r: _matchvalue(r))
636 return subset.filter(lambda r: _matchvalue(r))
637
637
638 def date(repo, subset, x):
638 def date(repo, subset, x):
639 """``date(interval)``
639 """``date(interval)``
640 Changesets within the interval, see :hg:`help dates`.
640 Changesets within the interval, see :hg:`help dates`.
641 """
641 """
642 # i18n: "date" is a keyword
642 # i18n: "date" is a keyword
643 ds = getstring(x, _("date requires a string"))
643 ds = getstring(x, _("date requires a string"))
644 dm = util.matchdate(ds)
644 dm = util.matchdate(ds)
645 return subset.filter(lambda x: dm(repo[x].date()[0]))
645 return subset.filter(lambda x: dm(repo[x].date()[0]))
646
646
647 def desc(repo, subset, x):
647 def desc(repo, subset, x):
648 """``desc(string)``
648 """``desc(string)``
649 Search commit message for string. The match is case-insensitive.
649 Search commit message for string. The match is case-insensitive.
650 """
650 """
651 # i18n: "desc" is a keyword
651 # i18n: "desc" is a keyword
652 ds = encoding.lower(getstring(x, _("desc requires a string")))
652 ds = encoding.lower(getstring(x, _("desc requires a string")))
653
653
654 def matches(x):
654 def matches(x):
655 c = repo[x]
655 c = repo[x]
656 return ds in encoding.lower(c.description())
656 return ds in encoding.lower(c.description())
657
657
658 return subset.filter(matches)
658 return subset.filter(matches)
659
659
660 def _descendants(repo, subset, x, followfirst=False):
660 def _descendants(repo, subset, x, followfirst=False):
661 args = getset(repo, spanset(repo), x)
661 args = getset(repo, spanset(repo), x)
662 if not args:
662 if not args:
663 return baseset([])
663 return baseset([])
664 s = _revdescendants(repo, args, followfirst)
664 s = _revdescendants(repo, args, followfirst)
665
665
666 # Both sets need to be ascending in order to lazily return the union
666 # Both sets need to be ascending in order to lazily return the union
667 # in the correct order.
667 # in the correct order.
668 args.ascending()
668 args.ascending()
669 result = (orderedlazyset(s, subset.__contains__, ascending=True) +
669 result = (orderedlazyset(s, subset.__contains__, ascending=True) +
670 orderedlazyset(args, subset.__contains__, ascending=True))
670 orderedlazyset(args, subset.__contains__, ascending=True))
671
671
672 # Wrap result in a lazyset since it's an _addset, which doesn't implement
672 # Wrap result in a lazyset since it's an _addset, which doesn't implement
673 # all the necessary functions to be consumed by callers.
673 # all the necessary functions to be consumed by callers.
674 return orderedlazyset(result, lambda r: True, ascending=True)
674 return orderedlazyset(result, lambda r: True, ascending=True)
675
675
676 def descendants(repo, subset, x):
676 def descendants(repo, subset, x):
677 """``descendants(set)``
677 """``descendants(set)``
678 Changesets which are descendants of changesets in set.
678 Changesets which are descendants of changesets in set.
679 """
679 """
680 return _descendants(repo, subset, x)
680 return _descendants(repo, subset, x)
681
681
682 def _firstdescendants(repo, subset, x):
682 def _firstdescendants(repo, subset, x):
683 # ``_firstdescendants(set)``
683 # ``_firstdescendants(set)``
684 # Like ``descendants(set)`` but follows only the first parents.
684 # Like ``descendants(set)`` but follows only the first parents.
685 return _descendants(repo, subset, x, followfirst=True)
685 return _descendants(repo, subset, x, followfirst=True)
686
686
687 def destination(repo, subset, x):
687 def destination(repo, subset, x):
688 """``destination([set])``
688 """``destination([set])``
689 Changesets that were created by a graft, transplant or rebase operation,
689 Changesets that were created by a graft, transplant or rebase operation,
690 with the given revisions specified as the source. Omitting the optional set
690 with the given revisions specified as the source. Omitting the optional set
691 is the same as passing all().
691 is the same as passing all().
692 """
692 """
693 if x is not None:
693 if x is not None:
694 args = getset(repo, spanset(repo), x).set()
694 args = getset(repo, spanset(repo), x).set()
695 else:
695 else:
696 args = getall(repo, spanset(repo), x).set()
696 args = getall(repo, spanset(repo), x).set()
697
697
698 dests = set()
698 dests = set()
699
699
700 # subset contains all of the possible destinations that can be returned, so
700 # subset contains all of the possible destinations that can be returned, so
701 # iterate over them and see if their source(s) were provided in the args.
701 # iterate over them and see if their source(s) were provided in the args.
702 # Even if the immediate src of r is not in the args, src's source (or
702 # Even if the immediate src of r is not in the args, src's source (or
703 # further back) may be. Scanning back further than the immediate src allows
703 # further back) may be. Scanning back further than the immediate src allows
704 # transitive transplants and rebases to yield the same results as transitive
704 # transitive transplants and rebases to yield the same results as transitive
705 # grafts.
705 # grafts.
706 for r in subset:
706 for r in subset:
707 src = _getrevsource(repo, r)
707 src = _getrevsource(repo, r)
708 lineage = None
708 lineage = None
709
709
710 while src is not None:
710 while src is not None:
711 if lineage is None:
711 if lineage is None:
712 lineage = list()
712 lineage = list()
713
713
714 lineage.append(r)
714 lineage.append(r)
715
715
716 # The visited lineage is a match if the current source is in the arg
716 # The visited lineage is a match if the current source is in the arg
717 # set. Since every candidate dest is visited by way of iterating
717 # set. Since every candidate dest is visited by way of iterating
718 # subset, any dests further back in the lineage will be tested by a
718 # subset, any dests further back in the lineage will be tested by a
719 # different iteration over subset. Likewise, if the src was already
719 # different iteration over subset. Likewise, if the src was already
720 # selected, the current lineage can be selected without going back
720 # selected, the current lineage can be selected without going back
721 # further.
721 # further.
722 if src in args or src in dests:
722 if src in args or src in dests:
723 dests.update(lineage)
723 dests.update(lineage)
724 break
724 break
725
725
726 r = src
726 r = src
727 src = _getrevsource(repo, r)
727 src = _getrevsource(repo, r)
728
728
729 return subset.filter(dests.__contains__)
729 return subset.filter(dests.__contains__)
730
730
731 def divergent(repo, subset, x):
731 def divergent(repo, subset, x):
732 """``divergent()``
732 """``divergent()``
733 Final successors of changesets with an alternative set of final successors.
733 Final successors of changesets with an alternative set of final successors.
734 """
734 """
735 # i18n: "divergent" is a keyword
735 # i18n: "divergent" is a keyword
736 getargs(x, 0, 0, _("divergent takes no arguments"))
736 getargs(x, 0, 0, _("divergent takes no arguments"))
737 divergent = obsmod.getrevs(repo, 'divergent')
737 divergent = obsmod.getrevs(repo, 'divergent')
738 return subset.filter(divergent.__contains__)
738 return subset.filter(divergent.__contains__)
739
739
740 def draft(repo, subset, x):
740 def draft(repo, subset, x):
741 """``draft()``
741 """``draft()``
742 Changeset in draft phase."""
742 Changeset in draft phase."""
743 # i18n: "draft" is a keyword
743 # i18n: "draft" is a keyword
744 getargs(x, 0, 0, _("draft takes no arguments"))
744 getargs(x, 0, 0, _("draft takes no arguments"))
745 pc = repo._phasecache
745 pc = repo._phasecache
746 return subset.filter(lambda r: pc.phase(repo, r) == phases.draft)
746 return subset.filter(lambda r: pc.phase(repo, r) == phases.draft)
747
747
748 def extinct(repo, subset, x):
748 def extinct(repo, subset, x):
749 """``extinct()``
749 """``extinct()``
750 Obsolete changesets with obsolete descendants only.
750 Obsolete changesets with obsolete descendants only.
751 """
751 """
752 # i18n: "extinct" is a keyword
752 # i18n: "extinct" is a keyword
753 getargs(x, 0, 0, _("extinct takes no arguments"))
753 getargs(x, 0, 0, _("extinct takes no arguments"))
754 extincts = obsmod.getrevs(repo, 'extinct')
754 extincts = obsmod.getrevs(repo, 'extinct')
755 return subset & extincts
755 return subset & extincts
756
756
757 def extra(repo, subset, x):
757 def extra(repo, subset, x):
758 """``extra(label, [value])``
758 """``extra(label, [value])``
759 Changesets with the given label in the extra metadata, with the given
759 Changesets with the given label in the extra metadata, with the given
760 optional value.
760 optional value.
761
761
762 If `value` starts with `re:`, the remainder of the value is treated as
762 If `value` starts with `re:`, the remainder of the value is treated as
763 a regular expression. To match a value that actually starts with `re:`,
763 a regular expression. To match a value that actually starts with `re:`,
764 use the prefix `literal:`.
764 use the prefix `literal:`.
765 """
765 """
766
766
767 # i18n: "extra" is a keyword
767 # i18n: "extra" is a keyword
768 l = getargs(x, 1, 2, _('extra takes at least 1 and at most 2 arguments'))
768 l = getargs(x, 1, 2, _('extra takes at least 1 and at most 2 arguments'))
769 # i18n: "extra" is a keyword
769 # i18n: "extra" is a keyword
770 label = getstring(l[0], _('first argument to extra must be a string'))
770 label = getstring(l[0], _('first argument to extra must be a string'))
771 value = None
771 value = None
772
772
773 if len(l) > 1:
773 if len(l) > 1:
774 # i18n: "extra" is a keyword
774 # i18n: "extra" is a keyword
775 value = getstring(l[1], _('second argument to extra must be a string'))
775 value = getstring(l[1], _('second argument to extra must be a string'))
776 kind, value, matcher = _stringmatcher(value)
776 kind, value, matcher = _stringmatcher(value)
777
777
778 def _matchvalue(r):
778 def _matchvalue(r):
779 extra = repo[r].extra()
779 extra = repo[r].extra()
780 return label in extra and (value is None or matcher(extra[label]))
780 return label in extra and (value is None or matcher(extra[label]))
781
781
782 return subset.filter(lambda r: _matchvalue(r))
782 return subset.filter(lambda r: _matchvalue(r))
783
783
784 def filelog(repo, subset, x):
784 def filelog(repo, subset, x):
785 """``filelog(pattern)``
785 """``filelog(pattern)``
786 Changesets connected to the specified filelog.
786 Changesets connected to the specified filelog.
787
787
788 For performance reasons, visits only revisions mentioned in the file-level
788 For performance reasons, visits only revisions mentioned in the file-level
789 filelog, rather than filtering through all changesets (much faster, but
789 filelog, rather than filtering through all changesets (much faster, but
790 doesn't include deletes or duplicate changes). For a slower, more accurate
790 doesn't include deletes or duplicate changes). For a slower, more accurate
791 result, use ``file()``.
791 result, use ``file()``.
792
792
793 The pattern without explicit kind like ``glob:`` is expected to be
793 The pattern without explicit kind like ``glob:`` is expected to be
794 relative to the current directory and match against a file exactly
794 relative to the current directory and match against a file exactly
795 for efficiency.
795 for efficiency.
796 """
796 """
797
797
798 # i18n: "filelog" is a keyword
798 # i18n: "filelog" is a keyword
799 pat = getstring(x, _("filelog requires a pattern"))
799 pat = getstring(x, _("filelog requires a pattern"))
800 s = set()
800 s = set()
801
801
802 if not matchmod.patkind(pat):
802 if not matchmod.patkind(pat):
803 f = pathutil.canonpath(repo.root, repo.getcwd(), pat)
803 f = pathutil.canonpath(repo.root, repo.getcwd(), pat)
804 fl = repo.file(f)
804 fl = repo.file(f)
805 for fr in fl:
805 for fr in fl:
806 s.add(fl.linkrev(fr))
806 s.add(fl.linkrev(fr))
807 else:
807 else:
808 m = matchmod.match(repo.root, repo.getcwd(), [pat], ctx=repo[None])
808 m = matchmod.match(repo.root, repo.getcwd(), [pat], ctx=repo[None])
809 for f in repo[None]:
809 for f in repo[None]:
810 if m(f):
810 if m(f):
811 fl = repo.file(f)
811 fl = repo.file(f)
812 for fr in fl:
812 for fr in fl:
813 s.add(fl.linkrev(fr))
813 s.add(fl.linkrev(fr))
814
814
815 return subset.filter(s.__contains__)
815 return subset.filter(s.__contains__)
816
816
817 def first(repo, subset, x):
817 def first(repo, subset, x):
818 """``first(set, [n])``
818 """``first(set, [n])``
819 An alias for limit().
819 An alias for limit().
820 """
820 """
821 return limit(repo, subset, x)
821 return limit(repo, subset, x)
822
822
823 def _follow(repo, subset, x, name, followfirst=False):
823 def _follow(repo, subset, x, name, followfirst=False):
824 l = getargs(x, 0, 1, _("%s takes no arguments or a filename") % name)
824 l = getargs(x, 0, 1, _("%s takes no arguments or a filename") % name)
825 c = repo['.']
825 c = repo['.']
826 if l:
826 if l:
827 x = getstring(l[0], _("%s expected a filename") % name)
827 x = getstring(l[0], _("%s expected a filename") % name)
828 if x in c:
828 if x in c:
829 cx = c[x]
829 cx = c[x]
830 s = set(ctx.rev() for ctx in cx.ancestors(followfirst=followfirst))
830 s = set(ctx.rev() for ctx in cx.ancestors(followfirst=followfirst))
831 # include the revision responsible for the most recent version
831 # include the revision responsible for the most recent version
832 s.add(cx.linkrev())
832 s.add(cx.linkrev())
833 else:
833 else:
834 return baseset([])
834 return baseset([])
835 else:
835 else:
836 s = _revancestors(repo, baseset([c.rev()]), followfirst)
836 s = _revancestors(repo, baseset([c.rev()]), followfirst)
837
837
838 return subset.filter(s.__contains__)
838 return subset.filter(s.__contains__)
839
839
840 def follow(repo, subset, x):
840 def follow(repo, subset, x):
841 """``follow([file])``
841 """``follow([file])``
842 An alias for ``::.`` (ancestors of the working copy's first parent).
842 An alias for ``::.`` (ancestors of the working copy's first parent).
843 If a filename is specified, the history of the given file is followed,
843 If a filename is specified, the history of the given file is followed,
844 including copies.
844 including copies.
845 """
845 """
846 return _follow(repo, subset, x, 'follow')
846 return _follow(repo, subset, x, 'follow')
847
847
848 def _followfirst(repo, subset, x):
848 def _followfirst(repo, subset, x):
849 # ``followfirst([file])``
849 # ``followfirst([file])``
850 # Like ``follow([file])`` but follows only the first parent of
850 # Like ``follow([file])`` but follows only the first parent of
851 # every revision or file revision.
851 # every revision or file revision.
852 return _follow(repo, subset, x, '_followfirst', followfirst=True)
852 return _follow(repo, subset, x, '_followfirst', followfirst=True)
853
853
854 def getall(repo, subset, x):
854 def getall(repo, subset, x):
855 """``all()``
855 """``all()``
856 All changesets, the same as ``0:tip``.
856 All changesets, the same as ``0:tip``.
857 """
857 """
858 # i18n: "all" is a keyword
858 # i18n: "all" is a keyword
859 getargs(x, 0, 0, _("all takes no arguments"))
859 getargs(x, 0, 0, _("all takes no arguments"))
860 return subset
860 return subset
861
861
862 def grep(repo, subset, x):
862 def grep(repo, subset, x):
863 """``grep(regex)``
863 """``grep(regex)``
864 Like ``keyword(string)`` but accepts a regex. Use ``grep(r'...')``
864 Like ``keyword(string)`` but accepts a regex. Use ``grep(r'...')``
865 to ensure special escape characters are handled correctly. Unlike
865 to ensure special escape characters are handled correctly. Unlike
866 ``keyword(string)``, the match is case-sensitive.
866 ``keyword(string)``, the match is case-sensitive.
867 """
867 """
868 try:
868 try:
869 # i18n: "grep" is a keyword
869 # i18n: "grep" is a keyword
870 gr = re.compile(getstring(x, _("grep requires a string")))
870 gr = re.compile(getstring(x, _("grep requires a string")))
871 except re.error, e:
871 except re.error, e:
872 raise error.ParseError(_('invalid match pattern: %s') % e)
872 raise error.ParseError(_('invalid match pattern: %s') % e)
873
873
874 def matches(x):
874 def matches(x):
875 c = repo[x]
875 c = repo[x]
876 for e in c.files() + [c.user(), c.description()]:
876 for e in c.files() + [c.user(), c.description()]:
877 if gr.search(e):
877 if gr.search(e):
878 return True
878 return True
879 return False
879 return False
880
880
881 return subset.filter(matches)
881 return subset.filter(matches)
882
882
883 def _matchfiles(repo, subset, x):
883 def _matchfiles(repo, subset, x):
884 # _matchfiles takes a revset list of prefixed arguments:
884 # _matchfiles takes a revset list of prefixed arguments:
885 #
885 #
886 # [p:foo, i:bar, x:baz]
886 # [p:foo, i:bar, x:baz]
887 #
887 #
888 # builds a match object from them and filters subset. Allowed
888 # builds a match object from them and filters subset. Allowed
889 # prefixes are 'p:' for regular patterns, 'i:' for include
889 # prefixes are 'p:' for regular patterns, 'i:' for include
890 # patterns and 'x:' for exclude patterns. Use 'r:' prefix to pass
890 # patterns and 'x:' for exclude patterns. Use 'r:' prefix to pass
891 # a revision identifier, or the empty string to reference the
891 # a revision identifier, or the empty string to reference the
892 # working directory, from which the match object is
892 # working directory, from which the match object is
893 # initialized. Use 'd:' to set the default matching mode, default
893 # initialized. Use 'd:' to set the default matching mode, default
894 # to 'glob'. At most one 'r:' and 'd:' argument can be passed.
894 # to 'glob'. At most one 'r:' and 'd:' argument can be passed.
895
895
896 # i18n: "_matchfiles" is a keyword
896 # i18n: "_matchfiles" is a keyword
897 l = getargs(x, 1, -1, _("_matchfiles requires at least one argument"))
897 l = getargs(x, 1, -1, _("_matchfiles requires at least one argument"))
898 pats, inc, exc = [], [], []
898 pats, inc, exc = [], [], []
899 hasset = False
899 hasset = False
900 rev, default = None, None
900 rev, default = None, None
901 for arg in l:
901 for arg in l:
902 # i18n: "_matchfiles" is a keyword
902 # i18n: "_matchfiles" is a keyword
903 s = getstring(arg, _("_matchfiles requires string arguments"))
903 s = getstring(arg, _("_matchfiles requires string arguments"))
904 prefix, value = s[:2], s[2:]
904 prefix, value = s[:2], s[2:]
905 if prefix == 'p:':
905 if prefix == 'p:':
906 pats.append(value)
906 pats.append(value)
907 elif prefix == 'i:':
907 elif prefix == 'i:':
908 inc.append(value)
908 inc.append(value)
909 elif prefix == 'x:':
909 elif prefix == 'x:':
910 exc.append(value)
910 exc.append(value)
911 elif prefix == 'r:':
911 elif prefix == 'r:':
912 if rev is not None:
912 if rev is not None:
913 # i18n: "_matchfiles" is a keyword
913 # i18n: "_matchfiles" is a keyword
914 raise error.ParseError(_('_matchfiles expected at most one '
914 raise error.ParseError(_('_matchfiles expected at most one '
915 'revision'))
915 'revision'))
916 rev = value
916 rev = value
917 elif prefix == 'd:':
917 elif prefix == 'd:':
918 if default is not None:
918 if default is not None:
919 # i18n: "_matchfiles" is a keyword
919 # i18n: "_matchfiles" is a keyword
920 raise error.ParseError(_('_matchfiles expected at most one '
920 raise error.ParseError(_('_matchfiles expected at most one '
921 'default mode'))
921 'default mode'))
922 default = value
922 default = value
923 else:
923 else:
924 # i18n: "_matchfiles" is a keyword
924 # i18n: "_matchfiles" is a keyword
925 raise error.ParseError(_('invalid _matchfiles prefix: %s') % prefix)
925 raise error.ParseError(_('invalid _matchfiles prefix: %s') % prefix)
926 if not hasset and matchmod.patkind(value) == 'set':
926 if not hasset and matchmod.patkind(value) == 'set':
927 hasset = True
927 hasset = True
928 if not default:
928 if not default:
929 default = 'glob'
929 default = 'glob'
930
930
931 def matches(x):
931 def matches(x):
932 m = None
932 m = None
933 c = repo[x]
933 c = repo[x]
934 if not m or (hasset and rev is None):
934 if not m or (hasset and rev is None):
935 ctx = c
935 ctx = c
936 if rev is not None:
936 if rev is not None:
937 ctx = repo[rev or None]
937 ctx = repo[rev or None]
938 m = matchmod.match(repo.root, repo.getcwd(), pats, include=inc,
938 m = matchmod.match(repo.root, repo.getcwd(), pats, include=inc,
939 exclude=exc, ctx=ctx, default=default)
939 exclude=exc, ctx=ctx, default=default)
940 for f in c.files():
940 for f in c.files():
941 if m(f):
941 if m(f):
942 return True
942 return True
943 return False
943 return False
944
944
945 return subset.filter(matches)
945 return subset.filter(matches)
946
946
947 def hasfile(repo, subset, x):
947 def hasfile(repo, subset, x):
948 """``file(pattern)``
948 """``file(pattern)``
949 Changesets affecting files matched by pattern.
949 Changesets affecting files matched by pattern.
950
950
951 For a faster but less accurate result, consider using ``filelog()``
951 For a faster but less accurate result, consider using ``filelog()``
952 instead.
952 instead.
953
953
954 This predicate uses ``glob:`` as the default kind of pattern.
954 This predicate uses ``glob:`` as the default kind of pattern.
955 """
955 """
956 # i18n: "file" is a keyword
956 # i18n: "file" is a keyword
957 pat = getstring(x, _("file requires a pattern"))
957 pat = getstring(x, _("file requires a pattern"))
958 return _matchfiles(repo, subset, ('string', 'p:' + pat))
958 return _matchfiles(repo, subset, ('string', 'p:' + pat))
959
959
960 def head(repo, subset, x):
960 def head(repo, subset, x):
961 """``head()``
961 """``head()``
962 Changeset is a named branch head.
962 Changeset is a named branch head.
963 """
963 """
964 # i18n: "head" is a keyword
964 # i18n: "head" is a keyword
965 getargs(x, 0, 0, _("head takes no arguments"))
965 getargs(x, 0, 0, _("head takes no arguments"))
966 hs = set()
966 hs = set()
967 for b, ls in repo.branchmap().iteritems():
967 for b, ls in repo.branchmap().iteritems():
968 hs.update(repo[h].rev() for h in ls)
968 hs.update(repo[h].rev() for h in ls)
969 return baseset(hs).filter(subset.__contains__)
969 return baseset(hs).filter(subset.__contains__)
970
970
971 def heads(repo, subset, x):
971 def heads(repo, subset, x):
972 """``heads(set)``
972 """``heads(set)``
973 Members of set with no children in set.
973 Members of set with no children in set.
974 """
974 """
975 s = getset(repo, subset, x)
975 s = getset(repo, subset, x)
976 ps = parents(repo, subset, x)
976 ps = parents(repo, subset, x)
977 return s - ps
977 return s - ps
978
978
979 def hidden(repo, subset, x):
979 def hidden(repo, subset, x):
980 """``hidden()``
980 """``hidden()``
981 Hidden changesets.
981 Hidden changesets.
982 """
982 """
983 # i18n: "hidden" is a keyword
983 # i18n: "hidden" is a keyword
984 getargs(x, 0, 0, _("hidden takes no arguments"))
984 getargs(x, 0, 0, _("hidden takes no arguments"))
985 hiddenrevs = repoview.filterrevs(repo, 'visible')
985 hiddenrevs = repoview.filterrevs(repo, 'visible')
986 return subset & hiddenrevs
986 return subset & hiddenrevs
987
987
988 def keyword(repo, subset, x):
988 def keyword(repo, subset, x):
989 """``keyword(string)``
989 """``keyword(string)``
990 Search commit message, user name, and names of changed files for
990 Search commit message, user name, and names of changed files for
991 string. The match is case-insensitive.
991 string. The match is case-insensitive.
992 """
992 """
993 # i18n: "keyword" is a keyword
993 # i18n: "keyword" is a keyword
994 kw = encoding.lower(getstring(x, _("keyword requires a string")))
994 kw = encoding.lower(getstring(x, _("keyword requires a string")))
995
995
996 def matches(r):
996 def matches(r):
997 c = repo[r]
997 c = repo[r]
998 return util.any(kw in encoding.lower(t) for t in c.files() + [c.user(),
998 return util.any(kw in encoding.lower(t) for t in c.files() + [c.user(),
999 c.description()])
999 c.description()])
1000
1000
1001 return subset.filter(matches)
1001 return subset.filter(matches)
1002
1002
1003 def limit(repo, subset, x):
1003 def limit(repo, subset, x):
1004 """``limit(set, [n])``
1004 """``limit(set, [n])``
1005 First n members of set, defaulting to 1.
1005 First n members of set, defaulting to 1.
1006 """
1006 """
1007 # i18n: "limit" is a keyword
1007 # i18n: "limit" is a keyword
1008 l = getargs(x, 1, 2, _("limit requires one or two arguments"))
1008 l = getargs(x, 1, 2, _("limit requires one or two arguments"))
1009 try:
1009 try:
1010 lim = 1
1010 lim = 1
1011 if len(l) == 2:
1011 if len(l) == 2:
1012 # i18n: "limit" is a keyword
1012 # i18n: "limit" is a keyword
1013 lim = int(getstring(l[1], _("limit requires a number")))
1013 lim = int(getstring(l[1], _("limit requires a number")))
1014 except (TypeError, ValueError):
1014 except (TypeError, ValueError):
1015 # i18n: "limit" is a keyword
1015 # i18n: "limit" is a keyword
1016 raise error.ParseError(_("limit expects a number"))
1016 raise error.ParseError(_("limit expects a number"))
1017 ss = subset.set()
1017 ss = subset.set()
1018 os = getset(repo, spanset(repo), l[0])
1018 os = getset(repo, spanset(repo), l[0])
1019 bs = baseset([])
1019 bs = baseset([])
1020 it = iter(os)
1020 it = iter(os)
1021 for x in xrange(lim):
1021 for x in xrange(lim):
1022 try:
1022 try:
1023 y = it.next()
1023 y = it.next()
1024 if y in ss:
1024 if y in ss:
1025 bs.append(y)
1025 bs.append(y)
1026 except (StopIteration):
1026 except (StopIteration):
1027 break
1027 break
1028 return bs
1028 return bs
1029
1029
1030 def last(repo, subset, x):
1030 def last(repo, subset, x):
1031 """``last(set, [n])``
1031 """``last(set, [n])``
1032 Last n members of set, defaulting to 1.
1032 Last n members of set, defaulting to 1.
1033 """
1033 """
1034 # i18n: "last" is a keyword
1034 # i18n: "last" is a keyword
1035 l = getargs(x, 1, 2, _("last requires one or two arguments"))
1035 l = getargs(x, 1, 2, _("last requires one or two arguments"))
1036 try:
1036 try:
1037 lim = 1
1037 lim = 1
1038 if len(l) == 2:
1038 if len(l) == 2:
1039 # i18n: "last" is a keyword
1039 # i18n: "last" is a keyword
1040 lim = int(getstring(l[1], _("last requires a number")))
1040 lim = int(getstring(l[1], _("last requires a number")))
1041 except (TypeError, ValueError):
1041 except (TypeError, ValueError):
1042 # i18n: "last" is a keyword
1042 # i18n: "last" is a keyword
1043 raise error.ParseError(_("last expects a number"))
1043 raise error.ParseError(_("last expects a number"))
1044 ss = subset.set()
1044 ss = subset.set()
1045 os = getset(repo, spanset(repo), l[0])
1045 os = getset(repo, spanset(repo), l[0])
1046 os.reverse()
1046 os.reverse()
1047 bs = baseset([])
1047 bs = baseset([])
1048 it = iter(os)
1048 it = iter(os)
1049 for x in xrange(lim):
1049 for x in xrange(lim):
1050 try:
1050 try:
1051 y = it.next()
1051 y = it.next()
1052 if y in ss:
1052 if y in ss:
1053 bs.append(y)
1053 bs.append(y)
1054 except (StopIteration):
1054 except (StopIteration):
1055 break
1055 break
1056 return bs
1056 return bs
1057
1057
1058 def maxrev(repo, subset, x):
1058 def maxrev(repo, subset, x):
1059 """``max(set)``
1059 """``max(set)``
1060 Changeset with highest revision number in set.
1060 Changeset with highest revision number in set.
1061 """
1061 """
1062 os = getset(repo, spanset(repo), x)
1062 os = getset(repo, spanset(repo), x)
1063 if os:
1063 if os:
1064 m = os.max()
1064 m = os.max()
1065 if m in subset:
1065 if m in subset:
1066 return baseset([m])
1066 return baseset([m])
1067 return baseset([])
1067 return baseset([])
1068
1068
1069 def merge(repo, subset, x):
1069 def merge(repo, subset, x):
1070 """``merge()``
1070 """``merge()``
1071 Changeset is a merge changeset.
1071 Changeset is a merge changeset.
1072 """
1072 """
1073 # i18n: "merge" is a keyword
1073 # i18n: "merge" is a keyword
1074 getargs(x, 0, 0, _("merge takes no arguments"))
1074 getargs(x, 0, 0, _("merge takes no arguments"))
1075 cl = repo.changelog
1075 cl = repo.changelog
1076 return subset.filter(lambda r: cl.parentrevs(r)[1] != -1)
1076 return subset.filter(lambda r: cl.parentrevs(r)[1] != -1)
1077
1077
1078 def branchpoint(repo, subset, x):
1078 def branchpoint(repo, subset, x):
1079 """``branchpoint()``
1079 """``branchpoint()``
1080 Changesets with more than one child.
1080 Changesets with more than one child.
1081 """
1081 """
1082 # i18n: "branchpoint" is a keyword
1082 # i18n: "branchpoint" is a keyword
1083 getargs(x, 0, 0, _("branchpoint takes no arguments"))
1083 getargs(x, 0, 0, _("branchpoint takes no arguments"))
1084 cl = repo.changelog
1084 cl = repo.changelog
1085 if not subset:
1085 if not subset:
1086 return baseset([])
1086 return baseset([])
1087 baserev = min(subset)
1087 baserev = min(subset)
1088 parentscount = [0]*(len(repo) - baserev)
1088 parentscount = [0]*(len(repo) - baserev)
1089 for r in cl.revs(start=baserev + 1):
1089 for r in cl.revs(start=baserev + 1):
1090 for p in cl.parentrevs(r):
1090 for p in cl.parentrevs(r):
1091 if p >= baserev:
1091 if p >= baserev:
1092 parentscount[p - baserev] += 1
1092 parentscount[p - baserev] += 1
1093 return subset.filter(lambda r: parentscount[r - baserev] > 1)
1093 return subset.filter(lambda r: parentscount[r - baserev] > 1)
1094
1094
1095 def minrev(repo, subset, x):
1095 def minrev(repo, subset, x):
1096 """``min(set)``
1096 """``min(set)``
1097 Changeset with lowest revision number in set.
1097 Changeset with lowest revision number in set.
1098 """
1098 """
1099 os = getset(repo, spanset(repo), x)
1099 os = getset(repo, spanset(repo), x)
1100 if os:
1100 if os:
1101 m = os.min()
1101 m = os.min()
1102 if m in subset:
1102 if m in subset:
1103 return baseset([m])
1103 return baseset([m])
1104 return baseset([])
1104 return baseset([])
1105
1105
1106 def modifies(repo, subset, x):
1106 def modifies(repo, subset, x):
1107 """``modifies(pattern)``
1107 """``modifies(pattern)``
1108 Changesets modifying files matched by pattern.
1108 Changesets modifying files matched by pattern.
1109
1109
1110 The pattern without explicit kind like ``glob:`` is expected to be
1110 The pattern without explicit kind like ``glob:`` is expected to be
1111 relative to the current directory and match against a file or a
1111 relative to the current directory and match against a file or a
1112 directory.
1112 directory.
1113 """
1113 """
1114 # i18n: "modifies" is a keyword
1114 # i18n: "modifies" is a keyword
1115 pat = getstring(x, _("modifies requires a pattern"))
1115 pat = getstring(x, _("modifies requires a pattern"))
1116 return checkstatus(repo, subset, pat, 0)
1116 return checkstatus(repo, subset, pat, 0)
1117
1117
1118 def node_(repo, subset, x):
1118 def node_(repo, subset, x):
1119 """``id(string)``
1119 """``id(string)``
1120 Revision non-ambiguously specified by the given hex string prefix.
1120 Revision non-ambiguously specified by the given hex string prefix.
1121 """
1121 """
1122 # i18n: "id" is a keyword
1122 # i18n: "id" is a keyword
1123 l = getargs(x, 1, 1, _("id requires one argument"))
1123 l = getargs(x, 1, 1, _("id requires one argument"))
1124 # i18n: "id" is a keyword
1124 # i18n: "id" is a keyword
1125 n = getstring(l[0], _("id requires a string"))
1125 n = getstring(l[0], _("id requires a string"))
1126 if len(n) == 40:
1126 if len(n) == 40:
1127 rn = repo[n].rev()
1127 rn = repo[n].rev()
1128 else:
1128 else:
1129 rn = None
1129 rn = None
1130 pm = repo.changelog._partialmatch(n)
1130 pm = repo.changelog._partialmatch(n)
1131 if pm is not None:
1131 if pm is not None:
1132 rn = repo.changelog.rev(pm)
1132 rn = repo.changelog.rev(pm)
1133
1133
1134 return subset.filter(lambda r: r == rn)
1134 return subset.filter(lambda r: r == rn)
1135
1135
1136 def obsolete(repo, subset, x):
1136 def obsolete(repo, subset, x):
1137 """``obsolete()``
1137 """``obsolete()``
1138 Mutable changeset with a newer version."""
1138 Mutable changeset with a newer version."""
1139 # i18n: "obsolete" is a keyword
1139 # i18n: "obsolete" is a keyword
1140 getargs(x, 0, 0, _("obsolete takes no arguments"))
1140 getargs(x, 0, 0, _("obsolete takes no arguments"))
1141 obsoletes = obsmod.getrevs(repo, 'obsolete')
1141 obsoletes = obsmod.getrevs(repo, 'obsolete')
1142 return subset & obsoletes
1142 return subset & obsoletes
1143
1143
1144 def origin(repo, subset, x):
1144 def origin(repo, subset, x):
1145 """``origin([set])``
1145 """``origin([set])``
1146 Changesets that were specified as a source for the grafts, transplants or
1146 Changesets that were specified as a source for the grafts, transplants or
1147 rebases that created the given revisions. Omitting the optional set is the
1147 rebases that created the given revisions. Omitting the optional set is the
1148 same as passing all(). If a changeset created by these operations is itself
1148 same as passing all(). If a changeset created by these operations is itself
1149 specified as a source for one of these operations, only the source changeset
1149 specified as a source for one of these operations, only the source changeset
1150 for the first operation is selected.
1150 for the first operation is selected.
1151 """
1151 """
1152 if x is not None:
1152 if x is not None:
1153 args = getset(repo, spanset(repo), x).set()
1153 args = getset(repo, spanset(repo), x).set()
1154 else:
1154 else:
1155 args = getall(repo, spanset(repo), x).set()
1155 args = getall(repo, spanset(repo), x).set()
1156
1156
1157 def _firstsrc(rev):
1157 def _firstsrc(rev):
1158 src = _getrevsource(repo, rev)
1158 src = _getrevsource(repo, rev)
1159 if src is None:
1159 if src is None:
1160 return None
1160 return None
1161
1161
1162 while True:
1162 while True:
1163 prev = _getrevsource(repo, src)
1163 prev = _getrevsource(repo, src)
1164
1164
1165 if prev is None:
1165 if prev is None:
1166 return src
1166 return src
1167 src = prev
1167 src = prev
1168
1168
1169 o = set([_firstsrc(r) for r in args])
1169 o = set([_firstsrc(r) for r in args])
1170 return subset.filter(o.__contains__)
1170 return subset.filter(o.__contains__)
1171
1171
1172 def outgoing(repo, subset, x):
1172 def outgoing(repo, subset, x):
1173 """``outgoing([path])``
1173 """``outgoing([path])``
1174 Changesets not found in the specified destination repository, or the
1174 Changesets not found in the specified destination repository, or the
1175 default push location.
1175 default push location.
1176 """
1176 """
1177 import hg # avoid start-up nasties
1177 import hg # avoid start-up nasties
1178 # i18n: "outgoing" is a keyword
1178 # i18n: "outgoing" is a keyword
1179 l = getargs(x, 0, 1, _("outgoing takes one or no arguments"))
1179 l = getargs(x, 0, 1, _("outgoing takes one or no arguments"))
1180 # i18n: "outgoing" is a keyword
1180 # i18n: "outgoing" is a keyword
1181 dest = l and getstring(l[0], _("outgoing requires a repository path")) or ''
1181 dest = l and getstring(l[0], _("outgoing requires a repository path")) or ''
1182 dest = repo.ui.expandpath(dest or 'default-push', dest or 'default')
1182 dest = repo.ui.expandpath(dest or 'default-push', dest or 'default')
1183 dest, branches = hg.parseurl(dest)
1183 dest, branches = hg.parseurl(dest)
1184 revs, checkout = hg.addbranchrevs(repo, repo, branches, [])
1184 revs, checkout = hg.addbranchrevs(repo, repo, branches, [])
1185 if revs:
1185 if revs:
1186 revs = [repo.lookup(rev) for rev in revs]
1186 revs = [repo.lookup(rev) for rev in revs]
1187 other = hg.peer(repo, {}, dest)
1187 other = hg.peer(repo, {}, dest)
1188 repo.ui.pushbuffer()
1188 repo.ui.pushbuffer()
1189 outgoing = discovery.findcommonoutgoing(repo, other, onlyheads=revs)
1189 outgoing = discovery.findcommonoutgoing(repo, other, onlyheads=revs)
1190 repo.ui.popbuffer()
1190 repo.ui.popbuffer()
1191 cl = repo.changelog
1191 cl = repo.changelog
1192 o = set([cl.rev(r) for r in outgoing.missing])
1192 o = set([cl.rev(r) for r in outgoing.missing])
1193 return subset.filter(o.__contains__)
1193 return subset.filter(o.__contains__)
1194
1194
1195 def p1(repo, subset, x):
1195 def p1(repo, subset, x):
1196 """``p1([set])``
1196 """``p1([set])``
1197 First parent of changesets in set, or the working directory.
1197 First parent of changesets in set, or the working directory.
1198 """
1198 """
1199 if x is None:
1199 if x is None:
1200 p = repo[x].p1().rev()
1200 p = repo[x].p1().rev()
1201 return subset.filter(lambda r: r == p)
1201 return subset.filter(lambda r: r == p)
1202
1202
1203 ps = set()
1203 ps = set()
1204 cl = repo.changelog
1204 cl = repo.changelog
1205 for r in getset(repo, spanset(repo), x):
1205 for r in getset(repo, spanset(repo), x):
1206 ps.add(cl.parentrevs(r)[0])
1206 ps.add(cl.parentrevs(r)[0])
1207 return subset & ps
1207 return subset & ps
1208
1208
1209 def p2(repo, subset, x):
1209 def p2(repo, subset, x):
1210 """``p2([set])``
1210 """``p2([set])``
1211 Second parent of changesets in set, or the working directory.
1211 Second parent of changesets in set, or the working directory.
1212 """
1212 """
1213 if x is None:
1213 if x is None:
1214 ps = repo[x].parents()
1214 ps = repo[x].parents()
1215 try:
1215 try:
1216 p = ps[1].rev()
1216 p = ps[1].rev()
1217 return subset.filter(lambda r: r == p)
1217 return subset.filter(lambda r: r == p)
1218 except IndexError:
1218 except IndexError:
1219 return baseset([])
1219 return baseset([])
1220
1220
1221 ps = set()
1221 ps = set()
1222 cl = repo.changelog
1222 cl = repo.changelog
1223 for r in getset(repo, spanset(repo), x):
1223 for r in getset(repo, spanset(repo), x):
1224 ps.add(cl.parentrevs(r)[1])
1224 ps.add(cl.parentrevs(r)[1])
1225 return subset & ps
1225 return subset & ps
1226
1226
1227 def parents(repo, subset, x):
1227 def parents(repo, subset, x):
1228 """``parents([set])``
1228 """``parents([set])``
1229 The set of all parents for all changesets in set, or the working directory.
1229 The set of all parents for all changesets in set, or the working directory.
1230 """
1230 """
1231 if x is None:
1231 if x is None:
1232 ps = tuple(p.rev() for p in repo[x].parents())
1232 ps = tuple(p.rev() for p in repo[x].parents())
1233 return subset & ps
1233 return subset & ps
1234
1234
1235 ps = set()
1235 ps = set()
1236 cl = repo.changelog
1236 cl = repo.changelog
1237 for r in getset(repo, spanset(repo), x):
1237 for r in getset(repo, spanset(repo), x):
1238 ps.update(cl.parentrevs(r))
1238 ps.update(cl.parentrevs(r))
1239 return baseset(ps) & subset
1239 return baseset(ps) & subset
1240
1240
1241 def parentspec(repo, subset, x, n):
1241 def parentspec(repo, subset, x, n):
1242 """``set^0``
1242 """``set^0``
1243 The set.
1243 The set.
1244 ``set^1`` (or ``set^``), ``set^2``
1244 ``set^1`` (or ``set^``), ``set^2``
1245 First or second parent, respectively, of all changesets in set.
1245 First or second parent, respectively, of all changesets in set.
1246 """
1246 """
1247 try:
1247 try:
1248 n = int(n[1])
1248 n = int(n[1])
1249 if n not in (0, 1, 2):
1249 if n not in (0, 1, 2):
1250 raise ValueError
1250 raise ValueError
1251 except (TypeError, ValueError):
1251 except (TypeError, ValueError):
1252 raise error.ParseError(_("^ expects a number 0, 1, or 2"))
1252 raise error.ParseError(_("^ expects a number 0, 1, or 2"))
1253 ps = set()
1253 ps = set()
1254 cl = repo.changelog
1254 cl = repo.changelog
1255 for r in getset(repo, baseset(cl), x):
1255 for r in getset(repo, baseset(cl), x):
1256 if n == 0:
1256 if n == 0:
1257 ps.add(r)
1257 ps.add(r)
1258 elif n == 1:
1258 elif n == 1:
1259 ps.add(cl.parentrevs(r)[0])
1259 ps.add(cl.parentrevs(r)[0])
1260 elif n == 2:
1260 elif n == 2:
1261 parents = cl.parentrevs(r)
1261 parents = cl.parentrevs(r)
1262 if len(parents) > 1:
1262 if len(parents) > 1:
1263 ps.add(parents[1])
1263 ps.add(parents[1])
1264 return subset & ps
1264 return subset & ps
1265
1265
1266 def present(repo, subset, x):
1266 def present(repo, subset, x):
1267 """``present(set)``
1267 """``present(set)``
1268 An empty set, if any revision in set isn't found; otherwise,
1268 An empty set, if any revision in set isn't found; otherwise,
1269 all revisions in set.
1269 all revisions in set.
1270
1270
1271 If any of specified revisions is not present in the local repository,
1271 If any of specified revisions is not present in the local repository,
1272 the query is normally aborted. But this predicate allows the query
1272 the query is normally aborted. But this predicate allows the query
1273 to continue even in such cases.
1273 to continue even in such cases.
1274 """
1274 """
1275 try:
1275 try:
1276 return getset(repo, subset, x)
1276 return getset(repo, subset, x)
1277 except error.RepoLookupError:
1277 except error.RepoLookupError:
1278 return baseset([])
1278 return baseset([])
1279
1279
1280 def public(repo, subset, x):
1280 def public(repo, subset, x):
1281 """``public()``
1281 """``public()``
1282 Changeset in public phase."""
1282 Changeset in public phase."""
1283 # i18n: "public" is a keyword
1283 # i18n: "public" is a keyword
1284 getargs(x, 0, 0, _("public takes no arguments"))
1284 getargs(x, 0, 0, _("public takes no arguments"))
1285 pc = repo._phasecache
1285 pc = repo._phasecache
1286 return subset.filter(lambda r: pc.phase(repo, r) == phases.public)
1286 return subset.filter(lambda r: pc.phase(repo, r) == phases.public)
1287
1287
1288 def remote(repo, subset, x):
1288 def remote(repo, subset, x):
1289 """``remote([id [,path]])``
1289 """``remote([id [,path]])``
1290 Local revision that corresponds to the given identifier in a
1290 Local revision that corresponds to the given identifier in a
1291 remote repository, if present. Here, the '.' identifier is a
1291 remote repository, if present. Here, the '.' identifier is a
1292 synonym for the current local branch.
1292 synonym for the current local branch.
1293 """
1293 """
1294
1294
1295 import hg # avoid start-up nasties
1295 import hg # avoid start-up nasties
1296 # i18n: "remote" is a keyword
1296 # i18n: "remote" is a keyword
1297 l = getargs(x, 0, 2, _("remote takes one, two or no arguments"))
1297 l = getargs(x, 0, 2, _("remote takes one, two or no arguments"))
1298
1298
1299 q = '.'
1299 q = '.'
1300 if len(l) > 0:
1300 if len(l) > 0:
1301 # i18n: "remote" is a keyword
1301 # i18n: "remote" is a keyword
1302 q = getstring(l[0], _("remote requires a string id"))
1302 q = getstring(l[0], _("remote requires a string id"))
1303 if q == '.':
1303 if q == '.':
1304 q = repo['.'].branch()
1304 q = repo['.'].branch()
1305
1305
1306 dest = ''
1306 dest = ''
1307 if len(l) > 1:
1307 if len(l) > 1:
1308 # i18n: "remote" is a keyword
1308 # i18n: "remote" is a keyword
1309 dest = getstring(l[1], _("remote requires a repository path"))
1309 dest = getstring(l[1], _("remote requires a repository path"))
1310 dest = repo.ui.expandpath(dest or 'default')
1310 dest = repo.ui.expandpath(dest or 'default')
1311 dest, branches = hg.parseurl(dest)
1311 dest, branches = hg.parseurl(dest)
1312 revs, checkout = hg.addbranchrevs(repo, repo, branches, [])
1312 revs, checkout = hg.addbranchrevs(repo, repo, branches, [])
1313 if revs:
1313 if revs:
1314 revs = [repo.lookup(rev) for rev in revs]
1314 revs = [repo.lookup(rev) for rev in revs]
1315 other = hg.peer(repo, {}, dest)
1315 other = hg.peer(repo, {}, dest)
1316 n = other.lookup(q)
1316 n = other.lookup(q)
1317 if n in repo:
1317 if n in repo:
1318 r = repo[n].rev()
1318 r = repo[n].rev()
1319 if r in subset:
1319 if r in subset:
1320 return baseset([r])
1320 return baseset([r])
1321 return baseset([])
1321 return baseset([])
1322
1322
1323 def removes(repo, subset, x):
1323 def removes(repo, subset, x):
1324 """``removes(pattern)``
1324 """``removes(pattern)``
1325 Changesets which remove files matching pattern.
1325 Changesets which remove files matching pattern.
1326
1326
1327 The pattern without explicit kind like ``glob:`` is expected to be
1327 The pattern without explicit kind like ``glob:`` is expected to be
1328 relative to the current directory and match against a file or a
1328 relative to the current directory and match against a file or a
1329 directory.
1329 directory.
1330 """
1330 """
1331 # i18n: "removes" is a keyword
1331 # i18n: "removes" is a keyword
1332 pat = getstring(x, _("removes requires a pattern"))
1332 pat = getstring(x, _("removes requires a pattern"))
1333 return checkstatus(repo, subset, pat, 2)
1333 return checkstatus(repo, subset, pat, 2)
1334
1334
1335 def rev(repo, subset, x):
1335 def rev(repo, subset, x):
1336 """``rev(number)``
1336 """``rev(number)``
1337 Revision with the given numeric identifier.
1337 Revision with the given numeric identifier.
1338 """
1338 """
1339 # i18n: "rev" is a keyword
1339 # i18n: "rev" is a keyword
1340 l = getargs(x, 1, 1, _("rev requires one argument"))
1340 l = getargs(x, 1, 1, _("rev requires one argument"))
1341 try:
1341 try:
1342 # i18n: "rev" is a keyword
1342 # i18n: "rev" is a keyword
1343 l = int(getstring(l[0], _("rev requires a number")))
1343 l = int(getstring(l[0], _("rev requires a number")))
1344 except (TypeError, ValueError):
1344 except (TypeError, ValueError):
1345 # i18n: "rev" is a keyword
1345 # i18n: "rev" is a keyword
1346 raise error.ParseError(_("rev expects a number"))
1346 raise error.ParseError(_("rev expects a number"))
1347 return subset.filter(lambda r: r == l)
1347 return subset.filter(lambda r: r == l)
1348
1348
1349 def matching(repo, subset, x):
1349 def matching(repo, subset, x):
1350 """``matching(revision [, field])``
1350 """``matching(revision [, field])``
1351 Changesets in which a given set of fields match the set of fields in the
1351 Changesets in which a given set of fields match the set of fields in the
1352 selected revision or set.
1352 selected revision or set.
1353
1353
1354 To match more than one field pass the list of fields to match separated
1354 To match more than one field pass the list of fields to match separated
1355 by spaces (e.g. ``author description``).
1355 by spaces (e.g. ``author description``).
1356
1356
1357 Valid fields are most regular revision fields and some special fields.
1357 Valid fields are most regular revision fields and some special fields.
1358
1358
1359 Regular revision fields are ``description``, ``author``, ``branch``,
1359 Regular revision fields are ``description``, ``author``, ``branch``,
1360 ``date``, ``files``, ``phase``, ``parents``, ``substate``, ``user``
1360 ``date``, ``files``, ``phase``, ``parents``, ``substate``, ``user``
1361 and ``diff``.
1361 and ``diff``.
1362 Note that ``author`` and ``user`` are synonyms. ``diff`` refers to the
1362 Note that ``author`` and ``user`` are synonyms. ``diff`` refers to the
1363 contents of the revision. Two revisions matching their ``diff`` will
1363 contents of the revision. Two revisions matching their ``diff`` will
1364 also match their ``files``.
1364 also match their ``files``.
1365
1365
1366 Special fields are ``summary`` and ``metadata``:
1366 Special fields are ``summary`` and ``metadata``:
1367 ``summary`` matches the first line of the description.
1367 ``summary`` matches the first line of the description.
1368 ``metadata`` is equivalent to matching ``description user date``
1368 ``metadata`` is equivalent to matching ``description user date``
1369 (i.e. it matches the main metadata fields).
1369 (i.e. it matches the main metadata fields).
1370
1370
1371 ``metadata`` is the default field which is used when no fields are
1371 ``metadata`` is the default field which is used when no fields are
1372 specified. You can match more than one field at a time.
1372 specified. You can match more than one field at a time.
1373 """
1373 """
1374 # i18n: "matching" is a keyword
1374 # i18n: "matching" is a keyword
1375 l = getargs(x, 1, 2, _("matching takes 1 or 2 arguments"))
1375 l = getargs(x, 1, 2, _("matching takes 1 or 2 arguments"))
1376
1376
1377 revs = getset(repo, baseset(repo.changelog), l[0])
1377 revs = getset(repo, baseset(repo.changelog), l[0])
1378
1378
1379 fieldlist = ['metadata']
1379 fieldlist = ['metadata']
1380 if len(l) > 1:
1380 if len(l) > 1:
1381 fieldlist = getstring(l[1],
1381 fieldlist = getstring(l[1],
1382 # i18n: "matching" is a keyword
1382 # i18n: "matching" is a keyword
1383 _("matching requires a string "
1383 _("matching requires a string "
1384 "as its second argument")).split()
1384 "as its second argument")).split()
1385
1385
1386 # Make sure that there are no repeated fields,
1386 # Make sure that there are no repeated fields,
1387 # expand the 'special' 'metadata' field type
1387 # expand the 'special' 'metadata' field type
1388 # and check the 'files' whenever we check the 'diff'
1388 # and check the 'files' whenever we check the 'diff'
1389 fields = []
1389 fields = []
1390 for field in fieldlist:
1390 for field in fieldlist:
1391 if field == 'metadata':
1391 if field == 'metadata':
1392 fields += ['user', 'description', 'date']
1392 fields += ['user', 'description', 'date']
1393 elif field == 'diff':
1393 elif field == 'diff':
1394 # a revision matching the diff must also match the files
1394 # a revision matching the diff must also match the files
1395 # since matching the diff is very costly, make sure to
1395 # since matching the diff is very costly, make sure to
1396 # also match the files first
1396 # also match the files first
1397 fields += ['files', 'diff']
1397 fields += ['files', 'diff']
1398 else:
1398 else:
1399 if field == 'author':
1399 if field == 'author':
1400 field = 'user'
1400 field = 'user'
1401 fields.append(field)
1401 fields.append(field)
1402 fields = set(fields)
1402 fields = set(fields)
1403 if 'summary' in fields and 'description' in fields:
1403 if 'summary' in fields and 'description' in fields:
1404 # If a revision matches its description it also matches its summary
1404 # If a revision matches its description it also matches its summary
1405 fields.discard('summary')
1405 fields.discard('summary')
1406
1406
1407 # We may want to match more than one field
1407 # We may want to match more than one field
1408 # Not all fields take the same amount of time to be matched
1408 # Not all fields take the same amount of time to be matched
1409 # Sort the selected fields in order of increasing matching cost
1409 # Sort the selected fields in order of increasing matching cost
1410 fieldorder = ['phase', 'parents', 'user', 'date', 'branch', 'summary',
1410 fieldorder = ['phase', 'parents', 'user', 'date', 'branch', 'summary',
1411 'files', 'description', 'substate', 'diff']
1411 'files', 'description', 'substate', 'diff']
1412 def fieldkeyfunc(f):
1412 def fieldkeyfunc(f):
1413 try:
1413 try:
1414 return fieldorder.index(f)
1414 return fieldorder.index(f)
1415 except ValueError:
1415 except ValueError:
1416 # assume an unknown field is very costly
1416 # assume an unknown field is very costly
1417 return len(fieldorder)
1417 return len(fieldorder)
1418 fields = list(fields)
1418 fields = list(fields)
1419 fields.sort(key=fieldkeyfunc)
1419 fields.sort(key=fieldkeyfunc)
1420
1420
1421 # Each field will be matched with its own "getfield" function
1421 # Each field will be matched with its own "getfield" function
1422 # which will be added to the getfieldfuncs array of functions
1422 # which will be added to the getfieldfuncs array of functions
1423 getfieldfuncs = []
1423 getfieldfuncs = []
1424 _funcs = {
1424 _funcs = {
1425 'user': lambda r: repo[r].user(),
1425 'user': lambda r: repo[r].user(),
1426 'branch': lambda r: repo[r].branch(),
1426 'branch': lambda r: repo[r].branch(),
1427 'date': lambda r: repo[r].date(),
1427 'date': lambda r: repo[r].date(),
1428 'description': lambda r: repo[r].description(),
1428 'description': lambda r: repo[r].description(),
1429 'files': lambda r: repo[r].files(),
1429 'files': lambda r: repo[r].files(),
1430 'parents': lambda r: repo[r].parents(),
1430 'parents': lambda r: repo[r].parents(),
1431 'phase': lambda r: repo[r].phase(),
1431 'phase': lambda r: repo[r].phase(),
1432 'substate': lambda r: repo[r].substate,
1432 'substate': lambda r: repo[r].substate,
1433 'summary': lambda r: repo[r].description().splitlines()[0],
1433 'summary': lambda r: repo[r].description().splitlines()[0],
1434 'diff': lambda r: list(repo[r].diff(git=True),)
1434 'diff': lambda r: list(repo[r].diff(git=True),)
1435 }
1435 }
1436 for info in fields:
1436 for info in fields:
1437 getfield = _funcs.get(info, None)
1437 getfield = _funcs.get(info, None)
1438 if getfield is None:
1438 if getfield is None:
1439 raise error.ParseError(
1439 raise error.ParseError(
1440 # i18n: "matching" is a keyword
1440 # i18n: "matching" is a keyword
1441 _("unexpected field name passed to matching: %s") % info)
1441 _("unexpected field name passed to matching: %s") % info)
1442 getfieldfuncs.append(getfield)
1442 getfieldfuncs.append(getfield)
1443 # convert the getfield array of functions into a "getinfo" function
1443 # convert the getfield array of functions into a "getinfo" function
1444 # which returns an array of field values (or a single value if there
1444 # which returns an array of field values (or a single value if there
1445 # is only one field to match)
1445 # is only one field to match)
1446 getinfo = lambda r: [f(r) for f in getfieldfuncs]
1446 getinfo = lambda r: [f(r) for f in getfieldfuncs]
1447
1447
1448 def matches(x):
1448 def matches(x):
1449 for rev in revs:
1449 for rev in revs:
1450 target = getinfo(rev)
1450 target = getinfo(rev)
1451 match = True
1451 match = True
1452 for n, f in enumerate(getfieldfuncs):
1452 for n, f in enumerate(getfieldfuncs):
1453 if target[n] != f(x):
1453 if target[n] != f(x):
1454 match = False
1454 match = False
1455 if match:
1455 if match:
1456 return True
1456 return True
1457 return False
1457 return False
1458
1458
1459 return subset.filter(matches)
1459 return subset.filter(matches)
1460
1460
1461 def reverse(repo, subset, x):
1461 def reverse(repo, subset, x):
1462 """``reverse(set)``
1462 """``reverse(set)``
1463 Reverse order of set.
1463 Reverse order of set.
1464 """
1464 """
1465 l = getset(repo, subset, x)
1465 l = getset(repo, subset, x)
1466 l.reverse()
1466 l.reverse()
1467 return l
1467 return l
1468
1468
1469 def roots(repo, subset, x):
1469 def roots(repo, subset, x):
1470 """``roots(set)``
1470 """``roots(set)``
1471 Changesets in set with no parent changeset in set.
1471 Changesets in set with no parent changeset in set.
1472 """
1472 """
1473 s = getset(repo, spanset(repo), x).set()
1473 s = getset(repo, spanset(repo), x).set()
1474 subset = baseset([r for r in s if r in subset.set()])
1474 subset = baseset([r for r in s if r in subset.set()])
1475 cs = _children(repo, subset, s)
1475 cs = _children(repo, subset, s)
1476 return subset - cs
1476 return subset - cs
1477
1477
1478 def secret(repo, subset, x):
1478 def secret(repo, subset, x):
1479 """``secret()``
1479 """``secret()``
1480 Changeset in secret phase."""
1480 Changeset in secret phase."""
1481 # i18n: "secret" is a keyword
1481 # i18n: "secret" is a keyword
1482 getargs(x, 0, 0, _("secret takes no arguments"))
1482 getargs(x, 0, 0, _("secret takes no arguments"))
1483 pc = repo._phasecache
1483 pc = repo._phasecache
1484 return subset.filter(lambda x: pc.phase(repo, x) == phases.secret)
1484 return subset.filter(lambda x: pc.phase(repo, x) == phases.secret)
1485
1485
1486 def sort(repo, subset, x):
1486 def sort(repo, subset, x):
1487 """``sort(set[, [-]key...])``
1487 """``sort(set[, [-]key...])``
1488 Sort set by keys. The default sort order is ascending, specify a key
1488 Sort set by keys. The default sort order is ascending, specify a key
1489 as ``-key`` to sort in descending order.
1489 as ``-key`` to sort in descending order.
1490
1490
1491 The keys can be:
1491 The keys can be:
1492
1492
1493 - ``rev`` for the revision number,
1493 - ``rev`` for the revision number,
1494 - ``branch`` for the branch name,
1494 - ``branch`` for the branch name,
1495 - ``desc`` for the commit message (description),
1495 - ``desc`` for the commit message (description),
1496 - ``user`` for user name (``author`` can be used as an alias),
1496 - ``user`` for user name (``author`` can be used as an alias),
1497 - ``date`` for the commit date
1497 - ``date`` for the commit date
1498 """
1498 """
1499 # i18n: "sort" is a keyword
1499 # i18n: "sort" is a keyword
1500 l = getargs(x, 1, 2, _("sort requires one or two arguments"))
1500 l = getargs(x, 1, 2, _("sort requires one or two arguments"))
1501 keys = "rev"
1501 keys = "rev"
1502 if len(l) == 2:
1502 if len(l) == 2:
1503 # i18n: "sort" is a keyword
1503 # i18n: "sort" is a keyword
1504 keys = getstring(l[1], _("sort spec must be a string"))
1504 keys = getstring(l[1], _("sort spec must be a string"))
1505
1505
1506 s = l[0]
1506 s = l[0]
1507 keys = keys.split()
1507 keys = keys.split()
1508 l = []
1508 l = []
1509 def invert(s):
1509 def invert(s):
1510 return "".join(chr(255 - ord(c)) for c in s)
1510 return "".join(chr(255 - ord(c)) for c in s)
1511 revs = getset(repo, subset, s)
1511 revs = getset(repo, subset, s)
1512 if keys == ["rev"]:
1512 if keys == ["rev"]:
1513 revs.sort()
1513 revs.sort()
1514 return revs
1514 return revs
1515 elif keys == ["-rev"]:
1515 elif keys == ["-rev"]:
1516 revs.sort(reverse=True)
1516 revs.sort(reverse=True)
1517 return revs
1517 return revs
1518 for r in revs:
1518 for r in revs:
1519 c = repo[r]
1519 c = repo[r]
1520 e = []
1520 e = []
1521 for k in keys:
1521 for k in keys:
1522 if k == 'rev':
1522 if k == 'rev':
1523 e.append(r)
1523 e.append(r)
1524 elif k == '-rev':
1524 elif k == '-rev':
1525 e.append(-r)
1525 e.append(-r)
1526 elif k == 'branch':
1526 elif k == 'branch':
1527 e.append(c.branch())
1527 e.append(c.branch())
1528 elif k == '-branch':
1528 elif k == '-branch':
1529 e.append(invert(c.branch()))
1529 e.append(invert(c.branch()))
1530 elif k == 'desc':
1530 elif k == 'desc':
1531 e.append(c.description())
1531 e.append(c.description())
1532 elif k == '-desc':
1532 elif k == '-desc':
1533 e.append(invert(c.description()))
1533 e.append(invert(c.description()))
1534 elif k in 'user author':
1534 elif k in 'user author':
1535 e.append(c.user())
1535 e.append(c.user())
1536 elif k in '-user -author':
1536 elif k in '-user -author':
1537 e.append(invert(c.user()))
1537 e.append(invert(c.user()))
1538 elif k == 'date':
1538 elif k == 'date':
1539 e.append(c.date()[0])
1539 e.append(c.date()[0])
1540 elif k == '-date':
1540 elif k == '-date':
1541 e.append(-c.date()[0])
1541 e.append(-c.date()[0])
1542 else:
1542 else:
1543 raise error.ParseError(_("unknown sort key %r") % k)
1543 raise error.ParseError(_("unknown sort key %r") % k)
1544 e.append(r)
1544 e.append(r)
1545 l.append(e)
1545 l.append(e)
1546 l.sort()
1546 l.sort()
1547 return baseset([e[-1] for e in l])
1547 return baseset([e[-1] for e in l])
1548
1548
1549 def _stringmatcher(pattern):
1549 def _stringmatcher(pattern):
1550 """
1550 """
1551 accepts a string, possibly starting with 're:' or 'literal:' prefix.
1551 accepts a string, possibly starting with 're:' or 'literal:' prefix.
1552 returns the matcher name, pattern, and matcher function.
1552 returns the matcher name, pattern, and matcher function.
1553 missing or unknown prefixes are treated as literal matches.
1553 missing or unknown prefixes are treated as literal matches.
1554
1554
1555 helper for tests:
1555 helper for tests:
1556 >>> def test(pattern, *tests):
1556 >>> def test(pattern, *tests):
1557 ... kind, pattern, matcher = _stringmatcher(pattern)
1557 ... kind, pattern, matcher = _stringmatcher(pattern)
1558 ... return (kind, pattern, [bool(matcher(t)) for t in tests])
1558 ... return (kind, pattern, [bool(matcher(t)) for t in tests])
1559
1559
1560 exact matching (no prefix):
1560 exact matching (no prefix):
1561 >>> test('abcdefg', 'abc', 'def', 'abcdefg')
1561 >>> test('abcdefg', 'abc', 'def', 'abcdefg')
1562 ('literal', 'abcdefg', [False, False, True])
1562 ('literal', 'abcdefg', [False, False, True])
1563
1563
1564 regex matching ('re:' prefix)
1564 regex matching ('re:' prefix)
1565 >>> test('re:a.+b', 'nomatch', 'fooadef', 'fooadefbar')
1565 >>> test('re:a.+b', 'nomatch', 'fooadef', 'fooadefbar')
1566 ('re', 'a.+b', [False, False, True])
1566 ('re', 'a.+b', [False, False, True])
1567
1567
1568 force exact matches ('literal:' prefix)
1568 force exact matches ('literal:' prefix)
1569 >>> test('literal:re:foobar', 'foobar', 're:foobar')
1569 >>> test('literal:re:foobar', 'foobar', 're:foobar')
1570 ('literal', 're:foobar', [False, True])
1570 ('literal', 're:foobar', [False, True])
1571
1571
1572 unknown prefixes are ignored and treated as literals
1572 unknown prefixes are ignored and treated as literals
1573 >>> test('foo:bar', 'foo', 'bar', 'foo:bar')
1573 >>> test('foo:bar', 'foo', 'bar', 'foo:bar')
1574 ('literal', 'foo:bar', [False, False, True])
1574 ('literal', 'foo:bar', [False, False, True])
1575 """
1575 """
1576 if pattern.startswith('re:'):
1576 if pattern.startswith('re:'):
1577 pattern = pattern[3:]
1577 pattern = pattern[3:]
1578 try:
1578 try:
1579 regex = re.compile(pattern)
1579 regex = re.compile(pattern)
1580 except re.error, e:
1580 except re.error, e:
1581 raise error.ParseError(_('invalid regular expression: %s')
1581 raise error.ParseError(_('invalid regular expression: %s')
1582 % e)
1582 % e)
1583 return 're', pattern, regex.search
1583 return 're', pattern, regex.search
1584 elif pattern.startswith('literal:'):
1584 elif pattern.startswith('literal:'):
1585 pattern = pattern[8:]
1585 pattern = pattern[8:]
1586 return 'literal', pattern, pattern.__eq__
1586 return 'literal', pattern, pattern.__eq__
1587
1587
1588 def _substringmatcher(pattern):
1588 def _substringmatcher(pattern):
1589 kind, pattern, matcher = _stringmatcher(pattern)
1589 kind, pattern, matcher = _stringmatcher(pattern)
1590 if kind == 'literal':
1590 if kind == 'literal':
1591 matcher = lambda s: pattern in s
1591 matcher = lambda s: pattern in s
1592 return kind, pattern, matcher
1592 return kind, pattern, matcher
1593
1593
1594 def tag(repo, subset, x):
1594 def tag(repo, subset, x):
1595 """``tag([name])``
1595 """``tag([name])``
1596 The specified tag by name, or all tagged revisions if no name is given.
1596 The specified tag by name, or all tagged revisions if no name is given.
1597
1597
1598 If `name` starts with `re:`, the remainder of the name is treated as
1598 If `name` starts with `re:`, the remainder of the name is treated as
1599 a regular expression. To match a tag that actually starts with `re:`,
1599 a regular expression. To match a tag that actually starts with `re:`,
1600 use the prefix `literal:`.
1600 use the prefix `literal:`.
1601 """
1601 """
1602 # i18n: "tag" is a keyword
1602 # i18n: "tag" is a keyword
1603 args = getargs(x, 0, 1, _("tag takes one or no arguments"))
1603 args = getargs(x, 0, 1, _("tag takes one or no arguments"))
1604 cl = repo.changelog
1604 cl = repo.changelog
1605 if args:
1605 if args:
1606 pattern = getstring(args[0],
1606 pattern = getstring(args[0],
1607 # i18n: "tag" is a keyword
1607 # i18n: "tag" is a keyword
1608 _('the argument to tag must be a string'))
1608 _('the argument to tag must be a string'))
1609 kind, pattern, matcher = _stringmatcher(pattern)
1609 kind, pattern, matcher = _stringmatcher(pattern)
1610 if kind == 'literal':
1610 if kind == 'literal':
1611 # avoid resolving all tags
1611 # avoid resolving all tags
1612 tn = repo._tagscache.tags.get(pattern, None)
1612 tn = repo._tagscache.tags.get(pattern, None)
1613 if tn is None:
1613 if tn is None:
1614 raise util.Abort(_("tag '%s' does not exist") % pattern)
1614 raise util.Abort(_("tag '%s' does not exist") % pattern)
1615 s = set([repo[tn].rev()])
1615 s = set([repo[tn].rev()])
1616 else:
1616 else:
1617 s = set([cl.rev(n) for t, n in repo.tagslist() if matcher(t)])
1617 s = set([cl.rev(n) for t, n in repo.tagslist() if matcher(t)])
1618 else:
1618 else:
1619 s = set([cl.rev(n) for t, n in repo.tagslist() if t != 'tip'])
1619 s = set([cl.rev(n) for t, n in repo.tagslist() if t != 'tip'])
1620 return subset & s
1620 return subset & s
1621
1621
1622 def tagged(repo, subset, x):
1622 def tagged(repo, subset, x):
1623 return tag(repo, subset, x)
1623 return tag(repo, subset, x)
1624
1624
1625 def unstable(repo, subset, x):
1625 def unstable(repo, subset, x):
1626 """``unstable()``
1626 """``unstable()``
1627 Non-obsolete changesets with obsolete ancestors.
1627 Non-obsolete changesets with obsolete ancestors.
1628 """
1628 """
1629 # i18n: "unstable" is a keyword
1629 # i18n: "unstable" is a keyword
1630 getargs(x, 0, 0, _("unstable takes no arguments"))
1630 getargs(x, 0, 0, _("unstable takes no arguments"))
1631 unstables = obsmod.getrevs(repo, 'unstable')
1631 unstables = obsmod.getrevs(repo, 'unstable')
1632 return subset & unstables
1632 return subset & unstables
1633
1633
1634
1634
1635 def user(repo, subset, x):
1635 def user(repo, subset, x):
1636 """``user(string)``
1636 """``user(string)``
1637 User name contains string. The match is case-insensitive.
1637 User name contains string. The match is case-insensitive.
1638
1638
1639 If `string` starts with `re:`, the remainder of the string is treated as
1639 If `string` starts with `re:`, the remainder of the string is treated as
1640 a regular expression. To match a user that actually contains `re:`, use
1640 a regular expression. To match a user that actually contains `re:`, use
1641 the prefix `literal:`.
1641 the prefix `literal:`.
1642 """
1642 """
1643 return author(repo, subset, x)
1643 return author(repo, subset, x)
1644
1644
1645 # for internal use
1645 # for internal use
1646 def _list(repo, subset, x):
1646 def _list(repo, subset, x):
1647 s = getstring(x, "internal error")
1647 s = getstring(x, "internal error")
1648 if not s:
1648 if not s:
1649 return baseset([])
1649 return baseset([])
1650 ls = [repo[r].rev() for r in s.split('\0')]
1650 ls = [repo[r].rev() for r in s.split('\0')]
1651 s = subset.set()
1651 s = subset.set()
1652 return baseset([r for r in ls if r in s])
1652 return baseset([r for r in ls if r in s])
1653
1653
1654 # for internal use
1654 # for internal use
1655 def _intlist(repo, subset, x):
1655 def _intlist(repo, subset, x):
1656 s = getstring(x, "internal error")
1656 s = getstring(x, "internal error")
1657 if not s:
1657 if not s:
1658 return baseset([])
1658 return baseset([])
1659 ls = [int(r) for r in s.split('\0')]
1659 ls = [int(r) for r in s.split('\0')]
1660 s = subset.set()
1660 s = subset.set()
1661 return baseset([r for r in ls if r in s])
1661 return baseset([r for r in ls if r in s])
1662
1662
1663 # for internal use
1663 # for internal use
1664 def _hexlist(repo, subset, x):
1664 def _hexlist(repo, subset, x):
1665 s = getstring(x, "internal error")
1665 s = getstring(x, "internal error")
1666 if not s:
1666 if not s:
1667 return baseset([])
1667 return baseset([])
1668 cl = repo.changelog
1668 cl = repo.changelog
1669 ls = [cl.rev(node.bin(r)) for r in s.split('\0')]
1669 ls = [cl.rev(node.bin(r)) for r in s.split('\0')]
1670 s = subset.set()
1670 s = subset.set()
1671 return baseset([r for r in ls if r in s])
1671 return baseset([r for r in ls if r in s])
1672
1672
1673 symbols = {
1673 symbols = {
1674 "adds": adds,
1674 "adds": adds,
1675 "all": getall,
1675 "all": getall,
1676 "ancestor": ancestor,
1676 "ancestor": ancestor,
1677 "ancestors": ancestors,
1677 "ancestors": ancestors,
1678 "_firstancestors": _firstancestors,
1678 "_firstancestors": _firstancestors,
1679 "author": author,
1679 "author": author,
1680 "only": only,
1680 "only": only,
1681 "bisect": bisect,
1681 "bisect": bisect,
1682 "bisected": bisected,
1682 "bisected": bisected,
1683 "bookmark": bookmark,
1683 "bookmark": bookmark,
1684 "branch": branch,
1684 "branch": branch,
1685 "branchpoint": branchpoint,
1685 "branchpoint": branchpoint,
1686 "bumped": bumped,
1686 "bumped": bumped,
1687 "bundle": bundle,
1687 "bundle": bundle,
1688 "children": children,
1688 "children": children,
1689 "closed": closed,
1689 "closed": closed,
1690 "contains": contains,
1690 "contains": contains,
1691 "converted": converted,
1691 "converted": converted,
1692 "date": date,
1692 "date": date,
1693 "desc": desc,
1693 "desc": desc,
1694 "descendants": descendants,
1694 "descendants": descendants,
1695 "_firstdescendants": _firstdescendants,
1695 "_firstdescendants": _firstdescendants,
1696 "destination": destination,
1696 "destination": destination,
1697 "divergent": divergent,
1697 "divergent": divergent,
1698 "draft": draft,
1698 "draft": draft,
1699 "extinct": extinct,
1699 "extinct": extinct,
1700 "extra": extra,
1700 "extra": extra,
1701 "file": hasfile,
1701 "file": hasfile,
1702 "filelog": filelog,
1702 "filelog": filelog,
1703 "first": first,
1703 "first": first,
1704 "follow": follow,
1704 "follow": follow,
1705 "_followfirst": _followfirst,
1705 "_followfirst": _followfirst,
1706 "grep": grep,
1706 "grep": grep,
1707 "head": head,
1707 "head": head,
1708 "heads": heads,
1708 "heads": heads,
1709 "hidden": hidden,
1709 "hidden": hidden,
1710 "id": node_,
1710 "id": node_,
1711 "keyword": keyword,
1711 "keyword": keyword,
1712 "last": last,
1712 "last": last,
1713 "limit": limit,
1713 "limit": limit,
1714 "_matchfiles": _matchfiles,
1714 "_matchfiles": _matchfiles,
1715 "max": maxrev,
1715 "max": maxrev,
1716 "merge": merge,
1716 "merge": merge,
1717 "min": minrev,
1717 "min": minrev,
1718 "modifies": modifies,
1718 "modifies": modifies,
1719 "obsolete": obsolete,
1719 "obsolete": obsolete,
1720 "origin": origin,
1720 "origin": origin,
1721 "outgoing": outgoing,
1721 "outgoing": outgoing,
1722 "p1": p1,
1722 "p1": p1,
1723 "p2": p2,
1723 "p2": p2,
1724 "parents": parents,
1724 "parents": parents,
1725 "present": present,
1725 "present": present,
1726 "public": public,
1726 "public": public,
1727 "remote": remote,
1727 "remote": remote,
1728 "removes": removes,
1728 "removes": removes,
1729 "rev": rev,
1729 "rev": rev,
1730 "reverse": reverse,
1730 "reverse": reverse,
1731 "roots": roots,
1731 "roots": roots,
1732 "sort": sort,
1732 "sort": sort,
1733 "secret": secret,
1733 "secret": secret,
1734 "matching": matching,
1734 "matching": matching,
1735 "tag": tag,
1735 "tag": tag,
1736 "tagged": tagged,
1736 "tagged": tagged,
1737 "user": user,
1737 "user": user,
1738 "unstable": unstable,
1738 "unstable": unstable,
1739 "_list": _list,
1739 "_list": _list,
1740 "_intlist": _intlist,
1740 "_intlist": _intlist,
1741 "_hexlist": _hexlist,
1741 "_hexlist": _hexlist,
1742 }
1742 }
1743
1743
1744 # symbols which can't be used for a DoS attack for any given input
1744 # symbols which can't be used for a DoS attack for any given input
1745 # (e.g. those which accept regexes as plain strings shouldn't be included)
1745 # (e.g. those which accept regexes as plain strings shouldn't be included)
1746 # functions that just return a lot of changesets (like all) don't count here
1746 # functions that just return a lot of changesets (like all) don't count here
1747 safesymbols = set([
1747 safesymbols = set([
1748 "adds",
1748 "adds",
1749 "all",
1749 "all",
1750 "ancestor",
1750 "ancestor",
1751 "ancestors",
1751 "ancestors",
1752 "_firstancestors",
1752 "_firstancestors",
1753 "author",
1753 "author",
1754 "bisect",
1754 "bisect",
1755 "bisected",
1755 "bisected",
1756 "bookmark",
1756 "bookmark",
1757 "branch",
1757 "branch",
1758 "branchpoint",
1758 "branchpoint",
1759 "bumped",
1759 "bumped",
1760 "bundle",
1760 "bundle",
1761 "children",
1761 "children",
1762 "closed",
1762 "closed",
1763 "converted",
1763 "converted",
1764 "date",
1764 "date",
1765 "desc",
1765 "desc",
1766 "descendants",
1766 "descendants",
1767 "_firstdescendants",
1767 "_firstdescendants",
1768 "destination",
1768 "destination",
1769 "divergent",
1769 "divergent",
1770 "draft",
1770 "draft",
1771 "extinct",
1771 "extinct",
1772 "extra",
1772 "extra",
1773 "file",
1773 "file",
1774 "filelog",
1774 "filelog",
1775 "first",
1775 "first",
1776 "follow",
1776 "follow",
1777 "_followfirst",
1777 "_followfirst",
1778 "head",
1778 "head",
1779 "heads",
1779 "heads",
1780 "hidden",
1780 "hidden",
1781 "id",
1781 "id",
1782 "keyword",
1782 "keyword",
1783 "last",
1783 "last",
1784 "limit",
1784 "limit",
1785 "_matchfiles",
1785 "_matchfiles",
1786 "max",
1786 "max",
1787 "merge",
1787 "merge",
1788 "min",
1788 "min",
1789 "modifies",
1789 "modifies",
1790 "obsolete",
1790 "obsolete",
1791 "origin",
1791 "origin",
1792 "outgoing",
1792 "outgoing",
1793 "p1",
1793 "p1",
1794 "p2",
1794 "p2",
1795 "parents",
1795 "parents",
1796 "present",
1796 "present",
1797 "public",
1797 "public",
1798 "remote",
1798 "remote",
1799 "removes",
1799 "removes",
1800 "rev",
1800 "rev",
1801 "reverse",
1801 "reverse",
1802 "roots",
1802 "roots",
1803 "sort",
1803 "sort",
1804 "secret",
1804 "secret",
1805 "matching",
1805 "matching",
1806 "tag",
1806 "tag",
1807 "tagged",
1807 "tagged",
1808 "user",
1808 "user",
1809 "unstable",
1809 "unstable",
1810 "_list",
1810 "_list",
1811 "_intlist",
1811 "_intlist",
1812 "_hexlist",
1812 "_hexlist",
1813 ])
1813 ])
1814
1814
1815 methods = {
1815 methods = {
1816 "range": rangeset,
1816 "range": rangeset,
1817 "dagrange": dagrange,
1817 "dagrange": dagrange,
1818 "string": stringset,
1818 "string": stringset,
1819 "symbol": symbolset,
1819 "symbol": symbolset,
1820 "and": andset,
1820 "and": andset,
1821 "or": orset,
1821 "or": orset,
1822 "not": notset,
1822 "not": notset,
1823 "list": listset,
1823 "list": listset,
1824 "func": func,
1824 "func": func,
1825 "ancestor": ancestorspec,
1825 "ancestor": ancestorspec,
1826 "parent": parentspec,
1826 "parent": parentspec,
1827 "parentpost": p1,
1827 "parentpost": p1,
1828 }
1828 }
1829
1829
1830 def optimize(x, small):
1830 def optimize(x, small):
1831 if x is None:
1831 if x is None:
1832 return 0, x
1832 return 0, x
1833
1833
1834 smallbonus = 1
1834 smallbonus = 1
1835 if small:
1835 if small:
1836 smallbonus = .5
1836 smallbonus = .5
1837
1837
1838 op = x[0]
1838 op = x[0]
1839 if op == 'minus':
1839 if op == 'minus':
1840 return optimize(('and', x[1], ('not', x[2])), small)
1840 return optimize(('and', x[1], ('not', x[2])), small)
1841 elif op == 'dagrangepre':
1841 elif op == 'dagrangepre':
1842 return optimize(('func', ('symbol', 'ancestors'), x[1]), small)
1842 return optimize(('func', ('symbol', 'ancestors'), x[1]), small)
1843 elif op == 'dagrangepost':
1843 elif op == 'dagrangepost':
1844 return optimize(('func', ('symbol', 'descendants'), x[1]), small)
1844 return optimize(('func', ('symbol', 'descendants'), x[1]), small)
1845 elif op == 'rangepre':
1845 elif op == 'rangepre':
1846 return optimize(('range', ('string', '0'), x[1]), small)
1846 return optimize(('range', ('string', '0'), x[1]), small)
1847 elif op == 'rangepost':
1847 elif op == 'rangepost':
1848 return optimize(('range', x[1], ('string', 'tip')), small)
1848 return optimize(('range', x[1], ('string', 'tip')), small)
1849 elif op == 'negate':
1849 elif op == 'negate':
1850 return optimize(('string',
1850 return optimize(('string',
1851 '-' + getstring(x[1], _("can't negate that"))), small)
1851 '-' + getstring(x[1], _("can't negate that"))), small)
1852 elif op in 'string symbol negate':
1852 elif op in 'string symbol negate':
1853 return smallbonus, x # single revisions are small
1853 return smallbonus, x # single revisions are small
1854 elif op == 'and':
1854 elif op == 'and':
1855 wa, ta = optimize(x[1], True)
1855 wa, ta = optimize(x[1], True)
1856 wb, tb = optimize(x[2], True)
1856 wb, tb = optimize(x[2], True)
1857
1857
1858 # (::x and not ::y)/(not ::y and ::x) have a fast path
1858 # (::x and not ::y)/(not ::y and ::x) have a fast path
1859 def isonly(revs, bases):
1859 def isonly(revs, bases):
1860 return (
1860 return (
1861 revs[0] == 'func'
1861 revs[0] == 'func'
1862 and getstring(revs[1], _('not a symbol')) == 'ancestors'
1862 and getstring(revs[1], _('not a symbol')) == 'ancestors'
1863 and bases[0] == 'not'
1863 and bases[0] == 'not'
1864 and bases[1][0] == 'func'
1864 and bases[1][0] == 'func'
1865 and getstring(bases[1][1], _('not a symbol')) == 'ancestors')
1865 and getstring(bases[1][1], _('not a symbol')) == 'ancestors')
1866
1866
1867 w = min(wa, wb)
1867 w = min(wa, wb)
1868 if isonly(ta, tb):
1868 if isonly(ta, tb):
1869 return w, ('func', ('symbol', 'only'), ('list', ta[2], tb[1][2]))
1869 return w, ('func', ('symbol', 'only'), ('list', ta[2], tb[1][2]))
1870 if isonly(tb, ta):
1870 if isonly(tb, ta):
1871 return w, ('func', ('symbol', 'only'), ('list', tb[2], ta[1][2]))
1871 return w, ('func', ('symbol', 'only'), ('list', tb[2], ta[1][2]))
1872
1872
1873 if wa > wb:
1873 if wa > wb:
1874 return w, (op, tb, ta)
1874 return w, (op, tb, ta)
1875 return w, (op, ta, tb)
1875 return w, (op, ta, tb)
1876 elif op == 'or':
1876 elif op == 'or':
1877 wa, ta = optimize(x[1], False)
1877 wa, ta = optimize(x[1], False)
1878 wb, tb = optimize(x[2], False)
1878 wb, tb = optimize(x[2], False)
1879 if wb < wa:
1879 if wb < wa:
1880 wb, wa = wa, wb
1880 wb, wa = wa, wb
1881 return max(wa, wb), (op, ta, tb)
1881 return max(wa, wb), (op, ta, tb)
1882 elif op == 'not':
1882 elif op == 'not':
1883 o = optimize(x[1], not small)
1883 o = optimize(x[1], not small)
1884 return o[0], (op, o[1])
1884 return o[0], (op, o[1])
1885 elif op == 'parentpost':
1885 elif op == 'parentpost':
1886 o = optimize(x[1], small)
1886 o = optimize(x[1], small)
1887 return o[0], (op, o[1])
1887 return o[0], (op, o[1])
1888 elif op == 'group':
1888 elif op == 'group':
1889 return optimize(x[1], small)
1889 return optimize(x[1], small)
1890 elif op in 'dagrange range list parent ancestorspec':
1890 elif op in 'dagrange range list parent ancestorspec':
1891 if op == 'parent':
1891 if op == 'parent':
1892 # x^:y means (x^) : y, not x ^ (:y)
1892 # x^:y means (x^) : y, not x ^ (:y)
1893 post = ('parentpost', x[1])
1893 post = ('parentpost', x[1])
1894 if x[2][0] == 'dagrangepre':
1894 if x[2][0] == 'dagrangepre':
1895 return optimize(('dagrange', post, x[2][1]), small)
1895 return optimize(('dagrange', post, x[2][1]), small)
1896 elif x[2][0] == 'rangepre':
1896 elif x[2][0] == 'rangepre':
1897 return optimize(('range', post, x[2][1]), small)
1897 return optimize(('range', post, x[2][1]), small)
1898
1898
1899 wa, ta = optimize(x[1], small)
1899 wa, ta = optimize(x[1], small)
1900 wb, tb = optimize(x[2], small)
1900 wb, tb = optimize(x[2], small)
1901 return wa + wb, (op, ta, tb)
1901 return wa + wb, (op, ta, tb)
1902 elif op == 'func':
1902 elif op == 'func':
1903 f = getstring(x[1], _("not a symbol"))
1903 f = getstring(x[1], _("not a symbol"))
1904 wa, ta = optimize(x[2], small)
1904 wa, ta = optimize(x[2], small)
1905 if f in ("author branch closed date desc file grep keyword "
1905 if f in ("author branch closed date desc file grep keyword "
1906 "outgoing user"):
1906 "outgoing user"):
1907 w = 10 # slow
1907 w = 10 # slow
1908 elif f in "modifies adds removes":
1908 elif f in "modifies adds removes":
1909 w = 30 # slower
1909 w = 30 # slower
1910 elif f == "contains":
1910 elif f == "contains":
1911 w = 100 # very slow
1911 w = 100 # very slow
1912 elif f == "ancestor":
1912 elif f == "ancestor":
1913 w = 1 * smallbonus
1913 w = 1 * smallbonus
1914 elif f in "reverse limit first":
1914 elif f in "reverse limit first _intlist":
1915 w = 0
1915 w = 0
1916 elif f in "sort":
1916 elif f in "sort":
1917 w = 10 # assume most sorts look at changelog
1917 w = 10 # assume most sorts look at changelog
1918 else:
1918 else:
1919 w = 1
1919 w = 1
1920 return w + wa, (op, x[1], ta)
1920 return w + wa, (op, x[1], ta)
1921 return 1, x
1921 return 1, x
1922
1922
1923 _aliasarg = ('func', ('symbol', '_aliasarg'))
1923 _aliasarg = ('func', ('symbol', '_aliasarg'))
1924 def _getaliasarg(tree):
1924 def _getaliasarg(tree):
1925 """If tree matches ('func', ('symbol', '_aliasarg'), ('string', X))
1925 """If tree matches ('func', ('symbol', '_aliasarg'), ('string', X))
1926 return X, None otherwise.
1926 return X, None otherwise.
1927 """
1927 """
1928 if (len(tree) == 3 and tree[:2] == _aliasarg
1928 if (len(tree) == 3 and tree[:2] == _aliasarg
1929 and tree[2][0] == 'string'):
1929 and tree[2][0] == 'string'):
1930 return tree[2][1]
1930 return tree[2][1]
1931 return None
1931 return None
1932
1932
1933 def _checkaliasarg(tree, known=None):
1933 def _checkaliasarg(tree, known=None):
1934 """Check tree contains no _aliasarg construct or only ones which
1934 """Check tree contains no _aliasarg construct or only ones which
1935 value is in known. Used to avoid alias placeholders injection.
1935 value is in known. Used to avoid alias placeholders injection.
1936 """
1936 """
1937 if isinstance(tree, tuple):
1937 if isinstance(tree, tuple):
1938 arg = _getaliasarg(tree)
1938 arg = _getaliasarg(tree)
1939 if arg is not None and (not known or arg not in known):
1939 if arg is not None and (not known or arg not in known):
1940 raise error.ParseError(_("not a function: %s") % '_aliasarg')
1940 raise error.ParseError(_("not a function: %s") % '_aliasarg')
1941 for t in tree:
1941 for t in tree:
1942 _checkaliasarg(t, known)
1942 _checkaliasarg(t, known)
1943
1943
1944 class revsetalias(object):
1944 class revsetalias(object):
1945 funcre = re.compile('^([^(]+)\(([^)]+)\)$')
1945 funcre = re.compile('^([^(]+)\(([^)]+)\)$')
1946 args = None
1946 args = None
1947
1947
1948 def __init__(self, name, value):
1948 def __init__(self, name, value):
1949 '''Aliases like:
1949 '''Aliases like:
1950
1950
1951 h = heads(default)
1951 h = heads(default)
1952 b($1) = ancestors($1) - ancestors(default)
1952 b($1) = ancestors($1) - ancestors(default)
1953 '''
1953 '''
1954 m = self.funcre.search(name)
1954 m = self.funcre.search(name)
1955 if m:
1955 if m:
1956 self.name = m.group(1)
1956 self.name = m.group(1)
1957 self.tree = ('func', ('symbol', m.group(1)))
1957 self.tree = ('func', ('symbol', m.group(1)))
1958 self.args = [x.strip() for x in m.group(2).split(',')]
1958 self.args = [x.strip() for x in m.group(2).split(',')]
1959 for arg in self.args:
1959 for arg in self.args:
1960 # _aliasarg() is an unknown symbol only used separate
1960 # _aliasarg() is an unknown symbol only used separate
1961 # alias argument placeholders from regular strings.
1961 # alias argument placeholders from regular strings.
1962 value = value.replace(arg, '_aliasarg(%r)' % (arg,))
1962 value = value.replace(arg, '_aliasarg(%r)' % (arg,))
1963 else:
1963 else:
1964 self.name = name
1964 self.name = name
1965 self.tree = ('symbol', name)
1965 self.tree = ('symbol', name)
1966
1966
1967 self.replacement, pos = parse(value)
1967 self.replacement, pos = parse(value)
1968 if pos != len(value):
1968 if pos != len(value):
1969 raise error.ParseError(_('invalid token'), pos)
1969 raise error.ParseError(_('invalid token'), pos)
1970 # Check for placeholder injection
1970 # Check for placeholder injection
1971 _checkaliasarg(self.replacement, self.args)
1971 _checkaliasarg(self.replacement, self.args)
1972
1972
1973 def _getalias(aliases, tree):
1973 def _getalias(aliases, tree):
1974 """If tree looks like an unexpanded alias, return it. Return None
1974 """If tree looks like an unexpanded alias, return it. Return None
1975 otherwise.
1975 otherwise.
1976 """
1976 """
1977 if isinstance(tree, tuple) and tree:
1977 if isinstance(tree, tuple) and tree:
1978 if tree[0] == 'symbol' and len(tree) == 2:
1978 if tree[0] == 'symbol' and len(tree) == 2:
1979 name = tree[1]
1979 name = tree[1]
1980 alias = aliases.get(name)
1980 alias = aliases.get(name)
1981 if alias and alias.args is None and alias.tree == tree:
1981 if alias and alias.args is None and alias.tree == tree:
1982 return alias
1982 return alias
1983 if tree[0] == 'func' and len(tree) > 1:
1983 if tree[0] == 'func' and len(tree) > 1:
1984 if tree[1][0] == 'symbol' and len(tree[1]) == 2:
1984 if tree[1][0] == 'symbol' and len(tree[1]) == 2:
1985 name = tree[1][1]
1985 name = tree[1][1]
1986 alias = aliases.get(name)
1986 alias = aliases.get(name)
1987 if alias and alias.args is not None and alias.tree == tree[:2]:
1987 if alias and alias.args is not None and alias.tree == tree[:2]:
1988 return alias
1988 return alias
1989 return None
1989 return None
1990
1990
1991 def _expandargs(tree, args):
1991 def _expandargs(tree, args):
1992 """Replace _aliasarg instances with the substitution value of the
1992 """Replace _aliasarg instances with the substitution value of the
1993 same name in args, recursively.
1993 same name in args, recursively.
1994 """
1994 """
1995 if not tree or not isinstance(tree, tuple):
1995 if not tree or not isinstance(tree, tuple):
1996 return tree
1996 return tree
1997 arg = _getaliasarg(tree)
1997 arg = _getaliasarg(tree)
1998 if arg is not None:
1998 if arg is not None:
1999 return args[arg]
1999 return args[arg]
2000 return tuple(_expandargs(t, args) for t in tree)
2000 return tuple(_expandargs(t, args) for t in tree)
2001
2001
2002 def _expandaliases(aliases, tree, expanding, cache):
2002 def _expandaliases(aliases, tree, expanding, cache):
2003 """Expand aliases in tree, recursively.
2003 """Expand aliases in tree, recursively.
2004
2004
2005 'aliases' is a dictionary mapping user defined aliases to
2005 'aliases' is a dictionary mapping user defined aliases to
2006 revsetalias objects.
2006 revsetalias objects.
2007 """
2007 """
2008 if not isinstance(tree, tuple):
2008 if not isinstance(tree, tuple):
2009 # Do not expand raw strings
2009 # Do not expand raw strings
2010 return tree
2010 return tree
2011 alias = _getalias(aliases, tree)
2011 alias = _getalias(aliases, tree)
2012 if alias is not None:
2012 if alias is not None:
2013 if alias in expanding:
2013 if alias in expanding:
2014 raise error.ParseError(_('infinite expansion of revset alias "%s" '
2014 raise error.ParseError(_('infinite expansion of revset alias "%s" '
2015 'detected') % alias.name)
2015 'detected') % alias.name)
2016 expanding.append(alias)
2016 expanding.append(alias)
2017 if alias.name not in cache:
2017 if alias.name not in cache:
2018 cache[alias.name] = _expandaliases(aliases, alias.replacement,
2018 cache[alias.name] = _expandaliases(aliases, alias.replacement,
2019 expanding, cache)
2019 expanding, cache)
2020 result = cache[alias.name]
2020 result = cache[alias.name]
2021 expanding.pop()
2021 expanding.pop()
2022 if alias.args is not None:
2022 if alias.args is not None:
2023 l = getlist(tree[2])
2023 l = getlist(tree[2])
2024 if len(l) != len(alias.args):
2024 if len(l) != len(alias.args):
2025 raise error.ParseError(
2025 raise error.ParseError(
2026 _('invalid number of arguments: %s') % len(l))
2026 _('invalid number of arguments: %s') % len(l))
2027 l = [_expandaliases(aliases, a, [], cache) for a in l]
2027 l = [_expandaliases(aliases, a, [], cache) for a in l]
2028 result = _expandargs(result, dict(zip(alias.args, l)))
2028 result = _expandargs(result, dict(zip(alias.args, l)))
2029 else:
2029 else:
2030 result = tuple(_expandaliases(aliases, t, expanding, cache)
2030 result = tuple(_expandaliases(aliases, t, expanding, cache)
2031 for t in tree)
2031 for t in tree)
2032 return result
2032 return result
2033
2033
2034 def findaliases(ui, tree):
2034 def findaliases(ui, tree):
2035 _checkaliasarg(tree)
2035 _checkaliasarg(tree)
2036 aliases = {}
2036 aliases = {}
2037 for k, v in ui.configitems('revsetalias'):
2037 for k, v in ui.configitems('revsetalias'):
2038 alias = revsetalias(k, v)
2038 alias = revsetalias(k, v)
2039 aliases[alias.name] = alias
2039 aliases[alias.name] = alias
2040 return _expandaliases(aliases, tree, [], {})
2040 return _expandaliases(aliases, tree, [], {})
2041
2041
2042 def parse(spec, lookup=None):
2042 def parse(spec, lookup=None):
2043 p = parser.parser(tokenize, elements)
2043 p = parser.parser(tokenize, elements)
2044 return p.parse(spec, lookup=lookup)
2044 return p.parse(spec, lookup=lookup)
2045
2045
2046 def match(ui, spec, repo=None):
2046 def match(ui, spec, repo=None):
2047 if not spec:
2047 if not spec:
2048 raise error.ParseError(_("empty query"))
2048 raise error.ParseError(_("empty query"))
2049 lookup = None
2049 lookup = None
2050 if repo:
2050 if repo:
2051 lookup = repo.__contains__
2051 lookup = repo.__contains__
2052 tree, pos = parse(spec, lookup)
2052 tree, pos = parse(spec, lookup)
2053 if (pos != len(spec)):
2053 if (pos != len(spec)):
2054 raise error.ParseError(_("invalid token"), pos)
2054 raise error.ParseError(_("invalid token"), pos)
2055 if ui:
2055 if ui:
2056 tree = findaliases(ui, tree)
2056 tree = findaliases(ui, tree)
2057 weight, tree = optimize(tree, True)
2057 weight, tree = optimize(tree, True)
2058 def mfunc(repo, subset):
2058 def mfunc(repo, subset):
2059 if util.safehasattr(subset, 'set'):
2059 if util.safehasattr(subset, 'set'):
2060 return getset(repo, subset, tree)
2060 return getset(repo, subset, tree)
2061 return getset(repo, baseset(subset), tree)
2061 return getset(repo, baseset(subset), tree)
2062 return mfunc
2062 return mfunc
2063
2063
2064 def formatspec(expr, *args):
2064 def formatspec(expr, *args):
2065 '''
2065 '''
2066 This is a convenience function for using revsets internally, and
2066 This is a convenience function for using revsets internally, and
2067 escapes arguments appropriately. Aliases are intentionally ignored
2067 escapes arguments appropriately. Aliases are intentionally ignored
2068 so that intended expression behavior isn't accidentally subverted.
2068 so that intended expression behavior isn't accidentally subverted.
2069
2069
2070 Supported arguments:
2070 Supported arguments:
2071
2071
2072 %r = revset expression, parenthesized
2072 %r = revset expression, parenthesized
2073 %d = int(arg), no quoting
2073 %d = int(arg), no quoting
2074 %s = string(arg), escaped and single-quoted
2074 %s = string(arg), escaped and single-quoted
2075 %b = arg.branch(), escaped and single-quoted
2075 %b = arg.branch(), escaped and single-quoted
2076 %n = hex(arg), single-quoted
2076 %n = hex(arg), single-quoted
2077 %% = a literal '%'
2077 %% = a literal '%'
2078
2078
2079 Prefixing the type with 'l' specifies a parenthesized list of that type.
2079 Prefixing the type with 'l' specifies a parenthesized list of that type.
2080
2080
2081 >>> formatspec('%r:: and %lr', '10 or 11', ("this()", "that()"))
2081 >>> formatspec('%r:: and %lr', '10 or 11', ("this()", "that()"))
2082 '(10 or 11):: and ((this()) or (that()))'
2082 '(10 or 11):: and ((this()) or (that()))'
2083 >>> formatspec('%d:: and not %d::', 10, 20)
2083 >>> formatspec('%d:: and not %d::', 10, 20)
2084 '10:: and not 20::'
2084 '10:: and not 20::'
2085 >>> formatspec('%ld or %ld', [], [1])
2085 >>> formatspec('%ld or %ld', [], [1])
2086 "_list('') or 1"
2086 "_list('') or 1"
2087 >>> formatspec('keyword(%s)', 'foo\\xe9')
2087 >>> formatspec('keyword(%s)', 'foo\\xe9')
2088 "keyword('foo\\\\xe9')"
2088 "keyword('foo\\\\xe9')"
2089 >>> b = lambda: 'default'
2089 >>> b = lambda: 'default'
2090 >>> b.branch = b
2090 >>> b.branch = b
2091 >>> formatspec('branch(%b)', b)
2091 >>> formatspec('branch(%b)', b)
2092 "branch('default')"
2092 "branch('default')"
2093 >>> formatspec('root(%ls)', ['a', 'b', 'c', 'd'])
2093 >>> formatspec('root(%ls)', ['a', 'b', 'c', 'd'])
2094 "root(_list('a\\x00b\\x00c\\x00d'))"
2094 "root(_list('a\\x00b\\x00c\\x00d'))"
2095 '''
2095 '''
2096
2096
2097 def quote(s):
2097 def quote(s):
2098 return repr(str(s))
2098 return repr(str(s))
2099
2099
2100 def argtype(c, arg):
2100 def argtype(c, arg):
2101 if c == 'd':
2101 if c == 'd':
2102 return str(int(arg))
2102 return str(int(arg))
2103 elif c == 's':
2103 elif c == 's':
2104 return quote(arg)
2104 return quote(arg)
2105 elif c == 'r':
2105 elif c == 'r':
2106 parse(arg) # make sure syntax errors are confined
2106 parse(arg) # make sure syntax errors are confined
2107 return '(%s)' % arg
2107 return '(%s)' % arg
2108 elif c == 'n':
2108 elif c == 'n':
2109 return quote(node.hex(arg))
2109 return quote(node.hex(arg))
2110 elif c == 'b':
2110 elif c == 'b':
2111 return quote(arg.branch())
2111 return quote(arg.branch())
2112
2112
2113 def listexp(s, t):
2113 def listexp(s, t):
2114 l = len(s)
2114 l = len(s)
2115 if l == 0:
2115 if l == 0:
2116 return "_list('')"
2116 return "_list('')"
2117 elif l == 1:
2117 elif l == 1:
2118 return argtype(t, s[0])
2118 return argtype(t, s[0])
2119 elif t == 'd':
2119 elif t == 'd':
2120 return "_intlist('%s')" % "\0".join(str(int(a)) for a in s)
2120 return "_intlist('%s')" % "\0".join(str(int(a)) for a in s)
2121 elif t == 's':
2121 elif t == 's':
2122 return "_list('%s')" % "\0".join(s)
2122 return "_list('%s')" % "\0".join(s)
2123 elif t == 'n':
2123 elif t == 'n':
2124 return "_hexlist('%s')" % "\0".join(node.hex(a) for a in s)
2124 return "_hexlist('%s')" % "\0".join(node.hex(a) for a in s)
2125 elif t == 'b':
2125 elif t == 'b':
2126 return "_list('%s')" % "\0".join(a.branch() for a in s)
2126 return "_list('%s')" % "\0".join(a.branch() for a in s)
2127
2127
2128 m = l // 2
2128 m = l // 2
2129 return '(%s or %s)' % (listexp(s[:m], t), listexp(s[m:], t))
2129 return '(%s or %s)' % (listexp(s[:m], t), listexp(s[m:], t))
2130
2130
2131 ret = ''
2131 ret = ''
2132 pos = 0
2132 pos = 0
2133 arg = 0
2133 arg = 0
2134 while pos < len(expr):
2134 while pos < len(expr):
2135 c = expr[pos]
2135 c = expr[pos]
2136 if c == '%':
2136 if c == '%':
2137 pos += 1
2137 pos += 1
2138 d = expr[pos]
2138 d = expr[pos]
2139 if d == '%':
2139 if d == '%':
2140 ret += d
2140 ret += d
2141 elif d in 'dsnbr':
2141 elif d in 'dsnbr':
2142 ret += argtype(d, args[arg])
2142 ret += argtype(d, args[arg])
2143 arg += 1
2143 arg += 1
2144 elif d == 'l':
2144 elif d == 'l':
2145 # a list of some type
2145 # a list of some type
2146 pos += 1
2146 pos += 1
2147 d = expr[pos]
2147 d = expr[pos]
2148 ret += listexp(list(args[arg]), d)
2148 ret += listexp(list(args[arg]), d)
2149 arg += 1
2149 arg += 1
2150 else:
2150 else:
2151 raise util.Abort('unexpected revspec format character %s' % d)
2151 raise util.Abort('unexpected revspec format character %s' % d)
2152 else:
2152 else:
2153 ret += c
2153 ret += c
2154 pos += 1
2154 pos += 1
2155
2155
2156 return ret
2156 return ret
2157
2157
2158 def prettyformat(tree):
2158 def prettyformat(tree):
2159 def _prettyformat(tree, level, lines):
2159 def _prettyformat(tree, level, lines):
2160 if not isinstance(tree, tuple) or tree[0] in ('string', 'symbol'):
2160 if not isinstance(tree, tuple) or tree[0] in ('string', 'symbol'):
2161 lines.append((level, str(tree)))
2161 lines.append((level, str(tree)))
2162 else:
2162 else:
2163 lines.append((level, '(%s' % tree[0]))
2163 lines.append((level, '(%s' % tree[0]))
2164 for s in tree[1:]:
2164 for s in tree[1:]:
2165 _prettyformat(s, level + 1, lines)
2165 _prettyformat(s, level + 1, lines)
2166 lines[-1:] = [(lines[-1][0], lines[-1][1] + ')')]
2166 lines[-1:] = [(lines[-1][0], lines[-1][1] + ')')]
2167
2167
2168 lines = []
2168 lines = []
2169 _prettyformat(tree, 0, lines)
2169 _prettyformat(tree, 0, lines)
2170 output = '\n'.join((' '*l + s) for l, s in lines)
2170 output = '\n'.join((' '*l + s) for l, s in lines)
2171 return output
2171 return output
2172
2172
2173 def depth(tree):
2173 def depth(tree):
2174 if isinstance(tree, tuple):
2174 if isinstance(tree, tuple):
2175 return max(map(depth, tree)) + 1
2175 return max(map(depth, tree)) + 1
2176 else:
2176 else:
2177 return 0
2177 return 0
2178
2178
2179 def funcsused(tree):
2179 def funcsused(tree):
2180 if not isinstance(tree, tuple) or tree[0] in ('string', 'symbol'):
2180 if not isinstance(tree, tuple) or tree[0] in ('string', 'symbol'):
2181 return set()
2181 return set()
2182 else:
2182 else:
2183 funcs = set()
2183 funcs = set()
2184 for s in tree[1:]:
2184 for s in tree[1:]:
2185 funcs |= funcsused(s)
2185 funcs |= funcsused(s)
2186 if tree[0] == 'func':
2186 if tree[0] == 'func':
2187 funcs.add(tree[1][1])
2187 funcs.add(tree[1][1])
2188 return funcs
2188 return funcs
2189
2189
2190 class baseset(list):
2190 class baseset(list):
2191 """Basic data structure that represents a revset and contains the basic
2191 """Basic data structure that represents a revset and contains the basic
2192 operation that it should be able to perform.
2192 operation that it should be able to perform.
2193
2193
2194 Every method in this class should be implemented by any smartset class.
2194 Every method in this class should be implemented by any smartset class.
2195 """
2195 """
2196 def __init__(self, data=()):
2196 def __init__(self, data=()):
2197 super(baseset, self).__init__(data)
2197 super(baseset, self).__init__(data)
2198 self._set = None
2198 self._set = None
2199
2199
2200 def ascending(self):
2200 def ascending(self):
2201 """Sorts the set in ascending order (in place).
2201 """Sorts the set in ascending order (in place).
2202
2202
2203 This is part of the mandatory API for smartset."""
2203 This is part of the mandatory API for smartset."""
2204 self.sort()
2204 self.sort()
2205
2205
2206 def descending(self):
2206 def descending(self):
2207 """Sorts the set in descending order (in place).
2207 """Sorts the set in descending order (in place).
2208
2208
2209 This is part of the mandatory API for smartset."""
2209 This is part of the mandatory API for smartset."""
2210 self.sort(reverse=True)
2210 self.sort(reverse=True)
2211
2211
2212 def min(self):
2212 def min(self):
2213 return min(self)
2213 return min(self)
2214
2214
2215 def max(self):
2215 def max(self):
2216 return max(self)
2216 return max(self)
2217
2217
2218 def set(self):
2218 def set(self):
2219 """Returns a set or a smartset containing all the elements.
2219 """Returns a set or a smartset containing all the elements.
2220
2220
2221 The returned structure should be the fastest option for membership
2221 The returned structure should be the fastest option for membership
2222 testing.
2222 testing.
2223
2223
2224 This is part of the mandatory API for smartset."""
2224 This is part of the mandatory API for smartset."""
2225 if not self._set:
2225 if not self._set:
2226 self._set = set(self)
2226 self._set = set(self)
2227 return self._set
2227 return self._set
2228
2228
2229 def __sub__(self, other):
2229 def __sub__(self, other):
2230 """Returns a new object with the substraction of the two collections.
2230 """Returns a new object with the substraction of the two collections.
2231
2231
2232 This is part of the mandatory API for smartset."""
2232 This is part of the mandatory API for smartset."""
2233 # If we are operating on 2 baseset, do the computation now since all
2233 # If we are operating on 2 baseset, do the computation now since all
2234 # data is available. The alternative is to involve a lazyset, which
2234 # data is available. The alternative is to involve a lazyset, which
2235 # may be slow.
2235 # may be slow.
2236 if isinstance(other, baseset):
2236 if isinstance(other, baseset):
2237 other = other.set()
2237 other = other.set()
2238 return baseset([x for x in self if x not in other])
2238 return baseset([x for x in self if x not in other])
2239
2239
2240 return self.filter(lambda x: x not in other)
2240 return self.filter(lambda x: x not in other)
2241
2241
2242 def __and__(self, other):
2242 def __and__(self, other):
2243 """Returns a new object with the intersection of the two collections.
2243 """Returns a new object with the intersection of the two collections.
2244
2244
2245 This is part of the mandatory API for smartset."""
2245 This is part of the mandatory API for smartset."""
2246 if isinstance(other, baseset):
2246 if isinstance(other, baseset):
2247 other = other.set()
2247 other = other.set()
2248 return baseset([y for y in self if y in other])
2248 return baseset([y for y in self if y in other])
2249
2249
2250 def __add__(self, other):
2250 def __add__(self, other):
2251 """Returns a new object with the union of the two collections.
2251 """Returns a new object with the union of the two collections.
2252
2252
2253 This is part of the mandatory API for smartset."""
2253 This is part of the mandatory API for smartset."""
2254 s = self.set()
2254 s = self.set()
2255 l = [r for r in other if r not in s]
2255 l = [r for r in other if r not in s]
2256 return baseset(list(self) + l)
2256 return baseset(list(self) + l)
2257
2257
2258 def isascending(self):
2258 def isascending(self):
2259 """Returns True if the collection is ascending order, False if not.
2259 """Returns True if the collection is ascending order, False if not.
2260
2260
2261 This is part of the mandatory API for smartset."""
2261 This is part of the mandatory API for smartset."""
2262 return False
2262 return False
2263
2263
2264 def isdescending(self):
2264 def isdescending(self):
2265 """Returns True if the collection is descending order, False if not.
2265 """Returns True if the collection is descending order, False if not.
2266
2266
2267 This is part of the mandatory API for smartset."""
2267 This is part of the mandatory API for smartset."""
2268 return False
2268 return False
2269
2269
2270 def filter(self, condition):
2270 def filter(self, condition):
2271 """Returns this smartset filtered by condition as a new smartset.
2271 """Returns this smartset filtered by condition as a new smartset.
2272
2272
2273 `condition` is a callable which takes a revision number and returns a
2273 `condition` is a callable which takes a revision number and returns a
2274 boolean.
2274 boolean.
2275
2275
2276 This is part of the mandatory API for smartset."""
2276 This is part of the mandatory API for smartset."""
2277 return lazyset(self, condition)
2277 return lazyset(self, condition)
2278
2278
2279 class _orderedsetmixin(object):
2279 class _orderedsetmixin(object):
2280 """Mixin class with utility methods for smartsets
2280 """Mixin class with utility methods for smartsets
2281
2281
2282 This should be extended by smartsets which have the isascending(),
2282 This should be extended by smartsets which have the isascending(),
2283 isdescending() and reverse() methods"""
2283 isdescending() and reverse() methods"""
2284
2284
2285 def _first(self):
2285 def _first(self):
2286 """return the first revision in the set"""
2286 """return the first revision in the set"""
2287 for r in self:
2287 for r in self:
2288 return r
2288 return r
2289 raise ValueError('arg is an empty sequence')
2289 raise ValueError('arg is an empty sequence')
2290
2290
2291 def _last(self):
2291 def _last(self):
2292 """return the last revision in the set"""
2292 """return the last revision in the set"""
2293 self.reverse()
2293 self.reverse()
2294 m = self._first()
2294 m = self._first()
2295 self.reverse()
2295 self.reverse()
2296 return m
2296 return m
2297
2297
2298 def min(self):
2298 def min(self):
2299 """return the smallest element in the set"""
2299 """return the smallest element in the set"""
2300 if self.isascending():
2300 if self.isascending():
2301 return self._first()
2301 return self._first()
2302 return self._last()
2302 return self._last()
2303
2303
2304 def max(self):
2304 def max(self):
2305 """return the largest element in the set"""
2305 """return the largest element in the set"""
2306 if self.isascending():
2306 if self.isascending():
2307 return self._last()
2307 return self._last()
2308 return self._first()
2308 return self._first()
2309
2309
2310 class lazyset(object):
2310 class lazyset(object):
2311 """Duck type for baseset class which iterates lazily over the revisions in
2311 """Duck type for baseset class which iterates lazily over the revisions in
2312 the subset and contains a function which tests for membership in the
2312 the subset and contains a function which tests for membership in the
2313 revset
2313 revset
2314 """
2314 """
2315 def __init__(self, subset, condition=lambda x: True):
2315 def __init__(self, subset, condition=lambda x: True):
2316 """
2316 """
2317 condition: a function that decide whether a revision in the subset
2317 condition: a function that decide whether a revision in the subset
2318 belongs to the revset or not.
2318 belongs to the revset or not.
2319 """
2319 """
2320 self._subset = subset
2320 self._subset = subset
2321 self._condition = condition
2321 self._condition = condition
2322 self._cache = {}
2322 self._cache = {}
2323
2323
2324 def ascending(self):
2324 def ascending(self):
2325 self._subset.sort()
2325 self._subset.sort()
2326
2326
2327 def descending(self):
2327 def descending(self):
2328 self._subset.sort(reverse=True)
2328 self._subset.sort(reverse=True)
2329
2329
2330 def min(self):
2330 def min(self):
2331 return min(self)
2331 return min(self)
2332
2332
2333 def max(self):
2333 def max(self):
2334 return max(self)
2334 return max(self)
2335
2335
2336 def __contains__(self, x):
2336 def __contains__(self, x):
2337 c = self._cache
2337 c = self._cache
2338 if x not in c:
2338 if x not in c:
2339 c[x] = x in self._subset and self._condition(x)
2339 c[x] = x in self._subset and self._condition(x)
2340 return c[x]
2340 return c[x]
2341
2341
2342 def __iter__(self):
2342 def __iter__(self):
2343 cond = self._condition
2343 cond = self._condition
2344 for x in self._subset:
2344 for x in self._subset:
2345 if cond(x):
2345 if cond(x):
2346 yield x
2346 yield x
2347
2347
2348 def __and__(self, x):
2348 def __and__(self, x):
2349 return lazyset(self, x.__contains__)
2349 return lazyset(self, x.__contains__)
2350
2350
2351 def __sub__(self, x):
2351 def __sub__(self, x):
2352 return lazyset(self, lambda r: r not in x)
2352 return lazyset(self, lambda r: r not in x)
2353
2353
2354 def __add__(self, x):
2354 def __add__(self, x):
2355 return _addset(self, x)
2355 return _addset(self, x)
2356
2356
2357 def __nonzero__(self):
2357 def __nonzero__(self):
2358 for r in self:
2358 for r in self:
2359 return True
2359 return True
2360 return False
2360 return False
2361
2361
2362 def __len__(self):
2362 def __len__(self):
2363 # Basic implementation to be changed in future patches.
2363 # Basic implementation to be changed in future patches.
2364 l = baseset([r for r in self])
2364 l = baseset([r for r in self])
2365 return len(l)
2365 return len(l)
2366
2366
2367 def __getitem__(self, x):
2367 def __getitem__(self, x):
2368 # Basic implementation to be changed in future patches.
2368 # Basic implementation to be changed in future patches.
2369 l = baseset([r for r in self])
2369 l = baseset([r for r in self])
2370 return l[x]
2370 return l[x]
2371
2371
2372 def sort(self, reverse=False):
2372 def sort(self, reverse=False):
2373 if not util.safehasattr(self._subset, 'sort'):
2373 if not util.safehasattr(self._subset, 'sort'):
2374 self._subset = baseset(self._subset)
2374 self._subset = baseset(self._subset)
2375 self._subset.sort(reverse=reverse)
2375 self._subset.sort(reverse=reverse)
2376
2376
2377 def reverse(self):
2377 def reverse(self):
2378 self._subset.reverse()
2378 self._subset.reverse()
2379
2379
2380 def set(self):
2380 def set(self):
2381 return set([r for r in self])
2381 return set([r for r in self])
2382
2382
2383 def isascending(self):
2383 def isascending(self):
2384 return False
2384 return False
2385
2385
2386 def isdescending(self):
2386 def isdescending(self):
2387 return False
2387 return False
2388
2388
2389 def filter(self, l):
2389 def filter(self, l):
2390 return lazyset(self, l)
2390 return lazyset(self, l)
2391
2391
2392 class orderedlazyset(_orderedsetmixin, lazyset):
2392 class orderedlazyset(_orderedsetmixin, lazyset):
2393 """Subclass of lazyset which subset can be ordered either ascending or
2393 """Subclass of lazyset which subset can be ordered either ascending or
2394 descendingly
2394 descendingly
2395 """
2395 """
2396 def __init__(self, subset, condition, ascending=True):
2396 def __init__(self, subset, condition, ascending=True):
2397 super(orderedlazyset, self).__init__(subset, condition)
2397 super(orderedlazyset, self).__init__(subset, condition)
2398 self._ascending = ascending
2398 self._ascending = ascending
2399
2399
2400 def filter(self, l):
2400 def filter(self, l):
2401 return orderedlazyset(self, l, ascending=self._ascending)
2401 return orderedlazyset(self, l, ascending=self._ascending)
2402
2402
2403 def ascending(self):
2403 def ascending(self):
2404 if not self._ascending:
2404 if not self._ascending:
2405 self.reverse()
2405 self.reverse()
2406
2406
2407 def descending(self):
2407 def descending(self):
2408 if self._ascending:
2408 if self._ascending:
2409 self.reverse()
2409 self.reverse()
2410
2410
2411 def __and__(self, x):
2411 def __and__(self, x):
2412 return orderedlazyset(self, x.__contains__,
2412 return orderedlazyset(self, x.__contains__,
2413 ascending=self._ascending)
2413 ascending=self._ascending)
2414
2414
2415 def __sub__(self, x):
2415 def __sub__(self, x):
2416 return orderedlazyset(self, lambda r: r not in x,
2416 return orderedlazyset(self, lambda r: r not in x,
2417 ascending=self._ascending)
2417 ascending=self._ascending)
2418
2418
2419 def __add__(self, x):
2419 def __add__(self, x):
2420 kwargs = {}
2420 kwargs = {}
2421 if self.isascending() and x.isascending():
2421 if self.isascending() and x.isascending():
2422 kwargs['ascending'] = True
2422 kwargs['ascending'] = True
2423 if self.isdescending() and x.isdescending():
2423 if self.isdescending() and x.isdescending():
2424 kwargs['ascending'] = False
2424 kwargs['ascending'] = False
2425 return _addset(self, x, **kwargs)
2425 return _addset(self, x, **kwargs)
2426
2426
2427 def sort(self, reverse=False):
2427 def sort(self, reverse=False):
2428 if reverse:
2428 if reverse:
2429 if self._ascending:
2429 if self._ascending:
2430 self._subset.sort(reverse=reverse)
2430 self._subset.sort(reverse=reverse)
2431 else:
2431 else:
2432 if not self._ascending:
2432 if not self._ascending:
2433 self._subset.sort(reverse=reverse)
2433 self._subset.sort(reverse=reverse)
2434 self._ascending = not reverse
2434 self._ascending = not reverse
2435
2435
2436 def isascending(self):
2436 def isascending(self):
2437 return self._ascending
2437 return self._ascending
2438
2438
2439 def isdescending(self):
2439 def isdescending(self):
2440 return not self._ascending
2440 return not self._ascending
2441
2441
2442 def reverse(self):
2442 def reverse(self):
2443 self._subset.reverse()
2443 self._subset.reverse()
2444 self._ascending = not self._ascending
2444 self._ascending = not self._ascending
2445
2445
2446 class _addset(_orderedsetmixin):
2446 class _addset(_orderedsetmixin):
2447 """Represent the addition of two sets
2447 """Represent the addition of two sets
2448
2448
2449 Wrapper structure for lazily adding two structures without losing much
2449 Wrapper structure for lazily adding two structures without losing much
2450 performance on the __contains__ method
2450 performance on the __contains__ method
2451
2451
2452 If the ascending attribute is set, that means the two structures are
2452 If the ascending attribute is set, that means the two structures are
2453 ordered in either an ascending or descending way. Therefore, we can add
2453 ordered in either an ascending or descending way. Therefore, we can add
2454 them maintaining the order by iterating over both at the same time
2454 them maintaining the order by iterating over both at the same time
2455
2455
2456 This class does not duck-type baseset and it's only supposed to be used
2456 This class does not duck-type baseset and it's only supposed to be used
2457 internally
2457 internally
2458 """
2458 """
2459 def __init__(self, revs1, revs2, ascending=None):
2459 def __init__(self, revs1, revs2, ascending=None):
2460 self._r1 = revs1
2460 self._r1 = revs1
2461 self._r2 = revs2
2461 self._r2 = revs2
2462 self._iter = None
2462 self._iter = None
2463 self._ascending = ascending
2463 self._ascending = ascending
2464 self._genlist = None
2464 self._genlist = None
2465
2465
2466 def __len__(self):
2466 def __len__(self):
2467 return len(self._list)
2467 return len(self._list)
2468
2468
2469 @util.propertycache
2469 @util.propertycache
2470 def _list(self):
2470 def _list(self):
2471 if not self._genlist:
2471 if not self._genlist:
2472 self._genlist = baseset(self._iterator())
2472 self._genlist = baseset(self._iterator())
2473 return self._genlist
2473 return self._genlist
2474
2474
2475 def filter(self, condition):
2475 def filter(self, condition):
2476 if self._ascending is not None:
2476 if self._ascending is not None:
2477 return orderedlazyset(self, condition, ascending=self._ascending)
2477 return orderedlazyset(self, condition, ascending=self._ascending)
2478 return lazyset(self, condition)
2478 return lazyset(self, condition)
2479
2479
2480 def ascending(self):
2480 def ascending(self):
2481 if self._ascending is None:
2481 if self._ascending is None:
2482 self.sort()
2482 self.sort()
2483 self._ascending = True
2483 self._ascending = True
2484 else:
2484 else:
2485 if not self._ascending:
2485 if not self._ascending:
2486 self.reverse()
2486 self.reverse()
2487
2487
2488 def descending(self):
2488 def descending(self):
2489 if self._ascending is None:
2489 if self._ascending is None:
2490 self.sort(reverse=True)
2490 self.sort(reverse=True)
2491 self._ascending = False
2491 self._ascending = False
2492 else:
2492 else:
2493 if self._ascending:
2493 if self._ascending:
2494 self.reverse()
2494 self.reverse()
2495
2495
2496 def __and__(self, other):
2496 def __and__(self, other):
2497 filterfunc = other.__contains__
2497 filterfunc = other.__contains__
2498 if self._ascending is not None:
2498 if self._ascending is not None:
2499 return orderedlazyset(self, filterfunc, ascending=self._ascending)
2499 return orderedlazyset(self, filterfunc, ascending=self._ascending)
2500 return lazyset(self, filterfunc)
2500 return lazyset(self, filterfunc)
2501
2501
2502 def __sub__(self, other):
2502 def __sub__(self, other):
2503 filterfunc = lambda r: r not in other
2503 filterfunc = lambda r: r not in other
2504 if self._ascending is not None:
2504 if self._ascending is not None:
2505 return orderedlazyset(self, filterfunc, ascending=self._ascending)
2505 return orderedlazyset(self, filterfunc, ascending=self._ascending)
2506 return lazyset(self, filterfunc)
2506 return lazyset(self, filterfunc)
2507
2507
2508 def __add__(self, other):
2508 def __add__(self, other):
2509 """When both collections are ascending or descending, preserve the order
2509 """When both collections are ascending or descending, preserve the order
2510 """
2510 """
2511 kwargs = {}
2511 kwargs = {}
2512 if self._ascending is not None:
2512 if self._ascending is not None:
2513 if self.isascending() and other.isascending():
2513 if self.isascending() and other.isascending():
2514 kwargs['ascending'] = True
2514 kwargs['ascending'] = True
2515 if self.isdescending() and other.isdescending():
2515 if self.isdescending() and other.isdescending():
2516 kwargs['ascending'] = False
2516 kwargs['ascending'] = False
2517 return _addset(self, other, **kwargs)
2517 return _addset(self, other, **kwargs)
2518
2518
2519 def _iterator(self):
2519 def _iterator(self):
2520 """Iterate over both collections without repeating elements
2520 """Iterate over both collections without repeating elements
2521
2521
2522 If the ascending attribute is not set, iterate over the first one and
2522 If the ascending attribute is not set, iterate over the first one and
2523 then over the second one checking for membership on the first one so we
2523 then over the second one checking for membership on the first one so we
2524 dont yield any duplicates.
2524 dont yield any duplicates.
2525
2525
2526 If the ascending attribute is set, iterate over both collections at the
2526 If the ascending attribute is set, iterate over both collections at the
2527 same time, yielding only one value at a time in the given order.
2527 same time, yielding only one value at a time in the given order.
2528 """
2528 """
2529 if not self._iter:
2529 if not self._iter:
2530 def gen():
2530 def gen():
2531 if self._ascending is None:
2531 if self._ascending is None:
2532 for r in self._r1:
2532 for r in self._r1:
2533 yield r
2533 yield r
2534 s = self._r1.set()
2534 s = self._r1.set()
2535 for r in self._r2:
2535 for r in self._r2:
2536 if r not in s:
2536 if r not in s:
2537 yield r
2537 yield r
2538 else:
2538 else:
2539 iter1 = iter(self._r1)
2539 iter1 = iter(self._r1)
2540 iter2 = iter(self._r2)
2540 iter2 = iter(self._r2)
2541
2541
2542 val1 = None
2542 val1 = None
2543 val2 = None
2543 val2 = None
2544
2544
2545 choice = max
2545 choice = max
2546 if self._ascending:
2546 if self._ascending:
2547 choice = min
2547 choice = min
2548 try:
2548 try:
2549 # Consume both iterators in an ordered way until one is
2549 # Consume both iterators in an ordered way until one is
2550 # empty
2550 # empty
2551 while True:
2551 while True:
2552 if val1 is None:
2552 if val1 is None:
2553 val1 = iter1.next()
2553 val1 = iter1.next()
2554 if val2 is None:
2554 if val2 is None:
2555 val2 = iter2.next()
2555 val2 = iter2.next()
2556 next = choice(val1, val2)
2556 next = choice(val1, val2)
2557 yield next
2557 yield next
2558 if val1 == next:
2558 if val1 == next:
2559 val1 = None
2559 val1 = None
2560 if val2 == next:
2560 if val2 == next:
2561 val2 = None
2561 val2 = None
2562 except StopIteration:
2562 except StopIteration:
2563 # Flush any remaining values and consume the other one
2563 # Flush any remaining values and consume the other one
2564 it = iter2
2564 it = iter2
2565 if val1 is not None:
2565 if val1 is not None:
2566 yield val1
2566 yield val1
2567 it = iter1
2567 it = iter1
2568 elif val2 is not None:
2568 elif val2 is not None:
2569 # might have been equality and both are empty
2569 # might have been equality and both are empty
2570 yield val2
2570 yield val2
2571 for val in it:
2571 for val in it:
2572 yield val
2572 yield val
2573
2573
2574 self._iter = _generatorset(gen())
2574 self._iter = _generatorset(gen())
2575
2575
2576 return self._iter
2576 return self._iter
2577
2577
2578 def __iter__(self):
2578 def __iter__(self):
2579 if self._genlist:
2579 if self._genlist:
2580 return iter(self._genlist)
2580 return iter(self._genlist)
2581 return iter(self._iterator())
2581 return iter(self._iterator())
2582
2582
2583 def __contains__(self, x):
2583 def __contains__(self, x):
2584 return x in self._r1 or x in self._r2
2584 return x in self._r1 or x in self._r2
2585
2585
2586 def set(self):
2586 def set(self):
2587 return self
2587 return self
2588
2588
2589 def sort(self, reverse=False):
2589 def sort(self, reverse=False):
2590 """Sort the added set
2590 """Sort the added set
2591
2591
2592 For this we use the cached list with all the generated values and if we
2592 For this we use the cached list with all the generated values and if we
2593 know they are ascending or descending we can sort them in a smart way.
2593 know they are ascending or descending we can sort them in a smart way.
2594 """
2594 """
2595 if self._ascending is None:
2595 if self._ascending is None:
2596 self._list.sort(reverse=reverse)
2596 self._list.sort(reverse=reverse)
2597 self._ascending = not reverse
2597 self._ascending = not reverse
2598 else:
2598 else:
2599 if bool(self._ascending) == bool(reverse):
2599 if bool(self._ascending) == bool(reverse):
2600 self.reverse()
2600 self.reverse()
2601
2601
2602 def isascending(self):
2602 def isascending(self):
2603 return self._ascending is not None and self._ascending
2603 return self._ascending is not None and self._ascending
2604
2604
2605 def isdescending(self):
2605 def isdescending(self):
2606 return self._ascending is not None and not self._ascending
2606 return self._ascending is not None and not self._ascending
2607
2607
2608 def reverse(self):
2608 def reverse(self):
2609 self._list.reverse()
2609 self._list.reverse()
2610 if self._ascending is not None:
2610 if self._ascending is not None:
2611 self._ascending = not self._ascending
2611 self._ascending = not self._ascending
2612
2612
2613 class _generatorset(object):
2613 class _generatorset(object):
2614 """Wrap a generator for lazy iteration
2614 """Wrap a generator for lazy iteration
2615
2615
2616 Wrapper structure for generators that provides lazy membership and can
2616 Wrapper structure for generators that provides lazy membership and can
2617 be iterated more than once.
2617 be iterated more than once.
2618 When asked for membership it generates values until either it finds the
2618 When asked for membership it generates values until either it finds the
2619 requested one or has gone through all the elements in the generator
2619 requested one or has gone through all the elements in the generator
2620
2620
2621 This class does not duck-type baseset and it's only supposed to be used
2621 This class does not duck-type baseset and it's only supposed to be used
2622 internally
2622 internally
2623 """
2623 """
2624 def __init__(self, gen):
2624 def __init__(self, gen):
2625 """
2625 """
2626 gen: a generator producing the values for the generatorset.
2626 gen: a generator producing the values for the generatorset.
2627 """
2627 """
2628 self._gen = gen
2628 self._gen = gen
2629 self._cache = {}
2629 self._cache = {}
2630 self._genlist = baseset([])
2630 self._genlist = baseset([])
2631 self._finished = False
2631 self._finished = False
2632
2632
2633 def __contains__(self, x):
2633 def __contains__(self, x):
2634 if x in self._cache:
2634 if x in self._cache:
2635 return self._cache[x]
2635 return self._cache[x]
2636
2636
2637 # Use new values only, as existing values would be cached.
2637 # Use new values only, as existing values would be cached.
2638 for l in self._consumegen():
2638 for l in self._consumegen():
2639 if l == x:
2639 if l == x:
2640 return True
2640 return True
2641
2641
2642 self._cache[x] = False
2642 self._cache[x] = False
2643 return False
2643 return False
2644
2644
2645 def __iter__(self):
2645 def __iter__(self):
2646 if self._finished:
2646 if self._finished:
2647 for x in self._genlist:
2647 for x in self._genlist:
2648 yield x
2648 yield x
2649 return
2649 return
2650
2650
2651 i = 0
2651 i = 0
2652 genlist = self._genlist
2652 genlist = self._genlist
2653 consume = self._consumegen()
2653 consume = self._consumegen()
2654 while True:
2654 while True:
2655 if i < len(genlist):
2655 if i < len(genlist):
2656 yield genlist[i]
2656 yield genlist[i]
2657 else:
2657 else:
2658 yield consume.next()
2658 yield consume.next()
2659 i += 1
2659 i += 1
2660
2660
2661 def _consumegen(self):
2661 def _consumegen(self):
2662 for item in self._gen:
2662 for item in self._gen:
2663 self._cache[item] = True
2663 self._cache[item] = True
2664 self._genlist.append(item)
2664 self._genlist.append(item)
2665 yield item
2665 yield item
2666 self._finished = True
2666 self._finished = True
2667
2667
2668 def set(self):
2668 def set(self):
2669 return self
2669 return self
2670
2670
2671 def sort(self, reverse=False):
2671 def sort(self, reverse=False):
2672 if not self._finished:
2672 if not self._finished:
2673 for i in self:
2673 for i in self:
2674 continue
2674 continue
2675 self._genlist.sort(reverse=reverse)
2675 self._genlist.sort(reverse=reverse)
2676
2676
2677 class _ascgeneratorset(_generatorset):
2677 class _ascgeneratorset(_generatorset):
2678 """Wrap a generator of ascending elements for lazy iteration
2678 """Wrap a generator of ascending elements for lazy iteration
2679
2679
2680 Same structure as _generatorset but stops iterating after it goes past
2680 Same structure as _generatorset but stops iterating after it goes past
2681 the value when asked for membership and the element is not contained
2681 the value when asked for membership and the element is not contained
2682
2682
2683 This class does not duck-type baseset and it's only supposed to be used
2683 This class does not duck-type baseset and it's only supposed to be used
2684 internally
2684 internally
2685 """
2685 """
2686 def __contains__(self, x):
2686 def __contains__(self, x):
2687 if x in self._cache:
2687 if x in self._cache:
2688 return self._cache[x]
2688 return self._cache[x]
2689
2689
2690 # Use new values only, as existing values would be cached.
2690 # Use new values only, as existing values would be cached.
2691 for l in self._consumegen():
2691 for l in self._consumegen():
2692 if l == x:
2692 if l == x:
2693 return True
2693 return True
2694 if l > x:
2694 if l > x:
2695 break
2695 break
2696
2696
2697 self._cache[x] = False
2697 self._cache[x] = False
2698 return False
2698 return False
2699
2699
2700 class _descgeneratorset(_generatorset):
2700 class _descgeneratorset(_generatorset):
2701 """Wrap a generator of descending elements for lazy iteration
2701 """Wrap a generator of descending elements for lazy iteration
2702
2702
2703 Same structure as _generatorset but stops iterating after it goes past
2703 Same structure as _generatorset but stops iterating after it goes past
2704 the value when asked for membership and the element is not contained
2704 the value when asked for membership and the element is not contained
2705
2705
2706 This class does not duck-type baseset and it's only supposed to be used
2706 This class does not duck-type baseset and it's only supposed to be used
2707 internally
2707 internally
2708 """
2708 """
2709 def __contains__(self, x):
2709 def __contains__(self, x):
2710 if x in self._cache:
2710 if x in self._cache:
2711 return self._cache[x]
2711 return self._cache[x]
2712
2712
2713 # Use new values only, as existing values would be cached.
2713 # Use new values only, as existing values would be cached.
2714 for l in self._consumegen():
2714 for l in self._consumegen():
2715 if l == x:
2715 if l == x:
2716 return True
2716 return True
2717 if l < x:
2717 if l < x:
2718 break
2718 break
2719
2719
2720 self._cache[x] = False
2720 self._cache[x] = False
2721 return False
2721 return False
2722
2722
2723 class spanset(_orderedsetmixin):
2723 class spanset(_orderedsetmixin):
2724 """Duck type for baseset class which represents a range of revisions and
2724 """Duck type for baseset class which represents a range of revisions and
2725 can work lazily and without having all the range in memory
2725 can work lazily and without having all the range in memory
2726
2726
2727 Note that spanset(x, y) behave almost like xrange(x, y) except for two
2727 Note that spanset(x, y) behave almost like xrange(x, y) except for two
2728 notable points:
2728 notable points:
2729 - when x < y it will be automatically descending,
2729 - when x < y it will be automatically descending,
2730 - revision filtered with this repoview will be skipped.
2730 - revision filtered with this repoview will be skipped.
2731
2731
2732 """
2732 """
2733 def __init__(self, repo, start=0, end=None):
2733 def __init__(self, repo, start=0, end=None):
2734 """
2734 """
2735 start: first revision included the set
2735 start: first revision included the set
2736 (default to 0)
2736 (default to 0)
2737 end: first revision excluded (last+1)
2737 end: first revision excluded (last+1)
2738 (default to len(repo)
2738 (default to len(repo)
2739
2739
2740 Spanset will be descending if `end` < `start`.
2740 Spanset will be descending if `end` < `start`.
2741 """
2741 """
2742 self._start = start
2742 self._start = start
2743 if end is not None:
2743 if end is not None:
2744 self._end = end
2744 self._end = end
2745 else:
2745 else:
2746 self._end = len(repo)
2746 self._end = len(repo)
2747 self._hiddenrevs = repo.changelog.filteredrevs
2747 self._hiddenrevs = repo.changelog.filteredrevs
2748
2748
2749 def ascending(self):
2749 def ascending(self):
2750 if self._start > self._end:
2750 if self._start > self._end:
2751 self.reverse()
2751 self.reverse()
2752
2752
2753 def descending(self):
2753 def descending(self):
2754 if self._start < self._end:
2754 if self._start < self._end:
2755 self.reverse()
2755 self.reverse()
2756
2756
2757 def __iter__(self):
2757 def __iter__(self):
2758 if self._start <= self._end:
2758 if self._start <= self._end:
2759 iterrange = xrange(self._start, self._end)
2759 iterrange = xrange(self._start, self._end)
2760 else:
2760 else:
2761 iterrange = xrange(self._start, self._end, -1)
2761 iterrange = xrange(self._start, self._end, -1)
2762
2762
2763 if self._hiddenrevs:
2763 if self._hiddenrevs:
2764 s = self._hiddenrevs
2764 s = self._hiddenrevs
2765 for r in iterrange:
2765 for r in iterrange:
2766 if r not in s:
2766 if r not in s:
2767 yield r
2767 yield r
2768 else:
2768 else:
2769 for r in iterrange:
2769 for r in iterrange:
2770 yield r
2770 yield r
2771
2771
2772 def __contains__(self, rev):
2772 def __contains__(self, rev):
2773 return (((self._end < rev <= self._start)
2773 return (((self._end < rev <= self._start)
2774 or (self._start <= rev < self._end))
2774 or (self._start <= rev < self._end))
2775 and not (self._hiddenrevs and rev in self._hiddenrevs))
2775 and not (self._hiddenrevs and rev in self._hiddenrevs))
2776
2776
2777 def __nonzero__(self):
2777 def __nonzero__(self):
2778 for r in self:
2778 for r in self:
2779 return True
2779 return True
2780 return False
2780 return False
2781
2781
2782 def __and__(self, x):
2782 def __and__(self, x):
2783 if isinstance(x, baseset):
2783 if isinstance(x, baseset):
2784 x = x.set()
2784 x = x.set()
2785 if self._start <= self._end:
2785 if self._start <= self._end:
2786 return orderedlazyset(self, x.__contains__)
2786 return orderedlazyset(self, x.__contains__)
2787 else:
2787 else:
2788 return orderedlazyset(self, x.__contains__, ascending=False)
2788 return orderedlazyset(self, x.__contains__, ascending=False)
2789
2789
2790 def __sub__(self, x):
2790 def __sub__(self, x):
2791 if isinstance(x, baseset):
2791 if isinstance(x, baseset):
2792 x = x.set()
2792 x = x.set()
2793 if self._start <= self._end:
2793 if self._start <= self._end:
2794 return orderedlazyset(self, lambda r: r not in x)
2794 return orderedlazyset(self, lambda r: r not in x)
2795 else:
2795 else:
2796 return orderedlazyset(self, lambda r: r not in x, ascending=False)
2796 return orderedlazyset(self, lambda r: r not in x, ascending=False)
2797
2797
2798 def __add__(self, x):
2798 def __add__(self, x):
2799 kwargs = {}
2799 kwargs = {}
2800 if self.isascending() and x.isascending():
2800 if self.isascending() and x.isascending():
2801 kwargs['ascending'] = True
2801 kwargs['ascending'] = True
2802 if self.isdescending() and x.isdescending():
2802 if self.isdescending() and x.isdescending():
2803 kwargs['ascending'] = False
2803 kwargs['ascending'] = False
2804 return _addset(self, x, **kwargs)
2804 return _addset(self, x, **kwargs)
2805
2805
2806 def __len__(self):
2806 def __len__(self):
2807 if not self._hiddenrevs:
2807 if not self._hiddenrevs:
2808 return abs(self._end - self._start)
2808 return abs(self._end - self._start)
2809 else:
2809 else:
2810 count = 0
2810 count = 0
2811 start = self._start
2811 start = self._start
2812 end = self._end
2812 end = self._end
2813 for rev in self._hiddenrevs:
2813 for rev in self._hiddenrevs:
2814 if (end < rev <= start) or (start <= rev < end):
2814 if (end < rev <= start) or (start <= rev < end):
2815 count += 1
2815 count += 1
2816 return abs(self._end - self._start) - count
2816 return abs(self._end - self._start) - count
2817
2817
2818 def __getitem__(self, x):
2818 def __getitem__(self, x):
2819 # Basic implementation to be changed in future patches.
2819 # Basic implementation to be changed in future patches.
2820 l = baseset([r for r in self])
2820 l = baseset([r for r in self])
2821 return l[x]
2821 return l[x]
2822
2822
2823 def sort(self, reverse=False):
2823 def sort(self, reverse=False):
2824 if bool(reverse) != (self._start > self._end):
2824 if bool(reverse) != (self._start > self._end):
2825 self.reverse()
2825 self.reverse()
2826
2826
2827 def reverse(self):
2827 def reverse(self):
2828 # Just switch the _start and _end parameters
2828 # Just switch the _start and _end parameters
2829 if self._start <= self._end:
2829 if self._start <= self._end:
2830 self._start, self._end = self._end - 1, self._start - 1
2830 self._start, self._end = self._end - 1, self._start - 1
2831 else:
2831 else:
2832 self._start, self._end = self._end + 1, self._start + 1
2832 self._start, self._end = self._end + 1, self._start + 1
2833
2833
2834 def set(self):
2834 def set(self):
2835 return self
2835 return self
2836
2836
2837 def isascending(self):
2837 def isascending(self):
2838 return self._start < self._end
2838 return self._start < self._end
2839
2839
2840 def isdescending(self):
2840 def isdescending(self):
2841 return self._start > self._end
2841 return self._start > self._end
2842
2842
2843 def filter(self, l):
2843 def filter(self, l):
2844 if self._start <= self._end:
2844 if self._start <= self._end:
2845 return orderedlazyset(self, l)
2845 return orderedlazyset(self, l)
2846 else:
2846 else:
2847 return orderedlazyset(self, l, ascending=False)
2847 return orderedlazyset(self, l, ascending=False)
2848
2848
2849 # tell hggettext to extract docstrings from these functions:
2849 # tell hggettext to extract docstrings from these functions:
2850 i18nfunctions = symbols.values()
2850 i18nfunctions = symbols.values()
General Comments 0
You need to be logged in to leave comments. Login now