lirs.c revision 1.1 1 1.1 yamt /* $NetBSD: lirs.c,v 1.1 2006/10/09 12:32:46 yamt Exp $ */
2 1.1 yamt
3 1.1 yamt /*-
4 1.1 yamt * Copyright (c)2005 YAMAMOTO Takashi,
5 1.1 yamt * All rights reserved.
6 1.1 yamt *
7 1.1 yamt * Redistribution and use in source and binary forms, with or without
8 1.1 yamt * modification, are permitted provided that the following conditions
9 1.1 yamt * are met:
10 1.1 yamt * 1. Redistributions of source code must retain the above copyright
11 1.1 yamt * notice, this list of conditions and the following disclaimer.
12 1.1 yamt * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 yamt * notice, this list of conditions and the following disclaimer in the
14 1.1 yamt * documentation and/or other materials provided with the distribution.
15 1.1 yamt *
16 1.1 yamt * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
17 1.1 yamt * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18 1.1 yamt * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19 1.1 yamt * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
20 1.1 yamt * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
21 1.1 yamt * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
22 1.1 yamt * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
23 1.1 yamt * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
24 1.1 yamt * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
25 1.1 yamt * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
26 1.1 yamt * SUCH DAMAGE.
27 1.1 yamt */
28 1.1 yamt
29 1.1 yamt #include <sys/queue.h>
30 1.1 yamt
31 1.1 yamt #include <assert.h>
32 1.1 yamt #include <stdio.h>
33 1.1 yamt #include <stdlib.h>
34 1.1 yamt
35 1.1 yamt #if defined(DEBUG)
36 1.1 yamt #define DFPRINTF(...) fprintf(__VA_ARGS__)
37 1.1 yamt #else
38 1.1 yamt #define DFPRINTF(...) /* nothing */
39 1.1 yamt #endif
40 1.1 yamt
41 1.1 yamt #define MAXID 102400
42 1.1 yamt
43 1.1 yamt struct buf {
44 1.1 yamt TAILQ_ENTRY(buf) b_s;
45 1.1 yamt TAILQ_ENTRY(buf) b_q;
46 1.1 yamt int b_type;
47 1.1 yamt #define B_L 1
48 1.1 yamt #define B_H 2
49 1.1 yamt #define B_R 4
50 1.1 yamt int b_flags;
51 1.1 yamt #define B_S 8
52 1.1 yamt int b_irr;
53 1.1 yamt int b_lastts;
54 1.1 yamt };
55 1.1 yamt
56 1.1 yamt struct buf bufs[MAXID];
57 1.1 yamt
58 1.1 yamt TAILQ_HEAD(, buf) q_q;
59 1.1 yamt TAILQ_HEAD(, buf) q_s;
60 1.1 yamt
61 1.1 yamt int nlirs_max = 2;
62 1.1 yamt int nbufs_max = 3;
63 1.1 yamt int nlirs;
64 1.1 yamt int nbufs;
65 1.1 yamt
66 1.1 yamt void buf_print(struct buf *, char *);
67 1.1 yamt
68 1.1 yamt void
69 1.1 yamt buf_print(struct buf *bp, char *s)
70 1.1 yamt {
71 1.1 yamt
72 1.1 yamt DFPRINTF(stderr, "%d(%s,%s,%d)%s", (bp - bufs),
73 1.1 yamt (bp->b_type == B_L) ? "L" :
74 1.1 yamt (bp->b_type == (B_H | B_R)) ? "HR" :
75 1.1 yamt (bp->b_type == B_H) ? "H" :
76 1.1 yamt (bp->b_type == 0) ? "free" :
77 1.1 yamt "unknown",
78 1.1 yamt (bp->b_flags & B_S) ? "S" : "",
79 1.1 yamt bp->b_irr,
80 1.1 yamt s);
81 1.1 yamt }
82 1.1 yamt
83 1.1 yamt void
84 1.1 yamt dump()
85 1.1 yamt {
86 1.1 yamt #if defined(DEBUG)
87 1.1 yamt struct buf *bp;
88 1.1 yamt int i;
89 1.1 yamt
90 1.1 yamt DFPRINTF(stderr, "S: ");
91 1.1 yamt TAILQ_FOREACH(bp, &q_s, b_s) {
92 1.1 yamt buf_print(bp, " ");
93 1.1 yamt }
94 1.1 yamt DFPRINTF(stderr, "\n");
95 1.1 yamt
96 1.1 yamt DFPRINTF(stderr, "Q: ");
97 1.1 yamt TAILQ_FOREACH(bp, &q_q, b_q) {
98 1.1 yamt buf_print(bp, " ");
99 1.1 yamt }
100 1.1 yamt DFPRINTF(stderr, "\n");
101 1.1 yamt
102 1.1 yamt #if 0
103 1.1 yamt for (i = 0; i < 256; i++) {
104 1.1 yamt
105 1.1 yamt bp = &bufs[i];
106 1.1 yamt if (bufs->b_type == 0) {
107 1.1 yamt continue;
108 1.1 yamt }
109 1.1 yamt }
110 1.1 yamt #endif
111 1.1 yamt
112 1.1 yamt DFPRINTF(stderr, "nlirs=%d, nbufs=%d\n", nlirs, nbufs);
113 1.1 yamt #endif /* defined(DEBUG) */
114 1.1 yamt }
115 1.1 yamt
116 1.1 yamt void
117 1.1 yamt reclaim()
118 1.1 yamt {
119 1.1 yamt struct buf *bp;
120 1.1 yamt
121 1.1 yamt if (nbufs <= nbufs_max) {
122 1.1 yamt return;
123 1.1 yamt }
124 1.1 yamt
125 1.1 yamt bp = TAILQ_FIRST(&q_q);
126 1.1 yamt buf_print(bp, ": reclaim\n");
127 1.1 yamt assert(bp->b_type == B_H | B_R);
128 1.1 yamt TAILQ_REMOVE(&q_q, bp, b_q);
129 1.1 yamt bp->b_type &= ~B_R;
130 1.1 yamt nbufs--;
131 1.1 yamt }
132 1.1 yamt
133 1.1 yamt void
134 1.1 yamt prune()
135 1.1 yamt {
136 1.1 yamt
137 1.1 yamt while (1) {
138 1.1 yamt struct buf *bp;
139 1.1 yamt
140 1.1 yamt bp = TAILQ_FIRST(&q_s);
141 1.1 yamt if (bp->b_type == B_L) {
142 1.1 yamt break;
143 1.1 yamt }
144 1.1 yamt buf_print(bp, ": prune\n");
145 1.1 yamt TAILQ_REMOVE(&q_s, bp, b_s);
146 1.1 yamt assert(bp->b_flags & B_S);
147 1.1 yamt bp->b_flags &= ~B_S;
148 1.1 yamt if ((bp->b_type & B_R) == 0) {
149 1.1 yamt bp->b_type &= ~B_H;
150 1.1 yamt }
151 1.1 yamt }
152 1.1 yamt }
153 1.1 yamt
154 1.1 yamt void
155 1.1 yamt reclaim_l()
156 1.1 yamt {
157 1.1 yamt struct buf *bp;
158 1.1 yamt
159 1.1 yamt if (nlirs <= nlirs_max) {
160 1.1 yamt return;
161 1.1 yamt }
162 1.1 yamt
163 1.1 yamt bp = TAILQ_FIRST(&q_s);
164 1.1 yamt buf_print(bp, ": reclaim_l\n");
165 1.1 yamt assert(bp->b_type == B_L);
166 1.1 yamt assert(bp->b_flags & B_S);
167 1.1 yamt bp->b_type = B_H | B_R;
168 1.1 yamt bp->b_flags &= ~B_S;
169 1.1 yamt TAILQ_REMOVE(&q_s, bp, b_s);
170 1.1 yamt TAILQ_INSERT_TAIL(&q_q, bp, b_q);
171 1.1 yamt nlirs--;
172 1.1 yamt prune();
173 1.1 yamt }
174 1.1 yamt
175 1.1 yamt void
176 1.1 yamt init(int n)
177 1.1 yamt {
178 1.1 yamt
179 1.1 yamt TAILQ_INIT(&q_q);
180 1.1 yamt TAILQ_INIT(&q_s);
181 1.1 yamt memset(&bufs, 0, sizeof(bufs));
182 1.1 yamt nbufs_max = n;
183 1.1 yamt #if 0
184 1.1 yamt nlirs_max = nbufs_max * 2 / 3;
185 1.1 yamt #else
186 1.1 yamt nlirs_max = nbufs_max * 90 / 100;
187 1.1 yamt #endif
188 1.1 yamt }
189 1.1 yamt
190 1.1 yamt struct object {int dummy;};
191 1.1 yamt int ts = 1;
192 1.1 yamt
193 1.1 yamt void
194 1.1 yamt fault(struct object *dummy, int i)
195 1.1 yamt {
196 1.1 yamt struct buf *bp;
197 1.1 yamt
198 1.1 yamt DFPRINTF(stderr, "----------\n");
199 1.1 yamt dump();
200 1.1 yamt
201 1.1 yamt DFPRINTF(stderr, "---------- ts %d\n", ts);
202 1.1 yamt
203 1.1 yamt bp = &bufs[i];
204 1.1 yamt buf_print(bp, ": access\n");
205 1.1 yamt if (bp->b_type == 0) {
206 1.1 yamt bp->b_irr = -1;
207 1.1 yamt } else {
208 1.1 yamt bp->b_irr = ts - bp->b_lastts - 1;
209 1.1 yamt }
210 1.1 yamt bp->b_lastts = ts;
211 1.1 yamt
212 1.1 yamt if (bp->b_type == B_L) {
213 1.1 yamt assert(bp->b_flags & B_S);
214 1.1 yamt TAILQ_REMOVE(&q_s, bp, b_s);
215 1.1 yamt TAILQ_INSERT_TAIL(&q_s, bp, b_s);
216 1.1 yamt prune();
217 1.1 yamt goto done;
218 1.1 yamt }
219 1.1 yamt if (bp->b_type == (B_H | B_R)) {
220 1.1 yamt if (bp->b_flags & B_S) {
221 1.1 yamt TAILQ_REMOVE(&q_s, bp, b_s);
222 1.1 yamt TAILQ_REMOVE(&q_q, bp, b_q);
223 1.1 yamt bp->b_type = B_L;
224 1.1 yamt nlirs++;
225 1.1 yamt reclaim_l();
226 1.1 yamt } else {
227 1.1 yamt TAILQ_REMOVE(&q_q, bp, b_q);
228 1.1 yamt TAILQ_INSERT_TAIL(&q_q, bp, b_q);
229 1.1 yamt }
230 1.1 yamt TAILQ_INSERT_TAIL(&q_s, bp, b_s);
231 1.1 yamt bp->b_flags |= B_S;
232 1.1 yamt goto done;
233 1.1 yamt }
234 1.1 yamt nbufs++;
235 1.1 yamt reclaim();
236 1.1 yamt if ((bp->b_flags & (B_R | B_L)) == 0) {
237 1.1 yamt printf("%d\n", i);
238 1.1 yamt }
239 1.1 yamt if (bp->b_type == 0) {
240 1.1 yamt buf_print(bp, ": new\n");
241 1.1 yamt if (nlirs < nlirs_max) {
242 1.1 yamt bp->b_type = B_L;
243 1.1 yamt TAILQ_INSERT_TAIL(&q_s, bp, b_s);
244 1.1 yamt bp->b_flags |= B_S;
245 1.1 yamt nlirs++;
246 1.1 yamt } else {
247 1.1 yamt bp->b_type = B_H;
248 1.1 yamt }
249 1.1 yamt }
250 1.1 yamt if (bp->b_type == B_H) {
251 1.1 yamt if (bp->b_flags & B_S) {
252 1.1 yamt TAILQ_REMOVE(&q_s, bp, b_s);
253 1.1 yamt bp->b_type = B_L;
254 1.1 yamt nlirs++;
255 1.1 yamt reclaim_l();
256 1.1 yamt } else {
257 1.1 yamt bp->b_type |= B_R;
258 1.1 yamt TAILQ_INSERT_TAIL(&q_q, bp, b_q);
259 1.1 yamt }
260 1.1 yamt TAILQ_INSERT_TAIL(&q_s, bp, b_s);
261 1.1 yamt bp->b_flags |= B_S;
262 1.1 yamt }
263 1.1 yamt done:
264 1.1 yamt ts++;
265 1.1 yamt }
266 1.1 yamt
267 1.1 yamt void
268 1.1 yamt test(void)
269 1.1 yamt {
270 1.1 yamt struct object obj;
271 1.1 yamt memset(&obj, 0, sizeof(obj));
272 1.1 yamt char *ln;
273 1.1 yamt
274 1.1 yamt for (;; free(ln)) {
275 1.1 yamt int i;
276 1.1 yamt int ch;
277 1.1 yamt
278 1.1 yamt ln = fparseln(stdin, NULL, NULL, NULL, 0);
279 1.1 yamt if (ln == NULL) {
280 1.1 yamt break;
281 1.1 yamt }
282 1.1 yamt ch = *ln;
283 1.1 yamt if (ch == '\0') {
284 1.1 yamt break;
285 1.1 yamt }
286 1.1 yamt #if 1
287 1.1 yamt if (ch == 'd') {
288 1.1 yamt dump();
289 1.1 yamt continue;
290 1.1 yamt }
291 1.1 yamt #endif
292 1.1 yamt i = atoi(ln);
293 1.1 yamt fault(&obj, i);
294 1.1 yamt }
295 1.1 yamt }
296 1.1 yamt
297 1.1 yamt int
298 1.1 yamt main(int argc, char *argv[])
299 1.1 yamt {
300 1.1 yamt
301 1.1 yamt init(atoi(argv[1]));
302 1.1 yamt test();
303 1.1 yamt exit(0);
304 1.1 yamt }
305