#ifdef _KERNEL
#include <sys/param.h>
#include <sys/extent.h>
#include <sys/malloc.h>
#include <sys/systm.h>
#include <sys/queue.h>
#include <sys/pool.h>
#include <ddb/db_output.h>
#else
#include <sys/param.h>
#include <sys/extent.h>
#include <sys/queue.h>
#include <errno.h>
#include <err.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#define malloc(s, t, flags) malloc(s)
#define free(p, t, s) free(p)
#define tsleep_nsec(c, p, s, t) (EWOULDBLOCK)
#define wakeup(chan) ((void)0)
struct pool {
size_t pr_size;
};
#define pool_init(a, b, c, d, e, f, g) do { (a)->pr_size = (b); } while (0)
#define pool_get(pp, flags) malloc((pp)->pr_size, 0, 0)
#define pool_put(pp, rp) free((rp), 0, 0)
#define panic(...) do { warnx(__VA_ARGS__); abort(); } while (0)
#endif
#if defined(DIAGNOSTIC) || defined(DDB)
void extent_print1(struct extent *, int (*)(const char *, ...)
__attribute__((__format__(__kprintf__,1,2))));
#endif
static void extent_insert_and_optimize(struct extent *, u_long, u_long,
struct extent_region *, struct extent_region *);
static struct extent_region *extent_alloc_region_descriptor(struct extent *, int);
static void extent_free_region_descriptor(struct extent *,
struct extent_region *);
int extent_do_alloc(struct extent *, u_long, u_long, u_long, u_long,
u_long, u_long, int, struct extent_region *, u_long *);
static __inline__ u_long
extent_align(u_long start, u_long align, u_long skew)
{
return ((((start - skew) + (align - 1)) & (-align)) + skew);
}
#if defined(DIAGNOSTIC) || defined(DDB)
static LIST_HEAD(listhead, extent) ext_list;
static void extent_register(struct extent *);
static void
extent_register(struct extent *ex)
{
#ifdef DIAGNOSTIC
struct extent *ep;
#endif
static int initialized;
if (!initialized){
LIST_INIT(&ext_list);
initialized = 1;
}
#ifdef DIAGNOSTIC
LIST_FOREACH(ep, &ext_list, ex_link) {
if (ep == ex)
panic("%s: already registered", __func__);
}
#endif
LIST_INSERT_HEAD(&ext_list, ex, ex_link);
}
#endif
struct pool ex_region_pl;
static void
extent_pool_init(void)
{
static int inited;
if (!inited) {
pool_init(&ex_region_pl, sizeof(struct extent_region), 0,
IPL_VM, 0, "extentpl", NULL);
inited = 1;
}
}
#ifdef DDB
void
extent_print_all(void)
{
struct extent *ep;
LIST_FOREACH(ep, &ext_list, ex_link) {
extent_print1(ep, db_printf);
}
}
#endif
struct extent *
extent_create(char *name, u_long start, u_long end, int mtype, caddr_t storage,
size_t storagesize, int flags)
{
struct extent *ex;
caddr_t cp = storage;
size_t sz = storagesize;
struct extent_region *rp;
int fixed_extent = (storage != NULL);
#ifdef DIAGNOSTIC
if (name == NULL)
panic("%s: name == NULL", __func__);
if (end < start) {
printf("%s: extent `%s', start 0x%lx, end 0x%lx\n",
__func__, name, start, end);
panic("%s: end < start", __func__);
}
if (fixed_extent && (storagesize < sizeof(struct extent_fixed)))
panic("%s: fixed extent, bad storagesize 0x%lx",
__func__, (u_long)storagesize);
if (fixed_extent == 0 && (storagesize != 0 || storage != NULL))
panic("%s: storage provided for non-fixed", __func__);
#endif
extent_pool_init();
if (fixed_extent) {
struct extent_fixed *fex;
memset(storage, 0, storagesize);
fex = (struct extent_fixed *)cp;
ex = (struct extent *)fex;
cp += ALIGN(sizeof(struct extent_fixed));
sz -= ALIGN(sizeof(struct extent_fixed));
fex->fex_storage = storage;
fex->fex_storagesize = storagesize;
LIST_INIT(&fex->fex_freelist);
while (sz >= ALIGN(sizeof(struct extent_region))) {
rp = (struct extent_region *)cp;
cp += ALIGN(sizeof(struct extent_region));
sz -= ALIGN(sizeof(struct extent_region));
LIST_INSERT_HEAD(&fex->fex_freelist, rp, er_link);
}
} else {
ex = (struct extent *)malloc(sizeof(struct extent),
mtype, (flags & EX_WAITOK) ? M_WAITOK : M_NOWAIT);
if (ex == NULL)
return (NULL);
}
LIST_INIT(&ex->ex_regions);
ex->ex_name = name;
ex->ex_start = start;
ex->ex_end = end;
ex->ex_mtype = mtype;
ex->ex_flags = 0;
if (fixed_extent)
ex->ex_flags |= EXF_FIXED;
if (flags & EX_NOCOALESCE)
ex->ex_flags |= EXF_NOCOALESCE;
if (flags & EX_FILLED) {
rp = extent_alloc_region_descriptor(ex, flags);
if (rp == NULL) {
if (!fixed_extent)
free(ex, mtype, sizeof(struct extent));
return (NULL);
}
rp->er_start = start;
rp->er_end = end;
LIST_INSERT_HEAD(&ex->ex_regions, rp, er_link);
}
#if defined(DIAGNOSTIC) || defined(DDB)
extent_register(ex);
#endif
return (ex);
}
void
extent_destroy(struct extent *ex)
{
struct extent_region *rp, *orp;
#ifdef DIAGNOSTIC
if (ex == NULL)
panic("%s: NULL extent", __func__);
#endif
for (rp = LIST_FIRST(&ex->ex_regions); rp != NULL; ) {
orp = rp;
rp = LIST_NEXT(rp, er_link);
LIST_REMOVE(orp, er_link);
extent_free_region_descriptor(ex, orp);
}
#if defined(DIAGNOSTIC) || defined(DDB)
LIST_REMOVE(ex, ex_link);
#endif
if ((ex->ex_flags & EXF_FIXED) == 0)
free(ex, ex->ex_mtype, sizeof(*ex));
}
static void
extent_insert_and_optimize(struct extent *ex, u_long start, u_long size,
struct extent_region *after, struct extent_region *rp)
{
struct extent_region *nextr;
int appended = 0;
if (after == NULL) {
if (((ex->ex_flags & EXF_NOCOALESCE) == 0) &&
!LIST_EMPTY(&ex->ex_regions) &&
((start + size) == LIST_FIRST(&ex->ex_regions)->er_start)) {
LIST_FIRST(&ex->ex_regions)->er_start = start;
extent_free_region_descriptor(ex, rp);
return;
}
rp->er_start = start;
rp->er_end = start + (size - 1);
LIST_INSERT_HEAD(&ex->ex_regions, rp, er_link);
return;
}
if (ex->ex_flags & EXF_NOCOALESCE)
goto cant_coalesce;
if ((after->er_end + 1) == start) {
after->er_end = start + (size - 1);
appended = 1;
}
if (LIST_NEXT(after, er_link) != NULL &&
((start + size) == LIST_NEXT(after, er_link)->er_start)) {
if (appended) {
after->er_end = LIST_NEXT(after, er_link)->er_end;
nextr = LIST_NEXT(after, er_link);
LIST_REMOVE(nextr, er_link);
extent_free_region_descriptor(ex, nextr);
} else {
LIST_NEXT(after, er_link)->er_start = start;
}
extent_free_region_descriptor(ex, rp);
return;
}
if (appended) {
extent_free_region_descriptor(ex, rp);
return;
}
cant_coalesce:
rp->er_start = start;
rp->er_end = start + (size - 1);
LIST_INSERT_AFTER(after, rp, er_link);
}
int
extent_do_alloc_region(struct extent *ex, u_long start, u_long size,
int flags, struct extent_region *myrp)
{
struct extent_region *rp, *last;
u_long end = start + (size - 1);
int error;
#ifdef DIAGNOSTIC
if (ex == NULL)
panic("%s: NULL extent", __func__);
if (size < 1) {
printf("%s: extent `%s', size 0x%lx\n",
__func__, ex->ex_name, size);
panic("%s: bad size", __func__);
}
if (end < start) {
printf("%s: extent `%s', start 0x%lx, size 0x%lx\n",
__func__, ex->ex_name, start, size);
panic("%s: overflow", __func__);
}
if ((flags & EX_CONFLICTOK) && (flags & EX_WAITSPACE))
panic("%s: EX_CONFLICTOK and EX_WAITSPACE "
"are mutually exclusive", __func__);
#endif
if ((start < ex->ex_start) || (end > ex->ex_end)) {
#ifdef DIAGNOSTIC
printf("%s: extent `%s' (0x%lx - 0x%lx)\n",
__func__, ex->ex_name, ex->ex_start, ex->ex_end);
printf("%s: start 0x%lx, end 0x%lx\n",
__func__, start, end);
panic("%s: region lies outside extent", __func__);
#else
extent_free_region_descriptor(ex, myrp);
return (EINVAL);
#endif
}
alloc_start:
last = NULL;
LIST_FOREACH(rp, &ex->ex_regions, er_link) {
if (rp->er_start > end) {
break;
}
if (rp->er_end >= start) {
if (flags & EX_WAITSPACE) {
ex->ex_flags |= EXF_WANTED;
error = tsleep_nsec(ex,
PRIBIO | ((flags & EX_CATCH) ? PCATCH : 0),
"extnt", INFSLP);
if (error)
return (error);
goto alloc_start;
}
if (flags & EX_CONFLICTOK) {
if (rp->er_start <= start) {
if (rp->er_end < ex->ex_end) {
start = rp->er_end + 1;
size = end - start + 1;
goto alloc_start;
}
} else if (rp->er_end < end) {
LIST_REMOVE(rp, er_link);
extent_free_region_descriptor(ex, rp);
goto alloc_start;
} else if (rp->er_start < end) {
if (rp->er_start > ex->ex_start) {
end = rp->er_start - 1;
size = end - start + 1;
goto alloc_start;
}
}
return (0);
}
extent_free_region_descriptor(ex, myrp);
return (EAGAIN);
}
last = rp;
}
extent_insert_and_optimize(ex, start, size, last, myrp);
return (0);
}
int
extent_alloc_region(struct extent *ex, u_long start, u_long size, int flags)
{
struct extent_region *rp;
rp = extent_alloc_region_descriptor(ex, flags);
if (rp == NULL) {
#ifdef DIAGNOSTIC
printf("%s: can't allocate region descriptor\n", __func__);
#endif
return (ENOMEM);
}
return extent_do_alloc_region(ex, start, size, flags, rp);
}
int
extent_alloc_region_with_descr(struct extent *ex, u_long start,
u_long size, int flags, struct extent_region *rp)
{
#ifdef DIAGNOSTIC
if ((ex->ex_flags & EXF_NOCOALESCE) == 0)
panic("%s: EX_NOCOALESCE not set", __func__);
#endif
rp->er_flags = ER_DISCARD;
return extent_do_alloc_region(ex, start, size, flags, rp);
}
#define LE_OV(x, y, z) ((((x) + (y)) >= (x)) && (((x) + (y)) <= (z)))
int
extent_do_alloc(struct extent *ex, u_long substart, u_long subend,
u_long size, u_long alignment, u_long skew, u_long boundary, int flags,
struct extent_region *myrp, u_long *result)
{
struct extent_region *rp, *last, *bestlast;
u_long newstart, newend, exend, beststart, bestovh, ovh;
u_long dontcross;
int error;
#ifdef DIAGNOSTIC
if (ex == NULL)
panic("%s: NULL extent", __func__);
if (myrp == NULL)
panic("%s: NULL region descriptor", __func__);
if (result == NULL)
panic("%s: NULL result pointer", __func__);
if ((substart < ex->ex_start) || (substart > ex->ex_end) ||
(subend > ex->ex_end) || (subend < ex->ex_start)) {
printf("%s: extent `%s', ex_start 0x%lx, ex_end 0x%lx\n",
__func__, ex->ex_name, ex->ex_start, ex->ex_end);
printf("%s: substart 0x%lx, subend 0x%lx\n",
__func__, substart, subend);
panic("%s: bad subregion", __func__);
}
if ((size < 1) || ((size - 1) > (subend - substart))) {
printf("%s: extent `%s', size 0x%lx\n",
__func__, ex->ex_name, size);
panic("%s: bad size", __func__);
}
if (alignment == 0)
panic("%s: bad alignment", __func__);
if (boundary && (boundary < size)) {
printf("%s: extent `%s', size 0x%lx, boundary 0x%lx\n",
__func__, ex->ex_name, size, boundary);
panic("%s: bad boundary", __func__);
}
#endif
alloc_start:
last = NULL;
bestovh = 0;
beststart = 0;
bestlast = NULL;
exend = ex->ex_end;
newstart = extent_align(substart, alignment, skew);
if (newstart < ex->ex_start) {
#ifdef DIAGNOSTIC
printf("%s: extent `%s' (0x%lx - 0x%lx), alignment 0x%lx\n",
__func__, ex->ex_name, ex->ex_start, ex->ex_end,
alignment);
panic("%s: overflow after alignment", __func__);
#else
extent_free_region_descriptor(ex, myrp);
return (EINVAL);
#endif
}
LIST_FOREACH(rp, &ex->ex_regions, er_link) {
if (rp->er_start >= newstart)
break;
last = rp;
}
if (last != NULL && last->er_end >= newstart)
newstart = extent_align((last->er_end + 1), alignment, skew);
for (; rp != NULL; rp = LIST_NEXT(rp, er_link)) {
if (rp->er_start > subend) {
exend = rp->er_start;
break;
}
if (LE_OV(newstart, size, rp->er_start)) {
if (boundary) {
newend = newstart + (size - 1);
dontcross = extent_align(newstart+1, boundary,
(flags & EX_BOUNDZERO) ? 0 : ex->ex_start)
- 1;
#if 0
printf("newstart=%lx newend=%lx ex_start=%lx ex_end=%lx boundary=%lx dontcross=%lx\n",
newstart, newend, ex->ex_start, ex->ex_end,
boundary, dontcross);
#endif
if (dontcross < ex->ex_start)
dontcross = ex->ex_end;
else if (newend > dontcross) {
newstart = dontcross + 1;
newend = newstart + (size - 1);
dontcross += boundary;
if (!LE_OV(newstart, size, rp->er_start))
goto skip;
}
if (newstart + size - 1 > ex->ex_end ||
dontcross < newstart)
goto fail;
}
ovh = rp->er_start - newstart - size;
if ((flags & EX_FAST) || (ovh == 0))
goto found;
if ((bestovh == 0) || (ovh < bestovh)) {
bestovh = ovh;
beststart = newstart;
bestlast = last;
}
}
skip:
newstart = extent_align((rp->er_end + 1), alignment, skew);
if (newstart < rp->er_end) {
goto fail;
}
last = rp;
}
if (LE_OV(newstart, (size - 1), subend)) {
if (boundary) {
newend = newstart + (size - 1);
dontcross = extent_align(newstart+1, boundary,
(flags & EX_BOUNDZERO) ? 0 : ex->ex_start)
- 1;
#if 0
printf("newstart=%lx newend=%lx ex_start=%lx ex_end=%lx boundary=%lx dontcross=%lx\n",
newstart, newend, ex->ex_start, ex->ex_end,
boundary, dontcross);
#endif
if (dontcross < ex->ex_start)
dontcross = ex->ex_end;
else if (newend > dontcross) {
newstart = dontcross + 1;
newend = newstart + (size - 1);
dontcross += boundary;
if (!LE_OV(newstart, (size - 1), subend))
goto fail;
}
if (newstart + size - 1 > ex->ex_end ||
dontcross < newstart)
goto fail;
}
ovh = exend - newstart - (size - 1);
if ((flags & EX_FAST) || (ovh == 0))
goto found;
if ((bestovh == 0) || (ovh < bestovh)) {
bestovh = ovh;
beststart = newstart;
bestlast = last;
}
}
fail:
if (((flags & EX_FAST) == 0) && (bestovh != 0)) {
newstart = beststart;
last = bestlast;
goto found;
}
if (flags & EX_WAITSPACE) {
ex->ex_flags |= EXF_WANTED;
error = tsleep_nsec(ex,
PRIBIO | ((flags & EX_CATCH) ? PCATCH : 0),
"extnt", INFSLP);
if (error)
return (error);
goto alloc_start;
}
extent_free_region_descriptor(ex, myrp);
return (EAGAIN);
found:
extent_insert_and_optimize(ex, newstart, size, last, myrp);
*result = newstart;
return (0);
}
int
extent_alloc_subregion(struct extent *ex, u_long substart, u_long subend,
u_long size, u_long alignment, u_long skew, u_long boundary, int flags,
u_long *result)
{
struct extent_region *rp;
rp = extent_alloc_region_descriptor(ex, flags);
if (rp == NULL) {
#ifdef DIAGNOSTIC
printf("%s: can't allocate region descriptor\n", __func__);
#endif
return (ENOMEM);
}
return extent_do_alloc(ex, substart, subend, size, alignment, skew,
boundary, flags, rp, result);
}
int
extent_alloc_subregion_with_descr(struct extent *ex, u_long substart,
u_long subend, u_long size, u_long alignment, u_long skew,
u_long boundary, int flags, struct extent_region *rp, u_long *result)
{
#ifdef DIAGNOSTIC
if ((ex->ex_flags & EXF_NOCOALESCE) == 0)
panic("%s: EX_NOCOALESCE not set", __func__);
#endif
rp->er_flags = ER_DISCARD;
return extent_do_alloc(ex, substart, subend, size, alignment, skew,
boundary, flags, rp, result);
}
int
extent_free(struct extent *ex, u_long start, u_long size, int flags)
{
struct extent_region *rp, *nrp = NULL;
struct extent_region *tmp;
u_long end = start + (size - 1);
int exflags;
int error = 0;
#ifdef DIAGNOSTIC
if (ex == NULL)
panic("%s: NULL extent", __func__);
if ((start < ex->ex_start) || (end > ex->ex_end)) {
extent_print(ex);
printf("%s: extent `%s', start 0x%lx, size 0x%lx\n",
__func__, ex->ex_name, start, size);
panic("%s: extent `%s', region not within extent",
__func__, ex->ex_name);
}
if (end < start) {
extent_print(ex);
printf("%s: extent `%s', start 0x%lx, size 0x%lx\n",
__func__, ex->ex_name, start, size);
panic("%s: overflow", __func__);
}
#endif
exflags = ex->ex_flags;
if ((exflags & EXF_NOCOALESCE) == 0) {
nrp = extent_alloc_region_descriptor(ex, flags);
if (nrp == NULL)
return (ENOMEM);
}
LIST_FOREACH_SAFE(rp, &ex->ex_regions, er_link, tmp) {
if (rp->er_end < start)
continue;
if (rp->er_start > end)
break;
if ((start == rp->er_start) && (end == rp->er_end)) {
LIST_REMOVE(rp, er_link);
extent_free_region_descriptor(ex, rp);
goto done;
}
if (ex->ex_flags & EXF_NOCOALESCE)
continue;
if ((start == rp->er_start) && (end < rp->er_end)) {
rp->er_start = (end + 1);
goto done;
}
if ((start > rp->er_start) && (end == rp->er_end)) {
rp->er_end = (start - 1);
goto done;
}
if ((start > rp->er_start) && (end < rp->er_end)) {
nrp->er_start = end + 1;
nrp->er_end = rp->er_end;
rp->er_end = start - 1;
LIST_INSERT_AFTER(rp, nrp, er_link);
nrp = NULL;
goto done;
}
if ((flags & EX_CONFLICTOK) == 0)
continue;
if ((start <= rp->er_start && end >= rp->er_end)) {
LIST_REMOVE(rp, er_link);
extent_free_region_descriptor(ex, rp);
continue;
}
if ((start <= rp->er_start) && (end >= rp->er_start))
rp->er_start = (end + 1);
if ((start <= rp->er_end) && (end >= rp->er_end))
rp->er_end = (start - 1);
}
if (flags & EX_CONFLICTOK)
goto done;
#if defined(DIAGNOSTIC) || defined(DDB)
extent_print(ex);
#endif
printf("%s: start 0x%lx, end 0x%lx\n", __func__, start, end);
panic("%s: region not found", __func__);
done:
if (nrp != NULL)
extent_free_region_descriptor(ex, nrp);
if (ex->ex_flags & EXF_WANTED) {
ex->ex_flags &= ~EXF_WANTED;
wakeup(ex);
}
return (error);
}
static struct extent_region *
extent_alloc_region_descriptor(struct extent *ex, int flags)
{
struct extent_region *rp;
if (ex->ex_flags & EXF_FIXED) {
struct extent_fixed *fex = (struct extent_fixed *)ex;
while (LIST_EMPTY(&fex->fex_freelist)) {
if (flags & EX_MALLOCOK)
goto alloc;
if ((flags & EX_WAITOK) == 0)
return (NULL);
ex->ex_flags |= EXF_FLWANTED;
if (tsleep_nsec(&fex->fex_freelist,
PRIBIO | ((flags & EX_CATCH) ? PCATCH : 0),
"extnt", INFSLP))
return (NULL);
}
rp = LIST_FIRST(&fex->fex_freelist);
LIST_REMOVE(rp, er_link);
return (rp);
}
alloc:
rp = pool_get(&ex_region_pl, (flags & EX_WAITOK) ? PR_WAITOK :
PR_NOWAIT);
if (rp != NULL)
rp->er_flags = ER_ALLOC;
return (rp);
}
static void
extent_free_region_descriptor(struct extent *ex, struct extent_region *rp)
{
if (rp->er_flags & ER_DISCARD)
return;
if (ex->ex_flags & EXF_FIXED) {
struct extent_fixed *fex = (struct extent_fixed *)ex;
if (rp->er_flags & ER_ALLOC) {
if (ex->ex_flags & EXF_FLWANTED) {
rp->er_flags = ER_ALLOC;
LIST_INSERT_HEAD(&fex->fex_freelist, rp,
er_link);
goto wake_em_up;
} else {
pool_put(&ex_region_pl, rp);
}
} else {
rp->er_flags = 0;
LIST_INSERT_HEAD(&fex->fex_freelist, rp, er_link);
}
if (ex->ex_flags & EXF_FLWANTED) {
wake_em_up:
ex->ex_flags &= ~EXF_FLWANTED;
wakeup(&fex->fex_freelist);
}
return;
}
pool_put(&ex_region_pl, rp);
}
#if defined(DIAGNOSTIC) || defined(DDB) || !defined(_KERNEL)
void
extent_print(struct extent *ex)
{
extent_print1(ex, printf);
}
void
extent_print1(struct extent *ex,
int (*pr)(const char *, ...) __attribute__((__format__(__kprintf__,1,2))))
{
struct extent_region *rp;
if (ex == NULL)
panic("%s: NULL extent", __func__);
#ifdef _KERNEL
(*pr)("extent `%s' (0x%lx - 0x%lx), flags=%b\n", ex->ex_name,
ex->ex_start, ex->ex_end, ex->ex_flags, EXF_BITS);
#else
(*pr)("extent `%s' (0x%lx - 0x%lx), flags = 0x%x\n", ex->ex_name,
ex->ex_start, ex->ex_end, ex->ex_flags);
#endif
LIST_FOREACH(rp, &ex->ex_regions, er_link)
(*pr)(" 0x%lx - 0x%lx\n", rp->er_start, rp->er_end);
}
#endif