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