Mercurial > hg > pyhgsh
changeset 104:20b3e7aad499
Pull from hg://edge2.net/hg/cmds
| author | mpm@selenic.com |
|---|---|
| date | Wed, 18 May 2005 17:29:10 -0800 |
| parents | 58039eddbdda (diff) 33500fe7d56c (current diff) |
| children | 6eeb50050486 |
| files | hg |
| diffstat | 10 files changed, 987 insertions(+), 434 deletions(-) [+] |
line wrap: on
line diff
--- a/.hgignore Sun May 15 15:30:36 2005 -0700 +++ b/.hgignore Wed May 18 17:29:10 2005 -0800 @@ -1,6 +1,7 @@ .*\.orig .*\.rej .*~ +.*\.so .*pyc build/.* dist/
--- a/README Sun May 15 15:30:36 2005 -0700 +++ b/README Wed May 18 17:29:10 2005 -0800 @@ -38,6 +38,8 @@ $ hg remove bar # mark a file as removed $ hg verify # check repo integrity $ hg tags # show current tags + $ hg annotate [files] # show changeset numbers for each file line + $ hg blame [files] # show commit users for each file line Branching and merging:
--- a/hg Sun May 15 15:30:36 2005 -0700 +++ b/hg Wed May 18 17:29:10 2005 -0800 @@ -38,6 +38,8 @@ dumpmanifest [rev] dump the latest or given revision of the manifest diff [files...] diff working directory (or selected files) tags show current changeset tags + annotate [files...] show changeset number per file line + blame [files...] show commit user per file line """ def filterfiles(list, files): @@ -87,7 +89,8 @@ options = {} opts = [('v', 'verbose', None, 'verbose'), - ('d', 'debug', None, 'debug')] + ('d', 'debug', None, 'debug'), + ('q', 'quiet', None, 'quiet')] args = fancyopts.fancyopts(sys.argv[1:], opts, options, 'hg [options] <command> [command options] [files]') @@ -98,7 +101,7 @@ except: cmd = "" -ui = hg.ui(options["verbose"], options["debug"]) +ui = hg.ui(options["verbose"], options["debug"], options["quiet"]) if cmd == "init": repo = hg.repository(ui, ".", create=1) @@ -112,8 +115,8 @@ else: try: repo = hg.repository(ui=ui) - except: - print "Unable to open repository" + except IOError: + ui.warn("Unable to open repository\n") sys.exit(0) relpath = None @@ -196,7 +199,7 @@ revs = map(lambda x: repo.lookup(x), doptions['revision']) if len(revs) > 2: - print "too many revisions to diff" + self.ui.warn("too many revisions to diff\n") sys.exit(1) if relpath: @@ -205,6 +208,46 @@ diff(args, *revs) +elif cmd == "annotate": + aoptions = {} + opts = [('r', 'revision', '', 'revision')] + args = fancyopts.fancyopts(args, opts, aoptions, + 'hg annotate [-r id] [files]') + if args: + node = repo.current + if aoptions['revision']: + node = repo.changelog.lookup(aoptions['revision']) + change = repo.changelog.read(node) + mmap = repo.manifest.read(change[0]) + for f in args: + for n, l in repo.file(f).annotate(mmap[f]): + sys.stdout.write("% 6s:%s"%(n, l)) + +elif cmd == "blame": + aoptions = {} + opts = [('r', 'revision', '', 'revision')] + args = fancyopts.fancyopts(args, opts, aoptions, + 'hg blame [-r id] [files]') + if args: + bcache = {} + node = repo.current + if aoptions['revision']: + node = repo.changelog.lookup(aoptions['revision']) + change = repo.changelog.read(node) + mmap = repo.manifest.read(change[0]) + for f in args: + for n, l in repo.file(f).annotate(mmap[f]): + try: + name = bcache[n] + except KeyError: + cl = repo.changelog.read(repo.changelog.node(n)) + name = cl[1] + f = name.find('@') + if f >= 0: + name = name[:f] + bcache[n] = name + sys.stdout.write("% 10s:%s"%(name, l)) + elif cmd == "export": node = repo.lookup(args[0]) prev, other = repo.changelog.parents(node) @@ -253,6 +296,11 @@ print "description:" print changes[4] +elif cmd == "tip": + n = repo.changelog.tip() + t = repo.changelog.rev(n) + ui.status("%d:%s\n" % (t, hg.hex(n))) + elif cmd == "log": if len(args) == 1: @@ -307,6 +355,9 @@ print f.encodepath(args[0]) elif cmd == "debugindex": + if ".hg" not in args[0]: + args[0] = ".hg/data/" + repo.file(args[0]).encodepath(args[0]) + "i" + r = hg.revlog(open, args[0], "") print " rev offset length base linkrev"+\ " p1 p2 nodeid" @@ -316,10 +367,23 @@ i, e[0], e[1], e[2], e[3], hg.hex(e[4][:5]), hg.hex(e[5][:5]), hg.hex(e[6][:5])) +elif cmd == "debugindexdot": + if ".hg" not in args[0]: + args[0] = ".hg/data/" + repo.file(args[0]).encodepath(args[0]) + "i" + + r = hg.revlog(open, args[0], "") + print "digraph G {" + for i in range(r.count()): + e = r.index[i] + print "\t%d -> %d" % (r.rev(e[4]), i) + if e[5] != hg.nullid: + print "\t%d -> %d" % (r.rev(e[5]), i) + print "}" + elif cmd == "merge": if args: other = hg.repository(ui, args[0]) - print "requesting changegroup" + ui.status("requesting changegroup\n") cg = repo.getchangegroup(other) repo.addchangegroup(cg) else: @@ -348,79 +412,119 @@ filenodes = {} manifestchangeset = {} changesets = revisions = files = 0 + errors = 0 - print "checking changesets" + ui.status("checking changesets\n") for i in range(repo.changelog.count()): changesets += 1 n = repo.changelog.node(i) - changes = repo.changelog.read(n) + for p in repo.changelog.parents(n): + if p not in repo.changelog.nodemap: + ui.warn("changeset %s has unknown parent %s\n" % + (hg.short(n), hg.short(p))) + errors += 1 + try: + changes = repo.changelog.read(n) + except Error, inst: + ui.warn("unpacking changeset %s: %s\n" % (short(n), inst)) + errors += 1 + manifestchangeset[changes[0]] = n for f in changes[3]: revisions += 1 filelinkrevs.setdefault(f, []).append(i) - print "checking manifests" + ui.status("checking manifests\n") for i in range(repo.manifest.count()): n = repo.manifest.node(i) + for p in repo.manifest.parents(n): + if p not in repo.manifest.nodemap: + ui.warn("manifest %s has unknown parent %s\n" % + (hg.short(n), hg.short(p))) + errors += 1 ca = repo.changelog.node(repo.manifest.linkrev(n)) cc = manifestchangeset[n] if ca != cc: - print "manifest %s points to %s, not %s" % \ - (hg.hex(n), hg.hex(ca), hg.hex(cc)) - m = repo.manifest.read(n) + ui.warn("manifest %s points to %s, not %s\n" % + (hg.hex(n), hg.hex(ca), hg.hex(cc))) + errors += 1 + + try: + m = repo.manifest.read(n) + except Exception, inst: + ui.warn("unpacking manifest %s: %s\n" % (hg.short(n), inst)) + errors += 1 + for f, fn in m.items(): filenodes.setdefault(f, {})[fn] = 1 - print "crosschecking files in changesets and manifests" + ui.status("crosschecking files in changesets and manifests\n") for f in filenodes: if f not in filelinkrevs: - print "file %s in manifest but not in changesets" + ui.warn("file %s in manifest but not in changesets\n" % f) + errors += 1 for f in filelinkrevs: if f not in filenodes: - print "file %s in changeset but not in manifest" + ui.warn("file %s in changeset but not in manifest" % f) + errors += 1 - print "checking files" + ui.status("checking files\n") for f in filenodes: files += 1 fl = repo.file(f) - nodes = {"\0"*20: 1} + nodes = { hg.nullid: 1 } for i in range(fl.count()): n = fl.node(i) if n not in filenodes[f]: - print "%s:%s not in manifests" % (f, hg.hex(n)) + ui.warn("%s:%s not in manifests\n" % (f, hg.short(n))) + errors += 1 else: del filenodes[f][n] flr = fl.linkrev(n) if flr not in filelinkrevs[f]: - print "%s:%s points to unexpected changeset rev %d" \ - % (f, hg.hex(n), fl.linkrev(n)) + ui.warn("%s:%s points to unexpected changeset rev %d\n" + % (f, hg.short(n), fl.linkrev(n))) + errors += 1 else: filelinkrevs[f].remove(flr) # verify contents - t = fl.read(n) - + try: + t = fl.read(n) + except Error, inst: + ui.warn("unpacking file %s %s: %s\n" % (f, short(n), inst)) + errors += 1 + # verify parents (p1, p2) = fl.parents(n) if p1 not in nodes: - print "%s:%s unknown parent 1 %s" % (f, hg.hex(n), hg.hex(p1)) + ui.warn("file %s:%s unknown parent 1 %s" % + (f, hg.short(n), hg.short(p1))) + errors += 1 if p2 not in nodes: - print "file %s:%s unknown parent %s" % (f, hg.hex(n), hg.hex(p1)) + ui.warn("file %s:%s unknown parent 2 %s" % + (f, hg.short(n), hg.short(p1))) + errors += 1 nodes[n] = 1 # cross-check for flr in filelinkrevs[f]: - print "changeset rev %d not in %s" % (flr, f) + ui.warn("changeset rev %d not in %s\n" % (flr, f)) + errors += 1 for node in filenodes[f]: - print "node %s in manifests not in %s" % (hg.hex(n), f) - + ui.warn("node %s in manifests not in %s\n" % (hg.hex(n), f)) + errors += 1 - print "%d files, %d changesets, %d total revisions" % (files, changesets, - revisions) + ui.status("%d files, %d changesets, %d total revisions\n" % + (files, changesets, revisions)) + + if errors: + ui.warn("%d integrity errors encountered!\n" % errors) + sys.exit(1) else: print "unknown command\n"
--- a/hgweb.py Sun May 15 15:30:36 2005 -0700 +++ b/hgweb.py Wed May 18 17:29:10 2005 -0800 @@ -24,173 +24,322 @@ l.append('&#%d;' % ord(c)) return ''.join(l) -def httphdr(type = "text/html"): +def httphdr(type): print 'Content-type: %s\n' % type -def htmldoctype(): - print '<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 3.2//EN">' +class page: + def __init__(self, type="text/html", title="Mercurial Web", + charset="ISO-8859-1"): + print 'Content-type: %s; charset=%s\n' % (type, charset) + print '<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">' + print '<HTML>' + print '<!-- created by hgweb 0.1 - jake@edge2.net -->' + print '<HEAD><TITLE>%s</TITLE>' % title + print '<style type="text/css">' + print 'body { font-family: sans-serif; font-size: 12px; }' + print 'table { font-size: 12px; }' + print '.errmsg { font-size: 200%; color: red; }' + print '.filename { font-size: 150%; color: purple; }' + print '.manifest { font-size: 150%; color: purple; }' + print '.filehist { font-size: 150%; color: purple; }' + print '.plusline { color: green; }' + print '.minusline { color: red; }' + print '.atline { color: purple; }' + print '</style>' + print '</HEAD>' + print '<BODY>' + + def endpage(self): + print '</BODY>' + print '</HTML>' -def htmlhead(title): - print '<HTML>' - print '<!-- created by hgweb 0.1 - jake@edge2.net -->' - print '<HEAD><TITLE>%s</TITLE></HEAD>' % (title, ) - print '<style type="text/css">' - print 'body { font-family: sans-serif; font-size: 12px; }' - print 'table { font-size: 12px; }' - print '.errmsg { font-size: 200%; color: red; }' - print '.filename { font-size: 150%; color: purple; }' - print '.plusline { color: green; }' - print '.minusline { color: red; }' - print '.atline { color: purple; }' - print '</style>' + def show_diff(self, a, b, fn): + a = a.splitlines(1) + b = b.splitlines(1) + l = difflib.unified_diff(a, b, fn, fn) + print '<pre>' + for line in l: + line = cgi.escape(line[:-1]) + if line.startswith('+'): + print '<span class="plusline">%s</span>' % (line, ) + elif line.startswith('-'): + print '<span class="minusline">%s</span>' % (line, ) + elif line.startswith('@'): + print '<span class="atline">%s</span>' % (line, ) + else: + print line + print '</pre>' -def startpage(title): - httphdr() - htmldoctype() - htmlhead(title) - print '<BODY>' +class errpage(page): + def __init__(self): + page.__init__(self, title="Mercurial Web Error Page") + +class change_list(page): -def endpage(): - print '</BODY>' - print '</HTML>' + numchanges = 50 # number of changes to show - + def __init__(self, repo, reponame): + page.__init__(self) + self.repo = repo + print '<h3>Changes For: %s</h3>' % reponame -def ent_change(repo, nodeid): - changes = repo.changelog.read(nodeid) - hn = hg.hex(nodeid) - i = repo.changelog.rev(nodeid) - (h1, h2) = [ hg.hex(x) for x in repo.changelog.parents(nodeid) ] - datestr = time.asctime(time.gmtime(float(changes[2].split(' ')[0]))) - print '<table width="100%" border="1">' - print '\t<tr><td valign="top" width="10%%">author:</td>' + \ - '<td valign="top" width="20%%">%s</td>' % (obfuscate(changes[1]), ) - print '\t\t<td valign="top" width="10%%">description:</td>' + \ - '<td width="60%%">' + \ - '<a href="?cmd=chkin;nd=%s">%s</a></td></tr>' % \ - (hn, nl2br(changes[4]), ) - print '\t<tr><td>date:</td><td>%s UTC</td>' % (datestr, ) - print '\t\t<td valign="top">files:</td><td valign="top">' - for f in changes[3]: - print '\t\t%s ' % f - print '\t</td></tr>' -# print '\t<tr><td>revision:</td><td colspan="3">%d:<a ' % (i, ) + \ -# 'href="?cmd=rev;nd=%s">%s</a></td></tr>' % (hn, hn, ) - print '</table><br />' + def content(self, hi=None): + cl = [] + count = self.repo.changelog.count() + if not hi: + hi = count + elif hi < self.numchanges: + hi = self.numchanges + + start = 0 + if hi - self.numchanges >= 0: + start = hi - self.numchanges + + nav = "Displaying Revisions: %d-%d" % (start, hi-1) + if start != 0: + nav = ('<a href="?cmd=changes;hi=%d">Previous %d</a> ' \ + % (start, self.numchanges)) + nav + if hi != count: + if hi + self.numchanges <= count: + nav += ' <a href="?cmd=changes;hi=%d">Next %d</a>' \ + % (hi + self.numchanges, self.numchanges) + else: + nav += ' <a href="?cmd=changes">Next %d</a>' % \ + self.numchanges + + print '<center>%s</center>' % nav + + for i in xrange(start, hi): + n = self.repo.changelog.node(i) + cl.append((n, self.repo.changelog.read(n))) + cl.reverse() -def ent_diff(a, b, fn): - a = a.splitlines(1) - b = b.splitlines(1) - l = difflib.unified_diff(a, b, fn, fn) - print '<pre>' - for line in l: - line = cgi.escape(line[:-1]) - if line.startswith('+'): - print '<span class="plusline">%s</span>' % (line, ) - elif line.startswith('-'): - print '<span class="minusline">%s</span>' % (line, ) - elif line.startswith('@'): - print '<span class="atline">%s</span>' % (line, ) - else: - print line - print '</pre>' + print '<table summary="" width="100%" align="center">' + for n, ch in cl: + print '<tr><td>' + self.change_table(n, ch) + print '</td></tr>' + print '</table>' + + print '<center>%s</center>' % nav + + def change_table(self, nodeid, changes): + hn = hg.hex(nodeid) + i = self.repo.changelog.rev(nodeid) + (h1, h2) = [ hg.hex(x) for x in self.repo.changelog.parents(nodeid) ] + datestr = time.asctime(time.gmtime(float(changes[2].split(' ')[0]))) + print '<table summary="" width="100%" border="1">' + print '\t<tr><td valign="top" width="10%">author:</td>' + \ + '<td valign="top" width="20%%">%s</td>' % \ + (obfuscate(changes[1]), ) + print '\t\t<td valign="top" width="10%">description:</td>' + \ + '<td width="60%">' + \ + '<a href="?cmd=chkin;nd=%s">%s</a></td></tr>' % \ + (hn, nl2br(cgi.escape(changes[4])), ) + print '\t<tr><td>date:</td><td>%s UTC</td>' % (datestr, ) + print '\t\t<td valign="top">files:</td><td valign="top">' + for f in changes[3]: + print '\t\t<a href="?cmd=file;cs=%s;fn=%s">%s</a> ' % \ + (hn, f, cgi.escape(f), ) + print '\t</td></tr>' + print '\t<tr><td>revision:</td><td colspan="3">%d:<a ' % (i, ) + \ + 'href="?cmd=chkin;nd=%s">%s</a></td></tr>' % (hn, hn, ) + print '</table><br />' + +class checkin(page): + def __init__(self, repo, nodestr): + page.__init__(self) + self.repo = repo + self.node = hg.bin(nodestr) + self.nodestr = nodestr + print '<h3>Checkin: %s</h3>' % nodestr -def ent_checkin(repo, nodeid): - startpage("Mercurial Web") + def content(self): + changes = self.repo.changelog.read(self.node) + i = self.repo.changelog.rev(self.node) + parents = self.repo.changelog.parents(self.node) + (h1, h2) = [ hg.hex(x) for x in parents ] + (i1, i2) = [ self.repo.changelog.rev(x) for x in parents ] + datestr = time.asctime(time.gmtime(float(changes[2].split(' ')[0]))) + mf = self.repo.manifest.read(changes[0]) + print '<table summary="" width="100%" border="1">' + print '\t<tr><td>revision:</td><td colspan="3">%d:' % (i, ), + print '<a href="?cmd=chkin;nd=%s">%s</a></td></tr>' % \ + (self.nodestr, self.nodestr, ) + print '\t<tr><td>parent(s):</td><td colspan="3">%d:' % (i1, ) + print '<a href="?cmd=chkin;nd=%s">%s</a>' % (h1, h1, ), + if i2 != -1: + print ' %d:<a href="?cmd=chkin;nd=%s">%s</a>' % \ + (i2, h2, h2, ), + else: + print ' %d:%s' % (i2, h2, ), + print '</td></tr>' + print '\t<tr><td>manifest:</td><td colspan="3">%d:' % \ + (self.repo.manifest.rev(changes[0]), ), + print '<a href="?cmd=mf;nd=%s">%s</a></td></tr>' % \ + (hg.hex(changes[0]), hg.hex(changes[0]), ) + print '\t<tr><td valign="top" width="10%">author:</td>' + \ + '<td valign="top" width="20%%">%s</td>' % \ + (obfuscate(changes[1]), ) + print '\t\t<td valign="top" width="10%">description:</td>' + \ + '<td width="60%">' + \ + '<a href="?cmd=chkin;nd=%s">%s</a></td></tr>' % \ + (self.nodestr, nl2br(cgi.escape(changes[4])), ) + print '\t<tr><td>date:</td><td>%s UTC</td>' % (datestr, ) + print '\t\t<td valign="top">files:</td><td valign="top">' + for f in changes[3]: + print '\t\t<a href="?cmd=file;nd=%s&fn=%s">%s</a>' % \ + (hg.hex(mf[f]), f, cgi.escape(f), ), + print ' ' + print '\t</td></tr>' + print '</table><br />' + + (c, a, d) = self.repo.diffrevs(parents[0], self.node) + change = self.repo.changelog.read(parents[0]) + mf2 = self.repo.manifest.read(change[0]) + for f in c: + self.show_diff(self.repo.file(f).read(mf2[f]), \ + self.repo.file(f).read(mf[f]), f) + for f in a: + self.show_diff('', self.repo.file(f).read(mf[f]), f) + for f in d: + self.show_diff(self.repo.file(f).read(mf2[f]), '', f) + +class filepage(page): + def __init__(self, repo, fn, node=None, cs=None): + page.__init__(self) + self.repo = repo + self.fn = fn + if cs: + chng = self.repo.changelog.read(hg.bin(cs)) + mf = self.repo.manifest.read(chng[0]) + self.node = mf[self.fn] + self.nodestr = hg.hex(self.node) + else: + self.nodestr = node + self.node = hg.bin(node) + print '<div class="filename">%s (%s)</div>' % \ + (cgi.escape(self.fn), self.nodestr, ) + print '<a href="?cmd=hist;fn=%s">history</a><br />' % self.fn - changes = repo.changelog.read(nodeid) - hn = hg.hex(nodeid) - i = repo.changelog.rev(nodeid) - parents = repo.changelog.parents(nodeid) - (h1, h2) = [ hg.hex(x) for x in parents ] - (i1, i2) = [ repo.changelog.rev(x) for x in parents ] - datestr = time.asctime(time.gmtime(float(changes[2].split(' ')[0]))) - mf = repo.manifest.read(changes[0]) - print '<table width="100%" border="1">' - print '\t<tr><td>revision:</td><td colspan="3">%d:' % (i, ), - print '<a href="?cmd=rev;nd=%s">%s</a></td></tr>' % (hn, hn, ) - print '\t<tr><td>parent(s):</td><td colspan="3">%d:' % (i1, ) - print '<a href="?cmd=rev;nd=%s">%s</a>' % (h1, h1, ), - if i2 != -1: - print ' %d:<a href="?cmd=rev;nd=%s">%s</a>' % \ - (i2, h2, h2, ), - else: - print ' %d:%s' % (i2, h2, ), - print '</td></tr>' - print '\t<tr><td>manifest:</td><td colspan="3">%d:' % \ - (repo.manifest.rev(changes[0]), ), - print '<a href="?cmd=mf;nd=%s">%s</a></td></tr>' % \ - (hg.hex(changes[0]), hg.hex(changes[0]), ) - print '\t<tr><td valign="top" width="10%%">author:</td>' + \ - '<td valign="top" width="20%%">%s</td>' % (obfuscate(changes[1]), ) - print '\t\t<td valign="top" width="10%%">description:</td>' + \ - '<td width="60%%">' + \ - '<a href="?cmd=chkin;nd=%s">%s</a></td></tr>' % \ - (hn, nl2br(changes[4]), ) - print '\t<tr><td>date:</td><td>%s UTC</td>' % (datestr, ) - print '\t\t<td valign="top">files:</td><td valign="top">' - for f in changes[3]: - print '\t\t<a href="?cmd=file;nd=%s&fn=%s">%s</a>' % \ - (hg.hex(mf[f]), f, f, ), - print ' ' - print '\t</td></tr>' - print '</table><br />' + def content(self): + print '<pre>' + print cgi.escape(self.repo.file(self.fn).read(self.node)) + print '</pre>' + +class mfpage(page): + def __init__(self, repo, node): + page.__init__(self) + self.repo = repo + self.nodestr = node + self.node = hg.bin(node) + + def content(self): + mf = self.repo.manifest.read(self.node) + fns = mf.keys() + fns.sort() + print '<div class="manifest">Manifest (%s)</div>' % self.nodestr + for f in fns: + print '<a href="?cmd=file;fn=%s;nd=%s">%s</a><br />' % \ + (f, hg.hex(mf[f]), f) + +class histpage(page): + def __init__(self, repo, fn): + page.__init__(self) + self.repo = repo + self.fn = fn - (c, a, d) = repo.diffrevs(parents[0], nodeid) - change = repo.changelog.read(parents[0]) - mf2 = repo.manifest.read(change[0]) - for f in c: - ent_diff(repo.file(f).read(mf2[f]), repo.file(f).read(mf[f]), f) - for f in a: - ent_diff('', repo.file(f).read(mf[f]), f) - for f in d: - ent_diff(repo.file(f).read(mf2[f]), '', f) - - endpage() - + def content(self): + print '<div class="filehist">File History: %s</div>' % self.fn + r = self.repo.file(self.fn) + print '<br />' + print '<table summary="" width="100%" align="center">' + for i in xrange(r.count()-1, -1, -1): + n = r.node(i) + (p1, p2) = r.parents(n) + (h, h1, h2) = map(hg.hex, (n, p1, p2)) + (i1, i2) = map(r.rev, (p1, p2)) + ci = r.linkrev(n) + cn = self.repo.changelog.node(ci) + cs = hg.hex(cn) + changes = self.repo.changelog.read(cn) + print '<tr><td>' + self.hist_ent(i, h, i1, h1, i2, h2, ci, cs, changes) + print '</tr></td>' + print '</table>' -def ent_file(repo, nodeid, fn): - print '<div class="filename">%s (%s)</div>' % (fn, hg.hex(nodeid), ) - print '<pre>' - print cgi.escape(repo.file(fn).read(nodeid)) - print '</pre>' - -def change_page(): - startpage("Mercurial Web") - print '<table width="100%" align="center">' - for i in xrange(0, repo.changelog.count()): - n = repo.changelog.node(i) - print '<tr><td>' - ent_change(repo, n) - print '</td></th>' - - print '</table>' - endpage() + def hist_ent(self, revi, revs, p1i, p1s, p2i, p2s, ci, cs, changes): + datestr = time.asctime(time.gmtime(float(changes[2].split(' ')[0]))) + print '<table summary="" width="100%" border="1">' + print '\t<tr><td valign="top" width="10%">author:</td>' + \ + '<td valign="top" width="20%%">%s</td>' % \ + (obfuscate(changes[1]), ) + print '\t\t<td valign="top" width="10%">description:</td>' + \ + '<td width="60%">' + \ + '<a href="?cmd=chkin;nd=%s">%s</a></td></tr>' % \ + (cs, nl2br(cgi.escape(changes[4])), ) + print '\t<tr><td>date:</td><td>%s UTC</td>' % (datestr, ) + print '\t\t<td>revision:</td><td>%d:<a ' % (revi, ) + \ + 'href="?cmd=file;cs=%s;fn=%s">%s</a></td></tr>' % \ + (cs, self.fn, revs ) + print '\t<tr><td>parent(s):</td><td colspan="3">%d:' % (p1i, ) + print '<a href="?cmd=file;nd=%s;fn=%s">%s</a>' % (p1s, self.fn, p1s, ), + if p2i != -1: + print ' %d:<a href="?cmd=file;nd=%s;fn=%s">%s</a>' % \ + (p2i, p2s, self.fn, p2s ), + print '</td></tr>' + print '</table><br />' args = cgi.parse() ui = hg.ui() repo = hg.repository(ui, repo_path) -if not args.has_key('cmd'): - change_page() +if not args.has_key('cmd') or args['cmd'][0] == 'changes': + page = change_list(repo, 'Mercurial') + hi = args.get('hi', ( repo.changelog.count(), )) + page.content(hi = int(hi[0])) + page.endpage() elif args['cmd'][0] == 'chkin': if not args.has_key('nd'): + page = errpage() print '<div class="errmsg">No Node!</div>' else: - ent_checkin(repo, hg.bin(args['nd'][0])) + page = checkin(repo, args['nd'][0]) + page.content() + page.endpage() elif args['cmd'][0] == 'file': - startpage("Mercurial Web") + if not (args.has_key('nd') and args.has_key('fn')) and \ + not (args.has_key('cs') and args.has_key('fn')): + page = errpage() + print '<div class="errmsg">Invalid Args!</div>' + else: + if args.has_key('nd'): + page = filepage(repo, args['fn'][0], node=args['nd'][0]) + else: + page = filepage(repo, args['fn'][0], cs=args['cs'][0]) + page.content() + page.endpage() +elif args['cmd'][0] == 'mf': if not args.has_key('nd'): + page = errpage() print '<div class="errmsg">No Node!</div>' - elif not args.has_key('fn'): + else: + page = mfpage(repo, args['nd'][0]) + page.content() + page.endpage() + +elif args['cmd'][0] == 'hist': + if not args.has_key('fn'): + page = errpage() print '<div class="errmsg">No Filename!</div>' else: - ent_file(repo, hg.bin(args['nd'][0]), args['fn'][0]) - endpage() + page = histpage(repo, args['fn'][0]) + page.content() + page.endpage() elif args['cmd'][0] == 'branches': httphdr("text/plain") @@ -222,6 +371,7 @@ sys.stdout.write(z.flush()) else: - startpage("Mercurial Web Error") - print '<div class="errmsg">unknown command: ', args['cmd'][0], '</div>' - endpage() + page = errpage() + print '<div class="errmsg">unknown command: %s</div>' % \ + cgi.escape(args['cmd'][0]) + page.endpage()
--- a/mercurial/hg.py Sun May 15 15:30:36 2005 -0700 +++ b/mercurial/hg.py Wed May 18 17:29:10 2005 -0800 @@ -10,6 +10,7 @@ from mercurial import byterange from mercurial.transaction import * from mercurial.revlog import * +from difflib import SequenceMatcher class filelog(revlog): def __init__(self, opener, path): @@ -29,41 +30,31 @@ def add(self, text, transaction, link, p1=None, p2=None): return self.addrevision(text, transaction, link, p1, p2) - def resolvedag(self, old, new, transaction, link): - """resolve unmerged heads in our DAG""" - if old == new: return None - a = self.ancestor(old, new) - if old == a: return None - return self.merge3(old, new, a, transaction, link) - - def merge3(self, my, other, base, transaction, link): - """perform a 3-way merge and append the result""" - def temp(prefix, node): - (fd, name) = tempfile.mkstemp(prefix) - f = os.fdopen(fd, "w") - f.write(self.revision(node)) - f.close() - return name - - a = temp("local", my) - b = temp("remote", other) - c = temp("parent", base) - - cmd = os.environ["HGMERGE"] - r = os.system("%s %s %s %s" % (cmd, a, b, c)) - if r: - raise "Merge failed, implement rollback!" - - t = open(a).read() - os.unlink(a) - os.unlink(b) - os.unlink(c) - return self.addrevision(t, transaction, link, my, other) - - def merge(self, other, transaction, linkseq, link): - """perform a merge and resolve resulting heads""" - (o, n) = self.mergedag(other, transaction, linkseq) - return self.resolvedag(o, n, transaction, link) + def annotate(self, node): + revs = [] + while node != nullid: + revs.append(node) + node = self.parents(node)[0] + revs.reverse() + prev = [] + annotate = [] + for node in revs: + curr = self.read(node).splitlines(1) + linkrev = self.linkrev(node) + sm = SequenceMatcher(None, prev, curr) + offset = 0 + for o, m, n, s, t in sm.get_opcodes(): + if o in ('insert','replace'): + annotate[m+offset:n+offset] = \ + [ (linkrev, l) for l in curr[s:t]] + if o == 'insert': + offset += m-n + elif o == 'delete': + del annotate[m+offset:n+offset] + offset -= m-n + assert len(annotate) == len(curr) + prev = curr + return annotate class manifest(revlog): def __init__(self, opener): @@ -74,7 +65,7 @@ def read(self, node): if self.mapcache and self.mapcache[0] == node: - return self.mapcache[1] + return self.mapcache[1].copy() text = self.revision(node) map = {} self.listcache = (text, text.splitlines(1)) @@ -87,7 +78,11 @@ def diff(self, a, b): # this is sneaky, as we're not actually using a and b if self.listcache and len(self.listcache[0]) == len(a): - return mdiff.diff(self.listcache[1], self.addlist, 1) + d = mdiff.diff(self.listcache[1], self.addlist, 1) + if mdiff.patch(a, d) != b: + sys.stderr.write("*** sortdiff failed, falling back ***\n") + return mdiff.textdiff(a, b) + return d else: return mdiff.textdiff(a, b) @@ -133,9 +128,6 @@ text = "\n".join(l) return self.addrevision(text, transaction, self.count(), p1, p2) - def merge3(self, my, other, base): - pass - class dircache: def __init__(self, opener, ui): self.opener = opener @@ -306,123 +298,8 @@ return filelog(self.opener, f) def transaction(self): - return transaction(self.opener, self.join("journal")) - - def merge(self, other): - tr = self.transaction() - changed = {} - new = {} - seqrev = self.changelog.count() - # some magic to allow fiddling in nested scope - nextrev = [seqrev] - - # helpers for back-linking file revisions to local changeset - # revisions so we can immediately get to changeset from annotate - def accumulate(text): - # track which files are added in which changeset and the - # corresponding _local_ changeset revision - files = self.changelog.extract(text)[3] - for f in files: - changed.setdefault(f, []).append(nextrev[0]) - nextrev[0] += 1 - - def seq(start): - while 1: - yield start - start += 1 - - def lseq(l): - for r in l: - yield r - - # begin the import/merge of changesets - self.ui.status("merging new changesets\n") - (co, cn) = self.changelog.mergedag(other.changelog, tr, - seq(seqrev), accumulate) - resolverev = self.changelog.count() - - # is there anything to do? - if co == cn: - tr.close() - return - - # do we need to resolve? - simple = (co == self.changelog.ancestor(co, cn)) - - # merge all files changed by the changesets, - # keeping track of the new tips - changelist = changed.keys() - changelist.sort() - for f in changelist: - sys.stdout.write(".") - sys.stdout.flush() - r = self.file(f) - node = r.merge(other.file(f), tr, lseq(changed[f]), resolverev) - if node: - new[f] = node - sys.stdout.write("\n") - - # begin the merge of the manifest - self.ui.status("merging manifests\n") - (mm, mo) = self.manifest.mergedag(other.manifest, tr, seq(seqrev)) - - # For simple merges, we don't need to resolve manifests or changesets - if simple: - tr.close() - return - - ma = self.manifest.ancestor(mm, mo) - - # resolve the manifest to point to all the merged files - self.ui.status("resolving manifests\n") - mmap = self.manifest.read(mm) # mine - omap = self.manifest.read(mo) # other - amap = self.manifest.read(ma) # ancestor - nmap = {} - - for f, mid in mmap.iteritems(): - if f in omap: - if mid != omap[f]: - nmap[f] = new.get(f, mid) # use merged version - else: - nmap[f] = new.get(f, mid) # they're the same - del omap[f] - elif f in amap: - if mid != amap[f]: - pass # we should prompt here - else: - pass # other deleted it - else: - nmap[f] = new.get(f, mid) # we created it - - del mmap - - for f, oid in omap.iteritems(): - if f in amap: - if oid != amap[f]: - pass # this is the nasty case, we should prompt - else: - pass # probably safe - else: - nmap[f] = new.get(f, oid) # remote created it - - del omap - del amap - - node = self.manifest.add(nmap, tr, resolverev, mm, mo) - - # Now all files and manifests are merged, we add the changed files - # and manifest id to the changelog - self.ui.status("committing merge changeset\n") - new = new.keys() - new.sort() - if co == cn: cn = -1 - - edittext = "\n"+"".join(["HG: changed %s\n" % f for f in new]) - edittext = self.ui.edit(edittext) - n = self.changelog.add(node, new, edittext, tr, co, cn) - - tr.close() + return transaction(self.opener, self.join("journal"), + self.join("undo")) def commit(self, parent, update = None, text = ""): tr = self.transaction() @@ -441,6 +318,7 @@ new = {} linkrev = self.changelog.count() for f in update: + self.ui.note(f + "\n") try: t = file(f).read() except IOError: @@ -488,6 +366,7 @@ l.sort() stats = [] for f in l: + self.ui.note(f + "\n") r = self.file(f) t = r.revision(mmap[f]) try: @@ -611,43 +490,57 @@ def newer(self, nodes): m = {} nl = [] + pm = {} cl = self.changelog t = l = cl.count() + + # find the lowest numbered node for n in nodes: l = min(l, cl.rev(n)) - for p in cl.parents(n): - m[p] = 1 + m[n] = 1 for i in xrange(l, t): n = cl.node(i) + if n in m: # explicitly listed + pm[n] = 1 + nl.append(n) + continue for p in cl.parents(n): - if p in m and n not in m: - m[n] = 1 + if p in pm: # parent listed + pm[n] = 1 nl.append(n) + break return nl def getchangegroup(self, remote): tip = remote.branches([])[0] + self.ui.debug("remote tip branch is %s:%s\n" % + (short(tip[0]), short(tip[1]))) m = self.changelog.nodemap unknown = [tip] search = [] fetch = [] if tip[0] in m: + self.ui.note("nothing to do!\n") return None while unknown: n = unknown.pop(0) if n == nullid: break if n[1] and n[1] in m: # do we know the base? + self.ui.debug("found incomplete branch %s\n" % short(n[1])) search.append(n) # schedule branch range for scanning else: + if n[2] in m and n[3] in m: + if n[1] not in fetch: + self.ui.debug("found new changeset %s\n" % + short(n[1])) + fetch.append(n[1]) # earliest unknown + continue for b in remote.branches([n[2], n[3]]): - if b[0] in m: - if n[1] not in fetch: - fetch.append(n[1]) # earliest unknown - else: + if b[0] not in m: unknown.append(b) while search: @@ -657,16 +550,23 @@ f = 1 for i in l + [n[1]]: if i in m: - if f <= 4: + if f <= 2: + self.ui.debug("found new branch changeset %s\n" % + short(p)) fetch.append(p) else: + self.ui.debug("narrowed branch search to %s:%s\n" + % (short(p), short(i))) search.append((p, i)) break p, f = i, f * 2 for f in fetch: if f in m: - raise "already have", hex(f[:4]) + raise "already have", short(f[:4]) + + self.ui.note("adding new changesets starting at " + + " ".join([short(f) for f in fetch]) + "\n") return remote.changegroup(fetch) @@ -725,17 +625,21 @@ tr = self.transaction() simple = True - print "merging changesets" + self.ui.status("adding changesets\n") # pull off the changeset group + def report(x): + self.ui.debug("add changeset %s\n" % short(x)) + return self.changelog.count() + csg = getchunk() co = self.changelog.tip() - cn = self.changelog.addgroup(csg, lambda x: self.changelog.count(), tr) + cn = self.changelog.addgroup(csg, report, tr) - print "merging manifests" + self.ui.status("adding manifests\n") # pull off the manifest group mfg = getchunk() - mo = self.manifest.tip() - mm = self.manifest.addgroup(mfg, lambda x: self.changelog.rev(x), tr) + mm = self.manifest.tip() + mo = self.manifest.addgroup(mfg, lambda x: self.changelog.rev(x), tr) # do we need a resolve? if self.changelog.ancestor(co, cn) != co: @@ -743,57 +647,70 @@ resolverev = self.changelog.count() # process the files - print "merging files" + self.ui.status("adding files\n") new = {} while 1: f = getchunk(4) if not f: break fg = getchunk() - + self.ui.debug("adding %s revisions\n" % f) fl = self.file(f) o = fl.tip() n = fl.addgroup(fg, lambda x: self.changelog.rev(x), tr) if not simple: - nn = fl.resolvedag(o, n, tr, resolverev) - if nn: new[f] = nn + if o == n: continue + # this file has changed between branches, so it must be + # represented in the merge changeset + new[f] = self.merge3(fl, f, o, n, tr, resolverev) # For simple merges, we don't need to resolve manifests or changesets if simple: + self.ui.debug("simple merge, skipping resolve\n") tr.close() return # resolve the manifest to point to all the merged files self.ui.status("resolving manifests\n") ma = self.manifest.ancestor(mm, mo) - mmap = self.manifest.read(mm) # mine omap = self.manifest.read(mo) # other amap = self.manifest.read(ma) # ancestor + mmap = self.manifest.read(mm) # mine + self.ui.debug("ancestor %s local %s other %s\n" % + (short(ma), short(mm), short(mo))) nmap = {} for f, mid in mmap.iteritems(): if f in omap: - if mid != omap[f]: - nmap[f] = new.get(f, mid) # use merged version + if mid != omap[f]: + self.ui.debug("%s versions differ\n" % f) + if f in new: self.ui.debug("%s updated in resolve\n" % f) + # use merged version or local version + nmap[f] = new.get(f, mid) else: - nmap[f] = new.get(f, mid) # they're the same + nmap[f] = mid # keep ours del omap[f] elif f in amap: - if mid != amap[f]: + if mid != amap[f]: + self.ui.debug("local changed %s which other deleted\n" % f) pass # we should prompt here else: + self.ui.debug("other deleted %s\n" % f) pass # other deleted it else: - nmap[f] = new.get(f, mid) # we created it + self.ui.debug("local created %s\n" %f) + nmap[f] = mid # we created it del mmap for f, oid in omap.iteritems(): if f in amap: if oid != amap[f]: + self.ui.debug("other changed %s which we deleted\n" % f) pass # this is the nasty case, we should prompt else: pass # probably safe else: + self.ui.debug("remote created %s\n" % f) nmap[f] = new.get(f, oid) # remote created it del omap @@ -808,18 +725,56 @@ new.sort() if co == cn: cn = -1 - edittext = "\n"+"".join(["HG: changed %s\n" % f for f in new]) + edittext = "\nHG: merge resolve\n" + \ + "".join(["HG: changed %s\n" % f for f in new]) edittext = self.ui.edit(edittext) n = self.changelog.add(node, new, edittext, tr, co, cn) tr.close() + def merge3(self, fl, fn, my, other, transaction, link): + """perform a 3-way merge and append the result""" + + def temp(prefix, node): + pre = "%s~%s." % (os.path.basename(fn), prefix) + (fd, name) = tempfile.mkstemp("", pre) + f = os.fdopen(fd, "w") + f.write(fl.revision(node)) + f.close() + return name + + base = fl.ancestor(my, other) + self.ui.note("resolving %s\n" % fn) + self.ui.debug("local %s remote %s ancestor %s\n" % + (short(my), short(other), short(base))) + + if my == base: + text = fl.revision(other) + else: + a = temp("local", my) + b = temp("remote", other) + c = temp("parent", base) + + cmd = os.environ["HGMERGE"] + self.ui.debug("invoking merge with %s\n" % cmd) + r = os.system("%s %s %s %s" % (cmd, a, b, c)) + if r: + raise "Merge failed!" + + text = open(a).read() + os.unlink(a) + os.unlink(b) + os.unlink(c) + + return fl.addrevision(text, transaction, link, my, other) + class remoterepository: def __init__(self, ui, path): self.url = path.replace("hg://", "http://", 1) self.ui = ui def do_cmd(self, cmd, **args): + self.ui.debug("sending %s command\n" % cmd) q = {"cmd": cmd} q.update(args) qs = urllib.urlencode(q) @@ -856,8 +811,10 @@ return localrepository(ui, path, create) class ui: - def __init__(self, verbose=False, debug=False): - self.verbose = verbose + def __init__(self, verbose=False, debug=False, quiet=False): + self.quiet = quiet and not verbose and not debug + self.verbose = verbose or debug + self.debugflag = debug def write(self, *args): for a in args: sys.stdout.write(str(a)) @@ -868,13 +825,13 @@ if re.match(pat, r): return r def status(self, *msg): - self.write(*msg) + if not self.quiet: self.write(*msg) def warn(self, msg): self.write(*msg) def note(self, msg): if self.verbose: self.write(*msg) def debug(self, msg): - if self.debug: self.write(*msg) + if self.debugflag: self.write(*msg) def edit(self, text): (fd, name) = tempfile.mkstemp("hg") f = os.fdopen(fd, "w")
--- a/mercurial/mdiff.py Sun May 15 15:30:36 2005 -0700 +++ b/mercurial/mdiff.py Wed May 18 17:29:10 2005 -0800 @@ -71,6 +71,9 @@ bl = len(a) + pl tl = bl + bl + pl # enough for the patches and two working texts b1, b2 = 0, bl + + if not tl: return a + m = mmap.mmap(devzero.fileno(), tl, mmap.MAP_PRIVATE) # load our original text @@ -122,23 +125,10 @@ return m[t[1]:t[1] + t[0]] def patch(a, bin): - last = pos = 0 - r = [] + return patches(a, [bin]) - c = 0 - while pos < len(bin): - p1, p2, l = struct.unpack(">lll", bin[pos:pos + 12]) - pos += 12 - r.append(a[last:p1]) - r.append(bin[pos:pos + l]) - pos += l - last = p2 - c += 1 - r.append(a[last:]) - - return "".join(r) - - - - - +try: + import mpatch + patches = mpatch.patches +except: + pass
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/mercurial/mpatch.c Wed May 18 17:29:10 2005 -0800 @@ -0,0 +1,293 @@ +/* + mpatch.c - efficient binary patching for Mercurial + + This implements a patch algorithm that's O(m + nlog n) where m is the + size of the output and n is the number of patches. + + Given a list of binary patches, it unpacks each into a hunk list, + then combines the hunk lists with a treewise recursion to form a + single hunk list. This hunk list is then applied to the original + text. + + The text (or binary) fragments are copied directly from their source + Python objects into a preallocated output string to avoid the + allocation of intermediate Python objects. Working memory is about 2x + the total number of hunks. + + Copyright 2005 Matt Mackall <mpm@selenic.com> + + This software may be used and distributed according to the terms + of the GNU General Public License, incorporated herein by reference. +*/ + +#include <Python.h> +#include <stdlib.h> +#include <string.h> +#include <netinet/in.h> +#include <sys/types.h> + +static char mpatch_doc[] = "Efficient binary patching."; + +struct frag { + int start, end, len; + char *data; +}; + +struct flist { + struct frag *base, *head, *tail; +}; + +static struct flist *lalloc(int size) +{ + struct flist *a; + + a = malloc(sizeof(struct flist)); + a->head = a->tail = a->base = malloc(sizeof(struct frag) * size); + return a; +} + +static void lfree(struct flist *a) +{ + free(a->base); + free(a); +} + +static int lsize(struct flist *a) +{ + return a->tail - a->head; +} + +/* move hunks in source that are less cut to dest, compensating + for changes in offset. the last hunk may be split if necessary. +*/ +static int gather(struct flist *dest, struct flist *src, int cut, int offset) +{ + struct frag *d = dest->tail, *s = src->head; + int postend, c, l; + + while (s != src->tail) { + if (s->start + offset >= cut) + break; /* we've gone far enough */ + + postend = offset + s->start + s->len; + if (postend <= cut) { + /* save this hunk */ + offset += s->start + s->len - s->end; + *d++ = *s++; + } + else { + /* break up this hunk */ + c = cut - offset; + if (s->end < c) + c = s->end; + l = cut - offset - s->start; + if (s->len < l) + l = s->len; + + offset += s->start + l - c; + + d->start = s->start; + d->end = c; + d->len = l; + d->data = s->data; + d++; + s->start = c; + s->len = s->len - l; + s->data = s->data + l; + + break; + } + } + + dest->tail = d; + src->head = s; + return offset; +} + +/* like gather, but with no output list */ +static int discard(struct flist *src, int cut, int offset) +{ + struct frag *s = src->head; + int postend, c, l; + + while (s != src->tail) { + if (s->start + offset >= cut) + break; + + postend = offset + s->start + s->len; + if (postend <= cut) { + offset += s->start + s->len - s->end; + s++; + } + else { + c = cut - offset; + if (s->end < c) + c = s->end; + l = cut - offset - s->start; + if (s->len < l) + l = s->len; + + offset += s->start + l - c; + s->start = c; + s->len = s->len - l; + s->data = s->data + l; + + break; + } + } + + src->head = s; + return offset; +} + +/* combine hunk lists a and b, while adjusting b for offset changes in a/ + this deletes a and b and returns the resultant list. */ +static struct flist *combine(struct flist *a, struct flist *b) +{ + struct flist *c; + struct frag *bh = b->head, *ct; + int offset = 0, post; + + c = lalloc((lsize(a) + lsize(b)) * 2); + + while (bh != b->tail) { + /* save old hunks */ + offset = gather(c, a, bh->start, offset); + + /* discard replaced hunks */ + post = discard(a, bh->end, offset); + + /* insert new hunk */ + ct = c->tail; + ct->start = bh->start - offset; + ct->end = bh->end - post; + ct->len = bh->len; + ct->data = bh->data; + c->tail++; + bh++; + offset = post; + } + + /* hold on to tail from a */ + memcpy(c->tail, a->head, sizeof(struct frag) * lsize(a)); + c->tail += lsize(a); + lfree(a); + lfree(b); + return c; +} + +/* decode a binary patch into a hunk list */ +static struct flist *decode(char *bin, int len) +{ + struct flist *l; + struct frag *lt; + char *end = bin + len; + + /* assume worst case size, we won't have many of these lists */ + l = lalloc(len / 12); + lt = l->tail; + + while (bin < end) { + lt->start = ntohl(*(uint32_t *)bin); + lt->end = ntohl(*(uint32_t *)(bin + 4)); + lt->len = ntohl(*(uint32_t *)(bin + 8)); + lt->data = bin + 12; + bin += 12 + lt->len; + lt++; + } + + l->tail = lt; + return l; +} + +/* calculate the size of resultant text */ +static int calcsize(int len, struct flist *l) +{ + int outlen = 0, last = 0; + struct frag *f = l->head; + + while (f != l->tail) { + outlen += f->start - last; + last = f->end; + outlen += f->len; + f++; + } + + outlen += len - last; + return outlen; +} + +static void apply(char *buf, char *orig, int len, struct flist *l) +{ + struct frag *f = l->head; + int last = 0; + char *p = buf; + + while (f != l->tail) { + memcpy(p, orig + last, f->start - last); + p += f->start - last; + memcpy(p, f->data, f->len); + last = f->end; + p += f->len; + f++; + } + memcpy(p, orig + last, len - last); +} + +/* recursively generate a patch of all bins between start and end */ +static struct flist *fold(PyObject *bins, int start, int end) +{ + int len; + + if (start + 1 == end) { + /* trivial case, output a decoded list */ + PyObject *tmp = PyList_GetItem(bins, start); + return decode(PyString_AsString(tmp), PyString_Size(tmp)); + } + + /* divide and conquer, memory management is elsewhere */ + len = (end - start) / 2; + return combine(fold(bins, start, start + len), + fold(bins, start + len, end)); +} + +static PyObject * +patches(PyObject *self, PyObject *args) +{ + PyObject *text, *bins, *result; + struct flist *patch; + char *in, *out; + int len, outlen; + + if (!PyArg_ParseTuple(args, "OO:mpatch", &text, &bins)) + return NULL; + + len = PyList_Size(bins); + if (!len) { + /* nothing to do */ + Py_INCREF(text); + return text; + } + + patch = fold(bins, 0, len); + outlen = calcsize(PyString_Size(text), patch); + result = PyString_FromStringAndSize(NULL, outlen); + in = PyString_AsString(text); + out = PyString_AsString(result); + apply(out, in, PyString_Size(text), patch); + lfree(patch); + + return result; +} + +static PyMethodDef methods[] = { + {"patches", patches, METH_VARARGS, "apply a series of patches\n"}, + {NULL, NULL} +}; + +PyMODINIT_FUNC +initmpatch(void) +{ + Py_InitModule3("mpatch", methods, mpatch_doc); +} +
--- a/mercurial/revlog.py Sun May 15 15:30:36 2005 -0700 +++ b/mercurial/revlog.py Wed May 18 17:29:10 2005 -0800 @@ -13,6 +13,7 @@ def hex(node): return binascii.hexlify(node) def bin(node): return binascii.unhexlify(node) +def short(node): return hex(node[:4]) def compress(text): return zlib.compress(text) @@ -28,26 +29,97 @@ nullid = "\0" * 20 indexformat = ">4l20s20s20s" +class lazyparser: + def __init__(self, data): + self.data = data + self.s = struct.calcsize(indexformat) + self.l = len(data)/self.s + self.index = [None] * self.l + self.map = {nullid: -1} + + if 0: + n = 0 + i = self.data + s = struct.calcsize(indexformat) + for f in xrange(0, len(i), s): + # offset, size, base, linkrev, p1, p2, nodeid + e = struct.unpack(indexformat, i[f:f + s]) + self.map[e[6]] = n + self.index.append(e) + n += 1 + + def load(self, pos): + block = pos / 1000 + i = block * 1000 + end = min(self.l, i + 1000) + while i < end: + d = self.data[i * self.s: (i + 1) * self.s] + e = struct.unpack(indexformat, d) + self.index[i] = e + self.map[e[6]] = i + i += 1 + +class lazyindex: + def __init__(self, parser): + self.p = parser + def __len__(self): + return len(self.p.index) + def __getitem__(self, pos): + i = self.p.index[pos] + if not i: + self.p.load(pos) + return self.p.index[pos] + return i + def append(self, e): + self.p.index.append(e) + +class lazymap: + def __init__(self, parser): + self.p = parser + def load(self, key): + n = self.p.data.find(key) + if n < 0: raise KeyError("node " + hex(key)) + pos = n / self.p.s + self.p.load(pos) + def __contains__(self, key): + try: + self[key] + return True + except KeyError: + return False + def __iter__(self): + for i in xrange(self.p.l): + try: + yield self.p.index[i][6] + except: + self.p.load(i) + yield self.p.index[i][6] + def __getitem__(self, key): + try: + return self.p.map[key] + except KeyError: + try: + self.load(key) + return self.p.map[key] + except KeyError: + raise KeyError("node " + hex(key)) + def __setitem__(self, key, val): + self.p.map[key] = val + class revlog: def __init__(self, opener, indexfile, datafile): self.indexfile = indexfile self.datafile = datafile - self.index = [] self.opener = opener self.cache = None - self.nodemap = {nullid: -1} # read the whole index for now, handle on-demand later try: - n = 0 i = self.opener(self.indexfile).read() - s = struct.calcsize(indexformat) - for f in xrange(0, len(i), s): - # offset, size, base, linkrev, p1, p2, nodeid - e = struct.unpack(indexformat, i[f:f + s]) - self.nodemap[e[6]] = n - self.index.append(e) - n += 1 - except IOError: pass + except IOError: + i = "" + parser = lazyparser(i) + self.index = lazyindex(parser) + self.nodemap = lazymap(parser) def tip(self): return self.node(len(self.index) - 1) def count(self): return len(self.index) @@ -78,15 +150,12 @@ return None - def revisions(self, list): - # this can be optimized to do spans, etc - # be stupid for now - for node in list: - yield self.revision(node) - def diff(self, a, b): return mdiff.textdiff(a, b) + def patches(self, t, pl): + return mdiff.patches(t, pl) + def revision(self, node): if node == nullid: return "" if self.cache and self.cache[0] == node: return self.cache[2] @@ -121,7 +190,8 @@ (p1, p2) = self.parents(node) if node != hash(text, p1, p2): - raise "integrity check failed on %s:%d" % (self.datafile, rev) + raise IOError("integrity check failed on %s:%d" + % (self.datafile, rev)) self.cache = (node, rev, text) return text @@ -141,7 +211,10 @@ start = self.start(base) end = self.end(t) prev = self.revision(self.tip()) - data = compress(self.diff(prev, text)) + d = self.diff(prev, text) + if self.patches(prev, [d]) != text: + raise AssertionError("diff failed") + data = compress(d) dist = end - start + len(data) # full versions are inserted when the needed deltas @@ -204,34 +277,9 @@ return nullid - def mergedag(self, other, transaction, linkseq, accumulate = None): - """combine the nodes from other's DAG into ours""" - old = self.tip() - i = self.count() - l = [] - - # merge the other revision log into our DAG - for r in range(other.count()): - id = other.node(r) - if id not in self.nodemap: - (xn, yn) = other.parents(id) - l.append((id, xn, yn)) - self.nodemap[id] = i - i += 1 - - # merge node date for new nodes - r = other.revisions([e[0] for e in l]) - for e in l: - t = r.next() - if accumulate: accumulate(t) - self.addrevision(t, transaction, linkseq.next(), e[1], e[2]) - - # return the unmerged heads for later resolving - return (old, self.tip()) - def group(self, linkmap): # given a list of changeset revs, return a set of deltas and - # metadata corresponding to nodes the first delta is + # metadata corresponding to nodes. the first delta is # parent(nodes[0]) -> nodes[0] the receiver is guaranteed to # have this parent as it has all history before these # changesets. parent is parent[0] @@ -346,6 +394,8 @@ # retrieve the parent revision of the delta chain chain = data[24:44] + if not chain in self.nodemap: + raise "unknown base %s" % short(chain[:4]) # track the base of the current delta log r = self.count() @@ -371,6 +421,8 @@ l, node, p1, p2, cs = struct.unpack(">l20s20s20s20s", data[pos:pos+84]) link = linkmapper(cs) + if node in self.nodemap: + raise "already have %s" % hex(node[:4]) delta = data[pos + 84:pos + l] pos += l @@ -388,7 +440,7 @@ dfh.flush() ifh.flush() text = self.revision(chain) - text = self.patch(text, delta) + text = self.patches(text, [delta]) chk = self.addrevision(text, transaction, link, p1, p2) if chk != node: raise "consistency error adding group"
--- a/mercurial/transaction.py Sun May 15 15:30:36 2005 -0700 +++ b/mercurial/transaction.py Wed May 18 17:29:10 2005 -0800 @@ -14,16 +14,16 @@ import os class transaction: - def __init__(self, opener, journal): + def __init__(self, opener, journal, after = None): self.opener = opener + self.after = after self.entries = [] self.map = {} self.journal = journal # abort here if the journal already exists if os.path.exists(self.journal): - print "journal already exists, recovering" - self.recover() + raise "journal already exists!" self.file = open(self.journal, "w") @@ -43,7 +43,10 @@ def close(self): self.file.close() self.entries = [] - os.unlink(self.journal) + if self.after: + os.rename(self.journal, self.after) + else: + os.unlink(self.journal) def abort(self): if not self.entries: return
--- a/setup.py Sun May 15 15:30:36 2005 -0700 +++ b/setup.py Wed May 18 17:29:10 2005 -0800 @@ -5,14 +5,15 @@ # './setup.py install', or # './setup.py --help' for more options -from distutils.core import setup +from distutils.core import setup, Extension setup(name='mercurial', - version='0.4f', - author='Matt Mackall', - author_email='mpm@selenic.com', - url='http://selenic.com/mercurial', - description='scalable distributed SCM', - license='GNU GPL', - packages=['mercurial'], - scripts=['hg', 'hgweb.py']) + version='0.4f', + author='Matt Mackall', + author_email='mpm@selenic.com', + url='http://selenic.com/mercurial', + description='scalable distributed SCM', + license='GNU GPL', + packages=['mercurial'], + ext_modules=[Extension('mercurial.mpatch', ['mercurial/mpatch.c'])], + scripts=['hg', 'hgweb.py'])