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