sys/cddl/compat/opensolaris/kern/opensolaris_kmem.c

   1 /*-
   2  * Copyright (c) 2006-2007 Pawel Jakub Dawidek <pjd@FreeBSD.org>
   3  * All rights reserved.
   4  *
   5  * Redistribution and use in source and binary forms, with or without
   6  * modification, are permitted provided that the following conditions
   7  * are met:
   8  * 1. Redistributions of source code must retain the above copyright
   9  *    notice, this list of conditions and the following disclaimer.
  10  * 2. Redistributions in binary form must reproduce the above copyright
  11  *    notice, this list of conditions and the following disclaimer in the
  12  *    documentation and/or other materials provided with the distribution.
  13  *
  14  * THIS SOFTWARE IS PROVIDED BY THE AUTHORS AND CONTRIBUTORS ``AS IS'' AND
  15  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  16  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  17  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHORS OR CONTRIBUTORS BE LIABLE
  18  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  19  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  20  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  21  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  22  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  23  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  24  * SUCH DAMAGE.
  25  */
  26
  27 #include <sys/cdefs.h>
  28 __FBSDID("$FreeBSD$");
  29
  30 #include <sys/param.h>
  31 #include <sys/kernel.h>
  32 #include <sys/systm.h>
  33 #include <sys/malloc.h>
  34 #include <sys/kmem.h>
  35 #include <sys/debug.h>
  36 #include <sys/mutex.h>
  37
  38 #include <vm/vm_page.h>
  39 #include <vm/vm_object.h>
  40 #include <vm/vm_kern.h>
  41 #include <vm/vm_map.h>
  42
  43 #ifdef KMEM_DEBUG
  44 #include <sys/queue.h>
  45 #include <sys/stack.h>
  46 #endif
  47
  48 #ifdef _KERNEL
  49 MALLOC_DEFINE(M_SOLARIS, "solaris", "Solaris");
  50 #else
  51 #define malloc(size, type, flags)       malloc(size)
  52 #define free(addr, type)                free(addr)
  53 #endif
  54
  55 #ifdef KMEM_DEBUG
  56 struct kmem_item {
  57         struct stack    stack;
  58         LIST_ENTRY(kmem_item) next;
  59 };
  60 static LIST_HEAD(, kmem_item) kmem_items;
  61 static struct mtx kmem_items_mtx;
  62 MTX_SYSINIT(kmem_items_mtx, &kmem_items_mtx, "kmem_items", MTX_DEF);
  63 #endif  /* KMEM_DEBUG */
  64
  65 #include <sys/vmem.h>
  66
  67 void *
  68 zfs_kmem_alloc(size_t size, int kmflags)
  69 {
  70         void *p;
  71 #ifdef KMEM_DEBUG
  72         struct kmem_item *i;
  73
  74         size += sizeof(struct kmem_item);
  75 #endif
  76         p = malloc(size, M_SOLARIS, kmflags);
  77 #ifndef _KERNEL
  78         if (kmflags & KM_SLEEP)
  79                 assert(p != NULL);
  80 #endif
  81 #ifdef KMEM_DEBUG
  82         if (p != NULL) {
  83                 i = p;
  84                 p = (u_char *)p + sizeof(struct kmem_item);
  85                 stack_save(&i->stack);
  86                 mtx_lock(&kmem_items_mtx);
  87                 LIST_INSERT_HEAD(&kmem_items, i, next);
  88                 mtx_unlock(&kmem_items_mtx);
  89         }
  90 #endif
  91         return (p);
  92 }
  93
  94 void
  95 zfs_kmem_free(void *buf, size_t size __unused)
  96 {
  97 #ifdef KMEM_DEBUG
  98         if (buf == NULL) {
  99                 printf("%s: attempt to free NULL\n", __func__);
 100                 return;
 101         }
 102         struct kmem_item *i;
 103
 104         buf = (u_char *)buf - sizeof(struct kmem_item);
 105         mtx_lock(&kmem_items_mtx);
 106         LIST_FOREACH(i, &kmem_items, next) {
 107                 if (i == buf)
 108                         break;
 109         }
 110         ASSERT(i != NULL);
 111         LIST_REMOVE(i, next);
 112         mtx_unlock(&kmem_items_mtx);
 113 #endif
 114         free(buf, M_SOLARIS);
 115 }
 116
 117 static uint64_t kmem_size_val;
 118
 119 static void
 120 kmem_size_init(void *unused __unused)
 121 {
 122
 123         kmem_size_val = (uint64_t)cnt.v_page_count * PAGE_SIZE;
 124         if (kmem_size_val > vm_kmem_size)
 125                 kmem_size_val = vm_kmem_size;
 126 }
 127 SYSINIT(kmem_size_init, SI_SUB_KMEM, SI_ORDER_ANY, kmem_size_init, NULL);
 128
 129 uint64_t
 130 kmem_size(void)
 131 {
 132
 133         return (kmem_size_val);
 134 }
 135
 136 static int
 137 kmem_std_constructor(void *mem, int size __unused, void *private, int flags)
 138 {
 139         struct kmem_cache *cache = private;
 140
 141         return (cache->kc_constructor(mem, cache->kc_private, flags));
 142 }
 143
 144 static void
 145 kmem_std_destructor(void *mem, int size __unused, void *private)
 146 {
 147         struct kmem_cache *cache = private;
 148
 149         cache->kc_destructor(mem, cache->kc_private);
 150 }
 151
 152 kmem_cache_t *
 153 kmem_cache_create(char *name, size_t bufsize, size_t align,
 154     int (*constructor)(void *, void *, int), void (*destructor)(void *, void *),
 155     void (*reclaim)(void *) __unused, void *private, vmem_t *vmp, int cflags)
 156 {
 157         kmem_cache_t *cache;
 158
 159         ASSERT(vmp == NULL);
 160
 161         cache = kmem_alloc(sizeof(*cache), KM_SLEEP);
 162         strlcpy(cache->kc_name, name, sizeof(cache->kc_name));
 163         cache->kc_constructor = constructor;
 164         cache->kc_destructor = destructor;
 165         cache->kc_private = private;
 166 #if defined(_KERNEL) && !defined(KMEM_DEBUG)
 167         cache->kc_zone = uma_zcreate(cache->kc_name, bufsize,
 168             constructor != NULL ? kmem_std_constructor : NULL,
 169             destructor != NULL ? kmem_std_destructor : NULL,
 170             NULL, NULL, align > 0 ? align - 1 : 0, cflags);
 171 #else
 172         cache->kc_size = bufsize;
 173 #endif
 174
 175         return (cache);
 176 }
 177
 178 void
 179 kmem_cache_destroy(kmem_cache_t *cache)
 180 {
 181 #if defined(_KERNEL) && !defined(KMEM_DEBUG)
 182         uma_zdestroy(cache->kc_zone);
 183 #endif
 184         kmem_free(cache, sizeof(*cache));
 185 }
 186
 187 void *
 188 kmem_cache_alloc(kmem_cache_t *cache, int flags)
 189 {
 190 #if defined(_KERNEL) && !defined(KMEM_DEBUG)
 191         return (uma_zalloc_arg(cache->kc_zone, cache, flags));
 192 #else
 193         void *p;
 194
 195         p = kmem_alloc(cache->kc_size, flags);
 196         if (p != NULL && cache->kc_constructor != NULL)
 197                 kmem_std_constructor(p, cache->kc_size, cache, flags);
 198         return (p);
 199 #endif
 200 }
 201
 202 void
 203 kmem_cache_free(kmem_cache_t *cache, void *buf)
 204 {
 205 #if defined(_KERNEL) && !defined(KMEM_DEBUG)
 206         uma_zfree_arg(cache->kc_zone, buf, cache);
 207 #else
 208         if (cache->kc_destructor != NULL)
 209                 kmem_std_destructor(buf, cache->kc_size, cache);
 210         kmem_free(buf, cache->kc_size);
 211 #endif
 212 }
 213
 214 #ifdef _KERNEL
 215 void
 216 kmem_cache_reap_now(kmem_cache_t *cache)
 217 {
 218 #ifndef KMEM_DEBUG
 219         zone_drain(cache->kc_zone);
 220 #endif
 221 }
 222
 223 void
 224 kmem_reap(void)
 225 {
 226         uma_reclaim();
 227 }
 228 #else
 229 void
 230 kmem_cache_reap_now(kmem_cache_t *cache __unused)
 231 {
 232 }
 233
 234 void
 235 kmem_reap(void)
 236 {
 237 }
 238 #endif
 239
 240 int
 241 kmem_debugging(void)
 242 {
 243         return (0);
 244 }
 245
 246 void *
 247 calloc(size_t n, size_t s)
 248 {
 249         return (kmem_zalloc(n * s, KM_NOSLEEP));
 250 }
 251
 252 #ifdef KMEM_DEBUG
 253 void kmem_show(void *);
 254 void
 255 kmem_show(void *dummy __unused)
 256 {
 257         struct kmem_item *i;
 258
 259         mtx_lock(&kmem_items_mtx);
 260         if (LIST_EMPTY(&kmem_items))
 261                 printf("KMEM_DEBUG: No leaked elements.\n");
 262         else {
 263                 printf("KMEM_DEBUG: Leaked elements:\n\n");
 264                 LIST_FOREACH(i, &kmem_items, next) {
 265                         printf("address=%p\n", i);
 266                         stack_print_ddb(&i->stack);
 267                         printf("\n");
 268                 }
 269         }
 270         mtx_unlock(&kmem_items_mtx);
 271 }
 272
 273 SYSUNINIT(sol_kmem, SI_SUB_CPU, SI_ORDER_FIRST, kmem_show, NULL);
 274 #endif  /* KMEM_DEBUG */