mercurial-crew-with-dirclash: comparison mercurial/localrepo.py

equal deleted inserted replaced

-:0952d164030e
+:83238c1db6de
 if not path:
 p = os.getcwd()
 while not os.path.isdir(os.path.join(p, ".hg")):
 oldp = p
 p = os.path.dirname(p)
-if p == oldp: raise repo.RepoError(_("no repo found"))
+if p == oldp:
+raise repo.RepoError(_("no repo found"))
 path = p
 self.path = os.path.join(path, ".hg")
 if not create and not os.path.isdir(self.path):
 raise repo.RepoError(_("repository %s not found") % path)
 os.mkdir(self.join("data"))
 self.dirstate = dirstate.dirstate(self.opener, ui, self.root)
 try:
 self.ui.readconfig(self.join("hgrc"))
-except IOError: pass
+except IOError:
+pass
 def hook(self, name, **args):
 def runhook(name, cmd):
 self.ui.note(_("running hook %s: %s\n") % (name, cmd))
 old = {}
 for t, n in self.tags().items():
 try:
 r = self.changelog.rev(n)
 except:
 r = -2 # sort to the beginning of the list if unknown
-l.append((r,t,n))
+l.append((r, t, n))
 l.sort()
-return [(t,n) for r,t,n in l]
+return [(t, n) for r, t, n in l]
 def nodetags(self, node):
 '''return the tags associated with a node'''
 if not self.nodetagscache:
 self.nodetagscache = {}
-for t,n in self.tags().items():
+for t, n in self.tags().items():
-self.nodetagscache.setdefault(n,[]).append(t)
+self.nodetagscache.setdefault(n, []).append(t)
 return self.nodetagscache.get(node, [])
 def lookup(self, key):
 try:
 return self.tags()[key]
 def wjoin(self, f):
 return os.path.join(self.root, f)
 def file(self, f):
-if f[0] == '/': f = f[1:]
+if f[0] == '/':
+f = f[1:]
 return filelog.filelog(self.opener, f)
 def getcwd(self):
 return self.dirstate.getcwd()
 n = self.changelog.add(mnode, changed, text, tr, p1, p2, user, date)
 tr.close()
 if update_dirstate:
 self.dirstate.setparents(n, nullid)
-def commit(self, files = None, text = "", user = None, date = None,
+def commit(self, files=None, text="", user=None, date=None,
-match = util.always, force=False):
+match=util.always, force=False):
 commit = []
 remove = []
 changed = []
 if files:
 util.pathto(self.getcwd(), fn), short(node)))
 else:
 for src, fn in self.dirstate.walk(files, match):
 yield src, fn
-def changes(self, node1 = None, node2 = None, files = [],
+def changes(self, node1=None, node2=None, files=[], match=util.always):
-match = util.always):
 mf2, u = None, []
 def fcmp(fn, mf):
 t1 = self.wread(fn)
 t2 = self.file(fn).read(mf.get(fn, nullid))
 change = self.changelog.read(self.dirstate.parents()[0])
 mf2 = mfmatches(change[0])
 for f in a + c + l:
 mf2[f] = ""
 for f in d:
-if f in mf2: del mf2[f]
+if f in mf2:
+del mf2[f]
 else:
 change = self.changelog.read(node2)
 mf2 = mfmatches(change[0])
 # flush lists from dirstate before comparing manifests
 for f in list:
 p = self.wjoin(f)
 if not os.path.exists(p):
 self.ui.warn(_("%s does not exist!\n") % f)
 elif not os.path.isfile(p):
-self.ui.warn(_("%s not added: only files supported currently\n") % f)
+self.ui.warn(_("%s not added: only files supported currently\n")
+% f)
 elif self.dirstate.state(f) in 'an':
 self.ui.warn(_("%s already tracked!\n") % f)
 else:
 self.dirstate.update([f], "a")
 if unlink:
 for f in list:
 try:
 util.unlink(self.wjoin(f))
 except OSError, inst:
-if inst.errno != errno.ENOENT: raise
+if inst.errno != errno.ENOENT:
+raise
 wlock = self.wlock()
 for f in list:
 p = self.wjoin(f)
 if os.path.exists(p):
 self.ui.warn(_("%s still exists!\n") % f)
 l = out.setdefault(h, [])
 l[len(l):] = self.nodetags(b)
 return out
 def branches(self, nodes):
-if not nodes: nodes = [self.changelog.tip()]
+if not nodes:
+nodes = [self.changelog.tip()]
 b = []
 for n in nodes:
 t = n
 while n:
 p = self.changelog.parents(n)
 while unknown:
 n = unknown.pop(0)
 if n[0] in seen:
 continue
-self.ui.debug(_("examining %s:%s\n") % (short(n[0]), short(n[1])))
+self.ui.debug(_("examining %s:%s\n")
+% (short(n[0]), short(n[1])))
 if n[0] == nullid:
 break
 if n in seenbranch:
 self.ui.debug(_("branch already found\n"))
 continue
 for p in range(0, len(r), 10):
 for b in remote.branches(r[p:p+10]):
 self.ui.debug(_("received %s:%s\n") %
 (short(b[0]), short(b[1])))
 if b[0] in m:
-self.ui.debug(_("found base node %s\n") % short(b[0]))
+self.ui.debug(_("found base node %s\n")
+% short(b[0]))
 base[b[0]] = 1
 elif b[0] not in seen:
 unknown.append(b)
 # do binary search on the branches we found
 subset.append(n)
 # this is the set of all roots we have to push
 return subset
-def pull(self, remote, heads = None):
+def pull(self, remote, heads=None):
 lock = self.lock()
 # if we have an empty repo, fetch everything
 if self.changelog.tip() == nullid:
 self.ui.status(_("requesting all changes\n"))
 def addchangegroup(self, source):
 def getchunk():
 d = source.read(4)
-if not d: return ""
+if not d:
+return ""
 l = struct.unpack(">l", d)[0]
-if l <= 4: return ""
+if l <= 4:
+return ""
 d = source.read(l - 4)
 if len(d) < l - 4:
 raise repo.RepoError(_("premature EOF reading chunk"
 " (got %d bytes, expected %d)")
 % (len(d), l - 4))
 return d
 def getgroup():
 while 1:
 c = getchunk()
-if not c: break
+if not c:
+break
 yield c
 def csmap(x):
 self.ui.debug(_("add changeset %s\n") % short(x))
 return self.changelog.count()
 def revmap(x):
 return self.changelog.rev(x)
-if not source: return
+if not source:
+return
 changesets = files = revisions = 0
 tr = self.transaction()
 oldheads = len(self.changelog.heads())
 # process the files
 self.ui.status(_("adding file changes\n"))
 while 1:
 f = getchunk()
-if not f: break
+if not f:
+break
 self.ui.debug(_("adding %s revisions\n") % f)
 fl = self.file(f)
 o = fl.count()
 n = fl.addgroup(getgroup(), revmap, tr)
 revisions += fl.count() - o
 tr.close()
 if changesets > 0:
 if not self.hook("changegroup",
 node=hex(self.changelog.node(cor+1))):
 self.ui.warn(_("abort: changegroup hook returned failure!\n"))
 return 1
 for i in range(cor + 1, cnr + 1):
 self.hook("commit", node=hex(self.changelog.node(i)))
 if c or a or d:
 raise util.Abort(_("outstanding uncommited changes"))
 if not forcemerge and not force:
 for f in u:
 if f in m2:
 t1 = self.wread(f)
 t2 = self.file(f).read(m2[f])
 if cmp(t1, t2) != 0:
 raise util.Abort(_("'%s' already exists in the working"
 " dir and differs from remote") % f)
 # is this a jump, or a merge?  i.e. is there a linear path
 # from p1 to p2?
 if moddirstate:
 wlock = self.wlock()
 for f in d:
-if f in mw: del mw[f]
+if f in mw:
+del mw[f]
 # If we're jumping between revisions (as opposed to merging),
 # and if neither the working directory nor the target rev has
 # the file, then we need to remove it from the dirstate, to
 # prevent the dirstate from listing the file when it is no
 if moddirstate and linear_path and f not in m2:
 self.dirstate.forget((f,))
 # Compare manifests
 for f, n in mw.iteritems():
-if choose and not choose(f): continue
+if choose and not choose(f):
+continue
 if f in m2:
 s = 0
 # is the wfile new since m1, and match m2?
 if f not in m1:
 util.set_exec(self.wjoin(f), mf2[f])
 else:
 a, b, c = mfa.get(f, 0), mfw[f], mf2[f]
 mode = ((a^b) | (a^c)) ^ a
 if mode != b:
-self.ui.debug(_(" updating permissions for %s\n") % f)
+self.ui.debug(_(" updating permissions for %s\n")
+% f)
 util.set_exec(self.wjoin(f), mode)
 del m2[f]
 elif f in ma:
 if n != ma[f]:
 r = _("d")
 self.ui.debug(_("local modified %s, keeping\n") % f)
 else:
 self.ui.debug(_("working dir created %s, keeping\n") % f)
 for f, n in m2.iteritems():
-if choose and not choose(f): continue
+if choose and not choose(f):
-if f[0] == "/": continue
+continue
+if f[0] == "/":
+continue
 if f in ma and n != ma[f]:
 r = _("k")
 if not force and (linear_path or allow):
 r = self.ui.prompt(
 (_("remote changed %s which local deleted\n") % f) +
 _("(k)eep or (d)elete?"), _("[kd]"), _("k"))
-if r == _("k"): get[f] = n
+if r == _("k"):
+get[f] = n
 elif f not in ma:
 self.ui.debug(_("remote created %s\n") % f)
 get[f] = n
 else:
 if force or p2 == pa: # going backwards?
 " affecting the following files:\n"))
 fl = merge.keys() + get.keys()
 fl.sort()
 for f in fl:
 cf = ""
-if f in merge: cf = _(" (resolve)")
+if f in merge:
+cf = _(" (resolve)")
 self.ui.status(" %s%s\n" % (f, cf))
 self.ui.warn(_("aborting update spanning branches!\n"))
 self.ui.status(_("(use update -m to merge across branches"
 " or -C to lose changes)\n"))
 return 1
 # get the files we don't need to change
 files = get.keys()
 files.sort()
 for f in files:
-if f[0] == "/": continue
+if f[0] == "/":
+continue
 self.ui.note(_("getting %s\n") % f)
 t = self.file(f).read(get[f])
 self.wwrite(f, t)
 util.set_exec(self.wjoin(f), mf2[f])
 if moddirstate:
 for f, fn in ff:
 filenodes.setdefault(f, {})[bin(fn[:40])] = 1
 self.ui.status(_("crosschecking files in changesets and manifests\n"))
-for m,c in neededmanifests.items():
+for m, c in neededmanifests.items():
 err(_("Changeset %s refers to unknown manifest %s") %
 (short(m), short(c)))
 del neededmanifests
 for f in filenodes:
 self.ui.status(_("checking files\n"))
 ff = filenodes.keys()
 ff.sort()
 for f in ff:
-if f == "/dev/null": continue
+if f == "/dev/null":
+continue
 files += 1
 fl = self.file(f)
 d = fl.checksize()
 if d:
 err(_("%s file data short %d bytes") % (f, d))
-nodes = { nullid: 1 }
+nodes = {nullid: 1}
 seen = {}
 for i in range(fl.count()):
 revisions += 1
 n = fl.node(i)

changeset 1615	83238c1db6de
parent 1597	96b47ef8f740
child 1616	f0f9e84849e7