##// END OF EJS Templates
changegroupsubset: use manifest.readfast to simplify collector
Matt Mackall -
r13712:c4706acc default
parent child Browse files
Show More
@@ -1,1945 +1,1931 b''
1 1 # localrepo.py - read/write repository class for mercurial
2 2 #
3 3 # Copyright 2005-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 node import bin, hex, nullid, nullrev, short
9 9 from i18n import _
10 10 import repo, changegroup, subrepo, discovery, pushkey
11 11 import changelog, dirstate, filelog, manifest, context, bookmarks
12 12 import lock, transaction, store, encoding
13 13 import util, extensions, hook, error
14 14 import match as matchmod
15 15 import merge as mergemod
16 16 import tags as tagsmod
17 17 import url as urlmod
18 18 from lock import release
19 19 import weakref, errno, os, time, inspect
20 20 propertycache = util.propertycache
21 21
22 22 class localrepository(repo.repository):
23 23 capabilities = set(('lookup', 'changegroupsubset', 'branchmap', 'pushkey'))
24 24 supportedformats = set(('revlogv1', 'parentdelta'))
25 25 supported = supportedformats | set(('store', 'fncache', 'shared',
26 26 'dotencode'))
27 27
28 28 def __init__(self, baseui, path=None, create=0):
29 29 repo.repository.__init__(self)
30 30 self.root = os.path.realpath(util.expandpath(path))
31 31 self.path = os.path.join(self.root, ".hg")
32 32 self.origroot = path
33 33 self.auditor = util.path_auditor(self.root, self._checknested)
34 34 self.opener = util.opener(self.path)
35 35 self.wopener = util.opener(self.root)
36 36 self.baseui = baseui
37 37 self.ui = baseui.copy()
38 38
39 39 try:
40 40 self.ui.readconfig(self.join("hgrc"), self.root)
41 41 extensions.loadall(self.ui)
42 42 except IOError:
43 43 pass
44 44
45 45 if not os.path.isdir(self.path):
46 46 if create:
47 47 if not os.path.exists(path):
48 48 util.makedirs(path)
49 49 os.mkdir(self.path)
50 50 requirements = ["revlogv1"]
51 51 if self.ui.configbool('format', 'usestore', True):
52 52 os.mkdir(os.path.join(self.path, "store"))
53 53 requirements.append("store")
54 54 if self.ui.configbool('format', 'usefncache', True):
55 55 requirements.append("fncache")
56 56 if self.ui.configbool('format', 'dotencode', True):
57 57 requirements.append('dotencode')
58 58 # create an invalid changelog
59 59 self.opener("00changelog.i", "a").write(
60 60 '\0\0\0\2' # represents revlogv2
61 61 ' dummy changelog to prevent using the old repo layout'
62 62 )
63 63 if self.ui.configbool('format', 'parentdelta', False):
64 64 requirements.append("parentdelta")
65 65 else:
66 66 raise error.RepoError(_("repository %s not found") % path)
67 67 elif create:
68 68 raise error.RepoError(_("repository %s already exists") % path)
69 69 else:
70 70 # find requirements
71 71 requirements = set()
72 72 try:
73 73 requirements = set(self.opener("requires").read().splitlines())
74 74 except IOError, inst:
75 75 if inst.errno != errno.ENOENT:
76 76 raise
77 77 for r in requirements - self.supported:
78 78 raise error.RequirementError(
79 79 _("requirement '%s' not supported") % r)
80 80
81 81 self.sharedpath = self.path
82 82 try:
83 83 s = os.path.realpath(self.opener("sharedpath").read())
84 84 if not os.path.exists(s):
85 85 raise error.RepoError(
86 86 _('.hg/sharedpath points to nonexistent directory %s') % s)
87 87 self.sharedpath = s
88 88 except IOError, inst:
89 89 if inst.errno != errno.ENOENT:
90 90 raise
91 91
92 92 self.store = store.store(requirements, self.sharedpath, util.opener)
93 93 self.spath = self.store.path
94 94 self.sopener = self.store.opener
95 95 self.sjoin = self.store.join
96 96 self.opener.createmode = self.store.createmode
97 97 self._applyrequirements(requirements)
98 98 if create:
99 99 self._writerequirements()
100 100
101 101 # These two define the set of tags for this repository. _tags
102 102 # maps tag name to node; _tagtypes maps tag name to 'global' or
103 103 # 'local'. (Global tags are defined by .hgtags across all
104 104 # heads, and local tags are defined in .hg/localtags.) They
105 105 # constitute the in-memory cache of tags.
106 106 self._tags = None
107 107 self._tagtypes = None
108 108
109 109 self._branchcache = None
110 110 self._branchcachetip = None
111 111 self.nodetagscache = None
112 112 self.filterpats = {}
113 113 self._datafilters = {}
114 114 self._transref = self._lockref = self._wlockref = None
115 115
116 116 def _applyrequirements(self, requirements):
117 117 self.requirements = requirements
118 118 self.sopener.options = {}
119 119 if 'parentdelta' in requirements:
120 120 self.sopener.options['parentdelta'] = 1
121 121
122 122 def _writerequirements(self):
123 123 reqfile = self.opener("requires", "w")
124 124 for r in self.requirements:
125 125 reqfile.write("%s\n" % r)
126 126 reqfile.close()
127 127
128 128 def _checknested(self, path):
129 129 """Determine if path is a legal nested repository."""
130 130 if not path.startswith(self.root):
131 131 return False
132 132 subpath = path[len(self.root) + 1:]
133 133
134 134 # XXX: Checking against the current working copy is wrong in
135 135 # the sense that it can reject things like
136 136 #
137 137 # $ hg cat -r 10 sub/x.txt
138 138 #
139 139 # if sub/ is no longer a subrepository in the working copy
140 140 # parent revision.
141 141 #
142 142 # However, it can of course also allow things that would have
143 143 # been rejected before, such as the above cat command if sub/
144 144 # is a subrepository now, but was a normal directory before.
145 145 # The old path auditor would have rejected by mistake since it
146 146 # panics when it sees sub/.hg/.
147 147 #
148 148 # All in all, checking against the working copy seems sensible
149 149 # since we want to prevent access to nested repositories on
150 150 # the filesystem *now*.
151 151 ctx = self[None]
152 152 parts = util.splitpath(subpath)
153 153 while parts:
154 154 prefix = os.sep.join(parts)
155 155 if prefix in ctx.substate:
156 156 if prefix == subpath:
157 157 return True
158 158 else:
159 159 sub = ctx.sub(prefix)
160 160 return sub.checknested(subpath[len(prefix) + 1:])
161 161 else:
162 162 parts.pop()
163 163 return False
164 164
165 165 @util.propertycache
166 166 def _bookmarks(self):
167 167 return bookmarks.read(self)
168 168
169 169 @util.propertycache
170 170 def _bookmarkcurrent(self):
171 171 return bookmarks.readcurrent(self)
172 172
173 173 @propertycache
174 174 def changelog(self):
175 175 c = changelog.changelog(self.sopener)
176 176 if 'HG_PENDING' in os.environ:
177 177 p = os.environ['HG_PENDING']
178 178 if p.startswith(self.root):
179 179 c.readpending('00changelog.i.a')
180 180 self.sopener.options['defversion'] = c.version
181 181 return c
182 182
183 183 @propertycache
184 184 def manifest(self):
185 185 return manifest.manifest(self.sopener)
186 186
187 187 @propertycache
188 188 def dirstate(self):
189 189 warned = [0]
190 190 def validate(node):
191 191 try:
192 192 r = self.changelog.rev(node)
193 193 return node
194 194 except error.LookupError:
195 195 if not warned[0]:
196 196 warned[0] = True
197 197 self.ui.warn(_("warning: ignoring unknown"
198 198 " working parent %s!\n") % short(node))
199 199 return nullid
200 200
201 201 return dirstate.dirstate(self.opener, self.ui, self.root, validate)
202 202
203 203 def __getitem__(self, changeid):
204 204 if changeid is None:
205 205 return context.workingctx(self)
206 206 return context.changectx(self, changeid)
207 207
208 208 def __contains__(self, changeid):
209 209 try:
210 210 return bool(self.lookup(changeid))
211 211 except error.RepoLookupError:
212 212 return False
213 213
214 214 def __nonzero__(self):
215 215 return True
216 216
217 217 def __len__(self):
218 218 return len(self.changelog)
219 219
220 220 def __iter__(self):
221 221 for i in xrange(len(self)):
222 222 yield i
223 223
224 224 def url(self):
225 225 return 'file:' + self.root
226 226
227 227 def hook(self, name, throw=False, **args):
228 228 return hook.hook(self.ui, self, name, throw, **args)
229 229
230 230 tag_disallowed = ':\r\n'
231 231
232 232 def _tag(self, names, node, message, local, user, date, extra={}):
233 233 if isinstance(names, str):
234 234 allchars = names
235 235 names = (names,)
236 236 else:
237 237 allchars = ''.join(names)
238 238 for c in self.tag_disallowed:
239 239 if c in allchars:
240 240 raise util.Abort(_('%r cannot be used in a tag name') % c)
241 241
242 242 branches = self.branchmap()
243 243 for name in names:
244 244 self.hook('pretag', throw=True, node=hex(node), tag=name,
245 245 local=local)
246 246 if name in branches:
247 247 self.ui.warn(_("warning: tag %s conflicts with existing"
248 248 " branch name\n") % name)
249 249
250 250 def writetags(fp, names, munge, prevtags):
251 251 fp.seek(0, 2)
252 252 if prevtags and prevtags[-1] != '\n':
253 253 fp.write('\n')
254 254 for name in names:
255 255 m = munge and munge(name) or name
256 256 if self._tagtypes and name in self._tagtypes:
257 257 old = self._tags.get(name, nullid)
258 258 fp.write('%s %s\n' % (hex(old), m))
259 259 fp.write('%s %s\n' % (hex(node), m))
260 260 fp.close()
261 261
262 262 prevtags = ''
263 263 if local:
264 264 try:
265 265 fp = self.opener('localtags', 'r+')
266 266 except IOError:
267 267 fp = self.opener('localtags', 'a')
268 268 else:
269 269 prevtags = fp.read()
270 270
271 271 # local tags are stored in the current charset
272 272 writetags(fp, names, None, prevtags)
273 273 for name in names:
274 274 self.hook('tag', node=hex(node), tag=name, local=local)
275 275 return
276 276
277 277 try:
278 278 fp = self.wfile('.hgtags', 'rb+')
279 279 except IOError:
280 280 fp = self.wfile('.hgtags', 'ab')
281 281 else:
282 282 prevtags = fp.read()
283 283
284 284 # committed tags are stored in UTF-8
285 285 writetags(fp, names, encoding.fromlocal, prevtags)
286 286
287 287 fp.close()
288 288
289 289 if '.hgtags' not in self.dirstate:
290 290 self[None].add(['.hgtags'])
291 291
292 292 m = matchmod.exact(self.root, '', ['.hgtags'])
293 293 tagnode = self.commit(message, user, date, extra=extra, match=m)
294 294
295 295 for name in names:
296 296 self.hook('tag', node=hex(node), tag=name, local=local)
297 297
298 298 return tagnode
299 299
300 300 def tag(self, names, node, message, local, user, date):
301 301 '''tag a revision with one or more symbolic names.
302 302
303 303 names is a list of strings or, when adding a single tag, names may be a
304 304 string.
305 305
306 306 if local is True, the tags are stored in a per-repository file.
307 307 otherwise, they are stored in the .hgtags file, and a new
308 308 changeset is committed with the change.
309 309
310 310 keyword arguments:
311 311
312 312 local: whether to store tags in non-version-controlled file
313 313 (default False)
314 314
315 315 message: commit message to use if committing
316 316
317 317 user: name of user to use if committing
318 318
319 319 date: date tuple to use if committing'''
320 320
321 321 if not local:
322 322 for x in self.status()[:5]:
323 323 if '.hgtags' in x:
324 324 raise util.Abort(_('working copy of .hgtags is changed '
325 325 '(please commit .hgtags manually)'))
326 326
327 327 self.tags() # instantiate the cache
328 328 self._tag(names, node, message, local, user, date)
329 329
330 330 def tags(self):
331 331 '''return a mapping of tag to node'''
332 332 if self._tags is None:
333 333 (self._tags, self._tagtypes) = self._findtags()
334 334
335 335 return self._tags
336 336
337 337 def _findtags(self):
338 338 '''Do the hard work of finding tags. Return a pair of dicts
339 339 (tags, tagtypes) where tags maps tag name to node, and tagtypes
340 340 maps tag name to a string like \'global\' or \'local\'.
341 341 Subclasses or extensions are free to add their own tags, but
342 342 should be aware that the returned dicts will be retained for the
343 343 duration of the localrepo object.'''
344 344
345 345 # XXX what tagtype should subclasses/extensions use? Currently
346 346 # mq and bookmarks add tags, but do not set the tagtype at all.
347 347 # Should each extension invent its own tag type? Should there
348 348 # be one tagtype for all such "virtual" tags? Or is the status
349 349 # quo fine?
350 350
351 351 alltags = {} # map tag name to (node, hist)
352 352 tagtypes = {}
353 353
354 354 tagsmod.findglobaltags(self.ui, self, alltags, tagtypes)
355 355 tagsmod.readlocaltags(self.ui, self, alltags, tagtypes)
356 356
357 357 # Build the return dicts. Have to re-encode tag names because
358 358 # the tags module always uses UTF-8 (in order not to lose info
359 359 # writing to the cache), but the rest of Mercurial wants them in
360 360 # local encoding.
361 361 tags = {}
362 362 for (name, (node, hist)) in alltags.iteritems():
363 363 if node != nullid:
364 364 tags[encoding.tolocal(name)] = node
365 365 tags['tip'] = self.changelog.tip()
366 366 tagtypes = dict([(encoding.tolocal(name), value)
367 367 for (name, value) in tagtypes.iteritems()])
368 368 return (tags, tagtypes)
369 369
370 370 def tagtype(self, tagname):
371 371 '''
372 372 return the type of the given tag. result can be:
373 373
374 374 'local' : a local tag
375 375 'global' : a global tag
376 376 None : tag does not exist
377 377 '''
378 378
379 379 self.tags()
380 380
381 381 return self._tagtypes.get(tagname)
382 382
383 383 def tagslist(self):
384 384 '''return a list of tags ordered by revision'''
385 385 l = []
386 386 for t, n in self.tags().iteritems():
387 387 try:
388 388 r = self.changelog.rev(n)
389 389 except:
390 390 r = -2 # sort to the beginning of the list if unknown
391 391 l.append((r, t, n))
392 392 return [(t, n) for r, t, n in sorted(l)]
393 393
394 394 def nodetags(self, node):
395 395 '''return the tags associated with a node'''
396 396 if not self.nodetagscache:
397 397 self.nodetagscache = {}
398 398 for t, n in self.tags().iteritems():
399 399 self.nodetagscache.setdefault(n, []).append(t)
400 400 for tags in self.nodetagscache.itervalues():
401 401 tags.sort()
402 402 return self.nodetagscache.get(node, [])
403 403
404 404 def nodebookmarks(self, node):
405 405 marks = []
406 406 for bookmark, n in self._bookmarks.iteritems():
407 407 if n == node:
408 408 marks.append(bookmark)
409 409 return sorted(marks)
410 410
411 411 def _branchtags(self, partial, lrev):
412 412 # TODO: rename this function?
413 413 tiprev = len(self) - 1
414 414 if lrev != tiprev:
415 415 ctxgen = (self[r] for r in xrange(lrev + 1, tiprev + 1))
416 416 self._updatebranchcache(partial, ctxgen)
417 417 self._writebranchcache(partial, self.changelog.tip(), tiprev)
418 418
419 419 return partial
420 420
421 421 def updatebranchcache(self):
422 422 tip = self.changelog.tip()
423 423 if self._branchcache is not None and self._branchcachetip == tip:
424 424 return self._branchcache
425 425
426 426 oldtip = self._branchcachetip
427 427 self._branchcachetip = tip
428 428 if oldtip is None or oldtip not in self.changelog.nodemap:
429 429 partial, last, lrev = self._readbranchcache()
430 430 else:
431 431 lrev = self.changelog.rev(oldtip)
432 432 partial = self._branchcache
433 433
434 434 self._branchtags(partial, lrev)
435 435 # this private cache holds all heads (not just tips)
436 436 self._branchcache = partial
437 437
438 438 def branchmap(self):
439 439 '''returns a dictionary {branch: [branchheads]}'''
440 440 self.updatebranchcache()
441 441 return self._branchcache
442 442
443 443 def branchtags(self):
444 444 '''return a dict where branch names map to the tipmost head of
445 445 the branch, open heads come before closed'''
446 446 bt = {}
447 447 for bn, heads in self.branchmap().iteritems():
448 448 tip = heads[-1]
449 449 for h in reversed(heads):
450 450 if 'close' not in self.changelog.read(h)[5]:
451 451 tip = h
452 452 break
453 453 bt[bn] = tip
454 454 return bt
455 455
456 456 def _readbranchcache(self):
457 457 partial = {}
458 458 try:
459 459 f = self.opener("cache/branchheads")
460 460 lines = f.read().split('\n')
461 461 f.close()
462 462 except (IOError, OSError):
463 463 return {}, nullid, nullrev
464 464
465 465 try:
466 466 last, lrev = lines.pop(0).split(" ", 1)
467 467 last, lrev = bin(last), int(lrev)
468 468 if lrev >= len(self) or self[lrev].node() != last:
469 469 # invalidate the cache
470 470 raise ValueError('invalidating branch cache (tip differs)')
471 471 for l in lines:
472 472 if not l:
473 473 continue
474 474 node, label = l.split(" ", 1)
475 475 label = encoding.tolocal(label.strip())
476 476 partial.setdefault(label, []).append(bin(node))
477 477 except KeyboardInterrupt:
478 478 raise
479 479 except Exception, inst:
480 480 if self.ui.debugflag:
481 481 self.ui.warn(str(inst), '\n')
482 482 partial, last, lrev = {}, nullid, nullrev
483 483 return partial, last, lrev
484 484
485 485 def _writebranchcache(self, branches, tip, tiprev):
486 486 try:
487 487 f = self.opener("cache/branchheads", "w", atomictemp=True)
488 488 f.write("%s %s\n" % (hex(tip), tiprev))
489 489 for label, nodes in branches.iteritems():
490 490 for node in nodes:
491 491 f.write("%s %s\n" % (hex(node), encoding.fromlocal(label)))
492 492 f.rename()
493 493 except (IOError, OSError):
494 494 pass
495 495
496 496 def _updatebranchcache(self, partial, ctxgen):
497 497 # collect new branch entries
498 498 newbranches = {}
499 499 for c in ctxgen:
500 500 newbranches.setdefault(c.branch(), []).append(c.node())
501 501 # if older branchheads are reachable from new ones, they aren't
502 502 # really branchheads. Note checking parents is insufficient:
503 503 # 1 (branch a) -> 2 (branch b) -> 3 (branch a)
504 504 for branch, newnodes in newbranches.iteritems():
505 505 bheads = partial.setdefault(branch, [])
506 506 bheads.extend(newnodes)
507 507 if len(bheads) <= 1:
508 508 continue
509 509 # starting from tip means fewer passes over reachable
510 510 while newnodes:
511 511 latest = newnodes.pop()
512 512 if latest not in bheads:
513 513 continue
514 514 minbhrev = self[min([self[bh].rev() for bh in bheads])].node()
515 515 reachable = self.changelog.reachable(latest, minbhrev)
516 516 reachable.remove(latest)
517 517 bheads = [b for b in bheads if b not in reachable]
518 518 partial[branch] = bheads
519 519
520 520 def lookup(self, key):
521 521 if isinstance(key, int):
522 522 return self.changelog.node(key)
523 523 elif key == '.':
524 524 return self.dirstate.parents()[0]
525 525 elif key == 'null':
526 526 return nullid
527 527 elif key == 'tip':
528 528 return self.changelog.tip()
529 529 n = self.changelog._match(key)
530 530 if n:
531 531 return n
532 532 if key in self._bookmarks:
533 533 return self._bookmarks[key]
534 534 if key in self.tags():
535 535 return self.tags()[key]
536 536 if key in self.branchtags():
537 537 return self.branchtags()[key]
538 538 n = self.changelog._partialmatch(key)
539 539 if n:
540 540 return n
541 541
542 542 # can't find key, check if it might have come from damaged dirstate
543 543 if key in self.dirstate.parents():
544 544 raise error.Abort(_("working directory has unknown parent '%s'!")
545 545 % short(key))
546 546 try:
547 547 if len(key) == 20:
548 548 key = hex(key)
549 549 except:
550 550 pass
551 551 raise error.RepoLookupError(_("unknown revision '%s'") % key)
552 552
553 553 def lookupbranch(self, key, remote=None):
554 554 repo = remote or self
555 555 if key in repo.branchmap():
556 556 return key
557 557
558 558 repo = (remote and remote.local()) and remote or self
559 559 return repo[key].branch()
560 560
561 561 def local(self):
562 562 return True
563 563
564 564 def join(self, f):
565 565 return os.path.join(self.path, f)
566 566
567 567 def wjoin(self, f):
568 568 return os.path.join(self.root, f)
569 569
570 570 def file(self, f):
571 571 if f[0] == '/':
572 572 f = f[1:]
573 573 return filelog.filelog(self.sopener, f)
574 574
575 575 def changectx(self, changeid):
576 576 return self[changeid]
577 577
578 578 def parents(self, changeid=None):
579 579 '''get list of changectxs for parents of changeid'''
580 580 return self[changeid].parents()
581 581
582 582 def filectx(self, path, changeid=None, fileid=None):
583 583 """changeid can be a changeset revision, node, or tag.
584 584 fileid can be a file revision or node."""
585 585 return context.filectx(self, path, changeid, fileid)
586 586
587 587 def getcwd(self):
588 588 return self.dirstate.getcwd()
589 589
590 590 def pathto(self, f, cwd=None):
591 591 return self.dirstate.pathto(f, cwd)
592 592
593 593 def wfile(self, f, mode='r'):
594 594 return self.wopener(f, mode)
595 595
596 596 def _link(self, f):
597 597 return os.path.islink(self.wjoin(f))
598 598
599 599 def _loadfilter(self, filter):
600 600 if filter not in self.filterpats:
601 601 l = []
602 602 for pat, cmd in self.ui.configitems(filter):
603 603 if cmd == '!':
604 604 continue
605 605 mf = matchmod.match(self.root, '', [pat])
606 606 fn = None
607 607 params = cmd
608 608 for name, filterfn in self._datafilters.iteritems():
609 609 if cmd.startswith(name):
610 610 fn = filterfn
611 611 params = cmd[len(name):].lstrip()
612 612 break
613 613 if not fn:
614 614 fn = lambda s, c, **kwargs: util.filter(s, c)
615 615 # Wrap old filters not supporting keyword arguments
616 616 if not inspect.getargspec(fn)[2]:
617 617 oldfn = fn
618 618 fn = lambda s, c, **kwargs: oldfn(s, c)
619 619 l.append((mf, fn, params))
620 620 self.filterpats[filter] = l
621 621 return self.filterpats[filter]
622 622
623 623 def _filter(self, filterpats, filename, data):
624 624 for mf, fn, cmd in filterpats:
625 625 if mf(filename):
626 626 self.ui.debug("filtering %s through %s\n" % (filename, cmd))
627 627 data = fn(data, cmd, ui=self.ui, repo=self, filename=filename)
628 628 break
629 629
630 630 return data
631 631
632 632 @propertycache
633 633 def _encodefilterpats(self):
634 634 return self._loadfilter('encode')
635 635
636 636 @propertycache
637 637 def _decodefilterpats(self):
638 638 return self._loadfilter('decode')
639 639
640 640 def adddatafilter(self, name, filter):
641 641 self._datafilters[name] = filter
642 642
643 643 def wread(self, filename):
644 644 if self._link(filename):
645 645 data = os.readlink(self.wjoin(filename))
646 646 else:
647 647 data = self.wopener(filename, 'r').read()
648 648 return self._filter(self._encodefilterpats, filename, data)
649 649
650 650 def wwrite(self, filename, data, flags):
651 651 data = self._filter(self._decodefilterpats, filename, data)
652 652 if 'l' in flags:
653 653 self.wopener.symlink(data, filename)
654 654 else:
655 655 self.wopener(filename, 'w').write(data)
656 656 if 'x' in flags:
657 657 util.set_flags(self.wjoin(filename), False, True)
658 658
659 659 def wwritedata(self, filename, data):
660 660 return self._filter(self._decodefilterpats, filename, data)
661 661
662 662 def transaction(self, desc):
663 663 tr = self._transref and self._transref() or None
664 664 if tr and tr.running():
665 665 return tr.nest()
666 666
667 667 # abort here if the journal already exists
668 668 if os.path.exists(self.sjoin("journal")):
669 669 raise error.RepoError(
670 670 _("abandoned transaction found - run hg recover"))
671 671
672 672 # save dirstate for rollback
673 673 try:
674 674 ds = self.opener("dirstate").read()
675 675 except IOError:
676 676 ds = ""
677 677 self.opener("journal.dirstate", "w").write(ds)
678 678 self.opener("journal.branch", "w").write(
679 679 encoding.fromlocal(self.dirstate.branch()))
680 680 self.opener("journal.desc", "w").write("%d\n%s\n" % (len(self), desc))
681 681
682 682 renames = [(self.sjoin("journal"), self.sjoin("undo")),
683 683 (self.join("journal.dirstate"), self.join("undo.dirstate")),
684 684 (self.join("journal.branch"), self.join("undo.branch")),
685 685 (self.join("journal.desc"), self.join("undo.desc"))]
686 686 tr = transaction.transaction(self.ui.warn, self.sopener,
687 687 self.sjoin("journal"),
688 688 aftertrans(renames),
689 689 self.store.createmode)
690 690 self._transref = weakref.ref(tr)
691 691 return tr
692 692
693 693 def recover(self):
694 694 lock = self.lock()
695 695 try:
696 696 if os.path.exists(self.sjoin("journal")):
697 697 self.ui.status(_("rolling back interrupted transaction\n"))
698 698 transaction.rollback(self.sopener, self.sjoin("journal"),
699 699 self.ui.warn)
700 700 self.invalidate()
701 701 return True
702 702 else:
703 703 self.ui.warn(_("no interrupted transaction available\n"))
704 704 return False
705 705 finally:
706 706 lock.release()
707 707
708 708 def rollback(self, dryrun=False):
709 709 wlock = lock = None
710 710 try:
711 711 wlock = self.wlock()
712 712 lock = self.lock()
713 713 if os.path.exists(self.sjoin("undo")):
714 714 try:
715 715 args = self.opener("undo.desc", "r").read().splitlines()
716 716 if len(args) >= 3 and self.ui.verbose:
717 717 desc = _("repository tip rolled back to revision %s"
718 718 " (undo %s: %s)\n") % (
719 719 int(args[0]) - 1, args[1], args[2])
720 720 elif len(args) >= 2:
721 721 desc = _("repository tip rolled back to revision %s"
722 722 " (undo %s)\n") % (
723 723 int(args[0]) - 1, args[1])
724 724 except IOError:
725 725 desc = _("rolling back unknown transaction\n")
726 726 self.ui.status(desc)
727 727 if dryrun:
728 728 return
729 729 transaction.rollback(self.sopener, self.sjoin("undo"),
730 730 self.ui.warn)
731 731 util.rename(self.join("undo.dirstate"), self.join("dirstate"))
732 732 if os.path.exists(self.join('undo.bookmarks')):
733 733 util.rename(self.join('undo.bookmarks'),
734 734 self.join('bookmarks'))
735 735 try:
736 736 branch = self.opener("undo.branch").read()
737 737 self.dirstate.setbranch(branch)
738 738 except IOError:
739 739 self.ui.warn(_("Named branch could not be reset, "
740 740 "current branch still is: %s\n")
741 741 % self.dirstate.branch())
742 742 self.invalidate()
743 743 self.dirstate.invalidate()
744 744 self.destroyed()
745 745 parents = tuple([p.rev() for p in self.parents()])
746 746 if len(parents) > 1:
747 747 self.ui.status(_("working directory now based on "
748 748 "revisions %d and %d\n") % parents)
749 749 else:
750 750 self.ui.status(_("working directory now based on "
751 751 "revision %d\n") % parents)
752 752 else:
753 753 self.ui.warn(_("no rollback information available\n"))
754 754 return 1
755 755 finally:
756 756 release(lock, wlock)
757 757
758 758 def invalidatecaches(self):
759 759 self._tags = None
760 760 self._tagtypes = None
761 761 self.nodetagscache = None
762 762 self._branchcache = None # in UTF-8
763 763 self._branchcachetip = None
764 764
765 765 def invalidate(self):
766 766 for a in ("changelog", "manifest", "_bookmarks", "_bookmarkcurrent"):
767 767 if a in self.__dict__:
768 768 delattr(self, a)
769 769 self.invalidatecaches()
770 770
771 771 def _lock(self, lockname, wait, releasefn, acquirefn, desc):
772 772 try:
773 773 l = lock.lock(lockname, 0, releasefn, desc=desc)
774 774 except error.LockHeld, inst:
775 775 if not wait:
776 776 raise
777 777 self.ui.warn(_("waiting for lock on %s held by %r\n") %
778 778 (desc, inst.locker))
779 779 # default to 600 seconds timeout
780 780 l = lock.lock(lockname, int(self.ui.config("ui", "timeout", "600")),
781 781 releasefn, desc=desc)
782 782 if acquirefn:
783 783 acquirefn()
784 784 return l
785 785
786 786 def lock(self, wait=True):
787 787 '''Lock the repository store (.hg/store) and return a weak reference
788 788 to the lock. Use this before modifying the store (e.g. committing or
789 789 stripping). If you are opening a transaction, get a lock as well.)'''
790 790 l = self._lockref and self._lockref()
791 791 if l is not None and l.held:
792 792 l.lock()
793 793 return l
794 794
795 795 l = self._lock(self.sjoin("lock"), wait, self.store.write,
796 796 self.invalidate, _('repository %s') % self.origroot)
797 797 self._lockref = weakref.ref(l)
798 798 return l
799 799
800 800 def wlock(self, wait=True):
801 801 '''Lock the non-store parts of the repository (everything under
802 802 .hg except .hg/store) and return a weak reference to the lock.
803 803 Use this before modifying files in .hg.'''
804 804 l = self._wlockref and self._wlockref()
805 805 if l is not None and l.held:
806 806 l.lock()
807 807 return l
808 808
809 809 l = self._lock(self.join("wlock"), wait, self.dirstate.write,
810 810 self.dirstate.invalidate, _('working directory of %s') %
811 811 self.origroot)
812 812 self._wlockref = weakref.ref(l)
813 813 return l
814 814
815 815 def _filecommit(self, fctx, manifest1, manifest2, linkrev, tr, changelist):
816 816 """
817 817 commit an individual file as part of a larger transaction
818 818 """
819 819
820 820 fname = fctx.path()
821 821 text = fctx.data()
822 822 flog = self.file(fname)
823 823 fparent1 = manifest1.get(fname, nullid)
824 824 fparent2 = fparent2o = manifest2.get(fname, nullid)
825 825
826 826 meta = {}
827 827 copy = fctx.renamed()
828 828 if copy and copy[0] != fname:
829 829 # Mark the new revision of this file as a copy of another
830 830 # file. This copy data will effectively act as a parent
831 831 # of this new revision. If this is a merge, the first
832 832 # parent will be the nullid (meaning "look up the copy data")
833 833 # and the second one will be the other parent. For example:
834 834 #
835 835 # 0 --- 1 --- 3 rev1 changes file foo
836 836 # \ / rev2 renames foo to bar and changes it
837 837 # \- 2 -/ rev3 should have bar with all changes and
838 838 # should record that bar descends from
839 839 # bar in rev2 and foo in rev1
840 840 #
841 841 # this allows this merge to succeed:
842 842 #
843 843 # 0 --- 1 --- 3 rev4 reverts the content change from rev2
844 844 # \ / merging rev3 and rev4 should use bar@rev2
845 845 # \- 2 --- 4 as the merge base
846 846 #
847 847
848 848 cfname = copy[0]
849 849 crev = manifest1.get(cfname)
850 850 newfparent = fparent2
851 851
852 852 if manifest2: # branch merge
853 853 if fparent2 == nullid or crev is None: # copied on remote side
854 854 if cfname in manifest2:
855 855 crev = manifest2[cfname]
856 856 newfparent = fparent1
857 857
858 858 # find source in nearest ancestor if we've lost track
859 859 if not crev:
860 860 self.ui.debug(" %s: searching for copy revision for %s\n" %
861 861 (fname, cfname))
862 862 for ancestor in self[None].ancestors():
863 863 if cfname in ancestor:
864 864 crev = ancestor[cfname].filenode()
865 865 break
866 866
867 867 if crev:
868 868 self.ui.debug(" %s: copy %s:%s\n" % (fname, cfname, hex(crev)))
869 869 meta["copy"] = cfname
870 870 meta["copyrev"] = hex(crev)
871 871 fparent1, fparent2 = nullid, newfparent
872 872 else:
873 873 self.ui.warn(_("warning: can't find ancestor for '%s' "
874 874 "copied from '%s'!\n") % (fname, cfname))
875 875
876 876 elif fparent2 != nullid:
877 877 # is one parent an ancestor of the other?
878 878 fparentancestor = flog.ancestor(fparent1, fparent2)
879 879 if fparentancestor == fparent1:
880 880 fparent1, fparent2 = fparent2, nullid
881 881 elif fparentancestor == fparent2:
882 882 fparent2 = nullid
883 883
884 884 # is the file changed?
885 885 if fparent2 != nullid or flog.cmp(fparent1, text) or meta:
886 886 changelist.append(fname)
887 887 return flog.add(text, meta, tr, linkrev, fparent1, fparent2)
888 888
889 889 # are just the flags changed during merge?
890 890 if fparent1 != fparent2o and manifest1.flags(fname) != fctx.flags():
891 891 changelist.append(fname)
892 892
893 893 return fparent1
894 894
895 895 def commit(self, text="", user=None, date=None, match=None, force=False,
896 896 editor=False, extra={}):
897 897 """Add a new revision to current repository.
898 898
899 899 Revision information is gathered from the working directory,
900 900 match can be used to filter the committed files. If editor is
901 901 supplied, it is called to get a commit message.
902 902 """
903 903
904 904 def fail(f, msg):
905 905 raise util.Abort('%s: %s' % (f, msg))
906 906
907 907 if not match:
908 908 match = matchmod.always(self.root, '')
909 909
910 910 if not force:
911 911 vdirs = []
912 912 match.dir = vdirs.append
913 913 match.bad = fail
914 914
915 915 wlock = self.wlock()
916 916 try:
917 917 wctx = self[None]
918 918 merge = len(wctx.parents()) > 1
919 919
920 920 if (not force and merge and match and
921 921 (match.files() or match.anypats())):
922 922 raise util.Abort(_('cannot partially commit a merge '
923 923 '(do not specify files or patterns)'))
924 924
925 925 changes = self.status(match=match, clean=force)
926 926 if force:
927 927 changes[0].extend(changes[6]) # mq may commit unchanged files
928 928
929 929 # check subrepos
930 930 subs = []
931 931 removedsubs = set()
932 932 for p in wctx.parents():
933 933 removedsubs.update(s for s in p.substate if match(s))
934 934 for s in wctx.substate:
935 935 removedsubs.discard(s)
936 936 if match(s) and wctx.sub(s).dirty():
937 937 subs.append(s)
938 938 if (subs or removedsubs):
939 939 if (not match('.hgsub') and
940 940 '.hgsub' in (wctx.modified() + wctx.added())):
941 941 raise util.Abort(_("can't commit subrepos without .hgsub"))
942 942 if '.hgsubstate' not in changes[0]:
943 943 changes[0].insert(0, '.hgsubstate')
944 944
945 945 if subs and not self.ui.configbool('ui', 'commitsubrepos', True):
946 946 changedsubs = [s for s in subs if wctx.sub(s).dirty(True)]
947 947 if changedsubs:
948 948 raise util.Abort(_("uncommitted changes in subrepo %s")
949 949 % changedsubs[0])
950 950
951 951 # make sure all explicit patterns are matched
952 952 if not force and match.files():
953 953 matched = set(changes[0] + changes[1] + changes[2])
954 954
955 955 for f in match.files():
956 956 if f == '.' or f in matched or f in wctx.substate:
957 957 continue
958 958 if f in changes[3]: # missing
959 959 fail(f, _('file not found!'))
960 960 if f in vdirs: # visited directory
961 961 d = f + '/'
962 962 for mf in matched:
963 963 if mf.startswith(d):
964 964 break
965 965 else:
966 966 fail(f, _("no match under directory!"))
967 967 elif f not in self.dirstate:
968 968 fail(f, _("file not tracked!"))
969 969
970 970 if (not force and not extra.get("close") and not merge
971 971 and not (changes[0] or changes[1] or changes[2])
972 972 and wctx.branch() == wctx.p1().branch()):
973 973 return None
974 974
975 975 ms = mergemod.mergestate(self)
976 976 for f in changes[0]:
977 977 if f in ms and ms[f] == 'u':
978 978 raise util.Abort(_("unresolved merge conflicts "
979 979 "(see hg help resolve)"))
980 980
981 981 cctx = context.workingctx(self, text, user, date, extra, changes)
982 982 if editor:
983 983 cctx._text = editor(self, cctx, subs)
984 984 edited = (text != cctx._text)
985 985
986 986 # commit subs
987 987 if subs or removedsubs:
988 988 state = wctx.substate.copy()
989 989 for s in sorted(subs):
990 990 sub = wctx.sub(s)
991 991 self.ui.status(_('committing subrepository %s\n') %
992 992 subrepo.subrelpath(sub))
993 993 sr = sub.commit(cctx._text, user, date)
994 994 state[s] = (state[s][0], sr)
995 995 subrepo.writestate(self, state)
996 996
997 997 # Save commit message in case this transaction gets rolled back
998 998 # (e.g. by a pretxncommit hook). Leave the content alone on
999 999 # the assumption that the user will use the same editor again.
1000 1000 msgfile = self.opener('last-message.txt', 'wb')
1001 1001 msgfile.write(cctx._text)
1002 1002 msgfile.close()
1003 1003
1004 1004 p1, p2 = self.dirstate.parents()
1005 1005 hookp1, hookp2 = hex(p1), (p2 != nullid and hex(p2) or '')
1006 1006 try:
1007 1007 self.hook("precommit", throw=True, parent1=hookp1, parent2=hookp2)
1008 1008 ret = self.commitctx(cctx, True)
1009 1009 except:
1010 1010 if edited:
1011 1011 msgfn = self.pathto(msgfile.name[len(self.root)+1:])
1012 1012 self.ui.write(
1013 1013 _('note: commit message saved in %s\n') % msgfn)
1014 1014 raise
1015 1015
1016 1016 # update bookmarks, dirstate and mergestate
1017 1017 parents = (p1, p2)
1018 1018 if p2 == nullid:
1019 1019 parents = (p1,)
1020 1020 bookmarks.update(self, parents, ret)
1021 1021 for f in changes[0] + changes[1]:
1022 1022 self.dirstate.normal(f)
1023 1023 for f in changes[2]:
1024 1024 self.dirstate.forget(f)
1025 1025 self.dirstate.setparents(ret)
1026 1026 ms.reset()
1027 1027 finally:
1028 1028 wlock.release()
1029 1029
1030 1030 self.hook("commit", node=hex(ret), parent1=hookp1, parent2=hookp2)
1031 1031 return ret
1032 1032
1033 1033 def commitctx(self, ctx, error=False):
1034 1034 """Add a new revision to current repository.
1035 1035 Revision information is passed via the context argument.
1036 1036 """
1037 1037
1038 1038 tr = lock = None
1039 1039 removed = list(ctx.removed())
1040 1040 p1, p2 = ctx.p1(), ctx.p2()
1041 1041 m1 = p1.manifest().copy()
1042 1042 m2 = p2.manifest()
1043 1043 user = ctx.user()
1044 1044
1045 1045 lock = self.lock()
1046 1046 try:
1047 1047 tr = self.transaction("commit")
1048 1048 trp = weakref.proxy(tr)
1049 1049
1050 1050 # check in files
1051 1051 new = {}
1052 1052 changed = []
1053 1053 linkrev = len(self)
1054 1054 for f in sorted(ctx.modified() + ctx.added()):
1055 1055 self.ui.note(f + "\n")
1056 1056 try:
1057 1057 fctx = ctx[f]
1058 1058 new[f] = self._filecommit(fctx, m1, m2, linkrev, trp,
1059 1059 changed)
1060 1060 m1.set(f, fctx.flags())
1061 1061 except OSError, inst:
1062 1062 self.ui.warn(_("trouble committing %s!\n") % f)
1063 1063 raise
1064 1064 except IOError, inst:
1065 1065 errcode = getattr(inst, 'errno', errno.ENOENT)
1066 1066 if error or errcode and errcode != errno.ENOENT:
1067 1067 self.ui.warn(_("trouble committing %s!\n") % f)
1068 1068 raise
1069 1069 else:
1070 1070 removed.append(f)
1071 1071
1072 1072 # update manifest
1073 1073 m1.update(new)
1074 1074 removed = [f for f in sorted(removed) if f in m1 or f in m2]
1075 1075 drop = [f for f in removed if f in m1]
1076 1076 for f in drop:
1077 1077 del m1[f]
1078 1078 mn = self.manifest.add(m1, trp, linkrev, p1.manifestnode(),
1079 1079 p2.manifestnode(), (new, drop))
1080 1080
1081 1081 # update changelog
1082 1082 self.changelog.delayupdate()
1083 1083 n = self.changelog.add(mn, changed + removed, ctx.description(),
1084 1084 trp, p1.node(), p2.node(),
1085 1085 user, ctx.date(), ctx.extra().copy())
1086 1086 p = lambda: self.changelog.writepending() and self.root or ""
1087 1087 xp1, xp2 = p1.hex(), p2 and p2.hex() or ''
1088 1088 self.hook('pretxncommit', throw=True, node=hex(n), parent1=xp1,
1089 1089 parent2=xp2, pending=p)
1090 1090 self.changelog.finalize(trp)
1091 1091 tr.close()
1092 1092
1093 1093 if self._branchcache:
1094 1094 self.updatebranchcache()
1095 1095 return n
1096 1096 finally:
1097 1097 if tr:
1098 1098 tr.release()
1099 1099 lock.release()
1100 1100
1101 1101 def destroyed(self):
1102 1102 '''Inform the repository that nodes have been destroyed.
1103 1103 Intended for use by strip and rollback, so there's a common
1104 1104 place for anything that has to be done after destroying history.'''
1105 1105 # XXX it might be nice if we could take the list of destroyed
1106 1106 # nodes, but I don't see an easy way for rollback() to do that
1107 1107
1108 1108 # Ensure the persistent tag cache is updated. Doing it now
1109 1109 # means that the tag cache only has to worry about destroyed
1110 1110 # heads immediately after a strip/rollback. That in turn
1111 1111 # guarantees that "cachetip == currenttip" (comparing both rev
1112 1112 # and node) always means no nodes have been added or destroyed.
1113 1113
1114 1114 # XXX this is suboptimal when qrefresh'ing: we strip the current
1115 1115 # head, refresh the tag cache, then immediately add a new head.
1116 1116 # But I think doing it this way is necessary for the "instant
1117 1117 # tag cache retrieval" case to work.
1118 1118 self.invalidatecaches()
1119 1119
1120 1120 def walk(self, match, node=None):
1121 1121 '''
1122 1122 walk recursively through the directory tree or a given
1123 1123 changeset, finding all files matched by the match
1124 1124 function
1125 1125 '''
1126 1126 return self[node].walk(match)
1127 1127
1128 1128 def status(self, node1='.', node2=None, match=None,
1129 1129 ignored=False, clean=False, unknown=False,
1130 1130 listsubrepos=False):
1131 1131 """return status of files between two nodes or node and working directory
1132 1132
1133 1133 If node1 is None, use the first dirstate parent instead.
1134 1134 If node2 is None, compare node1 with working directory.
1135 1135 """
1136 1136
1137 1137 def mfmatches(ctx):
1138 1138 mf = ctx.manifest().copy()
1139 1139 for fn in mf.keys():
1140 1140 if not match(fn):
1141 1141 del mf[fn]
1142 1142 return mf
1143 1143
1144 1144 if isinstance(node1, context.changectx):
1145 1145 ctx1 = node1
1146 1146 else:
1147 1147 ctx1 = self[node1]
1148 1148 if isinstance(node2, context.changectx):
1149 1149 ctx2 = node2
1150 1150 else:
1151 1151 ctx2 = self[node2]
1152 1152
1153 1153 working = ctx2.rev() is None
1154 1154 parentworking = working and ctx1 == self['.']
1155 1155 match = match or matchmod.always(self.root, self.getcwd())
1156 1156 listignored, listclean, listunknown = ignored, clean, unknown
1157 1157
1158 1158 # load earliest manifest first for caching reasons
1159 1159 if not working and ctx2.rev() < ctx1.rev():
1160 1160 ctx2.manifest()
1161 1161
1162 1162 if not parentworking:
1163 1163 def bad(f, msg):
1164 1164 if f not in ctx1:
1165 1165 self.ui.warn('%s: %s\n' % (self.dirstate.pathto(f), msg))
1166 1166 match.bad = bad
1167 1167
1168 1168 if working: # we need to scan the working dir
1169 1169 subrepos = []
1170 1170 if '.hgsub' in self.dirstate:
1171 1171 subrepos = ctx1.substate.keys()
1172 1172 s = self.dirstate.status(match, subrepos, listignored,
1173 1173 listclean, listunknown)
1174 1174 cmp, modified, added, removed, deleted, unknown, ignored, clean = s
1175 1175
1176 1176 # check for any possibly clean files
1177 1177 if parentworking and cmp:
1178 1178 fixup = []
1179 1179 # do a full compare of any files that might have changed
1180 1180 for f in sorted(cmp):
1181 1181 if (f not in ctx1 or ctx2.flags(f) != ctx1.flags(f)
1182 1182 or ctx1[f].cmp(ctx2[f])):
1183 1183 modified.append(f)
1184 1184 else:
1185 1185 fixup.append(f)
1186 1186
1187 1187 # update dirstate for files that are actually clean
1188 1188 if fixup:
1189 1189 if listclean:
1190 1190 clean += fixup
1191 1191
1192 1192 try:
1193 1193 # updating the dirstate is optional
1194 1194 # so we don't wait on the lock
1195 1195 wlock = self.wlock(False)
1196 1196 try:
1197 1197 for f in fixup:
1198 1198 self.dirstate.normal(f)
1199 1199 finally:
1200 1200 wlock.release()
1201 1201 except error.LockError:
1202 1202 pass
1203 1203
1204 1204 if not parentworking:
1205 1205 mf1 = mfmatches(ctx1)
1206 1206 if working:
1207 1207 # we are comparing working dir against non-parent
1208 1208 # generate a pseudo-manifest for the working dir
1209 1209 mf2 = mfmatches(self['.'])
1210 1210 for f in cmp + modified + added:
1211 1211 mf2[f] = None
1212 1212 mf2.set(f, ctx2.flags(f))
1213 1213 for f in removed:
1214 1214 if f in mf2:
1215 1215 del mf2[f]
1216 1216 else:
1217 1217 # we are comparing two revisions
1218 1218 deleted, unknown, ignored = [], [], []
1219 1219 mf2 = mfmatches(ctx2)
1220 1220
1221 1221 modified, added, clean = [], [], []
1222 1222 for fn in mf2:
1223 1223 if fn in mf1:
1224 1224 if (mf1.flags(fn) != mf2.flags(fn) or
1225 1225 (mf1[fn] != mf2[fn] and
1226 1226 (mf2[fn] or ctx1[fn].cmp(ctx2[fn])))):
1227 1227 modified.append(fn)
1228 1228 elif listclean:
1229 1229 clean.append(fn)
1230 1230 del mf1[fn]
1231 1231 else:
1232 1232 added.append(fn)
1233 1233 removed = mf1.keys()
1234 1234
1235 1235 r = modified, added, removed, deleted, unknown, ignored, clean
1236 1236
1237 1237 if listsubrepos:
1238 1238 for subpath, sub in subrepo.itersubrepos(ctx1, ctx2):
1239 1239 if working:
1240 1240 rev2 = None
1241 1241 else:
1242 1242 rev2 = ctx2.substate[subpath][1]
1243 1243 try:
1244 1244 submatch = matchmod.narrowmatcher(subpath, match)
1245 1245 s = sub.status(rev2, match=submatch, ignored=listignored,
1246 1246 clean=listclean, unknown=listunknown,
1247 1247 listsubrepos=True)
1248 1248 for rfiles, sfiles in zip(r, s):
1249 1249 rfiles.extend("%s/%s" % (subpath, f) for f in sfiles)
1250 1250 except error.LookupError:
1251 1251 self.ui.status(_("skipping missing subrepository: %s\n")
1252 1252 % subpath)
1253 1253
1254 1254 for l in r:
1255 1255 l.sort()
1256 1256 return r
1257 1257
1258 1258 def heads(self, start=None):
1259 1259 heads = self.changelog.heads(start)
1260 1260 # sort the output in rev descending order
1261 1261 return sorted(heads, key=self.changelog.rev, reverse=True)
1262 1262
1263 1263 def branchheads(self, branch=None, start=None, closed=False):
1264 1264 '''return a (possibly filtered) list of heads for the given branch
1265 1265
1266 1266 Heads are returned in topological order, from newest to oldest.
1267 1267 If branch is None, use the dirstate branch.
1268 1268 If start is not None, return only heads reachable from start.
1269 1269 If closed is True, return heads that are marked as closed as well.
1270 1270 '''
1271 1271 if branch is None:
1272 1272 branch = self[None].branch()
1273 1273 branches = self.branchmap()
1274 1274 if branch not in branches:
1275 1275 return []
1276 1276 # the cache returns heads ordered lowest to highest
1277 1277 bheads = list(reversed(branches[branch]))
1278 1278 if start is not None:
1279 1279 # filter out the heads that cannot be reached from startrev
1280 1280 fbheads = set(self.changelog.nodesbetween([start], bheads)[2])
1281 1281 bheads = [h for h in bheads if h in fbheads]
1282 1282 if not closed:
1283 1283 bheads = [h for h in bheads if
1284 1284 ('close' not in self.changelog.read(h)[5])]
1285 1285 return bheads
1286 1286
1287 1287 def branches(self, nodes):
1288 1288 if not nodes:
1289 1289 nodes = [self.changelog.tip()]
1290 1290 b = []
1291 1291 for n in nodes:
1292 1292 t = n
1293 1293 while 1:
1294 1294 p = self.changelog.parents(n)
1295 1295 if p[1] != nullid or p[0] == nullid:
1296 1296 b.append((t, n, p[0], p[1]))
1297 1297 break
1298 1298 n = p[0]
1299 1299 return b
1300 1300
1301 1301 def between(self, pairs):
1302 1302 r = []
1303 1303
1304 1304 for top, bottom in pairs:
1305 1305 n, l, i = top, [], 0
1306 1306 f = 1
1307 1307
1308 1308 while n != bottom and n != nullid:
1309 1309 p = self.changelog.parents(n)[0]
1310 1310 if i == f:
1311 1311 l.append(n)
1312 1312 f = f * 2
1313 1313 n = p
1314 1314 i += 1
1315 1315
1316 1316 r.append(l)
1317 1317
1318 1318 return r
1319 1319
1320 1320 def pull(self, remote, heads=None, force=False):
1321 1321 lock = self.lock()
1322 1322 try:
1323 1323 tmp = discovery.findcommonincoming(self, remote, heads=heads,
1324 1324 force=force)
1325 1325 common, fetch, rheads = tmp
1326 1326 if not fetch:
1327 1327 self.ui.status(_("no changes found\n"))
1328 1328 result = 0
1329 1329 else:
1330 1330 if heads is None and fetch == [nullid]:
1331 1331 self.ui.status(_("requesting all changes\n"))
1332 1332 elif heads is None and remote.capable('changegroupsubset'):
1333 1333 # issue1320, avoid a race if remote changed after discovery
1334 1334 heads = rheads
1335 1335
1336 1336 if heads is None:
1337 1337 cg = remote.changegroup(fetch, 'pull')
1338 1338 elif not remote.capable('changegroupsubset'):
1339 1339 raise util.Abort(_("partial pull cannot be done because "
1340 1340 "other repository doesn't support "
1341 1341 "changegroupsubset."))
1342 1342 else:
1343 1343 cg = remote.changegroupsubset(fetch, heads, 'pull')
1344 1344 result = self.addchangegroup(cg, 'pull', remote.url(),
1345 1345 lock=lock)
1346 1346 finally:
1347 1347 lock.release()
1348 1348
1349 1349 return result
1350 1350
1351 1351 def checkpush(self, force, revs):
1352 1352 """Extensions can override this function if additional checks have
1353 1353 to be performed before pushing, or call it if they override push
1354 1354 command.
1355 1355 """
1356 1356 pass
1357 1357
1358 1358 def push(self, remote, force=False, revs=None, newbranch=False):
1359 1359 '''Push outgoing changesets (limited by revs) from the current
1360 1360 repository to remote. Return an integer:
1361 1361 - 0 means HTTP error *or* nothing to push
1362 1362 - 1 means we pushed and remote head count is unchanged *or*
1363 1363 we have outgoing changesets but refused to push
1364 1364 - other values as described by addchangegroup()
1365 1365 '''
1366 1366 # there are two ways to push to remote repo:
1367 1367 #
1368 1368 # addchangegroup assumes local user can lock remote
1369 1369 # repo (local filesystem, old ssh servers).
1370 1370 #
1371 1371 # unbundle assumes local user cannot lock remote repo (new ssh
1372 1372 # servers, http servers).
1373 1373
1374 1374 self.checkpush(force, revs)
1375 1375 lock = None
1376 1376 unbundle = remote.capable('unbundle')
1377 1377 if not unbundle:
1378 1378 lock = remote.lock()
1379 1379 try:
1380 1380 cg, remote_heads = discovery.prepush(self, remote, force, revs,
1381 1381 newbranch)
1382 1382 ret = remote_heads
1383 1383 if cg is not None:
1384 1384 if unbundle:
1385 1385 # local repo finds heads on server, finds out what
1386 1386 # revs it must push. once revs transferred, if server
1387 1387 # finds it has different heads (someone else won
1388 1388 # commit/push race), server aborts.
1389 1389 if force:
1390 1390 remote_heads = ['force']
1391 1391 # ssh: return remote's addchangegroup()
1392 1392 # http: return remote's addchangegroup() or 0 for error
1393 1393 ret = remote.unbundle(cg, remote_heads, 'push')
1394 1394 else:
1395 1395 # we return an integer indicating remote head count change
1396 1396 ret = remote.addchangegroup(cg, 'push', self.url(),
1397 1397 lock=lock)
1398 1398 finally:
1399 1399 if lock is not None:
1400 1400 lock.release()
1401 1401
1402 1402 self.ui.debug("checking for updated bookmarks\n")
1403 1403 rb = remote.listkeys('bookmarks')
1404 1404 for k in rb.keys():
1405 1405 if k in self._bookmarks:
1406 1406 nr, nl = rb[k], hex(self._bookmarks[k])
1407 1407 if nr in self:
1408 1408 cr = self[nr]
1409 1409 cl = self[nl]
1410 1410 if cl in cr.descendants():
1411 1411 r = remote.pushkey('bookmarks', k, nr, nl)
1412 1412 if r:
1413 1413 self.ui.status(_("updating bookmark %s\n") % k)
1414 1414 else:
1415 1415 self.ui.warn(_('updating bookmark %s'
1416 1416 ' failed!\n') % k)
1417 1417
1418 1418 return ret
1419 1419
1420 1420 def changegroupinfo(self, nodes, source):
1421 1421 if self.ui.verbose or source == 'bundle':
1422 1422 self.ui.status(_("%d changesets found\n") % len(nodes))
1423 1423 if self.ui.debugflag:
1424 1424 self.ui.debug("list of changesets:\n")
1425 1425 for node in nodes:
1426 1426 self.ui.debug("%s\n" % hex(node))
1427 1427
1428 1428 def changegroupsubset(self, bases, heads, source):
1429 1429 """Compute a changegroup consisting of all the nodes that are
1430 1430 descendents of any of the bases and ancestors of any of the heads.
1431 1431 Return a chunkbuffer object whose read() method will return
1432 1432 successive changegroup chunks.
1433 1433
1434 1434 It is fairly complex as determining which filenodes and which
1435 1435 manifest nodes need to be included for the changeset to be complete
1436 1436 is non-trivial.
1437 1437
1438 1438 Another wrinkle is doing the reverse, figuring out which changeset in
1439 1439 the changegroup a particular filenode or manifestnode belongs to.
1440 1440 """
1441 1441
1442 1442 cl = self.changelog
1443 1443 mf = self.manifest
1444 1444 mfs = {} # needed manifests
1445 1445 fnodes = {} # needed file nodes
1446 1446
1447 1447 if not bases:
1448 1448 bases = [nullid]
1449 1449 csets, bases, heads = cl.nodesbetween(bases, heads)
1450 1450
1451 1451 # can we go through the fast path ?
1452 1452 heads.sort()
1453 1453 if heads == sorted(self.heads()):
1454 1454 return self._changegroup(csets, source)
1455 1455
1456 1456 # slow path
1457 1457 self.hook('preoutgoing', throw=True, source=source)
1458 1458 self.changegroupinfo(csets, source)
1459 1459
1460 1460 # We assume that all ancestors of bases are known
1461 1461 commonrevs = set(cl.ancestors(*[cl.rev(n) for n in bases]))
1462 1462
1463 1463 # A function generating function that sets up the initial environment
1464 1464 # the inner function.
1465 1465 def filenode_collector(changedfiles):
1466 1466 # This gathers information from each manifestnode included in the
1467 1467 # changegroup about which filenodes the manifest node references
1468 1468 # so we can include those in the changegroup too.
1469 1469 #
1470 1470 # It also remembers which changenode each filenode belongs to. It
1471 1471 # does this by assuming the a filenode belongs to the changenode
1472 1472 # the first manifest that references it belongs to.
1473 1473 def collect(mnode):
1474 1474 r = mf.rev(mnode)
1475 1475 clnode = mfs[mnode]
1476 if mf.deltaparent(r) in mf.parentrevs(r):
1477 # If the previous rev is one of the parents,
1478 # we only need to see a diff.
1479 deltamf = mf.readdelta(mnode)
1480 # For each line in the delta
1481 for f, fnode in deltamf.iteritems():
1482 # And if the file is in the list of files we care
1483 # about.
1484 if f in changedfiles:
1485 # Create the set of filenodes for the file if
1486 # there isn't one already.
1487 fnodes.setdefault(f, {}).setdefault(fnode, clnode)
1488 else:
1489 # Otherwise we need a full manifest.
1490 m = mf.read(mnode)
1491 # For every file in we care about.
1476 mdata = mf.readfast(mnode)
1492 1477 for f in changedfiles:
1493 if f in m:
1494 fnodes.setdefault(f, {}).setdefault(m[f], clnode)
1478 if f in mdata:
1479 fnodes.setdefault(f, {}).setdefault(mdata[f], clnode)
1480
1495 1481 return collect
1496 1482
1497 1483 # If we determine that a particular file or manifest node must be a
1498 1484 # node that the recipient of the changegroup will already have, we can
1499 1485 # also assume the recipient will have all the parents. This function
1500 1486 # prunes them from the set of missing nodes.
1501 1487 def prune(revlog, missingnodes):
1502 1488 # drop any nodes that claim to be part of a cset in commonrevs
1503 1489 drop = set()
1504 1490 for n in missingnodes:
1505 1491 if revlog.linkrev(revlog.rev(n)) in commonrevs:
1506 1492 drop.add(n)
1507 1493 for n in drop:
1508 1494 missingnodes.pop(n, None)
1509 1495
1510 1496 # Now that we have all theses utility functions to help out and
1511 1497 # logically divide up the task, generate the group.
1512 1498 def gengroup():
1513 1499 # The set of changed files starts empty.
1514 1500 changedfiles = set()
1515 1501 collect = changegroup.collector(cl, mfs, changedfiles)
1516 1502
1517 1503 # Create a changenode group generator that will call our functions
1518 1504 # back to lookup the owning changenode and collect information.
1519 1505 group = cl.group(csets, lambda x: x, collect)
1520 1506 for count, chunk in enumerate(group):
1521 1507 yield chunk
1522 1508 # revlog.group yields three entries per node, so
1523 1509 # dividing by 3 gives an approximation of how many
1524 1510 # nodes have been processed.
1525 1511 self.ui.progress(_('bundling'), count / 3,
1526 1512 unit=_('changesets'))
1527 1513 changecount = count / 3
1528 1514 self.ui.progress(_('bundling'), None)
1529 1515
1530 1516 prune(mf, mfs)
1531 1517 # Create a generator for the manifestnodes that calls our lookup
1532 1518 # and data collection functions back.
1533 1519 group = mf.group(sorted(mfs, key=mf.rev),
1534 1520 lambda mnode: mfs[mnode],
1535 1521 filenode_collector(changedfiles))
1536 1522 efiles = {}
1537 1523 for count, chunk in enumerate(group):
1538 1524 if count % 3 == 1:
1539 1525 mnode = chunk[:20]
1540 1526 efiles.update(mf.readdelta(mnode))
1541 1527 yield chunk
1542 1528 # see above comment for why we divide by 3
1543 1529 self.ui.progress(_('bundling'), count / 3,
1544 1530 unit=_('manifests'), total=changecount)
1545 1531 self.ui.progress(_('bundling'), None)
1546 1532 efiles = len(efiles)
1547 1533
1548 1534 mfs.clear()
1549 1535
1550 1536 # Go through all our files in order sorted by name.
1551 1537 for idx, fname in enumerate(sorted(changedfiles)):
1552 1538 filerevlog = self.file(fname)
1553 1539 if not len(filerevlog):
1554 1540 raise util.Abort(_("empty or missing revlog for %s") % fname)
1555 1541 # Toss out the filenodes that the recipient isn't really
1556 1542 # missing.
1557 1543 missingfnodes = fnodes.pop(fname, {})
1558 1544 prune(filerevlog, missingfnodes)
1559 1545 # If any filenodes are left, generate the group for them,
1560 1546 # otherwise don't bother.
1561 1547 if missingfnodes:
1562 1548 yield changegroup.chunkheader(len(fname))
1563 1549 yield fname
1564 1550 # Create a group generator and only pass in a changenode
1565 1551 # lookup function as we need to collect no information
1566 1552 # from filenodes.
1567 1553 group = filerevlog.group(
1568 1554 sorted(missingfnodes, key=filerevlog.rev),
1569 1555 lambda fnode: missingfnodes[fnode])
1570 1556 for chunk in group:
1571 1557 # even though we print the same progress on
1572 1558 # most loop iterations, put the progress call
1573 1559 # here so that time estimates (if any) can be updated
1574 1560 self.ui.progress(
1575 1561 _('bundling'), idx, item=fname,
1576 1562 unit=_('files'), total=efiles)
1577 1563 yield chunk
1578 1564 # Signal that no more groups are left.
1579 1565 yield changegroup.closechunk()
1580 1566 self.ui.progress(_('bundling'), None)
1581 1567
1582 1568 if csets:
1583 1569 self.hook('outgoing', node=hex(csets[0]), source=source)
1584 1570
1585 1571 return changegroup.unbundle10(util.chunkbuffer(gengroup()), 'UN')
1586 1572
1587 1573 def changegroup(self, basenodes, source):
1588 1574 # to avoid a race we use changegroupsubset() (issue1320)
1589 1575 return self.changegroupsubset(basenodes, self.heads(), source)
1590 1576
1591 1577 def _changegroup(self, nodes, source):
1592 1578 """Compute the changegroup of all nodes that we have that a recipient
1593 1579 doesn't. Return a chunkbuffer object whose read() method will return
1594 1580 successive changegroup chunks.
1595 1581
1596 1582 This is much easier than the previous function as we can assume that
1597 1583 the recipient has any changenode we aren't sending them.
1598 1584
1599 1585 nodes is the set of nodes to send"""
1600 1586
1601 1587 self.hook('preoutgoing', throw=True, source=source)
1602 1588
1603 1589 cl = self.changelog
1604 1590 revset = set([cl.rev(n) for n in nodes])
1605 1591 self.changegroupinfo(nodes, source)
1606 1592
1607 1593 def identity(x):
1608 1594 return x
1609 1595
1610 1596 def gennodelst(log):
1611 1597 for r in log:
1612 1598 if log.linkrev(r) in revset:
1613 1599 yield log.node(r)
1614 1600
1615 1601 def lookuplinkrev_func(revlog):
1616 1602 def lookuplinkrev(n):
1617 1603 return cl.node(revlog.linkrev(revlog.rev(n)))
1618 1604 return lookuplinkrev
1619 1605
1620 1606 def gengroup():
1621 1607 '''yield a sequence of changegroup chunks (strings)'''
1622 1608 # construct a list of all changed files
1623 1609 changedfiles = set()
1624 1610 mmfs = {}
1625 1611 collect = changegroup.collector(cl, mmfs, changedfiles)
1626 1612
1627 1613 for cnt, chnk in enumerate(cl.group(nodes, identity, collect)):
1628 1614 # revlog.group yields three entries per node, so
1629 1615 # dividing by 3 gives an approximation of how many
1630 1616 # nodes have been processed.
1631 1617 self.ui.progress(_('bundling'), cnt / 3, unit=_('changesets'))
1632 1618 yield chnk
1633 1619 changecount = cnt / 3
1634 1620 self.ui.progress(_('bundling'), None)
1635 1621
1636 1622 mnfst = self.manifest
1637 1623 nodeiter = gennodelst(mnfst)
1638 1624 efiles = {}
1639 1625 for cnt, chnk in enumerate(mnfst.group(nodeiter,
1640 1626 lookuplinkrev_func(mnfst))):
1641 1627 if cnt % 3 == 1:
1642 1628 mnode = chnk[:20]
1643 1629 efiles.update(mnfst.readdelta(mnode))
1644 1630 # see above comment for why we divide by 3
1645 1631 self.ui.progress(_('bundling'), cnt / 3,
1646 1632 unit=_('manifests'), total=changecount)
1647 1633 yield chnk
1648 1634 efiles = len(efiles)
1649 1635 self.ui.progress(_('bundling'), None)
1650 1636
1651 1637 for idx, fname in enumerate(sorted(changedfiles)):
1652 1638 filerevlog = self.file(fname)
1653 1639 if not len(filerevlog):
1654 1640 raise util.Abort(_("empty or missing revlog for %s") % fname)
1655 1641 nodeiter = gennodelst(filerevlog)
1656 1642 nodeiter = list(nodeiter)
1657 1643 if nodeiter:
1658 1644 yield changegroup.chunkheader(len(fname))
1659 1645 yield fname
1660 1646 lookup = lookuplinkrev_func(filerevlog)
1661 1647 for chnk in filerevlog.group(nodeiter, lookup):
1662 1648 self.ui.progress(
1663 1649 _('bundling'), idx, item=fname,
1664 1650 total=efiles, unit=_('files'))
1665 1651 yield chnk
1666 1652 self.ui.progress(_('bundling'), None)
1667 1653
1668 1654 yield changegroup.closechunk()
1669 1655
1670 1656 if nodes:
1671 1657 self.hook('outgoing', node=hex(nodes[0]), source=source)
1672 1658
1673 1659 return changegroup.unbundle10(util.chunkbuffer(gengroup()), 'UN')
1674 1660
1675 1661 def addchangegroup(self, source, srctype, url, emptyok=False, lock=None):
1676 1662 """Add the changegroup returned by source.read() to this repo.
1677 1663 srctype is a string like 'push', 'pull', or 'unbundle'. url is
1678 1664 the URL of the repo where this changegroup is coming from.
1679 1665 If lock is not None, the function takes ownership of the lock
1680 1666 and releases it after the changegroup is added.
1681 1667
1682 1668 Return an integer summarizing the change to this repo:
1683 1669 - nothing changed or no source: 0
1684 1670 - more heads than before: 1+added heads (2..n)
1685 1671 - fewer heads than before: -1-removed heads (-2..-n)
1686 1672 - number of heads stays the same: 1
1687 1673 """
1688 1674 def csmap(x):
1689 1675 self.ui.debug("add changeset %s\n" % short(x))
1690 1676 return len(cl)
1691 1677
1692 1678 def revmap(x):
1693 1679 return cl.rev(x)
1694 1680
1695 1681 if not source:
1696 1682 return 0
1697 1683
1698 1684 self.hook('prechangegroup', throw=True, source=srctype, url=url)
1699 1685
1700 1686 changesets = files = revisions = 0
1701 1687 efiles = set()
1702 1688
1703 1689 # write changelog data to temp files so concurrent readers will not see
1704 1690 # inconsistent view
1705 1691 cl = self.changelog
1706 1692 cl.delayupdate()
1707 1693 oldheads = len(cl.heads())
1708 1694
1709 1695 tr = self.transaction("\n".join([srctype, urlmod.hidepassword(url)]))
1710 1696 try:
1711 1697 trp = weakref.proxy(tr)
1712 1698 # pull off the changeset group
1713 1699 self.ui.status(_("adding changesets\n"))
1714 1700 clstart = len(cl)
1715 1701 class prog(object):
1716 1702 step = _('changesets')
1717 1703 count = 1
1718 1704 ui = self.ui
1719 1705 total = None
1720 1706 def __call__(self):
1721 1707 self.ui.progress(self.step, self.count, unit=_('chunks'),
1722 1708 total=self.total)
1723 1709 self.count += 1
1724 1710 pr = prog()
1725 1711 source.callback = pr
1726 1712
1727 1713 if (cl.addgroup(source, csmap, trp) is None
1728 1714 and not emptyok):
1729 1715 raise util.Abort(_("received changelog group is empty"))
1730 1716 clend = len(cl)
1731 1717 changesets = clend - clstart
1732 1718 for c in xrange(clstart, clend):
1733 1719 efiles.update(self[c].files())
1734 1720 efiles = len(efiles)
1735 1721 self.ui.progress(_('changesets'), None)
1736 1722
1737 1723 # pull off the manifest group
1738 1724 self.ui.status(_("adding manifests\n"))
1739 1725 pr.step = _('manifests')
1740 1726 pr.count = 1
1741 1727 pr.total = changesets # manifests <= changesets
1742 1728 # no need to check for empty manifest group here:
1743 1729 # if the result of the merge of 1 and 2 is the same in 3 and 4,
1744 1730 # no new manifest will be created and the manifest group will
1745 1731 # be empty during the pull
1746 1732 self.manifest.addgroup(source, revmap, trp)
1747 1733 self.ui.progress(_('manifests'), None)
1748 1734
1749 1735 needfiles = {}
1750 1736 if self.ui.configbool('server', 'validate', default=False):
1751 1737 # validate incoming csets have their manifests
1752 1738 for cset in xrange(clstart, clend):
1753 1739 mfest = self.changelog.read(self.changelog.node(cset))[0]
1754 1740 mfest = self.manifest.readdelta(mfest)
1755 1741 # store file nodes we must see
1756 1742 for f, n in mfest.iteritems():
1757 1743 needfiles.setdefault(f, set()).add(n)
1758 1744
1759 1745 # process the files
1760 1746 self.ui.status(_("adding file changes\n"))
1761 1747 pr.step = 'files'
1762 1748 pr.count = 1
1763 1749 pr.total = efiles
1764 1750 source.callback = None
1765 1751
1766 1752 while 1:
1767 1753 f = source.chunk()
1768 1754 if not f:
1769 1755 break
1770 1756 self.ui.debug("adding %s revisions\n" % f)
1771 1757 pr()
1772 1758 fl = self.file(f)
1773 1759 o = len(fl)
1774 1760 if fl.addgroup(source, revmap, trp) is None:
1775 1761 raise util.Abort(_("received file revlog group is empty"))
1776 1762 revisions += len(fl) - o
1777 1763 files += 1
1778 1764 if f in needfiles:
1779 1765 needs = needfiles[f]
1780 1766 for new in xrange(o, len(fl)):
1781 1767 n = fl.node(new)
1782 1768 if n in needs:
1783 1769 needs.remove(n)
1784 1770 if not needs:
1785 1771 del needfiles[f]
1786 1772 self.ui.progress(_('files'), None)
1787 1773
1788 1774 for f, needs in needfiles.iteritems():
1789 1775 fl = self.file(f)
1790 1776 for n in needs:
1791 1777 try:
1792 1778 fl.rev(n)
1793 1779 except error.LookupError:
1794 1780 raise util.Abort(
1795 1781 _('missing file data for %s:%s - run hg verify') %
1796 1782 (f, hex(n)))
1797 1783
1798 1784 newheads = len(cl.heads())
1799 1785 heads = ""
1800 1786 if oldheads and newheads != oldheads:
1801 1787 heads = _(" (%+d heads)") % (newheads - oldheads)
1802 1788
1803 1789 self.ui.status(_("added %d changesets"
1804 1790 " with %d changes to %d files%s\n")
1805 1791 % (changesets, revisions, files, heads))
1806 1792
1807 1793 if changesets > 0:
1808 1794 p = lambda: cl.writepending() and self.root or ""
1809 1795 self.hook('pretxnchangegroup', throw=True,
1810 1796 node=hex(cl.node(clstart)), source=srctype,
1811 1797 url=url, pending=p)
1812 1798
1813 1799 # make changelog see real files again
1814 1800 cl.finalize(trp)
1815 1801
1816 1802 tr.close()
1817 1803 finally:
1818 1804 tr.release()
1819 1805 if lock:
1820 1806 lock.release()
1821 1807
1822 1808 if changesets > 0:
1823 1809 # forcefully update the on-disk branch cache
1824 1810 self.ui.debug("updating the branch cache\n")
1825 1811 self.updatebranchcache()
1826 1812 self.hook("changegroup", node=hex(cl.node(clstart)),
1827 1813 source=srctype, url=url)
1828 1814
1829 1815 for i in xrange(clstart, clend):
1830 1816 self.hook("incoming", node=hex(cl.node(i)),
1831 1817 source=srctype, url=url)
1832 1818
1833 1819 # never return 0 here:
1834 1820 if newheads < oldheads:
1835 1821 return newheads - oldheads - 1
1836 1822 else:
1837 1823 return newheads - oldheads + 1
1838 1824
1839 1825
1840 1826 def stream_in(self, remote, requirements):
1841 1827 lock = self.lock()
1842 1828 try:
1843 1829 fp = remote.stream_out()
1844 1830 l = fp.readline()
1845 1831 try:
1846 1832 resp = int(l)
1847 1833 except ValueError:
1848 1834 raise error.ResponseError(
1849 1835 _('Unexpected response from remote server:'), l)
1850 1836 if resp == 1:
1851 1837 raise util.Abort(_('operation forbidden by server'))
1852 1838 elif resp == 2:
1853 1839 raise util.Abort(_('locking the remote repository failed'))
1854 1840 elif resp != 0:
1855 1841 raise util.Abort(_('the server sent an unknown error code'))
1856 1842 self.ui.status(_('streaming all changes\n'))
1857 1843 l = fp.readline()
1858 1844 try:
1859 1845 total_files, total_bytes = map(int, l.split(' ', 1))
1860 1846 except (ValueError, TypeError):
1861 1847 raise error.ResponseError(
1862 1848 _('Unexpected response from remote server:'), l)
1863 1849 self.ui.status(_('%d files to transfer, %s of data\n') %
1864 1850 (total_files, util.bytecount(total_bytes)))
1865 1851 start = time.time()
1866 1852 for i in xrange(total_files):
1867 1853 # XXX doesn't support '\n' or '\r' in filenames
1868 1854 l = fp.readline()
1869 1855 try:
1870 1856 name, size = l.split('\0', 1)
1871 1857 size = int(size)
1872 1858 except (ValueError, TypeError):
1873 1859 raise error.ResponseError(
1874 1860 _('Unexpected response from remote server:'), l)
1875 1861 self.ui.debug('adding %s (%s)\n' % (name, util.bytecount(size)))
1876 1862 # for backwards compat, name was partially encoded
1877 1863 ofp = self.sopener(store.decodedir(name), 'w')
1878 1864 for chunk in util.filechunkiter(fp, limit=size):
1879 1865 ofp.write(chunk)
1880 1866 ofp.close()
1881 1867 elapsed = time.time() - start
1882 1868 if elapsed <= 0:
1883 1869 elapsed = 0.001
1884 1870 self.ui.status(_('transferred %s in %.1f seconds (%s/sec)\n') %
1885 1871 (util.bytecount(total_bytes), elapsed,
1886 1872 util.bytecount(total_bytes / elapsed)))
1887 1873
1888 1874 # new requirements = old non-format requirements + new format-related
1889 1875 # requirements from the streamed-in repository
1890 1876 requirements.update(set(self.requirements) - self.supportedformats)
1891 1877 self._applyrequirements(requirements)
1892 1878 self._writerequirements()
1893 1879
1894 1880 self.invalidate()
1895 1881 return len(self.heads()) + 1
1896 1882 finally:
1897 1883 lock.release()
1898 1884
1899 1885 def clone(self, remote, heads=[], stream=False):
1900 1886 '''clone remote repository.
1901 1887
1902 1888 keyword arguments:
1903 1889 heads: list of revs to clone (forces use of pull)
1904 1890 stream: use streaming clone if possible'''
1905 1891
1906 1892 # now, all clients that can request uncompressed clones can
1907 1893 # read repo formats supported by all servers that can serve
1908 1894 # them.
1909 1895
1910 1896 # if revlog format changes, client will have to check version
1911 1897 # and format flags on "stream" capability, and use
1912 1898 # uncompressed only if compatible.
1913 1899
1914 1900 if stream and not heads:
1915 1901 # 'stream' means remote revlog format is revlogv1 only
1916 1902 if remote.capable('stream'):
1917 1903 return self.stream_in(remote, set(('revlogv1',)))
1918 1904 # otherwise, 'streamreqs' contains the remote revlog format
1919 1905 streamreqs = remote.capable('streamreqs')
1920 1906 if streamreqs:
1921 1907 streamreqs = set(streamreqs.split(','))
1922 1908 # if we support it, stream in and adjust our requirements
1923 1909 if not streamreqs - self.supportedformats:
1924 1910 return self.stream_in(remote, streamreqs)
1925 1911 return self.pull(remote, heads)
1926 1912
1927 1913 def pushkey(self, namespace, key, old, new):
1928 1914 return pushkey.push(self, namespace, key, old, new)
1929 1915
1930 1916 def listkeys(self, namespace):
1931 1917 return pushkey.list(self, namespace)
1932 1918
1933 1919 # used to avoid circular references so destructors work
1934 1920 def aftertrans(files):
1935 1921 renamefiles = [tuple(t) for t in files]
1936 1922 def a():
1937 1923 for src, dest in renamefiles:
1938 1924 util.rename(src, dest)
1939 1925 return a
1940 1926
1941 1927 def instance(ui, path, create):
1942 1928 return localrepository(ui, util.drop_scheme('file', path), create)
1943 1929
1944 1930 def islocal(path):
1945 1931 return True
General Comments 0
You need to be logged in to leave comments. Login now