11 * shell sort is plenty good enough
12 * because we're going to do a bunch of disk i/o's
15 sortclumpinfo(ClumpInfo *ci, int *s, int n)
19 for(m = (n + 3) / 5; m > 0; m = (m + 1) / 3){
20 for(i = n - m; i-- > 0;){
21 for(j = i + m; j < n; j += m){
22 if(memcmp(ci[s[j - m]].score, ci[s[j]].score, VtScoreSize) <= 0)
33 syncarenaindex(Index *ix, Arena *arena, u32int clump, u64int a, int fix)
44 cis = MKN(ClumpInfo, ClumpChunks);
45 addrs = MKN(u64int, ClumpChunks);
46 s = MKN(int, ClumpChunks);
48 for(; clump < arena->clumps; clump += n){
50 if(n > arena->clumps - clump)
51 n = arena->clumps - clump;
52 n = readclumpinfos(arena, clump, cis, n);
54 fprint(2, "arena directory read failed\n");
59 for(i = 0; i < n; i++){
61 a += cis[i].size + ClumpSize;
65 sortclumpinfo(cis, s, n);
67 for(i = 0; i < n; i++){
70 ia.size = ci->uncsize;
71 ia.addr = addrs[s[i]];
72 ia.blocks = (ci->size + ClumpSize + (1 << ABlockLog) - 1) >> ABlockLog;
74 if(loadientry(ix, ci->score, ci->type, &ie) < 0)
75 fprint(2, "missing block type=%d score=%V\n", ci->type, ci->score);
76 else if(iaddrcmp(&ia, &ie.ia) != 0){
77 fprint(2, "\nmismatched index entry and clump at %d\n", clump + i);
78 fprint(2, "\tclump: type=%d size=%d blocks=%d addr=%lld\n", ia.type, ia.size, ia.blocks, ia.addr);
79 fprint(2, "\tindex: type=%d size=%d block=%d addr=%lld\n", ie.ia.type, ie.ia.size, ie.ia.blocks, ie.ia.addr);
80 pack = readlump(ie.score, ie.ia.type, ie.ia.size);
83 fprint(2, "duplicated lump\n");
93 scorecp(ie.score, ci->score);
96 if(storeientry(ix, &ie) < 0){
97 fprint(2, "can't fix index: %r");
102 if(0 && clump / 1000 != (clump + n) / 1000)
112 syncindex(Index *ix, int fix)
117 int i, e, e1, ok, ok1;
120 for(i = 0; i < ix->narenas; i++){
121 arena = ix->arenas[i];
122 clump = arena->clumps;
124 e = syncarena(arena, TWID32, fix, fix);
127 e1 &= ~(SyncHeader|SyncCIZero);
129 fprint(2, "arena %s: header is out-of-date\n", arena->name);
133 ok1 = syncarenaindex(ix, arena, clump, a + ix->amap[i].start, fix);
134 if(fix && ok1==0 && (e & SyncHeader) && wbarena(arena) < 0)
135 fprint(2, "arena=%s header write failed: %r\n", arena->name);
139 if(fix && wbindex(ix) < 0){
140 fprint(2, "can't write back index header for %s: %r\n", ix->name);