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 void *
  66 zfs_kmem_alloc(size_t size, int kmflags)
  67 {
  68         void *p;
  69 #ifdef KMEM_DEBUG
  70         struct kmem_item *i;
  71
  72         size += sizeof(struct kmem_item);
  73 #endif
  74         p = malloc(size, M_SOLARIS, kmflags);
  75 #ifndef _KERNEL
  76         if (kmflags & KM_SLEEP)
  77                 assert(p != NULL);
  78 #endif
  79 #ifdef KMEM_DEBUG
  80         if (p != NULL) {
  81                 i = p;
  82                 p = (u_char *)p + sizeof(struct kmem_item);
  83                 stack_save(&i->stack);
  84                 mtx_lock(&kmem_items_mtx);
  85                 LIST_INSERT_HEAD(&kmem_items, i, next);
  86                 mtx_unlock(&kmem_items_mtx);
  87         }
  88 #endif
  89         return (p);
  90 }
  91
  92 void
  93 zfs_kmem_free(void *buf, size_t size __unused)
  94 {
  95 #ifdef KMEM_DEBUG
  96         if (buf == NULL) {
  97                 printf("%s: attempt to free NULL\n", __func__);
  98                 return;
  99         }
 100         struct kmem_item *i;
 101
 102         buf = (u_char *)buf - sizeof(struct kmem_item);
 103         mtx_lock(&kmem_items_mtx);
 104         LIST_FOREACH(i, &kmem_items, next) {
 105                 if (i == buf)
 106                         break;
 107         }
 108         ASSERT(i != NULL);
 109         LIST_REMOVE(i, next);
 110         mtx_unlock(&kmem_items_mtx);
 111 #endif
 112         free(buf, M_SOLARIS);
 113 }
 114
 115 static uint64_t kmem_size_val;
 116
 117 static void
 118 kmem_size_init(void *unused __unused)
 119 {
 120
 121         kmem_size_val = (uint64_t)cnt.v_page_count * PAGE_SIZE;
 122         if (kmem_size_val > vm_kmem_size)
 123                 kmem_size_val = vm_kmem_size;
 124 }
 125 SYSINIT(kmem_size_init, SI_SUB_KMEM, SI_ORDER_ANY, kmem_size_init, NULL);
 126
 127 uint64_t
 128 kmem_size(void)
 129 {
 130
 131         return (kmem_size_val);
 132 }
 133
 134 uint64_t
 135 kmem_used(void)
 136 {
 137
 138         return (kmem_map->size);
 139 }
 140
 141 static int
 142 kmem_std_constructor(void *mem, int size __unused, void *private, int flags)
 143 {
 144         struct kmem_cache *cache = private;
 145
 146         return (cache->kc_constructor(mem, cache->kc_private, flags));
 147 }
 148
 149 static void
 150 kmem_std_destructor(void *mem, int size __unused, void *private)
 151 {
 152         struct kmem_cache *cache = private;
 153
 154         cache->kc_destructor(mem, cache->kc_private);
 155 }
 156
 157 kmem_cache_t *
 158 kmem_cache_create(char *name, size_t bufsize, size_t align,
 159     int (*constructor)(void *, void *, int), void (*destructor)(void *, void *),
 160     void (*reclaim)(void *) __unused, void *private, vmem_t *vmp, int cflags)
 161 {
 162         kmem_cache_t *cache;
 163
 164         ASSERT(vmp == NULL);
 165
 166         cache = kmem_alloc(sizeof(*cache), KM_SLEEP);
 167         strlcpy(cache->kc_name, name, sizeof(cache->kc_name));
 168         cache->kc_constructor = constructor;
 169         cache->kc_destructor = destructor;
 170         cache->kc_private = private;
 171 #if defined(_KERNEL) && !defined(KMEM_DEBUG)
 172         cache->kc_zone = uma_zcreate(cache->kc_name, bufsize,
 173             constructor != NULL ? kmem_std_constructor : NULL,
 174             destructor != NULL ? kmem_std_destructor : NULL,
 175             NULL, NULL, align > 0 ? align - 1 : 0, cflags);
 176 #else
 177         cache->kc_size = bufsize;
 178 #endif
 179
 180         return (cache);
 181 }
 182
 183 void
 184 kmem_cache_destroy(kmem_cache_t *cache)
 185 {
 186 #if defined(_KERNEL) && !defined(KMEM_DEBUG)
 187         uma_zdestroy(cache->kc_zone);
 188 #endif
 189         kmem_free(cache, sizeof(*cache));
 190 }
 191
 192 void *
 193 kmem_cache_alloc(kmem_cache_t *cache, int flags)
 194 {
 195 #if defined(_KERNEL) && !defined(KMEM_DEBUG)
 196         return (uma_zalloc_arg(cache->kc_zone, cache, flags));
 197 #else
 198         void *p;
 199
 200         p = kmem_alloc(cache->kc_size, flags);
 201         if (p != NULL && cache->kc_constructor != NULL)
 202                 kmem_std_constructor(p, cache->kc_size, cache, flags);
 203         return (p);
 204 #endif
 205 }
 206
 207 void
 208 kmem_cache_free(kmem_cache_t *cache, void *buf)
 209 {
 210 #if defined(_KERNEL) && !defined(KMEM_DEBUG)
 211         uma_zfree_arg(cache->kc_zone, buf, cache);
 212 #else
 213         if (cache->kc_destructor != NULL)
 214                 kmem_std_destructor(buf, cache->kc_size, cache);
 215         kmem_free(buf, cache->kc_size);
 216 #endif
 217 }
 218
 219 #ifdef _KERNEL
 220 void
 221 kmem_cache_reap_now(kmem_cache_t *cache)
 222 {
 223 #ifndef KMEM_DEBUG
 224         zone_drain(cache->kc_zone);
 225 #endif
 226 }
 227
 228 void
 229 kmem_reap(void)
 230 {
 231         uma_reclaim();
 232 }
 233 #else
 234 void
 235 kmem_cache_reap_now(kmem_cache_t *cache __unused)
 236 {
 237 }
 238
 239 void
 240 kmem_reap(void)
 241 {
 242 }
 243 #endif
 244
 245 int
 246 kmem_debugging(void)
 247 {
 248         return (0);
 249 }
 250
 251 void *
 252 calloc(size_t n, size_t s)
 253 {
 254         return (kmem_zalloc(n * s, KM_NOSLEEP));
 255 }
 256
 257 #ifdef KMEM_DEBUG
 258 void kmem_show(void *);
 259 void
 260 kmem_show(void *dummy __unused)
 261 {
 262         struct kmem_item *i;
 263
 264         mtx_lock(&kmem_items_mtx);
 265         if (LIST_EMPTY(&kmem_items))
 266                 printf("KMEM_DEBUG: No leaked elements.\n");
 267         else {
 268                 printf("KMEM_DEBUG: Leaked elements:\n\n");
 269                 LIST_FOREACH(i, &kmem_items, next) {
 270                         printf("address=%p\n", i);
 271                         stack_print_ddb(&i->stack);
 272                         printf("\n");
 273                 }
 274         }
 275         mtx_unlock(&kmem_items_mtx);
 276 }
 277
 278 SYSUNINIT(sol_kmem, SI_SUB_CPU, SI_ORDER_FIRST, kmem_show, NULL);
 279 #endif  /* KMEM_DEBUG */