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