Blame


1 7a4ee46d 2003-11-23 devnull #include "stdinc.h"
2 7a4ee46d 2003-11-23 devnull #include "dat.h"
3 7a4ee46d 2003-11-23 devnull #include "fns.h"
4 7a4ee46d 2003-11-23 devnull
5 7a4ee46d 2003-11-23 devnull void
6 7a4ee46d 2003-11-23 devnull usage(void)
7 7a4ee46d 2003-11-23 devnull {
8 7a4ee46d 2003-11-23 devnull fprint(2, "usage: fmtindex config\n");
9 7a4ee46d 2003-11-23 devnull threadexitsall(0);
10 7a4ee46d 2003-11-23 devnull }
11 7a4ee46d 2003-11-23 devnull
12 7a4ee46d 2003-11-23 devnull void
13 7a4ee46d 2003-11-23 devnull threadmain(int argc, char *argv[])
14 7a4ee46d 2003-11-23 devnull {
15 7a4ee46d 2003-11-23 devnull Config conf;
16 7a4ee46d 2003-11-23 devnull Index *ix;
17 7a4ee46d 2003-11-23 devnull ArenaPart *ap;
18 7a4ee46d 2003-11-23 devnull Arena **arenas;
19 7a4ee46d 2003-11-23 devnull AMap *amap;
20 7a4ee46d 2003-11-23 devnull u64int addr;
21 7a4ee46d 2003-11-23 devnull char *file;
22 7a4ee46d 2003-11-23 devnull u32int i, j, n, narenas;
23 7a4ee46d 2003-11-23 devnull int add;
24 7a4ee46d 2003-11-23 devnull
25 7a4ee46d 2003-11-23 devnull fmtinstall('V', vtscorefmt);
26 7a4ee46d 2003-11-23 devnull statsinit();
27 7a4ee46d 2003-11-23 devnull
28 7a4ee46d 2003-11-23 devnull add = 0;
29 7a4ee46d 2003-11-23 devnull ARGBEGIN{
30 7a4ee46d 2003-11-23 devnull case 'a':
31 7a4ee46d 2003-11-23 devnull add = 1;
32 7a4ee46d 2003-11-23 devnull break;
33 7a4ee46d 2003-11-23 devnull default:
34 7a4ee46d 2003-11-23 devnull usage();
35 7a4ee46d 2003-11-23 devnull break;
36 7a4ee46d 2003-11-23 devnull }ARGEND
37 7a4ee46d 2003-11-23 devnull
38 7a4ee46d 2003-11-23 devnull if(argc != 1)
39 7a4ee46d 2003-11-23 devnull usage();
40 7a4ee46d 2003-11-23 devnull
41 7a4ee46d 2003-11-23 devnull file = argv[0];
42 7a4ee46d 2003-11-23 devnull
43 7a4ee46d 2003-11-23 devnull if(runconfig(file, &conf) < 0)
44 7a4ee46d 2003-11-23 devnull sysfatal("can't initialize config %s: %r", file);
45 7a4ee46d 2003-11-23 devnull if(conf.index == nil)
46 7a4ee46d 2003-11-23 devnull sysfatal("no index specified in %s", file);
47 7a4ee46d 2003-11-23 devnull if(nameok(conf.index) < 0)
48 7a4ee46d 2003-11-23 devnull sysfatal("illegal index name %s", conf.index);
49 7a4ee46d 2003-11-23 devnull
50 7a4ee46d 2003-11-23 devnull narenas = 0;
51 7a4ee46d 2003-11-23 devnull for(i = 0; i < conf.naparts; i++){
52 7a4ee46d 2003-11-23 devnull ap = conf.aparts[i];
53 7a4ee46d 2003-11-23 devnull narenas += ap->narenas;
54 7a4ee46d 2003-11-23 devnull }
55 7a4ee46d 2003-11-23 devnull
56 7a4ee46d 2003-11-23 devnull if(add){
57 7a4ee46d 2003-11-23 devnull ix = initindex(conf.index, conf.sects, conf.nsects);
58 7a4ee46d 2003-11-23 devnull if(ix == nil)
59 7a4ee46d 2003-11-23 devnull sysfatal("can't initialize index %s: %r", conf.index);
60 7a4ee46d 2003-11-23 devnull }else{
61 7a4ee46d 2003-11-23 devnull ix = newindex(conf.index, conf.sects, conf.nsects);
62 7a4ee46d 2003-11-23 devnull if(ix == nil)
63 7a4ee46d 2003-11-23 devnull sysfatal("can't create new index %s: %r", conf.index);
64 7a4ee46d 2003-11-23 devnull
65 7a4ee46d 2003-11-23 devnull n = 0;
66 7a4ee46d 2003-11-23 devnull for(i = 0; i < ix->nsects; i++)
67 7a4ee46d 2003-11-23 devnull n += ix->sects[i]->blocks;
68 7a4ee46d 2003-11-23 devnull
69 7a4ee46d 2003-11-23 devnull fprint(2, "using %ud buckets of %ud; div=%d\n", ix->buckets, n, ix->div);
70 7a4ee46d 2003-11-23 devnull }
71 7a4ee46d 2003-11-23 devnull amap = MKNZ(AMap, narenas);
72 7a4ee46d 2003-11-23 devnull arenas = MKNZ(Arena*, narenas);
73 7a4ee46d 2003-11-23 devnull
74 7a4ee46d 2003-11-23 devnull addr = IndexBase;
75 7a4ee46d 2003-11-23 devnull n = 0;
76 7a4ee46d 2003-11-23 devnull for(i = 0; i < conf.naparts; i++){
77 7a4ee46d 2003-11-23 devnull ap = conf.aparts[i];
78 7a4ee46d 2003-11-23 devnull for(j = 0; j < ap->narenas; j++){
79 7a4ee46d 2003-11-23 devnull if(n >= narenas)
80 7a4ee46d 2003-11-23 devnull sysfatal("too few slots in index's arena set");
81 7a4ee46d 2003-11-23 devnull
82 7a4ee46d 2003-11-23 devnull arenas[n] = ap->arenas[j];
83 7a4ee46d 2003-11-23 devnull if(n < ix->narenas){
84 7a4ee46d 2003-11-23 devnull if(arenas[n] != ix->arenas[n])
85 7a4ee46d 2003-11-23 devnull sysfatal("mismatched arenas %s and %s at slot %d\n",
86 7a4ee46d 2003-11-23 devnull arenas[n]->name, ix->arenas[n]->name, n);
87 7a4ee46d 2003-11-23 devnull amap[n] = ix->amap[n];
88 7a4ee46d 2003-11-23 devnull if(amap[n].start != addr)
89 7a4ee46d 2003-11-23 devnull sysfatal("mis-located arena %s in index %s\n", arenas[n]->name, ix->name);
90 7a4ee46d 2003-11-23 devnull addr = amap[n].stop;
91 7a4ee46d 2003-11-23 devnull }else{
92 7a4ee46d 2003-11-23 devnull amap[n].start = addr;
93 7a4ee46d 2003-11-23 devnull addr += ap->arenas[j]->size;
94 7a4ee46d 2003-11-23 devnull amap[n].stop = addr;
95 7a4ee46d 2003-11-23 devnull namecp(amap[n].name, ap->arenas[j]->name);
96 7a4ee46d 2003-11-23 devnull fprint(2, "add arena %s at [%lld,%lld)\n",
97 7a4ee46d 2003-11-23 devnull amap[n].name, amap[n].start, amap[n].stop);
98 7a4ee46d 2003-11-23 devnull }
99 7a4ee46d 2003-11-23 devnull
100 7a4ee46d 2003-11-23 devnull n++;
101 7a4ee46d 2003-11-23 devnull }
102 7a4ee46d 2003-11-23 devnull }
103 7a4ee46d 2003-11-23 devnull fprint(2, "configured index=%s with arenas=%d and storage=%lld\n",
104 7a4ee46d 2003-11-23 devnull ix->name, n, addr - IndexBase);
105 333c1dcc 2004-03-13 devnull fprint(2, "\tbitblocks=%d maxdepth=%d buckets=%d\n",
106 333c1dcc 2004-03-13 devnull ix->bitblocks, ix->maxdepth, ix->buckets);
107 7a4ee46d 2003-11-23 devnull
108 7a4ee46d 2003-11-23 devnull ix->amap = amap;
109 7a4ee46d 2003-11-23 devnull ix->arenas = arenas;
110 7a4ee46d 2003-11-23 devnull ix->narenas = narenas;
111 7a4ee46d 2003-11-23 devnull
112 7a4ee46d 2003-11-23 devnull if(wbindex(ix) < 0)
113 7a4ee46d 2003-11-23 devnull fprint(2, "can't write back arena partition header for %s: %r\n", file);
114 7a4ee46d 2003-11-23 devnull
115 7a4ee46d 2003-11-23 devnull threadexitsall(0);
116 7a4ee46d 2003-11-23 devnull }