5 static int extra, missing, wrong;
14 print("# diff actual correct\n");
16 print("%s block 0x%llux\n", eb->part->name, eb->addr);
20 pie(IEntry *ie, char c)
22 print("%c %V %22lld %3d %5d %3d\n",
23 c, ie->score, ie->ia.addr, ie->ia.type, ie->ia.size, ie->ia.blocks);
27 checkbucket(Index *ix, u32int buck, IBucket *ib)
33 int i, ei, ok, c, hdr;
35 is = ix->sects[indexsect0(ix, buck)];
36 if(buck < is->start || buck >= is->stop){
37 seterr(EAdmin, "cannot find index section for bucket %lud\n", (ulong)buck);
41 eb = getdblock(is->part, is->blockbase + ((u64int)buck << is->blocklog), OREAD);
44 unpackibucket(&eib, eb->data, is->bucketmagic);
49 for(i = 0; i < ib->n; i++){
51 c = ientrycmp(&ib->data[i * IEntrySize], &eib.data[ei * IEntrySize]);
53 unpackientry(&ie, &ib->data[i * IEntrySize]);
54 unpackientry(&eie, &eib.data[ei * IEntrySize]);
55 if(iaddrcmp(&ie.ia, &eie.ia) != 0){
73 unpackientry(&eie, &eib.data[ei*IEntrySize]);
83 unpackientry(&ie, &ib->data[i*IEntrySize]);
89 for(; ei < eib.n; ei++){
94 unpackientry(&eie, &eib.data[ei*IEntrySize]);
103 checkindex(Index *ix, Part *part, u64int off, u64int clumps, int zero)
112 //ZZZ make buffer size configurable
113 b = alloczblock(ix->blocksize, 0, ix->blocksize);
114 z = alloczblock(ix->blocksize, 1, ix->blocksize);
115 ies = initiestream(part, off, clumps, 64*1024);
116 if(b == nil || z == nil || ies == nil){
117 werrstr("allocating: %r");
124 memset(&ib, 0, sizeof ib);
130 buck = buildbucket(ix, ies, &ib, ix->blocksize-IBucketSize);
133 for(; next != buck; next++){
134 if(next == ix->buckets){
137 werrstr("internal error: bucket out of range");
140 werrstr("%d spurious entries, %d missing, %d wrong", extra, missing, wrong);
143 bok = checkbucket(ix, next, &zib);
148 if(buck >= ix->buckets){
151 werrstr("internal error: bucket out of range");
155 bok = checkbucket(ix, buck, &ib);
168 checkbloom(Bloom *b1, Bloom *b2, int fix)
171 int i, n, extra, missing;
173 if(b1==nil && b2==nil)
175 if(b1==nil || b2==nil){
176 werrstr("nil/non-nil");
181 if(memcmp(b1->data, b2->data, BloomHeadSize) != 0){
182 werrstr("bloom header mismatch");
185 a1 = (u32int*)b1->data;
186 a2 = (u32int*)b2->data;
190 for(i=BloomHeadSize/4; i<n; i++){
192 print("%.8ux/%.8ux.", a1[i], a2[i]);
193 extra += countbits(a1[i] & ~a2[i]);
194 missing += countbits(a2[i] & ~a1[i]);
198 fprint(2, "bloom filter: %d spurious bits, %d missing bits\n", extra, missing);
200 fprint(2, "bloom filter: correct\n");
202 werrstr("missing bits");
205 if(fix && (missing || extra)){
206 memmove(b1->data, b2->data, b1->size);
207 return writebloom(b1);
216 fprint(2, "usage: checkindex [-f] [-B blockcachesize] config tmp\n");
223 threadmain(int argc, char *argv[])
225 Bloom *oldbloom, *newbloom;
236 bcmem = unittoull(ARGF());
254 part = initpart(argv[1], ORDWR|ODIRECT);
256 sysfatal("can't initialize temporary partition: %r");
261 if(initventi(argv[0], &conf) < 0)
262 sysfatal("can't init venti: %r");
263 oldbloom = mainindex->bloom;
266 newbloom = vtmallocz(sizeof *newbloom);
267 bloominit(newbloom, oldbloom->size, nil);
268 newbloom->data = vtmallocz(oldbloom->size);
270 if(bcmem < maxblocksize * (mainindex->narenas + mainindex->nsects * 4 + 16))
271 bcmem = maxblocksize * (mainindex->narenas + mainindex->nsects * 4 + 16);
272 if(0) fprint(2, "initialize %d bytes of disk block cache\n", bcmem);
275 fprint(2, "checkindex: building entry list\n");
276 clumps = sortrawientries(mainindex, part, &base, newbloom);
278 sysfatal("can't build sorted index: %r");
279 fprint(2, "checkindex: checking %lld entries at %lld\n", clumps, base);
281 if(checkindex(mainindex, part, base, clumps, !skipz) < 0){
282 fprint(2, "checkindex: %r\n");
285 if(checkbloom(oldbloom, newbloom, fix) < 0){
286 fprint(2, "checkbloom: %r\n");
290 sysfatal("errors found");
291 fprint(2, "checkindex: index is correct\n");