ref: a04a475ed903350c4758f6d8320e56d9ca4c5b14
parent: 0ee6366d9d661574b73d6a419bf53185ec7b9d8d
author: Ori Bernstein <[email protected]>
date: Wed Jan 27 21:41:45 EST 2021
git/log: rewrite in C rc is great and all, but doing graph traversal in it is not very fast. It just works better when rewritten in C.
--- a/log
+++ /dev/null
@@ -1,49 +1,0 @@
-#!/bin/rc -e
-rfork en
-. /sys/lib/git/common.rc
-
-gitup
-
-flagfmt='e:expr expression, c:branch commit, s:short'; args='file ...'
-eval `''{aux/getflags $*} || exec aux/usage-
-base=/mnt/git/object/
-if(~ $#branch 0)
- branch=`{git/branch}-if(~ $#expr 0)
- commits=`{git/query $branch}-if not
- commits=`{git/query $expr}-
-files=()
-if(! ~ $#* 0)
- files=`"{walk -f $gitrel/^$* | subst '^\./' | sort}-
-while(! ~ $#commits 0){- ids=$nids
- show=()
- c=$commits(1)
- if(! ~ $#files 0){- ncomm=`{comm -12 /env/files <{git/query -c $c~ $c | subst '^..' | sort} | wc -l}- if(! ~ $ncomm 0)
- show=true
- }
- commits=$commits(2-)
- if(~ $#expr 0)
- commits=($commits `{cat $base/$c/parent >[2]/dev/null})- if(! ~ $#commits 0)
- commits=`$nl{walk -emp -n0 $base^$commits | sort -rn | uniq | awk -F/ '{print $NF}'}-
- if(~ $#files 0 || ~ $show true){- if(~ $short 1)
- echo $c `{cat $base/$c/msg | sed 1q}- if not{- echo -n 'Hash: '`''{cat $base/$c/hash}- echo -n 'Author: '`''{cat $base/$c/author}- echo -n 'Date: '`''{date `{mtime $base/$c/msg | awk '{print $1}'}}- subst -g '^' ' ' <$base/$c/msg
- echo
- }
- }
-}
-exit ''
--- /dev/null
+++ b/log.c
@@ -1,0 +1,323 @@
+#include <u.h>
+#include <libc.h>
+#include "git.h"
+
+typedef struct Pfilt Pfilt;
+struct Pfilt {+ char *elt;
+ int show;
+ Pfilt *sub;
+ int nsub;
+};
+
+Biobuf *out;
+char *queryexpr;
+char *commitid;
+int shortlog;
+
+Object **heap;
+int nheap;
+int heapsz;
+Objset done;
+Pfilt *pathfilt;
+
+void
+filteradd(Pfilt *pf, char *path)
+{+ char *p, *e;
+ int i;
+
+ if((e = strchr(path, '/')) != nil)
+ p = smprint("%.*s", (int)(e - path), path);+ else
+ p = strdup(path);
+
+ while(e != nil && *e == '/')
+ e++;
+ for(i = 0; i < pf->nsub; i++){+ if(strcmp(pf->sub[i].elt, p) == 0){+ pf->sub[i].show = pf->sub[i].show || (e == nil);
+ if(e != nil)
+ filteradd(&pf->sub[i], e);
+ free(p);
+ return;
+ }
+ }
+ pf->sub = earealloc(pf->sub, pf->nsub+1, sizeof(Pfilt));
+ pf->sub[pf->nsub].elt = p;
+ pf->sub[pf->nsub].show = (e == nil);
+ pf->sub[pf->nsub].nsub = 0;
+ pf->sub[pf->nsub].sub = nil;
+ if(e != nil)
+ filteradd(&pf->sub[pf->nsub], e);
+ pf->nsub++;
+}
+
+Hash
+lookup(Pfilt *pf, Object *o)
+{+ int i;
+
+ for(i = 0; i < o->tree->nent; i++)
+ if(strcmp(o->tree->ent[i].name, pf->elt) == 0)
+ return o->tree->ent[i].h;
+ return Zhash;
+}
+
+int
+filtermatch1(Pfilt *pf, Object *t, Object *pt)
+{+ Object *a, *b;
+ Hash ha, hb;
+ int i, r;
+
+ if(pf->show)
+ return 1;
+ if(t->type != pt->type)
+ return 1;
+ if(t->type != GTree)
+ return 0;
+
+ for(i = 0; i < pf->nsub; i++){+ ha = lookup(&pf->sub[i], t);
+ hb = lookup(&pf->sub[i], pt);
+ if(hasheq(&ha, &hb))
+ continue;
+ if(hasheq(&ha, &Zhash) || hasheq(&hb, &Zhash))
+ return 1;
+ if((a = readobject(ha)) == nil)
+ sysfatal("read %H: %r", ha);+ if((b = readobject(hb)) == nil)
+ sysfatal("read %H: %r", hb);+ r = filtermatch1(&pf->sub[i], a, b);
+ unref(a);
+ unref(b);
+ if(r)
+ return 1;
+ }
+ return 0;
+}
+
+int
+filtermatch(Object *o)
+{+ Object *t, *p, *pt;
+ int i, r;
+
+ if(pathfilt == nil)
+ return 1;
+ if((t = readobject(o->commit->tree)) == nil)
+ sysfatal("read %H: %r", o->commit->tree);+ for(i = 0; i < o->commit->nparent; i++){+ if((p = readobject(o->commit->parent[i])) == nil)
+ sysfatal("read %H: %r", o->commit->parent[i]);+ if((pt = readobject(p->commit->tree)) == nil)
+ sysfatal("read %H: %r", o->commit->tree);+ r = filtermatch1(pathfilt, t, pt);
+ unref(p);
+ unref(pt);
+ if(r)
+ return 1;
+ }
+ return 0;
+}
+
+
+static char*
+nextline(char *p, char *e)
+{+ for(; p != e; p++)
+ if(*p == '\n')
+ break;
+ return p;
+}
+
+static void
+show(Object *o)
+{+ Tm tm;
+ char *p, *q, *e;
+
+ assert(o->type == GCommit);
+ if(!filtermatch(o))
+ return;
+
+ if(shortlog){+ p = o->commit->msg;
+ e = p + o->commit->nmsg;
+ q = nextline(p, e);
+ Bprint(out, "%H %.*s\n", o->hash, (int)(q - p), p);
+ }else{+ tmtime(&tm, o->commit->mtime, tzload("local"));+ Bprint(out, "Hash:\t%H\n", o->hash);
+ Bprint(out, "Author:\t%s\n", o->commit->author);
+ Bprint(out, "Date:\t%τ\n", tmfmt(&tm, "WW MMM D hh:mm:ss z YYYY"));
+ Bprint(out, "\n");
+ p = o->commit->msg;
+ e = p + o->commit->nmsg;
+ for(; p != e; p = q){+ q = nextline(p, e);
+ Bprint(out, "\t%.*s\n", (int)(q - p), p);
+ if(q != e)
+ q++;
+ }
+ Bprint(out, "\n");
+ }
+ Bflush(out);
+}
+
+static void
+showquery(char *q)
+{+ Object *o;
+ Hash *h;
+ int n, i;
+
+ if((n = resolverefs(&h, q)) == -1)
+ sysfatal("resolve: %r");+ for(i = 0; i < n; i++){+ if((o = readobject(h[i])) == nil)
+ sysfatal("read %H: %r", h[i]);+ show(o);
+ unref(o);
+ }
+ exits(nil);
+}
+
+static void
+qput(Object *o)
+{+ Object *p;
+ int i;
+
+ if(oshas(&done, o->hash))
+ return;
+ osadd(&done, o);
+ if(nheap == heapsz){+ heapsz *= 2;
+ heap = earealloc(heap, heapsz, sizeof(Object*));
+ }
+ heap[nheap++] = o;
+ for(i = nheap - 1; i > 0; i /= 2){+ o = heap[i];
+ p = heap[(i-1)/2];
+ if(o->commit->mtime < p->commit->mtime)
+ break;
+ heap[i] = p;
+ heap[i/2] = o;
+ }
+}
+
+static Object*
+qpop(void)
+{+ Object *o, *t;
+ int i, l, r, m;
+
+ if(nheap == 0)
+ return nil;
+
+ i = 0;
+ o = heap[0];
+ t = heap[--nheap];
+ heap[0] = t;
+ while(1){+ m = i;
+ l = 2*i+1;
+ r = 2*i+2;
+ if(l < nheap && heap[m]->commit->mtime < heap[l]->commit->mtime)
+ m = l;
+ if(r < nheap && heap[m]->commit->mtime < heap[r]->commit->mtime)
+ m = r;
+ else
+ break;
+ t = heap[m];
+ heap[m] = heap[i];
+ heap[i] = t;
+ i = m;
+ }
+ return o;
+}
+
+static void
+showcommits(char *c)
+{+ Object *o, *p;
+ int i;
+ Hash h;
+
+ if(c == nil)
+ c = "HEAD";
+ if(resolveref(&h, c) == -1)
+ sysfatal("resolve %s: %r", c);+ if((o = readobject(h)) == nil)
+ sysfatal("load %H: %r", h);+ heapsz = 8;
+ heap = eamalloc(heapsz, sizeof(Object*));
+ osinit(&done);
+ qput(o);
+ while((o = qpop()) != nil){+ show(o);
+ for(i = 0; i < o->commit->nparent; i++){+ if((p = readobject(o->commit->parent[i])) == nil)
+ sysfatal("load %H: %r", o->commit->parent[i]);+ qput(p);
+ }
+ unref(o);
+ }
+}
+
+static void
+usage(void)
+{+ fprint(2, "usage: %s [-s] [-e expr | -c commit] files..\n", argv0);
+ exits("usage");+}
+
+void
+main(int argc, char **argv)
+{+ char path[1024], repo[1024], *p, *r;
+ int i;
+
+ ARGBEGIN{+ case 'e':
+ queryexpr = EARGF(usage());
+ break;
+ case 'c':
+ commitid = EARGF(usage());
+ break;
+ case 's':
+ shortlog++;
+ break;
+ default:
+ usage();
+ break;
+ }ARGEND;
+
+ if(argc != 0){+ if(findrepo(repo, sizeof(repo)) == -1)
+ sysfatal("find root: %r");+ if(getwd(path, sizeof(path)) == nil)
+ sysfatal("getwd: %r");+ if(strlen(path) < strlen(repo))
+ sysfatal("path changed");+ p = path + strlen(repo);
+ pathfilt = emalloc(sizeof(Pfilt));
+ for(i = 0; i < argc; i++){+ r = smprint("./%s/%s", p, argv[i]);+ cleanname(r);
+ filteradd(pathfilt, r);
+ free(r);
+ }
+ }
+
+ gitinit();
+ tmfmtinstall();
+ out = Bfdopen(1, OWRITE);
+ if(queryexpr != nil)
+ showquery(queryexpr);
+ else
+ showcommits(commitid);
+ exits(nil);
+}
--- a/mkfile
+++ b/mkfile
@@ -5,6 +5,7 @@
conf\
fetch\
fs\
+ log\
query\
repack\
save\