subr_extent.c revision 1.37 1 1.37 sommerfe /* $NetBSD: subr_extent.c,v 1.37 2000/08/12 16:29:36 sommerfeld Exp $ */
2 1.1 thorpej
3 1.1 thorpej /*-
4 1.11 thorpej * Copyright (c) 1996, 1998 The NetBSD Foundation, Inc.
5 1.1 thorpej * All rights reserved.
6 1.1 thorpej *
7 1.1 thorpej * This code is derived from software contributed to The NetBSD Foundation
8 1.1 thorpej * by Jason R. Thorpe and Matthias Drochner.
9 1.1 thorpej *
10 1.1 thorpej * Redistribution and use in source and binary forms, with or without
11 1.1 thorpej * modification, are permitted provided that the following conditions
12 1.1 thorpej * are met:
13 1.1 thorpej * 1. Redistributions of source code must retain the above copyright
14 1.1 thorpej * notice, this list of conditions and the following disclaimer.
15 1.1 thorpej * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 thorpej * notice, this list of conditions and the following disclaimer in the
17 1.1 thorpej * documentation and/or other materials provided with the distribution.
18 1.1 thorpej * 3. All advertising materials mentioning features or use of this software
19 1.1 thorpej * must display the following acknowledgement:
20 1.20 christos * This product includes software developed by the NetBSD
21 1.20 christos * Foundation, Inc. and its contributors.
22 1.1 thorpej * 4. Neither the name of The NetBSD Foundation nor the names of its
23 1.1 thorpej * contributors may be used to endorse or promote products derived
24 1.1 thorpej * from this software without specific prior written permission.
25 1.1 thorpej *
26 1.1 thorpej * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
27 1.1 thorpej * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
28 1.1 thorpej * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
29 1.10 jtc * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
30 1.10 jtc * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
31 1.1 thorpej * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
32 1.1 thorpej * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
33 1.1 thorpej * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
34 1.1 thorpej * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
35 1.1 thorpej * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
36 1.1 thorpej * POSSIBILITY OF SUCH DAMAGE.
37 1.1 thorpej */
38 1.1 thorpej
39 1.1 thorpej /*
40 1.1 thorpej * General purpose extent manager.
41 1.1 thorpej */
42 1.1 thorpej
43 1.7 cgd #ifdef _KERNEL
44 1.1 thorpej #include <sys/param.h>
45 1.1 thorpej #include <sys/extent.h>
46 1.1 thorpej #include <sys/malloc.h>
47 1.14 pk #include <sys/pool.h>
48 1.1 thorpej #include <sys/time.h>
49 1.1 thorpej #include <sys/systm.h>
50 1.1 thorpej #include <sys/proc.h>
51 1.12 thorpej #include <sys/lock.h>
52 1.34 mrg
53 1.34 mrg #include <uvm/uvm_extern.h>
54 1.29 thorpej
55 1.29 thorpej #define KMEM_IS_RUNNING (kmem_map != NULL)
56 1.18 pk #elif defined(_EXTENT_TESTING)
57 1.7 cgd /*
58 1.7 cgd * user-land definitions, so it can fit into a testing harness.
59 1.7 cgd */
60 1.7 cgd #include <sys/param.h>
61 1.18 pk #include <sys/pool.h>
62 1.7 cgd #include <sys/extent.h>
63 1.7 cgd #include <errno.h>
64 1.7 cgd #include <stdlib.h>
65 1.7 cgd #include <stdio.h>
66 1.28 ross #include <string.h>
67 1.7 cgd
68 1.30 jhawk /*
69 1.30 jhawk * Use multi-line #defines to avoid screwing up the kernel tags file;
70 1.30 jhawk * without this, ctags produces a tags file where panic() shows up
71 1.30 jhawk * in subr_extent.c rather than subr_prf.c.
72 1.30 jhawk */
73 1.30 jhawk #define \
74 1.30 jhawk malloc(s, t, flags) malloc(s)
75 1.30 jhawk #define \
76 1.30 jhawk free(p, t) free(p)
77 1.30 jhawk #define \
78 1.30 jhawk tsleep(chan, pri, str, timo) (EWOULDBLOCK)
79 1.30 jhawk #define \
80 1.30 jhawk wakeup(chan) ((void)0)
81 1.30 jhawk #define \
82 1.30 jhawk pool_get(pool, flags) malloc(pool->pr_size,0,0)
83 1.30 jhawk #define \
84 1.30 jhawk pool_put(pool, rp) free(rp,0)
85 1.30 jhawk #define \
86 1.30 jhawk panic(a) printf(a)
87 1.30 jhawk #define \
88 1.30 jhawk splhigh() (1)
89 1.30 jhawk #define \
90 1.30 jhawk splx(s) ((void)(s))
91 1.29 thorpej
92 1.31 thorpej #define \
93 1.31 thorpej simple_lock_init(l) ((void)(l))
94 1.31 thorpej #define \
95 1.31 thorpej simple_lock(l) ((void)(l))
96 1.31 thorpej #define \
97 1.31 thorpej simple_unlock(l) ((void)(l))
98 1.29 thorpej #define KMEM_IS_RUNNING (1)
99 1.7 cgd #endif
100 1.1 thorpej
101 1.15 sommerfe static pool_handle_t expool_create __P((void));
102 1.6 thorpej static void extent_insert_and_optimize __P((struct extent *, u_long, u_long,
103 1.6 thorpej int, struct extent_region *, struct extent_region *));
104 1.1 thorpej static struct extent_region *extent_alloc_region_descriptor
105 1.1 thorpej __P((struct extent *, int));
106 1.1 thorpej static void extent_free_region_descriptor __P((struct extent *,
107 1.1 thorpej struct extent_region *));
108 1.1 thorpej
109 1.14 pk static pool_handle_t expool;
110 1.14 pk
111 1.1 thorpej /*
112 1.6 thorpej * Macro to align to an arbitrary power-of-two boundary.
113 1.6 thorpej */
114 1.19 pk #define EXTENT_ALIGN(_start, _align, _skew) \
115 1.19 pk (((((_start) - (_skew)) + ((_align) - 1)) & (-(_align))) + (_skew))
116 1.6 thorpej
117 1.6 thorpej /*
118 1.15 sommerfe * Create the extent_region pool.
119 1.15 sommerfe * (This is deferred until one of our callers thinks we can malloc()).
120 1.15 sommerfe */
121 1.15 sommerfe
122 1.15 sommerfe static pool_handle_t expool_create()
123 1.15 sommerfe {
124 1.18 pk #if defined(_KERNEL)
125 1.18 pk expool = pool_create(sizeof(struct extent_region), 0, 0,
126 1.18 pk 0, "extent", 0, 0, 0, 0);
127 1.18 pk #else
128 1.18 pk expool = (pool_handle_t)malloc(sizeof(*expool),0,0);
129 1.18 pk expool->pr_size = sizeof(struct extent_region);
130 1.18 pk #endif
131 1.18 pk return (expool);
132 1.15 sommerfe }
133 1.15 sommerfe
134 1.15 sommerfe /*
135 1.1 thorpej * Allocate and initialize an extent map.
136 1.1 thorpej */
137 1.1 thorpej struct extent *
138 1.1 thorpej extent_create(name, start, end, mtype, storage, storagesize, flags)
139 1.11 thorpej const char *name;
140 1.1 thorpej u_long start, end;
141 1.1 thorpej int mtype;
142 1.1 thorpej caddr_t storage;
143 1.1 thorpej size_t storagesize;
144 1.1 thorpej int flags;
145 1.1 thorpej {
146 1.1 thorpej struct extent *ex;
147 1.1 thorpej caddr_t cp = storage;
148 1.1 thorpej size_t sz = storagesize;
149 1.1 thorpej struct extent_region *rp;
150 1.1 thorpej int fixed_extent = (storage != NULL);
151 1.26 pk int s;
152 1.1 thorpej
153 1.6 thorpej #ifdef DIAGNOSTIC
154 1.1 thorpej /* Check arguments. */
155 1.1 thorpej if (name == NULL)
156 1.1 thorpej panic("extent_create: name == NULL");
157 1.1 thorpej if (end < start) {
158 1.5 christos printf("extent_create: extent `%s', start 0x%lx, end 0x%lx\n",
159 1.1 thorpej name, start, end);
160 1.1 thorpej panic("extent_create: end < start");
161 1.1 thorpej }
162 1.1 thorpej if (fixed_extent && (storagesize < sizeof(struct extent_fixed)))
163 1.22 thorpej panic("extent_create: fixed extent, bad storagesize 0x%lx",
164 1.22 thorpej (u_long)storagesize);
165 1.6 thorpej if (fixed_extent == 0 && (storagesize != 0 || storage != NULL))
166 1.6 thorpej panic("extent_create: storage provided for non-fixed");
167 1.6 thorpej #endif
168 1.1 thorpej
169 1.1 thorpej /* Allocate extent descriptor. */
170 1.1 thorpej if (fixed_extent) {
171 1.1 thorpej struct extent_fixed *fex;
172 1.1 thorpej
173 1.16 perry memset(storage, 0, storagesize);
174 1.1 thorpej
175 1.1 thorpej /*
176 1.1 thorpej * Align all descriptors on "long" boundaries.
177 1.1 thorpej */
178 1.1 thorpej fex = (struct extent_fixed *)cp;
179 1.1 thorpej ex = (struct extent *)fex;
180 1.6 thorpej cp += ALIGN(sizeof(struct extent_fixed));
181 1.6 thorpej sz -= ALIGN(sizeof(struct extent_fixed));
182 1.1 thorpej fex->fex_storage = storage;
183 1.1 thorpej fex->fex_storagesize = storagesize;
184 1.1 thorpej
185 1.1 thorpej /*
186 1.1 thorpej * In a fixed extent, we have to pre-allocate region
187 1.1 thorpej * descriptors and place them in the extent's freelist.
188 1.1 thorpej */
189 1.1 thorpej LIST_INIT(&fex->fex_freelist);
190 1.6 thorpej while (sz >= ALIGN(sizeof(struct extent_region))) {
191 1.1 thorpej rp = (struct extent_region *)cp;
192 1.6 thorpej cp += ALIGN(sizeof(struct extent_region));
193 1.6 thorpej sz -= ALIGN(sizeof(struct extent_region));
194 1.1 thorpej LIST_INSERT_HEAD(&fex->fex_freelist, rp, er_link);
195 1.1 thorpej }
196 1.1 thorpej } else {
197 1.26 pk s = splhigh();
198 1.26 pk if (expool == NULL)
199 1.26 pk expool_create();
200 1.26 pk splx(s);
201 1.26 pk if (expool == NULL)
202 1.26 pk return (NULL);
203 1.15 sommerfe
204 1.1 thorpej ex = (struct extent *)malloc(sizeof(struct extent),
205 1.1 thorpej mtype, (flags & EX_WAITOK) ? M_WAITOK : M_NOWAIT);
206 1.1 thorpej if (ex == NULL)
207 1.1 thorpej return (NULL);
208 1.1 thorpej }
209 1.1 thorpej
210 1.1 thorpej /* Fill in the extent descriptor and return it to the caller. */
211 1.12 thorpej simple_lock_init(&ex->ex_slock);
212 1.1 thorpej LIST_INIT(&ex->ex_regions);
213 1.1 thorpej ex->ex_name = name;
214 1.1 thorpej ex->ex_start = start;
215 1.1 thorpej ex->ex_end = end;
216 1.1 thorpej ex->ex_mtype = mtype;
217 1.1 thorpej ex->ex_flags = 0;
218 1.1 thorpej if (fixed_extent)
219 1.1 thorpej ex->ex_flags |= EXF_FIXED;
220 1.6 thorpej if (flags & EX_NOCOALESCE)
221 1.6 thorpej ex->ex_flags |= EXF_NOCOALESCE;
222 1.1 thorpej return (ex);
223 1.1 thorpej }
224 1.1 thorpej
225 1.1 thorpej /*
226 1.1 thorpej * Destroy an extent map.
227 1.21 chs * Since we're freeing the data, there can't be any references
228 1.21 chs * so we don't need any locking.
229 1.1 thorpej */
230 1.1 thorpej void
231 1.1 thorpej extent_destroy(ex)
232 1.1 thorpej struct extent *ex;
233 1.1 thorpej {
234 1.1 thorpej struct extent_region *rp, *orp;
235 1.1 thorpej
236 1.6 thorpej #ifdef DIAGNOSTIC
237 1.1 thorpej /* Check arguments. */
238 1.1 thorpej if (ex == NULL)
239 1.1 thorpej panic("extent_destroy: NULL extent");
240 1.6 thorpej #endif
241 1.12 thorpej
242 1.1 thorpej /* Free all region descriptors in extent. */
243 1.1 thorpej for (rp = ex->ex_regions.lh_first; rp != NULL; ) {
244 1.1 thorpej orp = rp;
245 1.1 thorpej rp = rp->er_link.le_next;
246 1.1 thorpej LIST_REMOVE(orp, er_link);
247 1.1 thorpej extent_free_region_descriptor(ex, orp);
248 1.1 thorpej }
249 1.1 thorpej
250 1.1 thorpej /* If we're not a fixed extent, free the extent descriptor itself. */
251 1.1 thorpej if ((ex->ex_flags & EXF_FIXED) == 0)
252 1.6 thorpej free(ex, ex->ex_mtype);
253 1.1 thorpej }
254 1.1 thorpej
255 1.1 thorpej /*
256 1.1 thorpej * Insert a region descriptor into the sorted region list after the
257 1.1 thorpej * entry "after" or at the head of the list (if "after" is NULL).
258 1.6 thorpej * The region descriptor we insert is passed in "rp". We must
259 1.6 thorpej * allocate the region descriptor before calling this function!
260 1.6 thorpej * If we don't need the region descriptor, it will be freed here.
261 1.1 thorpej */
262 1.6 thorpej static void
263 1.6 thorpej extent_insert_and_optimize(ex, start, size, flags, after, rp)
264 1.1 thorpej struct extent *ex;
265 1.1 thorpej u_long start, size;
266 1.1 thorpej int flags;
267 1.6 thorpej struct extent_region *after, *rp;
268 1.1 thorpej {
269 1.7 cgd struct extent_region *nextr;
270 1.1 thorpej int appended = 0;
271 1.1 thorpej
272 1.1 thorpej if (after == NULL) {
273 1.1 thorpej /*
274 1.1 thorpej * We're the first in the region list. If there's
275 1.1 thorpej * a region after us, attempt to coalesce to save
276 1.1 thorpej * descriptor overhead.
277 1.1 thorpej */
278 1.6 thorpej if (((ex->ex_flags & EXF_NOCOALESCE) == 0) &&
279 1.1 thorpej (ex->ex_regions.lh_first != NULL) &&
280 1.1 thorpej ((start + size) == ex->ex_regions.lh_first->er_start)) {
281 1.1 thorpej /*
282 1.1 thorpej * We can coalesce. Prepend us to the first region.
283 1.1 thorpej */
284 1.1 thorpej ex->ex_regions.lh_first->er_start = start;
285 1.6 thorpej extent_free_region_descriptor(ex, rp);
286 1.6 thorpej return;
287 1.1 thorpej }
288 1.1 thorpej
289 1.1 thorpej /*
290 1.6 thorpej * Can't coalesce. Fill in the region descriptor
291 1.1 thorpej * in, and insert us at the head of the region list.
292 1.1 thorpej */
293 1.1 thorpej rp->er_start = start;
294 1.1 thorpej rp->er_end = start + (size - 1);
295 1.1 thorpej LIST_INSERT_HEAD(&ex->ex_regions, rp, er_link);
296 1.6 thorpej return;
297 1.1 thorpej }
298 1.1 thorpej
299 1.1 thorpej /*
300 1.6 thorpej * If EXF_NOCOALESCE is set, coalescing is disallowed.
301 1.1 thorpej */
302 1.6 thorpej if (ex->ex_flags & EXF_NOCOALESCE)
303 1.6 thorpej goto cant_coalesce;
304 1.1 thorpej
305 1.1 thorpej /*
306 1.1 thorpej * Attempt to coalesce with the region before us.
307 1.1 thorpej */
308 1.1 thorpej if ((after->er_end + 1) == start) {
309 1.1 thorpej /*
310 1.1 thorpej * We can coalesce. Append ourselves and make
311 1.1 thorpej * note of it.
312 1.1 thorpej */
313 1.1 thorpej after->er_end = start + (size - 1);
314 1.1 thorpej appended = 1;
315 1.1 thorpej }
316 1.1 thorpej
317 1.1 thorpej /*
318 1.1 thorpej * Attempt to coalesce with the region after us.
319 1.1 thorpej */
320 1.1 thorpej if ((after->er_link.le_next != NULL) &&
321 1.1 thorpej ((start + size) == after->er_link.le_next->er_start)) {
322 1.1 thorpej /*
323 1.1 thorpej * We can coalesce. Note that if we appended ourselves
324 1.1 thorpej * to the previous region, we exactly fit the gap, and
325 1.1 thorpej * can free the "next" region descriptor.
326 1.1 thorpej */
327 1.1 thorpej if (appended) {
328 1.1 thorpej /*
329 1.1 thorpej * Yup, we can free it up.
330 1.1 thorpej */
331 1.1 thorpej after->er_end = after->er_link.le_next->er_end;
332 1.7 cgd nextr = after->er_link.le_next;
333 1.7 cgd LIST_REMOVE(nextr, er_link);
334 1.7 cgd extent_free_region_descriptor(ex, nextr);
335 1.1 thorpej } else {
336 1.1 thorpej /*
337 1.1 thorpej * Nope, just prepend us to the next region.
338 1.1 thorpej */
339 1.1 thorpej after->er_link.le_next->er_start = start;
340 1.1 thorpej }
341 1.6 thorpej
342 1.6 thorpej extent_free_region_descriptor(ex, rp);
343 1.6 thorpej return;
344 1.1 thorpej }
345 1.1 thorpej
346 1.1 thorpej /*
347 1.1 thorpej * We weren't able to coalesce with the next region, but
348 1.1 thorpej * we don't need to allocate a region descriptor if we
349 1.1 thorpej * appended ourselves to the previous region.
350 1.1 thorpej */
351 1.6 thorpej if (appended) {
352 1.6 thorpej extent_free_region_descriptor(ex, rp);
353 1.6 thorpej return;
354 1.6 thorpej }
355 1.1 thorpej
356 1.6 thorpej cant_coalesce:
357 1.1 thorpej
358 1.1 thorpej /*
359 1.6 thorpej * Fill in the region descriptor and insert ourselves
360 1.1 thorpej * into the region list.
361 1.1 thorpej */
362 1.1 thorpej rp->er_start = start;
363 1.1 thorpej rp->er_end = start + (size - 1);
364 1.1 thorpej LIST_INSERT_AFTER(after, rp, er_link);
365 1.1 thorpej }
366 1.1 thorpej
367 1.1 thorpej /*
368 1.1 thorpej * Allocate a specific region in an extent map.
369 1.1 thorpej */
370 1.1 thorpej int
371 1.1 thorpej extent_alloc_region(ex, start, size, flags)
372 1.1 thorpej struct extent *ex;
373 1.1 thorpej u_long start, size;
374 1.1 thorpej int flags;
375 1.1 thorpej {
376 1.6 thorpej struct extent_region *rp, *last, *myrp;
377 1.1 thorpej u_long end = start + (size - 1);
378 1.1 thorpej int error;
379 1.1 thorpej
380 1.6 thorpej #ifdef DIAGNOSTIC
381 1.1 thorpej /* Check arguments. */
382 1.1 thorpej if (ex == NULL)
383 1.1 thorpej panic("extent_alloc_region: NULL extent");
384 1.1 thorpej if (size < 1) {
385 1.5 christos printf("extent_alloc_region: extent `%s', size 0x%lx\n",
386 1.1 thorpej ex->ex_name, size);
387 1.1 thorpej panic("extent_alloc_region: bad size");
388 1.1 thorpej }
389 1.1 thorpej if (end < start) {
390 1.5 christos printf(
391 1.1 thorpej "extent_alloc_region: extent `%s', start 0x%lx, size 0x%lx\n",
392 1.1 thorpej ex->ex_name, start, size);
393 1.1 thorpej panic("extent_alloc_region: overflow");
394 1.1 thorpej }
395 1.6 thorpej #endif
396 1.6 thorpej
397 1.1 thorpej /*
398 1.1 thorpej * Make sure the requested region lies within the
399 1.1 thorpej * extent.
400 1.12 thorpej *
401 1.12 thorpej * We don't lock to check the range, because those values
402 1.12 thorpej * are never modified, and if another thread deletes the
403 1.12 thorpej * extent, we're screwed anyway.
404 1.1 thorpej */
405 1.1 thorpej if ((start < ex->ex_start) || (end > ex->ex_end)) {
406 1.6 thorpej #ifdef DIAGNOSTIC
407 1.5 christos printf("extent_alloc_region: extent `%s' (0x%lx - 0x%lx)\n",
408 1.1 thorpej ex->ex_name, ex->ex_start, ex->ex_end);
409 1.5 christos printf("extent_alloc_region: start 0x%lx, end 0x%lx\n",
410 1.1 thorpej start, end);
411 1.1 thorpej panic("extent_alloc_region: region lies outside extent");
412 1.6 thorpej #else
413 1.6 thorpej return (EINVAL);
414 1.6 thorpej #endif
415 1.6 thorpej }
416 1.6 thorpej
417 1.6 thorpej /*
418 1.6 thorpej * Allocate the region descriptor. It will be freed later
419 1.12 thorpej * if we can coalesce with another region. Don't lock before
420 1.12 thorpej * here! This could block.
421 1.6 thorpej */
422 1.6 thorpej myrp = extent_alloc_region_descriptor(ex, flags);
423 1.6 thorpej if (myrp == NULL) {
424 1.6 thorpej #ifdef DIAGNOSTIC
425 1.6 thorpej printf(
426 1.6 thorpej "extent_alloc_region: can't allocate region descriptor\n");
427 1.6 thorpej #endif
428 1.6 thorpej return (ENOMEM);
429 1.1 thorpej }
430 1.1 thorpej
431 1.1 thorpej alloc_start:
432 1.12 thorpej simple_lock(&ex->ex_slock);
433 1.12 thorpej
434 1.1 thorpej /*
435 1.1 thorpej * Attempt to place ourselves in the desired area of the
436 1.1 thorpej * extent. We save ourselves some work by keeping the list sorted.
437 1.1 thorpej * In other words, if the start of the current region is greater
438 1.1 thorpej * than the end of our region, we don't have to search any further.
439 1.1 thorpej */
440 1.1 thorpej
441 1.1 thorpej /*
442 1.1 thorpej * Keep a pointer to the last region we looked at so
443 1.1 thorpej * that we don't have to traverse the list again when
444 1.1 thorpej * we insert ourselves. If "last" is NULL when we
445 1.1 thorpej * finally insert ourselves, we go at the head of the
446 1.1 thorpej * list. See extent_insert_and_optimize() for details.
447 1.1 thorpej */
448 1.1 thorpej last = NULL;
449 1.1 thorpej
450 1.1 thorpej for (rp = ex->ex_regions.lh_first; rp != NULL;
451 1.1 thorpej rp = rp->er_link.le_next) {
452 1.1 thorpej if (rp->er_start > end) {
453 1.1 thorpej /*
454 1.1 thorpej * We lie before this region and don't
455 1.1 thorpej * conflict.
456 1.1 thorpej */
457 1.9 thorpej break;
458 1.1 thorpej }
459 1.1 thorpej
460 1.1 thorpej /*
461 1.1 thorpej * The current region begins before we end.
462 1.1 thorpej * Check for a conflict.
463 1.1 thorpej */
464 1.1 thorpej if (rp->er_end >= start) {
465 1.1 thorpej /*
466 1.6 thorpej * We conflict. If we can (and want to) wait,
467 1.6 thorpej * do so.
468 1.1 thorpej */
469 1.6 thorpej if (flags & EX_WAITSPACE) {
470 1.1 thorpej ex->ex_flags |= EXF_WANTED;
471 1.37 sommerfe error = ltsleep(ex,
472 1.37 sommerfe PNORELOCK | PRIBIO | ((flags & EX_CATCH) ? PCATCH : 0),
473 1.37 sommerfe "extnt", 0, &ex->ex_slock);
474 1.1 thorpej if (error)
475 1.1 thorpej return (error);
476 1.1 thorpej goto alloc_start;
477 1.1 thorpej }
478 1.6 thorpej extent_free_region_descriptor(ex, myrp);
479 1.12 thorpej simple_unlock(&ex->ex_slock);
480 1.1 thorpej return (EAGAIN);
481 1.1 thorpej }
482 1.1 thorpej /*
483 1.1 thorpej * We don't conflict, but this region lies before
484 1.1 thorpej * us. Keep a pointer to this region, and keep
485 1.1 thorpej * trying.
486 1.1 thorpej */
487 1.1 thorpej last = rp;
488 1.1 thorpej }
489 1.1 thorpej
490 1.1 thorpej /*
491 1.1 thorpej * We don't conflict with any regions. "last" points
492 1.1 thorpej * to the region we fall after, or is NULL if we belong
493 1.1 thorpej * at the beginning of the region list. Insert ourselves.
494 1.1 thorpej */
495 1.6 thorpej extent_insert_and_optimize(ex, start, size, flags, last, myrp);
496 1.12 thorpej simple_unlock(&ex->ex_slock);
497 1.6 thorpej return (0);
498 1.1 thorpej }
499 1.1 thorpej
500 1.1 thorpej /*
501 1.1 thorpej * Macro to check (x + y) <= z. This check is designed to fail
502 1.1 thorpej * if an overflow occurs.
503 1.1 thorpej */
504 1.1 thorpej #define LE_OV(x, y, z) ((((x) + (y)) >= (x)) && (((x) + (y)) <= (z)))
505 1.1 thorpej
506 1.1 thorpej /*
507 1.1 thorpej * Allocate a region in an extent map subregion.
508 1.1 thorpej *
509 1.1 thorpej * If EX_FAST is specified, we return the first fit in the map.
510 1.1 thorpej * Otherwise, we try to minimize fragmentation by finding the
511 1.1 thorpej * smallest gap that will hold the request.
512 1.1 thorpej *
513 1.1 thorpej * The allocated region is aligned to "alignment", which must be
514 1.1 thorpej * a power of 2.
515 1.1 thorpej */
516 1.1 thorpej int
517 1.19 pk extent_alloc_subregion1(ex, substart, subend, size, alignment, skew, boundary,
518 1.1 thorpej flags, result)
519 1.1 thorpej struct extent *ex;
520 1.19 pk u_long substart, subend, size, alignment, skew, boundary;
521 1.1 thorpej int flags;
522 1.1 thorpej u_long *result;
523 1.1 thorpej {
524 1.6 thorpej struct extent_region *rp, *myrp, *last, *bestlast;
525 1.1 thorpej u_long newstart, newend, beststart, bestovh, ovh;
526 1.23 mycroft u_long dontcross;
527 1.1 thorpej int error;
528 1.1 thorpej
529 1.6 thorpej #ifdef DIAGNOSTIC
530 1.12 thorpej /*
531 1.12 thorpej * Check arguments.
532 1.12 thorpej *
533 1.12 thorpej * We don't lock to check these, because these values
534 1.12 thorpej * are never modified, and if another thread deletes the
535 1.12 thorpej * extent, we're screwed anyway.
536 1.12 thorpej */
537 1.1 thorpej if (ex == NULL)
538 1.1 thorpej panic("extent_alloc_subregion: NULL extent");
539 1.1 thorpej if (result == NULL)
540 1.1 thorpej panic("extent_alloc_subregion: NULL result pointer");
541 1.8 thorpej if ((substart < ex->ex_start) || (substart > ex->ex_end) ||
542 1.8 thorpej (subend > ex->ex_end) || (subend < ex->ex_start)) {
543 1.5 christos printf("extent_alloc_subregion: extent `%s', ex_start 0x%lx, ex_end 0x%lx\n",
544 1.1 thorpej ex->ex_name, ex->ex_start, ex->ex_end);
545 1.5 christos printf("extent_alloc_subregion: substart 0x%lx, subend 0x%lx\n",
546 1.1 thorpej substart, subend);
547 1.1 thorpej panic("extent_alloc_subregion: bad subregion");
548 1.1 thorpej }
549 1.8 thorpej if ((size < 1) || ((size - 1) > (subend - substart))) {
550 1.5 christos printf("extent_alloc_subregion: extent `%s', size 0x%lx\n",
551 1.1 thorpej ex->ex_name, size);
552 1.1 thorpej panic("extent_alloc_subregion: bad size");
553 1.1 thorpej }
554 1.1 thorpej if (alignment == 0)
555 1.1 thorpej panic("extent_alloc_subregion: bad alignment");
556 1.1 thorpej if (boundary && (boundary < size)) {
557 1.5 christos printf(
558 1.1 thorpej "extent_alloc_subregion: extent `%s', size 0x%lx,
559 1.1 thorpej boundary 0x%lx\n", ex->ex_name, size, boundary);
560 1.1 thorpej panic("extent_alloc_subregion: bad boundary");
561 1.1 thorpej }
562 1.6 thorpej #endif
563 1.6 thorpej
564 1.6 thorpej /*
565 1.6 thorpej * Allocate the region descriptor. It will be freed later
566 1.12 thorpej * if we can coalesce with another region. Don't lock before
567 1.12 thorpej * here! This could block.
568 1.6 thorpej */
569 1.6 thorpej myrp = extent_alloc_region_descriptor(ex, flags);
570 1.6 thorpej if (myrp == NULL) {
571 1.6 thorpej #ifdef DIAGNOSTIC
572 1.6 thorpej printf(
573 1.6 thorpej "extent_alloc_subregion: can't allocate region descriptor\n");
574 1.6 thorpej #endif
575 1.6 thorpej return (ENOMEM);
576 1.6 thorpej }
577 1.1 thorpej
578 1.1 thorpej alloc_start:
579 1.12 thorpej simple_lock(&ex->ex_slock);
580 1.12 thorpej
581 1.1 thorpej /*
582 1.1 thorpej * Keep a pointer to the last region we looked at so
583 1.1 thorpej * that we don't have to traverse the list again when
584 1.1 thorpej * we insert ourselves. If "last" is NULL when we
585 1.1 thorpej * finally insert ourselves, we go at the head of the
586 1.1 thorpej * list. See extent_insert_and_optimize() for deatails.
587 1.1 thorpej */
588 1.1 thorpej last = NULL;
589 1.1 thorpej
590 1.1 thorpej /*
591 1.1 thorpej * Keep track of size and location of the smallest
592 1.1 thorpej * chunk we fit in.
593 1.1 thorpej *
594 1.1 thorpej * Since the extent can be as large as the numeric range
595 1.1 thorpej * of the CPU (0 - 0xffffffff for 32-bit systems), the
596 1.1 thorpej * best overhead value can be the maximum unsigned integer.
597 1.1 thorpej * Thus, we initialize "bestovh" to 0, since we insert ourselves
598 1.1 thorpej * into the region list immediately on an exact match (which
599 1.1 thorpej * is the only case where "bestovh" would be set to 0).
600 1.1 thorpej */
601 1.1 thorpej bestovh = 0;
602 1.1 thorpej beststart = 0;
603 1.1 thorpej bestlast = NULL;
604 1.1 thorpej
605 1.1 thorpej /*
606 1.1 thorpej * For N allocated regions, we must make (N + 1)
607 1.1 thorpej * checks for unallocated space. The first chunk we
608 1.1 thorpej * check is the area from the beginning of the subregion
609 1.9 thorpej * to the first allocated region after that point.
610 1.1 thorpej */
611 1.19 pk newstart = EXTENT_ALIGN(substart, alignment, skew);
612 1.1 thorpej if (newstart < ex->ex_start) {
613 1.6 thorpej #ifdef DIAGNOSTIC
614 1.5 christos printf(
615 1.1 thorpej "extent_alloc_subregion: extent `%s' (0x%lx - 0x%lx), alignment 0x%lx\n",
616 1.1 thorpej ex->ex_name, ex->ex_start, ex->ex_end, alignment);
617 1.12 thorpej simple_unlock(&ex->ex_slock);
618 1.1 thorpej panic("extent_alloc_subregion: overflow after alignment");
619 1.6 thorpej #else
620 1.6 thorpej extent_free_region_descriptor(ex, myrp);
621 1.12 thorpej simple_unlock(&ex->ex_slock);
622 1.6 thorpej return (EINVAL);
623 1.6 thorpej #endif
624 1.1 thorpej }
625 1.1 thorpej
626 1.9 thorpej /*
627 1.9 thorpej * Find the first allocated region that begins on or after
628 1.9 thorpej * the subregion start, advancing the "last" pointer along
629 1.9 thorpej * the way.
630 1.9 thorpej */
631 1.1 thorpej for (rp = ex->ex_regions.lh_first; rp != NULL;
632 1.18 pk rp = rp->er_link.le_next) {
633 1.9 thorpej if (rp->er_start >= newstart)
634 1.9 thorpej break;
635 1.9 thorpej last = rp;
636 1.9 thorpej }
637 1.17 pk
638 1.17 pk /*
639 1.25 drochner * Relocate the start of our candidate region to the end of
640 1.25 drochner * the last allocated region (if there was one overlapping
641 1.25 drochner * our subrange).
642 1.17 pk */
643 1.25 drochner if (last != NULL && last->er_end >= newstart)
644 1.19 pk newstart = EXTENT_ALIGN((last->er_end + 1), alignment, skew);
645 1.9 thorpej
646 1.9 thorpej for (; rp != NULL; rp = rp->er_link.le_next) {
647 1.1 thorpej /*
648 1.1 thorpej * Check the chunk before "rp". Note that our
649 1.1 thorpej * comparison is safe from overflow conditions.
650 1.1 thorpej */
651 1.1 thorpej if (LE_OV(newstart, size, rp->er_start)) {
652 1.1 thorpej /*
653 1.1 thorpej * Do a boundary check, if necessary. Note
654 1.1 thorpej * that a region may *begin* on the boundary,
655 1.1 thorpej * but it must end before the boundary.
656 1.1 thorpej */
657 1.1 thorpej if (boundary) {
658 1.1 thorpej newend = newstart + (size - 1);
659 1.1 thorpej
660 1.1 thorpej /*
661 1.23 mycroft * Calculate the next boundary after the start
662 1.23 mycroft * of this region.
663 1.23 mycroft */
664 1.24 mycroft dontcross = EXTENT_ALIGN(newstart+1, boundary,
665 1.23 mycroft (flags & EX_BOUNDZERO) ? 0 : ex->ex_start)
666 1.23 mycroft - 1;
667 1.23 mycroft
668 1.24 mycroft #if 0
669 1.33 pk printf("newstart=%lx newend=%lx ex_start=%lx ex_end=%lx boundary=%lx dontcross=%lx\n",
670 1.24 mycroft newstart, newend, ex->ex_start, ex->ex_end,
671 1.24 mycroft boundary, dontcross);
672 1.24 mycroft #endif
673 1.24 mycroft
674 1.32 mrg /* Check for overflow */
675 1.32 mrg if (dontcross < ex->ex_start)
676 1.32 mrg dontcross = ex->ex_end;
677 1.32 mrg else if (newend > dontcross) {
678 1.24 mycroft /*
679 1.24 mycroft * Candidate region crosses boundary.
680 1.24 mycroft * Throw away the leading part and see
681 1.24 mycroft * if we still fit.
682 1.24 mycroft */
683 1.24 mycroft newstart = dontcross + 1;
684 1.24 mycroft newend = newstart + (size - 1);
685 1.24 mycroft dontcross += boundary;
686 1.24 mycroft if (!LE_OV(newstart, size, rp->er_start))
687 1.24 mycroft continue;
688 1.24 mycroft }
689 1.24 mycroft
690 1.23 mycroft /*
691 1.23 mycroft * If we run past the end of
692 1.23 mycroft * the extent or the boundary
693 1.23 mycroft * overflows, then the request
694 1.23 mycroft * can't fit.
695 1.1 thorpej */
696 1.36 mrg if (newstart + size - 1 > ex->ex_end ||
697 1.23 mycroft dontcross < newstart)
698 1.23 mycroft goto fail;
699 1.1 thorpej }
700 1.1 thorpej
701 1.1 thorpej /*
702 1.1 thorpej * We would fit into this space. Calculate
703 1.1 thorpej * the overhead (wasted space). If we exactly
704 1.1 thorpej * fit, or we're taking the first fit, insert
705 1.1 thorpej * ourselves into the region list.
706 1.1 thorpej */
707 1.1 thorpej ovh = rp->er_start - newstart - size;
708 1.1 thorpej if ((flags & EX_FAST) || (ovh == 0))
709 1.1 thorpej goto found;
710 1.1 thorpej
711 1.1 thorpej /*
712 1.1 thorpej * Don't exactly fit, but check to see
713 1.1 thorpej * if we're better than any current choice.
714 1.1 thorpej */
715 1.1 thorpej if ((bestovh == 0) || (ovh < bestovh)) {
716 1.1 thorpej bestovh = ovh;
717 1.1 thorpej beststart = newstart;
718 1.1 thorpej bestlast = last;
719 1.1 thorpej }
720 1.1 thorpej }
721 1.1 thorpej
722 1.1 thorpej /*
723 1.1 thorpej * Skip past the current region and check again.
724 1.1 thorpej */
725 1.19 pk newstart = EXTENT_ALIGN((rp->er_end + 1), alignment, skew);
726 1.1 thorpej if (newstart < rp->er_end) {
727 1.1 thorpej /*
728 1.1 thorpej * Overflow condition. Don't error out, since
729 1.1 thorpej * we might have a chunk of space that we can
730 1.1 thorpej * use.
731 1.1 thorpej */
732 1.1 thorpej goto fail;
733 1.1 thorpej }
734 1.1 thorpej
735 1.1 thorpej last = rp;
736 1.1 thorpej }
737 1.1 thorpej
738 1.1 thorpej /*
739 1.1 thorpej * The final check is from the current starting point to the
740 1.1 thorpej * end of the subregion. If there were no allocated regions,
741 1.1 thorpej * "newstart" is set to the beginning of the subregion, or
742 1.1 thorpej * just past the end of the last allocated region, adjusted
743 1.1 thorpej * for alignment in either case.
744 1.1 thorpej */
745 1.1 thorpej if (LE_OV(newstart, (size - 1), subend)) {
746 1.24 mycroft /*
747 1.24 mycroft * Do a boundary check, if necessary. Note
748 1.24 mycroft * that a region may *begin* on the boundary,
749 1.24 mycroft * but it must end before the boundary.
750 1.24 mycroft */
751 1.24 mycroft if (boundary) {
752 1.24 mycroft newend = newstart + (size - 1);
753 1.24 mycroft
754 1.24 mycroft /*
755 1.24 mycroft * Calculate the next boundary after the start
756 1.24 mycroft * of this region.
757 1.24 mycroft */
758 1.24 mycroft dontcross = EXTENT_ALIGN(newstart+1, boundary,
759 1.24 mycroft (flags & EX_BOUNDZERO) ? 0 : ex->ex_start)
760 1.24 mycroft - 1;
761 1.24 mycroft
762 1.24 mycroft #if 0
763 1.33 pk printf("newstart=%lx newend=%lx ex_start=%lx ex_end=%lx boundary=%lx dontcross=%lx\n",
764 1.24 mycroft newstart, newend, ex->ex_start, ex->ex_end,
765 1.24 mycroft boundary, dontcross);
766 1.24 mycroft #endif
767 1.24 mycroft
768 1.32 mrg /* Check for overflow */
769 1.32 mrg if (dontcross < ex->ex_start)
770 1.32 mrg dontcross = ex->ex_end;
771 1.32 mrg else if (newend > dontcross) {
772 1.24 mycroft /*
773 1.24 mycroft * Candidate region crosses boundary.
774 1.24 mycroft * Throw away the leading part and see
775 1.24 mycroft * if we still fit.
776 1.24 mycroft */
777 1.24 mycroft newstart = dontcross + 1;
778 1.24 mycroft newend = newstart + (size - 1);
779 1.24 mycroft dontcross += boundary;
780 1.24 mycroft if (!LE_OV(newstart, (size - 1), subend))
781 1.24 mycroft goto fail;
782 1.24 mycroft }
783 1.24 mycroft
784 1.24 mycroft /*
785 1.24 mycroft * If we run past the end of
786 1.24 mycroft * the extent or the boundary
787 1.24 mycroft * overflows, then the request
788 1.24 mycroft * can't fit.
789 1.24 mycroft */
790 1.36 mrg if (newstart + size - 1 > ex->ex_end ||
791 1.24 mycroft dontcross < newstart)
792 1.24 mycroft goto fail;
793 1.24 mycroft }
794 1.24 mycroft
795 1.1 thorpej /*
796 1.1 thorpej * We would fit into this space. Calculate
797 1.1 thorpej * the overhead (wasted space). If we exactly
798 1.1 thorpej * fit, or we're taking the first fit, insert
799 1.1 thorpej * ourselves into the region list.
800 1.1 thorpej */
801 1.1 thorpej ovh = ex->ex_end - newstart - (size - 1);
802 1.1 thorpej if ((flags & EX_FAST) || (ovh == 0))
803 1.1 thorpej goto found;
804 1.1 thorpej
805 1.1 thorpej /*
806 1.1 thorpej * Don't exactly fit, but check to see
807 1.1 thorpej * if we're better than any current choice.
808 1.1 thorpej */
809 1.1 thorpej if ((bestovh == 0) || (ovh < bestovh)) {
810 1.1 thorpej bestovh = ovh;
811 1.1 thorpej beststart = newstart;
812 1.1 thorpej bestlast = last;
813 1.1 thorpej }
814 1.1 thorpej }
815 1.1 thorpej
816 1.1 thorpej fail:
817 1.1 thorpej /*
818 1.1 thorpej * One of the following two conditions have
819 1.1 thorpej * occurred:
820 1.1 thorpej *
821 1.1 thorpej * There is no chunk large enough to hold the request.
822 1.1 thorpej *
823 1.1 thorpej * If EX_FAST was not specified, there is not an
824 1.1 thorpej * exact match for the request.
825 1.1 thorpej *
826 1.1 thorpej * Note that if we reach this point and EX_FAST is
827 1.1 thorpej * set, then we know there is no space in the extent for
828 1.1 thorpej * the request.
829 1.1 thorpej */
830 1.1 thorpej if (((flags & EX_FAST) == 0) && (bestovh != 0)) {
831 1.1 thorpej /*
832 1.1 thorpej * We have a match that's "good enough".
833 1.1 thorpej */
834 1.1 thorpej newstart = beststart;
835 1.1 thorpej last = bestlast;
836 1.1 thorpej goto found;
837 1.1 thorpej }
838 1.1 thorpej
839 1.1 thorpej /*
840 1.1 thorpej * No space currently available. Wait for it to free up,
841 1.1 thorpej * if possible.
842 1.1 thorpej */
843 1.6 thorpej if (flags & EX_WAITSPACE) {
844 1.1 thorpej ex->ex_flags |= EXF_WANTED;
845 1.37 sommerfe error = ltsleep(ex,
846 1.37 sommerfe PNORELOCK | PRIBIO | ((flags & EX_CATCH) ? PCATCH : 0),
847 1.37 sommerfe "extnt", 0, &ex->ex_slock);
848 1.1 thorpej if (error)
849 1.1 thorpej return (error);
850 1.1 thorpej goto alloc_start;
851 1.1 thorpej }
852 1.1 thorpej
853 1.6 thorpej extent_free_region_descriptor(ex, myrp);
854 1.12 thorpej simple_unlock(&ex->ex_slock);
855 1.1 thorpej return (EAGAIN);
856 1.1 thorpej
857 1.1 thorpej found:
858 1.1 thorpej /*
859 1.1 thorpej * Insert ourselves into the region list.
860 1.1 thorpej */
861 1.6 thorpej extent_insert_and_optimize(ex, newstart, size, flags, last, myrp);
862 1.12 thorpej simple_unlock(&ex->ex_slock);
863 1.6 thorpej *result = newstart;
864 1.6 thorpej return (0);
865 1.1 thorpej }
866 1.1 thorpej
867 1.1 thorpej int
868 1.1 thorpej extent_free(ex, start, size, flags)
869 1.1 thorpej struct extent *ex;
870 1.1 thorpej u_long start, size;
871 1.1 thorpej int flags;
872 1.1 thorpej {
873 1.12 thorpej struct extent_region *rp, *nrp = NULL;
874 1.1 thorpej u_long end = start + (size - 1);
875 1.12 thorpej int exflags;
876 1.1 thorpej
877 1.6 thorpej #ifdef DIAGNOSTIC
878 1.12 thorpej /*
879 1.12 thorpej * Check arguments.
880 1.12 thorpej *
881 1.12 thorpej * We don't lock to check these, because these values
882 1.12 thorpej * are never modified, and if another thread deletes the
883 1.12 thorpej * extent, we're screwed anyway.
884 1.12 thorpej */
885 1.1 thorpej if (ex == NULL)
886 1.1 thorpej panic("extent_free: NULL extent");
887 1.1 thorpej if ((start < ex->ex_start) || (start > ex->ex_end)) {
888 1.1 thorpej extent_print(ex);
889 1.5 christos printf("extent_free: extent `%s', start 0x%lx, size 0x%lx\n",
890 1.1 thorpej ex->ex_name, start, size);
891 1.1 thorpej panic("extent_free: extent `%s', region not within extent",
892 1.1 thorpej ex->ex_name);
893 1.1 thorpej }
894 1.1 thorpej /* Check for an overflow. */
895 1.1 thorpej if (end < start) {
896 1.1 thorpej extent_print(ex);
897 1.5 christos printf("extent_free: extent `%s', start 0x%lx, size 0x%lx\n",
898 1.1 thorpej ex->ex_name, start, size);
899 1.1 thorpej panic("extent_free: overflow");
900 1.1 thorpej }
901 1.6 thorpej #endif
902 1.1 thorpej
903 1.1 thorpej /*
904 1.12 thorpej * If we're allowing coalescing, we must allocate a region
905 1.12 thorpej * descriptor now, since it might block.
906 1.12 thorpej *
907 1.12 thorpej * XXX Make a static, create-time flags word, so we don't
908 1.12 thorpej * XXX have to lock to read it!
909 1.12 thorpej */
910 1.12 thorpej simple_lock(&ex->ex_slock);
911 1.12 thorpej exflags = ex->ex_flags;
912 1.12 thorpej simple_unlock(&ex->ex_slock);
913 1.14 pk
914 1.12 thorpej if ((exflags & EXF_NOCOALESCE) == 0) {
915 1.12 thorpej /* Allocate a region descriptor. */
916 1.12 thorpej nrp = extent_alloc_region_descriptor(ex, flags);
917 1.12 thorpej if (nrp == NULL)
918 1.12 thorpej return (ENOMEM);
919 1.12 thorpej }
920 1.12 thorpej
921 1.12 thorpej simple_lock(&ex->ex_slock);
922 1.12 thorpej
923 1.12 thorpej /*
924 1.1 thorpej * Find region and deallocate. Several possibilities:
925 1.1 thorpej *
926 1.1 thorpej * 1. (start == er_start) && (end == er_end):
927 1.1 thorpej * Free descriptor.
928 1.1 thorpej *
929 1.1 thorpej * 2. (start == er_start) && (end < er_end):
930 1.1 thorpej * Adjust er_start.
931 1.1 thorpej *
932 1.1 thorpej * 3. (start > er_start) && (end == er_end):
933 1.1 thorpej * Adjust er_end.
934 1.1 thorpej *
935 1.1 thorpej * 4. (start > er_start) && (end < er_end):
936 1.1 thorpej * Fragment region. Requires descriptor alloc.
937 1.1 thorpej *
938 1.6 thorpej * Cases 2, 3, and 4 require that the EXF_NOCOALESCE flag
939 1.1 thorpej * is not set.
940 1.1 thorpej */
941 1.1 thorpej for (rp = ex->ex_regions.lh_first; rp != NULL;
942 1.1 thorpej rp = rp->er_link.le_next) {
943 1.1 thorpej /*
944 1.1 thorpej * Save ourselves some comparisons; does the current
945 1.1 thorpej * region end before chunk to be freed begins? If so,
946 1.1 thorpej * then we haven't found the appropriate region descriptor.
947 1.1 thorpej */
948 1.1 thorpej if (rp->er_end < start)
949 1.1 thorpej continue;
950 1.1 thorpej
951 1.1 thorpej /*
952 1.1 thorpej * Save ourselves some traversal; does the current
953 1.1 thorpej * region begin after the chunk to be freed ends? If so,
954 1.1 thorpej * then we've already passed any possible region descriptors
955 1.1 thorpej * that might have contained the chunk to be freed.
956 1.1 thorpej */
957 1.1 thorpej if (rp->er_start > end)
958 1.1 thorpej break;
959 1.1 thorpej
960 1.1 thorpej /* Case 1. */
961 1.1 thorpej if ((start == rp->er_start) && (end == rp->er_end)) {
962 1.1 thorpej LIST_REMOVE(rp, er_link);
963 1.1 thorpej extent_free_region_descriptor(ex, rp);
964 1.1 thorpej goto done;
965 1.1 thorpej }
966 1.1 thorpej
967 1.1 thorpej /*
968 1.6 thorpej * The following cases all require that EXF_NOCOALESCE
969 1.1 thorpej * is not set.
970 1.1 thorpej */
971 1.6 thorpej if (ex->ex_flags & EXF_NOCOALESCE)
972 1.1 thorpej continue;
973 1.1 thorpej
974 1.1 thorpej /* Case 2. */
975 1.1 thorpej if ((start == rp->er_start) && (end < rp->er_end)) {
976 1.1 thorpej rp->er_start = (end + 1);
977 1.1 thorpej goto done;
978 1.1 thorpej }
979 1.1 thorpej
980 1.1 thorpej /* Case 3. */
981 1.1 thorpej if ((start > rp->er_start) && (end == rp->er_end)) {
982 1.1 thorpej rp->er_end = (start - 1);
983 1.1 thorpej goto done;
984 1.1 thorpej }
985 1.1 thorpej
986 1.1 thorpej /* Case 4. */
987 1.1 thorpej if ((start > rp->er_start) && (end < rp->er_end)) {
988 1.1 thorpej /* Fill in new descriptor. */
989 1.1 thorpej nrp->er_start = end + 1;
990 1.1 thorpej nrp->er_end = rp->er_end;
991 1.1 thorpej
992 1.1 thorpej /* Adjust current descriptor. */
993 1.1 thorpej rp->er_end = start - 1;
994 1.1 thorpej
995 1.13 pk /* Insert new descriptor after current. */
996 1.1 thorpej LIST_INSERT_AFTER(rp, nrp, er_link);
997 1.13 pk
998 1.13 pk /* We used the new descriptor, so don't free it below */
999 1.13 pk nrp = NULL;
1000 1.1 thorpej goto done;
1001 1.1 thorpej }
1002 1.1 thorpej }
1003 1.1 thorpej
1004 1.1 thorpej /* Region not found, or request otherwise invalid. */
1005 1.12 thorpej simple_unlock(&ex->ex_slock);
1006 1.1 thorpej extent_print(ex);
1007 1.5 christos printf("extent_free: start 0x%lx, end 0x%lx\n", start, end);
1008 1.1 thorpej panic("extent_free: region not found");
1009 1.1 thorpej
1010 1.1 thorpej done:
1011 1.13 pk if (nrp != NULL)
1012 1.13 pk extent_free_region_descriptor(ex, nrp);
1013 1.1 thorpej if (ex->ex_flags & EXF_WANTED) {
1014 1.1 thorpej ex->ex_flags &= ~EXF_WANTED;
1015 1.1 thorpej wakeup(ex);
1016 1.1 thorpej }
1017 1.12 thorpej simple_unlock(&ex->ex_slock);
1018 1.1 thorpej return (0);
1019 1.1 thorpej }
1020 1.1 thorpej
1021 1.12 thorpej /*
1022 1.12 thorpej * Allocate an extent region descriptor. EXTENT MUST NOT BE LOCKED,
1023 1.12 thorpej * AS THIS FUNCTION MAY BLOCK! We will handle any locking we may need.
1024 1.12 thorpej */
1025 1.1 thorpej static struct extent_region *
1026 1.1 thorpej extent_alloc_region_descriptor(ex, flags)
1027 1.1 thorpej struct extent *ex;
1028 1.1 thorpej int flags;
1029 1.1 thorpej {
1030 1.1 thorpej struct extent_region *rp;
1031 1.12 thorpej int exflags;
1032 1.26 pk int s;
1033 1.29 thorpej
1034 1.29 thorpej /*
1035 1.29 thorpej * If the kernel memory allocator is not yet running, we can't
1036 1.29 thorpej * use it (obviously).
1037 1.29 thorpej */
1038 1.29 thorpej if (KMEM_IS_RUNNING == 0)
1039 1.29 thorpej flags &= ~EX_MALLOCOK;
1040 1.12 thorpej
1041 1.12 thorpej /*
1042 1.12 thorpej * XXX Make a static, create-time flags word, so we don't
1043 1.12 thorpej * XXX have to lock to read it!
1044 1.12 thorpej */
1045 1.12 thorpej simple_lock(&ex->ex_slock);
1046 1.12 thorpej exflags = ex->ex_flags;
1047 1.12 thorpej simple_unlock(&ex->ex_slock);
1048 1.1 thorpej
1049 1.12 thorpej if (exflags & EXF_FIXED) {
1050 1.1 thorpej struct extent_fixed *fex = (struct extent_fixed *)ex;
1051 1.1 thorpej
1052 1.12 thorpej for (;;) {
1053 1.12 thorpej simple_lock(&ex->ex_slock);
1054 1.12 thorpej if ((rp = fex->fex_freelist.lh_first) != NULL) {
1055 1.12 thorpej /*
1056 1.12 thorpej * Don't muck with flags after pulling it off
1057 1.12 thorpej * the freelist; it may have been dynamically
1058 1.12 thorpej * allocated, and kindly given to us. We
1059 1.12 thorpej * need to remember that information.
1060 1.12 thorpej */
1061 1.12 thorpej LIST_REMOVE(rp, er_link);
1062 1.12 thorpej simple_unlock(&ex->ex_slock);
1063 1.12 thorpej return (rp);
1064 1.12 thorpej }
1065 1.12 thorpej if (flags & EX_MALLOCOK) {
1066 1.12 thorpej simple_unlock(&ex->ex_slock);
1067 1.1 thorpej goto alloc;
1068 1.12 thorpej }
1069 1.12 thorpej if ((flags & EX_WAITOK) == 0) {
1070 1.12 thorpej simple_unlock(&ex->ex_slock);
1071 1.1 thorpej return (NULL);
1072 1.12 thorpej }
1073 1.1 thorpej ex->ex_flags |= EXF_FLWANTED;
1074 1.37 sommerfe if (ltsleep(&fex->fex_freelist,
1075 1.37 sommerfe PNORELOCK| PRIBIO | ((flags & EX_CATCH) ? PCATCH : 0),
1076 1.37 sommerfe "extnt", 0, &ex->ex_slock))
1077 1.1 thorpej return (NULL);
1078 1.1 thorpej }
1079 1.1 thorpej }
1080 1.1 thorpej
1081 1.1 thorpej alloc:
1082 1.26 pk s = splhigh();
1083 1.26 pk if (expool == NULL && !expool_create()) {
1084 1.26 pk splx(s);
1085 1.15 sommerfe return (NULL);
1086 1.26 pk }
1087 1.15 sommerfe
1088 1.14 pk rp = pool_get(expool, (flags & EX_WAITOK) ? PR_WAITOK : 0);
1089 1.26 pk splx(s);
1090 1.1 thorpej
1091 1.7 cgd if (rp != NULL)
1092 1.7 cgd rp->er_flags = ER_ALLOC;
1093 1.1 thorpej
1094 1.1 thorpej return (rp);
1095 1.1 thorpej }
1096 1.1 thorpej
1097 1.12 thorpej /*
1098 1.12 thorpej * Free an extent region descriptor. EXTENT _MUST_ BE LOCKED! This
1099 1.12 thorpej * is safe as we do not block here.
1100 1.12 thorpej */
1101 1.1 thorpej static void
1102 1.1 thorpej extent_free_region_descriptor(ex, rp)
1103 1.1 thorpej struct extent *ex;
1104 1.1 thorpej struct extent_region *rp;
1105 1.1 thorpej {
1106 1.26 pk int s;
1107 1.1 thorpej
1108 1.6 thorpej if (ex->ex_flags & EXF_FIXED) {
1109 1.1 thorpej struct extent_fixed *fex = (struct extent_fixed *)ex;
1110 1.1 thorpej
1111 1.6 thorpej /*
1112 1.6 thorpej * If someone's waiting for a region descriptor,
1113 1.6 thorpej * be nice and give them this one, rather than
1114 1.6 thorpej * just free'ing it back to the system.
1115 1.6 thorpej */
1116 1.6 thorpej if (rp->er_flags & ER_ALLOC) {
1117 1.6 thorpej if (ex->ex_flags & EXF_FLWANTED) {
1118 1.6 thorpej /* Clear all but ER_ALLOC flag. */
1119 1.6 thorpej rp->er_flags = ER_ALLOC;
1120 1.6 thorpej LIST_INSERT_HEAD(&fex->fex_freelist, rp,
1121 1.6 thorpej er_link);
1122 1.6 thorpej goto wake_em_up;
1123 1.6 thorpej } else {
1124 1.26 pk s = splhigh();
1125 1.14 pk pool_put(expool, rp);
1126 1.26 pk splx(s);
1127 1.6 thorpej }
1128 1.6 thorpej } else {
1129 1.6 thorpej /* Clear all flags. */
1130 1.6 thorpej rp->er_flags = 0;
1131 1.6 thorpej LIST_INSERT_HEAD(&fex->fex_freelist, rp, er_link);
1132 1.6 thorpej }
1133 1.6 thorpej
1134 1.1 thorpej if (ex->ex_flags & EXF_FLWANTED) {
1135 1.6 thorpej wake_em_up:
1136 1.1 thorpej ex->ex_flags &= ~EXF_FLWANTED;
1137 1.1 thorpej wakeup(&fex->fex_freelist);
1138 1.1 thorpej }
1139 1.6 thorpej return;
1140 1.6 thorpej }
1141 1.6 thorpej
1142 1.6 thorpej /*
1143 1.6 thorpej * We know it's dynamically allocated if we get here.
1144 1.6 thorpej */
1145 1.26 pk s = splhigh();
1146 1.14 pk pool_put(expool, rp);
1147 1.26 pk splx(s);
1148 1.1 thorpej }
1149 1.1 thorpej
1150 1.1 thorpej void
1151 1.1 thorpej extent_print(ex)
1152 1.1 thorpej struct extent *ex;
1153 1.1 thorpej {
1154 1.1 thorpej struct extent_region *rp;
1155 1.1 thorpej
1156 1.1 thorpej if (ex == NULL)
1157 1.1 thorpej panic("extent_print: NULL extent");
1158 1.1 thorpej
1159 1.12 thorpej simple_lock(&ex->ex_slock);
1160 1.12 thorpej
1161 1.5 christos printf("extent `%s' (0x%lx - 0x%lx), flags = 0x%x\n", ex->ex_name,
1162 1.1 thorpej ex->ex_start, ex->ex_end, ex->ex_flags);
1163 1.1 thorpej
1164 1.1 thorpej for (rp = ex->ex_regions.lh_first; rp != NULL;
1165 1.1 thorpej rp = rp->er_link.le_next)
1166 1.5 christos printf(" 0x%lx - 0x%lx\n", rp->er_start, rp->er_end);
1167 1.12 thorpej
1168 1.12 thorpej simple_unlock(&ex->ex_slock);
1169 1.1 thorpej }
1170