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