tnew - plan9port - [fork] Plan 9 from user space
HTML git clone git://src.adamsgaard.dk/plan9port
DIR Log
DIR Files
DIR Refs
DIR README
DIR LICENSE
---
DIR commit 686bd37d9d8db5e3b969a3aa2d5b455e0976b262
DIR parent d20564a9a6d75192ec21170f2c6cd699eb361d96
HTML Author: rsc <devnull@localhost>
Date: Tue, 18 Jul 2006 15:26:24 +0000
new
Diffstat:
A src/cmd/venti/srv/cmparenas.c | 271 +++++++++++++++++++++++++++++++
1 file changed, 271 insertions(+), 0 deletions(-)
---
DIR diff --git a/src/cmd/venti/srv/cmparenas.c b/src/cmd/venti/srv/cmparenas.c
t@@ -0,0 +1,271 @@
+#include "stdinc.h"
+#include "dat.h"
+#include "fns.h"
+
+static int verbose;
+static int fd;
+static int fd1;
+static uchar *data;
+static uchar *data1;
+static int blocksize;
+static int sleepms;
+
+void
+usage(void)
+{
+ fprint(2, "usage: cmparenas [-b blocksize] [-s ms] [-v] arenapart1 arenapart2 [name...]]\n");
+ threadexitsall(0);
+}
+
+static int
+preadblock(int fd, uchar *buf, int n, vlong off)
+{
+ int nr, m;
+
+ for(nr = 0; nr < n; nr += m){
+ m = n - nr;
+ m = pread(fd, &buf[nr], m, off+nr);
+ if(m <= 0){
+ if(m == 0)
+ werrstr("early eof");
+ return -1;
+ }
+ }
+ return 0;
+}
+
+static int
+readblock(int fd, uchar *buf, int n)
+{
+ int nr, m;
+
+ for(nr = 0; nr < n; nr += m){
+ m = n - nr;
+ m = read(fd, &buf[nr], m);
+ if(m <= 0){
+ if(m == 0)
+ werrstr("early eof");
+ return -1;
+ }
+ }
+ return 0;
+}
+
+static void
+cmparena(char *name, vlong len)
+{
+ Arena arena;
+ ArenaHead head;
+ DigestState s;
+ u64int n, e;
+ u32int bs;
+ u8int score[VtScoreSize];
+ int i, j;
+ char buf[20];
+
+ fprint(2, "cmp %s\n", name);
+
+ memset(&arena, 0, sizeof arena);
+ memset(&s, 0, sizeof s);
+
+ /*
+ * read a little bit, which will include the header
+ */
+ if(readblock(fd, data, HeadSize) < 0){
+ fprint(2, "%s: reading header: %r\n", name);
+ return;
+ }
+ if(unpackarenahead(&head, data) < 0){
+ fprint(2, "%s: corrupt arena header: %r\n", name);
+ return;
+ }
+ if(head.version != ArenaVersion4 && head.version != ArenaVersion5)
+ fprint(2, "%s: warning: unknown arena version %d\n", name, head.version);
+ if(len != 0 && len != head.size)
+ fprint(2, "%s: warning: unexpected length %lld != %lld\n", name, head.size, len);
+ if(strcmp(name, "<stdin>") != 0 && strcmp(head.name, name) != 0)
+ fprint(2, "%s: warning: unexpected name %s\n", name, head.name);
+
+ if(readblock(fd1, data1, HeadSize) < 0){
+ fprint(2, "%s: reading header: %r\n", name);
+ return;
+ }
+ if(unpackarenahead(&head, data) < 0){
+ fprint(2, "%s: corrupt arena header: %r\n", name);
+ return;
+ }
+ if(head.version != ArenaVersion4 && head.version != ArenaVersion5)
+ fprint(2, "%s: warning: unknown arena version %d\n", name, head.version);
+ if(len != 0 && len != head.size)
+ fprint(2, "%s: warning: unexpected length %lld != %lld\n", name, head.size, len);
+ if(strcmp(name, "<stdin>") != 0 && strcmp(head.name, name) != 0)
+ fprint(2, "%s: warning: unexpected name %s\n", name, head.name);
+
+ seek(fd, -HeadSize, 1);
+ seek(fd1, -HeadSize, 1);
+
+ /*
+ * now we know how much to read
+ * read everything but the last block, which is special
+ */
+ e = head.size;
+ bs = blocksize;
+ for(n = 0; n < e; n += bs){
+ if(n + bs > e)
+ bs = e - n;
+ if(readblock(fd, data, bs) < 0){
+ fprint(2, "%s: read data: %r\n", name);
+ return;
+ }
+ if(readblock(fd1, data1, bs) < 0){
+ fprint(2, "%s: read data: %r\n", name);
+ return;
+ }
+ if(memcmp(data, data1, bs) != 0){
+ print("mismatch at %llx\n", n);
+ for(i=0; i<bs; i+=16){
+ if(memcmp(data+i, data1+i, 16) != 0){
+ snprint(buf, sizeof buf, "%llx", n+i);
+ print("%s ", buf);
+ for(j=0; j<16; j++){
+ print(" %.2ux", data[i+j]);
+ if(j == 7)
+ print(" -");
+ }
+ print("\n");
+ print("%*s ", (int)strlen(buf), "");
+ for(j=0; j<16; j++){
+ print(" %.2ux", data1[i+j]);
+ if(j == 7)
+ print(" -");
+ }
+ print("\n");
+ }
+ }
+ }
+ }
+}
+
+static int
+shouldcheck(char *name, char **s, int n)
+{
+ int i;
+
+ if(n == 0)
+ return 1;
+
+ for(i=0; i<n; i++){
+ if(s[i] && strcmp(name, s[i]) == 0){
+ s[i] = nil;
+ return 1;
+ }
+ }
+ return 0;
+}
+
+char *
+readap(int fd, ArenaPart *ap)
+{
+ char *table;
+
+ if(preadblock(fd, data, 8192, PartBlank) < 0)
+ sysfatal("read arena part header: %r");
+ if(unpackarenapart(ap, data) < 0)
+ sysfatal("corrupted arena part header: %r");
+ fprint(2, "# arena part version=%d blocksize=%d arenabase=%d\n",
+ ap->version, ap->blocksize, ap->arenabase);
+ ap->tabbase = (PartBlank+HeadSize+ap->blocksize-1)&~(ap->blocksize-1);
+ ap->tabsize = ap->arenabase - ap->tabbase;
+ table = malloc(ap->tabsize+1);
+ if(preadblock(fd, (uchar*)table, ap->tabsize, ap->tabbase) < 0)
+ sysfatal("reading arena part directory: %r");
+ table[ap->tabsize] = 0;
+ return table;
+}
+
+void
+threadmain(int argc, char *argv[])
+{
+ int i, nline;
+ char *p, *q, *table, *table1, *f[10], line[256];
+ vlong start, stop;
+ ArenaPart ap;
+ ArenaPart ap1;
+
+ ventifmtinstall();
+ blocksize = MaxIoSize;
+ ARGBEGIN{
+ case 'b':
+ blocksize = unittoull(EARGF(usage()));
+ break;
+ case 's':
+ sleepms = atoi(EARGF(usage()));
+ break;
+ case 'v':
+ verbose++;
+ break;
+ default:
+ usage();
+ break;
+ }ARGEND
+
+ if(argc < 2)
+ usage();
+
+ data = vtmalloc(blocksize);
+ data1 = vtmalloc(blocksize);
+ if((fd = open(argv[0], OREAD)) < 0)
+ sysfatal("open %s: %r", argv[0]);
+ if((fd1 = open(argv[1], OREAD)) < 0)
+ sysfatal("open %s: %r", argv[0]);
+
+ table = readap(fd, &ap);
+ table1 = readap(fd1, &ap1);
+ if(strcmp(table, table1) != 0)
+ sysfatal("arena partitions do not have identical tables");
+
+ nline = atoi(table);
+ p = strchr(table, '\n');
+ if(p)
+ p++;
+ for(i=0; i<nline; i++){
+ if(p == nil){
+ fprint(2, "warning: unexpected arena table end\n");
+ break;
+ }
+ q = strchr(p, '\n');
+ if(q)
+ *q++ = 0;
+ if(strlen(p) >= sizeof line){
+ fprint(2, "warning: long arena table line: %s\n", p);
+ p = q;
+ continue;
+ }
+ strcpy(line, p);
+ memset(f, 0, sizeof f);
+ if(tokenize(line, f, nelem(f)) < 3){
+ fprint(2, "warning: bad arena table line: %s\n", p);
+ p = q;
+ continue;
+ }
+ p = q;
+ if(shouldcheck(f[0], argv+1, argc-1)){
+ start = strtoull(f[1], 0, 0);
+ stop = strtoull(f[2], 0, 0);
+ if(stop <= start){
+ fprint(2, "%s: bad start,stop %lld,%lld\n", f[0], stop, start);
+ continue;
+ }
+ if(seek(fd, start, 0) < 0)
+ fprint(2, "%s: seek to start: %r\n", f[0]);
+ if(seek(fd1, start, 0) < 0)
+ fprint(2, "%s: seek to start: %r\n", f[0]);
+ cmparena(f[0], stop - start);
+ }
+ }
+ for(i=2; i<argc; i++)
+ if(argv[i] != 0)
+ fprint(2, "%s: did not find arena\n", argv[i]);
+
+ threadexitsall(nil);
+}