#include <sys/types.h>
#include <sys/t_lock.h>
#include <sys/param.h>
#include <sys/sysmacros.h>
#include <sys/tuneable.h>
#include <sys/systm.h>
#include <sys/vm.h>
#include <sys/kmem.h>
#include <sys/vmem.h>
#include <sys/mman.h>
#include <sys/cmn_err.h>
#include <sys/debug.h>
#include <sys/dumphdr.h>
#include <sys/bootconf.h>
#include <sys/lgrp.h>
#include <vm/seg_kmem.h>
#include <vm/hat.h>
#include <vm/page.h>
#include <vm/vm_dep.h>
#include <vm/faultcode.h>
#include <sys/promif.h>
#include <vm/seg_kp.h>
#include <sys/bitmap.h>
#include <sys/mem_cage.h>
#ifdef __sparc
#include <sys/ivintr.h>
#include <sys/panic.h>
#endif
extern ulong_t *segkp_bitmap;
char *kernelheap;
char *ekernelheap;
struct seg kvseg;
struct seg kvseg_core;
struct seg kzioseg;
vmem_t *heap_arena;
vmem_t *heap_core_arena;
char *heap_core_base;
char *heap_lp_base;
char *heap_lp_end;
vmem_t *hat_memload_arena;
struct seg kvseg32;
vmem_t *heap32_arena;
vmem_t *heaptext_arena;
struct as kas;
int segkmem_reloc;
vmem_t *static_arena;
vmem_t *static_alloc_arena;
vmem_t *zio_arena = NULL;
vmem_t *zio_alloc_arena = NULL;
#if defined(__amd64)
vmem_t *kvmm_arena;
struct seg kvmmseg;
#endif
size_t segkmem_lpsize;
int segkmem_lpszc = 0;
size_t segkmem_kmemlp_quantum = 0x400000;
size_t segkmem_heaplp_quantum;
vmem_t *heap_lp_arena;
static vmem_t *kmem_lp_arena;
static segkmem_lpcb_t segkmem_lpcb;
#ifdef __sparc
static uint_t segkmem_lpshift = PAGESHIFT;
static vmem_t *segkmem_ppa_arena;
#endif
size_t segkmem_kmemlp_max;
uint_t segkmem_kmemlp_pcnt;
size_t segkmem_kmemlp_min;
static ulong_t segkmem_lpthrottle_max = 0x400000;
static ulong_t segkmem_lpthrottle_start = 0x40;
static ulong_t segkmem_use_lpthrottle = 1;
typedef struct segkmem_gc_list {
struct segkmem_gc_list *gc_next;
vmem_t *gc_arena;
size_t gc_size;
} segkmem_gc_list_t;
static segkmem_gc_list_t *segkmem_gc_list;
static void *
hat_memload_alloc(vmem_t *vmp, size_t size, int flags)
{
flags |= (VM_MEMLOAD | VM_NORELOC);
return (segkmem_alloc(vmp, size, flags));
}
void *
segkmem_alloc_permanent(vmem_t *vmp, size_t size, int flags)
{
return (segkmem_alloc(vmp, size, flags | VM_NORELOC));
}
void
kernelheap_init(
void *heap_start,
void *heap_end,
char *first_avail,
void *core_start,
void *core_end)
{
uintptr_t textbase;
size_t core_size;
size_t heap_size;
vmem_t *heaptext_parent;
size_t heap_lp_size = 0;
#ifdef __sparc
size_t kmem64_sz = kmem64_aligned_end - kmem64_base;
#endif
kernelheap = heap_start;
ekernelheap = heap_end;
#ifdef __sparc
heap_lp_size = (((uintptr_t)heap_end - (uintptr_t)heap_start) / 4);
kmem64_sz = P2ROUNDUP(kmem64_sz, MMU_PAGESIZE256M);
if (kmem64_sz <= heap_lp_size / 2)
heap_lp_size -= kmem64_sz;
heap_lp_base = ekernelheap - heap_lp_size;
heap_lp_end = heap_lp_base + heap_lp_size;
#endif
core_size = (uintptr_t)core_end - (uintptr_t)core_start;
if (core_size > 0) {
ASSERT(core_size >= HEAPTEXT_SIZE);
textbase = (uintptr_t)core_end - HEAPTEXT_SIZE;
core_size -= HEAPTEXT_SIZE;
}
#ifndef __sparc
else {
ekernelheap -= HEAPTEXT_SIZE;
textbase = (uintptr_t)ekernelheap;
}
#endif
heap_size = (uintptr_t)ekernelheap - (uintptr_t)kernelheap;
heap_arena = vmem_init("heap", kernelheap, heap_size, PAGESIZE,
segkmem_alloc, segkmem_free);
if (core_size > 0) {
heap_core_arena = vmem_create("heap_core", core_start,
core_size, PAGESIZE, NULL, NULL, NULL, 0, VM_SLEEP);
heap_core_base = core_start;
} else {
heap_core_arena = heap_arena;
heap_core_base = kernelheap;
}
if (heap_lp_size) {
(void) vmem_xalloc(heap_arena, heap_lp_size, PAGESIZE, 0, 0,
heap_lp_base, heap_lp_end,
VM_NOSLEEP | VM_BESTFIT | VM_PANIC);
}
(void) vmem_xalloc(heap_arena, first_avail - kernelheap, PAGESIZE,
0, 0, kernelheap, first_avail, VM_NOSLEEP | VM_BESTFIT | VM_PANIC);
#ifdef __sparc
heap32_arena = vmem_create("heap32", (void *)SYSBASE32,
SYSLIMIT32 - SYSBASE32 - HEAPTEXT_SIZE, PAGESIZE, NULL,
NULL, NULL, 0, VM_SLEEP);
(void) vmem_xalloc(heap32_arena, PANICBUFSIZE, PAGESIZE, 0, 0,
panicbuf, panicbuf + PANICBUFSIZE,
VM_NOSLEEP | VM_BESTFIT | VM_PANIC);
(void) vmem_xalloc(heap32_arena, IVSIZE, PAGESIZE, 0, 0,
intr_vec_table, (caddr_t)intr_vec_table + IVSIZE,
VM_NOSLEEP | VM_BESTFIT | VM_PANIC);
textbase = SYSLIMIT32 - HEAPTEXT_SIZE;
heaptext_parent = NULL;
#else
heap32_arena = heap_core_arena;
heaptext_parent = heap_core_arena;
#endif
heaptext_arena = vmem_create("heaptext", (void *)textbase,
HEAPTEXT_SIZE, PAGESIZE, NULL, NULL, heaptext_parent, 0, VM_SLEEP);
static_arena = vmem_create("static", NULL, 0, PAGESIZE,
segkmem_alloc_permanent, segkmem_free, heap_arena, 0, VM_SLEEP);
static_alloc_arena = vmem_create("static_alloc", NULL, 0,
sizeof (uint64_t), vmem_alloc, vmem_free, static_arena,
0, VM_SLEEP);
hat_memload_arena = vmem_create("hat_memload", NULL, 0, PAGESIZE,
hat_memload_alloc, segkmem_free, heap_arena, 0,
VM_SLEEP | VMC_POPULATOR | VMC_DUMPSAFE);
}
void
boot_mapin(caddr_t addr, size_t size)
{
caddr_t eaddr;
page_t *pp;
pfn_t pfnum;
if (page_resv(btop(size), KM_NOSLEEP) == 0)
panic("boot_mapin: page_resv failed");
for (eaddr = addr + size; addr < eaddr; addr += PAGESIZE) {
pfnum = va_to_pfn(addr);
if (pfnum == PFN_INVALID)
continue;
if ((pp = page_numtopp_nolock(pfnum)) == NULL)
panic("boot_mapin(): No pp for pfnum = %lx", pfnum);
if (pp->p_szc != 0)
page_boot_demote(pp);
pp = page_numtopp(pfnum, SE_EXCL);
if (pp == NULL || PP_ISFREE(pp))
panic("boot_alloc: pp is NULL or free");
if (kcage_on && !PP_ISNORELOC(pp)) {
PP_SETNORELOC(pp);
PLCNT_XFER_NORELOC(pp);
}
(void) page_hashin(pp, &kvp, (u_offset_t)(uintptr_t)addr, NULL);
pp->p_lckcnt = 1;
#if defined(__x86)
page_downgrade(pp);
#else
page_unlock(pp);
#endif
}
}
void *
boot_alloc(void *inaddr, size_t size, uint_t align)
{
caddr_t addr = inaddr;
if (bootops == NULL)
prom_panic("boot_alloc: attempt to allocate memory after "
"BOP_GONE");
size = ptob(btopr(size));
#ifdef __sparc
if (bop_alloc_chunk(addr, size, align) != (caddr_t)addr)
panic("boot_alloc: bop_alloc_chunk failed");
#else
if (BOP_ALLOC(bootops, addr, size, align) != addr)
panic("boot_alloc: BOP_ALLOC failed");
#endif
boot_mapin((caddr_t)addr, size);
return (addr);
}
static void
segkmem_badop()
{
panic("segkmem_badop");
}
#define SEGKMEM_BADOP(t) (t(*)())(uintptr_t)segkmem_badop
static faultcode_t
segkmem_fault(struct hat *hat, struct seg *seg, caddr_t addr, size_t size,
enum fault_type type, enum seg_rw rw)
{
pgcnt_t npages;
spgcnt_t pg;
page_t *pp;
struct vnode *vp = seg->s_data;
ASSERT(RW_READ_HELD(&seg->s_as->a_lock));
if (seg->s_as != &kas || size > seg->s_size ||
addr < seg->s_base || addr + size > seg->s_base + seg->s_size)
panic("segkmem_fault: bad args");
if (segkp_bitmap && seg == &kvseg &&
BT_TEST(segkp_bitmap, btop((uintptr_t)(addr - seg->s_base))))
return (SEGOP_FAULT(hat, segkp, addr, size, type, rw));
if (rw != S_READ && rw != S_WRITE && rw != S_OTHER)
return (FC_NOSUPPORT);
npages = btopr(size);
switch (type) {
case F_SOFTLOCK:
for (pg = 0; pg < npages; pg++) {
pp = page_lookup(vp, (u_offset_t)(uintptr_t)addr,
SE_SHARED);
if (pp == NULL) {
if (!hat_probe(kas.a_hat, addr)) {
addr -= PAGESIZE;
while (--pg >= 0) {
pp = page_find(vp, (u_offset_t)
(uintptr_t)addr);
if (pp)
page_unlock(pp);
addr -= PAGESIZE;
}
return (FC_NOMAP);
}
}
addr += PAGESIZE;
}
if (rw == S_OTHER)
hat_reserve(seg->s_as, addr, size);
return (0);
case F_SOFTUNLOCK:
while (npages--) {
pp = page_find(vp, (u_offset_t)(uintptr_t)addr);
if (pp)
page_unlock(pp);
addr += PAGESIZE;
}
return (0);
default:
return (FC_NOSUPPORT);
}
}
static int
segkmem_setprot(struct seg *seg, caddr_t addr, size_t size, uint_t prot)
{
ASSERT(RW_LOCK_HELD(&seg->s_as->a_lock));
if (seg->s_as != &kas || size > seg->s_size ||
addr < seg->s_base || addr + size > seg->s_base + seg->s_size)
panic("segkmem_setprot: bad args");
if (segkp_bitmap && seg == &kvseg &&
BT_TEST(segkp_bitmap, btop((uintptr_t)(addr - seg->s_base))))
return (SEGOP_SETPROT(segkp, addr, size, prot));
if (prot == 0)
hat_unload(kas.a_hat, addr, size, HAT_UNLOAD);
else
hat_chgprot(kas.a_hat, addr, size, prot);
return (0);
}
static int
segkmem_checkprot(struct seg *seg, caddr_t addr, size_t size, uint_t prot)
{
ASSERT(RW_LOCK_HELD(&seg->s_as->a_lock));
if (seg->s_as != &kas)
segkmem_badop();
if (segkp_bitmap && seg == &kvseg &&
BT_TEST(segkp_bitmap, btop((uintptr_t)(addr - seg->s_base))))
return (SEGOP_CHECKPROT(segkp, addr, size, prot));
segkmem_badop();
return (0);
}
static int
segkmem_kluster(struct seg *seg, caddr_t addr, ssize_t delta)
{
ASSERT(RW_LOCK_HELD(&seg->s_as->a_lock));
if (seg->s_as != &kas)
segkmem_badop();
if (segkp_bitmap && seg == &kvseg &&
BT_TEST(segkp_bitmap, btop((uintptr_t)(addr - seg->s_base))))
return (SEGOP_KLUSTER(segkp, addr, delta));
segkmem_badop();
return (0);
}
static void
segkmem_xdump_range(void *arg, void *start, size_t size)
{
struct as *as = arg;
caddr_t addr = start;
caddr_t addr_end = addr + size;
while (addr < addr_end) {
pfn_t pfn = hat_getpfnum(kas.a_hat, addr);
if (pfn != PFN_INVALID && pfn <= physmax && pf_is_memory(pfn))
dump_addpage(as, addr, pfn);
addr += PAGESIZE;
dump_timeleft = dump_timeout;
}
}
static void
segkmem_dump_range(void *arg, void *start, size_t size)
{
caddr_t addr = start;
caddr_t addr_end = addr + size;
if (SEGKMEM_USE_LARGEPAGES &&
addr == heap_lp_base && addr_end == heap_lp_end &&
vmem_size(heap_lp_arena, VMEM_ALLOC) < size) {
vmem_walk(heap_lp_arena, VMEM_ALLOC | VMEM_REENTRANT,
segkmem_xdump_range, arg);
} else {
segkmem_xdump_range(arg, start, size);
}
}
static void
segkmem_dump(struct seg *seg)
{
if (seg == &kvseg) {
vmem_walk(heap_arena, VMEM_ALLOC | VMEM_REENTRANT,
segkmem_dump_range, seg->s_as);
#ifndef __sparc
vmem_walk(heaptext_arena, VMEM_ALLOC | VMEM_REENTRANT,
segkmem_dump_range, seg->s_as);
#endif
} else if (seg == &kvseg_core) {
vmem_walk(heap_core_arena, VMEM_ALLOC | VMEM_REENTRANT,
segkmem_dump_range, seg->s_as);
} else if (seg == &kvseg32) {
vmem_walk(heap32_arena, VMEM_ALLOC | VMEM_REENTRANT,
segkmem_dump_range, seg->s_as);
vmem_walk(heaptext_arena, VMEM_ALLOC | VMEM_REENTRANT,
segkmem_dump_range, seg->s_as);
} else if (seg == &kzioseg) {
return;
#if defined(__amd64)
} else if (seg == &kvmmseg) {
return;
#endif
} else {
segkmem_dump_range(seg->s_as, seg->s_base, seg->s_size);
}
}
static int
segkmem_pagelock(struct seg *seg, caddr_t addr, size_t len,
page_t ***ppp, enum lock_type type, enum seg_rw rw)
{
page_t **pplist, *pp;
pgcnt_t npages;
spgcnt_t pg;
size_t nb;
struct vnode *vp = seg->s_data;
ASSERT(ppp != NULL);
if (segkp_bitmap && seg == &kvseg &&
BT_TEST(segkp_bitmap, btop((uintptr_t)(addr - seg->s_base))))
return (SEGOP_PAGELOCK(segkp, addr, len, ppp, type, rw));
npages = btopr(len);
nb = sizeof (page_t *) * npages;
if (type == L_PAGEUNLOCK) {
pplist = *ppp;
ASSERT(pplist != NULL);
for (pg = 0; pg < npages; pg++) {
pp = pplist[pg];
page_unlock(pp);
}
kmem_free(pplist, nb);
return (0);
}
ASSERT(type == L_PAGELOCK);
pplist = kmem_alloc(nb, KM_NOSLEEP);
if (pplist == NULL) {
*ppp = NULL;
return (ENOTSUP);
}
for (pg = 0; pg < npages; pg++) {
pp = page_lookup(vp, (u_offset_t)(uintptr_t)addr, SE_SHARED);
if (pp == NULL) {
while (--pg >= 0)
page_unlock(pplist[pg]);
kmem_free(pplist, nb);
*ppp = NULL;
return (ENOTSUP);
}
pplist[pg] = pp;
addr += PAGESIZE;
}
*ppp = pplist;
return (0);
}
static int
segkmem_getmemid(struct seg *seg, caddr_t addr, memid_t *memidp)
{
ASSERT(RW_LOCK_HELD(&seg->s_as->a_lock));
if (seg->s_as != &kas)
segkmem_badop();
if (segkp_bitmap && seg == &kvseg &&
BT_TEST(segkp_bitmap, btop((uintptr_t)(addr - seg->s_base))))
return (SEGOP_GETMEMID(segkp, addr, memidp));
segkmem_badop();
return (0);
}
static lgrp_mem_policy_info_t *
segkmem_getpolicy(struct seg *seg, caddr_t addr)
{
return (NULL);
}
static int
segkmem_capable(struct seg *seg, segcapability_t capability)
{
if (capability == S_CAPABILITY_NOMINFLT)
return (1);
return (0);
}
struct seg_ops segkmem_ops = {
SEGKMEM_BADOP(int),
SEGKMEM_BADOP(int),
SEGKMEM_BADOP(void),
segkmem_fault,
SEGKMEM_BADOP(faultcode_t),
segkmem_setprot,
segkmem_checkprot,
segkmem_kluster,
SEGKMEM_BADOP(size_t),
SEGKMEM_BADOP(int),
SEGKMEM_BADOP(size_t),
SEGKMEM_BADOP(int),
SEGKMEM_BADOP(int),
SEGKMEM_BADOP(u_offset_t),
SEGKMEM_BADOP(int),
SEGKMEM_BADOP(int),
SEGKMEM_BADOP(int),
segkmem_dump,
segkmem_pagelock,
SEGKMEM_BADOP(int),
segkmem_getmemid,
segkmem_getpolicy,
segkmem_capable,
seg_inherit_notsup
};
int
segkmem_create(struct seg *seg)
{
ASSERT(seg->s_as == &kas && RW_WRITE_HELD(&kas.a_lock));
seg->s_ops = &segkmem_ops;
if (seg == &kzioseg)
seg->s_data = &kvps[KV_ZVP];
#if defined(__amd64)
else if (seg == &kvmmseg)
seg->s_data = &kvps[KV_VVP];
#endif
else
seg->s_data = &kvps[KV_KVP];
kas.a_size += seg->s_size;
return (0);
}
page_t *
segkmem_page_create(void *addr, size_t size, int vmflag, void *arg)
{
struct seg kseg = { 0 };
int pgflags = PG_EXCL;
struct vnode *vp = arg;
if (vp == NULL)
vp = &kvp;
kseg.s_as = &kas;
if (segkmem_reloc == 0 || (vmflag & VM_NORELOC))
pgflags |= PG_NORELOC;
if ((vmflag & VM_NOSLEEP) == 0)
pgflags |= PG_WAIT;
if (vmflag & VM_PANIC)
pgflags |= PG_PANIC;
if (vmflag & VM_PUSHPAGE)
pgflags |= PG_PUSHPAGE;
if (vmflag & VM_NORMALPRI) {
ASSERT(vmflag & VM_NOSLEEP);
pgflags |= PG_NORMALPRI;
}
return (page_create_va(vp, (u_offset_t)(uintptr_t)addr, size,
pgflags, &kseg, addr));
}
void *
segkmem_xalloc(vmem_t *vmp, void *inaddr, size_t size, int vmflag, uint_t attr,
page_t *(*page_create_func)(void *, size_t, int, void *), void *pcarg)
{
page_t *ppl;
caddr_t addr = inaddr;
pgcnt_t npages = btopr(size);
int allocflag;
if (inaddr == NULL && (addr = vmem_alloc(vmp, size, vmflag)) == NULL)
return (NULL);
ASSERT(((uintptr_t)addr & PAGEOFFSET) == 0);
if (page_resv(npages, vmflag & VM_KMFLAGS) == 0) {
if (inaddr == NULL)
vmem_free(vmp, addr, size);
return (NULL);
}
ppl = page_create_func(addr, size, vmflag, pcarg);
if (ppl == NULL) {
if (inaddr == NULL)
vmem_free(vmp, addr, size);
page_unresv(npages);
return (NULL);
}
if (vmflag & VM_MEMLOAD)
allocflag = HAT_NO_KALLOC;
#if defined(__x86)
else if (vmem_is_populator())
allocflag = HAT_NO_KALLOC;
#endif
else
allocflag = 0;
while (ppl != NULL) {
page_t *pp = ppl;
page_sub(&ppl, pp);
ASSERT(page_iolock_assert(pp));
ASSERT(PAGE_EXCL(pp));
page_io_unlock(pp);
hat_memload(kas.a_hat, (caddr_t)(uintptr_t)pp->p_offset, pp,
(PROT_ALL & ~PROT_USER) | HAT_NOSYNC | attr,
HAT_LOAD_LOCK | allocflag);
pp->p_lckcnt = 1;
#if defined(__x86)
page_downgrade(pp);
#else
if (vmflag & SEGKMEM_SHARELOCKED)
page_downgrade(pp);
else
page_unlock(pp);
#endif
}
return (addr);
}
static void *
segkmem_alloc_vn(vmem_t *vmp, size_t size, int vmflag, struct vnode *vp)
{
void *addr;
segkmem_gc_list_t *gcp, **prev_gcpp;
ASSERT(vp != NULL);
if (kvseg.s_base == NULL) {
#ifndef __sparc
if (bootops->bsys_alloc == NULL)
halt("Memory allocation between bop_alloc() and "
"kmem_alloc().\n");
#endif
for (prev_gcpp = &segkmem_gc_list; (gcp = *prev_gcpp) != NULL;
prev_gcpp = &gcp->gc_next) {
if (gcp->gc_arena == vmp && gcp->gc_size == size) {
*prev_gcpp = gcp->gc_next;
return (gcp);
}
}
addr = vmem_alloc(vmp, size, vmflag | VM_PANIC);
if (boot_alloc(addr, size, BO_NO_ALIGN) != addr)
panic("segkmem_alloc: boot_alloc failed");
return (addr);
}
return (segkmem_xalloc(vmp, NULL, size, vmflag, 0,
segkmem_page_create, vp));
}
void *
segkmem_alloc(vmem_t *vmp, size_t size, int vmflag)
{
return (segkmem_alloc_vn(vmp, size, vmflag, &kvp));
}
static void *
segkmem_zio_alloc(vmem_t *vmp, size_t size, int vmflag)
{
return (segkmem_alloc_vn(vmp, size, vmflag, &kvps[KV_ZVP]));
}
void
segkmem_xfree(vmem_t *vmp, void *inaddr, size_t size, struct vnode *vp,
void (*func)(page_t *))
{
page_t *pp;
caddr_t addr = inaddr;
caddr_t eaddr;
pgcnt_t npages = btopr(size);
ASSERT(((uintptr_t)addr & PAGEOFFSET) == 0);
ASSERT(vp != NULL);
if (kvseg.s_base == NULL) {
segkmem_gc_list_t *gc = inaddr;
gc->gc_arena = vmp;
gc->gc_size = size;
gc->gc_next = segkmem_gc_list;
segkmem_gc_list = gc;
return;
}
hat_unload(kas.a_hat, addr, size, HAT_UNLOAD_UNLOCK);
for (eaddr = addr + size; addr < eaddr; addr += PAGESIZE) {
#if defined(__x86)
pp = page_find(vp, (u_offset_t)(uintptr_t)addr);
if (pp == NULL)
panic("segkmem_free: page not found");
if (!page_tryupgrade(pp)) {
page_unlock(pp);
pp = page_lookup(vp, (u_offset_t)(uintptr_t)addr,
SE_EXCL);
}
#else
pp = page_lookup(vp, (u_offset_t)(uintptr_t)addr, SE_EXCL);
#endif
if (pp == NULL)
panic("segkmem_free: page not found");
pp->p_lckcnt = 0;
if (func)
func(pp);
else
page_destroy(pp, 0);
}
if (func == NULL)
page_unresv(npages);
if (vmp != NULL)
vmem_free(vmp, inaddr, size);
}
void
segkmem_free(vmem_t *vmp, void *inaddr, size_t size)
{
segkmem_xfree(vmp, inaddr, size, &kvp, NULL);
}
static void
segkmem_zio_free(vmem_t *vmp, void *inaddr, size_t size)
{
segkmem_xfree(vmp, inaddr, size, &kvps[KV_ZVP], NULL);
}
void
segkmem_gc(void)
{
ASSERT(kvseg.s_base != NULL);
while (segkmem_gc_list != NULL) {
segkmem_gc_list_t *gc = segkmem_gc_list;
segkmem_gc_list = gc->gc_next;
segkmem_free(gc->gc_arena, gc, gc->gc_size);
}
}
void
segkmem_mapin(struct seg *seg, void *addr, size_t size, uint_t vprot,
pfn_t pfn, uint_t flags)
{
hat_unload(seg->s_as->a_hat, addr, size, HAT_UNLOAD_UNLOCK);
hat_devload(seg->s_as->a_hat, addr, size, pfn, vprot,
flags | HAT_LOAD_LOCK);
}
void
segkmem_mapout(struct seg *seg, void *addr, size_t size)
{
hat_unload(seg->s_as->a_hat, addr, size, HAT_UNLOAD_UNLOCK);
}
void *
kmem_getpages(pgcnt_t npages, int kmflag)
{
return (kmem_alloc(ptob(npages), kmflag));
}
void
kmem_freepages(void *addr, pgcnt_t npages)
{
kmem_free(addr, ptob(npages));
}
#ifdef __sparc
static page_t *
segkmem_page_create_large(void *addr, size_t size, int vmflag, void *arg)
{
int pgflags;
pgflags = PG_EXCL;
if (segkmem_reloc == 0 || (vmflag & VM_NORELOC))
pgflags |= PG_NORELOC;
if (!(vmflag & VM_NOSLEEP))
pgflags |= PG_WAIT;
if (vmflag & VM_PUSHPAGE)
pgflags |= PG_PUSHPAGE;
if (vmflag & VM_NORMALPRI)
pgflags |= PG_NORMALPRI;
return (page_create_va_large(&kvp, (u_offset_t)(uintptr_t)addr, size,
pgflags, &kvseg, addr, arg));
}
static void *
segkmem_xalloc_lp(vmem_t *vmp, void *inaddr, size_t size, int vmflag,
uint_t attr, page_t *(*page_create_func)(void *, size_t, int, void *),
void *pcarg)
{
caddr_t addr = inaddr, pa;
size_t lpsize = segkmem_lpsize;
pgcnt_t npages = btopr(size);
pgcnt_t nbpages = btop(lpsize);
pgcnt_t nlpages = size >> segkmem_lpshift;
size_t ppasize = nbpages * sizeof (page_t *);
page_t *pp, *rootpp, **ppa, *pplist = NULL;
int i;
vmflag |= VM_NOSLEEP;
if (page_resv(npages, vmflag & VM_KMFLAGS) == 0) {
return (NULL);
}
if ((ppa = vmem_alloc(segkmem_ppa_arena, ppasize, vmflag)) == NULL) {
goto fail_array_alloc;
}
if (inaddr == NULL && (addr = vmem_alloc(vmp, size, vmflag)) == NULL)
goto fail_vmem_alloc;
ASSERT(((uintptr_t)addr & (lpsize - 1)) == 0);
for (pa = addr, i = 0; i < nlpages; i++, pa += lpsize) {
if ((pp = page_create_func(pa, lpsize, vmflag, pcarg)) == NULL)
goto fail_page_create;
page_list_concat(&pplist, &pp);
}
while ((rootpp = pplist) != NULL) {
for (i = 0; i < nbpages; i++) {
ASSERT(pplist != NULL);
pp = pplist;
page_sub(&pplist, pp);
ASSERT(page_iolock_assert(pp));
page_io_unlock(pp);
ppa[i] = pp;
}
hat_memload_array(kas.a_hat,
(caddr_t)(uintptr_t)rootpp->p_offset, lpsize,
ppa, (PROT_ALL & ~PROT_USER) | HAT_NOSYNC | attr,
HAT_LOAD_LOCK);
for (--i; i >= 0; --i) {
ppa[i]->p_lckcnt = 1;
page_unlock(ppa[i]);
}
}
vmem_free(segkmem_ppa_arena, ppa, ppasize);
return (addr);
fail_page_create:
while ((rootpp = pplist) != NULL) {
for (i = 0, pp = pplist; i < nbpages; i++, pp = pplist) {
ASSERT(pp != NULL);
page_sub(&pplist, pp);
ASSERT(page_iolock_assert(pp));
page_io_unlock(pp);
}
page_destroy_pages(rootpp);
}
if (inaddr == NULL)
vmem_free(vmp, addr, size);
fail_vmem_alloc:
vmem_free(segkmem_ppa_arena, ppa, ppasize);
fail_array_alloc:
page_unresv(npages);
return (NULL);
}
static void
segkmem_free_one_lp(caddr_t addr, size_t size)
{
page_t *pp, *rootpp = NULL;
pgcnt_t pgs_left = btopr(size);
ASSERT(size == segkmem_lpsize);
hat_unload(kas.a_hat, addr, size, HAT_UNLOAD_UNLOCK);
for (; pgs_left > 0; addr += PAGESIZE, pgs_left--) {
pp = page_lookup(&kvp, (u_offset_t)(uintptr_t)addr, SE_EXCL);
if (pp == NULL)
panic("segkmem_free_one_lp: page not found");
ASSERT(PAGE_EXCL(pp));
pp->p_lckcnt = 0;
if (rootpp == NULL)
rootpp = pp;
}
ASSERT(rootpp != NULL);
page_destroy_pages(rootpp);
}
#endif
void *
segkmem_alloc_lp(vmem_t *vmp, size_t *sizep, size_t align, int vmflag)
{
size_t size;
kthread_t *t = curthread;
segkmem_lpcb_t *lpcb = &segkmem_lpcb;
ASSERT(sizep != NULL);
size = *sizep;
if (lpcb->lp_uselp && !(t->t_flag & T_PANIC) &&
!(vmflag & SEGKMEM_SHARELOCKED)) {
size_t kmemlp_qnt = segkmem_kmemlp_quantum;
size_t asize = P2ROUNDUP(size, kmemlp_qnt);
void *addr = NULL;
ulong_t *lpthrtp = &lpcb->lp_throttle;
ulong_t lpthrt = *lpthrtp;
int dowakeup = 0;
int doalloc = 1;
ASSERT(kmem_lp_arena != NULL);
ASSERT(asize >= size);
if (lpthrt != 0) {
lpthrt = atomic_inc_ulong_nv(lpthrtp);
if (lpthrt >= segkmem_lpthrottle_max) {
lpthrt = atomic_cas_ulong(lpthrtp, lpthrt,
segkmem_lpthrottle_max / 4);
}
if (lpthrt > segkmem_lpthrottle_start &&
!ISP2(lpthrt)) {
lpcb->allocs_throttled++;
lpthrt--;
if (ISP2(lpthrt))
kmem_reap();
return (segkmem_alloc(vmp, size, vmflag));
}
}
if (!(vmflag & VM_NOSLEEP) &&
segkmem_heaplp_quantum >= (8 * kmemlp_qnt) &&
vmem_size(kmem_lp_arena, VMEM_FREE) <= kmemlp_qnt &&
asize < (segkmem_heaplp_quantum - kmemlp_qnt)) {
mutex_enter(&lpcb->lp_lock);
if (lpcb->lp_wait) {
cv_wait(&lpcb->lp_cv, &lpcb->lp_lock);
if (vmem_size(kmem_lp_arena, VMEM_FREE) <
kmemlp_qnt) {
doalloc = 0;
}
} else if (vmem_size(kmem_lp_arena, VMEM_FREE) <=
kmemlp_qnt) {
if (asize == kmemlp_qnt)
asize += kmemlp_qnt;
dowakeup = 1;
lpcb->lp_wait = 1;
}
mutex_exit(&lpcb->lp_lock);
}
if (doalloc) {
addr = vmem_alloc(kmem_lp_arena, asize,
(vmflag | VM_ABORT) & ~VM_PANIC);
if (dowakeup) {
mutex_enter(&lpcb->lp_lock);
ASSERT(lpcb->lp_wait != 0);
lpcb->lp_wait = 0;
cv_broadcast(&lpcb->lp_cv);
mutex_exit(&lpcb->lp_lock);
}
}
if (addr != NULL) {
*sizep = asize;
*lpthrtp = 0;
return (addr);
}
if (vmflag & VM_NOSLEEP)
lpcb->nosleep_allocs_failed++;
else
lpcb->sleep_allocs_failed++;
lpcb->alloc_bytes_failed += size;
if (segkmem_use_lpthrottle && lpthrt == 0) {
lpthrt = atomic_cas_ulong(lpthrtp, lpthrt, 1);
}
}
return (segkmem_alloc(vmp, size, vmflag));
}
void
segkmem_free_lp(vmem_t *vmp, void *inaddr, size_t size)
{
if (kmem_lp_arena == NULL || !IS_KMEM_VA_LARGEPAGE((caddr_t)inaddr)) {
segkmem_free(vmp, inaddr, size);
} else {
vmem_free(kmem_lp_arena, inaddr, size);
}
}
#ifdef __sparc
static void *
segkmem_alloc_lpi(vmem_t *vmp, size_t size, int vmflag)
{
segkmem_lpcb_t *lpcb = &segkmem_lpcb;
void *addr;
ASSERT(size != 0);
ASSERT(vmp == heap_lp_arena);
if (vmem_size(vmp, VMEM_ALLOC) >= segkmem_kmemlp_max) {
lpcb->allocs_limited++;
return (NULL);
}
addr = segkmem_xalloc_lp(vmp, NULL, size, vmflag, 0,
segkmem_page_create_large, NULL);
return (addr);
}
static void
segkmem_free_lpi(vmem_t *vmp, void *inaddr, size_t size)
{
pgcnt_t nlpages = size >> segkmem_lpshift;
size_t lpsize = segkmem_lpsize;
caddr_t addr = inaddr;
pgcnt_t npages = btopr(size);
int i;
ASSERT(vmp == heap_lp_arena);
ASSERT(IS_KMEM_VA_LARGEPAGE(addr));
ASSERT(((uintptr_t)inaddr & (lpsize - 1)) == 0);
for (i = 0; i < nlpages; i++) {
segkmem_free_one_lp(addr, lpsize);
addr += lpsize;
}
page_unresv(npages);
vmem_free(vmp, inaddr, size);
}
#endif
int
segkmem_lpsetup()
{
int use_large_pages = 0;
#ifdef __sparc
size_t memtotal = physmem * PAGESIZE;
if (heap_lp_base == NULL) {
segkmem_lpsize = PAGESIZE;
return (0);
}
segkmem_lpsize = get_segkmem_lpsize(segkmem_lpsize);
if (segkmem_lpsize <= PAGESIZE) {
vmem_xfree(heap_arena, heap_lp_base,
heap_lp_end - heap_lp_base);
heap_lp_base = NULL;
heap_lp_end = NULL;
segkmem_lpsize = PAGESIZE;
return (0);
}
if (segkmem_heaplp_quantum == 0 || !ISP2(segkmem_heaplp_quantum) ||
P2PHASE(segkmem_heaplp_quantum, segkmem_lpsize)) {
segkmem_heaplp_quantum = segkmem_lpsize;
}
if (segkmem_kmemlp_quantum == 0 || !ISP2(segkmem_kmemlp_quantum) ||
segkmem_kmemlp_quantum > segkmem_heaplp_quantum) {
segkmem_kmemlp_quantum = segkmem_heaplp_quantum;
}
if (segkmem_kmemlp_max == 0) {
if (segkmem_kmemlp_pcnt == 0 || segkmem_kmemlp_pcnt > 100)
segkmem_kmemlp_pcnt = 12;
segkmem_kmemlp_max = (memtotal * segkmem_kmemlp_pcnt) / 100;
}
segkmem_kmemlp_max = P2ROUNDUP(segkmem_kmemlp_max,
segkmem_heaplp_quantum);
if (segkmem_kmemlp_min) {
segkmem_kmemlp_min = P2ROUNDUP(segkmem_kmemlp_min,
segkmem_heaplp_quantum);
if (segkmem_kmemlp_min > segkmem_kmemlp_max)
segkmem_kmemlp_min = segkmem_kmemlp_max;
}
use_large_pages = 1;
segkmem_lpszc = page_szc(segkmem_lpsize);
segkmem_lpshift = page_get_shift(segkmem_lpszc);
#endif
return (use_large_pages);
}
void
segkmem_zio_init(void *zio_mem_base, size_t zio_mem_size)
{
ASSERT(zio_mem_base != NULL);
ASSERT(zio_mem_size != 0);
zio_arena = vmem_create("zfs_file_data", zio_mem_base, zio_mem_size,
PAGESIZE, NULL, NULL, NULL, 32 * 1024, VM_SLEEP);
zio_alloc_arena = vmem_create("zfs_file_data_buf", NULL, 0, PAGESIZE,
segkmem_zio_alloc, segkmem_zio_free, zio_arena, 0, VM_SLEEP);
ASSERT(zio_arena != NULL);
ASSERT(zio_alloc_arena != NULL);
}
#if defined(__amd64)
void
segkmem_kvmm_init(void *base, size_t size)
{
ASSERT(base != NULL);
ASSERT(size != 0);
kvmm_arena = vmem_create("kvmm_arena", base, size, 1024 * 1024,
NULL, NULL, NULL, 0, VM_SLEEP);
ASSERT(kvmm_arena != NULL);
}
#elif defined(__sparc)
static void *
segkmem_alloc_ppa(vmem_t *vmp, size_t size, int vmflag)
{
size_t ppaquantum = btopr(segkmem_lpsize) * sizeof (page_t *);
void *addr;
if (ppaquantum <= PAGESIZE)
return (segkmem_alloc(vmp, size, vmflag));
ASSERT((size & (ppaquantum - 1)) == 0);
addr = vmem_xalloc(vmp, size, ppaquantum, 0, 0, NULL, NULL, vmflag);
if (addr != NULL && segkmem_xalloc(vmp, addr, size, vmflag, 0,
segkmem_page_create, NULL) == NULL) {
vmem_xfree(vmp, addr, size);
addr = NULL;
}
return (addr);
}
static void
segkmem_free_ppa(vmem_t *vmp, void *addr, size_t size)
{
size_t ppaquantum = btopr(segkmem_lpsize) * sizeof (page_t *);
ASSERT(addr != NULL);
if (ppaquantum <= PAGESIZE) {
segkmem_free(vmp, addr, size);
} else {
segkmem_free(NULL, addr, size);
vmem_xfree(vmp, addr, size);
}
}
void
segkmem_heap_lp_init()
{
segkmem_lpcb_t *lpcb = &segkmem_lpcb;
size_t heap_lp_size = heap_lp_end - heap_lp_base;
size_t lpsize = segkmem_lpsize;
size_t ppaquantum;
void *addr;
if (segkmem_lpsize <= PAGESIZE) {
ASSERT(heap_lp_base == NULL);
ASSERT(heap_lp_end == NULL);
return;
}
ASSERT(segkmem_heaplp_quantum >= lpsize);
ASSERT((segkmem_heaplp_quantum & (lpsize - 1)) == 0);
ASSERT(lpcb->lp_uselp == 0);
ASSERT(heap_lp_base != NULL);
ASSERT(heap_lp_end != NULL);
ASSERT(heap_lp_base < heap_lp_end);
ASSERT(heap_lp_arena == NULL);
ASSERT(((uintptr_t)heap_lp_base & (lpsize - 1)) == 0);
ASSERT(((uintptr_t)heap_lp_end & (lpsize - 1)) == 0);
heap_lp_arena = vmem_create("heap_lp", heap_lp_base, heap_lp_size,
segkmem_heaplp_quantum, NULL, NULL, NULL, 0, VM_SLEEP);
ASSERT(heap_lp_arena != NULL);
kmem_lp_arena = vmem_create("kmem_lp", NULL, 0, segkmem_kmemlp_quantum,
segkmem_alloc_lpi, segkmem_free_lpi, heap_lp_arena, 0, VM_SLEEP);
ASSERT(kmem_lp_arena != NULL);
mutex_init(&lpcb->lp_lock, NULL, MUTEX_DEFAULT, NULL);
cv_init(&lpcb->lp_cv, NULL, CV_DEFAULT, NULL);
ppaquantum = btopr(lpsize) * sizeof (page_t *);
segkmem_ppa_arena = vmem_create("segkmem_ppa", NULL, 0, ppaquantum,
segkmem_alloc_ppa, segkmem_free_ppa, heap_arena, ppaquantum,
VM_SLEEP);
ASSERT(segkmem_ppa_arena != NULL);
if (segkmem_kmemlp_min) {
ASSERT(P2PHASE(segkmem_kmemlp_min,
segkmem_heaplp_quantum) == 0);
if ((addr = segkmem_alloc_lpi(heap_lp_arena,
segkmem_kmemlp_min, VM_SLEEP)) != NULL) {
addr = vmem_add(kmem_lp_arena, addr,
segkmem_kmemlp_min, VM_SLEEP);
ASSERT(addr != NULL);
}
}
lpcb->lp_uselp = 1;
}
#endif