##// END OF EJS Templates
context: change default changeid from old form '' to '.'...
Martin von Zweigbergk -
r37169:05c13e5a default
parent child Browse files
Show More
@@ -1,2617 +1,2617 b''
1 1 # context.py - changeset and file context objects for mercurial
2 2 #
3 3 # Copyright 2006, 2007 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 from __future__ import absolute_import
9 9
10 10 import errno
11 11 import filecmp
12 12 import os
13 13 import re
14 14 import stat
15 15
16 16 from .i18n import _
17 17 from .node import (
18 18 addednodeid,
19 19 bin,
20 20 hex,
21 21 modifiednodeid,
22 22 nullid,
23 23 nullrev,
24 24 short,
25 25 wdirid,
26 26 wdirnodes,
27 27 wdirrev,
28 28 )
29 29 from . import (
30 30 dagop,
31 31 encoding,
32 32 error,
33 33 fileset,
34 34 match as matchmod,
35 35 obsolete as obsmod,
36 36 obsutil,
37 37 patch,
38 38 pathutil,
39 39 phases,
40 40 pycompat,
41 41 repoview,
42 42 revlog,
43 43 scmutil,
44 44 sparse,
45 45 subrepo,
46 46 subrepoutil,
47 47 util,
48 48 )
49 49 from .utils import (
50 50 dateutil,
51 51 stringutil,
52 52 )
53 53
54 54 propertycache = util.propertycache
55 55
56 56 nonascii = re.compile(br'[^\x21-\x7f]').search
57 57
58 58 class basectx(object):
59 59 """A basectx object represents the common logic for its children:
60 60 changectx: read-only context that is already present in the repo,
61 61 workingctx: a context that represents the working directory and can
62 62 be committed,
63 63 memctx: a context that represents changes in-memory and can also
64 64 be committed."""
65 65 def __new__(cls, repo, changeid='', *args, **kwargs):
66 66 if isinstance(changeid, basectx):
67 67 return changeid
68 68
69 69 o = super(basectx, cls).__new__(cls)
70 70
71 71 o._repo = repo
72 72 o._rev = nullrev
73 73 o._node = nullid
74 74
75 75 return o
76 76
77 77 def __bytes__(self):
78 78 return short(self.node())
79 79
80 80 __str__ = encoding.strmethod(__bytes__)
81 81
82 82 def __repr__(self):
83 83 return r"<%s %s>" % (type(self).__name__, str(self))
84 84
85 85 def __eq__(self, other):
86 86 try:
87 87 return type(self) == type(other) and self._rev == other._rev
88 88 except AttributeError:
89 89 return False
90 90
91 91 def __ne__(self, other):
92 92 return not (self == other)
93 93
94 94 def __contains__(self, key):
95 95 return key in self._manifest
96 96
97 97 def __getitem__(self, key):
98 98 return self.filectx(key)
99 99
100 100 def __iter__(self):
101 101 return iter(self._manifest)
102 102
103 103 def _buildstatusmanifest(self, status):
104 104 """Builds a manifest that includes the given status results, if this is
105 105 a working copy context. For non-working copy contexts, it just returns
106 106 the normal manifest."""
107 107 return self.manifest()
108 108
109 109 def _matchstatus(self, other, match):
110 110 """This internal method provides a way for child objects to override the
111 111 match operator.
112 112 """
113 113 return match
114 114
115 115 def _buildstatus(self, other, s, match, listignored, listclean,
116 116 listunknown):
117 117 """build a status with respect to another context"""
118 118 # Load earliest manifest first for caching reasons. More specifically,
119 119 # if you have revisions 1000 and 1001, 1001 is probably stored as a
120 120 # delta against 1000. Thus, if you read 1000 first, we'll reconstruct
121 121 # 1000 and cache it so that when you read 1001, we just need to apply a
122 122 # delta to what's in the cache. So that's one full reconstruction + one
123 123 # delta application.
124 124 mf2 = None
125 125 if self.rev() is not None and self.rev() < other.rev():
126 126 mf2 = self._buildstatusmanifest(s)
127 127 mf1 = other._buildstatusmanifest(s)
128 128 if mf2 is None:
129 129 mf2 = self._buildstatusmanifest(s)
130 130
131 131 modified, added = [], []
132 132 removed = []
133 133 clean = []
134 134 deleted, unknown, ignored = s.deleted, s.unknown, s.ignored
135 135 deletedset = set(deleted)
136 136 d = mf1.diff(mf2, match=match, clean=listclean)
137 137 for fn, value in d.iteritems():
138 138 if fn in deletedset:
139 139 continue
140 140 if value is None:
141 141 clean.append(fn)
142 142 continue
143 143 (node1, flag1), (node2, flag2) = value
144 144 if node1 is None:
145 145 added.append(fn)
146 146 elif node2 is None:
147 147 removed.append(fn)
148 148 elif flag1 != flag2:
149 149 modified.append(fn)
150 150 elif node2 not in wdirnodes:
151 151 # When comparing files between two commits, we save time by
152 152 # not comparing the file contents when the nodeids differ.
153 153 # Note that this means we incorrectly report a reverted change
154 154 # to a file as a modification.
155 155 modified.append(fn)
156 156 elif self[fn].cmp(other[fn]):
157 157 modified.append(fn)
158 158 else:
159 159 clean.append(fn)
160 160
161 161 if removed:
162 162 # need to filter files if they are already reported as removed
163 163 unknown = [fn for fn in unknown if fn not in mf1 and
164 164 (not match or match(fn))]
165 165 ignored = [fn for fn in ignored if fn not in mf1 and
166 166 (not match or match(fn))]
167 167 # if they're deleted, don't report them as removed
168 168 removed = [fn for fn in removed if fn not in deletedset]
169 169
170 170 return scmutil.status(modified, added, removed, deleted, unknown,
171 171 ignored, clean)
172 172
173 173 @propertycache
174 174 def substate(self):
175 175 return subrepoutil.state(self, self._repo.ui)
176 176
177 177 def subrev(self, subpath):
178 178 return self.substate[subpath][1]
179 179
180 180 def rev(self):
181 181 return self._rev
182 182 def node(self):
183 183 return self._node
184 184 def hex(self):
185 185 return hex(self.node())
186 186 def manifest(self):
187 187 return self._manifest
188 188 def manifestctx(self):
189 189 return self._manifestctx
190 190 def repo(self):
191 191 return self._repo
192 192 def phasestr(self):
193 193 return phases.phasenames[self.phase()]
194 194 def mutable(self):
195 195 return self.phase() > phases.public
196 196
197 197 def getfileset(self, expr):
198 198 return fileset.getfileset(self, expr)
199 199
200 200 def obsolete(self):
201 201 """True if the changeset is obsolete"""
202 202 return self.rev() in obsmod.getrevs(self._repo, 'obsolete')
203 203
204 204 def extinct(self):
205 205 """True if the changeset is extinct"""
206 206 return self.rev() in obsmod.getrevs(self._repo, 'extinct')
207 207
208 208 def orphan(self):
209 209 """True if the changeset is not obsolete but it's ancestor are"""
210 210 return self.rev() in obsmod.getrevs(self._repo, 'orphan')
211 211
212 212 def phasedivergent(self):
213 213 """True if the changeset try to be a successor of a public changeset
214 214
215 215 Only non-public and non-obsolete changesets may be bumped.
216 216 """
217 217 return self.rev() in obsmod.getrevs(self._repo, 'phasedivergent')
218 218
219 219 def contentdivergent(self):
220 220 """Is a successors of a changeset with multiple possible successors set
221 221
222 222 Only non-public and non-obsolete changesets may be divergent.
223 223 """
224 224 return self.rev() in obsmod.getrevs(self._repo, 'contentdivergent')
225 225
226 226 def isunstable(self):
227 227 """True if the changeset is either unstable, bumped or divergent"""
228 228 return self.orphan() or self.phasedivergent() or self.contentdivergent()
229 229
230 230 def instabilities(self):
231 231 """return the list of instabilities affecting this changeset.
232 232
233 233 Instabilities are returned as strings. possible values are:
234 234 - orphan,
235 235 - phase-divergent,
236 236 - content-divergent.
237 237 """
238 238 instabilities = []
239 239 if self.orphan():
240 240 instabilities.append('orphan')
241 241 if self.phasedivergent():
242 242 instabilities.append('phase-divergent')
243 243 if self.contentdivergent():
244 244 instabilities.append('content-divergent')
245 245 return instabilities
246 246
247 247 def parents(self):
248 248 """return contexts for each parent changeset"""
249 249 return self._parents
250 250
251 251 def p1(self):
252 252 return self._parents[0]
253 253
254 254 def p2(self):
255 255 parents = self._parents
256 256 if len(parents) == 2:
257 257 return parents[1]
258 258 return changectx(self._repo, nullrev)
259 259
260 260 def _fileinfo(self, path):
261 261 if r'_manifest' in self.__dict__:
262 262 try:
263 263 return self._manifest[path], self._manifest.flags(path)
264 264 except KeyError:
265 265 raise error.ManifestLookupError(self._node, path,
266 266 _('not found in manifest'))
267 267 if r'_manifestdelta' in self.__dict__ or path in self.files():
268 268 if path in self._manifestdelta:
269 269 return (self._manifestdelta[path],
270 270 self._manifestdelta.flags(path))
271 271 mfl = self._repo.manifestlog
272 272 try:
273 273 node, flag = mfl[self._changeset.manifest].find(path)
274 274 except KeyError:
275 275 raise error.ManifestLookupError(self._node, path,
276 276 _('not found in manifest'))
277 277
278 278 return node, flag
279 279
280 280 def filenode(self, path):
281 281 return self._fileinfo(path)[0]
282 282
283 283 def flags(self, path):
284 284 try:
285 285 return self._fileinfo(path)[1]
286 286 except error.LookupError:
287 287 return ''
288 288
289 289 def sub(self, path, allowcreate=True):
290 290 '''return a subrepo for the stored revision of path, never wdir()'''
291 291 return subrepo.subrepo(self, path, allowcreate=allowcreate)
292 292
293 293 def nullsub(self, path, pctx):
294 294 return subrepo.nullsubrepo(self, path, pctx)
295 295
296 296 def workingsub(self, path):
297 297 '''return a subrepo for the stored revision, or wdir if this is a wdir
298 298 context.
299 299 '''
300 300 return subrepo.subrepo(self, path, allowwdir=True)
301 301
302 302 def match(self, pats=None, include=None, exclude=None, default='glob',
303 303 listsubrepos=False, badfn=None):
304 304 r = self._repo
305 305 return matchmod.match(r.root, r.getcwd(), pats,
306 306 include, exclude, default,
307 307 auditor=r.nofsauditor, ctx=self,
308 308 listsubrepos=listsubrepos, badfn=badfn)
309 309
310 310 def diff(self, ctx2=None, match=None, **opts):
311 311 """Returns a diff generator for the given contexts and matcher"""
312 312 if ctx2 is None:
313 313 ctx2 = self.p1()
314 314 if ctx2 is not None:
315 315 ctx2 = self._repo[ctx2]
316 316 diffopts = patch.diffopts(self._repo.ui, pycompat.byteskwargs(opts))
317 317 return patch.diff(self._repo, ctx2, self, match=match, opts=diffopts)
318 318
319 319 def dirs(self):
320 320 return self._manifest.dirs()
321 321
322 322 def hasdir(self, dir):
323 323 return self._manifest.hasdir(dir)
324 324
325 325 def status(self, other=None, match=None, listignored=False,
326 326 listclean=False, listunknown=False, listsubrepos=False):
327 327 """return status of files between two nodes or node and working
328 328 directory.
329 329
330 330 If other is None, compare this node with working directory.
331 331
332 332 returns (modified, added, removed, deleted, unknown, ignored, clean)
333 333 """
334 334
335 335 ctx1 = self
336 336 ctx2 = self._repo[other]
337 337
338 338 # This next code block is, admittedly, fragile logic that tests for
339 339 # reversing the contexts and wouldn't need to exist if it weren't for
340 340 # the fast (and common) code path of comparing the working directory
341 341 # with its first parent.
342 342 #
343 343 # What we're aiming for here is the ability to call:
344 344 #
345 345 # workingctx.status(parentctx)
346 346 #
347 347 # If we always built the manifest for each context and compared those,
348 348 # then we'd be done. But the special case of the above call means we
349 349 # just copy the manifest of the parent.
350 350 reversed = False
351 351 if (not isinstance(ctx1, changectx)
352 352 and isinstance(ctx2, changectx)):
353 353 reversed = True
354 354 ctx1, ctx2 = ctx2, ctx1
355 355
356 356 match = match or matchmod.always(self._repo.root, self._repo.getcwd())
357 357 match = ctx2._matchstatus(ctx1, match)
358 358 r = scmutil.status([], [], [], [], [], [], [])
359 359 r = ctx2._buildstatus(ctx1, r, match, listignored, listclean,
360 360 listunknown)
361 361
362 362 if reversed:
363 363 # Reverse added and removed. Clear deleted, unknown and ignored as
364 364 # these make no sense to reverse.
365 365 r = scmutil.status(r.modified, r.removed, r.added, [], [], [],
366 366 r.clean)
367 367
368 368 if listsubrepos:
369 369 for subpath, sub in scmutil.itersubrepos(ctx1, ctx2):
370 370 try:
371 371 rev2 = ctx2.subrev(subpath)
372 372 except KeyError:
373 373 # A subrepo that existed in node1 was deleted between
374 374 # node1 and node2 (inclusive). Thus, ctx2's substate
375 375 # won't contain that subpath. The best we can do ignore it.
376 376 rev2 = None
377 377 submatch = matchmod.subdirmatcher(subpath, match)
378 378 s = sub.status(rev2, match=submatch, ignored=listignored,
379 379 clean=listclean, unknown=listunknown,
380 380 listsubrepos=True)
381 381 for rfiles, sfiles in zip(r, s):
382 382 rfiles.extend("%s/%s" % (subpath, f) for f in sfiles)
383 383
384 384 for l in r:
385 385 l.sort()
386 386
387 387 return r
388 388
389 389 def _filterederror(repo, changeid):
390 390 """build an exception to be raised about a filtered changeid
391 391
392 392 This is extracted in a function to help extensions (eg: evolve) to
393 393 experiment with various message variants."""
394 394 if repo.filtername.startswith('visible'):
395 395
396 396 # Check if the changeset is obsolete
397 397 unfilteredrepo = repo.unfiltered()
398 398 ctx = unfilteredrepo[changeid]
399 399
400 400 # If the changeset is obsolete, enrich the message with the reason
401 401 # that made this changeset not visible
402 402 if ctx.obsolete():
403 403 msg = obsutil._getfilteredreason(repo, changeid, ctx)
404 404 else:
405 405 msg = _("hidden revision '%s'") % changeid
406 406
407 407 hint = _('use --hidden to access hidden revisions')
408 408
409 409 return error.FilteredRepoLookupError(msg, hint=hint)
410 410 msg = _("filtered revision '%s' (not in '%s' subset)")
411 411 msg %= (changeid, repo.filtername)
412 412 return error.FilteredRepoLookupError(msg)
413 413
414 414 class changectx(basectx):
415 415 """A changecontext object makes access to data related to a particular
416 416 changeset convenient. It represents a read-only context already present in
417 417 the repo."""
418 def __init__(self, repo, changeid=''):
418 def __init__(self, repo, changeid='.'):
419 419 """changeid is a revision number, node, or tag"""
420 420
421 421 # since basectx.__new__ already took care of copying the object, we
422 422 # don't need to do anything in __init__, so we just exit here
423 423 if isinstance(changeid, basectx):
424 424 return
425 425
426 426 if changeid == '':
427 427 changeid = '.'
428 428 self._repo = repo
429 429
430 430 try:
431 431 if isinstance(changeid, int):
432 432 self._node = repo.changelog.node(changeid)
433 433 self._rev = changeid
434 434 return
435 435 if not pycompat.ispy3 and isinstance(changeid, long):
436 436 changeid = "%d" % changeid
437 437 if changeid == 'null':
438 438 self._node = nullid
439 439 self._rev = nullrev
440 440 return
441 441 if changeid == 'tip':
442 442 self._node = repo.changelog.tip()
443 443 self._rev = repo.changelog.rev(self._node)
444 444 return
445 445 if (changeid == '.'
446 446 or repo.local() and changeid == repo.dirstate.p1()):
447 447 # this is a hack to delay/avoid loading obsmarkers
448 448 # when we know that '.' won't be hidden
449 449 self._node = repo.dirstate.p1()
450 450 self._rev = repo.unfiltered().changelog.rev(self._node)
451 451 return
452 452 if len(changeid) == 20:
453 453 try:
454 454 self._node = changeid
455 455 self._rev = repo.changelog.rev(changeid)
456 456 return
457 457 except error.FilteredRepoLookupError:
458 458 raise
459 459 except LookupError:
460 460 pass
461 461
462 462 try:
463 463 r = int(changeid)
464 464 if '%d' % r != changeid:
465 465 raise ValueError
466 466 l = len(repo.changelog)
467 467 if r < 0:
468 468 r += l
469 469 if r < 0 or r >= l and r != wdirrev:
470 470 raise ValueError
471 471 self._rev = r
472 472 self._node = repo.changelog.node(r)
473 473 return
474 474 except error.FilteredIndexError:
475 475 raise
476 476 except (ValueError, OverflowError, IndexError):
477 477 pass
478 478
479 479 if len(changeid) == 40:
480 480 try:
481 481 self._node = bin(changeid)
482 482 self._rev = repo.changelog.rev(self._node)
483 483 return
484 484 except error.FilteredLookupError:
485 485 raise
486 486 except (TypeError, LookupError):
487 487 pass
488 488
489 489 # lookup bookmarks through the name interface
490 490 try:
491 491 self._node = repo.names.singlenode(repo, changeid)
492 492 self._rev = repo.changelog.rev(self._node)
493 493 return
494 494 except KeyError:
495 495 pass
496 496 except error.FilteredRepoLookupError:
497 497 raise
498 498 except error.RepoLookupError:
499 499 pass
500 500
501 501 self._node = repo.unfiltered().changelog._partialmatch(changeid)
502 502 if self._node is not None:
503 503 self._rev = repo.changelog.rev(self._node)
504 504 return
505 505
506 506 # lookup failed
507 507 # check if it might have come from damaged dirstate
508 508 #
509 509 # XXX we could avoid the unfiltered if we had a recognizable
510 510 # exception for filtered changeset access
511 511 if (repo.local()
512 512 and changeid in repo.unfiltered().dirstate.parents()):
513 513 msg = _("working directory has unknown parent '%s'!")
514 514 raise error.Abort(msg % short(changeid))
515 515 try:
516 516 if len(changeid) == 20 and nonascii(changeid):
517 517 changeid = hex(changeid)
518 518 except TypeError:
519 519 pass
520 520 except (error.FilteredIndexError, error.FilteredLookupError,
521 521 error.FilteredRepoLookupError):
522 522 raise _filterederror(repo, changeid)
523 523 except IndexError:
524 524 pass
525 525 raise error.RepoLookupError(
526 526 _("unknown revision '%s'") % changeid)
527 527
528 528 def __hash__(self):
529 529 try:
530 530 return hash(self._rev)
531 531 except AttributeError:
532 532 return id(self)
533 533
534 534 def __nonzero__(self):
535 535 return self._rev != nullrev
536 536
537 537 __bool__ = __nonzero__
538 538
539 539 @propertycache
540 540 def _changeset(self):
541 541 return self._repo.changelog.changelogrevision(self.rev())
542 542
543 543 @propertycache
544 544 def _manifest(self):
545 545 return self._manifestctx.read()
546 546
547 547 @property
548 548 def _manifestctx(self):
549 549 return self._repo.manifestlog[self._changeset.manifest]
550 550
551 551 @propertycache
552 552 def _manifestdelta(self):
553 553 return self._manifestctx.readdelta()
554 554
555 555 @propertycache
556 556 def _parents(self):
557 557 repo = self._repo
558 558 p1, p2 = repo.changelog.parentrevs(self._rev)
559 559 if p2 == nullrev:
560 560 return [changectx(repo, p1)]
561 561 return [changectx(repo, p1), changectx(repo, p2)]
562 562
563 563 def changeset(self):
564 564 c = self._changeset
565 565 return (
566 566 c.manifest,
567 567 c.user,
568 568 c.date,
569 569 c.files,
570 570 c.description,
571 571 c.extra,
572 572 )
573 573 def manifestnode(self):
574 574 return self._changeset.manifest
575 575
576 576 def user(self):
577 577 return self._changeset.user
578 578 def date(self):
579 579 return self._changeset.date
580 580 def files(self):
581 581 return self._changeset.files
582 582 def description(self):
583 583 return self._changeset.description
584 584 def branch(self):
585 585 return encoding.tolocal(self._changeset.extra.get("branch"))
586 586 def closesbranch(self):
587 587 return 'close' in self._changeset.extra
588 588 def extra(self):
589 589 """Return a dict of extra information."""
590 590 return self._changeset.extra
591 591 def tags(self):
592 592 """Return a list of byte tag names"""
593 593 return self._repo.nodetags(self._node)
594 594 def bookmarks(self):
595 595 """Return a list of byte bookmark names."""
596 596 return self._repo.nodebookmarks(self._node)
597 597 def phase(self):
598 598 return self._repo._phasecache.phase(self._repo, self._rev)
599 599 def hidden(self):
600 600 return self._rev in repoview.filterrevs(self._repo, 'visible')
601 601
602 602 def isinmemory(self):
603 603 return False
604 604
605 605 def children(self):
606 606 """return list of changectx contexts for each child changeset.
607 607
608 608 This returns only the immediate child changesets. Use descendants() to
609 609 recursively walk children.
610 610 """
611 611 c = self._repo.changelog.children(self._node)
612 612 return [changectx(self._repo, x) for x in c]
613 613
614 614 def ancestors(self):
615 615 for a in self._repo.changelog.ancestors([self._rev]):
616 616 yield changectx(self._repo, a)
617 617
618 618 def descendants(self):
619 619 """Recursively yield all children of the changeset.
620 620
621 621 For just the immediate children, use children()
622 622 """
623 623 for d in self._repo.changelog.descendants([self._rev]):
624 624 yield changectx(self._repo, d)
625 625
626 626 def filectx(self, path, fileid=None, filelog=None):
627 627 """get a file context from this changeset"""
628 628 if fileid is None:
629 629 fileid = self.filenode(path)
630 630 return filectx(self._repo, path, fileid=fileid,
631 631 changectx=self, filelog=filelog)
632 632
633 633 def ancestor(self, c2, warn=False):
634 634 """return the "best" ancestor context of self and c2
635 635
636 636 If there are multiple candidates, it will show a message and check
637 637 merge.preferancestor configuration before falling back to the
638 638 revlog ancestor."""
639 639 # deal with workingctxs
640 640 n2 = c2._node
641 641 if n2 is None:
642 642 n2 = c2._parents[0]._node
643 643 cahs = self._repo.changelog.commonancestorsheads(self._node, n2)
644 644 if not cahs:
645 645 anc = nullid
646 646 elif len(cahs) == 1:
647 647 anc = cahs[0]
648 648 else:
649 649 # experimental config: merge.preferancestor
650 650 for r in self._repo.ui.configlist('merge', 'preferancestor'):
651 651 try:
652 652 ctx = changectx(self._repo, r)
653 653 except error.RepoLookupError:
654 654 continue
655 655 anc = ctx.node()
656 656 if anc in cahs:
657 657 break
658 658 else:
659 659 anc = self._repo.changelog.ancestor(self._node, n2)
660 660 if warn:
661 661 self._repo.ui.status(
662 662 (_("note: using %s as ancestor of %s and %s\n") %
663 663 (short(anc), short(self._node), short(n2))) +
664 664 ''.join(_(" alternatively, use --config "
665 665 "merge.preferancestor=%s\n") %
666 666 short(n) for n in sorted(cahs) if n != anc))
667 667 return changectx(self._repo, anc)
668 668
669 669 def descendant(self, other):
670 670 """True if other is descendant of this changeset"""
671 671 return self._repo.changelog.descendant(self._rev, other._rev)
672 672
673 673 def walk(self, match):
674 674 '''Generates matching file names.'''
675 675
676 676 # Wrap match.bad method to have message with nodeid
677 677 def bad(fn, msg):
678 678 # The manifest doesn't know about subrepos, so don't complain about
679 679 # paths into valid subrepos.
680 680 if any(fn == s or fn.startswith(s + '/')
681 681 for s in self.substate):
682 682 return
683 683 match.bad(fn, _('no such file in rev %s') % self)
684 684
685 685 m = matchmod.badmatch(match, bad)
686 686 return self._manifest.walk(m)
687 687
688 688 def matches(self, match):
689 689 return self.walk(match)
690 690
691 691 class basefilectx(object):
692 692 """A filecontext object represents the common logic for its children:
693 693 filectx: read-only access to a filerevision that is already present
694 694 in the repo,
695 695 workingfilectx: a filecontext that represents files from the working
696 696 directory,
697 697 memfilectx: a filecontext that represents files in-memory,
698 698 overlayfilectx: duplicate another filecontext with some fields overridden.
699 699 """
700 700 @propertycache
701 701 def _filelog(self):
702 702 return self._repo.file(self._path)
703 703
704 704 @propertycache
705 705 def _changeid(self):
706 706 if r'_changeid' in self.__dict__:
707 707 return self._changeid
708 708 elif r'_changectx' in self.__dict__:
709 709 return self._changectx.rev()
710 710 elif r'_descendantrev' in self.__dict__:
711 711 # this file context was created from a revision with a known
712 712 # descendant, we can (lazily) correct for linkrev aliases
713 713 return self._adjustlinkrev(self._descendantrev)
714 714 else:
715 715 return self._filelog.linkrev(self._filerev)
716 716
717 717 @propertycache
718 718 def _filenode(self):
719 719 if r'_fileid' in self.__dict__:
720 720 return self._filelog.lookup(self._fileid)
721 721 else:
722 722 return self._changectx.filenode(self._path)
723 723
724 724 @propertycache
725 725 def _filerev(self):
726 726 return self._filelog.rev(self._filenode)
727 727
728 728 @propertycache
729 729 def _repopath(self):
730 730 return self._path
731 731
732 732 def __nonzero__(self):
733 733 try:
734 734 self._filenode
735 735 return True
736 736 except error.LookupError:
737 737 # file is missing
738 738 return False
739 739
740 740 __bool__ = __nonzero__
741 741
742 742 def __bytes__(self):
743 743 try:
744 744 return "%s@%s" % (self.path(), self._changectx)
745 745 except error.LookupError:
746 746 return "%s@???" % self.path()
747 747
748 748 __str__ = encoding.strmethod(__bytes__)
749 749
750 750 def __repr__(self):
751 751 return r"<%s %s>" % (type(self).__name__, str(self))
752 752
753 753 def __hash__(self):
754 754 try:
755 755 return hash((self._path, self._filenode))
756 756 except AttributeError:
757 757 return id(self)
758 758
759 759 def __eq__(self, other):
760 760 try:
761 761 return (type(self) == type(other) and self._path == other._path
762 762 and self._filenode == other._filenode)
763 763 except AttributeError:
764 764 return False
765 765
766 766 def __ne__(self, other):
767 767 return not (self == other)
768 768
769 769 def filerev(self):
770 770 return self._filerev
771 771 def filenode(self):
772 772 return self._filenode
773 773 @propertycache
774 774 def _flags(self):
775 775 return self._changectx.flags(self._path)
776 776 def flags(self):
777 777 return self._flags
778 778 def filelog(self):
779 779 return self._filelog
780 780 def rev(self):
781 781 return self._changeid
782 782 def linkrev(self):
783 783 return self._filelog.linkrev(self._filerev)
784 784 def node(self):
785 785 return self._changectx.node()
786 786 def hex(self):
787 787 return self._changectx.hex()
788 788 def user(self):
789 789 return self._changectx.user()
790 790 def date(self):
791 791 return self._changectx.date()
792 792 def files(self):
793 793 return self._changectx.files()
794 794 def description(self):
795 795 return self._changectx.description()
796 796 def branch(self):
797 797 return self._changectx.branch()
798 798 def extra(self):
799 799 return self._changectx.extra()
800 800 def phase(self):
801 801 return self._changectx.phase()
802 802 def phasestr(self):
803 803 return self._changectx.phasestr()
804 804 def obsolete(self):
805 805 return self._changectx.obsolete()
806 806 def instabilities(self):
807 807 return self._changectx.instabilities()
808 808 def manifest(self):
809 809 return self._changectx.manifest()
810 810 def changectx(self):
811 811 return self._changectx
812 812 def renamed(self):
813 813 return self._copied
814 814 def repo(self):
815 815 return self._repo
816 816 def size(self):
817 817 return len(self.data())
818 818
819 819 def path(self):
820 820 return self._path
821 821
822 822 def isbinary(self):
823 823 try:
824 824 return stringutil.binary(self.data())
825 825 except IOError:
826 826 return False
827 827 def isexec(self):
828 828 return 'x' in self.flags()
829 829 def islink(self):
830 830 return 'l' in self.flags()
831 831
832 832 def isabsent(self):
833 833 """whether this filectx represents a file not in self._changectx
834 834
835 835 This is mainly for merge code to detect change/delete conflicts. This is
836 836 expected to be True for all subclasses of basectx."""
837 837 return False
838 838
839 839 _customcmp = False
840 840 def cmp(self, fctx):
841 841 """compare with other file context
842 842
843 843 returns True if different than fctx.
844 844 """
845 845 if fctx._customcmp:
846 846 return fctx.cmp(self)
847 847
848 848 if (fctx._filenode is None
849 849 and (self._repo._encodefilterpats
850 850 # if file data starts with '\1\n', empty metadata block is
851 851 # prepended, which adds 4 bytes to filelog.size().
852 852 or self.size() - 4 == fctx.size())
853 853 or self.size() == fctx.size()):
854 854 return self._filelog.cmp(self._filenode, fctx.data())
855 855
856 856 return True
857 857
858 858 def _adjustlinkrev(self, srcrev, inclusive=False):
859 859 """return the first ancestor of <srcrev> introducing <fnode>
860 860
861 861 If the linkrev of the file revision does not point to an ancestor of
862 862 srcrev, we'll walk down the ancestors until we find one introducing
863 863 this file revision.
864 864
865 865 :srcrev: the changeset revision we search ancestors from
866 866 :inclusive: if true, the src revision will also be checked
867 867 """
868 868 repo = self._repo
869 869 cl = repo.unfiltered().changelog
870 870 mfl = repo.manifestlog
871 871 # fetch the linkrev
872 872 lkr = self.linkrev()
873 873 # hack to reuse ancestor computation when searching for renames
874 874 memberanc = getattr(self, '_ancestrycontext', None)
875 875 iteranc = None
876 876 if srcrev is None:
877 877 # wctx case, used by workingfilectx during mergecopy
878 878 revs = [p.rev() for p in self._repo[None].parents()]
879 879 inclusive = True # we skipped the real (revless) source
880 880 else:
881 881 revs = [srcrev]
882 882 if memberanc is None:
883 883 memberanc = iteranc = cl.ancestors(revs, lkr,
884 884 inclusive=inclusive)
885 885 # check if this linkrev is an ancestor of srcrev
886 886 if lkr not in memberanc:
887 887 if iteranc is None:
888 888 iteranc = cl.ancestors(revs, lkr, inclusive=inclusive)
889 889 fnode = self._filenode
890 890 path = self._path
891 891 for a in iteranc:
892 892 ac = cl.read(a) # get changeset data (we avoid object creation)
893 893 if path in ac[3]: # checking the 'files' field.
894 894 # The file has been touched, check if the content is
895 895 # similar to the one we search for.
896 896 if fnode == mfl[ac[0]].readfast().get(path):
897 897 return a
898 898 # In theory, we should never get out of that loop without a result.
899 899 # But if manifest uses a buggy file revision (not children of the
900 900 # one it replaces) we could. Such a buggy situation will likely
901 901 # result is crash somewhere else at to some point.
902 902 return lkr
903 903
904 904 def introrev(self):
905 905 """return the rev of the changeset which introduced this file revision
906 906
907 907 This method is different from linkrev because it take into account the
908 908 changeset the filectx was created from. It ensures the returned
909 909 revision is one of its ancestors. This prevents bugs from
910 910 'linkrev-shadowing' when a file revision is used by multiple
911 911 changesets.
912 912 """
913 913 lkr = self.linkrev()
914 914 attrs = vars(self)
915 915 noctx = not (r'_changeid' in attrs or r'_changectx' in attrs)
916 916 if noctx or self.rev() == lkr:
917 917 return self.linkrev()
918 918 return self._adjustlinkrev(self.rev(), inclusive=True)
919 919
920 920 def introfilectx(self):
921 921 """Return filectx having identical contents, but pointing to the
922 922 changeset revision where this filectx was introduced"""
923 923 introrev = self.introrev()
924 924 if self.rev() == introrev:
925 925 return self
926 926 return self.filectx(self.filenode(), changeid=introrev)
927 927
928 928 def _parentfilectx(self, path, fileid, filelog):
929 929 """create parent filectx keeping ancestry info for _adjustlinkrev()"""
930 930 fctx = filectx(self._repo, path, fileid=fileid, filelog=filelog)
931 931 if r'_changeid' in vars(self) or r'_changectx' in vars(self):
932 932 # If self is associated with a changeset (probably explicitly
933 933 # fed), ensure the created filectx is associated with a
934 934 # changeset that is an ancestor of self.changectx.
935 935 # This lets us later use _adjustlinkrev to get a correct link.
936 936 fctx._descendantrev = self.rev()
937 937 fctx._ancestrycontext = getattr(self, '_ancestrycontext', None)
938 938 elif r'_descendantrev' in vars(self):
939 939 # Otherwise propagate _descendantrev if we have one associated.
940 940 fctx._descendantrev = self._descendantrev
941 941 fctx._ancestrycontext = getattr(self, '_ancestrycontext', None)
942 942 return fctx
943 943
944 944 def parents(self):
945 945 _path = self._path
946 946 fl = self._filelog
947 947 parents = self._filelog.parents(self._filenode)
948 948 pl = [(_path, node, fl) for node in parents if node != nullid]
949 949
950 950 r = fl.renamed(self._filenode)
951 951 if r:
952 952 # - In the simple rename case, both parent are nullid, pl is empty.
953 953 # - In case of merge, only one of the parent is null id and should
954 954 # be replaced with the rename information. This parent is -always-
955 955 # the first one.
956 956 #
957 957 # As null id have always been filtered out in the previous list
958 958 # comprehension, inserting to 0 will always result in "replacing
959 959 # first nullid parent with rename information.
960 960 pl.insert(0, (r[0], r[1], self._repo.file(r[0])))
961 961
962 962 return [self._parentfilectx(path, fnode, l) for path, fnode, l in pl]
963 963
964 964 def p1(self):
965 965 return self.parents()[0]
966 966
967 967 def p2(self):
968 968 p = self.parents()
969 969 if len(p) == 2:
970 970 return p[1]
971 971 return filectx(self._repo, self._path, fileid=-1, filelog=self._filelog)
972 972
973 973 def annotate(self, follow=False, skiprevs=None, diffopts=None):
974 974 """Returns a list of annotateline objects for each line in the file
975 975
976 976 - line.fctx is the filectx of the node where that line was last changed
977 977 - line.lineno is the line number at the first appearance in the managed
978 978 file
979 979 - line.text is the data on that line (including newline character)
980 980 """
981 981 getlog = util.lrucachefunc(lambda x: self._repo.file(x))
982 982
983 983 def parents(f):
984 984 # Cut _descendantrev here to mitigate the penalty of lazy linkrev
985 985 # adjustment. Otherwise, p._adjustlinkrev() would walk changelog
986 986 # from the topmost introrev (= srcrev) down to p.linkrev() if it
987 987 # isn't an ancestor of the srcrev.
988 988 f._changeid
989 989 pl = f.parents()
990 990
991 991 # Don't return renamed parents if we aren't following.
992 992 if not follow:
993 993 pl = [p for p in pl if p.path() == f.path()]
994 994
995 995 # renamed filectx won't have a filelog yet, so set it
996 996 # from the cache to save time
997 997 for p in pl:
998 998 if not r'_filelog' in p.__dict__:
999 999 p._filelog = getlog(p.path())
1000 1000
1001 1001 return pl
1002 1002
1003 1003 # use linkrev to find the first changeset where self appeared
1004 1004 base = self.introfilectx()
1005 1005 if getattr(base, '_ancestrycontext', None) is None:
1006 1006 cl = self._repo.changelog
1007 1007 if base.rev() is None:
1008 1008 # wctx is not inclusive, but works because _ancestrycontext
1009 1009 # is used to test filelog revisions
1010 1010 ac = cl.ancestors([p.rev() for p in base.parents()],
1011 1011 inclusive=True)
1012 1012 else:
1013 1013 ac = cl.ancestors([base.rev()], inclusive=True)
1014 1014 base._ancestrycontext = ac
1015 1015
1016 1016 return dagop.annotate(base, parents, skiprevs=skiprevs,
1017 1017 diffopts=diffopts)
1018 1018
1019 1019 def ancestors(self, followfirst=False):
1020 1020 visit = {}
1021 1021 c = self
1022 1022 if followfirst:
1023 1023 cut = 1
1024 1024 else:
1025 1025 cut = None
1026 1026
1027 1027 while True:
1028 1028 for parent in c.parents()[:cut]:
1029 1029 visit[(parent.linkrev(), parent.filenode())] = parent
1030 1030 if not visit:
1031 1031 break
1032 1032 c = visit.pop(max(visit))
1033 1033 yield c
1034 1034
1035 1035 def decodeddata(self):
1036 1036 """Returns `data()` after running repository decoding filters.
1037 1037
1038 1038 This is often equivalent to how the data would be expressed on disk.
1039 1039 """
1040 1040 return self._repo.wwritedata(self.path(), self.data())
1041 1041
1042 1042 class filectx(basefilectx):
1043 1043 """A filecontext object makes access to data related to a particular
1044 1044 filerevision convenient."""
1045 1045 def __init__(self, repo, path, changeid=None, fileid=None,
1046 1046 filelog=None, changectx=None):
1047 1047 """changeid can be a changeset revision, node, or tag.
1048 1048 fileid can be a file revision or node."""
1049 1049 self._repo = repo
1050 1050 self._path = path
1051 1051
1052 1052 assert (changeid is not None
1053 1053 or fileid is not None
1054 1054 or changectx is not None), \
1055 1055 ("bad args: changeid=%r, fileid=%r, changectx=%r"
1056 1056 % (changeid, fileid, changectx))
1057 1057
1058 1058 if filelog is not None:
1059 1059 self._filelog = filelog
1060 1060
1061 1061 if changeid is not None:
1062 1062 self._changeid = changeid
1063 1063 if changectx is not None:
1064 1064 self._changectx = changectx
1065 1065 if fileid is not None:
1066 1066 self._fileid = fileid
1067 1067
1068 1068 @propertycache
1069 1069 def _changectx(self):
1070 1070 try:
1071 1071 return changectx(self._repo, self._changeid)
1072 1072 except error.FilteredRepoLookupError:
1073 1073 # Linkrev may point to any revision in the repository. When the
1074 1074 # repository is filtered this may lead to `filectx` trying to build
1075 1075 # `changectx` for filtered revision. In such case we fallback to
1076 1076 # creating `changectx` on the unfiltered version of the reposition.
1077 1077 # This fallback should not be an issue because `changectx` from
1078 1078 # `filectx` are not used in complex operations that care about
1079 1079 # filtering.
1080 1080 #
1081 1081 # This fallback is a cheap and dirty fix that prevent several
1082 1082 # crashes. It does not ensure the behavior is correct. However the
1083 1083 # behavior was not correct before filtering either and "incorrect
1084 1084 # behavior" is seen as better as "crash"
1085 1085 #
1086 1086 # Linkrevs have several serious troubles with filtering that are
1087 1087 # complicated to solve. Proper handling of the issue here should be
1088 1088 # considered when solving linkrev issue are on the table.
1089 1089 return changectx(self._repo.unfiltered(), self._changeid)
1090 1090
1091 1091 def filectx(self, fileid, changeid=None):
1092 1092 '''opens an arbitrary revision of the file without
1093 1093 opening a new filelog'''
1094 1094 return filectx(self._repo, self._path, fileid=fileid,
1095 1095 filelog=self._filelog, changeid=changeid)
1096 1096
1097 1097 def rawdata(self):
1098 1098 return self._filelog.revision(self._filenode, raw=True)
1099 1099
1100 1100 def rawflags(self):
1101 1101 """low-level revlog flags"""
1102 1102 return self._filelog.flags(self._filerev)
1103 1103
1104 1104 def data(self):
1105 1105 try:
1106 1106 return self._filelog.read(self._filenode)
1107 1107 except error.CensoredNodeError:
1108 1108 if self._repo.ui.config("censor", "policy") == "ignore":
1109 1109 return ""
1110 1110 raise error.Abort(_("censored node: %s") % short(self._filenode),
1111 1111 hint=_("set censor.policy to ignore errors"))
1112 1112
1113 1113 def size(self):
1114 1114 return self._filelog.size(self._filerev)
1115 1115
1116 1116 @propertycache
1117 1117 def _copied(self):
1118 1118 """check if file was actually renamed in this changeset revision
1119 1119
1120 1120 If rename logged in file revision, we report copy for changeset only
1121 1121 if file revisions linkrev points back to the changeset in question
1122 1122 or both changeset parents contain different file revisions.
1123 1123 """
1124 1124
1125 1125 renamed = self._filelog.renamed(self._filenode)
1126 1126 if not renamed:
1127 1127 return renamed
1128 1128
1129 1129 if self.rev() == self.linkrev():
1130 1130 return renamed
1131 1131
1132 1132 name = self.path()
1133 1133 fnode = self._filenode
1134 1134 for p in self._changectx.parents():
1135 1135 try:
1136 1136 if fnode == p.filenode(name):
1137 1137 return None
1138 1138 except error.LookupError:
1139 1139 pass
1140 1140 return renamed
1141 1141
1142 1142 def children(self):
1143 1143 # hard for renames
1144 1144 c = self._filelog.children(self._filenode)
1145 1145 return [filectx(self._repo, self._path, fileid=x,
1146 1146 filelog=self._filelog) for x in c]
1147 1147
1148 1148 class committablectx(basectx):
1149 1149 """A committablectx object provides common functionality for a context that
1150 1150 wants the ability to commit, e.g. workingctx or memctx."""
1151 1151 def __init__(self, repo, text="", user=None, date=None, extra=None,
1152 1152 changes=None):
1153 1153 self._repo = repo
1154 1154 self._rev = None
1155 1155 self._node = None
1156 1156 self._text = text
1157 1157 if date:
1158 1158 self._date = dateutil.parsedate(date)
1159 1159 if user:
1160 1160 self._user = user
1161 1161 if changes:
1162 1162 self._status = changes
1163 1163
1164 1164 self._extra = {}
1165 1165 if extra:
1166 1166 self._extra = extra.copy()
1167 1167 if 'branch' not in self._extra:
1168 1168 try:
1169 1169 branch = encoding.fromlocal(self._repo.dirstate.branch())
1170 1170 except UnicodeDecodeError:
1171 1171 raise error.Abort(_('branch name not in UTF-8!'))
1172 1172 self._extra['branch'] = branch
1173 1173 if self._extra['branch'] == '':
1174 1174 self._extra['branch'] = 'default'
1175 1175
1176 1176 def __bytes__(self):
1177 1177 return bytes(self._parents[0]) + "+"
1178 1178
1179 1179 __str__ = encoding.strmethod(__bytes__)
1180 1180
1181 1181 def __nonzero__(self):
1182 1182 return True
1183 1183
1184 1184 __bool__ = __nonzero__
1185 1185
1186 1186 def _buildflagfunc(self):
1187 1187 # Create a fallback function for getting file flags when the
1188 1188 # filesystem doesn't support them
1189 1189
1190 1190 copiesget = self._repo.dirstate.copies().get
1191 1191 parents = self.parents()
1192 1192 if len(parents) < 2:
1193 1193 # when we have one parent, it's easy: copy from parent
1194 1194 man = parents[0].manifest()
1195 1195 def func(f):
1196 1196 f = copiesget(f, f)
1197 1197 return man.flags(f)
1198 1198 else:
1199 1199 # merges are tricky: we try to reconstruct the unstored
1200 1200 # result from the merge (issue1802)
1201 1201 p1, p2 = parents
1202 1202 pa = p1.ancestor(p2)
1203 1203 m1, m2, ma = p1.manifest(), p2.manifest(), pa.manifest()
1204 1204
1205 1205 def func(f):
1206 1206 f = copiesget(f, f) # may be wrong for merges with copies
1207 1207 fl1, fl2, fla = m1.flags(f), m2.flags(f), ma.flags(f)
1208 1208 if fl1 == fl2:
1209 1209 return fl1
1210 1210 if fl1 == fla:
1211 1211 return fl2
1212 1212 if fl2 == fla:
1213 1213 return fl1
1214 1214 return '' # punt for conflicts
1215 1215
1216 1216 return func
1217 1217
1218 1218 @propertycache
1219 1219 def _flagfunc(self):
1220 1220 return self._repo.dirstate.flagfunc(self._buildflagfunc)
1221 1221
1222 1222 @propertycache
1223 1223 def _status(self):
1224 1224 return self._repo.status()
1225 1225
1226 1226 @propertycache
1227 1227 def _user(self):
1228 1228 return self._repo.ui.username()
1229 1229
1230 1230 @propertycache
1231 1231 def _date(self):
1232 1232 ui = self._repo.ui
1233 1233 date = ui.configdate('devel', 'default-date')
1234 1234 if date is None:
1235 1235 date = dateutil.makedate()
1236 1236 return date
1237 1237
1238 1238 def subrev(self, subpath):
1239 1239 return None
1240 1240
1241 1241 def manifestnode(self):
1242 1242 return None
1243 1243 def user(self):
1244 1244 return self._user or self._repo.ui.username()
1245 1245 def date(self):
1246 1246 return self._date
1247 1247 def description(self):
1248 1248 return self._text
1249 1249 def files(self):
1250 1250 return sorted(self._status.modified + self._status.added +
1251 1251 self._status.removed)
1252 1252
1253 1253 def modified(self):
1254 1254 return self._status.modified
1255 1255 def added(self):
1256 1256 return self._status.added
1257 1257 def removed(self):
1258 1258 return self._status.removed
1259 1259 def deleted(self):
1260 1260 return self._status.deleted
1261 1261 def branch(self):
1262 1262 return encoding.tolocal(self._extra['branch'])
1263 1263 def closesbranch(self):
1264 1264 return 'close' in self._extra
1265 1265 def extra(self):
1266 1266 return self._extra
1267 1267
1268 1268 def isinmemory(self):
1269 1269 return False
1270 1270
1271 1271 def tags(self):
1272 1272 return []
1273 1273
1274 1274 def bookmarks(self):
1275 1275 b = []
1276 1276 for p in self.parents():
1277 1277 b.extend(p.bookmarks())
1278 1278 return b
1279 1279
1280 1280 def phase(self):
1281 1281 phase = phases.draft # default phase to draft
1282 1282 for p in self.parents():
1283 1283 phase = max(phase, p.phase())
1284 1284 return phase
1285 1285
1286 1286 def hidden(self):
1287 1287 return False
1288 1288
1289 1289 def children(self):
1290 1290 return []
1291 1291
1292 1292 def flags(self, path):
1293 1293 if r'_manifest' in self.__dict__:
1294 1294 try:
1295 1295 return self._manifest.flags(path)
1296 1296 except KeyError:
1297 1297 return ''
1298 1298
1299 1299 try:
1300 1300 return self._flagfunc(path)
1301 1301 except OSError:
1302 1302 return ''
1303 1303
1304 1304 def ancestor(self, c2):
1305 1305 """return the "best" ancestor context of self and c2"""
1306 1306 return self._parents[0].ancestor(c2) # punt on two parents for now
1307 1307
1308 1308 def walk(self, match):
1309 1309 '''Generates matching file names.'''
1310 1310 return sorted(self._repo.dirstate.walk(match,
1311 1311 subrepos=sorted(self.substate),
1312 1312 unknown=True, ignored=False))
1313 1313
1314 1314 def matches(self, match):
1315 1315 return sorted(self._repo.dirstate.matches(match))
1316 1316
1317 1317 def ancestors(self):
1318 1318 for p in self._parents:
1319 1319 yield p
1320 1320 for a in self._repo.changelog.ancestors(
1321 1321 [p.rev() for p in self._parents]):
1322 1322 yield changectx(self._repo, a)
1323 1323
1324 1324 def markcommitted(self, node):
1325 1325 """Perform post-commit cleanup necessary after committing this ctx
1326 1326
1327 1327 Specifically, this updates backing stores this working context
1328 1328 wraps to reflect the fact that the changes reflected by this
1329 1329 workingctx have been committed. For example, it marks
1330 1330 modified and added files as normal in the dirstate.
1331 1331
1332 1332 """
1333 1333
1334 1334 with self._repo.dirstate.parentchange():
1335 1335 for f in self.modified() + self.added():
1336 1336 self._repo.dirstate.normal(f)
1337 1337 for f in self.removed():
1338 1338 self._repo.dirstate.drop(f)
1339 1339 self._repo.dirstate.setparents(node)
1340 1340
1341 1341 # write changes out explicitly, because nesting wlock at
1342 1342 # runtime may prevent 'wlock.release()' in 'repo.commit()'
1343 1343 # from immediately doing so for subsequent changing files
1344 1344 self._repo.dirstate.write(self._repo.currenttransaction())
1345 1345
1346 1346 def dirty(self, missing=False, merge=True, branch=True):
1347 1347 return False
1348 1348
1349 1349 class workingctx(committablectx):
1350 1350 """A workingctx object makes access to data related to
1351 1351 the current working directory convenient.
1352 1352 date - any valid date string or (unixtime, offset), or None.
1353 1353 user - username string, or None.
1354 1354 extra - a dictionary of extra values, or None.
1355 1355 changes - a list of file lists as returned by localrepo.status()
1356 1356 or None to use the repository status.
1357 1357 """
1358 1358 def __init__(self, repo, text="", user=None, date=None, extra=None,
1359 1359 changes=None):
1360 1360 super(workingctx, self).__init__(repo, text, user, date, extra, changes)
1361 1361
1362 1362 def __iter__(self):
1363 1363 d = self._repo.dirstate
1364 1364 for f in d:
1365 1365 if d[f] != 'r':
1366 1366 yield f
1367 1367
1368 1368 def __contains__(self, key):
1369 1369 return self._repo.dirstate[key] not in "?r"
1370 1370
1371 1371 def hex(self):
1372 1372 return hex(wdirid)
1373 1373
1374 1374 @propertycache
1375 1375 def _parents(self):
1376 1376 p = self._repo.dirstate.parents()
1377 1377 if p[1] == nullid:
1378 1378 p = p[:-1]
1379 1379 return [changectx(self._repo, x) for x in p]
1380 1380
1381 1381 def filectx(self, path, filelog=None):
1382 1382 """get a file context from the working directory"""
1383 1383 return workingfilectx(self._repo, path, workingctx=self,
1384 1384 filelog=filelog)
1385 1385
1386 1386 def dirty(self, missing=False, merge=True, branch=True):
1387 1387 "check whether a working directory is modified"
1388 1388 # check subrepos first
1389 1389 for s in sorted(self.substate):
1390 1390 if self.sub(s).dirty(missing=missing):
1391 1391 return True
1392 1392 # check current working dir
1393 1393 return ((merge and self.p2()) or
1394 1394 (branch and self.branch() != self.p1().branch()) or
1395 1395 self.modified() or self.added() or self.removed() or
1396 1396 (missing and self.deleted()))
1397 1397
1398 1398 def add(self, list, prefix=""):
1399 1399 with self._repo.wlock():
1400 1400 ui, ds = self._repo.ui, self._repo.dirstate
1401 1401 uipath = lambda f: ds.pathto(pathutil.join(prefix, f))
1402 1402 rejected = []
1403 1403 lstat = self._repo.wvfs.lstat
1404 1404 for f in list:
1405 1405 # ds.pathto() returns an absolute file when this is invoked from
1406 1406 # the keyword extension. That gets flagged as non-portable on
1407 1407 # Windows, since it contains the drive letter and colon.
1408 1408 scmutil.checkportable(ui, os.path.join(prefix, f))
1409 1409 try:
1410 1410 st = lstat(f)
1411 1411 except OSError:
1412 1412 ui.warn(_("%s does not exist!\n") % uipath(f))
1413 1413 rejected.append(f)
1414 1414 continue
1415 1415 if st.st_size > 10000000:
1416 1416 ui.warn(_("%s: up to %d MB of RAM may be required "
1417 1417 "to manage this file\n"
1418 1418 "(use 'hg revert %s' to cancel the "
1419 1419 "pending addition)\n")
1420 1420 % (f, 3 * st.st_size // 1000000, uipath(f)))
1421 1421 if not (stat.S_ISREG(st.st_mode) or stat.S_ISLNK(st.st_mode)):
1422 1422 ui.warn(_("%s not added: only files and symlinks "
1423 1423 "supported currently\n") % uipath(f))
1424 1424 rejected.append(f)
1425 1425 elif ds[f] in 'amn':
1426 1426 ui.warn(_("%s already tracked!\n") % uipath(f))
1427 1427 elif ds[f] == 'r':
1428 1428 ds.normallookup(f)
1429 1429 else:
1430 1430 ds.add(f)
1431 1431 return rejected
1432 1432
1433 1433 def forget(self, files, prefix=""):
1434 1434 with self._repo.wlock():
1435 1435 ds = self._repo.dirstate
1436 1436 uipath = lambda f: ds.pathto(pathutil.join(prefix, f))
1437 1437 rejected = []
1438 1438 for f in files:
1439 1439 if f not in self._repo.dirstate:
1440 1440 self._repo.ui.warn(_("%s not tracked!\n") % uipath(f))
1441 1441 rejected.append(f)
1442 1442 elif self._repo.dirstate[f] != 'a':
1443 1443 self._repo.dirstate.remove(f)
1444 1444 else:
1445 1445 self._repo.dirstate.drop(f)
1446 1446 return rejected
1447 1447
1448 1448 def undelete(self, list):
1449 1449 pctxs = self.parents()
1450 1450 with self._repo.wlock():
1451 1451 ds = self._repo.dirstate
1452 1452 for f in list:
1453 1453 if self._repo.dirstate[f] != 'r':
1454 1454 self._repo.ui.warn(_("%s not removed!\n") % ds.pathto(f))
1455 1455 else:
1456 1456 fctx = f in pctxs[0] and pctxs[0][f] or pctxs[1][f]
1457 1457 t = fctx.data()
1458 1458 self._repo.wwrite(f, t, fctx.flags())
1459 1459 self._repo.dirstate.normal(f)
1460 1460
1461 1461 def copy(self, source, dest):
1462 1462 try:
1463 1463 st = self._repo.wvfs.lstat(dest)
1464 1464 except OSError as err:
1465 1465 if err.errno != errno.ENOENT:
1466 1466 raise
1467 1467 self._repo.ui.warn(_("%s does not exist!\n")
1468 1468 % self._repo.dirstate.pathto(dest))
1469 1469 return
1470 1470 if not (stat.S_ISREG(st.st_mode) or stat.S_ISLNK(st.st_mode)):
1471 1471 self._repo.ui.warn(_("copy failed: %s is not a file or a "
1472 1472 "symbolic link\n")
1473 1473 % self._repo.dirstate.pathto(dest))
1474 1474 else:
1475 1475 with self._repo.wlock():
1476 1476 if self._repo.dirstate[dest] in '?':
1477 1477 self._repo.dirstate.add(dest)
1478 1478 elif self._repo.dirstate[dest] in 'r':
1479 1479 self._repo.dirstate.normallookup(dest)
1480 1480 self._repo.dirstate.copy(source, dest)
1481 1481
1482 1482 def match(self, pats=None, include=None, exclude=None, default='glob',
1483 1483 listsubrepos=False, badfn=None):
1484 1484 r = self._repo
1485 1485
1486 1486 # Only a case insensitive filesystem needs magic to translate user input
1487 1487 # to actual case in the filesystem.
1488 1488 icasefs = not util.fscasesensitive(r.root)
1489 1489 return matchmod.match(r.root, r.getcwd(), pats, include, exclude,
1490 1490 default, auditor=r.auditor, ctx=self,
1491 1491 listsubrepos=listsubrepos, badfn=badfn,
1492 1492 icasefs=icasefs)
1493 1493
1494 1494 def _filtersuspectsymlink(self, files):
1495 1495 if not files or self._repo.dirstate._checklink:
1496 1496 return files
1497 1497
1498 1498 # Symlink placeholders may get non-symlink-like contents
1499 1499 # via user error or dereferencing by NFS or Samba servers,
1500 1500 # so we filter out any placeholders that don't look like a
1501 1501 # symlink
1502 1502 sane = []
1503 1503 for f in files:
1504 1504 if self.flags(f) == 'l':
1505 1505 d = self[f].data()
1506 1506 if (d == '' or len(d) >= 1024 or '\n' in d
1507 1507 or stringutil.binary(d)):
1508 1508 self._repo.ui.debug('ignoring suspect symlink placeholder'
1509 1509 ' "%s"\n' % f)
1510 1510 continue
1511 1511 sane.append(f)
1512 1512 return sane
1513 1513
1514 1514 def _checklookup(self, files):
1515 1515 # check for any possibly clean files
1516 1516 if not files:
1517 1517 return [], [], []
1518 1518
1519 1519 modified = []
1520 1520 deleted = []
1521 1521 fixup = []
1522 1522 pctx = self._parents[0]
1523 1523 # do a full compare of any files that might have changed
1524 1524 for f in sorted(files):
1525 1525 try:
1526 1526 # This will return True for a file that got replaced by a
1527 1527 # directory in the interim, but fixing that is pretty hard.
1528 1528 if (f not in pctx or self.flags(f) != pctx.flags(f)
1529 1529 or pctx[f].cmp(self[f])):
1530 1530 modified.append(f)
1531 1531 else:
1532 1532 fixup.append(f)
1533 1533 except (IOError, OSError):
1534 1534 # A file become inaccessible in between? Mark it as deleted,
1535 1535 # matching dirstate behavior (issue5584).
1536 1536 # The dirstate has more complex behavior around whether a
1537 1537 # missing file matches a directory, etc, but we don't need to
1538 1538 # bother with that: if f has made it to this point, we're sure
1539 1539 # it's in the dirstate.
1540 1540 deleted.append(f)
1541 1541
1542 1542 return modified, deleted, fixup
1543 1543
1544 1544 def _poststatusfixup(self, status, fixup):
1545 1545 """update dirstate for files that are actually clean"""
1546 1546 poststatus = self._repo.postdsstatus()
1547 1547 if fixup or poststatus:
1548 1548 try:
1549 1549 oldid = self._repo.dirstate.identity()
1550 1550
1551 1551 # updating the dirstate is optional
1552 1552 # so we don't wait on the lock
1553 1553 # wlock can invalidate the dirstate, so cache normal _after_
1554 1554 # taking the lock
1555 1555 with self._repo.wlock(False):
1556 1556 if self._repo.dirstate.identity() == oldid:
1557 1557 if fixup:
1558 1558 normal = self._repo.dirstate.normal
1559 1559 for f in fixup:
1560 1560 normal(f)
1561 1561 # write changes out explicitly, because nesting
1562 1562 # wlock at runtime may prevent 'wlock.release()'
1563 1563 # after this block from doing so for subsequent
1564 1564 # changing files
1565 1565 tr = self._repo.currenttransaction()
1566 1566 self._repo.dirstate.write(tr)
1567 1567
1568 1568 if poststatus:
1569 1569 for ps in poststatus:
1570 1570 ps(self, status)
1571 1571 else:
1572 1572 # in this case, writing changes out breaks
1573 1573 # consistency, because .hg/dirstate was
1574 1574 # already changed simultaneously after last
1575 1575 # caching (see also issue5584 for detail)
1576 1576 self._repo.ui.debug('skip updating dirstate: '
1577 1577 'identity mismatch\n')
1578 1578 except error.LockError:
1579 1579 pass
1580 1580 finally:
1581 1581 # Even if the wlock couldn't be grabbed, clear out the list.
1582 1582 self._repo.clearpostdsstatus()
1583 1583
1584 1584 def _dirstatestatus(self, match, ignored=False, clean=False, unknown=False):
1585 1585 '''Gets the status from the dirstate -- internal use only.'''
1586 1586 subrepos = []
1587 1587 if '.hgsub' in self:
1588 1588 subrepos = sorted(self.substate)
1589 1589 cmp, s = self._repo.dirstate.status(match, subrepos, ignored=ignored,
1590 1590 clean=clean, unknown=unknown)
1591 1591
1592 1592 # check for any possibly clean files
1593 1593 fixup = []
1594 1594 if cmp:
1595 1595 modified2, deleted2, fixup = self._checklookup(cmp)
1596 1596 s.modified.extend(modified2)
1597 1597 s.deleted.extend(deleted2)
1598 1598
1599 1599 if fixup and clean:
1600 1600 s.clean.extend(fixup)
1601 1601
1602 1602 self._poststatusfixup(s, fixup)
1603 1603
1604 1604 if match.always():
1605 1605 # cache for performance
1606 1606 if s.unknown or s.ignored or s.clean:
1607 1607 # "_status" is cached with list*=False in the normal route
1608 1608 self._status = scmutil.status(s.modified, s.added, s.removed,
1609 1609 s.deleted, [], [], [])
1610 1610 else:
1611 1611 self._status = s
1612 1612
1613 1613 return s
1614 1614
1615 1615 @propertycache
1616 1616 def _manifest(self):
1617 1617 """generate a manifest corresponding to the values in self._status
1618 1618
1619 1619 This reuse the file nodeid from parent, but we use special node
1620 1620 identifiers for added and modified files. This is used by manifests
1621 1621 merge to see that files are different and by update logic to avoid
1622 1622 deleting newly added files.
1623 1623 """
1624 1624 return self._buildstatusmanifest(self._status)
1625 1625
1626 1626 def _buildstatusmanifest(self, status):
1627 1627 """Builds a manifest that includes the given status results."""
1628 1628 parents = self.parents()
1629 1629
1630 1630 man = parents[0].manifest().copy()
1631 1631
1632 1632 ff = self._flagfunc
1633 1633 for i, l in ((addednodeid, status.added),
1634 1634 (modifiednodeid, status.modified)):
1635 1635 for f in l:
1636 1636 man[f] = i
1637 1637 try:
1638 1638 man.setflag(f, ff(f))
1639 1639 except OSError:
1640 1640 pass
1641 1641
1642 1642 for f in status.deleted + status.removed:
1643 1643 if f in man:
1644 1644 del man[f]
1645 1645
1646 1646 return man
1647 1647
1648 1648 def _buildstatus(self, other, s, match, listignored, listclean,
1649 1649 listunknown):
1650 1650 """build a status with respect to another context
1651 1651
1652 1652 This includes logic for maintaining the fast path of status when
1653 1653 comparing the working directory against its parent, which is to skip
1654 1654 building a new manifest if self (working directory) is not comparing
1655 1655 against its parent (repo['.']).
1656 1656 """
1657 1657 s = self._dirstatestatus(match, listignored, listclean, listunknown)
1658 1658 # Filter out symlinks that, in the case of FAT32 and NTFS filesystems,
1659 1659 # might have accidentally ended up with the entire contents of the file
1660 1660 # they are supposed to be linking to.
1661 1661 s.modified[:] = self._filtersuspectsymlink(s.modified)
1662 1662 if other != self._repo['.']:
1663 1663 s = super(workingctx, self)._buildstatus(other, s, match,
1664 1664 listignored, listclean,
1665 1665 listunknown)
1666 1666 return s
1667 1667
1668 1668 def _matchstatus(self, other, match):
1669 1669 """override the match method with a filter for directory patterns
1670 1670
1671 1671 We use inheritance to customize the match.bad method only in cases of
1672 1672 workingctx since it belongs only to the working directory when
1673 1673 comparing against the parent changeset.
1674 1674
1675 1675 If we aren't comparing against the working directory's parent, then we
1676 1676 just use the default match object sent to us.
1677 1677 """
1678 1678 if other != self._repo['.']:
1679 1679 def bad(f, msg):
1680 1680 # 'f' may be a directory pattern from 'match.files()',
1681 1681 # so 'f not in ctx1' is not enough
1682 1682 if f not in other and not other.hasdir(f):
1683 1683 self._repo.ui.warn('%s: %s\n' %
1684 1684 (self._repo.dirstate.pathto(f), msg))
1685 1685 match.bad = bad
1686 1686 return match
1687 1687
1688 1688 def markcommitted(self, node):
1689 1689 super(workingctx, self).markcommitted(node)
1690 1690
1691 1691 sparse.aftercommit(self._repo, node)
1692 1692
1693 1693 class committablefilectx(basefilectx):
1694 1694 """A committablefilectx provides common functionality for a file context
1695 1695 that wants the ability to commit, e.g. workingfilectx or memfilectx."""
1696 1696 def __init__(self, repo, path, filelog=None, ctx=None):
1697 1697 self._repo = repo
1698 1698 self._path = path
1699 1699 self._changeid = None
1700 1700 self._filerev = self._filenode = None
1701 1701
1702 1702 if filelog is not None:
1703 1703 self._filelog = filelog
1704 1704 if ctx:
1705 1705 self._changectx = ctx
1706 1706
1707 1707 def __nonzero__(self):
1708 1708 return True
1709 1709
1710 1710 __bool__ = __nonzero__
1711 1711
1712 1712 def linkrev(self):
1713 1713 # linked to self._changectx no matter if file is modified or not
1714 1714 return self.rev()
1715 1715
1716 1716 def parents(self):
1717 1717 '''return parent filectxs, following copies if necessary'''
1718 1718 def filenode(ctx, path):
1719 1719 return ctx._manifest.get(path, nullid)
1720 1720
1721 1721 path = self._path
1722 1722 fl = self._filelog
1723 1723 pcl = self._changectx._parents
1724 1724 renamed = self.renamed()
1725 1725
1726 1726 if renamed:
1727 1727 pl = [renamed + (None,)]
1728 1728 else:
1729 1729 pl = [(path, filenode(pcl[0], path), fl)]
1730 1730
1731 1731 for pc in pcl[1:]:
1732 1732 pl.append((path, filenode(pc, path), fl))
1733 1733
1734 1734 return [self._parentfilectx(p, fileid=n, filelog=l)
1735 1735 for p, n, l in pl if n != nullid]
1736 1736
1737 1737 def children(self):
1738 1738 return []
1739 1739
1740 1740 class workingfilectx(committablefilectx):
1741 1741 """A workingfilectx object makes access to data related to a particular
1742 1742 file in the working directory convenient."""
1743 1743 def __init__(self, repo, path, filelog=None, workingctx=None):
1744 1744 super(workingfilectx, self).__init__(repo, path, filelog, workingctx)
1745 1745
1746 1746 @propertycache
1747 1747 def _changectx(self):
1748 1748 return workingctx(self._repo)
1749 1749
1750 1750 def data(self):
1751 1751 return self._repo.wread(self._path)
1752 1752 def renamed(self):
1753 1753 rp = self._repo.dirstate.copied(self._path)
1754 1754 if not rp:
1755 1755 return None
1756 1756 return rp, self._changectx._parents[0]._manifest.get(rp, nullid)
1757 1757
1758 1758 def size(self):
1759 1759 return self._repo.wvfs.lstat(self._path).st_size
1760 1760 def date(self):
1761 1761 t, tz = self._changectx.date()
1762 1762 try:
1763 1763 return (self._repo.wvfs.lstat(self._path)[stat.ST_MTIME], tz)
1764 1764 except OSError as err:
1765 1765 if err.errno != errno.ENOENT:
1766 1766 raise
1767 1767 return (t, tz)
1768 1768
1769 1769 def exists(self):
1770 1770 return self._repo.wvfs.exists(self._path)
1771 1771
1772 1772 def lexists(self):
1773 1773 return self._repo.wvfs.lexists(self._path)
1774 1774
1775 1775 def audit(self):
1776 1776 return self._repo.wvfs.audit(self._path)
1777 1777
1778 1778 def cmp(self, fctx):
1779 1779 """compare with other file context
1780 1780
1781 1781 returns True if different than fctx.
1782 1782 """
1783 1783 # fctx should be a filectx (not a workingfilectx)
1784 1784 # invert comparison to reuse the same code path
1785 1785 return fctx.cmp(self)
1786 1786
1787 1787 def remove(self, ignoremissing=False):
1788 1788 """wraps unlink for a repo's working directory"""
1789 1789 self._repo.wvfs.unlinkpath(self._path, ignoremissing=ignoremissing)
1790 1790
1791 1791 def write(self, data, flags, backgroundclose=False, **kwargs):
1792 1792 """wraps repo.wwrite"""
1793 1793 self._repo.wwrite(self._path, data, flags,
1794 1794 backgroundclose=backgroundclose,
1795 1795 **kwargs)
1796 1796
1797 1797 def markcopied(self, src):
1798 1798 """marks this file a copy of `src`"""
1799 1799 if self._repo.dirstate[self._path] in "nma":
1800 1800 self._repo.dirstate.copy(src, self._path)
1801 1801
1802 1802 def clearunknown(self):
1803 1803 """Removes conflicting items in the working directory so that
1804 1804 ``write()`` can be called successfully.
1805 1805 """
1806 1806 wvfs = self._repo.wvfs
1807 1807 f = self._path
1808 1808 wvfs.audit(f)
1809 1809 if wvfs.isdir(f) and not wvfs.islink(f):
1810 1810 wvfs.rmtree(f, forcibly=True)
1811 1811 if self._repo.ui.configbool('experimental', 'merge.checkpathconflicts'):
1812 1812 for p in reversed(list(util.finddirs(f))):
1813 1813 if wvfs.isfileorlink(p):
1814 1814 wvfs.unlink(p)
1815 1815 break
1816 1816
1817 1817 def setflags(self, l, x):
1818 1818 self._repo.wvfs.setflags(self._path, l, x)
1819 1819
1820 1820 class overlayworkingctx(committablectx):
1821 1821 """Wraps another mutable context with a write-back cache that can be
1822 1822 converted into a commit context.
1823 1823
1824 1824 self._cache[path] maps to a dict with keys: {
1825 1825 'exists': bool?
1826 1826 'date': date?
1827 1827 'data': str?
1828 1828 'flags': str?
1829 1829 'copied': str? (path or None)
1830 1830 }
1831 1831 If `exists` is True, `flags` must be non-None and 'date' is non-None. If it
1832 1832 is `False`, the file was deleted.
1833 1833 """
1834 1834
1835 1835 def __init__(self, repo):
1836 1836 super(overlayworkingctx, self).__init__(repo)
1837 1837 self._repo = repo
1838 1838 self.clean()
1839 1839
1840 1840 def setbase(self, wrappedctx):
1841 1841 self._wrappedctx = wrappedctx
1842 1842 self._parents = [wrappedctx]
1843 1843 # Drop old manifest cache as it is now out of date.
1844 1844 # This is necessary when, e.g., rebasing several nodes with one
1845 1845 # ``overlayworkingctx`` (e.g. with --collapse).
1846 1846 util.clearcachedproperty(self, '_manifest')
1847 1847
1848 1848 def data(self, path):
1849 1849 if self.isdirty(path):
1850 1850 if self._cache[path]['exists']:
1851 1851 if self._cache[path]['data']:
1852 1852 return self._cache[path]['data']
1853 1853 else:
1854 1854 # Must fallback here, too, because we only set flags.
1855 1855 return self._wrappedctx[path].data()
1856 1856 else:
1857 1857 raise error.ProgrammingError("No such file or directory: %s" %
1858 1858 path)
1859 1859 else:
1860 1860 return self._wrappedctx[path].data()
1861 1861
1862 1862 @propertycache
1863 1863 def _manifest(self):
1864 1864 parents = self.parents()
1865 1865 man = parents[0].manifest().copy()
1866 1866
1867 1867 flag = self._flagfunc
1868 1868 for path in self.added():
1869 1869 man[path] = addednodeid
1870 1870 man.setflag(path, flag(path))
1871 1871 for path in self.modified():
1872 1872 man[path] = modifiednodeid
1873 1873 man.setflag(path, flag(path))
1874 1874 for path in self.removed():
1875 1875 del man[path]
1876 1876 return man
1877 1877
1878 1878 @propertycache
1879 1879 def _flagfunc(self):
1880 1880 def f(path):
1881 1881 return self._cache[path]['flags']
1882 1882 return f
1883 1883
1884 1884 def files(self):
1885 1885 return sorted(self.added() + self.modified() + self.removed())
1886 1886
1887 1887 def modified(self):
1888 1888 return [f for f in self._cache.keys() if self._cache[f]['exists'] and
1889 1889 self._existsinparent(f)]
1890 1890
1891 1891 def added(self):
1892 1892 return [f for f in self._cache.keys() if self._cache[f]['exists'] and
1893 1893 not self._existsinparent(f)]
1894 1894
1895 1895 def removed(self):
1896 1896 return [f for f in self._cache.keys() if
1897 1897 not self._cache[f]['exists'] and self._existsinparent(f)]
1898 1898
1899 1899 def isinmemory(self):
1900 1900 return True
1901 1901
1902 1902 def filedate(self, path):
1903 1903 if self.isdirty(path):
1904 1904 return self._cache[path]['date']
1905 1905 else:
1906 1906 return self._wrappedctx[path].date()
1907 1907
1908 1908 def markcopied(self, path, origin):
1909 1909 if self.isdirty(path):
1910 1910 self._cache[path]['copied'] = origin
1911 1911 else:
1912 1912 raise error.ProgrammingError('markcopied() called on clean context')
1913 1913
1914 1914 def copydata(self, path):
1915 1915 if self.isdirty(path):
1916 1916 return self._cache[path]['copied']
1917 1917 else:
1918 1918 raise error.ProgrammingError('copydata() called on clean context')
1919 1919
1920 1920 def flags(self, path):
1921 1921 if self.isdirty(path):
1922 1922 if self._cache[path]['exists']:
1923 1923 return self._cache[path]['flags']
1924 1924 else:
1925 1925 raise error.ProgrammingError("No such file or directory: %s" %
1926 1926 self._path)
1927 1927 else:
1928 1928 return self._wrappedctx[path].flags()
1929 1929
1930 1930 def _existsinparent(self, path):
1931 1931 try:
1932 1932 # ``commitctx` raises a ``ManifestLookupError`` if a path does not
1933 1933 # exist, unlike ``workingctx``, which returns a ``workingfilectx``
1934 1934 # with an ``exists()`` function.
1935 1935 self._wrappedctx[path]
1936 1936 return True
1937 1937 except error.ManifestLookupError:
1938 1938 return False
1939 1939
1940 1940 def _auditconflicts(self, path):
1941 1941 """Replicates conflict checks done by wvfs.write().
1942 1942
1943 1943 Since we never write to the filesystem and never call `applyupdates` in
1944 1944 IMM, we'll never check that a path is actually writable -- e.g., because
1945 1945 it adds `a/foo`, but `a` is actually a file in the other commit.
1946 1946 """
1947 1947 def fail(path, component):
1948 1948 # p1() is the base and we're receiving "writes" for p2()'s
1949 1949 # files.
1950 1950 if 'l' in self.p1()[component].flags():
1951 1951 raise error.Abort("error: %s conflicts with symlink %s "
1952 1952 "in %s." % (path, component,
1953 1953 self.p1().rev()))
1954 1954 else:
1955 1955 raise error.Abort("error: '%s' conflicts with file '%s' in "
1956 1956 "%s." % (path, component,
1957 1957 self.p1().rev()))
1958 1958
1959 1959 # Test that each new directory to be created to write this path from p2
1960 1960 # is not a file in p1.
1961 1961 components = path.split('/')
1962 1962 for i in xrange(len(components)):
1963 1963 component = "/".join(components[0:i])
1964 1964 if component in self.p1():
1965 1965 fail(path, component)
1966 1966
1967 1967 # Test the other direction -- that this path from p2 isn't a directory
1968 1968 # in p1 (test that p1 doesn't any paths matching `path/*`).
1969 1969 match = matchmod.match('/', '', [path + '/'], default=b'relpath')
1970 1970 matches = self.p1().manifest().matches(match)
1971 1971 if len(matches) > 0:
1972 1972 if len(matches) == 1 and matches.keys()[0] == path:
1973 1973 return
1974 1974 raise error.Abort("error: file '%s' cannot be written because "
1975 1975 " '%s/' is a folder in %s (containing %d "
1976 1976 "entries: %s)"
1977 1977 % (path, path, self.p1(), len(matches),
1978 1978 ', '.join(matches.keys())))
1979 1979
1980 1980 def write(self, path, data, flags='', **kwargs):
1981 1981 if data is None:
1982 1982 raise error.ProgrammingError("data must be non-None")
1983 1983 self._auditconflicts(path)
1984 1984 self._markdirty(path, exists=True, data=data, date=dateutil.makedate(),
1985 1985 flags=flags)
1986 1986
1987 1987 def setflags(self, path, l, x):
1988 1988 self._markdirty(path, exists=True, date=dateutil.makedate(),
1989 1989 flags=(l and 'l' or '') + (x and 'x' or ''))
1990 1990
1991 1991 def remove(self, path):
1992 1992 self._markdirty(path, exists=False)
1993 1993
1994 1994 def exists(self, path):
1995 1995 """exists behaves like `lexists`, but needs to follow symlinks and
1996 1996 return False if they are broken.
1997 1997 """
1998 1998 if self.isdirty(path):
1999 1999 # If this path exists and is a symlink, "follow" it by calling
2000 2000 # exists on the destination path.
2001 2001 if (self._cache[path]['exists'] and
2002 2002 'l' in self._cache[path]['flags']):
2003 2003 return self.exists(self._cache[path]['data'].strip())
2004 2004 else:
2005 2005 return self._cache[path]['exists']
2006 2006
2007 2007 return self._existsinparent(path)
2008 2008
2009 2009 def lexists(self, path):
2010 2010 """lexists returns True if the path exists"""
2011 2011 if self.isdirty(path):
2012 2012 return self._cache[path]['exists']
2013 2013
2014 2014 return self._existsinparent(path)
2015 2015
2016 2016 def size(self, path):
2017 2017 if self.isdirty(path):
2018 2018 if self._cache[path]['exists']:
2019 2019 return len(self._cache[path]['data'])
2020 2020 else:
2021 2021 raise error.ProgrammingError("No such file or directory: %s" %
2022 2022 self._path)
2023 2023 return self._wrappedctx[path].size()
2024 2024
2025 2025 def tomemctx(self, text, branch=None, extra=None, date=None, parents=None,
2026 2026 user=None, editor=None):
2027 2027 """Converts this ``overlayworkingctx`` into a ``memctx`` ready to be
2028 2028 committed.
2029 2029
2030 2030 ``text`` is the commit message.
2031 2031 ``parents`` (optional) are rev numbers.
2032 2032 """
2033 2033 # Default parents to the wrapped contexts' if not passed.
2034 2034 if parents is None:
2035 2035 parents = self._wrappedctx.parents()
2036 2036 if len(parents) == 1:
2037 2037 parents = (parents[0], None)
2038 2038
2039 2039 # ``parents`` is passed as rev numbers; convert to ``commitctxs``.
2040 2040 if parents[1] is None:
2041 2041 parents = (self._repo[parents[0]], None)
2042 2042 else:
2043 2043 parents = (self._repo[parents[0]], self._repo[parents[1]])
2044 2044
2045 2045 files = self._cache.keys()
2046 2046 def getfile(repo, memctx, path):
2047 2047 if self._cache[path]['exists']:
2048 2048 return memfilectx(repo, memctx, path,
2049 2049 self._cache[path]['data'],
2050 2050 'l' in self._cache[path]['flags'],
2051 2051 'x' in self._cache[path]['flags'],
2052 2052 self._cache[path]['copied'])
2053 2053 else:
2054 2054 # Returning None, but including the path in `files`, is
2055 2055 # necessary for memctx to register a deletion.
2056 2056 return None
2057 2057 return memctx(self._repo, parents, text, files, getfile, date=date,
2058 2058 extra=extra, user=user, branch=branch, editor=editor)
2059 2059
2060 2060 def isdirty(self, path):
2061 2061 return path in self._cache
2062 2062
2063 2063 def isempty(self):
2064 2064 # We need to discard any keys that are actually clean before the empty
2065 2065 # commit check.
2066 2066 self._compact()
2067 2067 return len(self._cache) == 0
2068 2068
2069 2069 def clean(self):
2070 2070 self._cache = {}
2071 2071
2072 2072 def _compact(self):
2073 2073 """Removes keys from the cache that are actually clean, by comparing
2074 2074 them with the underlying context.
2075 2075
2076 2076 This can occur during the merge process, e.g. by passing --tool :local
2077 2077 to resolve a conflict.
2078 2078 """
2079 2079 keys = []
2080 2080 for path in self._cache.keys():
2081 2081 cache = self._cache[path]
2082 2082 try:
2083 2083 underlying = self._wrappedctx[path]
2084 2084 if (underlying.data() == cache['data'] and
2085 2085 underlying.flags() == cache['flags']):
2086 2086 keys.append(path)
2087 2087 except error.ManifestLookupError:
2088 2088 # Path not in the underlying manifest (created).
2089 2089 continue
2090 2090
2091 2091 for path in keys:
2092 2092 del self._cache[path]
2093 2093 return keys
2094 2094
2095 2095 def _markdirty(self, path, exists, data=None, date=None, flags=''):
2096 2096 self._cache[path] = {
2097 2097 'exists': exists,
2098 2098 'data': data,
2099 2099 'date': date,
2100 2100 'flags': flags,
2101 2101 'copied': None,
2102 2102 }
2103 2103
2104 2104 def filectx(self, path, filelog=None):
2105 2105 return overlayworkingfilectx(self._repo, path, parent=self,
2106 2106 filelog=filelog)
2107 2107
2108 2108 class overlayworkingfilectx(committablefilectx):
2109 2109 """Wrap a ``workingfilectx`` but intercepts all writes into an in-memory
2110 2110 cache, which can be flushed through later by calling ``flush()``."""
2111 2111
2112 2112 def __init__(self, repo, path, filelog=None, parent=None):
2113 2113 super(overlayworkingfilectx, self).__init__(repo, path, filelog,
2114 2114 parent)
2115 2115 self._repo = repo
2116 2116 self._parent = parent
2117 2117 self._path = path
2118 2118
2119 2119 def cmp(self, fctx):
2120 2120 return self.data() != fctx.data()
2121 2121
2122 2122 def changectx(self):
2123 2123 return self._parent
2124 2124
2125 2125 def data(self):
2126 2126 return self._parent.data(self._path)
2127 2127
2128 2128 def date(self):
2129 2129 return self._parent.filedate(self._path)
2130 2130
2131 2131 def exists(self):
2132 2132 return self.lexists()
2133 2133
2134 2134 def lexists(self):
2135 2135 return self._parent.exists(self._path)
2136 2136
2137 2137 def renamed(self):
2138 2138 path = self._parent.copydata(self._path)
2139 2139 if not path:
2140 2140 return None
2141 2141 return path, self._changectx._parents[0]._manifest.get(path, nullid)
2142 2142
2143 2143 def size(self):
2144 2144 return self._parent.size(self._path)
2145 2145
2146 2146 def markcopied(self, origin):
2147 2147 self._parent.markcopied(self._path, origin)
2148 2148
2149 2149 def audit(self):
2150 2150 pass
2151 2151
2152 2152 def flags(self):
2153 2153 return self._parent.flags(self._path)
2154 2154
2155 2155 def setflags(self, islink, isexec):
2156 2156 return self._parent.setflags(self._path, islink, isexec)
2157 2157
2158 2158 def write(self, data, flags, backgroundclose=False, **kwargs):
2159 2159 return self._parent.write(self._path, data, flags, **kwargs)
2160 2160
2161 2161 def remove(self, ignoremissing=False):
2162 2162 return self._parent.remove(self._path)
2163 2163
2164 2164 def clearunknown(self):
2165 2165 pass
2166 2166
2167 2167 class workingcommitctx(workingctx):
2168 2168 """A workingcommitctx object makes access to data related to
2169 2169 the revision being committed convenient.
2170 2170
2171 2171 This hides changes in the working directory, if they aren't
2172 2172 committed in this context.
2173 2173 """
2174 2174 def __init__(self, repo, changes,
2175 2175 text="", user=None, date=None, extra=None):
2176 2176 super(workingctx, self).__init__(repo, text, user, date, extra,
2177 2177 changes)
2178 2178
2179 2179 def _dirstatestatus(self, match, ignored=False, clean=False, unknown=False):
2180 2180 """Return matched files only in ``self._status``
2181 2181
2182 2182 Uncommitted files appear "clean" via this context, even if
2183 2183 they aren't actually so in the working directory.
2184 2184 """
2185 2185 if clean:
2186 2186 clean = [f for f in self._manifest if f not in self._changedset]
2187 2187 else:
2188 2188 clean = []
2189 2189 return scmutil.status([f for f in self._status.modified if match(f)],
2190 2190 [f for f in self._status.added if match(f)],
2191 2191 [f for f in self._status.removed if match(f)],
2192 2192 [], [], [], clean)
2193 2193
2194 2194 @propertycache
2195 2195 def _changedset(self):
2196 2196 """Return the set of files changed in this context
2197 2197 """
2198 2198 changed = set(self._status.modified)
2199 2199 changed.update(self._status.added)
2200 2200 changed.update(self._status.removed)
2201 2201 return changed
2202 2202
2203 2203 def makecachingfilectxfn(func):
2204 2204 """Create a filectxfn that caches based on the path.
2205 2205
2206 2206 We can't use util.cachefunc because it uses all arguments as the cache
2207 2207 key and this creates a cycle since the arguments include the repo and
2208 2208 memctx.
2209 2209 """
2210 2210 cache = {}
2211 2211
2212 2212 def getfilectx(repo, memctx, path):
2213 2213 if path not in cache:
2214 2214 cache[path] = func(repo, memctx, path)
2215 2215 return cache[path]
2216 2216
2217 2217 return getfilectx
2218 2218
2219 2219 def memfilefromctx(ctx):
2220 2220 """Given a context return a memfilectx for ctx[path]
2221 2221
2222 2222 This is a convenience method for building a memctx based on another
2223 2223 context.
2224 2224 """
2225 2225 def getfilectx(repo, memctx, path):
2226 2226 fctx = ctx[path]
2227 2227 # this is weird but apparently we only keep track of one parent
2228 2228 # (why not only store that instead of a tuple?)
2229 2229 copied = fctx.renamed()
2230 2230 if copied:
2231 2231 copied = copied[0]
2232 2232 return memfilectx(repo, memctx, path, fctx.data(),
2233 2233 islink=fctx.islink(), isexec=fctx.isexec(),
2234 2234 copied=copied)
2235 2235
2236 2236 return getfilectx
2237 2237
2238 2238 def memfilefrompatch(patchstore):
2239 2239 """Given a patch (e.g. patchstore object) return a memfilectx
2240 2240
2241 2241 This is a convenience method for building a memctx based on a patchstore.
2242 2242 """
2243 2243 def getfilectx(repo, memctx, path):
2244 2244 data, mode, copied = patchstore.getfile(path)
2245 2245 if data is None:
2246 2246 return None
2247 2247 islink, isexec = mode
2248 2248 return memfilectx(repo, memctx, path, data, islink=islink,
2249 2249 isexec=isexec, copied=copied)
2250 2250
2251 2251 return getfilectx
2252 2252
2253 2253 class memctx(committablectx):
2254 2254 """Use memctx to perform in-memory commits via localrepo.commitctx().
2255 2255
2256 2256 Revision information is supplied at initialization time while
2257 2257 related files data and is made available through a callback
2258 2258 mechanism. 'repo' is the current localrepo, 'parents' is a
2259 2259 sequence of two parent revisions identifiers (pass None for every
2260 2260 missing parent), 'text' is the commit message and 'files' lists
2261 2261 names of files touched by the revision (normalized and relative to
2262 2262 repository root).
2263 2263
2264 2264 filectxfn(repo, memctx, path) is a callable receiving the
2265 2265 repository, the current memctx object and the normalized path of
2266 2266 requested file, relative to repository root. It is fired by the
2267 2267 commit function for every file in 'files', but calls order is
2268 2268 undefined. If the file is available in the revision being
2269 2269 committed (updated or added), filectxfn returns a memfilectx
2270 2270 object. If the file was removed, filectxfn return None for recent
2271 2271 Mercurial. Moved files are represented by marking the source file
2272 2272 removed and the new file added with copy information (see
2273 2273 memfilectx).
2274 2274
2275 2275 user receives the committer name and defaults to current
2276 2276 repository username, date is the commit date in any format
2277 2277 supported by dateutil.parsedate() and defaults to current date, extra
2278 2278 is a dictionary of metadata or is left empty.
2279 2279 """
2280 2280
2281 2281 # Mercurial <= 3.1 expects the filectxfn to raise IOError for missing files.
2282 2282 # Extensions that need to retain compatibility across Mercurial 3.1 can use
2283 2283 # this field to determine what to do in filectxfn.
2284 2284 _returnnoneformissingfiles = True
2285 2285
2286 2286 def __init__(self, repo, parents, text, files, filectxfn, user=None,
2287 2287 date=None, extra=None, branch=None, editor=False):
2288 2288 super(memctx, self).__init__(repo, text, user, date, extra)
2289 2289 self._rev = None
2290 2290 self._node = None
2291 2291 parents = [(p or nullid) for p in parents]
2292 2292 p1, p2 = parents
2293 2293 self._parents = [changectx(self._repo, p) for p in (p1, p2)]
2294 2294 files = sorted(set(files))
2295 2295 self._files = files
2296 2296 if branch is not None:
2297 2297 self._extra['branch'] = encoding.fromlocal(branch)
2298 2298 self.substate = {}
2299 2299
2300 2300 if isinstance(filectxfn, patch.filestore):
2301 2301 filectxfn = memfilefrompatch(filectxfn)
2302 2302 elif not callable(filectxfn):
2303 2303 # if store is not callable, wrap it in a function
2304 2304 filectxfn = memfilefromctx(filectxfn)
2305 2305
2306 2306 # memoizing increases performance for e.g. vcs convert scenarios.
2307 2307 self._filectxfn = makecachingfilectxfn(filectxfn)
2308 2308
2309 2309 if editor:
2310 2310 self._text = editor(self._repo, self, [])
2311 2311 self._repo.savecommitmessage(self._text)
2312 2312
2313 2313 def filectx(self, path, filelog=None):
2314 2314 """get a file context from the working directory
2315 2315
2316 2316 Returns None if file doesn't exist and should be removed."""
2317 2317 return self._filectxfn(self._repo, self, path)
2318 2318
2319 2319 def commit(self):
2320 2320 """commit context to the repo"""
2321 2321 return self._repo.commitctx(self)
2322 2322
2323 2323 @propertycache
2324 2324 def _manifest(self):
2325 2325 """generate a manifest based on the return values of filectxfn"""
2326 2326
2327 2327 # keep this simple for now; just worry about p1
2328 2328 pctx = self._parents[0]
2329 2329 man = pctx.manifest().copy()
2330 2330
2331 2331 for f in self._status.modified:
2332 2332 p1node = nullid
2333 2333 p2node = nullid
2334 2334 p = pctx[f].parents() # if file isn't in pctx, check p2?
2335 2335 if len(p) > 0:
2336 2336 p1node = p[0].filenode()
2337 2337 if len(p) > 1:
2338 2338 p2node = p[1].filenode()
2339 2339 man[f] = revlog.hash(self[f].data(), p1node, p2node)
2340 2340
2341 2341 for f in self._status.added:
2342 2342 man[f] = revlog.hash(self[f].data(), nullid, nullid)
2343 2343
2344 2344 for f in self._status.removed:
2345 2345 if f in man:
2346 2346 del man[f]
2347 2347
2348 2348 return man
2349 2349
2350 2350 @propertycache
2351 2351 def _status(self):
2352 2352 """Calculate exact status from ``files`` specified at construction
2353 2353 """
2354 2354 man1 = self.p1().manifest()
2355 2355 p2 = self._parents[1]
2356 2356 # "1 < len(self._parents)" can't be used for checking
2357 2357 # existence of the 2nd parent, because "memctx._parents" is
2358 2358 # explicitly initialized by the list, of which length is 2.
2359 2359 if p2.node() != nullid:
2360 2360 man2 = p2.manifest()
2361 2361 managing = lambda f: f in man1 or f in man2
2362 2362 else:
2363 2363 managing = lambda f: f in man1
2364 2364
2365 2365 modified, added, removed = [], [], []
2366 2366 for f in self._files:
2367 2367 if not managing(f):
2368 2368 added.append(f)
2369 2369 elif self[f]:
2370 2370 modified.append(f)
2371 2371 else:
2372 2372 removed.append(f)
2373 2373
2374 2374 return scmutil.status(modified, added, removed, [], [], [], [])
2375 2375
2376 2376 class memfilectx(committablefilectx):
2377 2377 """memfilectx represents an in-memory file to commit.
2378 2378
2379 2379 See memctx and committablefilectx for more details.
2380 2380 """
2381 2381 def __init__(self, repo, changectx, path, data, islink=False,
2382 2382 isexec=False, copied=None):
2383 2383 """
2384 2384 path is the normalized file path relative to repository root.
2385 2385 data is the file content as a string.
2386 2386 islink is True if the file is a symbolic link.
2387 2387 isexec is True if the file is executable.
2388 2388 copied is the source file path if current file was copied in the
2389 2389 revision being committed, or None."""
2390 2390 super(memfilectx, self).__init__(repo, path, None, changectx)
2391 2391 self._data = data
2392 2392 self._flags = (islink and 'l' or '') + (isexec and 'x' or '')
2393 2393 self._copied = None
2394 2394 if copied:
2395 2395 self._copied = (copied, nullid)
2396 2396
2397 2397 def data(self):
2398 2398 return self._data
2399 2399
2400 2400 def remove(self, ignoremissing=False):
2401 2401 """wraps unlink for a repo's working directory"""
2402 2402 # need to figure out what to do here
2403 2403 del self._changectx[self._path]
2404 2404
2405 2405 def write(self, data, flags, **kwargs):
2406 2406 """wraps repo.wwrite"""
2407 2407 self._data = data
2408 2408
2409 2409 class overlayfilectx(committablefilectx):
2410 2410 """Like memfilectx but take an original filectx and optional parameters to
2411 2411 override parts of it. This is useful when fctx.data() is expensive (i.e.
2412 2412 flag processor is expensive) and raw data, flags, and filenode could be
2413 2413 reused (ex. rebase or mode-only amend a REVIDX_EXTSTORED file).
2414 2414 """
2415 2415
2416 2416 def __init__(self, originalfctx, datafunc=None, path=None, flags=None,
2417 2417 copied=None, ctx=None):
2418 2418 """originalfctx: filecontext to duplicate
2419 2419
2420 2420 datafunc: None or a function to override data (file content). It is a
2421 2421 function to be lazy. path, flags, copied, ctx: None or overridden value
2422 2422
2423 2423 copied could be (path, rev), or False. copied could also be just path,
2424 2424 and will be converted to (path, nullid). This simplifies some callers.
2425 2425 """
2426 2426
2427 2427 if path is None:
2428 2428 path = originalfctx.path()
2429 2429 if ctx is None:
2430 2430 ctx = originalfctx.changectx()
2431 2431 ctxmatch = lambda: True
2432 2432 else:
2433 2433 ctxmatch = lambda: ctx == originalfctx.changectx()
2434 2434
2435 2435 repo = originalfctx.repo()
2436 2436 flog = originalfctx.filelog()
2437 2437 super(overlayfilectx, self).__init__(repo, path, flog, ctx)
2438 2438
2439 2439 if copied is None:
2440 2440 copied = originalfctx.renamed()
2441 2441 copiedmatch = lambda: True
2442 2442 else:
2443 2443 if copied and not isinstance(copied, tuple):
2444 2444 # repo._filecommit will recalculate copyrev so nullid is okay
2445 2445 copied = (copied, nullid)
2446 2446 copiedmatch = lambda: copied == originalfctx.renamed()
2447 2447
2448 2448 # When data, copied (could affect data), ctx (could affect filelog
2449 2449 # parents) are not overridden, rawdata, rawflags, and filenode may be
2450 2450 # reused (repo._filecommit should double check filelog parents).
2451 2451 #
2452 2452 # path, flags are not hashed in filelog (but in manifestlog) so they do
2453 2453 # not affect reusable here.
2454 2454 #
2455 2455 # If ctx or copied is overridden to a same value with originalfctx,
2456 2456 # still consider it's reusable. originalfctx.renamed() may be a bit
2457 2457 # expensive so it's not called unless necessary. Assuming datafunc is
2458 2458 # always expensive, do not call it for this "reusable" test.
2459 2459 reusable = datafunc is None and ctxmatch() and copiedmatch()
2460 2460
2461 2461 if datafunc is None:
2462 2462 datafunc = originalfctx.data
2463 2463 if flags is None:
2464 2464 flags = originalfctx.flags()
2465 2465
2466 2466 self._datafunc = datafunc
2467 2467 self._flags = flags
2468 2468 self._copied = copied
2469 2469
2470 2470 if reusable:
2471 2471 # copy extra fields from originalfctx
2472 2472 attrs = ['rawdata', 'rawflags', '_filenode', '_filerev']
2473 2473 for attr_ in attrs:
2474 2474 if util.safehasattr(originalfctx, attr_):
2475 2475 setattr(self, attr_, getattr(originalfctx, attr_))
2476 2476
2477 2477 def data(self):
2478 2478 return self._datafunc()
2479 2479
2480 2480 class metadataonlyctx(committablectx):
2481 2481 """Like memctx but it's reusing the manifest of different commit.
2482 2482 Intended to be used by lightweight operations that are creating
2483 2483 metadata-only changes.
2484 2484
2485 2485 Revision information is supplied at initialization time. 'repo' is the
2486 2486 current localrepo, 'ctx' is original revision which manifest we're reuisng
2487 2487 'parents' is a sequence of two parent revisions identifiers (pass None for
2488 2488 every missing parent), 'text' is the commit.
2489 2489
2490 2490 user receives the committer name and defaults to current repository
2491 2491 username, date is the commit date in any format supported by
2492 2492 dateutil.parsedate() and defaults to current date, extra is a dictionary of
2493 2493 metadata or is left empty.
2494 2494 """
2495 2495 def __new__(cls, repo, originalctx, *args, **kwargs):
2496 2496 return super(metadataonlyctx, cls).__new__(cls, repo)
2497 2497
2498 2498 def __init__(self, repo, originalctx, parents=None, text=None, user=None,
2499 2499 date=None, extra=None, editor=False):
2500 2500 if text is None:
2501 2501 text = originalctx.description()
2502 2502 super(metadataonlyctx, self).__init__(repo, text, user, date, extra)
2503 2503 self._rev = None
2504 2504 self._node = None
2505 2505 self._originalctx = originalctx
2506 2506 self._manifestnode = originalctx.manifestnode()
2507 2507 if parents is None:
2508 2508 parents = originalctx.parents()
2509 2509 else:
2510 2510 parents = [repo[p] for p in parents if p is not None]
2511 2511 parents = parents[:]
2512 2512 while len(parents) < 2:
2513 2513 parents.append(repo[nullid])
2514 2514 p1, p2 = self._parents = parents
2515 2515
2516 2516 # sanity check to ensure that the reused manifest parents are
2517 2517 # manifests of our commit parents
2518 2518 mp1, mp2 = self.manifestctx().parents
2519 2519 if p1 != nullid and p1.manifestnode() != mp1:
2520 2520 raise RuntimeError('can\'t reuse the manifest: '
2521 2521 'its p1 doesn\'t match the new ctx p1')
2522 2522 if p2 != nullid and p2.manifestnode() != mp2:
2523 2523 raise RuntimeError('can\'t reuse the manifest: '
2524 2524 'its p2 doesn\'t match the new ctx p2')
2525 2525
2526 2526 self._files = originalctx.files()
2527 2527 self.substate = {}
2528 2528
2529 2529 if editor:
2530 2530 self._text = editor(self._repo, self, [])
2531 2531 self._repo.savecommitmessage(self._text)
2532 2532
2533 2533 def manifestnode(self):
2534 2534 return self._manifestnode
2535 2535
2536 2536 @property
2537 2537 def _manifestctx(self):
2538 2538 return self._repo.manifestlog[self._manifestnode]
2539 2539
2540 2540 def filectx(self, path, filelog=None):
2541 2541 return self._originalctx.filectx(path, filelog=filelog)
2542 2542
2543 2543 def commit(self):
2544 2544 """commit context to the repo"""
2545 2545 return self._repo.commitctx(self)
2546 2546
2547 2547 @property
2548 2548 def _manifest(self):
2549 2549 return self._originalctx.manifest()
2550 2550
2551 2551 @propertycache
2552 2552 def _status(self):
2553 2553 """Calculate exact status from ``files`` specified in the ``origctx``
2554 2554 and parents manifests.
2555 2555 """
2556 2556 man1 = self.p1().manifest()
2557 2557 p2 = self._parents[1]
2558 2558 # "1 < len(self._parents)" can't be used for checking
2559 2559 # existence of the 2nd parent, because "metadataonlyctx._parents" is
2560 2560 # explicitly initialized by the list, of which length is 2.
2561 2561 if p2.node() != nullid:
2562 2562 man2 = p2.manifest()
2563 2563 managing = lambda f: f in man1 or f in man2
2564 2564 else:
2565 2565 managing = lambda f: f in man1
2566 2566
2567 2567 modified, added, removed = [], [], []
2568 2568 for f in self._files:
2569 2569 if not managing(f):
2570 2570 added.append(f)
2571 2571 elif f in self:
2572 2572 modified.append(f)
2573 2573 else:
2574 2574 removed.append(f)
2575 2575
2576 2576 return scmutil.status(modified, added, removed, [], [], [], [])
2577 2577
2578 2578 class arbitraryfilectx(object):
2579 2579 """Allows you to use filectx-like functions on a file in an arbitrary
2580 2580 location on disk, possibly not in the working directory.
2581 2581 """
2582 2582 def __init__(self, path, repo=None):
2583 2583 # Repo is optional because contrib/simplemerge uses this class.
2584 2584 self._repo = repo
2585 2585 self._path = path
2586 2586
2587 2587 def cmp(self, fctx):
2588 2588 # filecmp follows symlinks whereas `cmp` should not, so skip the fast
2589 2589 # path if either side is a symlink.
2590 2590 symlinks = ('l' in self.flags() or 'l' in fctx.flags())
2591 2591 if not symlinks and isinstance(fctx, workingfilectx) and self._repo:
2592 2592 # Add a fast-path for merge if both sides are disk-backed.
2593 2593 # Note that filecmp uses the opposite return values (True if same)
2594 2594 # from our cmp functions (True if different).
2595 2595 return not filecmp.cmp(self.path(), self._repo.wjoin(fctx.path()))
2596 2596 return self.data() != fctx.data()
2597 2597
2598 2598 def path(self):
2599 2599 return self._path
2600 2600
2601 2601 def flags(self):
2602 2602 return ''
2603 2603
2604 2604 def data(self):
2605 2605 return util.readfile(self._path)
2606 2606
2607 2607 def decodeddata(self):
2608 2608 with open(self._path, "rb") as f:
2609 2609 return f.read()
2610 2610
2611 2611 def remove(self):
2612 2612 util.unlink(self._path)
2613 2613
2614 2614 def write(self, data, flags, **kwargs):
2615 2615 assert not flags
2616 2616 with open(self._path, "w") as f:
2617 2617 f.write(data)
General Comments 0
You need to be logged in to leave comments. Login now