#include <sys/types.h>
#include <sys/param.h>
#include <sys/t_lock.h>
#include <sys/errno.h>
#include <sys/systm.h>
#include <sys/mman.h>
#include <sys/debug.h>
#include <sys/cred.h>
#include <sys/vmsystm.h>
#include <sys/tuneable.h>
#include <sys/bitmap.h>
#include <sys/swap.h>
#include <sys/kmem.h>
#include <sys/sysmacros.h>
#include <sys/vtrace.h>
#include <sys/cmn_err.h>
#include <sys/callb.h>
#include <sys/vm.h>
#include <sys/dumphdr.h>
#include <sys/lgrp.h>
#include <vm/hat.h>
#include <vm/as.h>
#include <vm/seg.h>
#include <vm/seg_vn.h>
#include <vm/pvn.h>
#include <vm/anon.h>
#include <vm/page.h>
#include <vm/vpage.h>
#include <sys/proc.h>
#include <sys/task.h>
#include <sys/project.h>
#include <sys/zone.h>
#include <sys/shm_impl.h>
#define PVN_MAX_GETPAGE_SZ 0x10000
#define PVN_MAX_GETPAGE_NUM 0x8
#if PVN_MAX_GETPAGE_SZ > PVN_MAX_GETPAGE_NUM * PAGESIZE
#define PVN_GETPAGE_SZ ptob(PVN_MAX_GETPAGE_NUM)
#define PVN_GETPAGE_NUM PVN_MAX_GETPAGE_NUM
#else
#define PVN_GETPAGE_SZ PVN_MAX_GETPAGE_SZ
#define PVN_GETPAGE_NUM btop(PVN_MAX_GETPAGE_SZ)
#endif
static int segvn_dup(struct seg *seg, struct seg *newseg);
static int segvn_unmap(struct seg *seg, caddr_t addr, size_t len);
static void segvn_free(struct seg *seg);
static faultcode_t segvn_fault(struct hat *hat, struct seg *seg,
caddr_t addr, size_t len, enum fault_type type,
enum seg_rw rw);
static faultcode_t segvn_faulta(struct seg *seg, caddr_t addr);
static int segvn_setprot(struct seg *seg, caddr_t addr,
size_t len, uint_t prot);
static int segvn_checkprot(struct seg *seg, caddr_t addr,
size_t len, uint_t prot);
static int segvn_kluster(struct seg *seg, caddr_t addr, ssize_t delta);
static size_t segvn_swapout(struct seg *seg);
static int segvn_sync(struct seg *seg, caddr_t addr, size_t len,
int attr, uint_t flags);
static size_t segvn_incore(struct seg *seg, caddr_t addr, size_t len,
char *vec);
static int segvn_lockop(struct seg *seg, caddr_t addr, size_t len,
int attr, int op, ulong_t *lockmap, size_t pos);
static int segvn_getprot(struct seg *seg, caddr_t addr, size_t len,
uint_t *protv);
static u_offset_t segvn_getoffset(struct seg *seg, caddr_t addr);
static int segvn_gettype(struct seg *seg, caddr_t addr);
static int segvn_getvp(struct seg *seg, caddr_t addr,
struct vnode **vpp);
static int segvn_advise(struct seg *seg, caddr_t addr, size_t len,
uint_t behav);
static void segvn_dump(struct seg *seg);
static int segvn_pagelock(struct seg *seg, caddr_t addr, size_t len,
struct page ***ppp, enum lock_type type, enum seg_rw rw);
static int segvn_setpagesize(struct seg *seg, caddr_t addr, size_t len,
uint_t szc);
static int segvn_getmemid(struct seg *seg, caddr_t addr,
memid_t *memidp);
static lgrp_mem_policy_info_t *segvn_getpolicy(struct seg *, caddr_t);
static int segvn_capable(struct seg *seg, segcapability_t capable);
static int segvn_inherit(struct seg *, caddr_t, size_t, uint_t);
struct seg_ops segvn_ops = {
segvn_dup,
segvn_unmap,
segvn_free,
segvn_fault,
segvn_faulta,
segvn_setprot,
segvn_checkprot,
segvn_kluster,
segvn_swapout,
segvn_sync,
segvn_incore,
segvn_lockop,
segvn_getprot,
segvn_getoffset,
segvn_gettype,
segvn_getvp,
segvn_advise,
segvn_dump,
segvn_pagelock,
segvn_setpagesize,
segvn_getmemid,
segvn_getpolicy,
segvn_capable,
segvn_inherit
};
static segvn_crargs_t zfod_segvn_crargs =
SEGVN_ZFOD_ARGS(PROT_ZFOD, PROT_ALL);
static segvn_crargs_t kzfod_segvn_crargs =
SEGVN_ZFOD_ARGS(PROT_ZFOD & ~PROT_USER,
PROT_ALL & ~PROT_USER);
static segvn_crargs_t stack_noexec_crargs =
SEGVN_ZFOD_ARGS(PROT_ZFOD & ~PROT_EXEC, PROT_ALL);
caddr_t zfod_argsp = (caddr_t)&zfod_segvn_crargs;
caddr_t kzfod_argsp = (caddr_t)&kzfod_segvn_crargs;
caddr_t stack_exec_argsp = (caddr_t)&zfod_segvn_crargs;
caddr_t stack_noexec_argsp = (caddr_t)&stack_noexec_crargs;
#define vpgtob(n) ((n) * sizeof (struct vpage))
size_t segvn_comb_thrshld = UINT_MAX;
size_t segvn_pglock_comb_thrshld = (1UL << 16);
size_t segvn_pglock_comb_balign = (1UL << 16);
uint_t segvn_pglock_comb_bshift;
size_t segvn_pglock_comb_palign;
static int segvn_concat(struct seg *, struct seg *, int);
static int segvn_extend_prev(struct seg *, struct seg *,
struct segvn_crargs *, size_t);
static int segvn_extend_next(struct seg *, struct seg *,
struct segvn_crargs *, size_t);
static void segvn_softunlock(struct seg *, caddr_t, size_t, enum seg_rw);
static void segvn_pagelist_rele(page_t **);
static void segvn_setvnode_mpss(vnode_t *);
static void segvn_relocate_pages(page_t **, page_t *);
static int segvn_full_szcpages(page_t **, uint_t, int *, uint_t *);
static int segvn_fill_vp_pages(struct segvn_data *, vnode_t *, u_offset_t,
uint_t, page_t **, page_t **, uint_t *, int *);
static faultcode_t segvn_fault_vnodepages(struct hat *, struct seg *, caddr_t,
caddr_t, enum fault_type, enum seg_rw, caddr_t, caddr_t, int);
static faultcode_t segvn_fault_anonpages(struct hat *, struct seg *, caddr_t,
caddr_t, enum fault_type, enum seg_rw, caddr_t, caddr_t, int);
static faultcode_t segvn_faultpage(struct hat *, struct seg *, caddr_t,
u_offset_t, struct vpage *, page_t **, uint_t,
enum fault_type, enum seg_rw, int);
static void segvn_vpage(struct seg *);
static size_t segvn_count_swap_by_vpages(struct seg *);
static void segvn_purge(struct seg *seg);
static int segvn_reclaim(void *, caddr_t, size_t, struct page **,
enum seg_rw, int);
static int shamp_reclaim(void *, caddr_t, size_t, struct page **,
enum seg_rw, int);
static int sameprot(struct seg *, caddr_t, size_t);
static int segvn_demote_range(struct seg *, caddr_t, size_t, int, uint_t);
static int segvn_clrszc(struct seg *);
static struct seg *segvn_split_seg(struct seg *, caddr_t);
static int segvn_claim_pages(struct seg *, struct vpage *, u_offset_t,
ulong_t, uint_t);
static void segvn_hat_rgn_unload_callback(caddr_t, caddr_t, caddr_t,
size_t, void *, u_offset_t);
static struct kmem_cache *segvn_cache;
static struct kmem_cache **segvn_szc_cache;
#ifdef VM_STATS
static struct segvnvmstats_str {
ulong_t fill_vp_pages[31];
ulong_t fltvnpages[49];
ulong_t fullszcpages[10];
ulong_t relocatepages[3];
ulong_t fltanpages[17];
ulong_t pagelock[2];
ulong_t demoterange[3];
} segvnvmstats;
#endif
#define SDR_RANGE 1
#define SDR_END 2
#define CALC_LPG_REGION(pgsz, seg, addr, len, lpgaddr, lpgeaddr) { \
if ((len) != 0) { \
lpgaddr = (caddr_t)P2ALIGN((uintptr_t)(addr), pgsz); \
ASSERT(lpgaddr >= (seg)->s_base); \
lpgeaddr = (caddr_t)P2ROUNDUP((uintptr_t)((addr) + \
(len)), pgsz); \
ASSERT(lpgeaddr > lpgaddr); \
ASSERT(lpgeaddr <= (seg)->s_base + (seg)->s_size); \
} else { \
lpgeaddr = lpgaddr = (addr); \
} \
}
static int
segvn_cache_constructor(void *buf, void *cdrarg, int kmflags)
{
struct segvn_data *svd = buf;
rw_init(&svd->lock, NULL, RW_DEFAULT, NULL);
mutex_init(&svd->segfree_syncmtx, NULL, MUTEX_DEFAULT, NULL);
svd->svn_trnext = svd->svn_trprev = NULL;
return (0);
}
static void
segvn_cache_destructor(void *buf, void *cdrarg)
{
struct segvn_data *svd = buf;
rw_destroy(&svd->lock);
mutex_destroy(&svd->segfree_syncmtx);
}
static int
svntr_cache_constructor(void *buf, void *cdrarg, int kmflags)
{
bzero(buf, sizeof (svntr_t));
return (0);
}
int noexec_user_stack = 0;
int noexec_user_stack_log = 1;
int segvn_lpg_disable = 0;
uint_t segvn_maxpgszc = 0;
ulong_t segvn_vmpss_clrszc_cnt;
ulong_t segvn_vmpss_clrszc_err;
ulong_t segvn_fltvnpages_clrszc_cnt;
ulong_t segvn_fltvnpages_clrszc_err;
ulong_t segvn_setpgsz_align_err;
ulong_t segvn_setpgsz_anon_align_err;
ulong_t segvn_setpgsz_getattr_err;
ulong_t segvn_setpgsz_eof_err;
ulong_t segvn_faultvnmpss_align_err1;
ulong_t segvn_faultvnmpss_align_err2;
ulong_t segvn_faultvnmpss_align_err3;
ulong_t segvn_faultvnmpss_align_err4;
ulong_t segvn_faultvnmpss_align_err5;
ulong_t segvn_vmpss_pageio_deadlk_err;
int segvn_use_regions = 1;
#define SEGVN_TEXTREPL_MAXBYTES_FACTOR (20)
size_t segvn_textrepl_max_bytes_factor = SEGVN_TEXTREPL_MAXBYTES_FACTOR;
static ulong_t svntr_hashtab_sz = 512;
static svntr_bucket_t *svntr_hashtab = NULL;
static struct kmem_cache *svntr_cache;
static svntr_stats_t *segvn_textrepl_stats;
static ksema_t segvn_trasync_sem;
int segvn_disable_textrepl = 1;
size_t textrepl_size_thresh = (size_t)-1;
size_t segvn_textrepl_bytes = 0;
size_t segvn_textrepl_max_bytes = 0;
clock_t segvn_update_textrepl_interval = 0;
int segvn_update_tr_time = 10;
int segvn_disable_textrepl_update = 0;
static void segvn_textrepl(struct seg *);
static void segvn_textunrepl(struct seg *, int);
static void segvn_inval_trcache(vnode_t *);
static void segvn_trasync_thread(void);
static void segvn_trupdate_wakeup(void *);
static void segvn_trupdate(void);
static void segvn_trupdate_seg(struct seg *, segvn_data_t *, svntr_t *,
ulong_t);
void
segvn_init(void)
{
uint_t maxszc;
uint_t szc;
size_t pgsz;
segvn_cache = kmem_cache_create("segvn_cache",
sizeof (struct segvn_data), 0,
segvn_cache_constructor, segvn_cache_destructor, NULL,
NULL, NULL, 0);
if (segvn_lpg_disable == 0) {
szc = maxszc = page_num_pagesizes() - 1;
if (szc == 0) {
segvn_lpg_disable = 1;
}
if (page_get_pagesize(0) != PAGESIZE) {
panic("segvn_init: bad szc 0");
}
while (szc != 0) {
pgsz = page_get_pagesize(szc);
if (pgsz <= PAGESIZE || !IS_P2ALIGNED(pgsz, pgsz)) {
panic("segvn_init: bad szc %d", szc);
}
szc--;
}
if (segvn_maxpgszc == 0 || segvn_maxpgszc > maxszc)
segvn_maxpgszc = maxszc;
}
if (segvn_maxpgszc) {
segvn_szc_cache = (struct kmem_cache **)kmem_alloc(
(segvn_maxpgszc + 1) * sizeof (struct kmem_cache *),
KM_SLEEP);
}
for (szc = 1; szc <= segvn_maxpgszc; szc++) {
char str[32];
(void) sprintf(str, "segvn_szc_cache%d", szc);
segvn_szc_cache[szc] = kmem_cache_create(str,
page_get_pagecnt(szc) * sizeof (page_t *), 0,
NULL, NULL, NULL, NULL, NULL, KMC_NODEBUG);
}
if (segvn_use_regions && !hat_supported(HAT_SHARED_REGIONS, NULL))
segvn_use_regions = 0;
if (segvn_use_regions && !segvn_disable_textrepl) {
segvn_disable_textrepl = 1;
}
#if defined(_LP64)
if (lgrp_optimizations() && textrepl_size_thresh != (size_t)-1 &&
!segvn_disable_textrepl) {
ulong_t i;
size_t hsz = svntr_hashtab_sz * sizeof (svntr_bucket_t);
svntr_cache = kmem_cache_create("svntr_cache",
sizeof (svntr_t), 0, svntr_cache_constructor, NULL,
NULL, NULL, NULL, 0);
svntr_hashtab = kmem_zalloc(hsz, KM_SLEEP);
for (i = 0; i < svntr_hashtab_sz; i++) {
mutex_init(&svntr_hashtab[i].tr_lock, NULL,
MUTEX_DEFAULT, NULL);
}
segvn_textrepl_max_bytes = ptob(physmem) /
segvn_textrepl_max_bytes_factor;
segvn_textrepl_stats = kmem_zalloc(NCPU *
sizeof (svntr_stats_t), KM_SLEEP);
sema_init(&segvn_trasync_sem, 0, NULL, SEMA_DEFAULT, NULL);
(void) thread_create(NULL, 0, segvn_trasync_thread,
NULL, 0, &p0, TS_RUN, minclsyspri);
}
#endif
if (!ISP2(segvn_pglock_comb_balign) ||
segvn_pglock_comb_balign < PAGESIZE) {
segvn_pglock_comb_balign = 1UL << 16;
}
segvn_pglock_comb_bshift = highbit(segvn_pglock_comb_balign) - 1;
segvn_pglock_comb_palign = btop(segvn_pglock_comb_balign);
}
#define SEGVN_PAGEIO ((void *)0x1)
#define SEGVN_NOPAGEIO ((void *)0x2)
static void
segvn_setvnode_mpss(vnode_t *vp)
{
int err;
ASSERT(vp->v_mpssdata == NULL ||
vp->v_mpssdata == SEGVN_PAGEIO ||
vp->v_mpssdata == SEGVN_NOPAGEIO);
if (vp->v_mpssdata == NULL) {
if (vn_vmpss_usepageio(vp)) {
err = VOP_PAGEIO(vp, (page_t *)NULL,
(u_offset_t)0, 0, 0, CRED(), NULL);
} else {
err = ENOSYS;
}
mutex_enter(&vp->v_lock);
if (vp->v_mpssdata == NULL) {
if (err == EINVAL) {
vp->v_mpssdata = SEGVN_PAGEIO;
} else {
vp->v_mpssdata = SEGVN_NOPAGEIO;
}
}
mutex_exit(&vp->v_lock);
}
}
int
segvn_create(struct seg **segpp, void *argsp)
{
struct seg *seg = *segpp;
extern lgrp_mem_policy_t lgrp_mem_default_policy;
struct segvn_crargs *a = (struct segvn_crargs *)argsp;
struct segvn_data *svd;
size_t swresv = 0;
struct cred *cred;
struct anon_map *amp;
int error = 0;
size_t pgsz;
lgrp_mem_policy_t mpolicy = lgrp_mem_default_policy;
int use_rgn = 0;
int trok = 0;
ASSERT(seg->s_as && AS_WRITE_HELD(seg->s_as));
if (a->type != MAP_PRIVATE && a->type != MAP_SHARED) {
panic("segvn_create type");
}
if (a->amp != NULL && a->vp != NULL) {
panic("segvn_create anon_map");
}
if (a->type == MAP_PRIVATE && (a->flags & MAP_TEXT) &&
a->vp != NULL && a->prot == (PROT_USER | PROT_READ | PROT_EXEC) &&
segvn_use_regions) {
use_rgn = 1;
}
if (a->type == MAP_SHARED)
a->flags &= ~MAP_NORESERVE;
if (a->szc != 0) {
if (segvn_lpg_disable != 0 || (a->szc == AS_MAP_NO_LPOOB) ||
(a->amp != NULL && a->type == MAP_PRIVATE) ||
(a->flags & MAP_NORESERVE) || seg->s_as == &kas) {
a->szc = 0;
} else {
if (a->szc > segvn_maxpgszc)
a->szc = segvn_maxpgszc;
pgsz = page_get_pagesize(a->szc);
if (!IS_P2ALIGNED(seg->s_base, pgsz) ||
!IS_P2ALIGNED(seg->s_size, pgsz)) {
a->szc = 0;
} else if (a->vp != NULL) {
if (IS_SWAPFSVP(a->vp) || VN_ISKAS(a->vp)) {
a->szc = 0;
} else if (map_addr_vacalign_check(seg->s_base,
a->offset & PAGEMASK)) {
a->szc = 0;
}
} else if (a->amp != NULL) {
pgcnt_t anum = btopr(a->offset);
pgcnt_t pgcnt = page_get_pagecnt(a->szc);
if (!IS_P2ALIGNED(anum, pgcnt)) {
a->szc = 0;
}
}
}
}
if (!(a->flags & MAP_NORESERVE) && ((a->vp == NULL && a->amp == NULL) ||
(a->type == MAP_PRIVATE && (a->prot & PROT_WRITE)))) {
if (anon_resv_zone(seg->s_size,
seg->s_as->a_proc->p_zone) == 0)
return (EAGAIN);
swresv = seg->s_size;
TRACE_3(TR_FAC_VM, TR_ANON_PROC, "anon proc:%p %lu %u",
seg, swresv, 1);
}
if (!use_rgn) {
hat_map(seg->s_as->a_hat, seg->s_base, seg->s_size, HAT_MAP);
}
if (a->cred) {
cred = a->cred;
crhold(cred);
} else {
crhold(cred = CRED());
}
if (a->vp != NULL) {
error = VOP_ADDMAP(a->vp, a->offset & PAGEMASK,
seg->s_as, seg->s_base, seg->s_size, a->prot,
a->maxprot, a->type, cred, NULL);
if (error) {
if (swresv != 0) {
anon_unresv_zone(swresv,
seg->s_as->a_proc->p_zone);
TRACE_3(TR_FAC_VM, TR_ANON_PROC,
"anon proc:%p %lu %u", seg, swresv, 0);
}
crfree(cred);
if (!use_rgn) {
hat_unload(seg->s_as->a_hat, seg->s_base,
seg->s_size, HAT_UNLOAD_UNMAP);
}
return (error);
}
trok = ((a->flags & MAP_TEXT) &&
(seg->s_size > textrepl_size_thresh ||
(a->flags & _MAP_TEXTREPL)) &&
lgrp_optimizations() && svntr_hashtab != NULL &&
a->type == MAP_PRIVATE && swresv == 0 &&
!(a->flags & MAP_NORESERVE) &&
seg->s_as != &kas && a->vp->v_type == VREG);
ASSERT(!trok || !use_rgn);
}
if ((a->vp == NULL || a->vp->v_type != VREG) &&
a->flags & MAP_NORESERVE) {
seg->s_as->a_resvsize -= seg->s_size;
}
if (a->amp == NULL && !use_rgn && !trok) {
struct seg *pseg, *nseg;
struct segvn_data *psvd, *nsvd;
lgrp_mem_policy_t ppolicy, npolicy;
uint_t lgrp_mem_policy_flags = 0;
if ((a->vp == NULL) && (a->type == MAP_PRIVATE) &&
!(a->flags & MAP_NORESERVE) && (seg->s_as != &kas)) {
lgrp_mem_policy_flags = a->lgrp_mem_policy_flags;
} else {
mpolicy = lgrp_mem_policy_default(seg->s_size, a->type);
}
pseg = AS_SEGPREV(seg->s_as, seg);
if (pseg != NULL &&
pseg->s_base + pseg->s_size == seg->s_base &&
pseg->s_ops == &segvn_ops) {
psvd = (struct segvn_data *)pseg->s_data;
ppolicy = psvd->policy_info.mem_policy;
if (lgrp_mem_policy_flags ==
LGRP_MP_FLAG_EXTEND_UP) {
if (ppolicy != lgrp_mem_default_policy) {
mpolicy = ppolicy;
} else {
mpolicy = lgrp_mem_policy_default(
pseg->s_size + seg->s_size,
a->type);
}
}
if (mpolicy == ppolicy &&
(pseg->s_size + seg->s_size <=
segvn_comb_thrshld || psvd->amp == NULL) &&
segvn_extend_prev(pseg, seg, a, swresv) == 0) {
crfree(cred);
nseg = AS_SEGNEXT(pseg->s_as, pseg);
if (nseg != NULL &&
nseg != pseg &&
nseg->s_ops == &segvn_ops &&
pseg->s_base + pseg->s_size ==
nseg->s_base)
(void) segvn_concat(pseg, nseg, 0);
ASSERT(pseg->s_szc == 0 ||
(a->szc == pseg->s_szc &&
IS_P2ALIGNED(pseg->s_base, pgsz) &&
IS_P2ALIGNED(pseg->s_size, pgsz)));
*segpp = pseg;
return (0);
}
}
nseg = AS_SEGNEXT(seg->s_as, seg);
if (nseg != NULL &&
seg->s_base + seg->s_size == nseg->s_base &&
nseg->s_ops == &segvn_ops) {
nsvd = (struct segvn_data *)nseg->s_data;
npolicy = nsvd->policy_info.mem_policy;
if (lgrp_mem_policy_flags ==
LGRP_MP_FLAG_EXTEND_DOWN) {
if (npolicy != lgrp_mem_default_policy) {
mpolicy = npolicy;
} else {
mpolicy = lgrp_mem_policy_default(
nseg->s_size + seg->s_size,
a->type);
}
}
if (mpolicy == npolicy &&
segvn_extend_next(seg, nseg, a, swresv) == 0) {
crfree(cred);
ASSERT(nseg->s_szc == 0 ||
(a->szc == nseg->s_szc &&
IS_P2ALIGNED(nseg->s_base, pgsz) &&
IS_P2ALIGNED(nseg->s_size, pgsz)));
*segpp = nseg;
return (0);
}
}
}
if (a->vp != NULL) {
VN_HOLD(a->vp);
if (a->type == MAP_SHARED)
lgrp_shm_policy_init(NULL, a->vp);
}
svd = kmem_cache_alloc(segvn_cache, KM_SLEEP);
seg->s_ops = &segvn_ops;
seg->s_data = (void *)svd;
seg->s_szc = a->szc;
svd->seg = seg;
svd->vp = a->vp;
svd->offset = a->vp ? (a->offset & PAGEMASK) : 0;
svd->prot = a->prot;
svd->maxprot = a->maxprot;
svd->pageprot = 0;
svd->type = a->type;
svd->vpage = NULL;
svd->cred = cred;
svd->advice = MADV_NORMAL;
svd->pageadvice = 0;
svd->flags = (ushort_t)a->flags;
svd->softlockcnt = 0;
svd->softlockcnt_sbase = 0;
svd->softlockcnt_send = 0;
svd->svn_inz = 0;
svd->rcookie = HAT_INVALID_REGION_COOKIE;
svd->pageswap = 0;
if (a->szc != 0 && a->vp != NULL) {
segvn_setvnode_mpss(a->vp);
}
if (svd->type == MAP_SHARED && svd->vp != NULL &&
(svd->vp->v_flag & VVMEXEC) && (svd->prot & PROT_WRITE)) {
ASSERT(vn_is_mapped(svd->vp, V_WRITE));
segvn_inval_trcache(svd->vp);
}
amp = a->amp;
if ((svd->amp = amp) == NULL) {
svd->anon_index = 0;
if (svd->type == MAP_SHARED) {
svd->swresv = 0;
if (a->vp == NULL) {
svd->amp = anonmap_alloc(seg->s_size, swresv,
ANON_SLEEP);
svd->amp->a_szc = seg->s_szc;
}
} else {
svd->swresv = swresv;
}
} else {
pgcnt_t anon_num;
if ((amp->size - a->offset) < seg->s_size) {
panic("segvn_create anon_map size");
}
anon_num = btopr(a->offset);
if (a->type == MAP_SHARED) {
ANON_LOCK_ENTER(&->a_rwlock, RW_WRITER);
amp->refcnt++;
if (a->szc > amp->a_szc) {
amp->a_szc = a->szc;
}
ANON_LOCK_EXIT(&->a_rwlock);
svd->anon_index = anon_num;
svd->swresv = 0;
} else {
struct anon *ap;
caddr_t addr;
caddr_t eaddr;
ulong_t anon_idx;
int hat_flag = HAT_LOAD;
if (svd->flags & MAP_TEXT) {
hat_flag |= HAT_LOAD_TEXT;
}
svd->amp = anonmap_alloc(seg->s_size, 0, ANON_SLEEP);
svd->amp->a_szc = seg->s_szc;
svd->anon_index = 0;
svd->swresv = swresv;
ANON_LOCK_ENTER(&->a_rwlock, RW_WRITER);
eaddr = seg->s_base + seg->s_size;
for (anon_idx = anon_num, addr = seg->s_base;
addr < eaddr; addr += PAGESIZE, anon_idx++) {
page_t *pp;
if ((ap = anon_get_ptr(amp->ahp,
anon_idx)) != NULL)
continue;
pp = anon_zero(seg, addr, &ap, cred);
if (ap == NULL || pp == NULL) {
panic("segvn_create anon_zero");
}
ASSERT(anon_get_ptr(amp->ahp,
anon_idx) == NULL);
(void) anon_set_ptr(amp->ahp, anon_idx, ap,
ANON_SLEEP);
ASSERT(seg->s_szc == 0);
ASSERT(!IS_VMODSORT(pp->p_vnode));
ASSERT(use_rgn == 0);
hat_memload(seg->s_as->a_hat, addr, pp,
svd->prot & ~PROT_WRITE, hat_flag);
page_unlock(pp);
}
ASSERT(seg->s_szc == 0);
anon_dup(amp->ahp, anon_num, svd->amp->ahp,
0, seg->s_size);
ANON_LOCK_EXIT(&->a_rwlock);
}
}
(void) lgrp_privm_policy_set(mpolicy, &svd->policy_info, seg->s_size);
if (svd->type == MAP_SHARED)
(void) lgrp_shm_policy_set(mpolicy, svd->amp, svd->anon_index,
svd->vp, svd->offset, seg->s_size);
if (use_rgn) {
ASSERT(!trok);
ASSERT(svd->amp == NULL);
svd->rcookie = hat_join_region(seg->s_as->a_hat, seg->s_base,
seg->s_size, (void *)svd->vp, svd->offset, svd->prot,
(uchar_t)seg->s_szc, segvn_hat_rgn_unload_callback,
HAT_REGION_TEXT);
}
ASSERT(!trok || !(svd->prot & PROT_WRITE));
svd->tr_state = trok ? SEGVN_TR_INIT : SEGVN_TR_OFF;
return (0);
}
static int
segvn_concat(struct seg *seg1, struct seg *seg2, int amp_cat)
{
struct segvn_data *svd1 = seg1->s_data;
struct segvn_data *svd2 = seg2->s_data;
struct anon_map *amp1 = svd1->amp;
struct anon_map *amp2 = svd2->amp;
struct vpage *vpage1 = svd1->vpage;
struct vpage *vpage2 = svd2->vpage, *nvpage = NULL;
size_t size, nvpsize;
pgcnt_t npages1, npages2;
ASSERT(seg1->s_as && seg2->s_as && seg1->s_as == seg2->s_as);
ASSERT(AS_WRITE_HELD(seg1->s_as));
ASSERT(seg1->s_ops == seg2->s_ops);
if (HAT_IS_REGION_COOKIE_VALID(svd1->rcookie) ||
HAT_IS_REGION_COOKIE_VALID(svd2->rcookie)) {
return (-1);
}
#define incompat(x) (svd1->x != svd2->x)
if (incompat(vp) || incompat(maxprot) ||
(!svd1->pageadvice && !svd2->pageadvice && incompat(advice)) ||
(!svd1->pageprot && !svd2->pageprot && incompat(prot)) ||
incompat(type) || incompat(cred) || incompat(flags) ||
seg1->s_szc != seg2->s_szc || incompat(policy_info.mem_policy) ||
(svd2->softlockcnt > 0) || svd1->softlockcnt_send > 0)
return (-1);
#undef incompat
if (svd1->vp != NULL &&
svd1->offset + seg1->s_size != svd2->offset) {
return (-1);
}
if (svd1->tr_state != SEGVN_TR_OFF || svd2->tr_state != SEGVN_TR_OFF) {
return (-1);
}
if (amp_cat == 0 && (amp1 != NULL || amp2 != NULL)) {
return (-1);
}
if (svd1->vp == NULL && svd1->type == MAP_SHARED) {
if (amp1 != amp2) {
return (-1);
}
if (amp1 != NULL && svd1->anon_index + btop(seg1->s_size) !=
svd2->anon_index) {
return (-1);
}
ASSERT(amp1 == NULL || amp1->refcnt >= 2);
}
if (vpage1 != NULL || vpage2 != NULL) {
struct vpage *vp, *evp;
npages1 = seg_pages(seg1);
npages2 = seg_pages(seg2);
nvpsize = vpgtob(npages1 + npages2);
if ((nvpage = kmem_zalloc(nvpsize, KM_NOSLEEP)) == NULL) {
return (-2);
}
if (vpage1 != NULL) {
bcopy(vpage1, nvpage, vpgtob(npages1));
} else {
evp = nvpage + npages1;
for (vp = nvpage; vp < evp; vp++) {
VPP_SETPROT(vp, svd1->prot);
VPP_SETADVICE(vp, svd1->advice);
}
}
if (vpage2 != NULL) {
bcopy(vpage2, nvpage + npages1, vpgtob(npages2));
} else {
evp = nvpage + npages1 + npages2;
for (vp = nvpage + npages1; vp < evp; vp++) {
VPP_SETPROT(vp, svd2->prot);
VPP_SETADVICE(vp, svd2->advice);
}
}
if (svd2->pageswap && (!svd1->pageswap && svd1->swresv)) {
ASSERT(svd1->swresv == seg1->s_size);
ASSERT(!(svd1->flags & MAP_NORESERVE));
ASSERT(!(svd2->flags & MAP_NORESERVE));
evp = nvpage + npages1;
for (vp = nvpage; vp < evp; vp++) {
VPP_SETSWAPRES(vp);
}
}
if (svd1->pageswap && (!svd2->pageswap && svd2->swresv)) {
ASSERT(svd2->swresv == seg2->s_size);
ASSERT(!(svd1->flags & MAP_NORESERVE));
ASSERT(!(svd2->flags & MAP_NORESERVE));
vp = nvpage + npages1;
evp = vp + npages2;
for (; vp < evp; vp++) {
VPP_SETSWAPRES(vp);
}
}
}
ASSERT((vpage1 != NULL || vpage2 != NULL) ||
(svd1->pageswap == 0 && svd2->pageswap == 0));
if (amp1 != NULL && svd1->type == MAP_SHARED) {
ASSERT(amp1 == amp2 && svd1->vp == NULL);
ANON_LOCK_ENTER(&1->a_rwlock, RW_WRITER);
ASSERT(amp1->refcnt >= 2);
amp1->refcnt--;
ANON_LOCK_EXIT(&1->a_rwlock);
svd2->amp = NULL;
} else if (amp1 != NULL || amp2 != NULL) {
struct anon_hdr *nahp;
struct anon_map *namp = NULL;
size_t asize;
ASSERT(svd1->type == MAP_PRIVATE);
asize = seg1->s_size + seg2->s_size;
if ((nahp = anon_create(btop(asize), ANON_NOSLEEP)) == NULL) {
if (nvpage != NULL) {
kmem_free(nvpage, nvpsize);
}
return (-2);
}
if (amp1 != NULL) {
ANON_LOCK_ENTER(&1->a_rwlock, RW_WRITER);
ASSERT(amp1->refcnt == 1);
if (anon_copy_ptr(amp1->ahp, svd1->anon_index,
nahp, 0, btop(seg1->s_size), ANON_NOSLEEP)) {
anon_release(nahp, btop(asize));
ANON_LOCK_EXIT(&1->a_rwlock);
if (nvpage != NULL) {
kmem_free(nvpage, nvpsize);
}
return (-2);
}
}
if (amp2 != NULL) {
ANON_LOCK_ENTER(&2->a_rwlock, RW_WRITER);
ASSERT(amp2->refcnt == 1);
if (anon_copy_ptr(amp2->ahp, svd2->anon_index,
nahp, btop(seg1->s_size), btop(seg2->s_size),
ANON_NOSLEEP)) {
anon_release(nahp, btop(asize));
ANON_LOCK_EXIT(&2->a_rwlock);
if (amp1 != NULL) {
ANON_LOCK_EXIT(&1->a_rwlock);
}
if (nvpage != NULL) {
kmem_free(nvpage, nvpsize);
}
return (-2);
}
}
if (amp1 != NULL) {
namp = amp1;
anon_release(amp1->ahp, btop(amp1->size));
}
if (amp2 != NULL) {
if (namp == NULL) {
ASSERT(amp1 == NULL);
namp = amp2;
anon_release(amp2->ahp, btop(amp2->size));
} else {
amp2->refcnt--;
ANON_LOCK_EXIT(&2->a_rwlock);
anonmap_free(amp2);
}
svd2->amp = NULL;
}
namp->ahp = nahp;
namp->size = asize;
svd1->amp = namp;
svd1->anon_index = 0;
ANON_LOCK_EXIT(&namp->a_rwlock);
}
if (nvpage != NULL) {
if (vpage1 != NULL) {
kmem_free(vpage1, vpgtob(npages1));
}
if (vpage2 != NULL) {
svd2->vpage = NULL;
kmem_free(vpage2, vpgtob(npages2));
}
if (svd2->pageprot) {
svd1->pageprot = 1;
}
if (svd2->pageadvice) {
svd1->pageadvice = 1;
}
if (svd2->pageswap) {
svd1->pageswap = 1;
}
svd1->vpage = nvpage;
}
svd1->swresv += svd2->swresv;
svd2->swresv = 0;
size = seg2->s_size;
seg_free(seg2);
seg1->s_size += size;
return (0);
}
static int
segvn_extend_prev(struct seg *seg1, struct seg *seg2, struct segvn_crargs *a,
size_t swresv)
{
struct segvn_data *svd1 = (struct segvn_data *)seg1->s_data;
size_t size;
struct anon_map *amp1;
struct vpage *new_vpage;
ASSERT(seg1->s_as && AS_WRITE_HELD(seg1->s_as));
if (HAT_IS_REGION_COOKIE_VALID(svd1->rcookie)) {
return (-1);
}
if (svd1->vp != a->vp || svd1->maxprot != a->maxprot ||
(!svd1->pageprot && (svd1->prot != a->prot)) ||
svd1->type != a->type || svd1->flags != a->flags ||
seg1->s_szc != a->szc || svd1->softlockcnt_send > 0)
return (-1);
if (svd1->vp != NULL &&
svd1->offset + seg1->s_size != (a->offset & PAGEMASK))
return (-1);
if (svd1->tr_state != SEGVN_TR_OFF) {
return (-1);
}
amp1 = svd1->amp;
if (amp1) {
pgcnt_t newpgs;
if (svd1->type == MAP_SHARED)
return (-1);
ANON_LOCK_ENTER(&1->a_rwlock, RW_WRITER);
if (amp1->refcnt > 1) {
ANON_LOCK_EXIT(&1->a_rwlock);
return (-1);
}
newpgs = anon_grow(amp1->ahp, &svd1->anon_index,
btop(seg1->s_size), btop(seg2->s_size), ANON_NOSLEEP);
if (newpgs == 0) {
ANON_LOCK_EXIT(&1->a_rwlock);
return (-1);
}
amp1->size = ptob(newpgs);
ANON_LOCK_EXIT(&1->a_rwlock);
}
if (svd1->vpage != NULL) {
struct vpage *vp, *evp;
new_vpage =
kmem_zalloc(vpgtob(seg_pages(seg1) + seg_pages(seg2)),
KM_NOSLEEP);
if (new_vpage == NULL)
return (-1);
bcopy(svd1->vpage, new_vpage, vpgtob(seg_pages(seg1)));
kmem_free(svd1->vpage, vpgtob(seg_pages(seg1)));
svd1->vpage = new_vpage;
vp = new_vpage + seg_pages(seg1);
evp = vp + seg_pages(seg2);
for (; vp < evp; vp++)
VPP_SETPROT(vp, a->prot);
if (svd1->pageswap && swresv) {
ASSERT(!(svd1->flags & MAP_NORESERVE));
ASSERT(swresv == seg2->s_size);
vp = new_vpage + seg_pages(seg1);
for (; vp < evp; vp++) {
VPP_SETSWAPRES(vp);
}
}
}
ASSERT(svd1->vpage != NULL || svd1->pageswap == 0);
size = seg2->s_size;
seg_free(seg2);
seg1->s_size += size;
svd1->swresv += swresv;
if (svd1->pageprot && (a->prot & PROT_WRITE) &&
svd1->type == MAP_SHARED && svd1->vp != NULL &&
(svd1->vp->v_flag & VVMEXEC)) {
ASSERT(vn_is_mapped(svd1->vp, V_WRITE));
segvn_inval_trcache(svd1->vp);
}
return (0);
}
static int
segvn_extend_next(struct seg *seg1, struct seg *seg2, struct segvn_crargs *a,
size_t swresv)
{
struct segvn_data *svd2 = (struct segvn_data *)seg2->s_data;
size_t size;
struct anon_map *amp2;
struct vpage *new_vpage;
ASSERT(seg2->s_as && AS_WRITE_HELD(seg2->s_as));
if (HAT_IS_REGION_COOKIE_VALID(svd2->rcookie)) {
return (-1);
}
if (svd2->vp != a->vp || svd2->maxprot != a->maxprot ||
(!svd2->pageprot && (svd2->prot != a->prot)) ||
svd2->type != a->type || svd2->flags != a->flags ||
seg2->s_szc != a->szc || svd2->softlockcnt_sbase > 0)
return (-1);
if (svd2->vp != NULL &&
(a->offset & PAGEMASK) + seg1->s_size != svd2->offset)
return (-1);
if (svd2->tr_state != SEGVN_TR_OFF) {
return (-1);
}
amp2 = svd2->amp;
if (amp2) {
pgcnt_t newpgs;
if (svd2->type == MAP_SHARED)
return (-1);
ANON_LOCK_ENTER(&2->a_rwlock, RW_WRITER);
if (amp2->refcnt > 1) {
ANON_LOCK_EXIT(&2->a_rwlock);
return (-1);
}
newpgs = anon_grow(amp2->ahp, &svd2->anon_index,
btop(seg2->s_size), btop(seg1->s_size),
ANON_NOSLEEP | ANON_GROWDOWN);
if (newpgs == 0) {
ANON_LOCK_EXIT(&2->a_rwlock);
return (-1);
}
amp2->size = ptob(newpgs);
ANON_LOCK_EXIT(&2->a_rwlock);
}
if (svd2->vpage != NULL) {
struct vpage *vp, *evp;
new_vpage =
kmem_zalloc(vpgtob(seg_pages(seg1) + seg_pages(seg2)),
KM_NOSLEEP);
if (new_vpage == NULL) {
if (amp2)
svd2->anon_index += seg_pages(seg1);
return (-1);
}
bcopy(svd2->vpage, new_vpage + seg_pages(seg1),
vpgtob(seg_pages(seg2)));
kmem_free(svd2->vpage, vpgtob(seg_pages(seg2)));
svd2->vpage = new_vpage;
vp = new_vpage;
evp = vp + seg_pages(seg1);
for (; vp < evp; vp++)
VPP_SETPROT(vp, a->prot);
if (svd2->pageswap && swresv) {
ASSERT(!(svd2->flags & MAP_NORESERVE));
ASSERT(swresv == seg1->s_size);
vp = new_vpage;
for (; vp < evp; vp++) {
VPP_SETSWAPRES(vp);
}
}
}
ASSERT(svd2->vpage != NULL || svd2->pageswap == 0);
size = seg1->s_size;
seg_free(seg1);
seg2->s_size += size;
seg2->s_base -= size;
svd2->offset -= size;
svd2->swresv += swresv;
if (svd2->pageprot && (a->prot & PROT_WRITE) &&
svd2->type == MAP_SHARED && svd2->vp != NULL &&
(svd2->vp->v_flag & VVMEXEC)) {
ASSERT(vn_is_mapped(svd2->vp, V_WRITE));
segvn_inval_trcache(svd2->vp);
}
return (0);
}
static int
segvn_dup_pages(struct seg *seg, struct seg *newseg)
{
int error;
uint_t prot;
page_t *pp;
struct anon *ap, *newap;
size_t i;
caddr_t addr;
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct segvn_data *newsvd = (struct segvn_data *)newseg->s_data;
ulong_t old_idx = svd->anon_index;
ulong_t new_idx = 0;
i = btopr(seg->s_size);
addr = seg->s_base;
while (i-- > 0) {
if ((ap = anon_get_ptr(svd->amp->ahp, old_idx)) != NULL) {
struct vpage *vpp;
vpp = &svd->vpage[seg_page(seg, addr)];
prot = svd->pageprot ? VPP_PROT(vpp) : svd->prot;
if (svd->svn_inz == SEGVN_INZ_ALL ||
(svd->svn_inz == SEGVN_INZ_VPP &&
VPP_ISINHZERO(vpp))) {
pp = anon_zero(newseg, addr, &newap,
newsvd->cred);
} else {
page_t *anon_pl[1+1];
uint_t vpprot;
error = anon_getpage(&ap, &vpprot, anon_pl,
PAGESIZE, seg, addr, S_READ, svd->cred);
if (error != 0)
return (error);
pp = anon_private(&newap, newseg, addr, prot,
anon_pl[0], 0, newsvd->cred);
}
if (pp == NULL) {
return (ENOMEM);
}
(void) anon_set_ptr(newsvd->amp->ahp, new_idx, newap,
ANON_SLEEP);
page_unlock(pp);
}
addr += PAGESIZE;
old_idx++;
new_idx++;
}
return (0);
}
static int
segvn_dup(struct seg *seg, struct seg *newseg)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct segvn_data *newsvd;
pgcnt_t npages = seg_pages(seg);
int error = 0;
size_t len;
struct anon_map *amp;
ASSERT(seg->s_as && AS_WRITE_HELD(seg->s_as));
ASSERT(newseg->s_as->a_proc->p_parent == curproc);
if ((len = svd->swresv) != 0) {
if (anon_resv(svd->swresv) == 0)
return (ENOMEM);
TRACE_3(TR_FAC_VM, TR_ANON_PROC, "anon proc:%p %lu %u",
seg, len, 0);
}
newsvd = kmem_cache_alloc(segvn_cache, KM_SLEEP);
newseg->s_ops = &segvn_ops;
newseg->s_data = (void *)newsvd;
newseg->s_szc = seg->s_szc;
newsvd->seg = newseg;
if ((newsvd->vp = svd->vp) != NULL) {
VN_HOLD(svd->vp);
if (svd->type == MAP_SHARED)
lgrp_shm_policy_init(NULL, svd->vp);
}
newsvd->offset = svd->offset;
newsvd->prot = svd->prot;
newsvd->maxprot = svd->maxprot;
newsvd->pageprot = svd->pageprot;
newsvd->type = svd->type;
newsvd->cred = svd->cred;
crhold(newsvd->cred);
newsvd->advice = svd->advice;
newsvd->pageadvice = svd->pageadvice;
newsvd->svn_inz = svd->svn_inz;
newsvd->swresv = svd->swresv;
newsvd->pageswap = svd->pageswap;
newsvd->flags = svd->flags;
newsvd->softlockcnt = 0;
newsvd->softlockcnt_sbase = 0;
newsvd->softlockcnt_send = 0;
newsvd->policy_info = svd->policy_info;
newsvd->rcookie = HAT_INVALID_REGION_COOKIE;
if ((amp = svd->amp) == NULL || svd->tr_state == SEGVN_TR_ON) {
ASSERT(!HAT_IS_REGION_COOKIE_VALID(svd->rcookie) ||
svd->tr_state == SEGVN_TR_OFF);
if (svd->tr_state == SEGVN_TR_ON) {
ASSERT(newsvd->vp != NULL && amp != NULL);
newsvd->tr_state = SEGVN_TR_INIT;
} else {
newsvd->tr_state = svd->tr_state;
}
newsvd->amp = NULL;
newsvd->anon_index = 0;
} else {
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
ASSERT(svd->tr_state == SEGVN_TR_OFF);
newsvd->tr_state = SEGVN_TR_OFF;
if (svd->type == MAP_SHARED) {
ASSERT(svd->svn_inz == SEGVN_INZ_NONE);
newsvd->amp = amp;
ANON_LOCK_ENTER(&->a_rwlock, RW_WRITER);
amp->refcnt++;
ANON_LOCK_EXIT(&->a_rwlock);
newsvd->anon_index = svd->anon_index;
} else {
int reclaim = 1;
newsvd->amp = anonmap_alloc(newseg->s_size, 0,
ANON_SLEEP);
newsvd->amp->a_szc = newseg->s_szc;
newsvd->anon_index = 0;
ASSERT(svd->svn_inz == SEGVN_INZ_NONE ||
svd->svn_inz == SEGVN_INZ_ALL ||
svd->svn_inz == SEGVN_INZ_VPP);
retry:
if (svd->softlockcnt ||
svd->svn_inz != SEGVN_INZ_NONE) {
if (svd->softlockcnt && reclaim == 1) {
segvn_purge(seg);
reclaim = 0;
goto retry;
}
error = segvn_dup_pages(seg, newseg);
if (error != 0) {
newsvd->vpage = NULL;
goto out;
}
} else {
if (seg->s_szc != 0) {
anon_dup_fill_holes(amp->ahp,
svd->anon_index, newsvd->amp->ahp,
0, seg->s_size, seg->s_szc,
svd->vp != NULL);
} else {
anon_dup(amp->ahp, svd->anon_index,
newsvd->amp->ahp, 0, seg->s_size);
}
hat_clrattr(seg->s_as->a_hat, seg->s_base,
seg->s_size, PROT_WRITE);
}
}
}
if (svd->vpage != NULL) {
uint_t i;
struct vpage *ovp = svd->vpage;
struct vpage *nvp;
nvp = newsvd->vpage =
kmem_alloc(vpgtob(npages), KM_SLEEP);
for (i = 0; i < npages; i++) {
*nvp = *ovp++;
VPP_CLRPPLOCK(nvp++);
}
} else
newsvd->vpage = NULL;
if (newsvd->vp != NULL) {
error = VOP_ADDMAP(newsvd->vp, (offset_t)newsvd->offset,
newseg->s_as, newseg->s_base, newseg->s_size, newsvd->prot,
newsvd->maxprot, newsvd->type, newsvd->cred, NULL);
}
out:
if (error == 0 && HAT_IS_REGION_COOKIE_VALID(svd->rcookie)) {
ASSERT(newsvd->amp == NULL);
ASSERT(newsvd->tr_state == SEGVN_TR_OFF);
newsvd->rcookie = svd->rcookie;
hat_dup_region(newseg->s_as->a_hat, newsvd->rcookie);
}
return (error);
}
extern int free_pages;
static void
segvn_hat_rgn_unload_callback(caddr_t saddr, caddr_t eaddr, caddr_t r_saddr,
size_t r_size, void *r_obj, u_offset_t r_objoff)
{
u_offset_t off;
size_t len;
vnode_t *vp = (vnode_t *)r_obj;
ASSERT(eaddr > saddr);
ASSERT(saddr >= r_saddr);
ASSERT(saddr < r_saddr + r_size);
ASSERT(eaddr > r_saddr);
ASSERT(eaddr <= r_saddr + r_size);
ASSERT(vp != NULL);
if (!free_pages) {
return;
}
len = eaddr - saddr;
off = (saddr - r_saddr) + r_objoff;
free_vp_pages(vp, off, len);
}
static void
segvn_hat_unload_callback(hat_callback_t *cb)
{
struct seg *seg = cb->hcb_data;
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
size_t len;
u_offset_t off;
ASSERT(svd->vp != NULL);
ASSERT(cb->hcb_end_addr > cb->hcb_start_addr);
ASSERT(cb->hcb_start_addr >= seg->s_base);
len = cb->hcb_end_addr - cb->hcb_start_addr;
off = cb->hcb_start_addr - seg->s_base;
free_vp_pages(svd->vp, svd->offset + off, len);
}
static size_t
segvn_count_swap_by_vpages(struct seg *seg)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct vpage *vp, *evp;
size_t nswappages = 0;
ASSERT(svd->pageswap);
ASSERT(svd->vpage != NULL);
evp = &svd->vpage[seg_page(seg, seg->s_base + seg->s_size)];
for (vp = svd->vpage; vp < evp; vp++) {
if (VPP_ISSWAPRES(vp))
nswappages++;
}
return (nswappages << PAGESHIFT);
}
static int
segvn_unmap(struct seg *seg, caddr_t addr, size_t len)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct segvn_data *nsvd;
struct seg *nseg;
struct anon_map *amp;
pgcnt_t opages;
pgcnt_t npages;
pgcnt_t dpages;
hat_callback_t callback;
hat_callback_t *cbp = NULL;
caddr_t nbase;
size_t nsize;
size_t oswresv;
int reclaim = 1;
ASSERT(seg->s_as && AS_WRITE_HELD(seg->s_as));
retry:
if (svd->softlockcnt > 0) {
ASSERT(svd->tr_state == SEGVN_TR_OFF);
if (svd->type == MAP_SHARED) {
return (EAGAIN);
}
if (reclaim == 1) {
segvn_purge(seg);
reclaim = 0;
goto retry;
}
return (EAGAIN);
}
if (addr < seg->s_base || addr + len > seg->s_base + seg->s_size ||
(len & PAGEOFFSET) || ((uintptr_t)addr & PAGEOFFSET)) {
panic("segvn_unmap");
}
if (seg->s_szc != 0) {
size_t pgsz = page_get_pagesize(seg->s_szc);
int err;
if (!IS_P2ALIGNED(addr, pgsz) || !IS_P2ALIGNED(len, pgsz)) {
ASSERT(seg->s_base != addr || seg->s_size != len);
if (HAT_IS_REGION_COOKIE_VALID(svd->rcookie)) {
ASSERT(svd->amp == NULL);
ASSERT(svd->tr_state == SEGVN_TR_OFF);
hat_leave_region(seg->s_as->a_hat,
svd->rcookie, HAT_REGION_TEXT);
svd->rcookie = HAT_INVALID_REGION_COOKIE;
} else if (svd->tr_state == SEGVN_TR_INIT) {
svd->tr_state = SEGVN_TR_OFF;
} else if (svd->tr_state == SEGVN_TR_ON) {
ASSERT(svd->amp != NULL);
segvn_textunrepl(seg, 1);
ASSERT(svd->amp == NULL);
ASSERT(svd->tr_state == SEGVN_TR_OFF);
}
VM_STAT_ADD(segvnvmstats.demoterange[0]);
err = segvn_demote_range(seg, addr, len, SDR_END, 0);
if (err == 0) {
return (IE_RETRY);
}
return (err);
}
}
if (svd->vp) {
int error;
error = VOP_DELMAP(svd->vp,
(offset_t)svd->offset + (uintptr_t)(addr - seg->s_base),
seg->s_as, addr, len, svd->prot, svd->maxprot,
svd->type, svd->cred, NULL);
if (error == EAGAIN)
return (error);
}
if (svd->tr_state == SEGVN_TR_OFF) {
(void) segvn_lockop(seg, addr, len, 0, MC_UNLOCK, NULL, 0);
}
if (HAT_IS_REGION_COOKIE_VALID(svd->rcookie)) {
ASSERT(svd->amp == NULL);
ASSERT(svd->tr_state == SEGVN_TR_OFF);
ASSERT(svd->type == MAP_PRIVATE);
hat_leave_region(seg->s_as->a_hat, svd->rcookie,
HAT_REGION_TEXT);
svd->rcookie = HAT_INVALID_REGION_COOKIE;
} else if (svd->tr_state == SEGVN_TR_ON) {
ASSERT(svd->amp != NULL);
ASSERT(svd->pageprot == 0 && !(svd->prot & PROT_WRITE));
segvn_textunrepl(seg, 1);
ASSERT(svd->amp == NULL && svd->tr_state == SEGVN_TR_OFF);
} else {
if (svd->tr_state != SEGVN_TR_OFF) {
ASSERT(svd->tr_state == SEGVN_TR_INIT);
svd->tr_state = SEGVN_TR_OFF;
}
if (svd->vp != NULL && free_pages != 0) {
callback.hcb_data = seg;
callback.hcb_function = segvn_hat_unload_callback;
cbp = &callback;
}
hat_unload_callback(seg->s_as->a_hat, addr, len,
HAT_UNLOAD_UNMAP, cbp);
if (svd->type == MAP_SHARED && svd->vp != NULL &&
(svd->vp->v_flag & VVMEXEC) &&
((svd->prot & PROT_WRITE) || svd->pageprot)) {
segvn_inval_trcache(svd->vp);
}
}
if (addr == seg->s_base && len == seg->s_size) {
seg_free(seg);
return (0);
}
opages = seg_pages(seg);
dpages = btop(len);
npages = opages - dpages;
amp = svd->amp;
ASSERT(amp == NULL || amp->a_szc >= seg->s_szc);
if (addr == seg->s_base) {
if (svd->vpage != NULL) {
size_t nbytes;
struct vpage *ovpage;
ovpage = svd->vpage;
nbytes = vpgtob(npages);
svd->vpage = kmem_alloc(nbytes, KM_SLEEP);
bcopy(&ovpage[dpages], svd->vpage, nbytes);
kmem_free(ovpage, vpgtob(opages));
}
if (amp != NULL) {
ANON_LOCK_ENTER(&->a_rwlock, RW_WRITER);
if (amp->refcnt == 1 || svd->type == MAP_PRIVATE) {
if (svd->type == MAP_SHARED) {
ASSERT(amp->refcnt == 1);
ASSERT(svd->softlockcnt == 0);
anonmap_purge(amp);
}
if (amp->a_szc == seg->s_szc) {
if (seg->s_szc != 0) {
anon_free_pages(amp->ahp,
svd->anon_index, len,
seg->s_szc);
} else {
anon_free(amp->ahp,
svd->anon_index,
len);
}
} else {
ASSERT(svd->type == MAP_SHARED);
ASSERT(amp->a_szc > seg->s_szc);
anon_shmap_free_pages(amp,
svd->anon_index, len);
}
if (svd->type == MAP_SHARED) {
anon_unresv_zone(len,
seg->s_as->a_proc->p_zone);
amp->swresv -= len;
}
}
ANON_LOCK_EXIT(&->a_rwlock);
svd->anon_index += dpages;
}
if (svd->vp != NULL)
svd->offset += len;
seg->s_base += len;
seg->s_size -= len;
if (svd->swresv) {
if (svd->flags & MAP_NORESERVE) {
ASSERT(amp);
oswresv = svd->swresv;
svd->swresv = ptob(anon_pages(amp->ahp,
svd->anon_index, npages));
anon_unresv_zone(oswresv - svd->swresv,
seg->s_as->a_proc->p_zone);
if (SEG_IS_PARTIAL_RESV(seg))
seg->s_as->a_resvsize -= oswresv -
svd->swresv;
} else {
size_t unlen;
if (svd->pageswap) {
oswresv = svd->swresv;
svd->swresv =
segvn_count_swap_by_vpages(seg);
ASSERT(oswresv >= svd->swresv);
unlen = oswresv - svd->swresv;
} else {
svd->swresv -= len;
ASSERT(svd->swresv == seg->s_size);
unlen = len;
}
anon_unresv_zone(unlen,
seg->s_as->a_proc->p_zone);
}
TRACE_3(TR_FAC_VM, TR_ANON_PROC, "anon proc:%p %lu %u",
seg, len, 0);
}
return (0);
}
if (addr + len == seg->s_base + seg->s_size) {
if (svd->vpage != NULL) {
size_t nbytes;
struct vpage *ovpage;
ovpage = svd->vpage;
nbytes = vpgtob(npages);
svd->vpage = kmem_alloc(nbytes, KM_SLEEP);
bcopy(ovpage, svd->vpage, nbytes);
kmem_free(ovpage, vpgtob(opages));
}
if (amp != NULL) {
ANON_LOCK_ENTER(&->a_rwlock, RW_WRITER);
if (amp->refcnt == 1 || svd->type == MAP_PRIVATE) {
ulong_t an_idx = svd->anon_index + npages;
if (svd->type == MAP_SHARED) {
ASSERT(amp->refcnt == 1);
ASSERT(svd->softlockcnt == 0);
anonmap_purge(amp);
}
if (amp->a_szc == seg->s_szc) {
if (seg->s_szc != 0) {
anon_free_pages(amp->ahp,
an_idx, len,
seg->s_szc);
} else {
anon_free(amp->ahp, an_idx,
len);
}
} else {
ASSERT(svd->type == MAP_SHARED);
ASSERT(amp->a_szc > seg->s_szc);
anon_shmap_free_pages(amp,
an_idx, len);
}
if (svd->type == MAP_SHARED) {
anon_unresv_zone(len,
seg->s_as->a_proc->p_zone);
amp->swresv -= len;
}
}
ANON_LOCK_EXIT(&->a_rwlock);
}
seg->s_size -= len;
if (svd->swresv) {
if (svd->flags & MAP_NORESERVE) {
ASSERT(amp);
oswresv = svd->swresv;
svd->swresv = ptob(anon_pages(amp->ahp,
svd->anon_index, npages));
anon_unresv_zone(oswresv - svd->swresv,
seg->s_as->a_proc->p_zone);
if (SEG_IS_PARTIAL_RESV(seg))
seg->s_as->a_resvsize -= oswresv -
svd->swresv;
} else {
size_t unlen;
if (svd->pageswap) {
oswresv = svd->swresv;
svd->swresv =
segvn_count_swap_by_vpages(seg);
ASSERT(oswresv >= svd->swresv);
unlen = oswresv - svd->swresv;
} else {
svd->swresv -= len;
ASSERT(svd->swresv == seg->s_size);
unlen = len;
}
anon_unresv_zone(unlen,
seg->s_as->a_proc->p_zone);
}
TRACE_3(TR_FAC_VM, TR_ANON_PROC,
"anon proc:%p %lu %u", seg, len, 0);
}
return (0);
}
nbase = addr + len;
nsize = (seg->s_base + seg->s_size) - nbase;
seg->s_size = addr - seg->s_base;
nseg = seg_alloc(seg->s_as, nbase, nsize);
if (nseg == NULL) {
panic("segvn_unmap seg_alloc");
}
nseg->s_ops = seg->s_ops;
nsvd = kmem_cache_alloc(segvn_cache, KM_SLEEP);
nseg->s_data = (void *)nsvd;
nseg->s_szc = seg->s_szc;
*nsvd = *svd;
nsvd->seg = nseg;
nsvd->offset = svd->offset + (uintptr_t)(nseg->s_base - seg->s_base);
nsvd->swresv = 0;
nsvd->softlockcnt = 0;
nsvd->softlockcnt_sbase = 0;
nsvd->softlockcnt_send = 0;
nsvd->svn_inz = svd->svn_inz;
ASSERT(nsvd->rcookie == HAT_INVALID_REGION_COOKIE);
if (svd->vp != NULL) {
VN_HOLD(nsvd->vp);
if (nsvd->type == MAP_SHARED)
lgrp_shm_policy_init(NULL, nsvd->vp);
}
crhold(svd->cred);
if (svd->vpage == NULL) {
nsvd->vpage = NULL;
} else {
size_t nbytes;
struct vpage *ovpage;
ovpage = svd->vpage;
npages = seg_pages(seg);
nbytes = vpgtob(npages);
svd->vpage = kmem_alloc(nbytes, KM_SLEEP);
bcopy(ovpage, svd->vpage, nbytes);
npages = seg_pages(nseg);
nbytes = vpgtob(npages);
nsvd->vpage = kmem_alloc(nbytes, KM_SLEEP);
bcopy(&ovpage[opages - npages], nsvd->vpage, nbytes);
kmem_free(ovpage, vpgtob(opages));
}
if (amp == NULL) {
nsvd->amp = NULL;
nsvd->anon_index = 0;
} else {
opages = btop((uintptr_t)(addr - seg->s_base));
ANON_LOCK_ENTER(&->a_rwlock, RW_WRITER);
if (amp->refcnt == 1 || svd->type == MAP_PRIVATE) {
ulong_t an_idx = svd->anon_index + opages;
if (svd->type == MAP_SHARED) {
ASSERT(amp->refcnt == 1);
ASSERT(svd->softlockcnt == 0);
anonmap_purge(amp);
}
if (amp->a_szc == seg->s_szc) {
if (seg->s_szc != 0) {
anon_free_pages(amp->ahp, an_idx, len,
seg->s_szc);
} else {
anon_free(amp->ahp, an_idx,
len);
}
} else {
ASSERT(svd->type == MAP_SHARED);
ASSERT(amp->a_szc > seg->s_szc);
anon_shmap_free_pages(amp, an_idx, len);
}
if (svd->type == MAP_SHARED) {
anon_unresv_zone(len,
seg->s_as->a_proc->p_zone);
amp->swresv -= len;
}
}
nsvd->anon_index = svd->anon_index +
btop((uintptr_t)(nseg->s_base - seg->s_base));
if (svd->type == MAP_SHARED) {
amp->refcnt++;
nsvd->amp = amp;
} else {
struct anon_map *namp;
struct anon_hdr *nahp;
ASSERT(svd->type == MAP_PRIVATE);
nahp = anon_create(btop(seg->s_size), ANON_SLEEP);
namp = anonmap_alloc(nseg->s_size, 0, ANON_SLEEP);
namp->a_szc = seg->s_szc;
(void) anon_copy_ptr(amp->ahp, svd->anon_index, nahp,
0, btop(seg->s_size), ANON_SLEEP);
(void) anon_copy_ptr(amp->ahp, nsvd->anon_index,
namp->ahp, 0, btop(nseg->s_size), ANON_SLEEP);
anon_release(amp->ahp, btop(amp->size));
svd->anon_index = 0;
nsvd->anon_index = 0;
amp->ahp = nahp;
amp->size = seg->s_size;
nsvd->amp = namp;
}
ANON_LOCK_EXIT(&->a_rwlock);
}
if (svd->swresv) {
if (svd->flags & MAP_NORESERVE) {
ASSERT(amp);
oswresv = svd->swresv;
svd->swresv = ptob(anon_pages(amp->ahp,
svd->anon_index, btop(seg->s_size)));
nsvd->swresv = ptob(anon_pages(nsvd->amp->ahp,
nsvd->anon_index, btop(nseg->s_size)));
ASSERT(oswresv >= (svd->swresv + nsvd->swresv));
anon_unresv_zone(oswresv - (svd->swresv + nsvd->swresv),
seg->s_as->a_proc->p_zone);
if (SEG_IS_PARTIAL_RESV(seg))
seg->s_as->a_resvsize -= oswresv -
(svd->swresv + nsvd->swresv);
} else {
size_t unlen;
if (svd->pageswap) {
oswresv = svd->swresv;
svd->swresv = segvn_count_swap_by_vpages(seg);
nsvd->swresv = segvn_count_swap_by_vpages(nseg);
ASSERT(oswresv >= (svd->swresv + nsvd->swresv));
unlen = oswresv - (svd->swresv + nsvd->swresv);
} else {
if (seg->s_size + nseg->s_size + len !=
svd->swresv) {
panic("segvn_unmap: cannot split "
"swap reservation");
}
svd->swresv = seg->s_size;
nsvd->swresv = nseg->s_size;
unlen = len;
}
anon_unresv_zone(unlen,
seg->s_as->a_proc->p_zone);
}
TRACE_3(TR_FAC_VM, TR_ANON_PROC, "anon proc:%p %lu %u",
seg, len, 0);
}
return (0);
}
static void
segvn_free(struct seg *seg)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
pgcnt_t npages = seg_pages(seg);
struct anon_map *amp;
size_t len;
ASSERT(seg->s_as && AS_WRITE_HELD(seg->s_as));
ASSERT(svd->tr_state == SEGVN_TR_OFF);
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
(void) segvn_lockop(seg, seg->s_base, seg->s_size,
0, MC_UNLOCK, NULL, 0);
if (svd->vpage != NULL) {
kmem_free(svd->vpage, vpgtob(npages));
svd->vpage = NULL;
}
if ((amp = svd->amp) != NULL) {
ANON_LOCK_ENTER(&->a_rwlock, RW_WRITER);
ASSERT(amp->a_szc >= seg->s_szc);
if (--amp->refcnt == 0) {
if (svd->type == MAP_PRIVATE) {
if (seg->s_szc != 0) {
anon_free_pages(amp->ahp,
svd->anon_index, seg->s_size,
seg->s_szc);
} else {
anon_free(amp->ahp, svd->anon_index,
seg->s_size);
}
} else {
ASSERT(svd->softlockcnt == 0);
anonmap_purge(amp);
if (amp->a_szc != 0) {
anon_shmap_free_pages(amp, 0,
amp->size);
} else {
anon_free(amp->ahp, 0, amp->size);
}
if ((len = amp->swresv) != 0) {
anon_unresv_zone(len,
seg->s_as->a_proc->p_zone);
TRACE_3(TR_FAC_VM, TR_ANON_PROC,
"anon proc:%p %lu %u", seg, len, 0);
}
}
svd->amp = NULL;
ANON_LOCK_EXIT(&->a_rwlock);
anonmap_free(amp);
} else if (svd->type == MAP_PRIVATE) {
if (seg->s_szc != 0) {
anon_free_pages(amp->ahp, svd->anon_index,
seg->s_size, seg->s_szc);
} else {
anon_free(amp->ahp, svd->anon_index,
seg->s_size);
}
ANON_LOCK_EXIT(&->a_rwlock);
} else {
ANON_LOCK_EXIT(&->a_rwlock);
}
}
if ((len = svd->swresv) != 0) {
anon_unresv_zone(svd->swresv,
seg->s_as->a_proc->p_zone);
TRACE_3(TR_FAC_VM, TR_ANON_PROC, "anon proc:%p %lu %u",
seg, len, 0);
if (SEG_IS_PARTIAL_RESV(seg))
seg->s_as->a_resvsize -= svd->swresv;
svd->swresv = 0;
}
if (svd->vp != NULL) {
if (svd->type == MAP_SHARED)
lgrp_shm_policy_fini(NULL, svd->vp);
VN_RELE(svd->vp);
svd->vp = NULL;
}
crfree(svd->cred);
svd->pageprot = 0;
svd->pageadvice = 0;
svd->pageswap = 0;
svd->cred = NULL;
ASSERT(svd->softlockcnt == 0);
mutex_enter(&svd->segfree_syncmtx);
mutex_exit(&svd->segfree_syncmtx);
seg->s_data = NULL;
kmem_cache_free(segvn_cache, svd);
}
static void
segvn_softunlock(struct seg *seg, caddr_t addr, size_t len, enum seg_rw rw)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
page_t *pp;
caddr_t adr;
struct vnode *vp;
u_offset_t offset;
ulong_t anon_index = 0;
struct anon_map *amp;
struct anon *ap = NULL;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
ASSERT(SEGVN_LOCK_HELD(seg->s_as, &svd->lock));
if ((amp = svd->amp) != NULL)
anon_index = svd->anon_index + seg_page(seg, addr);
if (HAT_IS_REGION_COOKIE_VALID(svd->rcookie)) {
ASSERT(svd->tr_state == SEGVN_TR_OFF);
hat_unlock_region(seg->s_as->a_hat, addr, len, svd->rcookie);
} else {
hat_unlock(seg->s_as->a_hat, addr, len);
}
for (adr = addr; adr < addr + len; adr += PAGESIZE) {
if (amp != NULL) {
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
if ((ap = anon_get_ptr(amp->ahp, anon_index++))
!= NULL) {
swap_xlate(ap, &vp, &offset);
} else {
vp = svd->vp;
offset = svd->offset +
(uintptr_t)(adr - seg->s_base);
}
ANON_LOCK_EXIT(&->a_rwlock);
} else {
vp = svd->vp;
offset = svd->offset +
(uintptr_t)(adr - seg->s_base);
}
pp = page_find(vp, offset);
if (pp == NULL) {
panic(
"segvn_softunlock: addr %p, ap %p, vp %p, off %llx",
(void *)adr, (void *)ap, (void *)vp, offset);
}
if (rw == S_WRITE) {
hat_setrefmod(pp);
if (seg->s_as->a_vbits)
hat_setstat(seg->s_as, adr, PAGESIZE,
P_REF | P_MOD);
} else if (rw != S_OTHER) {
hat_setref(pp);
if (seg->s_as->a_vbits)
hat_setstat(seg->s_as, adr, PAGESIZE, P_REF);
}
TRACE_3(TR_FAC_VM, TR_SEGVN_FAULT,
"segvn_fault:pp %p vp %p offset %llx", pp, vp, offset);
page_unlock(pp);
}
ASSERT(svd->softlockcnt >= btop(len));
if (!atomic_add_long_nv((ulong_t *)&svd->softlockcnt, -btop(len))) {
if (AS_ISUNMAPWAIT(seg->s_as)) {
mutex_enter(&seg->s_as->a_contents);
if (AS_ISUNMAPWAIT(seg->s_as)) {
AS_CLRUNMAPWAIT(seg->s_as);
cv_broadcast(&seg->s_as->a_cv);
}
mutex_exit(&seg->s_as->a_contents);
}
}
}
#define PAGE_HANDLED ((page_t *)-1)
static void
segvn_pagelist_rele(page_t **ppp)
{
for (; *ppp != NULL; ppp++) {
if (*ppp != PAGE_HANDLED)
page_unlock(*ppp);
}
}
static int stealcow = 1;
int enable_mbit_wa = 0;
static faultcode_t
segvn_faultpage(
struct hat *hat,
struct seg *seg,
caddr_t addr,
u_offset_t off,
struct vpage *vpage,
page_t *pl[],
uint_t vpprot,
enum fault_type type,
enum seg_rw rw,
int brkcow)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
page_t *pp, **ppp;
uint_t pageflags = 0;
page_t *anon_pl[1 + 1];
page_t *opp = NULL;
uint_t prot;
int err;
int cow;
int claim;
int steal = 0;
ulong_t anon_index = 0;
struct anon *ap, *oldap;
struct anon_map *amp;
int hat_flag = (type == F_SOFTLOCK) ? HAT_LOAD_LOCK : HAT_LOAD;
int anon_lock = 0;
anon_sync_obj_t cookie;
if (svd->flags & MAP_TEXT) {
hat_flag |= HAT_LOAD_TEXT;
}
ASSERT(SEGVN_READ_HELD(seg->s_as, &svd->lock));
ASSERT(seg->s_szc == 0);
ASSERT(svd->tr_state != SEGVN_TR_INIT);
if (svd->pageprot) {
uint_t protchk;
switch (rw) {
case S_READ:
protchk = PROT_READ;
break;
case S_WRITE:
protchk = PROT_WRITE;
break;
case S_EXEC:
protchk = PROT_EXEC;
break;
case S_OTHER:
default:
protchk = PROT_READ | PROT_WRITE | PROT_EXEC;
break;
}
prot = VPP_PROT(vpage);
if ((prot & protchk) == 0)
return (FC_PROT);
} else {
prot = svd->prot;
}
if (type == F_SOFTLOCK) {
atomic_inc_ulong((ulong_t *)&svd->softlockcnt);
}
if ((amp = svd->amp) != NULL) {
ASSERT(RW_READ_HELD(&->a_rwlock));
anon_index = svd->anon_index + seg_page(seg, addr);
anon_array_enter(amp, anon_index, &cookie);
anon_lock = 1;
}
if (svd->vp == NULL && amp != NULL) {
if ((ap = anon_get_ptr(amp->ahp, anon_index)) == NULL) {
if (svd->flags & MAP_NORESERVE) {
if (anon_resv_zone(ptob(1),
seg->s_as->a_proc->p_zone)) {
atomic_add_long(&svd->swresv, ptob(1));
atomic_add_long(&seg->s_as->a_resvsize,
ptob(1));
} else {
err = ENOMEM;
goto out;
}
}
if ((pp = anon_zero(seg, addr, &ap,
svd->cred)) == NULL) {
err = ENOMEM;
goto out;
}
(void) anon_set_ptr(amp->ahp, anon_index, ap,
ANON_SLEEP);
ASSERT(pp->p_szc == 0);
if (lgrp_optimizations())
page_migrate(seg, addr, &pp, 1);
if (enable_mbit_wa) {
if (rw == S_WRITE)
hat_setmod(pp);
else if (!hat_ismod(pp))
prot &= ~PROT_WRITE;
}
if (AS_ISPGLCK(seg->s_as) && vpage != NULL &&
(svd->flags & MAP_NORESERVE) &&
!VPP_ISPPLOCK(vpage)) {
proc_t *p = seg->s_as->a_proc;
ASSERT(svd->type == MAP_PRIVATE);
mutex_enter(&p->p_lock);
if (rctl_incr_locked_mem(p, NULL, PAGESIZE,
1) == 0) {
claim = VPP_PROT(vpage) & PROT_WRITE;
if (page_pp_lock(pp, claim, 0)) {
VPP_SETPPLOCK(vpage);
} else {
rctl_decr_locked_mem(p, NULL,
PAGESIZE, 1);
}
}
mutex_exit(&p->p_lock);
}
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
hat_memload(hat, addr, pp, prot, hat_flag);
if (!(hat_flag & HAT_LOAD_LOCK))
page_unlock(pp);
anon_array_exit(&cookie);
return (0);
}
}
if (amp != NULL) {
if ((ap = anon_get_ptr(amp->ahp, anon_index)) != NULL) {
err = anon_getpage(&ap, &vpprot, anon_pl, PAGESIZE,
seg, addr, rw, svd->cred);
if (err)
goto out;
if (svd->type == MAP_SHARED) {
vpprot |= PROT_WRITE;
}
opp = anon_pl[0];
}
}
if (opp == NULL) {
for (ppp = pl; (opp = *ppp) != NULL; ppp++) {
if (opp == PAGE_HANDLED)
continue;
ASSERT(opp->p_vnode == svd->vp);
if (opp->p_offset == off)
break;
}
if (opp == NULL) {
panic("segvn_faultpage not found");
}
*ppp = PAGE_HANDLED;
}
ASSERT(PAGE_LOCKED(opp));
TRACE_3(TR_FAC_VM, TR_SEGVN_FAULT,
"segvn_fault:pp %p vp %p offset %llx", opp, NULL, 0);
if (brkcow) {
ASSERT(svd->tr_state == SEGVN_TR_OFF);
cow = !(vpprot & PROT_WRITE);
} else if (svd->tr_state == SEGVN_TR_ON) {
ASSERT(amp != NULL);
ASSERT(svd->vp != NULL);
ASSERT(rw != S_WRITE);
cow = (ap == NULL);
} else {
cow = 0;
}
if (cow == 0) {
if (lgrp_optimizations())
page_migrate(seg, addr, &opp, 1);
if (IS_VMODSORT(opp->p_vnode) || enable_mbit_wa) {
if (rw == S_WRITE)
hat_setmod(opp);
else if (rw != S_OTHER && !hat_ismod(opp))
prot &= ~PROT_WRITE;
}
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE ||
(!svd->pageprot && svd->prot == (prot & vpprot)));
ASSERT(amp == NULL ||
svd->rcookie == HAT_INVALID_REGION_COOKIE);
hat_memload_region(hat, addr, opp, prot & vpprot, hat_flag,
svd->rcookie);
if (!(hat_flag & HAT_LOAD_LOCK))
page_unlock(opp);
if (anon_lock) {
anon_array_exit(&cookie);
}
return (0);
}
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
hat_setref(opp);
ASSERT(amp != NULL && anon_lock);
if ((ap = anon_get_ptr(amp->ahp, anon_index)) == NULL)
steal = 1;
(void) hat_pagesync(opp, HAT_SYNC_DONTZERO | HAT_SYNC_STOPON_MOD);
if (stealcow && freemem < minfree && steal && opp->p_szc == 0 &&
page_tryupgrade(opp) && !hat_ismod(opp) &&
((opp->p_lckcnt == 0 && opp->p_cowcnt == 0) ||
(opp->p_lckcnt == 0 && opp->p_cowcnt == 1 &&
vpage != NULL && VPP_ISPPLOCK(vpage)))) {
if (hat_page_is_mapped(opp)) {
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
hat_unload(seg->s_as->a_hat, addr, PAGESIZE,
HAT_UNLOAD);
}
if (!hat_ismod(opp) && !hat_page_is_mapped(opp))
pageflags |= STEAL_PAGE;
}
if (vpage != NULL && VPP_ISPPLOCK(vpage))
pageflags |= LOCK_PAGE;
if ((svd->flags & MAP_NORESERVE) && (ap == NULL)) {
if (anon_resv_zone(ptob(1), seg->s_as->a_proc->p_zone)) {
atomic_add_long(&svd->swresv, ptob(1));
atomic_add_long(&seg->s_as->a_resvsize, ptob(1));
} else {
page_unlock(opp);
err = ENOMEM;
goto out;
}
}
oldap = ap;
pp = anon_private(&ap, seg, addr, prot, opp, pageflags, svd->cred);
if (pp == NULL) {
err = ENOMEM;
goto out;
}
if (oldap != NULL)
anon_decref(oldap);
(void) anon_set_ptr(amp->ahp, anon_index, ap, ANON_SLEEP);
if (lgrp_optimizations())
page_migrate(seg, addr, &pp, 1);
ASSERT(pp->p_szc == 0);
ASSERT(!IS_VMODSORT(pp->p_vnode));
if (enable_mbit_wa) {
if (rw == S_WRITE)
hat_setmod(pp);
else if (!hat_ismod(pp))
prot &= ~PROT_WRITE;
}
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
hat_memload(hat, addr, pp, prot, hat_flag);
if (!(hat_flag & HAT_LOAD_LOCK))
page_unlock(pp);
ASSERT(anon_lock);
anon_array_exit(&cookie);
return (0);
out:
if (anon_lock)
anon_array_exit(&cookie);
if (type == F_SOFTLOCK) {
atomic_dec_ulong((ulong_t *)&svd->softlockcnt);
}
return (FC_MAKE_ERR(err));
}
static void
segvn_relocate_pages(page_t **targ, page_t *replacement)
{
page_t *pp;
pgcnt_t repl_npgs, curnpgs;
pgcnt_t i;
uint_t repl_szc = replacement->p_szc;
page_t *first_repl = replacement;
page_t *repl;
spgcnt_t npgs;
VM_STAT_ADD(segvnvmstats.relocatepages[0]);
ASSERT(repl_szc != 0);
npgs = repl_npgs = page_get_pagecnt(repl_szc);
i = 0;
while (repl_npgs) {
spgcnt_t nreloc;
int err;
ASSERT(replacement != NULL);
pp = targ[i];
ASSERT(pp->p_szc < repl_szc);
ASSERT(PAGE_EXCL(pp));
ASSERT(!PP_ISFREE(pp));
curnpgs = page_get_pagecnt(pp->p_szc);
if (curnpgs == 1) {
VM_STAT_ADD(segvnvmstats.relocatepages[1]);
repl = replacement;
page_sub(&replacement, repl);
ASSERT(PAGE_EXCL(repl));
ASSERT(!PP_ISFREE(repl));
ASSERT(repl->p_szc == repl_szc);
} else {
page_t *repl_savepp;
int j;
VM_STAT_ADD(segvnvmstats.relocatepages[2]);
repl_savepp = replacement;
for (j = 0; j < curnpgs; j++) {
repl = replacement;
page_sub(&replacement, repl);
ASSERT(PAGE_EXCL(repl));
ASSERT(!PP_ISFREE(repl));
ASSERT(repl->p_szc == repl_szc);
ASSERT(page_pptonum(targ[i + j]) ==
page_pptonum(targ[i]) + j);
}
repl = repl_savepp;
ASSERT(IS_P2ALIGNED(page_pptonum(repl), curnpgs));
}
err = page_relocate(&pp, &repl, 0, 1, &nreloc, NULL);
if (err || nreloc != curnpgs) {
panic("segvn_relocate_pages: "
"page_relocate failed err=%d curnpgs=%ld "
"nreloc=%ld", err, curnpgs, nreloc);
}
ASSERT(curnpgs <= repl_npgs);
repl_npgs -= curnpgs;
i += curnpgs;
}
ASSERT(replacement == NULL);
repl = first_repl;
repl_npgs = npgs;
for (i = 0; i < repl_npgs; i++) {
ASSERT(PAGE_EXCL(repl));
ASSERT(!PP_ISFREE(repl));
targ[i] = repl;
page_downgrade(targ[i]);
repl++;
}
}
static int
segvn_full_szcpages(page_t **ppa, uint_t szc, int *upgrdfail, uint_t *pszc)
{
page_t *pp;
pfn_t pfn;
pgcnt_t totnpgs = page_get_pagecnt(szc);
pfn_t first_pfn;
int contig = 1;
pgcnt_t i;
pgcnt_t j;
uint_t curszc;
pgcnt_t curnpgs;
int root = 0;
ASSERT(szc > 0);
VM_STAT_ADD(segvnvmstats.fullszcpages[0]);
for (i = 0; i < totnpgs; i++) {
pp = ppa[i];
ASSERT(PAGE_SHARED(pp));
ASSERT(!PP_ISFREE(pp));
pfn = page_pptonum(pp);
if (i == 0) {
if (!IS_P2ALIGNED(pfn, totnpgs)) {
contig = 0;
} else {
first_pfn = pfn;
}
} else if (contig && pfn != first_pfn + i) {
contig = 0;
}
if (pp->p_szc == 0) {
if (root) {
VM_STAT_ADD(segvnvmstats.fullszcpages[1]);
return (0);
}
} else if (!root) {
if ((curszc = pp->p_szc) >= szc) {
VM_STAT_ADD(segvnvmstats.fullszcpages[2]);
return (0);
}
if (curszc == 0) {
VM_STAT_ADD(segvnvmstats.fullszcpages[3]);
return (0);
}
curnpgs = page_get_pagecnt(curszc);
if (!IS_P2ALIGNED(pfn, curnpgs) ||
!IS_P2ALIGNED(i, curnpgs)) {
VM_STAT_ADD(segvnvmstats.fullszcpages[4]);
return (0);
}
root = 1;
} else {
ASSERT(i > 0);
VM_STAT_ADD(segvnvmstats.fullszcpages[5]);
if (pp->p_szc != curszc) {
VM_STAT_ADD(segvnvmstats.fullszcpages[6]);
return (0);
}
if (pfn - 1 != page_pptonum(ppa[i - 1])) {
panic("segvn_full_szcpages: "
"large page not physically contiguous");
}
if (P2PHASE(pfn, curnpgs) == curnpgs - 1) {
root = 0;
}
}
}
for (i = 0; i < totnpgs; i++) {
ASSERT(ppa[i]->p_szc < szc);
if (!page_tryupgrade(ppa[i])) {
for (j = 0; j < i; j++) {
page_downgrade(ppa[j]);
}
*pszc = ppa[i]->p_szc;
*upgrdfail = 1;
VM_STAT_ADD(segvnvmstats.fullszcpages[7]);
return (0);
}
}
if (contig) {
VM_STAT_ADD(segvnvmstats.fullszcpages[8]);
for (i = 0; i < totnpgs; i++) {
(void) hat_pageunload(ppa[i], HAT_FORCE_PGUNLOAD);
}
for (i = 0; i < totnpgs; i++) {
ppa[i]->p_szc = szc;
}
for (i = 0; i < totnpgs; i++) {
ASSERT(PAGE_EXCL(ppa[i]));
page_downgrade(ppa[i]);
}
if (pszc != NULL) {
*pszc = szc;
}
}
VM_STAT_ADD(segvnvmstats.fullszcpages[9]);
return (1);
}
static int
segvn_fill_vp_pages(struct segvn_data *svd, vnode_t *vp, u_offset_t off,
uint_t szc, page_t **ppa, page_t **ppplist, uint_t *ret_pszc,
int *downsize)
{
page_t *pplist = *ppplist;
size_t pgsz = page_get_pagesize(szc);
pgcnt_t pages = btop(pgsz);
ulong_t start_off = off;
u_offset_t eoff = off + pgsz;
spgcnt_t nreloc;
u_offset_t io_off = off;
size_t io_len;
page_t *io_pplist = NULL;
page_t *done_pplist = NULL;
pgcnt_t pgidx = 0;
page_t *pp;
page_t *newpp;
page_t *targpp;
int io_err = 0;
int i;
pfn_t pfn;
ulong_t ppages;
page_t *targ_pplist = NULL;
page_t *repl_pplist = NULL;
page_t *tmp_pplist;
int nios = 0;
uint_t pszc;
struct vattr va;
VM_STAT_ADD(segvnvmstats.fill_vp_pages[0]);
ASSERT(szc != 0);
ASSERT(pplist->p_szc == szc);
*downsize = 0;
while (off < eoff) {
newpp = pplist;
ASSERT(newpp != NULL);
ASSERT(PAGE_EXCL(newpp));
ASSERT(!PP_ISFREE(newpp));
pp = page_lookup_create(vp, off, SE_SHARED, newpp, NULL, 0);
ASSERT(pp != NULL);
ASSERT(!PP_ISFREE(pp));
ASSERT(pp->p_vnode == vp);
ASSERT(pp->p_offset == off);
if (pp == newpp) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[1]);
page_sub(&pplist, pp);
ASSERT(PAGE_EXCL(pp));
ASSERT(page_iolock_assert(pp));
page_list_concat(&io_pplist, &pp);
off += PAGESIZE;
continue;
}
VM_STAT_ADD(segvnvmstats.fill_vp_pages[2]);
pfn = page_pptonum(pp);
pszc = pp->p_szc;
if (pszc >= szc && targ_pplist == NULL && io_pplist == NULL &&
IS_P2ALIGNED(pfn, pages)) {
ASSERT(repl_pplist == NULL);
ASSERT(done_pplist == NULL);
ASSERT(pplist == *ppplist);
page_unlock(pp);
page_free_replacement_page(pplist);
page_create_putback(pages);
*ppplist = NULL;
VM_STAT_ADD(segvnvmstats.fill_vp_pages[3]);
return (1);
}
if (pszc >= szc) {
page_unlock(pp);
segvn_faultvnmpss_align_err1++;
goto out;
}
ppages = page_get_pagecnt(pszc);
if (!IS_P2ALIGNED(pfn, ppages)) {
ASSERT(pszc > 0);
page_unlock(pp);
segvn_faultvnmpss_align_err2++;
goto out;
}
pfn = page_pptonum(newpp);
if (!IS_P2ALIGNED(pfn, ppages)) {
ASSERT(pszc > 0);
page_unlock(pp);
segvn_faultvnmpss_align_err3++;
goto out;
}
if (!PAGE_EXCL(pp)) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[4]);
page_unlock(pp);
*downsize = 1;
*ret_pszc = pp->p_szc;
goto out;
}
targpp = pp;
if (io_pplist != NULL) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[5]);
io_len = off - io_off;
va.va_mask = AT_SIZE;
if (VOP_GETATTR(vp, &va, ATTR_HINT, svd->cred, NULL)) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[6]);
page_unlock(targpp);
goto out;
}
if (btopr(va.va_size) < btopr(io_off + io_len)) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[7]);
*downsize = 1;
*ret_pszc = 0;
page_unlock(targpp);
goto out;
}
io_err = VOP_PAGEIO(vp, io_pplist, io_off, io_len,
B_READ, svd->cred, NULL);
if (io_err) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[8]);
page_unlock(targpp);
if (io_err == EDEADLK) {
segvn_vmpss_pageio_deadlk_err++;
}
goto out;
}
nios++;
VM_STAT_ADD(segvnvmstats.fill_vp_pages[9]);
while (io_pplist != NULL) {
pp = io_pplist;
page_sub(&io_pplist, pp);
ASSERT(page_iolock_assert(pp));
page_io_unlock(pp);
pgidx = (pp->p_offset - start_off) >>
PAGESHIFT;
ASSERT(pgidx < pages);
ppa[pgidx] = pp;
page_list_concat(&done_pplist, &pp);
}
}
pp = targpp;
ASSERT(PAGE_EXCL(pp));
ASSERT(pp->p_szc <= pszc);
if (pszc != 0 && !group_page_trylock(pp, SE_EXCL)) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[10]);
page_unlock(pp);
*downsize = 1;
*ret_pszc = pp->p_szc;
goto out;
}
VM_STAT_ADD(segvnvmstats.fill_vp_pages[11]);
pszc = pp->p_szc;
ppages = page_get_pagecnt(pszc);
page_list_concat(&targ_pplist, &pp);
page_sub(&pplist, newpp);
page_list_concat(&repl_pplist, &newpp);
off += PAGESIZE;
while (--ppages != 0) {
newpp = pplist;
page_sub(&pplist, newpp);
off += PAGESIZE;
}
io_off = off;
}
if (io_pplist != NULL) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[12]);
io_len = eoff - io_off;
va.va_mask = AT_SIZE;
if (VOP_GETATTR(vp, &va, ATTR_HINT, svd->cred, NULL) != 0) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[13]);
goto out;
}
if (btopr(va.va_size) < btopr(io_off + io_len)) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[14]);
*downsize = 1;
*ret_pszc = 0;
goto out;
}
io_err = VOP_PAGEIO(vp, io_pplist, io_off, io_len,
B_READ, svd->cred, NULL);
if (io_err) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[15]);
if (io_err == EDEADLK) {
segvn_vmpss_pageio_deadlk_err++;
}
goto out;
}
nios++;
while (io_pplist != NULL) {
pp = io_pplist;
page_sub(&io_pplist, pp);
ASSERT(page_iolock_assert(pp));
page_io_unlock(pp);
pgidx = (pp->p_offset - start_off) >> PAGESHIFT;
ASSERT(pgidx < pages);
ppa[pgidx] = pp;
}
}
while (done_pplist != NULL) {
pp = done_pplist;
page_sub(&done_pplist, pp);
}
VM_STAT_ADD(segvnvmstats.fill_vp_pages[16]);
ASSERT(pplist == NULL);
*ppplist = NULL;
while (targ_pplist != NULL) {
int ret;
VM_STAT_ADD(segvnvmstats.fill_vp_pages[17]);
ASSERT(repl_pplist);
pp = targ_pplist;
page_sub(&targ_pplist, pp);
pgidx = (pp->p_offset - start_off) >> PAGESHIFT;
newpp = repl_pplist;
page_sub(&repl_pplist, newpp);
#ifdef DEBUG
pfn = page_pptonum(pp);
pszc = pp->p_szc;
ppages = page_get_pagecnt(pszc);
ASSERT(IS_P2ALIGNED(pfn, ppages));
pfn = page_pptonum(newpp);
ASSERT(IS_P2ALIGNED(pfn, ppages));
ASSERT(P2PHASE(pfn, pages) == pgidx);
#endif
nreloc = 0;
ret = page_relocate(&pp, &newpp, 0, 1, &nreloc, NULL);
if (ret != 0 || nreloc == 0) {
panic("segvn_fill_vp_pages: "
"page_relocate failed");
}
pp = newpp;
while (nreloc-- != 0) {
ASSERT(PAGE_EXCL(pp));
ASSERT(pp->p_vnode == vp);
ASSERT(pgidx ==
((pp->p_offset - start_off) >> PAGESHIFT));
ppa[pgidx++] = pp;
pp++;
}
}
if (svd->type == MAP_PRIVATE) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[18]);
for (i = 0; i < pages; i++) {
ASSERT(ppa[i] != NULL);
ASSERT(PAGE_EXCL(ppa[i]));
ASSERT(ppa[i]->p_vnode == vp);
ASSERT(ppa[i]->p_offset ==
start_off + (i << PAGESHIFT));
page_downgrade(ppa[i]);
}
ppa[pages] = NULL;
} else {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[19]);
for (i = 0; i < pages; i++) {
ASSERT(ppa[i] != NULL);
ASSERT(PAGE_EXCL(ppa[i]));
ASSERT(ppa[i]->p_vnode == vp);
ASSERT(ppa[i]->p_offset ==
start_off + (i << PAGESHIFT));
page_unlock(ppa[i]);
}
ppa[0] = NULL;
}
return (1);
out:
if (io_pplist != NULL) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[20]);
pp = io_pplist;
do {
ASSERT(pp->p_vnode == vp);
ASSERT(pp->p_offset == io_off);
ASSERT(page_iolock_assert(pp));
page_io_unlock(pp);
page_hashout(pp, NULL);
io_off += PAGESIZE;
} while ((pp = pp->p_next) != io_pplist);
page_list_concat(&io_pplist, &pplist);
pplist = io_pplist;
}
tmp_pplist = NULL;
while (targ_pplist != NULL) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[21]);
pp = targ_pplist;
ASSERT(PAGE_EXCL(pp));
page_sub(&targ_pplist, pp);
pszc = pp->p_szc;
ppages = page_get_pagecnt(pszc);
ASSERT(IS_P2ALIGNED(page_pptonum(pp), ppages));
if (pszc != 0) {
group_page_unlock(pp);
}
page_unlock(pp);
pp = repl_pplist;
ASSERT(pp != NULL);
ASSERT(PAGE_EXCL(pp));
ASSERT(pp->p_szc == szc);
page_sub(&repl_pplist, pp);
ASSERT(IS_P2ALIGNED(page_pptonum(pp), ppages));
page_list_concat(&tmp_pplist, &pp);
while (--ppages != 0) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[22]);
pp++;
ASSERT(PAGE_EXCL(pp));
ASSERT(pp->p_szc == szc);
page_list_concat(&tmp_pplist, &pp);
}
}
if (tmp_pplist != NULL) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[23]);
page_list_concat(&tmp_pplist, &pplist);
pplist = tmp_pplist;
}
ASSERT(pplist != NULL);
if (nios != 0) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[24]);
pp = pplist;
do {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[25]);
ASSERT(pp->p_szc == szc);
ASSERT(PAGE_EXCL(pp));
ASSERT(pp->p_vnode != vp);
pp->p_szc = 0;
} while ((pp = pp->p_next) != pplist);
pp = done_pplist;
do {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[26]);
ASSERT(pp->p_szc == szc);
ASSERT(PAGE_EXCL(pp));
ASSERT(pp->p_vnode == vp);
pp->p_szc = 0;
} while ((pp = pp->p_next) != done_pplist);
while (pplist != NULL) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[27]);
pp = pplist;
page_sub(&pplist, pp);
page_free(pp, 0);
}
while (done_pplist != NULL) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[28]);
pp = done_pplist;
page_sub(&done_pplist, pp);
page_unlock(pp);
}
*ppplist = NULL;
return (0);
}
ASSERT(pplist == *ppplist);
if (io_err) {
VM_STAT_ADD(segvnvmstats.fill_vp_pages[29]);
return (0);
}
VM_STAT_ADD(segvnvmstats.fill_vp_pages[30]);
page_free_replacement_page(pplist);
page_create_putback(pages);
*ppplist = NULL;
return (0);
}
int segvn_anypgsz = 0;
#define SEGVN_RESTORE_SOFTLOCK_VP(type, pages) \
if ((type) == F_SOFTLOCK) { \
atomic_add_long((ulong_t *)&(svd)->softlockcnt, \
-(pages)); \
}
#define SEGVN_UPDATE_MODBITS(ppa, pages, rw, prot, vpprot) \
if (IS_VMODSORT((ppa)[0]->p_vnode)) { \
if ((rw) == S_WRITE) { \
for (i = 0; i < (pages); i++) { \
ASSERT((ppa)[i]->p_vnode == \
(ppa)[0]->p_vnode); \
hat_setmod((ppa)[i]); \
} \
} else if ((rw) != S_OTHER && \
((prot) & (vpprot) & PROT_WRITE)) { \
for (i = 0; i < (pages); i++) { \
ASSERT((ppa)[i]->p_vnode == \
(ppa)[0]->p_vnode); \
if (!hat_ismod((ppa)[i])) { \
prot &= ~PROT_WRITE; \
break; \
} \
} \
} \
}
#ifdef VM_STATS
#define SEGVN_VMSTAT_FLTVNPAGES(idx) \
VM_STAT_ADD(segvnvmstats.fltvnpages[(idx)]);
#else
#define SEGVN_VMSTAT_FLTVNPAGES(idx)
#endif
static faultcode_t
segvn_fault_vnodepages(struct hat *hat, struct seg *seg, caddr_t lpgaddr,
caddr_t lpgeaddr, enum fault_type type, enum seg_rw rw, caddr_t addr,
caddr_t eaddr, int brkcow)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct anon_map *amp = svd->amp;
uchar_t segtype = svd->type;
uint_t szc = seg->s_szc;
size_t pgsz = page_get_pagesize(szc);
size_t maxpgsz = pgsz;
pgcnt_t pages = btop(pgsz);
pgcnt_t maxpages = pages;
size_t ppasize = (pages + 1) * sizeof (page_t *);
caddr_t a = lpgaddr;
caddr_t maxlpgeaddr = lpgeaddr;
u_offset_t off = svd->offset + (uintptr_t)(a - seg->s_base);
ulong_t aindx = svd->anon_index + seg_page(seg, a);
struct vpage *vpage = (svd->vpage != NULL) ?
&svd->vpage[seg_page(seg, a)] : NULL;
vnode_t *vp = svd->vp;
page_t **ppa;
uint_t pszc;
size_t ppgsz;
pgcnt_t ppages;
faultcode_t err = 0;
int ierr;
int vop_size_err = 0;
uint_t protchk, prot, vpprot;
ulong_t i;
int hat_flag = (type == F_SOFTLOCK) ? HAT_LOAD_LOCK : HAT_LOAD;
anon_sync_obj_t an_cookie;
enum seg_rw arw;
int alloc_failed = 0;
int adjszc_chk;
struct vattr va;
page_t *pplist;
pfn_t pfn;
int physcontig;
int upgrdfail;
int segvn_anypgsz_vnode = 0;
int tron = (svd->tr_state == SEGVN_TR_ON);
ASSERT(szc != 0);
ASSERT(vp != NULL);
ASSERT(brkcow == 0 || amp != NULL);
ASSERT(tron == 0 || amp != NULL);
ASSERT(enable_mbit_wa == 0);
ASSERT(!(svd->flags & MAP_NORESERVE));
ASSERT(type != F_SOFTUNLOCK);
ASSERT(IS_P2ALIGNED(a, maxpgsz));
ASSERT(amp == NULL || IS_P2ALIGNED(aindx, maxpages));
ASSERT(SEGVN_LOCK_HELD(seg->s_as, &svd->lock));
ASSERT(seg->s_szc < NBBY * sizeof (int));
ASSERT(type != F_SOFTLOCK || lpgeaddr - a == maxpgsz);
ASSERT(svd->tr_state != SEGVN_TR_INIT);
VM_STAT_COND_ADD(type == F_SOFTLOCK, segvnvmstats.fltvnpages[0]);
VM_STAT_COND_ADD(type != F_SOFTLOCK, segvnvmstats.fltvnpages[1]);
if (svd->flags & MAP_TEXT) {
hat_flag |= HAT_LOAD_TEXT;
}
if (svd->pageprot) {
prot = PROT_NONE;
switch (rw) {
case S_READ:
protchk = PROT_READ;
break;
case S_WRITE:
protchk = PROT_WRITE;
break;
case S_EXEC:
protchk = PROT_EXEC;
break;
case S_OTHER:
default:
protchk = PROT_READ | PROT_WRITE | PROT_EXEC;
break;
}
} else {
protchk = PROT_NONE;
prot = svd->prot;
}
if (rw == S_WRITE && segtype == MAP_PRIVATE) {
SEGVN_VMSTAT_FLTVNPAGES(2);
arw = S_READ;
} else {
arw = rw;
}
ppa = kmem_alloc(ppasize, KM_SLEEP);
VM_STAT_COND_ADD(amp != NULL, segvnvmstats.fltvnpages[3]);
ierr = 0;
for (;;) {
adjszc_chk = 0;
for (; a < lpgeaddr; a += pgsz, off += pgsz, aindx += pages) {
if (adjszc_chk) {
while (szc < seg->s_szc) {
uintptr_t e;
uint_t tszc;
tszc = segvn_anypgsz_vnode ? szc + 1 :
seg->s_szc;
ppgsz = page_get_pagesize(tszc);
if (!IS_P2ALIGNED(a, ppgsz) ||
((alloc_failed >> tszc) & 0x1)) {
break;
}
SEGVN_VMSTAT_FLTVNPAGES(4);
szc = tszc;
pgsz = ppgsz;
pages = btop(pgsz);
e = P2ROUNDUP((uintptr_t)eaddr, pgsz);
lpgeaddr = (caddr_t)e;
}
}
again:
if (IS_P2ALIGNED(a, maxpgsz) && amp != NULL) {
ASSERT(IS_P2ALIGNED(aindx, maxpages));
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
anon_array_enter(amp, aindx, &an_cookie);
if (anon_get_ptr(amp->ahp, aindx) != NULL) {
SEGVN_VMSTAT_FLTVNPAGES(5);
ASSERT(anon_pages(amp->ahp, aindx,
maxpages) == maxpages);
anon_array_exit(&an_cookie);
ANON_LOCK_EXIT(&->a_rwlock);
err = segvn_fault_anonpages(hat, seg,
a, a + maxpgsz, type, rw,
MAX(a, addr),
MIN(a + maxpgsz, eaddr), brkcow);
if (err != 0) {
SEGVN_VMSTAT_FLTVNPAGES(6);
goto out;
}
if (szc < seg->s_szc) {
szc = seg->s_szc;
pgsz = maxpgsz;
pages = maxpages;
lpgeaddr = maxlpgeaddr;
}
goto next;
} else {
ASSERT(anon_pages(amp->ahp, aindx,
maxpages) == 0);
SEGVN_VMSTAT_FLTVNPAGES(7);
anon_array_exit(&an_cookie);
ANON_LOCK_EXIT(&->a_rwlock);
}
}
ASSERT(!brkcow || IS_P2ALIGNED(a, maxpgsz));
ASSERT(!tron || IS_P2ALIGNED(a, maxpgsz));
if (svd->pageprot != 0 && IS_P2ALIGNED(a, maxpgsz)) {
ASSERT(vpage != NULL);
prot = VPP_PROT(vpage);
ASSERT(sameprot(seg, a, maxpgsz));
if ((prot & protchk) == 0) {
SEGVN_VMSTAT_FLTVNPAGES(8);
err = FC_PROT;
goto out;
}
}
if (type == F_SOFTLOCK) {
atomic_add_long((ulong_t *)&svd->softlockcnt,
pages);
}
pplist = NULL;
physcontig = 0;
ppa[0] = NULL;
if (!brkcow && !tron && szc &&
!page_exists_physcontig(vp, off, szc,
segtype == MAP_PRIVATE ? ppa : NULL)) {
SEGVN_VMSTAT_FLTVNPAGES(9);
if (page_alloc_pages(vp, seg, a, &pplist, NULL,
szc, 0, 0) && type != F_SOFTLOCK) {
SEGVN_VMSTAT_FLTVNPAGES(10);
pszc = 0;
ierr = -1;
alloc_failed |= (1 << szc);
break;
}
if (pplist != NULL &&
vp->v_mpssdata == SEGVN_PAGEIO) {
int downsize;
SEGVN_VMSTAT_FLTVNPAGES(11);
physcontig = segvn_fill_vp_pages(svd,
vp, off, szc, ppa, &pplist,
&pszc, &downsize);
ASSERT(!physcontig || pplist == NULL);
if (!physcontig && downsize &&
type != F_SOFTLOCK) {
ASSERT(pplist == NULL);
SEGVN_VMSTAT_FLTVNPAGES(12);
ierr = -1;
break;
}
ASSERT(!physcontig ||
segtype == MAP_PRIVATE ||
ppa[0] == NULL);
if (physcontig && ppa[0] == NULL) {
physcontig = 0;
}
}
} else if (!brkcow && !tron && szc && ppa[0] != NULL) {
SEGVN_VMSTAT_FLTVNPAGES(13);
ASSERT(segtype == MAP_PRIVATE);
physcontig = 1;
}
if (!physcontig) {
SEGVN_VMSTAT_FLTVNPAGES(14);
ppa[0] = NULL;
ierr = VOP_GETPAGE(vp, (offset_t)off, pgsz,
&vpprot, ppa, pgsz, seg, a, arw,
svd->cred, NULL);
#ifdef DEBUG
if (ierr == 0) {
for (i = 0; i < pages; i++) {
ASSERT(PAGE_LOCKED(ppa[i]));
ASSERT(!PP_ISFREE(ppa[i]));
ASSERT(ppa[i]->p_vnode == vp);
ASSERT(ppa[i]->p_offset ==
off + (i << PAGESHIFT));
}
}
#endif
if (segtype == MAP_PRIVATE) {
SEGVN_VMSTAT_FLTVNPAGES(15);
vpprot &= ~PROT_WRITE;
}
} else {
ASSERT(segtype == MAP_PRIVATE);
SEGVN_VMSTAT_FLTVNPAGES(16);
vpprot = PROT_ALL & ~PROT_WRITE;
ierr = 0;
}
if (ierr != 0) {
SEGVN_VMSTAT_FLTVNPAGES(17);
if (pplist != NULL) {
SEGVN_VMSTAT_FLTVNPAGES(18);
page_free_replacement_page(pplist);
page_create_putback(pages);
}
SEGVN_RESTORE_SOFTLOCK_VP(type, pages);
if (a + pgsz <= eaddr) {
SEGVN_VMSTAT_FLTVNPAGES(19);
err = FC_MAKE_ERR(ierr);
goto out;
}
va.va_mask = AT_SIZE;
if (VOP_GETATTR(vp, &va, 0, svd->cred, NULL)) {
SEGVN_VMSTAT_FLTVNPAGES(20);
err = FC_MAKE_ERR(EIO);
goto out;
}
if (btopr(va.va_size) >= btopr(off + pgsz)) {
SEGVN_VMSTAT_FLTVNPAGES(21);
err = FC_MAKE_ERR(ierr);
goto out;
}
if (btopr(va.va_size) <
btopr(off + (eaddr - a))) {
SEGVN_VMSTAT_FLTVNPAGES(22);
err = FC_MAKE_ERR(ierr);
goto out;
}
if (brkcow || tron || type == F_SOFTLOCK) {
SEGVN_VMSTAT_FLTVNPAGES(23);
vop_size_err = 1;
goto out;
}
SEGVN_VMSTAT_FLTVNPAGES(24);
ASSERT(szc != 0);
pszc = 0;
ierr = -1;
break;
}
if (amp != NULL) {
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
anon_array_enter(amp, aindx, &an_cookie);
}
if (amp != NULL &&
anon_get_ptr(amp->ahp, aindx) != NULL) {
ulong_t taindx = P2ALIGN(aindx, maxpages);
SEGVN_VMSTAT_FLTVNPAGES(25);
ASSERT(anon_pages(amp->ahp, taindx,
maxpages) == maxpages);
for (i = 0; i < pages; i++) {
page_unlock(ppa[i]);
}
anon_array_exit(&an_cookie);
ANON_LOCK_EXIT(&->a_rwlock);
if (pplist != NULL) {
page_free_replacement_page(pplist);
page_create_putback(pages);
}
SEGVN_RESTORE_SOFTLOCK_VP(type, pages);
if (szc < seg->s_szc) {
SEGVN_VMSTAT_FLTVNPAGES(26);
ASSERT(!brkcow && !tron &&
type != F_SOFTLOCK);
pszc = seg->s_szc;
ierr = -2;
break;
}
ASSERT(IS_P2ALIGNED(a, maxpgsz));
goto again;
}
#ifdef DEBUG
if (amp != NULL) {
ulong_t taindx = P2ALIGN(aindx, maxpages);
ASSERT(!anon_pages(amp->ahp, taindx, maxpages));
}
#endif
if (brkcow || tron) {
ASSERT(amp != NULL);
ASSERT(pplist == NULL);
ASSERT(szc == seg->s_szc);
ASSERT(IS_P2ALIGNED(a, maxpgsz));
ASSERT(IS_P2ALIGNED(aindx, maxpages));
SEGVN_VMSTAT_FLTVNPAGES(27);
ierr = anon_map_privatepages(amp, aindx, szc,
seg, a, prot, ppa, vpage, segvn_anypgsz,
tron ? PG_LOCAL : 0, svd->cred);
if (ierr != 0) {
SEGVN_VMSTAT_FLTVNPAGES(28);
anon_array_exit(&an_cookie);
ANON_LOCK_EXIT(&->a_rwlock);
SEGVN_RESTORE_SOFTLOCK_VP(type, pages);
err = FC_MAKE_ERR(ierr);
goto out;
}
ASSERT(!IS_VMODSORT(ppa[0]->p_vnode));
ASSERT(svd->rcookie ==
HAT_INVALID_REGION_COOKIE);
hat_memload_array(hat, a, pgsz, ppa, prot,
hat_flag);
if (!(hat_flag & HAT_LOAD_LOCK)) {
SEGVN_VMSTAT_FLTVNPAGES(29);
for (i = 0; i < pages; i++) {
page_unlock(ppa[i]);
}
}
anon_array_exit(&an_cookie);
ANON_LOCK_EXIT(&->a_rwlock);
goto next;
}
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE ||
(!svd->pageprot && svd->prot == (prot & vpprot)));
pfn = page_pptonum(ppa[0]);
chkszc:
if ((pszc = ppa[0]->p_szc) == szc &&
IS_P2ALIGNED(pfn, pages)) {
SEGVN_VMSTAT_FLTVNPAGES(30);
#ifdef DEBUG
for (i = 0; i < pages; i++) {
ASSERT(PAGE_LOCKED(ppa[i]));
ASSERT(!PP_ISFREE(ppa[i]));
ASSERT(page_pptonum(ppa[i]) ==
pfn + i);
ASSERT(ppa[i]->p_szc == szc);
ASSERT(ppa[i]->p_vnode == vp);
ASSERT(ppa[i]->p_offset ==
off + (i << PAGESHIFT));
}
#endif
if (pplist != NULL) {
page_free_replacement_page(pplist);
page_create_putback(pages);
}
if (PP_ISMIGRATE(ppa[0])) {
page_migrate(seg, a, ppa, pages);
}
SEGVN_UPDATE_MODBITS(ppa, pages, rw,
prot, vpprot);
hat_memload_array_region(hat, a, pgsz,
ppa, prot & vpprot, hat_flag,
svd->rcookie);
if (!(hat_flag & HAT_LOAD_LOCK)) {
for (i = 0; i < pages; i++) {
page_unlock(ppa[i]);
}
}
if (amp != NULL) {
anon_array_exit(&an_cookie);
ANON_LOCK_EXIT(&->a_rwlock);
}
goto next;
}
if (pszc > szc && szc < seg->s_szc &&
(segvn_anypgsz_vnode || pszc >= seg->s_szc)) {
pgcnt_t aphase;
uint_t pszc1 = MIN(pszc, seg->s_szc);
ppgsz = page_get_pagesize(pszc1);
ppages = btop(ppgsz);
aphase = btop(P2PHASE((uintptr_t)a, ppgsz));
ASSERT(type != F_SOFTLOCK);
SEGVN_VMSTAT_FLTVNPAGES(31);
if (aphase != P2PHASE(pfn, ppages)) {
segvn_faultvnmpss_align_err4++;
} else {
SEGVN_VMSTAT_FLTVNPAGES(32);
if (pplist != NULL) {
page_t *pl = pplist;
page_free_replacement_page(pl);
page_create_putback(pages);
}
for (i = 0; i < pages; i++) {
page_unlock(ppa[i]);
}
if (amp != NULL) {
anon_array_exit(&an_cookie);
ANON_LOCK_EXIT(&->a_rwlock);
}
pszc = pszc1;
ierr = -2;
break;
}
}
upgrdfail = 0;
if (szc == 0 ||
(pszc >= szc &&
!IS_P2ALIGNED(pfn, pages)) ||
(pszc < szc &&
!segvn_full_szcpages(ppa, szc, &upgrdfail,
&pszc))) {
if (upgrdfail && type != F_SOFTLOCK) {
ASSERT(pszc < szc);
SEGVN_VMSTAT_FLTVNPAGES(33);
if (pplist != NULL) {
page_t *pl = pplist;
page_free_replacement_page(pl);
page_create_putback(pages);
}
for (i = 0; i < pages; i++) {
page_unlock(ppa[i]);
}
if (amp != NULL) {
anon_array_exit(&an_cookie);
ANON_LOCK_EXIT(&->a_rwlock);
}
ierr = -1;
break;
}
if (szc != 0 && !upgrdfail) {
segvn_faultvnmpss_align_err5++;
}
SEGVN_VMSTAT_FLTVNPAGES(34);
if (pplist != NULL) {
page_free_replacement_page(pplist);
page_create_putback(pages);
}
SEGVN_UPDATE_MODBITS(ppa, pages, rw,
prot, vpprot);
if (upgrdfail && segvn_anypgsz_vnode) {
hat_memload_array_region(hat, a, pgsz,
ppa, prot & vpprot, hat_flag,
svd->rcookie);
} else {
for (i = 0; i < pages; i++) {
hat_memload_region(hat,
a + (i << PAGESHIFT),
ppa[i], prot & vpprot,
hat_flag, svd->rcookie);
}
}
if (!(hat_flag & HAT_LOAD_LOCK)) {
for (i = 0; i < pages; i++) {
page_unlock(ppa[i]);
}
}
if (amp != NULL) {
anon_array_exit(&an_cookie);
ANON_LOCK_EXIT(&->a_rwlock);
}
goto next;
}
if (pszc == szc) {
ASSERT(pszc == ppa[0]->p_szc);
ASSERT(IS_P2ALIGNED(pfn, pages));
goto chkszc;
}
if (pszc > szc) {
kmutex_t *szcmtx;
SEGVN_VMSTAT_FLTVNPAGES(35);
szcmtx = page_szc_lock(ppa[0]);
pszc = ppa[0]->p_szc;
ASSERT(szcmtx != NULL || pszc == 0);
ASSERT(ppa[0]->p_szc <= pszc);
if (pszc <= szc) {
SEGVN_VMSTAT_FLTVNPAGES(36);
if (szcmtx != NULL) {
mutex_exit(szcmtx);
}
goto chkszc;
}
if (pplist != NULL) {
SEGVN_VMSTAT_FLTVNPAGES(37);
page_free_replacement_page(pplist);
page_create_putback(pages);
}
SEGVN_UPDATE_MODBITS(ppa, pages, rw,
prot, vpprot);
hat_memload_array_region(hat, a, pgsz, ppa,
prot & vpprot, hat_flag, svd->rcookie);
mutex_exit(szcmtx);
if (!(hat_flag & HAT_LOAD_LOCK)) {
for (i = 0; i < pages; i++) {
page_unlock(ppa[i]);
}
}
if (amp != NULL) {
anon_array_exit(&an_cookie);
ANON_LOCK_EXIT(&->a_rwlock);
}
goto next;
}
if (pplist == NULL &&
page_alloc_pages(vp, seg, a, &pplist, NULL,
szc, 0, 0) && type != F_SOFTLOCK) {
SEGVN_VMSTAT_FLTVNPAGES(38);
for (i = 0; i < pages; i++) {
page_unlock(ppa[i]);
}
if (amp != NULL) {
anon_array_exit(&an_cookie);
ANON_LOCK_EXIT(&->a_rwlock);
}
ierr = -1;
alloc_failed |= (1 << szc);
break;
}
SEGVN_VMSTAT_FLTVNPAGES(39);
if (pplist != NULL) {
segvn_relocate_pages(ppa, pplist);
#ifdef DEBUG
} else {
ASSERT(type == F_SOFTLOCK);
SEGVN_VMSTAT_FLTVNPAGES(40);
#endif
}
SEGVN_UPDATE_MODBITS(ppa, pages, rw, prot, vpprot);
if (pplist == NULL && segvn_anypgsz_vnode == 0) {
ASSERT(type == F_SOFTLOCK);
for (i = 0; i < pages; i++) {
ASSERT(ppa[i]->p_szc < szc);
hat_memload_region(hat,
a + (i << PAGESHIFT),
ppa[i], prot & vpprot, hat_flag,
svd->rcookie);
}
} else {
ASSERT(pplist != NULL || type == F_SOFTLOCK);
hat_memload_array_region(hat, a, pgsz, ppa,
prot & vpprot, hat_flag, svd->rcookie);
}
if (!(hat_flag & HAT_LOAD_LOCK)) {
for (i = 0; i < pages; i++) {
ASSERT(PAGE_SHARED(ppa[i]));
page_unlock(ppa[i]);
}
}
if (amp != NULL) {
anon_array_exit(&an_cookie);
ANON_LOCK_EXIT(&->a_rwlock);
}
next:
if (vpage != NULL) {
vpage += pages;
}
adjszc_chk = 1;
}
if (a == lpgeaddr)
break;
ASSERT(a < lpgeaddr);
ASSERT(!brkcow && !tron && type != F_SOFTLOCK);
ASSERT(ierr == -1 || ierr == -2);
ASSERT(ierr == -2 || szc != 0);
ASSERT(ierr == -1 || szc < seg->s_szc);
if (ierr == -2) {
SEGVN_VMSTAT_FLTVNPAGES(41);
ASSERT(pszc > szc && pszc <= seg->s_szc);
szc = pszc;
} else if (segvn_anypgsz_vnode) {
SEGVN_VMSTAT_FLTVNPAGES(42);
szc--;
} else {
SEGVN_VMSTAT_FLTVNPAGES(43);
ASSERT(pszc < szc);
szc = 0;
}
pgsz = page_get_pagesize(szc);
pages = btop(pgsz);
if (ierr == -2) {
a = (caddr_t)P2ALIGN((uintptr_t)a, pgsz);
ASSERT(a >= lpgaddr);
lpgeaddr = (caddr_t)P2ROUNDUP((uintptr_t)eaddr, pgsz);
off = svd->offset + (uintptr_t)(a - seg->s_base);
aindx = svd->anon_index + seg_page(seg, a);
vpage = (svd->vpage != NULL) ?
&svd->vpage[seg_page(seg, a)] : NULL;
} else {
ASSERT(IS_P2ALIGNED(a, pgsz));
ASSERT(IS_P2ALIGNED(lpgeaddr, pgsz));
lpgeaddr = (caddr_t)P2ROUNDUP((uintptr_t)eaddr, pgsz);
ASSERT(a < lpgeaddr);
if (a < addr) {
SEGVN_VMSTAT_FLTVNPAGES(44);
a = (caddr_t)P2ALIGN((uintptr_t)addr, pgsz);
ASSERT(a >= lpgaddr);
off = svd->offset +
(uintptr_t)(a - seg->s_base);
aindx = svd->anon_index + seg_page(seg, a);
vpage = (svd->vpage != NULL) ?
&svd->vpage[seg_page(seg, a)] : NULL;
}
}
}
out:
kmem_free(ppa, ppasize);
if (!err && !vop_size_err) {
SEGVN_VMSTAT_FLTVNPAGES(45);
return (0);
}
if (type == F_SOFTLOCK && a > lpgaddr) {
SEGVN_VMSTAT_FLTVNPAGES(46);
segvn_softunlock(seg, lpgaddr, a - lpgaddr, S_OTHER);
}
if (!vop_size_err) {
SEGVN_VMSTAT_FLTVNPAGES(47);
return (err);
}
ASSERT(brkcow || tron || type == F_SOFTLOCK);
SEGVN_VMSTAT_FLTVNPAGES(48);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_WRITER);
err = 0;
if (seg->s_szc != 0) {
segvn_fltvnpages_clrszc_cnt++;
ASSERT(svd->softlockcnt == 0);
err = segvn_clrszc(seg);
if (err != 0) {
segvn_fltvnpages_clrszc_err++;
}
}
ASSERT(err || seg->s_szc == 0);
SEGVN_LOCK_DOWNGRADE(seg->s_as, &svd->lock);
return (err == 0 ? IE_RETRY : FC_MAKE_ERR(err));
}
static faultcode_t
segvn_fault_anonpages(struct hat *hat, struct seg *seg, caddr_t lpgaddr,
caddr_t lpgeaddr, enum fault_type type, enum seg_rw rw, caddr_t addr,
caddr_t eaddr, int brkcow)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct anon_map *amp = svd->amp;
uchar_t segtype = svd->type;
uint_t szc = seg->s_szc;
size_t pgsz = page_get_pagesize(szc);
size_t maxpgsz = pgsz;
pgcnt_t pages = btop(pgsz);
uint_t ppaszc = szc;
caddr_t a = lpgaddr;
ulong_t aindx = svd->anon_index + seg_page(seg, a);
struct vpage *vpage = (svd->vpage != NULL) ?
&svd->vpage[seg_page(seg, a)] : NULL;
page_t **ppa;
uint_t ppa_szc;
faultcode_t err;
int ierr;
uint_t protchk, prot, vpprot;
ulong_t i;
int hat_flag = (type == F_SOFTLOCK) ? HAT_LOAD_LOCK : HAT_LOAD;
anon_sync_obj_t cookie;
int adjszc_chk;
int pgflags = (svd->tr_state == SEGVN_TR_ON) ? PG_LOCAL : 0;
ASSERT(szc != 0);
ASSERT(amp != NULL);
ASSERT(enable_mbit_wa == 0);
ASSERT(!(svd->flags & MAP_NORESERVE));
ASSERT(type != F_SOFTUNLOCK);
ASSERT(IS_P2ALIGNED(a, maxpgsz));
ASSERT(!brkcow || svd->tr_state == SEGVN_TR_OFF);
ASSERT(svd->tr_state != SEGVN_TR_INIT);
ASSERT(SEGVN_LOCK_HELD(seg->s_as, &svd->lock));
VM_STAT_COND_ADD(type == F_SOFTLOCK, segvnvmstats.fltanpages[0]);
VM_STAT_COND_ADD(type != F_SOFTLOCK, segvnvmstats.fltanpages[1]);
if (svd->flags & MAP_TEXT) {
hat_flag |= HAT_LOAD_TEXT;
}
if (svd->pageprot) {
prot = PROT_NONE;
switch (rw) {
case S_READ:
protchk = PROT_READ;
break;
case S_WRITE:
protchk = PROT_WRITE;
break;
case S_EXEC:
protchk = PROT_EXEC;
break;
case S_OTHER:
default:
protchk = PROT_READ | PROT_WRITE | PROT_EXEC;
break;
}
VM_STAT_ADD(segvnvmstats.fltanpages[2]);
} else {
protchk = PROT_NONE;
prot = svd->prot;
}
ppa = kmem_cache_alloc(segvn_szc_cache[ppaszc], KM_SLEEP);
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
ierr = 0;
for (;;) {
adjszc_chk = 0;
for (; a < lpgeaddr; a += pgsz, aindx += pages) {
if (svd->pageprot != 0 && IS_P2ALIGNED(a, maxpgsz)) {
VM_STAT_ADD(segvnvmstats.fltanpages[3]);
ASSERT(vpage != NULL);
prot = VPP_PROT(vpage);
ASSERT(sameprot(seg, a, maxpgsz));
if ((prot & protchk) == 0) {
err = FC_PROT;
goto error;
}
}
if (adjszc_chk && IS_P2ALIGNED(a, maxpgsz) &&
pgsz < maxpgsz) {
ASSERT(a > lpgaddr);
szc = seg->s_szc;
pgsz = maxpgsz;
pages = btop(pgsz);
ASSERT(IS_P2ALIGNED(aindx, pages));
lpgeaddr = (caddr_t)P2ROUNDUP((uintptr_t)eaddr,
pgsz);
}
if (type == F_SOFTLOCK) {
atomic_add_long((ulong_t *)&svd->softlockcnt,
pages);
}
anon_array_enter(amp, aindx, &cookie);
ppa_szc = (uint_t)-1;
ierr = anon_map_getpages(amp, aindx, szc, seg, a,
prot, &vpprot, ppa, &ppa_szc, vpage, rw, brkcow,
segvn_anypgsz, pgflags, svd->cred);
if (ierr != 0) {
anon_array_exit(&cookie);
VM_STAT_ADD(segvnvmstats.fltanpages[4]);
if (type == F_SOFTLOCK) {
atomic_add_long(
(ulong_t *)&svd->softlockcnt,
-pages);
}
if (ierr > 0) {
VM_STAT_ADD(segvnvmstats.fltanpages[6]);
err = FC_MAKE_ERR(ierr);
goto error;
}
break;
}
ASSERT(!IS_VMODSORT(ppa[0]->p_vnode));
ASSERT(segtype == MAP_SHARED ||
ppa[0]->p_szc <= szc);
ASSERT(segtype == MAP_PRIVATE ||
ppa[0]->p_szc >= szc);
if (lgrp_optimizations())
page_migrate(seg, a, ppa, pages);
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
if (segtype == MAP_SHARED) {
vpprot |= PROT_WRITE;
}
hat_memload_array(hat, a, pgsz, ppa,
prot & vpprot, hat_flag);
if (hat_flag & HAT_LOAD_LOCK) {
VM_STAT_ADD(segvnvmstats.fltanpages[7]);
} else {
VM_STAT_ADD(segvnvmstats.fltanpages[8]);
for (i = 0; i < pages; i++)
page_unlock(ppa[i]);
}
if (vpage != NULL)
vpage += pages;
anon_array_exit(&cookie);
adjszc_chk = 1;
}
if (a == lpgeaddr)
break;
ASSERT(a < lpgeaddr);
ASSERT(ierr == -1 || ierr == -2);
if (segvn_anypgsz) {
ASSERT(ierr == -2 || szc != 0);
ASSERT(ierr == -1 || szc < seg->s_szc);
szc = (ierr == -1) ? szc - 1 : szc + 1;
} else {
if (ppa_szc == (uint_t)-1) {
szc = (ierr == -1) ? 0 : seg->s_szc;
} else {
ASSERT(ppa_szc <= seg->s_szc);
ASSERT(ierr == -2 || ppa_szc < szc);
ASSERT(ierr == -1 || ppa_szc > szc);
szc = ppa_szc;
}
}
pgsz = page_get_pagesize(szc);
pages = btop(pgsz);
ASSERT(type != F_SOFTLOCK || ierr == -1 ||
(IS_P2ALIGNED(a, pgsz) && IS_P2ALIGNED(lpgeaddr, pgsz)));
if (type == F_SOFTLOCK) {
VM_STAT_ADD(segvnvmstats.fltanpages[9]);
continue;
} else if (ierr == -2) {
VM_STAT_ADD(segvnvmstats.fltanpages[10]);
a = (caddr_t)P2ALIGN((uintptr_t)a, pgsz);
ASSERT(a >= lpgaddr);
lpgeaddr = (caddr_t)P2ROUNDUP((uintptr_t)eaddr, pgsz);
aindx = svd->anon_index + seg_page(seg, a);
vpage = (svd->vpage != NULL) ?
&svd->vpage[seg_page(seg, a)] : NULL;
} else {
VM_STAT_ADD(segvnvmstats.fltanpages[11]);
ASSERT(IS_P2ALIGNED(a, pgsz));
ASSERT(IS_P2ALIGNED(lpgeaddr, pgsz));
lpgeaddr = (caddr_t)P2ROUNDUP((uintptr_t)eaddr, pgsz);
ASSERT(a < lpgeaddr);
if (a < addr) {
VM_STAT_ADD(segvnvmstats.fltanpages[12]);
a = (caddr_t)P2ALIGN((uintptr_t)addr, pgsz);
ASSERT(a >= lpgaddr);
aindx = svd->anon_index + seg_page(seg, a);
vpage = (svd->vpage != NULL) ?
&svd->vpage[seg_page(seg, a)] : NULL;
}
}
}
VM_STAT_ADD(segvnvmstats.fltanpages[13]);
ANON_LOCK_EXIT(&->a_rwlock);
kmem_cache_free(segvn_szc_cache[ppaszc], ppa);
return (0);
error:
VM_STAT_ADD(segvnvmstats.fltanpages[14]);
ANON_LOCK_EXIT(&->a_rwlock);
kmem_cache_free(segvn_szc_cache[ppaszc], ppa);
if (type == F_SOFTLOCK && a > lpgaddr) {
VM_STAT_ADD(segvnvmstats.fltanpages[15]);
segvn_softunlock(seg, lpgaddr, a - lpgaddr, S_OTHER);
}
return (err);
}
int fltadvice = 1;
static faultcode_t
segvn_fault(struct hat *hat, struct seg *seg, caddr_t addr, size_t len,
enum fault_type type, enum seg_rw rw)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
page_t **plp, **ppp, *pp;
u_offset_t off;
caddr_t a;
struct vpage *vpage;
uint_t vpprot, prot = 0;
int err;
page_t *pl[PVN_GETPAGE_NUM + 1];
size_t plsz, pl_alloc_sz;
size_t page;
ulong_t anon_index = 0;
struct anon_map *amp;
int dogetpage = 0;
caddr_t lpgaddr, lpgeaddr;
size_t pgsz;
anon_sync_obj_t cookie;
int brkcow = BREAK_COW_SHARE(rw, type, svd->type);
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
ASSERT(svd->amp == NULL || svd->rcookie == HAT_INVALID_REGION_COOKIE);
if (type == F_SOFTUNLOCK) {
if (rw == S_READ_NOCOW) {
rw = S_READ;
ASSERT(AS_WRITE_HELD(seg->s_as));
}
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_READER);
pgsz = (seg->s_szc == 0) ? PAGESIZE :
page_get_pagesize(seg->s_szc);
VM_STAT_COND_ADD(pgsz > PAGESIZE, segvnvmstats.fltanpages[16]);
CALC_LPG_REGION(pgsz, seg, addr, len, lpgaddr, lpgeaddr);
segvn_softunlock(seg, lpgaddr, lpgeaddr - lpgaddr, rw);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
ASSERT(svd->tr_state == SEGVN_TR_OFF ||
!HAT_IS_REGION_COOKIE_VALID(svd->rcookie));
if (brkcow == 0) {
if (svd->tr_state == SEGVN_TR_INIT) {
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_WRITER);
if (svd->tr_state == SEGVN_TR_INIT) {
ASSERT(svd->vp != NULL && svd->amp == NULL);
ASSERT(svd->flags & MAP_TEXT);
ASSERT(svd->type == MAP_PRIVATE);
segvn_textrepl(seg);
ASSERT(svd->tr_state != SEGVN_TR_INIT);
ASSERT(svd->tr_state != SEGVN_TR_ON ||
svd->amp != NULL);
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
}
} else if (svd->tr_state != SEGVN_TR_OFF) {
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_WRITER);
if (rw == S_WRITE && svd->tr_state != SEGVN_TR_OFF) {
ASSERT(!svd->pageprot && !(svd->prot & PROT_WRITE));
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (FC_PROT);
}
if (svd->tr_state == SEGVN_TR_ON) {
ASSERT(svd->vp != NULL && svd->amp != NULL);
segvn_textunrepl(seg, 0);
ASSERT(svd->amp == NULL &&
svd->tr_state == SEGVN_TR_OFF);
} else if (svd->tr_state != SEGVN_TR_OFF) {
svd->tr_state = SEGVN_TR_OFF;
}
ASSERT(svd->amp == NULL && svd->tr_state == SEGVN_TR_OFF);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
}
top:
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_READER);
if (svd->pageprot == 0) {
uint_t protchk;
switch (rw) {
case S_READ:
case S_READ_NOCOW:
protchk = PROT_READ;
break;
case S_WRITE:
protchk = PROT_WRITE;
break;
case S_EXEC:
protchk = PROT_EXEC;
break;
case S_OTHER:
default:
protchk = PROT_READ | PROT_WRITE | PROT_EXEC;
break;
}
if ((svd->prot & protchk) == 0) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (FC_PROT);
}
}
if (brkcow && HAT_IS_REGION_COOKIE_VALID(svd->rcookie)) {
ASSERT(svd->amp == NULL);
ASSERT(svd->tr_state == SEGVN_TR_OFF);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_WRITER);
if (HAT_IS_REGION_COOKIE_VALID(svd->rcookie)) {
ASSERT(svd->softlockcnt == 0);
hat_leave_region(seg->s_as->a_hat, svd->rcookie,
HAT_REGION_TEXT);
svd->rcookie = HAT_INVALID_REGION_COOKIE;
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
goto top;
}
if (type == F_SOFTLOCK && svd->vp != NULL && seg->s_szc != 0) {
int demote = 0;
if (rw != S_READ_NOCOW) {
demote = 1;
}
if (!demote && len > PAGESIZE) {
pgsz = page_get_pagesize(seg->s_szc);
CALC_LPG_REGION(pgsz, seg, addr, len, lpgaddr,
lpgeaddr);
if (lpgeaddr - lpgaddr > pgsz) {
demote = 1;
}
}
ASSERT(demote || AS_WRITE_HELD(seg->s_as));
if (demote) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_WRITER);
if (seg->s_szc != 0) {
segvn_vmpss_clrszc_cnt++;
ASSERT(svd->softlockcnt == 0);
err = segvn_clrszc(seg);
if (err) {
segvn_vmpss_clrszc_err++;
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (FC_MAKE_ERR(err));
}
}
ASSERT(seg->s_szc == 0);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
goto top;
}
}
if (svd->amp == NULL && (svd->vp == NULL || brkcow)) {
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_WRITER);
if (svd->amp == NULL) {
svd->amp = anonmap_alloc(seg->s_size, 0, ANON_SLEEP);
svd->amp->a_szc = seg->s_szc;
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
goto top;
}
if (rw == S_READ_NOCOW) {
ASSERT(type == F_SOFTLOCK);
ASSERT(AS_WRITE_HELD(seg->s_as));
rw = S_READ;
}
amp = svd->amp;
if (seg->s_szc != 0) {
pgsz = page_get_pagesize(seg->s_szc);
ASSERT(SEGVN_LOCK_HELD(seg->s_as, &svd->lock));
CALC_LPG_REGION(pgsz, seg, addr, len, lpgaddr, lpgeaddr);
if (svd->vp == NULL) {
err = segvn_fault_anonpages(hat, seg, lpgaddr,
lpgeaddr, type, rw, addr, addr + len, brkcow);
} else {
err = segvn_fault_vnodepages(hat, seg, lpgaddr,
lpgeaddr, type, rw, addr, addr + len, brkcow);
if (err == IE_RETRY) {
ASSERT(seg->s_szc == 0);
ASSERT(SEGVN_READ_HELD(seg->s_as, &svd->lock));
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
goto top;
}
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (err);
}
page = seg_page(seg, addr);
if (amp != NULL) {
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
anon_index = svd->anon_index + page;
if (type == F_PROT && rw == S_READ &&
svd->tr_state == SEGVN_TR_OFF &&
svd->type == MAP_PRIVATE && svd->pageprot == 0) {
size_t index = anon_index;
struct anon *ap;
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
for (a = addr; a < addr + len; a += PAGESIZE, index++) {
anon_array_enter(amp, index, &cookie);
ap = anon_get_ptr(amp->ahp, index);
anon_array_exit(&cookie);
if ((ap == NULL) || (ap->an_refcnt != 1)) {
ANON_LOCK_EXIT(&->a_rwlock);
goto slow;
}
}
hat_chgprot(seg->s_as->a_hat, addr, len, svd->prot);
ANON_LOCK_EXIT(&->a_rwlock);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
}
slow:
if (svd->vpage == NULL)
vpage = NULL;
else
vpage = &svd->vpage[page];
off = svd->offset + (uintptr_t)(addr - seg->s_base);
if ((page != 0) && fltadvice && svd->tr_state != SEGVN_TR_ON) {
struct vpage *vpp = NULL;
ulong_t fanon_index = 0;
size_t fpage;
u_offset_t pgoff, fpgoff;
struct vnode *fvp;
struct anon *fap = NULL;
if (svd->advice == MADV_SEQUENTIAL ||
(svd->pageadvice &&
VPP_ADVICE(vpage) == MADV_SEQUENTIAL)) {
pgoff = off - PAGESIZE;
fpage = page - 1;
if (vpage != NULL)
vpp = &svd->vpage[fpage];
if (amp != NULL)
fanon_index = svd->anon_index + fpage;
while (pgoff > svd->offset) {
if (svd->advice != MADV_SEQUENTIAL &&
(!svd->pageadvice || (vpage &&
VPP_ADVICE(vpp) != MADV_SEQUENTIAL)))
break;
fap = NULL;
if (amp != NULL) {
ANON_LOCK_ENTER(&->a_rwlock,
RW_READER);
anon_array_enter(amp, fanon_index,
&cookie);
fap = anon_get_ptr(amp->ahp,
fanon_index);
if (fap != NULL) {
swap_xlate(fap, &fvp, &fpgoff);
} else {
fpgoff = pgoff;
fvp = svd->vp;
}
anon_array_exit(&cookie);
ANON_LOCK_EXIT(&->a_rwlock);
} else {
fpgoff = pgoff;
fvp = svd->vp;
}
if (fvp == NULL)
break;
pp = page_lookup_nowait(fvp, fpgoff, SE_SHARED);
if (pp == NULL)
break;
if (pp->p_lckcnt == 0 && pp->p_cowcnt == 0) {
VN_HOLD(fvp);
page_unlock(pp);
(void) VOP_PUTPAGE(fvp,
(offset_t)fpgoff, PAGESIZE,
(B_DONTNEED|B_FREE|B_ASYNC),
svd->cred, NULL);
VN_RELE(fvp);
} else {
page_unlock(pp);
}
--vpp;
--fanon_index;
pgoff -= PAGESIZE;
}
}
}
plp = pl;
*plp = NULL;
pl_alloc_sz = 0;
if (svd->vp != NULL) {
u_offset_t vp_off;
size_t vp_len;
struct anon *ap;
vnode_t *vp;
vp_off = off;
vp_len = len;
if (amp == NULL)
dogetpage = 1;
else {
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
ap = anon_get_ptr(amp->ahp, anon_index);
if (len <= PAGESIZE)
dogetpage = (ap == NULL);
else
dogetpage = non_anon(amp->ahp, anon_index,
&vp_off, &vp_len);
ANON_LOCK_EXIT(&->a_rwlock);
}
if (dogetpage) {
enum seg_rw arw;
struct as *as = seg->s_as;
if (len > ptob((sizeof (pl) / sizeof (pl[0])) - 1)) {
pl_alloc_sz =
(btop(len) + 1) * sizeof (page_t *);
plp = kmem_alloc(pl_alloc_sz, KM_SLEEP);
plp[0] = NULL;
plsz = len;
} else if (rw == S_WRITE && svd->type == MAP_PRIVATE ||
svd->tr_state == SEGVN_TR_ON || rw == S_OTHER ||
(((size_t)(addr + PAGESIZE) <
(size_t)(seg->s_base + seg->s_size)) &&
hat_probe(as->a_hat, addr + PAGESIZE))) {
plsz = len;
} else {
plsz = MIN((size_t)PVN_GETPAGE_SZ, (size_t)
((seg->s_base + seg->s_size) - addr));
ASSERT((addr + plsz) <=
(seg->s_base + seg->s_size));
}
if (rw == S_WRITE && svd->type == MAP_PRIVATE) {
arw = S_READ;
} else {
arw = rw;
}
vp = svd->vp;
TRACE_3(TR_FAC_VM, TR_SEGVN_GETPAGE,
"segvn_getpage:seg %p addr %p vp %p",
seg, addr, vp);
err = VOP_GETPAGE(vp, (offset_t)vp_off, vp_len,
&vpprot, plp, plsz, seg, addr + (vp_off - off), arw,
svd->cred, NULL);
if (err) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
segvn_pagelist_rele(plp);
if (pl_alloc_sz)
kmem_free(plp, pl_alloc_sz);
return (FC_MAKE_ERR(err));
}
if (svd->type == MAP_PRIVATE)
vpprot &= ~PROT_WRITE;
}
}
if (amp != NULL)
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
for (a = addr; a < addr + len; a += PAGESIZE, off += PAGESIZE) {
err = segvn_faultpage(hat, seg, a, off, vpage, plp, vpprot,
type, rw, brkcow);
if (err) {
if (amp != NULL)
ANON_LOCK_EXIT(&->a_rwlock);
if (type == F_SOFTLOCK && a > addr) {
segvn_softunlock(seg, addr, (a - addr),
S_OTHER);
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
segvn_pagelist_rele(plp);
if (pl_alloc_sz)
kmem_free(plp, pl_alloc_sz);
return (err);
}
if (vpage) {
vpage++;
} else if (svd->vpage) {
page = seg_page(seg, addr);
vpage = &svd->vpage[++page];
}
}
if (!dogetpage)
goto done;
if (svd->pageprot == 0)
prot = svd->prot & vpprot;
for (ppp = plp; (pp = *ppp) != NULL; ppp++) {
size_t diff;
struct anon *ap;
int anon_index;
anon_sync_obj_t cookie;
int hat_flag = HAT_LOAD_ADV;
if (svd->flags & MAP_TEXT) {
hat_flag |= HAT_LOAD_TEXT;
}
if (pp == PAGE_HANDLED)
continue;
if (svd->tr_state != SEGVN_TR_ON &&
pp->p_offset >= svd->offset &&
pp->p_offset < svd->offset + seg->s_size) {
diff = pp->p_offset - svd->offset;
ASSERT(svd->vp == pp->p_vnode);
page = btop(diff);
if (svd->pageprot)
prot = VPP_PROT(&svd->vpage[page]) & vpprot;
if (amp != NULL) {
anon_index = svd->anon_index + page;
anon_array_enter(amp, anon_index, &cookie);
ap = anon_get_ptr(amp->ahp, anon_index);
}
if ((amp == NULL) || (ap == NULL)) {
if (IS_VMODSORT(pp->p_vnode) ||
enable_mbit_wa) {
if (rw == S_WRITE)
hat_setmod(pp);
else if (rw != S_OTHER &&
!hat_ismod(pp))
prot &= ~PROT_WRITE;
}
ASSERT(amp == NULL ||
svd->rcookie == HAT_INVALID_REGION_COOKIE);
if ((prot & PROT_READ) && !PP_ISMIGRATE(pp)) {
hat_memload_region(hat,
seg->s_base + diff,
pp, prot, hat_flag,
svd->rcookie);
}
}
if (amp != NULL)
anon_array_exit(&cookie);
}
page_unlock(pp);
}
done:
if (amp != NULL)
ANON_LOCK_EXIT(&->a_rwlock);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
if (pl_alloc_sz)
kmem_free(plp, pl_alloc_sz);
return (0);
}
static faultcode_t
segvn_faulta(struct seg *seg, caddr_t addr)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
int err;
struct anon_map *amp;
vnode_t *vp;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_READER);
if ((amp = svd->amp) != NULL) {
struct anon *ap;
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
if ((ap = anon_get_ptr(amp->ahp,
svd->anon_index + seg_page(seg, addr))) != NULL) {
err = anon_getpage(&ap, NULL, NULL,
0, seg, addr, S_READ, svd->cred);
ANON_LOCK_EXIT(&->a_rwlock);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
if (err)
return (FC_MAKE_ERR(err));
return (0);
}
ANON_LOCK_EXIT(&->a_rwlock);
}
if (svd->vp == NULL) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
vp = svd->vp;
TRACE_3(TR_FAC_VM, TR_SEGVN_GETPAGE,
"segvn_getpage:seg %p addr %p vp %p", seg, addr, vp);
err = VOP_GETPAGE(vp,
(offset_t)(svd->offset + (uintptr_t)(addr - seg->s_base)),
PAGESIZE, NULL, NULL, 0, seg, addr,
S_OTHER, svd->cred, NULL);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
if (err)
return (FC_MAKE_ERR(err));
return (0);
}
static int
segvn_setprot(struct seg *seg, caddr_t addr, size_t len, uint_t prot)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct vpage *cvp, *svp = NULL, *evp = NULL;
struct vnode *vp;
size_t pgsz;
pgcnt_t pgcnt = 0;
anon_sync_obj_t cookie;
int unload_done = 0;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
if ((svd->maxprot & prot) != prot)
return (EACCES);
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_WRITER);
if (!svd->pageprot && svd->prot == prot) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
if (svd->softlockcnt > 0) {
ASSERT(svd->tr_state == SEGVN_TR_OFF);
if (svd->type == MAP_SHARED) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (EAGAIN);
}
segvn_purge(seg);
if (svd->softlockcnt > 0) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (EAGAIN);
}
}
if (HAT_IS_REGION_COOKIE_VALID(svd->rcookie)) {
ASSERT(svd->amp == NULL);
ASSERT(svd->tr_state == SEGVN_TR_OFF);
hat_leave_region(seg->s_as->a_hat, svd->rcookie,
HAT_REGION_TEXT);
svd->rcookie = HAT_INVALID_REGION_COOKIE;
unload_done = 1;
} else if (svd->tr_state == SEGVN_TR_INIT) {
svd->tr_state = SEGVN_TR_OFF;
} else if (svd->tr_state == SEGVN_TR_ON) {
ASSERT(svd->amp != NULL);
segvn_textunrepl(seg, 0);
ASSERT(svd->amp == NULL && svd->tr_state == SEGVN_TR_OFF);
unload_done = 1;
}
if ((prot & PROT_WRITE) && svd->type == MAP_SHARED &&
svd->vp != NULL && (svd->vp->v_flag & VVMEXEC)) {
ASSERT(vn_is_mapped(svd->vp, V_WRITE));
segvn_inval_trcache(svd->vp);
}
if (seg->s_szc != 0) {
int err;
pgsz = page_get_pagesize(seg->s_szc);
pgcnt = pgsz >> PAGESHIFT;
ASSERT(IS_P2ALIGNED(pgcnt, pgcnt));
if (!IS_P2ALIGNED(addr, pgsz) || !IS_P2ALIGNED(len, pgsz)) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
ASSERT(seg->s_base != addr || seg->s_size != len);
if (AS_READ_HELD(seg->s_as))
return (IE_RETRY);
VM_STAT_ADD(segvnvmstats.demoterange[1]);
if (svd->type == MAP_PRIVATE || svd->vp != NULL) {
err = segvn_demote_range(seg, addr, len,
SDR_END, 0);
} else {
uint_t szcvec = map_pgszcvec(seg->s_base,
pgsz, (uintptr_t)seg->s_base,
(svd->flags & MAP_TEXT), MAPPGSZC_SHM, 0);
err = segvn_demote_range(seg, addr, len,
SDR_END, szcvec);
}
if (err == 0)
return (IE_RETRY);
if (err == ENOMEM)
return (IE_NOMEM);
return (err);
}
}
if (svd->type == MAP_PRIVATE) {
if (prot & PROT_WRITE) {
if (!(svd->flags & MAP_NORESERVE) &&
!(svd->swresv && svd->pageswap == 0)) {
size_t sz = 0;
if (addr == seg->s_base &&
len == seg->s_size &&
svd->pageswap == 0) {
sz = seg->s_size;
} else {
segvn_vpage(seg);
if (svd->vpage == NULL) {
SEGVN_LOCK_EXIT(seg->s_as,
&svd->lock);
return (ENOMEM);
}
svp = &svd->vpage[seg_page(seg, addr)];
evp = &svd->vpage[seg_page(seg,
addr + len)];
if (svd->pageswap == 0) {
sz = len;
} else {
for (cvp = svp; cvp < evp;
cvp++) {
if (!VPP_ISSWAPRES(cvp))
sz++;
}
sz <<= PAGESHIFT;
}
}
if (anon_resv_zone(sz,
seg->s_as->a_proc->p_zone) == 0) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (IE_NOMEM);
}
if (svd->pageswap == 0 && sz == seg->s_size) {
svd->swresv = sz;
} else {
ASSERT(svd->vpage != NULL);
svd->swresv += sz;
svd->pageswap = 1;
for (cvp = svp; cvp < evp; cvp++) {
if (!VPP_ISSWAPRES(cvp))
VPP_SETSWAPRES(cvp);
}
}
}
} else {
if (svd->swresv != 0 && svd->vp != NULL &&
svd->amp == NULL && addr == seg->s_base &&
len == seg->s_size && svd->pageprot == 0) {
ASSERT(svd->pageswap == 0);
anon_unresv_zone(svd->swresv,
seg->s_as->a_proc->p_zone);
svd->swresv = 0;
TRACE_3(TR_FAC_VM, TR_ANON_PROC,
"anon proc:%p %lu %u", seg, 0, 0);
}
}
}
if (addr == seg->s_base && len == seg->s_size && svd->vpage == NULL) {
if (svd->prot == prot) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
svd->prot = (uchar_t)prot;
} else if (svd->type == MAP_PRIVATE) {
struct anon *ap = NULL;
page_t *pp;
u_offset_t offset, off;
struct anon_map *amp;
ulong_t anon_idx = 0;
segvn_vpage(seg);
if (svd->vpage == NULL) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (ENOMEM);
}
svd->pageprot = 1;
if ((amp = svd->amp) != NULL) {
anon_idx = svd->anon_index + seg_page(seg, addr);
ASSERT(seg->s_szc == 0 ||
IS_P2ALIGNED(anon_idx, pgcnt));
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
}
offset = svd->offset + (uintptr_t)(addr - seg->s_base);
evp = &svd->vpage[seg_page(seg, addr + len)];
for (svp = &svd->vpage[seg_page(seg, addr)]; svp < evp; svp++) {
if (seg->s_szc != 0) {
if (amp != NULL) {
anon_array_enter(amp, anon_idx,
&cookie);
}
if (IS_P2ALIGNED(anon_idx, pgcnt) &&
!segvn_claim_pages(seg, svp, offset,
anon_idx, prot)) {
if (amp != NULL) {
anon_array_exit(&cookie);
}
break;
}
if (amp != NULL) {
anon_array_exit(&cookie);
}
anon_idx++;
} else {
if (amp != NULL) {
anon_array_enter(amp, anon_idx,
&cookie);
ap = anon_get_ptr(amp->ahp, anon_idx++);
}
if (VPP_ISPPLOCK(svp) &&
VPP_PROT(svp) != prot) {
if (amp == NULL || ap == NULL) {
vp = svd->vp;
off = offset;
} else
swap_xlate(ap, &vp, &off);
if (amp != NULL)
anon_array_exit(&cookie);
if ((pp = page_lookup(vp, off,
SE_SHARED)) == NULL) {
panic("segvn_setprot: no page");
}
ASSERT(seg->s_szc == 0);
if ((VPP_PROT(svp) ^ prot) &
PROT_WRITE) {
if (prot & PROT_WRITE) {
if (!page_addclaim(
pp)) {
page_unlock(pp);
break;
}
} else {
if (!page_subclaim(
pp)) {
page_unlock(pp);
break;
}
}
}
page_unlock(pp);
} else if (amp != NULL)
anon_array_exit(&cookie);
}
VPP_SETPROT(svp, prot);
offset += PAGESIZE;
}
if (amp != NULL)
ANON_LOCK_EXIT(&->a_rwlock);
if (svp != evp) {
if (unload_done) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (IE_NOMEM);
}
len = (svp - &svd->vpage[seg_page(seg, addr)]) *
PAGESIZE;
ASSERT(seg->s_szc == 0 || IS_P2ALIGNED(len, pgsz));
if (len != 0)
hat_unload(seg->s_as->a_hat, addr,
len, HAT_UNLOAD);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (IE_NOMEM);
}
} else {
segvn_vpage(seg);
if (svd->vpage == NULL) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (ENOMEM);
}
svd->pageprot = 1;
evp = &svd->vpage[seg_page(seg, addr + len)];
for (svp = &svd->vpage[seg_page(seg, addr)]; svp < evp; svp++) {
VPP_SETPROT(svp, prot);
}
}
if (unload_done) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
if (((prot & PROT_WRITE) != 0 &&
(svd->vp != NULL || svd->type == MAP_PRIVATE)) ||
(prot & ~PROT_USER) == PROT_NONE) {
hat_unload(seg->s_as->a_hat, addr, len, HAT_UNLOAD);
} else {
hat_chgattr(seg->s_as->a_hat, addr, len, prot);
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
static int
segvn_setpagesize(struct seg *seg, caddr_t addr, size_t len, uint_t szc)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct segvn_data *nsvd;
struct anon_map *amp = svd->amp;
struct seg *nseg;
caddr_t eaddr = addr + len, a;
size_t pgsz = page_get_pagesize(szc);
pgcnt_t pgcnt = page_get_pagecnt(szc);
int err;
u_offset_t off = svd->offset + (uintptr_t)(addr - seg->s_base);
ASSERT(seg->s_as && AS_WRITE_HELD(seg->s_as));
ASSERT(addr >= seg->s_base && eaddr <= seg->s_base + seg->s_size);
if (seg->s_szc == szc || segvn_lpg_disable != 0) {
return (0);
}
if (!IS_P2ALIGNED(addr, pgsz) ||
(!IS_P2ALIGNED(eaddr, pgsz) &&
eaddr != seg->s_base + seg->s_size)) {
segvn_setpgsz_align_err++;
return (EINVAL);
}
if (amp != NULL && svd->type == MAP_SHARED) {
ulong_t an_idx = svd->anon_index + seg_page(seg, addr);
if (!IS_P2ALIGNED(an_idx, pgcnt)) {
segvn_setpgsz_anon_align_err++;
return (EINVAL);
}
}
if ((svd->flags & MAP_NORESERVE) || seg->s_as == &kas ||
szc > segvn_maxpgszc) {
return (EINVAL);
}
if (svd->vp != NULL &&
(IS_SWAPFSVP(svd->vp) || VN_ISKAS(svd->vp))) {
return (EINVAL);
}
if (seg->s_szc == 0 && svd->vp != NULL &&
map_addr_vacalign_check(addr, off)) {
return (EINVAL);
}
if (svd->pageprot) {
for (a = addr; a < eaddr; a += pgsz) {
if ((a + pgsz) > eaddr) {
if (!sameprot(seg, a, eaddr - a)) {
return (EINVAL);
}
} else {
if (!sameprot(seg, a, pgsz)) {
return (EINVAL);
}
}
}
}
if (svd->softlockcnt > 0) {
ASSERT(svd->tr_state == SEGVN_TR_OFF);
if (svd->type == MAP_SHARED) {
return (EAGAIN);
}
segvn_purge(seg);
if (svd->softlockcnt > 0) {
return (EAGAIN);
}
}
if (HAT_IS_REGION_COOKIE_VALID(svd->rcookie)) {
ASSERT(svd->amp == NULL);
ASSERT(svd->tr_state == SEGVN_TR_OFF);
hat_leave_region(seg->s_as->a_hat, svd->rcookie,
HAT_REGION_TEXT);
svd->rcookie = HAT_INVALID_REGION_COOKIE;
} else if (svd->tr_state == SEGVN_TR_INIT) {
svd->tr_state = SEGVN_TR_OFF;
} else if (svd->tr_state == SEGVN_TR_ON) {
ASSERT(svd->amp != NULL);
segvn_textunrepl(seg, 1);
ASSERT(svd->amp == NULL && svd->tr_state == SEGVN_TR_OFF);
amp = NULL;
}
if (addr != seg->s_base || eaddr != (seg->s_base + seg->s_size)) {
if (szc < seg->s_szc) {
VM_STAT_ADD(segvnvmstats.demoterange[2]);
err = segvn_demote_range(seg, addr, len, SDR_RANGE, 0);
if (err == 0) {
return (IE_RETRY);
}
if (err == ENOMEM) {
return (IE_NOMEM);
}
return (err);
}
if (addr != seg->s_base) {
nseg = segvn_split_seg(seg, addr);
if (eaddr != (nseg->s_base + nseg->s_size)) {
(void) segvn_split_seg(nseg, eaddr);
}
return (IE_RETRY);
}
if (eaddr != (seg->s_base + seg->s_size)) {
(void) segvn_split_seg(seg, eaddr);
}
return (IE_RETRY);
}
if ((err = segvn_clrszc(seg)) != 0) {
if (err == ENOMEM) {
err = IE_NOMEM;
}
return (err);
}
ASSERT(seg->s_szc == 0);
if (!IS_P2ALIGNED(eaddr, pgsz)) {
nseg = AS_SEGNEXT(seg->s_as, seg);
if (nseg == NULL || nseg == seg || eaddr != nseg->s_base) {
return (ENOMEM);
}
if (nseg->s_ops != &segvn_ops) {
return (EINVAL);
}
nsvd = (struct segvn_data *)nseg->s_data;
if (nsvd->softlockcnt > 0) {
if (nsvd->type == MAP_SHARED) {
return (EAGAIN);
}
segvn_purge(nseg);
if (nsvd->softlockcnt > 0) {
return (EAGAIN);
}
}
err = segvn_clrszc(nseg);
if (err == ENOMEM) {
err = IE_NOMEM;
}
if (err != 0) {
return (err);
}
ASSERT(nsvd->rcookie == HAT_INVALID_REGION_COOKIE);
err = segvn_concat(seg, nseg, 1);
if (err == -1) {
return (EINVAL);
}
if (err == -2) {
return (IE_NOMEM);
}
return (IE_RETRY);
}
if (amp != NULL) {
if (!IS_P2ALIGNED(svd->anon_index, pgcnt)) {
struct anon_hdr *nahp;
ASSERT(svd->type == MAP_PRIVATE);
ANON_LOCK_ENTER(&->a_rwlock, RW_WRITER);
ASSERT(amp->refcnt == 1);
nahp = anon_create(btop(amp->size), ANON_NOSLEEP);
if (nahp == NULL) {
ANON_LOCK_EXIT(&->a_rwlock);
return (IE_NOMEM);
}
if (anon_copy_ptr(amp->ahp, svd->anon_index,
nahp, 0, btop(seg->s_size), ANON_NOSLEEP)) {
anon_release(nahp, btop(amp->size));
ANON_LOCK_EXIT(&->a_rwlock);
return (IE_NOMEM);
}
anon_release(amp->ahp, btop(amp->size));
amp->ahp = nahp;
svd->anon_index = 0;
ANON_LOCK_EXIT(&->a_rwlock);
}
}
if (svd->vp != NULL && szc != 0) {
struct vattr va;
u_offset_t eoffpage = svd->offset;
va.va_mask = AT_SIZE;
eoffpage += seg->s_size;
eoffpage = btopr(eoffpage);
if (VOP_GETATTR(svd->vp, &va, 0, svd->cred, NULL) != 0) {
segvn_setpgsz_getattr_err++;
return (EINVAL);
}
if (btopr(va.va_size) < eoffpage) {
segvn_setpgsz_eof_err++;
return (EINVAL);
}
if (amp != NULL) {
if ((err = anon_fill_cow_holes(seg, seg->s_base,
amp->ahp, svd->anon_index, svd->vp, svd->offset,
seg->s_size, szc, svd->prot, svd->vpage,
svd->cred)) != 0) {
return (EINVAL);
}
}
segvn_setvnode_mpss(svd->vp);
}
if (amp != NULL) {
ANON_LOCK_ENTER(&->a_rwlock, RW_WRITER);
if (svd->type == MAP_PRIVATE) {
amp->a_szc = szc;
} else if (szc > amp->a_szc) {
amp->a_szc = szc;
}
ANON_LOCK_EXIT(&->a_rwlock);
}
seg->s_szc = szc;
return (0);
}
static int
segvn_clrszc(struct seg *seg)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct anon_map *amp = svd->amp;
size_t pgsz;
pgcnt_t pages;
int err = 0;
caddr_t a = seg->s_base;
caddr_t ea = a + seg->s_size;
ulong_t an_idx = svd->anon_index;
vnode_t *vp = svd->vp;
struct vpage *vpage = svd->vpage;
page_t *anon_pl[1 + 1], *pp;
struct anon *ap, *oldap;
uint_t prot = svd->prot, vpprot;
int pageflag = 0;
ASSERT(AS_WRITE_HELD(seg->s_as) ||
SEGVN_WRITE_HELD(seg->s_as, &svd->lock));
ASSERT(svd->softlockcnt == 0);
if (vp == NULL && amp == NULL) {
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
seg->s_szc = 0;
return (0);
}
if (HAT_IS_REGION_COOKIE_VALID(svd->rcookie)) {
ASSERT(svd->amp == NULL);
ASSERT(svd->tr_state == SEGVN_TR_OFF);
hat_leave_region(seg->s_as->a_hat, svd->rcookie,
HAT_REGION_TEXT);
svd->rcookie = HAT_INVALID_REGION_COOKIE;
} else if (svd->tr_state == SEGVN_TR_ON) {
ASSERT(svd->amp != NULL);
segvn_textunrepl(seg, 1);
ASSERT(svd->amp == NULL && svd->tr_state == SEGVN_TR_OFF);
amp = NULL;
} else {
if (svd->tr_state != SEGVN_TR_OFF) {
ASSERT(svd->tr_state == SEGVN_TR_INIT);
svd->tr_state = SEGVN_TR_OFF;
}
hat_unload(seg->s_as->a_hat, seg->s_base, seg->s_size,
HAT_UNLOAD_UNMAP);
}
if (amp == NULL || svd->type == MAP_SHARED) {
seg->s_szc = 0;
return (0);
}
pgsz = page_get_pagesize(seg->s_szc);
pages = btop(pgsz);
ANON_LOCK_ENTER(&->a_rwlock, RW_WRITER);
for (; a < ea; a += pgsz, an_idx += pages) {
if ((oldap = anon_get_ptr(amp->ahp, an_idx)) != NULL) {
ASSERT(vpage != NULL || svd->pageprot == 0);
if (vpage != NULL) {
ASSERT(sameprot(seg, a, pgsz));
prot = VPP_PROT(vpage);
pageflag = VPP_ISPPLOCK(vpage) ? LOCK_PAGE : 0;
}
if (seg->s_szc != 0) {
ASSERT(vp == NULL || anon_pages(amp->ahp,
an_idx, pages) == pages);
if ((err = anon_map_demotepages(amp, an_idx,
seg, a, prot, vpage, svd->cred)) != 0) {
goto out;
}
} else {
if (oldap->an_refcnt == 1) {
continue;
}
if ((err = anon_getpage(&oldap, &vpprot,
anon_pl, PAGESIZE, seg, a, S_READ,
svd->cred))) {
goto out;
}
if ((pp = anon_private(&ap, seg, a, prot,
anon_pl[0], pageflag, svd->cred)) == NULL) {
err = ENOMEM;
goto out;
}
anon_decref(oldap);
(void) anon_set_ptr(amp->ahp, an_idx, ap,
ANON_SLEEP);
page_unlock(pp);
}
}
vpage = (vpage == NULL) ? NULL : vpage + pages;
}
amp->a_szc = 0;
seg->s_szc = 0;
out:
ANON_LOCK_EXIT(&->a_rwlock);
return (err);
}
static int
segvn_claim_pages(
struct seg *seg,
struct vpage *svp,
u_offset_t off,
ulong_t anon_idx,
uint_t prot)
{
pgcnt_t pgcnt = page_get_pagecnt(seg->s_szc);
size_t ppasize = (pgcnt + 1) * sizeof (page_t *);
page_t **ppa;
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct anon_map *amp = svd->amp;
struct vpage *evp = svp + pgcnt;
caddr_t addr = ((uintptr_t)(svp - svd->vpage) << PAGESHIFT)
+ seg->s_base;
struct anon *ap;
struct vnode *vp = svd->vp;
page_t *pp;
pgcnt_t pg_idx, i;
int err = 0;
anoff_t aoff;
int anon = (amp != NULL) ? 1 : 0;
ASSERT(svd->type == MAP_PRIVATE);
ASSERT(svd->vpage != NULL);
ASSERT(seg->s_szc != 0);
ASSERT(IS_P2ALIGNED(pgcnt, pgcnt));
ASSERT(amp == NULL || IS_P2ALIGNED(anon_idx, pgcnt));
ASSERT(sameprot(seg, addr, pgcnt << PAGESHIFT));
if (VPP_PROT(svp) == prot)
return (1);
if (!((VPP_PROT(svp) ^ prot) & PROT_WRITE))
return (1);
ppa = kmem_alloc(ppasize, KM_SLEEP);
if (anon && vp != NULL) {
if (anon_get_ptr(amp->ahp, anon_idx) == NULL) {
anon = 0;
ASSERT(!anon_pages(amp->ahp, anon_idx, pgcnt));
}
ASSERT(!anon ||
anon_pages(amp->ahp, anon_idx, pgcnt) == pgcnt);
}
for (*ppa = NULL, pg_idx = 0; svp < evp; svp++, anon_idx++) {
if (!VPP_ISPPLOCK(svp))
continue;
if (anon) {
ap = anon_get_ptr(amp->ahp, anon_idx);
if (ap == NULL) {
panic("segvn_claim_pages: no anon slot");
}
swap_xlate(ap, &vp, &aoff);
off = (u_offset_t)aoff;
}
ASSERT(vp != NULL);
if ((pp = page_lookup(vp,
(u_offset_t)off, SE_SHARED)) == NULL) {
panic("segvn_claim_pages: no page");
}
ppa[pg_idx++] = pp;
off += PAGESIZE;
}
if (ppa[0] == NULL) {
kmem_free(ppa, ppasize);
return (1);
}
ASSERT(pg_idx <= pgcnt);
ppa[pg_idx] = NULL;
if (ppa[0]->p_szc == seg->s_szc) {
if (prot & PROT_WRITE)
err = page_addclaim_pages(ppa);
else
err = page_subclaim_pages(ppa);
} else {
for (i = 0; ppa[i]; i += pgcnt) {
ASSERT(IS_P2ALIGNED(page_pptonum(ppa[i]), pgcnt));
if (prot & PROT_WRITE)
err = page_addclaim_pages(&ppa[i]);
else
err = page_subclaim_pages(&ppa[i]);
if (err == 0)
break;
}
}
for (i = 0; i < pg_idx; i++) {
ASSERT(ppa[i] != NULL);
page_unlock(ppa[i]);
}
kmem_free(ppa, ppasize);
return (err);
}
static struct seg *
segvn_split_seg(struct seg *seg, caddr_t addr)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct seg *nseg;
size_t nsize;
struct segvn_data *nsvd;
ASSERT(AS_WRITE_HELD(seg->s_as));
ASSERT(svd->tr_state == SEGVN_TR_OFF);
ASSERT(addr >= seg->s_base);
ASSERT(addr <= seg->s_base + seg->s_size);
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
if (addr == seg->s_base || addr == seg->s_base + seg->s_size)
return (seg);
nsize = seg->s_base + seg->s_size - addr;
seg->s_size = addr - seg->s_base;
nseg = seg_alloc(seg->s_as, addr, nsize);
ASSERT(nseg != NULL);
nseg->s_ops = seg->s_ops;
nsvd = kmem_cache_alloc(segvn_cache, KM_SLEEP);
nseg->s_data = (void *)nsvd;
nseg->s_szc = seg->s_szc;
*nsvd = *svd;
ASSERT(nsvd->rcookie == HAT_INVALID_REGION_COOKIE);
nsvd->seg = nseg;
rw_init(&nsvd->lock, NULL, RW_DEFAULT, NULL);
if (nsvd->vp != NULL) {
VN_HOLD(nsvd->vp);
nsvd->offset = svd->offset +
(uintptr_t)(nseg->s_base - seg->s_base);
if (nsvd->type == MAP_SHARED)
lgrp_shm_policy_init(NULL, nsvd->vp);
} else {
nsvd->offset = 0;
}
ASSERT(svd->softlockcnt == 0);
ASSERT(svd->softlockcnt_sbase == 0);
ASSERT(svd->softlockcnt_send == 0);
crhold(svd->cred);
if (svd->vpage != NULL) {
size_t bytes = vpgtob(seg_pages(seg));
size_t nbytes = vpgtob(seg_pages(nseg));
struct vpage *ovpage = svd->vpage;
svd->vpage = kmem_alloc(bytes, KM_SLEEP);
bcopy(ovpage, svd->vpage, bytes);
nsvd->vpage = kmem_alloc(nbytes, KM_SLEEP);
bcopy(ovpage + seg_pages(seg), nsvd->vpage, nbytes);
kmem_free(ovpage, bytes + nbytes);
}
if (svd->amp != NULL && svd->type == MAP_PRIVATE) {
struct anon_map *oamp = svd->amp, *namp;
struct anon_hdr *nahp;
ANON_LOCK_ENTER(&oamp->a_rwlock, RW_WRITER);
ASSERT(oamp->refcnt == 1);
nahp = anon_create(btop(seg->s_size), ANON_SLEEP);
(void) anon_copy_ptr(oamp->ahp, svd->anon_index,
nahp, 0, btop(seg->s_size), ANON_SLEEP);
namp = anonmap_alloc(nseg->s_size, 0, ANON_SLEEP);
namp->a_szc = nseg->s_szc;
(void) anon_copy_ptr(oamp->ahp,
svd->anon_index + btop(seg->s_size),
namp->ahp, 0, btop(nseg->s_size), ANON_SLEEP);
anon_release(oamp->ahp, btop(oamp->size));
oamp->ahp = nahp;
oamp->size = seg->s_size;
svd->anon_index = 0;
nsvd->amp = namp;
nsvd->anon_index = 0;
ANON_LOCK_EXIT(&oamp->a_rwlock);
} else if (svd->amp != NULL) {
pgcnt_t pgcnt = page_get_pagecnt(seg->s_szc);
ASSERT(svd->amp == nsvd->amp);
ASSERT(seg->s_szc <= svd->amp->a_szc);
nsvd->anon_index = svd->anon_index + seg_pages(seg);
ASSERT(IS_P2ALIGNED(nsvd->anon_index, pgcnt));
ANON_LOCK_ENTER(&svd->amp->a_rwlock, RW_WRITER);
svd->amp->refcnt++;
ANON_LOCK_EXIT(&svd->amp->a_rwlock);
}
if (svd->swresv) {
if (svd->flags & MAP_NORESERVE) {
size_t oswresv;
ASSERT(svd->amp);
oswresv = svd->swresv;
svd->swresv = ptob(anon_pages(svd->amp->ahp,
svd->anon_index, btop(seg->s_size)));
nsvd->swresv = ptob(anon_pages(nsvd->amp->ahp,
nsvd->anon_index, btop(nseg->s_size)));
ASSERT(oswresv >= (svd->swresv + nsvd->swresv));
} else {
if (svd->pageswap) {
svd->swresv = segvn_count_swap_by_vpages(seg);
ASSERT(nsvd->swresv >= svd->swresv);
nsvd->swresv -= svd->swresv;
} else {
ASSERT(svd->swresv == seg->s_size +
nseg->s_size);
svd->swresv = seg->s_size;
nsvd->swresv = nseg->s_size;
}
}
}
return (nseg);
}
static int
segvn_demote_range(
struct seg *seg,
caddr_t addr,
size_t len,
int flag,
uint_t szcvec)
{
caddr_t eaddr = addr + len;
caddr_t lpgaddr, lpgeaddr;
struct seg *nseg;
struct seg *badseg1 = NULL;
struct seg *badseg2 = NULL;
size_t pgsz;
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
int err;
uint_t szc = seg->s_szc;
uint_t tszcvec;
ASSERT(AS_WRITE_HELD(seg->s_as));
ASSERT(svd->tr_state == SEGVN_TR_OFF);
ASSERT(szc != 0);
pgsz = page_get_pagesize(szc);
ASSERT(seg->s_base != addr || seg->s_size != len);
ASSERT(addr >= seg->s_base && eaddr <= seg->s_base + seg->s_size);
ASSERT(svd->softlockcnt == 0);
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
ASSERT(szcvec == 0 || (flag == SDR_END && svd->type == MAP_SHARED));
CALC_LPG_REGION(pgsz, seg, addr, len, lpgaddr, lpgeaddr);
ASSERT(flag == SDR_RANGE || eaddr < lpgeaddr || addr > lpgaddr);
if (flag == SDR_RANGE) {
badseg1 = nseg = segvn_split_seg(seg, lpgaddr);
(void) segvn_split_seg(nseg, lpgeaddr);
ASSERT(badseg1->s_base == lpgaddr);
ASSERT(badseg1->s_size == lpgeaddr - lpgaddr);
} else if (addr != lpgaddr) {
ASSERT(flag == SDR_END);
badseg1 = nseg = segvn_split_seg(seg, lpgaddr);
if (eaddr != lpgeaddr && eaddr > lpgaddr + pgsz &&
eaddr < lpgaddr + 2 * pgsz) {
(void) segvn_split_seg(nseg, lpgeaddr);
ASSERT(badseg1->s_base == lpgaddr);
ASSERT(badseg1->s_size == 2 * pgsz);
} else {
nseg = segvn_split_seg(nseg, lpgaddr + pgsz);
ASSERT(badseg1->s_base == lpgaddr);
ASSERT(badseg1->s_size == pgsz);
if (eaddr != lpgeaddr && eaddr > lpgaddr + pgsz) {
ASSERT(lpgeaddr - lpgaddr > 2 * pgsz);
nseg = segvn_split_seg(nseg, lpgeaddr - pgsz);
badseg2 = nseg;
(void) segvn_split_seg(nseg, lpgeaddr);
ASSERT(badseg2->s_base == lpgeaddr - pgsz);
ASSERT(badseg2->s_size == pgsz);
}
}
} else {
ASSERT(flag == SDR_END);
ASSERT(eaddr < lpgeaddr);
badseg1 = nseg = segvn_split_seg(seg, lpgeaddr - pgsz);
(void) segvn_split_seg(nseg, lpgeaddr);
ASSERT(badseg1->s_base == lpgeaddr - pgsz);
ASSERT(badseg1->s_size == pgsz);
}
ASSERT(badseg1 != NULL);
ASSERT(badseg1->s_szc == szc);
ASSERT(flag == SDR_RANGE || badseg1->s_size == pgsz ||
badseg1->s_size == 2 * pgsz);
ASSERT(sameprot(badseg1, badseg1->s_base, pgsz));
ASSERT(badseg1->s_size == pgsz ||
sameprot(badseg1, badseg1->s_base + pgsz, pgsz));
if (err = segvn_clrszc(badseg1)) {
return (err);
}
ASSERT(badseg1->s_szc == 0);
if (szc > 1 && (tszcvec = P2PHASE(szcvec, 1 << szc)) > 1) {
uint_t tszc = highbit(tszcvec) - 1;
caddr_t ta = MAX(addr, badseg1->s_base);
caddr_t te;
size_t tpgsz = page_get_pagesize(tszc);
ASSERT(svd->type == MAP_SHARED);
ASSERT(flag == SDR_END);
ASSERT(tszc < szc && tszc > 0);
if (eaddr > badseg1->s_base + badseg1->s_size) {
te = badseg1->s_base + badseg1->s_size;
} else {
te = eaddr;
}
ASSERT(ta <= te);
badseg1->s_szc = tszc;
if (!IS_P2ALIGNED(ta, tpgsz) || !IS_P2ALIGNED(te, tpgsz)) {
if (badseg2 != NULL) {
err = segvn_demote_range(badseg1, ta, te - ta,
SDR_END, tszcvec);
if (err != 0) {
return (err);
}
} else {
return (segvn_demote_range(badseg1, ta,
te - ta, SDR_END, tszcvec));
}
}
}
if (badseg2 == NULL)
return (0);
ASSERT(badseg2->s_szc == szc);
ASSERT(badseg2->s_size == pgsz);
ASSERT(sameprot(badseg2, badseg2->s_base, badseg2->s_size));
if (err = segvn_clrszc(badseg2)) {
return (err);
}
ASSERT(badseg2->s_szc == 0);
if (szc > 1 && (tszcvec = P2PHASE(szcvec, 1 << szc)) > 1) {
uint_t tszc = highbit(tszcvec) - 1;
size_t tpgsz = page_get_pagesize(tszc);
ASSERT(svd->type == MAP_SHARED);
ASSERT(flag == SDR_END);
ASSERT(tszc < szc && tszc > 0);
ASSERT(badseg2->s_base > addr);
ASSERT(eaddr > badseg2->s_base);
ASSERT(eaddr < badseg2->s_base + badseg2->s_size);
badseg2->s_szc = tszc;
if (!IS_P2ALIGNED(eaddr, tpgsz)) {
return (segvn_demote_range(badseg2, badseg2->s_base,
eaddr - badseg2->s_base, SDR_END, tszcvec));
}
}
return (0);
}
static int
segvn_checkprot(struct seg *seg, caddr_t addr, size_t len, uint_t prot)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct vpage *vp, *evp;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_READER);
if (svd->pageprot == 0) {
int err;
err = ((svd->prot & prot) != prot) ? EACCES : 0;
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (err);
}
evp = &svd->vpage[seg_page(seg, addr + len)];
for (vp = &svd->vpage[seg_page(seg, addr)]; vp < evp; vp++) {
if ((VPP_PROT(vp) & prot) != prot) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (EACCES);
}
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
static int
segvn_getprot(struct seg *seg, caddr_t addr, size_t len, uint_t *protv)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
size_t pgno = seg_page(seg, addr + len) - seg_page(seg, addr) + 1;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
if (pgno != 0) {
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_READER);
if (svd->pageprot == 0) {
do {
protv[--pgno] = svd->prot;
} while (pgno != 0);
} else {
size_t pgoff = seg_page(seg, addr);
do {
pgno--;
protv[pgno] = VPP_PROT(&svd->vpage[pgno+pgoff]);
} while (pgno != 0);
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
}
return (0);
}
static u_offset_t
segvn_getoffset(struct seg *seg, caddr_t addr)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
return (svd->offset + (uintptr_t)(addr - seg->s_base));
}
static int
segvn_gettype(struct seg *seg, caddr_t addr)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
return (svd->type | (svd->flags & (MAP_NORESERVE | MAP_TEXT |
MAP_INITDATA)));
}
static int
segvn_getvp(struct seg *seg, caddr_t addr, struct vnode **vpp)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
*vpp = svd->vp;
return (0);
}
static int
segvn_kluster(struct seg *seg, caddr_t addr, ssize_t delta)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct anon *oap, *ap;
ssize_t pd;
size_t page;
struct vnode *vp1, *vp2;
u_offset_t off1, off2;
struct anon_map *amp;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
ASSERT(AS_WRITE_HELD(seg->s_as) ||
SEGVN_LOCK_HELD(seg->s_as, &svd->lock));
if (addr + delta < seg->s_base ||
addr + delta >= (seg->s_base + seg->s_size))
return (-1);
pd = delta / (ssize_t)PAGESIZE;
page = seg_page(seg, addr);
if (svd->advice == MADV_RANDOM ||
svd->advice == MADV_SEQUENTIAL && delta < 0)
return (-1);
else if (svd->pageadvice && svd->vpage) {
struct vpage *bvpp, *evpp;
bvpp = &svd->vpage[page];
evpp = &svd->vpage[page + pd];
if (VPP_ADVICE(bvpp) == MADV_RANDOM ||
VPP_ADVICE(evpp) == MADV_SEQUENTIAL && delta < 0)
return (-1);
if (VPP_ADVICE(bvpp) != VPP_ADVICE(evpp) &&
VPP_ADVICE(evpp) == MADV_RANDOM)
return (-1);
}
if (svd->type == MAP_SHARED)
return (0);
if ((amp = svd->amp) == NULL)
return (0);
page += svd->anon_index;
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
oap = anon_get_ptr(amp->ahp, page);
ap = anon_get_ptr(amp->ahp, page + pd);
ANON_LOCK_EXIT(&->a_rwlock);
if ((oap == NULL && ap != NULL) || (oap != NULL && ap == NULL)) {
return (-1);
}
if (oap == NULL) {
return (0);
}
swap_xlate(ap, &vp1, &off1);
swap_xlate(oap, &vp2, &off2);
if (!VOP_CMP(vp1, vp2, NULL) || off1 - off2 != delta)
return (-1);
return (0);
}
static size_t
segvn_swapout(struct seg *seg)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct anon_map *amp;
pgcnt_t pgcnt = 0;
pgcnt_t npages;
pgcnt_t page;
ulong_t anon_index;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_READER);
if ((amp = svd->amp) != NULL)
anon_index = svd->anon_index;
npages = seg->s_size >> PAGESHIFT;
for (page = 0; page < npages; page++) {
page_t *pp;
struct anon *ap;
struct vnode *vp;
u_offset_t off;
anon_sync_obj_t cookie;
ap = NULL;
if (amp != NULL) {
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
if (anon_array_try_enter(amp, anon_index + page,
&cookie)) {
ANON_LOCK_EXIT(&->a_rwlock);
continue;
}
ap = anon_get_ptr(amp->ahp, anon_index + page);
if (ap != NULL) {
swap_xlate(ap, &vp, &off);
} else {
vp = svd->vp;
off = svd->offset + ptob(page);
}
anon_array_exit(&cookie);
ANON_LOCK_EXIT(&->a_rwlock);
} else {
vp = svd->vp;
off = svd->offset + ptob(page);
}
if (vp == NULL) {
ASSERT(ap == NULL);
continue;
}
pp = page_lookup_nowait(vp, off, SE_SHARED);
if (pp == NULL)
continue;
if (!page_tryupgrade(pp)) {
if (!page_io_trylock(pp)) {
if (!hat_page_is_mapped(pp))
pgcnt++;
} else {
page_io_unlock(pp);
}
page_unlock(pp);
continue;
}
ASSERT(!page_iolock_assert(pp));
if (pp->p_lckcnt != 0 || pp->p_cowcnt != 0 ||
hat_page_is_mapped(pp)) {
page_unlock(pp);
continue;
}
if (pp->p_szc != 0 && !page_try_demote_pages(pp)) {
page_unlock(pp);
continue;
}
ASSERT(pp->p_szc == 0);
if (hat_ismod(pp) && pp->p_vnode) {
VN_HOLD(vp);
page_unlock(pp);
if (!queue_io_request(vp, off))
VN_RELE(vp);
} else {
ASSERT(pp->p_vnode != NULL);
VN_DISPOSE(pp, B_FREE, 0, kcred);
}
pgcnt++;
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
cv_signal_pageout();
return (ptob(pgcnt));
}
static int
segvn_sync(struct seg *seg, caddr_t addr, size_t len, int attr, uint_t flags)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct vpage *vpp;
page_t *pp;
u_offset_t offset;
struct vnode *vp;
u_offset_t off;
caddr_t eaddr;
int bflags;
int err = 0;
int segtype;
int pageprot = 0;
int prot;
ulong_t anon_index = 0;
struct anon_map *amp;
struct anon *ap;
anon_sync_obj_t cookie;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_READER);
if (svd->softlockcnt > 0) {
if (svd->type == MAP_SHARED) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (EAGAIN);
}
segvn_purge(seg);
if (svd->softlockcnt > 0) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (EAGAIN);
}
} else if (svd->type == MAP_SHARED && svd->amp != NULL &&
svd->amp->a_softlockcnt > 0) {
segvn_purge(seg);
if (svd->amp->a_softlockcnt > 0 || svd->softlockcnt > 0) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (EAGAIN);
}
}
vpp = svd->vpage;
offset = svd->offset + (uintptr_t)(addr - seg->s_base);
bflags = ((flags & MS_ASYNC) ? B_ASYNC : 0) |
((flags & MS_INVALIDATE) ? B_INVAL : 0);
if (attr) {
pageprot = attr & ~(SHARED|PRIVATE);
segtype = (attr & SHARED) ? MAP_SHARED : MAP_PRIVATE;
if (svd->type != segtype) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
if (vpp == NULL) {
if (svd->prot != pageprot) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
prot = svd->prot;
} else
vpp = &svd->vpage[seg_page(seg, addr)];
} else if (svd->vp && svd->amp == NULL &&
(flags & MS_INVALIDATE) == 0) {
err = VOP_PUTPAGE(svd->vp, (offset_t)offset, len,
bflags, svd->cred, NULL);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (err);
}
if ((amp = svd->amp) != NULL)
anon_index = svd->anon_index + seg_page(seg, addr);
for (eaddr = addr + len; addr < eaddr; addr += PAGESIZE) {
ap = NULL;
if (amp != NULL) {
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
anon_array_enter(amp, anon_index, &cookie);
ap = anon_get_ptr(amp->ahp, anon_index++);
if (ap != NULL) {
swap_xlate(ap, &vp, &off);
} else {
vp = svd->vp;
off = offset;
}
anon_array_exit(&cookie);
ANON_LOCK_EXIT(&->a_rwlock);
} else {
vp = svd->vp;
off = offset;
}
offset += PAGESIZE;
if (vp == NULL)
continue;
if (attr) {
if (vpp) {
prot = VPP_PROT(vpp);
vpp++;
}
if (prot != pageprot) {
continue;
}
}
if (flags & MS_INVALIDATE) {
if ((pp = page_lookup(vp, off, SE_SHARED)) != NULL) {
if (pp->p_lckcnt != 0 || pp->p_cowcnt != 0) {
page_unlock(pp);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (EBUSY);
}
if (ap != NULL && pp->p_szc != 0 &&
page_tryupgrade(pp)) {
if (pp->p_lckcnt == 0 &&
pp->p_cowcnt == 0) {
(void) page_try_demote_pages(
pp);
}
}
page_unlock(pp);
}
} else if (svd->type == MAP_SHARED && amp != NULL) {
ASSERT(svd->vp == NULL);
pp = page_lookup_nowait(vp, off, SE_SHARED);
if (pp == NULL) {
continue;
}
if (pp->p_szc != 0) {
page_unlock(pp);
continue;
}
page_unlock(pp);
}
VN_HOLD(vp);
err = VOP_PUTPAGE(vp, (offset_t)off, PAGESIZE,
(bflags | (IS_SWAPFSVP(vp) ? B_PAGE_NOWAIT : 0)),
svd->cred, NULL);
VN_RELE(vp);
if (err)
break;
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (err);
}
static size_t
segvn_incore(struct seg *seg, caddr_t addr, size_t len, char *vec)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct vnode *vp, *avp;
u_offset_t offset, aoffset;
size_t p, ep;
int ret;
struct vpage *vpp;
page_t *pp;
uint_t start;
struct anon_map *amp;
struct anon *ap;
uint_t attr;
anon_sync_obj_t cookie;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_READER);
if (svd->amp == NULL && svd->vp == NULL) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
bzero(vec, btopr(len));
return (len);
}
p = seg_page(seg, addr);
ep = seg_page(seg, addr + len);
start = svd->vp ? SEG_PAGE_VNODEBACKED : 0;
amp = svd->amp;
for (; p < ep; p++, addr += PAGESIZE) {
vpp = (svd->vpage) ? &svd->vpage[p]: NULL;
ret = start;
ap = NULL;
avp = NULL;
if (amp != NULL) {
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
anon_array_enter(amp, svd->anon_index + p, &cookie);
ap = anon_get_ptr(amp->ahp, svd->anon_index + p);
if (ap != NULL) {
swap_xlate(ap, &avp, &aoffset);
}
anon_array_exit(&cookie);
ANON_LOCK_EXIT(&->a_rwlock);
}
if ((avp != NULL) && page_exists(avp, aoffset)) {
ret |= SEG_PAGE_INCORE;
attr = (uint_t)0;
if ((hat_getattr(seg->s_as->a_hat, addr,
&attr) != -1) && (attr & PROT_WRITE)) {
ret |= SEG_PAGE_ANON;
}
if ((pp = page_lookup_nowait(avp, aoffset,
SE_SHARED)) != NULL) {
if (pp->p_lckcnt)
ret |= SEG_PAGE_SOFTLOCK;
if (pp->p_cowcnt)
ret |= SEG_PAGE_HASCOW;
page_unlock(pp);
}
}
vp = svd->vp;
offset = svd->offset + (uintptr_t)(addr - seg->s_base);
if (vp != NULL) {
pp = page_lookup_nowait(vp, offset, SE_SHARED);
if ((pp == NULL) && (page_exists(vp, offset))) {
ret |= (SEG_PAGE_INCORE | SEG_PAGE_VNODE);
}
if (pp != NULL) {
ret |= (SEG_PAGE_INCORE | SEG_PAGE_VNODE);
if (pp->p_lckcnt)
ret |= SEG_PAGE_SOFTLOCK;
if (pp->p_cowcnt)
ret |= SEG_PAGE_HASCOW;
page_unlock(pp);
}
}
if (vpp) {
if (VPP_ISPPLOCK(vpp))
ret |= SEG_PAGE_LOCKED;
vpp++;
}
*vec++ = (char)ret;
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (len);
}
static int
segvn_lockop(struct seg *seg, caddr_t addr, size_t len,
int attr, int op, ulong_t *lockmap, size_t pos)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct vpage *vpp;
struct vpage *evp;
page_t *pp;
u_offset_t offset;
u_offset_t off;
int segtype;
int pageprot = 0;
int claim;
struct vnode *vp;
ulong_t anon_index = 0;
struct anon_map *amp;
struct anon *ap;
struct vattr va;
anon_sync_obj_t cookie;
struct kshmid *sp = NULL;
struct proc *p = curproc;
kproject_t *proj = NULL;
int chargeproc = 1;
size_t locked_bytes = 0;
size_t unlocked_bytes = 0;
int err = 0;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
if (svd->amp != NULL && svd->amp->a_sp != NULL) {
ASSERT(svd->type == MAP_SHARED);
ASSERT(svd->tr_state == SEGVN_TR_OFF);
sp = svd->amp->a_sp;
proj = sp->shm_perm.ipc_proj;
chargeproc = 0;
}
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_WRITER);
if (attr) {
pageprot = attr & ~(SHARED|PRIVATE);
segtype = attr & SHARED ? MAP_SHARED : MAP_PRIVATE;
if (svd->type != segtype) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
if (svd->pageprot == 0 && svd->prot != pageprot) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
}
if (op == MC_LOCK) {
if (svd->tr_state == SEGVN_TR_INIT) {
svd->tr_state = SEGVN_TR_OFF;
} else if (svd->tr_state == SEGVN_TR_ON) {
ASSERT(svd->amp != NULL);
segvn_textunrepl(seg, 0);
ASSERT(svd->amp == NULL &&
svd->tr_state == SEGVN_TR_OFF);
}
}
if ((vpp = svd->vpage) == NULL) {
if (op == MC_LOCK) {
segvn_vpage(seg);
if (svd->vpage == NULL) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (ENOMEM);
}
} else {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
}
if (op == MC_LOCK && svd->amp == NULL && svd->vp == NULL) {
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
svd->amp = anonmap_alloc(seg->s_size, 0, ANON_SLEEP);
svd->amp->a_szc = seg->s_szc;
}
if ((amp = svd->amp) != NULL) {
anon_index = svd->anon_index + seg_page(seg, addr);
}
offset = svd->offset + (uintptr_t)(addr - seg->s_base);
evp = &svd->vpage[seg_page(seg, addr + len)];
if (sp != NULL)
mutex_enter(&sp->shm_mlock);
if (op == MC_LOCK) {
if (sp == NULL) {
for (vpp = &svd->vpage[seg_page(seg, addr)]; vpp < evp;
vpp++) {
if (!VPP_ISPPLOCK(vpp))
unlocked_bytes += PAGESIZE;
}
} else {
ulong_t i_idx, i_edx;
anon_sync_obj_t i_cookie;
struct anon *i_ap;
struct vnode *i_vp;
u_offset_t i_off;
i_edx = svd->anon_index + seg_page(seg, addr + len);
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
for (i_idx = anon_index; i_idx < i_edx; i_idx++) {
anon_array_enter(amp, i_idx, &i_cookie);
i_ap = anon_get_ptr(amp->ahp, i_idx);
if (i_ap == NULL) {
unlocked_bytes += PAGESIZE;
anon_array_exit(&i_cookie);
continue;
}
swap_xlate(i_ap, &i_vp, &i_off);
anon_array_exit(&i_cookie);
pp = page_lookup(i_vp, i_off, SE_SHARED);
if (pp == NULL) {
unlocked_bytes += PAGESIZE;
continue;
} else if (pp->p_lckcnt == 0)
unlocked_bytes += PAGESIZE;
page_unlock(pp);
}
ANON_LOCK_EXIT(&->a_rwlock);
}
mutex_enter(&p->p_lock);
err = rctl_incr_locked_mem(p, proj, unlocked_bytes,
chargeproc);
mutex_exit(&p->p_lock);
if (err) {
if (sp != NULL)
mutex_exit(&sp->shm_mlock);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (err);
}
}
for (vpp = &svd->vpage[seg_page(seg, addr)]; vpp < evp;
vpp++, pos++, addr += PAGESIZE, offset += PAGESIZE, anon_index++) {
if ((attr == 0 || VPP_PROT(vpp) == pageprot) &&
((op == MC_LOCK && !VPP_ISPPLOCK(vpp)) ||
(op == MC_UNLOCK && VPP_ISPPLOCK(vpp)))) {
if (amp != NULL)
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
if (op == MC_LOCK && svd->vp == NULL &&
((svd->flags & MAP_NORESERVE) == 0) &&
amp != NULL &&
((ap = anon_get_ptr(amp->ahp, anon_index))
== NULL)) {
anon_array_enter(amp, anon_index, &cookie);
if ((ap = anon_get_ptr(amp->ahp,
anon_index)) == NULL) {
pp = anon_zero(seg, addr, &ap,
svd->cred);
if (pp == NULL) {
anon_array_exit(&cookie);
ANON_LOCK_EXIT(&->a_rwlock);
err = ENOMEM;
goto out;
}
ASSERT(anon_get_ptr(amp->ahp,
anon_index) == NULL);
(void) anon_set_ptr(amp->ahp,
anon_index, ap, ANON_SLEEP);
page_unlock(pp);
}
anon_array_exit(&cookie);
}
ap = NULL;
if (amp != NULL) {
anon_array_enter(amp, anon_index, &cookie);
ap = anon_get_ptr(amp->ahp, anon_index);
if (ap != NULL) {
swap_xlate(ap, &vp, &off);
} else {
if (svd->vp == NULL &&
(svd->flags & MAP_NORESERVE)) {
anon_array_exit(&cookie);
ANON_LOCK_EXIT(&->a_rwlock);
continue;
}
vp = svd->vp;
off = offset;
}
if (op != MC_LOCK || ap == NULL) {
anon_array_exit(&cookie);
ANON_LOCK_EXIT(&->a_rwlock);
}
} else {
vp = svd->vp;
off = offset;
}
if (op != MC_LOCK)
pp = page_lookup(vp, off, SE_SHARED);
else {
page_t *pl[1 + 1];
int error;
ASSERT(vp != NULL);
error = VOP_GETPAGE(vp, (offset_t)off, PAGESIZE,
(uint_t *)NULL, pl, PAGESIZE, seg, addr,
S_OTHER, svd->cred, NULL);
if (error && ap != NULL) {
anon_array_exit(&cookie);
ANON_LOCK_EXIT(&->a_rwlock);
}
if (error == EDEADLK) {
err = error;
goto out;
}
if (error && svd->vp) {
va.va_mask = AT_SIZE;
if (VOP_GETATTR(svd->vp, &va, 0,
svd->cred, NULL) != 0) {
err = EIO;
goto out;
}
if (btopr(va.va_size) >=
btopr(off + 1)) {
err = EIO;
goto out;
}
goto out;
} else if (error) {
err = EIO;
goto out;
}
pp = pl[0];
ASSERT(pp != NULL);
}
claim = ((VPP_PROT(vpp) & PROT_WRITE) &&
(svd->type == MAP_PRIVATE));
if (op == MC_LOCK) {
int ret = 1;
ASSERT(!VPP_ISPPLOCK(vpp));
ret = page_pp_lock(pp, claim, 0);
if (ap != NULL) {
if (ap->an_pvp != NULL) {
anon_swap_free(ap, pp);
}
anon_array_exit(&cookie);
ANON_LOCK_EXIT(&->a_rwlock);
}
if (ret == 0) {
page_unlock(pp);
err = EAGAIN;
goto out;
}
VPP_SETPPLOCK(vpp);
if (sp != NULL) {
if (pp->p_lckcnt == 1)
locked_bytes += PAGESIZE;
} else
locked_bytes += PAGESIZE;
if (lockmap != (ulong_t *)NULL)
BT_SET(lockmap, pos);
page_unlock(pp);
} else {
ASSERT(VPP_ISPPLOCK(vpp));
if (pp != NULL) {
ASSERT(sp == NULL || pp->p_lckcnt > 0);
page_pp_unlock(pp, claim, 0);
if (sp != NULL) {
if (pp->p_lckcnt == 0)
unlocked_bytes
+= PAGESIZE;
} else
unlocked_bytes += PAGESIZE;
page_unlock(pp);
} else {
ASSERT(sp == NULL);
unlocked_bytes += PAGESIZE;
}
VPP_CLRPPLOCK(vpp);
}
}
}
out:
if (op == MC_LOCK) {
if ((unlocked_bytes - locked_bytes) > 0) {
if (proj == NULL)
mutex_enter(&p->p_lock);
rctl_decr_locked_mem(p, proj,
(unlocked_bytes - locked_bytes), chargeproc);
if (proj == NULL)
mutex_exit(&p->p_lock);
}
} else {
if (unlocked_bytes > 0) {
if (proj == NULL)
mutex_enter(&p->p_lock);
rctl_decr_locked_mem(p, proj, unlocked_bytes,
chargeproc);
if (proj == NULL)
mutex_exit(&p->p_lock);
}
}
if (sp != NULL)
mutex_exit(&sp->shm_mlock);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (err);
}
static int
segvn_advise(struct seg *seg, caddr_t addr, size_t len, uint_t behav)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
size_t page;
int err = 0;
int already_set;
struct anon_map *amp;
ulong_t anon_index;
struct seg *next;
lgrp_mem_policy_t policy;
struct seg *prev;
struct vnode *vp;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
if (behav != MADV_FREE && behav != MADV_PURGE) {
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_WRITER);
if (svd->tr_state != SEGVN_TR_OFF) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
} else {
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_READER);
}
if ((behav == MADV_SEQUENTIAL &&
(seg->s_szc != 0 || HAT_IS_REGION_COOKIE_VALID(svd->rcookie))) ||
(!lgrp_optimizations() && (behav == MADV_ACCESS_DEFAULT ||
behav == MADV_ACCESS_LWP || behav == MADV_ACCESS_MANY))) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
if (behav == MADV_SEQUENTIAL || behav == MADV_ACCESS_DEFAULT ||
behav == MADV_ACCESS_LWP || behav == MADV_ACCESS_MANY) {
if (svd->softlockcnt > 0) {
if (svd->type == MAP_SHARED) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (EAGAIN);
}
segvn_purge(seg);
if (svd->softlockcnt > 0) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (EAGAIN);
}
} else if (svd->type == MAP_SHARED && svd->amp != NULL &&
svd->amp->a_softlockcnt > 0) {
segvn_purge(seg);
}
}
amp = svd->amp;
vp = svd->vp;
if (behav == MADV_FREE || behav == MADV_PURGE) {
pgcnt_t purged;
if (behav == MADV_FREE && (vp != NULL || amp == NULL)) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (0);
}
if (amp == NULL) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (EBUSY);
}
segvn_purge(seg);
page = seg_page(seg, addr);
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
err = anon_disclaim(amp,
svd->anon_index + page, len, behav, &purged);
if (purged != 0 && (svd->flags & MAP_NORESERVE)) {
ssize_t bytes = ptob(purged);
anon_unresv_zone(bytes, seg->s_as->a_proc->p_zone);
atomic_add_long(&svd->swresv, -bytes);
atomic_add_long(&seg->s_as->a_resvsize, -bytes);
}
ANON_LOCK_EXIT(&->a_rwlock);
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (behav == MADV_PURGE ? err : 0);
}
if ((addr == seg->s_base) && (len == seg->s_size)) {
switch (behav) {
case MADV_ACCESS_LWP:
case MADV_ACCESS_MANY:
case MADV_ACCESS_DEFAULT:
policy = lgrp_madv_to_policy(behav, len, svd->type);
if (svd->type == MAP_SHARED)
already_set = lgrp_shm_policy_set(policy, amp,
svd->anon_index, vp, svd->offset, len);
else {
if (AS_READ_HELD(seg->s_as)) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (IE_RETRY);
}
already_set = lgrp_privm_policy_set(policy,
&svd->policy_info, len);
}
if (already_set &&
!LGRP_MEM_POLICY_REAPPLICABLE(policy))
break;
page_mark_migrate(seg, addr, len, amp, svd->anon_index,
vp, svd->offset, 1);
if (already_set || svd->type == MAP_SHARED)
break;
prev = AS_SEGPREV(seg->s_as, seg);
next = AS_SEGNEXT(seg->s_as, seg);
if (next && next->s_ops == &segvn_ops &&
addr + len == next->s_base)
(void) segvn_concat(seg, next, 1);
if (prev && prev->s_ops == &segvn_ops &&
addr == prev->s_base + prev->s_size) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
if (!segvn_concat(prev, seg, 1))
err = IE_REATTACH;
return (err);
}
break;
case MADV_SEQUENTIAL:
ASSERT(seg->s_szc == 0);
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
hat_unload(seg->s_as->a_hat, addr, len,
HAT_UNLOAD);
case MADV_NORMAL:
case MADV_RANDOM:
svd->advice = (uchar_t)behav;
svd->pageadvice = 0;
break;
case MADV_WILLNEED:
case MADV_DONTNEED:
case MADV_FREE:
case MADV_PURGE:
break;
default:
err = EINVAL;
}
} else {
caddr_t eaddr;
struct seg *new_seg;
struct segvn_data *new_svd = NULL;
u_offset_t off;
caddr_t oldeaddr;
page = seg_page(seg, addr);
segvn_vpage(seg);
if (svd->vpage == NULL) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (ENOMEM);
}
switch (behav) {
struct vpage *bvpp, *evpp;
case MADV_ACCESS_LWP:
case MADV_ACCESS_MANY:
case MADV_ACCESS_DEFAULT:
if (seg->s_szc != 0) {
size_t pgsz;
pgsz = page_get_pagesize(seg->s_szc);
addr = (caddr_t)P2ALIGN((uintptr_t)addr, pgsz);
len = P2ROUNDUP(len, pgsz);
}
policy = lgrp_madv_to_policy(behav, len, svd->type);
anon_index = svd->anon_index + page;
off = svd->offset + (uintptr_t)(addr - seg->s_base);
if (svd->type == MAP_SHARED)
already_set = lgrp_shm_policy_set(policy, amp,
anon_index, vp, off, len);
else
already_set =
(policy == svd->policy_info.mem_policy);
if (already_set &&
!LGRP_MEM_POLICY_REAPPLICABLE(policy))
break;
if (svd->type == MAP_PRIVATE &&
AS_READ_HELD(seg->s_as)) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (IE_RETRY);
}
page_mark_migrate(seg, addr, len, amp, svd->anon_index,
vp, svd->offset, 1);
if (already_set || svd->type == MAP_SHARED)
break;
if (HAT_IS_REGION_COOKIE_VALID(svd->rcookie)) {
ASSERT(svd->amp == NULL);
ASSERT(svd->tr_state == SEGVN_TR_OFF);
ASSERT(svd->softlockcnt == 0);
hat_leave_region(seg->s_as->a_hat, svd->rcookie,
HAT_REGION_TEXT);
svd->rcookie = HAT_INVALID_REGION_COOKIE;
}
new_seg = NULL;
eaddr = addr + len;
oldeaddr = seg->s_base + seg->s_size;
if (addr > seg->s_base) {
if (svd->softlockcnt > 0)
segvn_purge(seg);
new_seg = segvn_split_seg(seg, addr);
new_svd = (struct segvn_data *)new_seg->s_data;
err = IE_REATTACH;
if (eaddr == oldeaddr) {
(void) lgrp_privm_policy_set(policy,
&new_svd->policy_info,
new_seg->s_size);
next = AS_SEGNEXT(new_seg->s_as,
new_seg);
if (next &&
next->s_ops == &segvn_ops &&
eaddr == next->s_base)
(void) segvn_concat(new_seg,
next, 1);
}
}
if (eaddr < oldeaddr) {
if (svd->softlockcnt > 0)
segvn_purge(seg);
if (new_seg != NULL && new_seg != seg) {
(void) segvn_split_seg(new_seg, eaddr);
(void) lgrp_privm_policy_set(policy,
&new_svd->policy_info,
new_seg->s_size);
} else {
(void) segvn_split_seg(seg, eaddr);
err = IE_REATTACH;
(void) lgrp_privm_policy_set(policy,
&svd->policy_info, seg->s_size);
if (addr == seg->s_base) {
prev = AS_SEGPREV(seg->s_as,
seg);
if (prev &&
prev->s_ops ==
&segvn_ops &&
addr == prev->s_base +
prev->s_size) {
SEGVN_LOCK_EXIT(
seg->s_as,
&svd->lock);
(void) segvn_concat(
prev, seg, 1);
return (err);
}
}
}
}
break;
case MADV_SEQUENTIAL:
ASSERT(seg->s_szc == 0);
ASSERT(svd->rcookie == HAT_INVALID_REGION_COOKIE);
hat_unload(seg->s_as->a_hat, addr, len, HAT_UNLOAD);
case MADV_NORMAL:
case MADV_RANDOM:
bvpp = &svd->vpage[page];
evpp = &svd->vpage[page + (len >> PAGESHIFT)];
for (; bvpp < evpp; bvpp++)
VPP_SETADVICE(bvpp, behav);
svd->advice = MADV_NORMAL;
break;
case MADV_WILLNEED:
case MADV_DONTNEED:
case MADV_FREE:
case MADV_PURGE:
break;
default:
err = EINVAL;
}
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (err);
}
static int
segvn_inherit(struct seg *seg, caddr_t addr, size_t len, uint_t behav)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct vpage *bvpp, *evpp;
size_t page;
int ret = 0;
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
if (behav != SEGP_INH_ZERO)
return (ENOTSUP);
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_WRITER);
if (svd->tr_state != SEGVN_TR_OFF ||
svd->type != MAP_PRIVATE ||
svd->vp != NULL) {
ret = EINVAL;
goto out;
}
if (svd->svn_inz == SEGVN_INZ_ALL) {
ret = 0;
goto out;
}
if ((addr == seg->s_base) && (len == seg->s_size)) {
svd->svn_inz = SEGVN_INZ_ALL;
ret = 0;
goto out;
}
if (svd->vpage == NULL) {
segvn_vpage(seg);
if (svd->vpage == NULL) {
ret = ENOMEM;
goto out;
}
}
svd->svn_inz = SEGVN_INZ_VPP;
page = seg_page(seg, addr);
bvpp = &svd->vpage[page];
evpp = &svd->vpage[page + (len >> PAGESHIFT)];
for (; bvpp < evpp; bvpp++)
VPP_SETINHZERO(bvpp);
ret = 0;
out:
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
return (ret);
}
static void
segvn_vpage(struct seg *seg)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct vpage *vp, *evp;
static pgcnt_t page_limit = 0;
ASSERT(SEGVN_WRITE_HELD(seg->s_as, &svd->lock));
if (svd->vpage == NULL) {
ulong_t mem_needed = seg_pages(seg) * sizeof (struct vpage);
pgcnt_t npages = mem_needed >> PAGESHIFT;
if (page_limit == 0)
page_limit = (total_pages >> 1) + (total_pages >> 3);
if (npages > page_limit)
return;
svd->pageadvice = 1;
svd->vpage = kmem_zalloc(mem_needed, KM_SLEEP);
evp = &svd->vpage[seg_page(seg, seg->s_base + seg->s_size)];
for (vp = svd->vpage; vp < evp; vp++) {
VPP_SETPROT(vp, svd->prot);
VPP_SETADVICE(vp, svd->advice);
}
}
}
static void
segvn_dump(struct seg *seg)
{
struct segvn_data *svd;
page_t *pp;
struct anon_map *amp;
ulong_t anon_index = 0;
struct vnode *vp;
u_offset_t off, offset;
pfn_t pfn;
pgcnt_t page, npages;
caddr_t addr;
npages = seg_pages(seg);
svd = (struct segvn_data *)seg->s_data;
vp = svd->vp;
off = offset = svd->offset;
addr = seg->s_base;
if ((amp = svd->amp) != NULL) {
anon_index = svd->anon_index;
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
}
for (page = 0; page < npages; page++, offset += PAGESIZE) {
struct anon *ap;
int we_own_it = 0;
if (amp && (ap = anon_get_ptr(svd->amp->ahp, anon_index++))) {
swap_xlate_nopanic(ap, &vp, &off);
} else {
vp = svd->vp;
off = offset;
}
if ((pp = page_lookup_nowait(vp, off, SE_SHARED)))
we_own_it = 1;
else
pp = page_exists(vp, off);
if (pp) {
pfn = page_pptonum(pp);
dump_addpage(seg->s_as, addr, pfn);
if (we_own_it)
page_unlock(pp);
}
addr += PAGESIZE;
dump_timeleft = dump_timeout;
}
if (amp != NULL)
ANON_LOCK_EXIT(&->a_rwlock);
}
#ifdef DEBUG
static uint32_t segvn_pglock_mtbf = 0;
#endif
#define PCACHE_SHWLIST ((page_t *)-2)
#define NOPCACHE_SHWLIST ((page_t *)-1)
static int
segvn_pagelock(struct seg *seg, caddr_t addr, size_t len, struct page ***ppp,
enum lock_type type, enum seg_rw rw)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
size_t np;
pgcnt_t adjustpages;
pgcnt_t npages;
ulong_t anon_index;
uint_t protchk = (rw == S_READ) ? PROT_READ : PROT_WRITE;
uint_t error;
struct anon_map *amp;
pgcnt_t anpgcnt;
struct page **pplist, **pl, *pp;
caddr_t a;
size_t page;
caddr_t lpgaddr, lpgeaddr;
anon_sync_obj_t cookie;
int anlock;
struct anon_map *pamp;
caddr_t paddr;
seg_preclaim_cbfunc_t preclaim_callback;
size_t pgsz;
int use_pcache;
size_t wlen = 0;
uint_t pflags = 0;
int sftlck_sbase = 0;
int sftlck_send = 0;
#ifdef DEBUG
if (type == L_PAGELOCK && segvn_pglock_mtbf) {
hrtime_t ts = gethrtime();
if ((ts % segvn_pglock_mtbf) == 0) {
return (ENOTSUP);
}
if ((ts % segvn_pglock_mtbf) == 1) {
return (EFAULT);
}
}
#endif
TRACE_2(TR_FAC_PHYSIO, TR_PHYSIO_SEGVN_START,
"segvn_pagelock: start seg %p addr %p", seg, addr);
ASSERT(seg->s_as && AS_LOCK_HELD(seg->s_as));
ASSERT(type == L_PAGELOCK || type == L_PAGEUNLOCK);
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_READER);
if (svd->vp != NULL) {
if (type == L_PAGELOCK) {
error = ENOTSUP;
goto out;
}
panic("segvn_pagelock(L_PAGEUNLOCK): vp != NULL");
}
if ((amp = svd->amp) == NULL) {
if (type == L_PAGELOCK) {
error = EFAULT;
goto out;
}
panic("segvn_pagelock(L_PAGEUNLOCK): amp == NULL");
}
if (rw != S_READ && rw != S_WRITE) {
if (type == L_PAGELOCK) {
error = ENOTSUP;
goto out;
}
panic("segvn_pagelock(L_PAGEUNLOCK): bad rw");
}
if (seg->s_szc != 0) {
pgsz = page_get_pagesize(seg->s_szc);
CALC_LPG_REGION(pgsz, seg, addr, len, lpgaddr, lpgeaddr);
adjustpages = btop((uintptr_t)(addr - lpgaddr));
} else if (len < segvn_pglock_comb_thrshld) {
lpgaddr = addr;
lpgeaddr = addr + len;
adjustpages = 0;
pgsz = PAGESIZE;
} else {
pflags = SEGP_PSHIFT | (segvn_pglock_comb_bshift << 16);
pgsz = PAGESIZE;
if (svd->type == MAP_PRIVATE) {
lpgaddr = (caddr_t)P2ALIGN((uintptr_t)addr,
segvn_pglock_comb_balign);
if (lpgaddr < seg->s_base) {
lpgaddr = seg->s_base;
sftlck_sbase = 1;
}
} else {
ulong_t aix = svd->anon_index + seg_page(seg, addr);
ulong_t aaix = P2ALIGN(aix, segvn_pglock_comb_palign);
if (aaix < svd->anon_index) {
lpgaddr = seg->s_base;
sftlck_sbase = 1;
} else {
lpgaddr = addr - ptob(aix - aaix);
ASSERT(lpgaddr >= seg->s_base);
}
}
if (svd->pageprot && lpgaddr != addr) {
struct vpage *vp = &svd->vpage[seg_page(seg, lpgaddr)];
struct vpage *evp = &svd->vpage[seg_page(seg, addr)];
while (vp < evp) {
if ((VPP_PROT(vp) & protchk) == 0) {
break;
}
vp++;
}
if (vp < evp) {
lpgaddr = addr;
pflags = 0;
}
}
lpgeaddr = addr + len;
if (pflags) {
if (svd->type == MAP_PRIVATE) {
lpgeaddr = (caddr_t)P2ROUNDUP(
(uintptr_t)lpgeaddr,
segvn_pglock_comb_balign);
} else {
ulong_t aix = svd->anon_index +
seg_page(seg, lpgeaddr);
ulong_t aaix = P2ROUNDUP(aix,
segvn_pglock_comb_palign);
if (aaix < aix) {
lpgeaddr = 0;
} else {
lpgeaddr += ptob(aaix - aix);
}
}
if (lpgeaddr == 0 ||
lpgeaddr > seg->s_base + seg->s_size) {
lpgeaddr = seg->s_base + seg->s_size;
sftlck_send = 1;
}
}
if (svd->pageprot && lpgeaddr != addr + len) {
struct vpage *vp;
struct vpage *evp;
vp = &svd->vpage[seg_page(seg, addr + len)];
evp = &svd->vpage[seg_page(seg, lpgeaddr)];
while (vp < evp) {
if ((VPP_PROT(vp) & protchk) == 0) {
break;
}
vp++;
}
if (vp < evp) {
lpgeaddr = addr + len;
}
}
adjustpages = btop((uintptr_t)(addr - lpgaddr));
}
if (svd->type == MAP_SHARED) {
pamp = amp;
paddr = (caddr_t)((lpgaddr - seg->s_base) +
ptob(svd->anon_index));
preclaim_callback = shamp_reclaim;
} else {
pamp = NULL;
paddr = lpgaddr;
preclaim_callback = segvn_reclaim;
}
if (type == L_PAGEUNLOCK) {
VM_STAT_ADD(segvnvmstats.pagelock[0]);
if (seg->s_as->a_vbits) {
for (a = addr; a < addr + len; a += PAGESIZE) {
if (rw == S_WRITE) {
hat_setstat(seg->s_as, a,
PAGESIZE, P_REF | P_MOD);
} else {
hat_setstat(seg->s_as, a,
PAGESIZE, P_REF);
}
}
}
npages = btop(len);
if ((*ppp)[npages] == NOPCACHE_SHWLIST) {
void *ptag;
if (pamp != NULL) {
ASSERT(svd->type == MAP_SHARED);
ptag = (void *)pamp;
paddr = (caddr_t)((addr - seg->s_base) +
ptob(svd->anon_index));
} else {
ptag = (void *)seg;
paddr = addr;
}
(void) preclaim_callback(ptag, paddr, len, *ppp, rw, 0);
} else {
ASSERT((*ppp)[npages] == PCACHE_SHWLIST ||
IS_SWAPFSVP((*ppp)[npages]->p_vnode));
len = lpgeaddr - lpgaddr;
npages = btop(len);
seg_pinactive(seg, pamp, paddr, len,
*ppp - adjustpages, rw, pflags, preclaim_callback);
}
if (pamp != NULL) {
ASSERT(svd->type == MAP_SHARED);
ASSERT(svd->softlockcnt >= npages);
atomic_add_long((ulong_t *)&svd->softlockcnt, -npages);
}
if (sftlck_sbase) {
ASSERT(svd->softlockcnt_sbase > 0);
atomic_dec_ulong((ulong_t *)&svd->softlockcnt_sbase);
}
if (sftlck_send) {
ASSERT(svd->softlockcnt_send > 0);
atomic_dec_ulong((ulong_t *)&svd->softlockcnt_send);
}
if (AS_ISUNMAPWAIT(seg->s_as)) {
if (svd->softlockcnt == 0) {
mutex_enter(&seg->s_as->a_contents);
if (AS_ISUNMAPWAIT(seg->s_as)) {
AS_CLRUNMAPWAIT(seg->s_as);
cv_broadcast(&seg->s_as->a_cv);
}
mutex_exit(&seg->s_as->a_contents);
} else if (pamp == NULL) {
ASSERT(svd->type == MAP_PRIVATE);
segvn_purge(seg);
}
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
TRACE_2(TR_FAC_PHYSIO, TR_PHYSIO_SEGVN_UNLOCK_END,
"segvn_pagelock: unlock seg %p addr %p", seg, addr);
return (0);
}
VM_STAT_ADD(segvnvmstats.pagelock[1]);
if (pamp != NULL) {
ASSERT(svd->type == MAP_SHARED);
if (svd->pageprot == 0) {
if ((svd->prot & protchk) == 0) {
error = EACCES;
goto out;
}
} else {
caddr_t ea;
if (seg->s_szc) {
a = lpgaddr;
ea = lpgeaddr;
} else {
a = addr;
ea = addr + len;
}
for (; a < ea; a += pgsz) {
struct vpage *vp;
ASSERT(seg->s_szc == 0 ||
sameprot(seg, a, pgsz));
vp = &svd->vpage[seg_page(seg, a)];
if ((VPP_PROT(vp) & protchk) == 0) {
error = EACCES;
goto out;
}
}
}
}
pplist = seg_plookup(seg, pamp, paddr, lpgeaddr - lpgaddr, rw, pflags);
if (pplist != NULL) {
if (pamp != NULL) {
npages = btop((uintptr_t)(lpgeaddr - lpgaddr));
ASSERT(svd->type == MAP_SHARED);
atomic_add_long((ulong_t *)&svd->softlockcnt,
npages);
}
if (sftlck_sbase) {
atomic_inc_ulong((ulong_t *)&svd->softlockcnt_sbase);
}
if (sftlck_send) {
atomic_inc_ulong((ulong_t *)&svd->softlockcnt_send);
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
*ppp = pplist + adjustpages;
TRACE_2(TR_FAC_PHYSIO, TR_PHYSIO_SEGVN_HIT_END,
"segvn_pagelock: cache hit seg %p addr %p", seg, addr);
return (0);
}
if (pamp == NULL) {
ASSERT(svd->type == MAP_PRIVATE);
if (svd->pageprot == 0) {
if ((svd->prot & protchk) == 0) {
error = EACCES;
goto out;
}
if (svd->prot & PROT_WRITE) {
wlen = lpgeaddr - lpgaddr;
} else {
wlen = 0;
ASSERT(rw == S_READ);
}
} else {
int wcont = 1;
for (a = lpgaddr, wlen = 0; a < lpgeaddr; a += pgsz) {
struct vpage *vp;
ASSERT(seg->s_szc == 0 ||
sameprot(seg, a, pgsz));
vp = &svd->vpage[seg_page(seg, a)];
if ((VPP_PROT(vp) & protchk) == 0) {
error = EACCES;
goto out;
}
if (wcont && (VPP_PROT(vp) & PROT_WRITE)) {
wlen += pgsz;
} else {
wcont = 0;
ASSERT(rw == S_READ);
}
}
}
ASSERT(rw == S_READ || wlen == lpgeaddr - lpgaddr);
ASSERT(rw == S_WRITE || wlen <= lpgeaddr - lpgaddr);
}
if (seg_pinsert_check(seg, pamp, paddr,
lpgeaddr - lpgaddr, pflags) == SEGP_SUCCESS) {
addr = lpgaddr;
len = lpgeaddr - lpgaddr;
use_pcache = 1;
} else {
use_pcache = 0;
adjustpages = 0;
}
npages = btop(len);
pplist = kmem_alloc(sizeof (page_t *) * (npages + 1), KM_SLEEP);
pl = pplist;
*ppp = pplist + adjustpages;
pl[npages] = use_pcache ? PCACHE_SHWLIST : NOPCACHE_SHWLIST;
page = seg_page(seg, addr);
anon_index = svd->anon_index + page;
anlock = 0;
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
ASSERT(amp->a_szc >= seg->s_szc);
anpgcnt = page_get_pagecnt(amp->a_szc);
for (a = addr; a < addr + len; a += PAGESIZE, anon_index++) {
struct anon *ap;
struct vnode *vp;
u_offset_t off;
if (a == addr || P2PHASE(anon_index, anpgcnt) == 0) {
ASSERT(anlock == 0);
anon_array_enter(amp, anon_index, &cookie);
anlock = 1;
}
ap = anon_get_ptr(amp->ahp, anon_index);
if (ap == NULL || ap->an_refcnt != 1) {
struct vpage *vpage;
if (seg->s_szc) {
error = EFAULT;
break;
}
if (svd->vpage != NULL) {
vpage = &svd->vpage[seg_page(seg, a)];
} else {
vpage = NULL;
}
ASSERT(anlock);
anon_array_exit(&cookie);
anlock = 0;
pp = NULL;
error = segvn_faultpage(seg->s_as->a_hat, seg, a, 0,
vpage, &pp, 0, F_INVAL, rw, 1);
if (error) {
error = fc_decode(error);
break;
}
anon_array_enter(amp, anon_index, &cookie);
anlock = 1;
ap = anon_get_ptr(amp->ahp, anon_index);
if (ap == NULL || ap->an_refcnt != 1) {
error = EFAULT;
break;
}
}
swap_xlate(ap, &vp, &off);
pp = page_lookup_nowait(vp, off, SE_SHARED);
if (pp == NULL) {
error = EFAULT;
break;
}
if (ap->an_pvp != NULL) {
anon_swap_free(ap, pp);
}
if (P2PHASE(anon_index, anpgcnt) == anpgcnt - 1) {
ASSERT(anlock);
anon_array_exit(&cookie);
anlock = 0;
}
*pplist++ = pp;
}
if (anlock) {
anon_array_exit(&cookie);
}
ANON_LOCK_EXIT(&->a_rwlock);
if (a >= addr + len) {
atomic_add_long((ulong_t *)&svd->softlockcnt, npages);
if (pamp != NULL) {
ASSERT(svd->type == MAP_SHARED);
atomic_add_long((ulong_t *)&pamp->a_softlockcnt,
npages);
wlen = len;
}
if (sftlck_sbase) {
atomic_inc_ulong((ulong_t *)&svd->softlockcnt_sbase);
}
if (sftlck_send) {
atomic_inc_ulong((ulong_t *)&svd->softlockcnt_send);
}
if (use_pcache) {
(void) seg_pinsert(seg, pamp, paddr, len, wlen, pl,
rw, pflags, preclaim_callback);
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
TRACE_2(TR_FAC_PHYSIO, TR_PHYSIO_SEGVN_FILL_END,
"segvn_pagelock: cache fill seg %p addr %p", seg, addr);
return (0);
}
pplist = pl;
np = ((uintptr_t)(a - addr)) >> PAGESHIFT;
while (np > (uint_t)0) {
ASSERT(PAGE_LOCKED(*pplist));
page_unlock(*pplist);
np--;
pplist++;
}
kmem_free(pl, sizeof (page_t *) * (npages + 1));
out:
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
*ppp = NULL;
TRACE_2(TR_FAC_PHYSIO, TR_PHYSIO_SEGVN_MISS_END,
"segvn_pagelock: cache miss seg %p addr %p", seg, addr);
return (error);
}
static void
segvn_purge(struct seg *seg)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
if (svd->amp == NULL || svd->vp != NULL) {
return;
}
if (svd->type == MAP_PRIVATE) {
if (svd->softlockcnt) {
seg_ppurge(seg, NULL, 0);
}
} else if (svd->softlockcnt == 0 && svd->amp->a_softlockcnt != 0) {
seg_ppurge(seg, svd->amp, 0);
}
}
static int
segvn_reclaim(void *ptag, caddr_t addr, size_t len, struct page **pplist,
enum seg_rw rw, int async)
{
struct seg *seg = (struct seg *)ptag;
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
pgcnt_t np, npages;
struct page **pl;
npages = np = btop(len);
ASSERT(npages);
ASSERT(svd->vp == NULL && svd->amp != NULL);
ASSERT(svd->softlockcnt >= npages);
ASSERT(async || AS_LOCK_HELD(seg->s_as));
pl = pplist;
ASSERT(pl[np] == NOPCACHE_SHWLIST || pl[np] == PCACHE_SHWLIST);
ASSERT(!async || pl[np] == PCACHE_SHWLIST);
while (np > (uint_t)0) {
if (rw == S_WRITE) {
hat_setrefmod(*pplist);
} else {
hat_setref(*pplist);
}
page_unlock(*pplist);
np--;
pplist++;
}
kmem_free(pl, sizeof (page_t *) * (npages + 1));
if (async) {
mutex_enter(&svd->segfree_syncmtx);
}
if (!atomic_add_long_nv((ulong_t *)&svd->softlockcnt, -npages)) {
if (async || AS_ISUNMAPWAIT(seg->s_as)) {
mutex_enter(&seg->s_as->a_contents);
if (async) {
AS_SETNOUNMAPWAIT(seg->s_as);
}
if (AS_ISUNMAPWAIT(seg->s_as)) {
AS_CLRUNMAPWAIT(seg->s_as);
cv_broadcast(&seg->s_as->a_cv);
}
mutex_exit(&seg->s_as->a_contents);
}
}
if (async) {
mutex_exit(&svd->segfree_syncmtx);
}
return (0);
}
static int
shamp_reclaim(void *ptag, caddr_t addr, size_t len, struct page **pplist,
enum seg_rw rw, int async)
{
amp_t *amp = (amp_t *)ptag;
pgcnt_t np, npages;
struct page **pl;
npages = np = btop(len);
ASSERT(npages);
ASSERT(amp->a_softlockcnt >= npages);
pl = pplist;
ASSERT(pl[np] == NOPCACHE_SHWLIST || pl[np] == PCACHE_SHWLIST);
ASSERT(!async || pl[np] == PCACHE_SHWLIST);
while (np > (uint_t)0) {
if (rw == S_WRITE) {
hat_setrefmod(*pplist);
} else {
hat_setref(*pplist);
}
page_unlock(*pplist);
np--;
pplist++;
}
kmem_free(pl, sizeof (page_t *) * (npages + 1));
mutex_enter(&->a_purgemtx);
if (!atomic_add_long_nv((ulong_t *)&->a_softlockcnt, -npages) &&
amp->a_purgewait) {
amp->a_purgewait = 0;
cv_broadcast(&->a_purgecv);
}
mutex_exit(&->a_purgemtx);
return (0);
}
static int
segvn_getmemid(struct seg *seg, caddr_t addr, memid_t *memidp)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct anon *ap = NULL;
ulong_t anon_index = 0;
struct anon_map *amp;
anon_sync_obj_t cookie;
if (svd->type == MAP_PRIVATE) {
memidp->val[0] = (uintptr_t)seg->s_as;
memidp->val[1] = (uintptr_t)addr;
return (0);
}
if (svd->type == MAP_SHARED) {
if (svd->vp) {
memidp->val[0] = (uintptr_t)svd->vp;
memidp->val[1] = (u_longlong_t)svd->offset +
(uintptr_t)(addr - seg->s_base);
return (0);
} else {
SEGVN_LOCK_ENTER(seg->s_as, &svd->lock, RW_READER);
if ((amp = svd->amp) != NULL) {
anon_index = svd->anon_index +
seg_page(seg, addr);
}
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
ASSERT(amp != NULL);
ANON_LOCK_ENTER(&->a_rwlock, RW_READER);
anon_array_enter(amp, anon_index, &cookie);
ap = anon_get_ptr(amp->ahp, anon_index);
if (ap == NULL) {
page_t *pp;
pp = anon_zero(seg, addr, &ap, svd->cred);
if (pp == NULL) {
anon_array_exit(&cookie);
ANON_LOCK_EXIT(&->a_rwlock);
return (ENOMEM);
}
ASSERT(anon_get_ptr(amp->ahp, anon_index)
== NULL);
(void) anon_set_ptr(amp->ahp, anon_index,
ap, ANON_SLEEP);
page_unlock(pp);
}
anon_array_exit(&cookie);
ANON_LOCK_EXIT(&->a_rwlock);
memidp->val[0] = (uintptr_t)ap;
memidp->val[1] = (uintptr_t)addr & PAGEOFFSET;
return (0);
}
}
return (EINVAL);
}
static int
sameprot(struct seg *seg, caddr_t a, size_t len)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
struct vpage *vpage;
spgcnt_t pages = btop(len);
uint_t prot;
if (svd->pageprot == 0)
return (1);
ASSERT(svd->vpage != NULL);
vpage = &svd->vpage[seg_page(seg, a)];
prot = VPP_PROT(vpage);
vpage++;
pages--;
while (pages-- > 0) {
if (prot != VPP_PROT(vpage))
return (0);
vpage++;
}
return (1);
}
static lgrp_mem_policy_info_t *
segvn_getpolicy(struct seg *seg, caddr_t addr)
{
struct anon_map *amp;
ulong_t anon_index;
lgrp_mem_policy_info_t *policy_info;
struct segvn_data *svn_data;
u_offset_t vn_off;
vnode_t *vp;
ASSERT(seg != NULL);
svn_data = (struct segvn_data *)seg->s_data;
if (svn_data == NULL)
return (NULL);
if (svn_data->type != MAP_SHARED) {
if (svn_data->tr_state != SEGVN_TR_ON) {
policy_info = &svn_data->policy_info;
} else {
policy_info = &svn_data->tr_policy_info;
ASSERT(policy_info->mem_policy ==
LGRP_MEM_POLICY_NEXT_SEG);
}
} else {
amp = svn_data->amp;
anon_index = svn_data->anon_index + seg_page(seg, addr);
vp = svn_data->vp;
vn_off = svn_data->offset + (uintptr_t)(addr - seg->s_base);
policy_info = lgrp_shm_policy_get(amp, anon_index, vp, vn_off);
}
return (policy_info);
}
static int
segvn_capable(struct seg *seg, segcapability_t capability)
{
return (0);
}
static void
segvn_textrepl(struct seg *seg)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
vnode_t *vp = svd->vp;
u_offset_t off = svd->offset;
size_t size = seg->s_size;
u_offset_t eoff = off + size;
uint_t szc = seg->s_szc;
ulong_t hash = SVNTR_HASH_FUNC(vp);
svntr_t *svntrp;
struct vattr va;
proc_t *p = seg->s_as->a_proc;
lgrp_id_t lgrp_id;
lgrp_id_t olid;
int first;
struct anon_map *amp;
ASSERT(AS_LOCK_HELD(seg->s_as));
ASSERT(SEGVN_WRITE_HELD(seg->s_as, &svd->lock));
ASSERT(p != NULL);
ASSERT(svd->tr_state == SEGVN_TR_INIT);
ASSERT(!HAT_IS_REGION_COOKIE_VALID(svd->rcookie));
ASSERT(svd->flags & MAP_TEXT);
ASSERT(svd->type == MAP_PRIVATE);
ASSERT(vp != NULL && svd->amp == NULL);
ASSERT(!svd->pageprot && !(svd->prot & PROT_WRITE));
ASSERT(!(svd->flags & MAP_NORESERVE) && svd->swresv == 0);
ASSERT(seg->s_as != &kas);
ASSERT(off < eoff);
ASSERT(svntr_hashtab != NULL);
if (!lgrp_optimizations()) {
svd->tr_state = SEGVN_TR_OFF;
return;
}
va.va_mask = AT_SIZE | AT_MTIME | AT_CTIME;
if (VOP_GETATTR(vp, &va, 0, svd->cred, NULL) != 0) {
svd->tr_state = SEGVN_TR_OFF;
SEGVN_TR_ADDSTAT(gaerr);
return;
}
if (btopr(va.va_size) < btopr(eoff)) {
svd->tr_state = SEGVN_TR_OFF;
SEGVN_TR_ADDSTAT(overmap);
return;
}
if (!(vp->v_flag & VVMEXEC)) {
mutex_enter(&vp->v_lock);
vp->v_flag |= VVMEXEC;
mutex_exit(&vp->v_lock);
}
mutex_enter(&svntr_hashtab[hash].tr_lock);
if (vn_is_mapped(vp, V_WRITE)) {
mutex_exit(&svntr_hashtab[hash].tr_lock);
svd->tr_state = SEGVN_TR_OFF;
SEGVN_TR_ADDSTAT(wrcnt);
return;
}
svntrp = svntr_hashtab[hash].tr_head;
for (; svntrp != NULL; svntrp = svntrp->tr_next) {
ASSERT(svntrp->tr_refcnt != 0);
if (svntrp->tr_vp != vp) {
continue;
}
if (!svntrp->tr_valid ||
svntrp->tr_mtime.tv_sec != va.va_mtime.tv_sec ||
svntrp->tr_mtime.tv_nsec != va.va_mtime.tv_nsec ||
svntrp->tr_ctime.tv_sec != va.va_ctime.tv_sec ||
svntrp->tr_ctime.tv_nsec != va.va_ctime.tv_nsec) {
mutex_exit(&svntr_hashtab[hash].tr_lock);
svd->tr_state = SEGVN_TR_OFF;
SEGVN_TR_ADDSTAT(stale);
return;
}
if (svntrp->tr_off == off && svntrp->tr_eoff == eoff &&
svntrp->tr_szc == szc) {
break;
}
if ((off >= svntrp->tr_off && off < svntrp->tr_eoff) ||
(eoff > svntrp->tr_off && eoff <= svntrp->tr_eoff)) {
mutex_exit(&svntr_hashtab[hash].tr_lock);
svd->tr_state = SEGVN_TR_OFF;
SEGVN_TR_ADDSTAT(overlap);
return;
}
}
if (svntrp == NULL) {
svntrp = kmem_cache_alloc(svntr_cache, KM_NOSLEEP);
if (svntrp == NULL) {
mutex_exit(&svntr_hashtab[hash].tr_lock);
svd->tr_state = SEGVN_TR_OFF;
SEGVN_TR_ADDSTAT(nokmem);
return;
}
#ifdef DEBUG
{
lgrp_id_t i;
for (i = 0; i < NLGRPS_MAX; i++) {
ASSERT(svntrp->tr_amp[i] == NULL);
}
}
#endif
svntrp->tr_vp = vp;
svntrp->tr_off = off;
svntrp->tr_eoff = eoff;
svntrp->tr_szc = szc;
svntrp->tr_valid = 1;
svntrp->tr_mtime = va.va_mtime;
svntrp->tr_ctime = va.va_ctime;
svntrp->tr_refcnt = 0;
svntrp->tr_next = svntr_hashtab[hash].tr_head;
svntr_hashtab[hash].tr_head = svntrp;
}
first = 1;
again:
lgrp_id = p->p_t1_lgrpid;
if (lgrp_id == LGRP_NONE) {
lgrp_id = lgrp_home_id(curthread);
}
ASSERT(lgrp_id != LGRP_NONE && lgrp_id < NLGRPS_MAX);
olid = p->p_tr_lgrpid;
if (lgrp_id != olid && olid != NLGRPS_MAX) {
lgrp_id_t nlid = (olid == LGRP_NONE) ? lgrp_id : NLGRPS_MAX;
if (atomic_cas_32((uint32_t *)&p->p_tr_lgrpid, olid, nlid) !=
olid) {
olid = p->p_tr_lgrpid;
ASSERT(olid != LGRP_NONE);
if (olid != lgrp_id && olid != NLGRPS_MAX) {
p->p_tr_lgrpid = NLGRPS_MAX;
}
}
ASSERT(p->p_tr_lgrpid != LGRP_NONE);
membar_producer();
if (first && p->p_t1_lgrpid != LGRP_NONE &&
p->p_t1_lgrpid != lgrp_id) {
first = 0;
goto again;
}
}
if ((amp = svntrp->tr_amp[lgrp_id]) == NULL) {
size_t trmem = atomic_add_long_nv(&segvn_textrepl_bytes, size);
if (trmem > segvn_textrepl_max_bytes) {
SEGVN_TR_ADDSTAT(normem);
goto fail;
}
if (anon_try_resv_zone(size, NULL) == 0) {
SEGVN_TR_ADDSTAT(noanon);
goto fail;
}
amp = anonmap_alloc(size, size, ANON_NOSLEEP);
if (amp == NULL) {
anon_unresv_zone(size, NULL);
SEGVN_TR_ADDSTAT(nokmem);
goto fail;
}
ASSERT(amp->refcnt == 1);
amp->a_szc = szc;
svntrp->tr_amp[lgrp_id] = amp;
SEGVN_TR_ADDSTAT(newamp);
}
svntrp->tr_refcnt++;
ASSERT(svd->svn_trnext == NULL);
ASSERT(svd->svn_trprev == NULL);
svd->svn_trnext = svntrp->tr_svnhead;
svd->svn_trprev = NULL;
if (svntrp->tr_svnhead != NULL) {
svntrp->tr_svnhead->svn_trprev = svd;
}
svntrp->tr_svnhead = svd;
ASSERT(amp->a_szc == szc && amp->size == size && amp->swresv == size);
ASSERT(amp->refcnt >= 1);
svd->amp = amp;
svd->anon_index = 0;
svd->tr_policy_info.mem_policy = LGRP_MEM_POLICY_NEXT_SEG;
svd->tr_policy_info.mem_lgrpid = lgrp_id;
svd->tr_state = SEGVN_TR_ON;
mutex_exit(&svntr_hashtab[hash].tr_lock);
SEGVN_TR_ADDSTAT(repl);
return;
fail:
ASSERT(segvn_textrepl_bytes >= size);
atomic_add_long(&segvn_textrepl_bytes, -size);
ASSERT(svntrp != NULL);
ASSERT(svntrp->tr_amp[lgrp_id] == NULL);
if (svntrp->tr_refcnt == 0) {
ASSERT(svntrp == svntr_hashtab[hash].tr_head);
svntr_hashtab[hash].tr_head = svntrp->tr_next;
mutex_exit(&svntr_hashtab[hash].tr_lock);
kmem_cache_free(svntr_cache, svntrp);
} else {
mutex_exit(&svntr_hashtab[hash].tr_lock);
}
svd->tr_state = SEGVN_TR_OFF;
}
static void
segvn_textunrepl(struct seg *seg, int unload_unmap)
{
struct segvn_data *svd = (struct segvn_data *)seg->s_data;
vnode_t *vp = svd->vp;
u_offset_t off = svd->offset;
size_t size = seg->s_size;
u_offset_t eoff = off + size;
uint_t szc = seg->s_szc;
ulong_t hash = SVNTR_HASH_FUNC(vp);
svntr_t *svntrp;
svntr_t **prv_svntrp;
lgrp_id_t lgrp_id = svd->tr_policy_info.mem_lgrpid;
lgrp_id_t i;
ASSERT(AS_LOCK_HELD(seg->s_as));
ASSERT(AS_WRITE_HELD(seg->s_as) ||
SEGVN_WRITE_HELD(seg->s_as, &svd->lock));
ASSERT(svd->tr_state == SEGVN_TR_ON);
ASSERT(!HAT_IS_REGION_COOKIE_VALID(svd->rcookie));
ASSERT(svd->amp != NULL);
ASSERT(svd->amp->refcnt >= 1);
ASSERT(svd->anon_index == 0);
ASSERT(lgrp_id != LGRP_NONE && lgrp_id < NLGRPS_MAX);
ASSERT(svntr_hashtab != NULL);
mutex_enter(&svntr_hashtab[hash].tr_lock);
prv_svntrp = &svntr_hashtab[hash].tr_head;
for (; (svntrp = *prv_svntrp) != NULL; prv_svntrp = &svntrp->tr_next) {
ASSERT(svntrp->tr_refcnt != 0);
if (svntrp->tr_vp == vp && svntrp->tr_off == off &&
svntrp->tr_eoff == eoff && svntrp->tr_szc == szc) {
break;
}
}
if (svntrp == NULL) {
panic("segvn_textunrepl: svntr record not found");
}
if (svntrp->tr_amp[lgrp_id] != svd->amp) {
panic("segvn_textunrepl: amp mismatch");
}
svd->tr_state = SEGVN_TR_OFF;
svd->amp = NULL;
if (svd->svn_trprev == NULL) {
ASSERT(svntrp->tr_svnhead == svd);
svntrp->tr_svnhead = svd->svn_trnext;
if (svntrp->tr_svnhead != NULL) {
svntrp->tr_svnhead->svn_trprev = NULL;
}
svd->svn_trnext = NULL;
} else {
svd->svn_trprev->svn_trnext = svd->svn_trnext;
if (svd->svn_trnext != NULL) {
svd->svn_trnext->svn_trprev = svd->svn_trprev;
svd->svn_trnext = NULL;
}
svd->svn_trprev = NULL;
}
if (--svntrp->tr_refcnt) {
mutex_exit(&svntr_hashtab[hash].tr_lock);
goto done;
}
*prv_svntrp = svntrp->tr_next;
mutex_exit(&svntr_hashtab[hash].tr_lock);
for (i = 0; i < NLGRPS_MAX; i++) {
struct anon_map *amp = svntrp->tr_amp[i];
if (amp == NULL) {
continue;
}
ASSERT(amp->refcnt == 1);
ASSERT(amp->swresv == size);
ASSERT(amp->size == size);
ASSERT(amp->a_szc == szc);
if (amp->a_szc != 0) {
anon_free_pages(amp->ahp, 0, size, szc);
} else {
anon_free(amp->ahp, 0, size);
}
svntrp->tr_amp[i] = NULL;
ASSERT(segvn_textrepl_bytes >= size);
atomic_add_long(&segvn_textrepl_bytes, -size);
anon_unresv_zone(amp->swresv, NULL);
amp->refcnt = 0;
anonmap_free(amp);
}
kmem_cache_free(svntr_cache, svntrp);
done:
hat_unload_callback(seg->s_as->a_hat, seg->s_base, size,
unload_unmap ? HAT_UNLOAD_UNMAP : 0, NULL);
}
static void
segvn_inval_trcache(vnode_t *vp)
{
ulong_t hash = SVNTR_HASH_FUNC(vp);
svntr_t *svntrp;
ASSERT(vp->v_flag & VVMEXEC);
if (svntr_hashtab == NULL) {
return;
}
mutex_enter(&svntr_hashtab[hash].tr_lock);
svntrp = svntr_hashtab[hash].tr_head;
for (; svntrp != NULL; svntrp = svntrp->tr_next) {
ASSERT(svntrp->tr_refcnt != 0);
if (svntrp->tr_vp == vp && svntrp->tr_valid) {
svntrp->tr_valid = 0;
}
}
mutex_exit(&svntr_hashtab[hash].tr_lock);
}
static void
segvn_trasync_thread(void)
{
callb_cpr_t cpr_info;
kmutex_t cpr_lock;
mutex_init(&cpr_lock, NULL, MUTEX_DEFAULT, NULL);
CALLB_CPR_INIT(&cpr_info, &cpr_lock,
callb_generic_cpr, "segvn_async");
if (segvn_update_textrepl_interval == 0) {
segvn_update_textrepl_interval = segvn_update_tr_time * hz;
} else {
segvn_update_textrepl_interval *= hz;
}
(void) timeout(segvn_trupdate_wakeup, NULL,
segvn_update_textrepl_interval);
for (;;) {
mutex_enter(&cpr_lock);
CALLB_CPR_SAFE_BEGIN(&cpr_info);
mutex_exit(&cpr_lock);
sema_p(&segvn_trasync_sem);
mutex_enter(&cpr_lock);
CALLB_CPR_SAFE_END(&cpr_info, &cpr_lock);
mutex_exit(&cpr_lock);
segvn_trupdate();
}
}
static uint64_t segvn_lgrp_trthr_migrs_snpsht = 0;
static void
segvn_trupdate_wakeup(void *dummy)
{
uint64_t cur_lgrp_trthr_migrs = lgrp_get_trthr_migrations();
if (cur_lgrp_trthr_migrs != segvn_lgrp_trthr_migrs_snpsht) {
segvn_lgrp_trthr_migrs_snpsht = cur_lgrp_trthr_migrs;
sema_v(&segvn_trasync_sem);
}
if (!segvn_disable_textrepl_update &&
segvn_update_textrepl_interval != 0) {
(void) timeout(segvn_trupdate_wakeup, dummy,
segvn_update_textrepl_interval);
}
}
static void
segvn_trupdate(void)
{
ulong_t hash;
svntr_t *svntrp;
segvn_data_t *svd;
ASSERT(svntr_hashtab != NULL);
for (hash = 0; hash < svntr_hashtab_sz; hash++) {
mutex_enter(&svntr_hashtab[hash].tr_lock);
svntrp = svntr_hashtab[hash].tr_head;
for (; svntrp != NULL; svntrp = svntrp->tr_next) {
ASSERT(svntrp->tr_refcnt != 0);
svd = svntrp->tr_svnhead;
for (; svd != NULL; svd = svd->svn_trnext) {
segvn_trupdate_seg(svd->seg, svd, svntrp,
hash);
}
}
mutex_exit(&svntr_hashtab[hash].tr_lock);
}
}
static void
segvn_trupdate_seg(struct seg *seg, segvn_data_t *svd, svntr_t *svntrp,
ulong_t hash)
{
proc_t *p;
lgrp_id_t lgrp_id;
struct as *as;
size_t size;
struct anon_map *amp;
ASSERT(svd->vp != NULL);
ASSERT(svd->vp == svntrp->tr_vp);
ASSERT(svd->offset == svntrp->tr_off);
ASSERT(svd->offset + seg->s_size == svntrp->tr_eoff);
ASSERT(seg != NULL);
ASSERT(svd->seg == seg);
ASSERT(seg->s_data == (void *)svd);
ASSERT(seg->s_szc == svntrp->tr_szc);
ASSERT(svd->tr_state == SEGVN_TR_ON);
ASSERT(!HAT_IS_REGION_COOKIE_VALID(svd->rcookie));
ASSERT(svd->amp != NULL);
ASSERT(svd->tr_policy_info.mem_policy == LGRP_MEM_POLICY_NEXT_SEG);
ASSERT(svd->tr_policy_info.mem_lgrpid != LGRP_NONE);
ASSERT(svd->tr_policy_info.mem_lgrpid < NLGRPS_MAX);
ASSERT(svntrp->tr_amp[svd->tr_policy_info.mem_lgrpid] == svd->amp);
ASSERT(svntrp->tr_refcnt != 0);
ASSERT(mutex_owned(&svntr_hashtab[hash].tr_lock));
as = seg->s_as;
ASSERT(as != NULL && as != &kas);
p = as->a_proc;
ASSERT(p != NULL);
ASSERT(p->p_tr_lgrpid != LGRP_NONE);
lgrp_id = p->p_t1_lgrpid;
if (lgrp_id == LGRP_NONE) {
return;
}
ASSERT(lgrp_id < NLGRPS_MAX);
if (svd->tr_policy_info.mem_lgrpid == lgrp_id) {
return;
}
if (!AS_LOCK_TRYENTER(as, RW_READER)) {
SEGVN_TR_ADDSTAT(nolock);
if (segvn_lgrp_trthr_migrs_snpsht) {
segvn_lgrp_trthr_migrs_snpsht = 0;
}
return;
}
if (!SEGVN_LOCK_TRYENTER(seg->s_as, &svd->lock, RW_WRITER)) {
AS_LOCK_EXIT(as);
SEGVN_TR_ADDSTAT(nolock);
if (segvn_lgrp_trthr_migrs_snpsht) {
segvn_lgrp_trthr_migrs_snpsht = 0;
}
return;
}
size = seg->s_size;
if (svntrp->tr_amp[lgrp_id] == NULL) {
size_t trmem = atomic_add_long_nv(&segvn_textrepl_bytes, size);
if (trmem > segvn_textrepl_max_bytes) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
AS_LOCK_EXIT(as);
atomic_add_long(&segvn_textrepl_bytes, -size);
SEGVN_TR_ADDSTAT(normem);
return;
}
if (anon_try_resv_zone(size, NULL) == 0) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
AS_LOCK_EXIT(as);
atomic_add_long(&segvn_textrepl_bytes, -size);
SEGVN_TR_ADDSTAT(noanon);
return;
}
amp = anonmap_alloc(size, size, KM_NOSLEEP);
if (amp == NULL) {
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
AS_LOCK_EXIT(as);
atomic_add_long(&segvn_textrepl_bytes, -size);
anon_unresv_zone(size, NULL);
SEGVN_TR_ADDSTAT(nokmem);
return;
}
ASSERT(amp->refcnt == 1);
amp->a_szc = seg->s_szc;
svntrp->tr_amp[lgrp_id] = amp;
}
mutex_exit(&svntr_hashtab[hash].tr_lock);
hat_unload_callback(as->a_hat, seg->s_base, size, 0, NULL);
mutex_enter(&svntr_hashtab[hash].tr_lock);
ASSERT(svd->tr_state == SEGVN_TR_ON);
ASSERT(svd->amp != NULL);
ASSERT(svd->tr_policy_info.mem_policy == LGRP_MEM_POLICY_NEXT_SEG);
ASSERT(svd->tr_policy_info.mem_lgrpid != lgrp_id);
ASSERT(svd->amp != svntrp->tr_amp[lgrp_id]);
svd->tr_policy_info.mem_lgrpid = lgrp_id;
svd->amp = svntrp->tr_amp[lgrp_id];
p->p_tr_lgrpid = NLGRPS_MAX;
SEGVN_LOCK_EXIT(seg->s_as, &svd->lock);
AS_LOCK_EXIT(as);
ASSERT(svntrp->tr_refcnt != 0);
ASSERT(svd->vp == svntrp->tr_vp);
ASSERT(svd->tr_policy_info.mem_lgrpid == lgrp_id);
ASSERT(svd->amp != NULL && svd->amp == svntrp->tr_amp[lgrp_id]);
ASSERT(svd->seg == seg);
ASSERT(svd->tr_state == SEGVN_TR_ON);
SEGVN_TR_ADDSTAT(asyncrepl);
}