1 #include "stdinc.h"
2 #include "dat.h"
3 #include "fns.h"
4 
5 int	count[VtMaxLumpSize][VtMaxType];
6 
7 enum
8 {
9 	ClumpChunks	= 32*1024
10 };
11 
12 static int
13 readarenainfo(Arena *arena)
14 {
15 	ClumpInfo *ci, *cis;
16 	u32int clump;
17 	int i, n, ok;
18 
19 	if(arena->clumps)
20 		fprint(2, "reading directory for arena=%s with %d entries\n", arena->name, arena->clumps);
21 
22 	cis = MKN(ClumpInfo, ClumpChunks);
23 	ok = 0;
24 	for(clump = 0; clump < arena->clumps; clump += n){
25 		n = ClumpChunks;
26 
27 		if(n > arena->clumps - clump)
28 			n = arena->clumps - clump;
29 
30 		if((i=readclumpinfos(arena, clump, cis, n)) != n){
31 			seterr(EOk, "arena directory read failed %d not %d: %r", i, n);
32 			ok = -1;
33 			break;
34 		}
35 
36 		for(i = 0; i < n; i++){
37 			ci = &cis[i];
38 			if(ci->type >= VtMaxType || ci->uncsize >= VtMaxLumpSize) {
39 				fprint(2, "bad clump: %d: type = %d: size = %d\n", clump+i, ci->type, ci->uncsize);
40 				continue;
41 			}
42 if(ci->uncsize == 422)
43 print("%s: %d: %V\n", arena->name, clump+i, ci->score);
44 			count[ci->uncsize][ci->type]++;
45 		}
46 	}
47 	free(cis);
48 	if(ok < 0)
49 		return TWID32;
50 	return clump;
51 }
52 
53 static void
54 clumpstats(Index *ix)
55 {
56 	int ok;
57 	ulong clumps, n;
58 	int i, j, t;
59 
60 	ok = 0;
61 	clumps = 0;
62 	for(i = 0; i < ix->narenas; i++){
63 		n = readarenainfo(ix->arenas[i]);
64 		if(n == TWID32){
65 			ok = -1;
66 			break;
67 		}
68 		clumps += n;
69 	}
70 
71 	if(ok < 0)
72 		return;
73 
74 	print("clumps = %ld\n", clumps);
75 	for(i=0; i<VtMaxLumpSize; i++) {
76 		t = 0;
77 		for(j=0; j<VtMaxType; j++)
78 			t += count[i][j];
79 		if(t == 0)
80 			continue;
81 		print("%d\t%d", i, t);
82 		for(j=0; j<VtMaxType; j++)
83 			print("\t%d", count[i][j]);
84 		print("\n");
85 	}
86 }
87 
88 
89 void
90 usage(void)
91 {
92 	fprint(2, "usage: clumpstats [-B blockcachesize] config\n");
93 	threadexitsall(0);
94 }
95 
96 void
97 threadmain(int argc, char *argv[])
98 {
99 	u32int bcmem;
100 
101 	bcmem = 0;
102 
103 	ARGBEGIN{
104 	case 'B':
105 		bcmem = unittoull(ARGF());
106 		break;
107 	default:
108 		usage();
109 		break;
110 	}ARGEND
111 
112 	readonly = 1;
113 
114 	if(argc != 1)
115 		usage();
116 
117 	if(initventi(argv[0]) < 0)
118 		sysfatal("can't init venti: %r");
119 
120 	if(bcmem < maxblocksize * (mainindex->narenas + mainindex->nsects * 4 + 16))
121 		bcmem = maxblocksize * (mainindex->narenas + mainindex->nsects * 4 + 16);
122 	fprint(2, "initialize %d bytes of disk block cache\n", bcmem);
123 	initdcache(bcmem);
124 
125 	clumpstats(mainindex);
126 	
127 	threadexitsall(0);
128 }