#include <sys/param.h>
#include <sys/systm.h>
#include <sys/proc_internal.h>
#include <sys/buf_internal.h>
#include <sys/vnode_internal.h>
#include <sys/mount_internal.h>
#include <sys/trace.h>
#include <sys/malloc.h>
#include <sys/resourcevar.h>
#include <miscfs/specfs/specdev.h>
#include <sys/ubc.h>
#include <sys/kauth.h>
#if DIAGNOSTIC
#include <kern/assert.h>
#endif
#include <kern/task.h>
#include <kern/zalloc.h>
#include <kern/lock.h>
#include <vm/vm_kern.h>
#include <sys/kdebug.h>
#include <machine/spl.h>
#if BALANCE_QUEUES
static __inline__ void bufqinc(int q);
static __inline__ void bufqdec(int q);
#endif
static int bcleanbuf(buf_t bp);
static int brecover_data(buf_t bp);
static boolean_t incore(vnode_t vp, daddr64_t blkno);
static buf_t incore_locked(vnode_t vp, daddr64_t blkno);
static buf_t getnewbuf(int slpflag, int slptimeo, int *queue);
static void bremfree_locked(buf_t bp);
static void buf_reassign(buf_t bp, vnode_t newvp);
static errno_t buf_acquire_locked(buf_t bp, int flags, int slpflag, int slptimeo);
static int buf_iterprepare(vnode_t vp, struct buflists *, int flags);
static void buf_itercomplete(vnode_t vp, struct buflists *, int flags);
__private_extern__ int bdwrite_internal(buf_t, int);
static void bufzoneinit(void);
static void bcleanbuf_thread_init(void);
static void bcleanbuf_thread(void);
static zone_t buf_hdr_zone;
static int buf_hdr_count;
#define BUFHASH(dvp, lbn) \
(&bufhashtbl[((long)(dvp) / sizeof(*(dvp)) + (int)(lbn)) & bufhash])
LIST_HEAD(bufhashhdr, buf) *bufhashtbl, invalhash;
u_long bufhash;
struct bufstats bufstats;
int nbdwrite = 0;
int blaundrycnt = 0;
static TAILQ_HEAD(ioqueue, buf) iobufqueue;
static TAILQ_HEAD(bqueues, buf) bufqueues[BQUEUES];
static int needbuffer;
static int need_iobuffer;
static lck_grp_t *buf_mtx_grp;
static lck_attr_t *buf_mtx_attr;
static lck_grp_attr_t *buf_mtx_grp_attr;
static lck_mtx_t *iobuffer_mtxp;
static lck_mtx_t *buf_mtxp;
static __inline__ int
buf_timestamp(void)
{
struct timeval t;
microuptime(&t);
return (t.tv_sec);
}
#if BALANCE_QUEUES
#define binsheadfree(bp, dp, whichq) do { \
TAILQ_INSERT_HEAD(dp, bp, b_freelist); \
bufqinc((whichq)); \
(bp)->b_whichq = whichq; \
(bp)->b_timestamp = buf_timestamp(); \
} while (0)
#define binstailfree(bp, dp, whichq) do { \
TAILQ_INSERT_TAIL(dp, bp, b_freelist); \
bufqinc((whichq)); \
(bp)->b_whichq = whichq; \
(bp)->b_timestamp = buf_timestamp(); \
} while (0)
#else
#define binsheadfree(bp, dp, whichq) do { \
TAILQ_INSERT_HEAD(dp, bp, b_freelist); \
(bp)->b_whichq = whichq; \
(bp)->b_timestamp = buf_timestamp(); \
} while (0)
#define binstailfree(bp, dp, whichq) do { \
TAILQ_INSERT_TAIL(dp, bp, b_freelist); \
(bp)->b_whichq = whichq; \
(bp)->b_timestamp = buf_timestamp(); \
} while (0)
#endif
#define BHASHENTCHECK(bp) \
if ((bp)->b_hash.le_prev != (struct buf **)0xdeadbeef) \
panic("%x: b_hash.le_prev is not deadbeef", (bp));
#define BLISTNONE(bp) \
(bp)->b_hash.le_next = (struct buf *)0; \
(bp)->b_hash.le_prev = (struct buf **)0xdeadbeef;
#define bufinsvn(bp, dp) LIST_INSERT_HEAD(dp, bp, b_vnbufs)
#define bufremvn(bp) { \
LIST_REMOVE(bp, b_vnbufs); \
(bp)->b_vnbufs.le_next = NOLIST; \
}
#define LRU_IS_STALE 120
#define AGE_IS_STALE 60
#define META_IS_STALE 180
int lru_is_stale = LRU_IS_STALE;
int age_is_stale = AGE_IS_STALE;
int meta_is_stale = META_IS_STALE;
static int boot_nbuf = 0;
static __inline__ void
blistenterhead(struct bufhashhdr * head, buf_t bp)
{
if ((bp->b_hash.le_next = (head)->lh_first) != NULL)
(head)->lh_first->b_hash.le_prev = &(bp)->b_hash.le_next;
(head)->lh_first = bp;
bp->b_hash.le_prev = &(head)->lh_first;
if (bp->b_hash.le_prev == (struct buf **)0xdeadbeef)
panic("blistenterhead: le_prev is deadbeef");
}
static __inline__ void
binshash(buf_t bp, struct bufhashhdr *dp)
{
#if DIAGNOSTIC
buf_t nbp;
#endif
BHASHENTCHECK(bp);
#if DIAGNOSTIC
nbp = dp->lh_first;
for(; nbp != NULL; nbp = nbp->b_hash.le_next) {
if(nbp == bp)
panic("buf already in hashlist");
}
#endif
blistenterhead(dp, bp);
}
static __inline__ void
bremhash(buf_t bp)
{
if (bp->b_hash.le_prev == (struct buf **)0xdeadbeef)
panic("bremhash le_prev is deadbeef");
if (bp->b_hash.le_next == bp)
panic("bremhash: next points to self");
if (bp->b_hash.le_next != NULL)
bp->b_hash.le_next->b_hash.le_prev = bp->b_hash.le_prev;
*bp->b_hash.le_prev = (bp)->b_hash.le_next;
}
int
buf_valid(buf_t bp) {
if ( (bp->b_flags & (B_DONE | B_DELWRI)) )
return 1;
return 0;
}
int
buf_fromcache(buf_t bp) {
if ( (bp->b_flags & B_CACHE) )
return 1;
return 0;
}
void
buf_markinvalid(buf_t bp) {
SET(bp->b_flags, B_INVAL);
}
void
buf_markdelayed(buf_t bp) {
SET(bp->b_flags, B_DELWRI);
buf_reassign(bp, bp->b_vp);
}
void
buf_markeintr(buf_t bp) {
SET(bp->b_flags, B_EINTR);
}
void
buf_markaged(buf_t bp) {
SET(bp->b_flags, B_AGE);
}
errno_t
buf_error(buf_t bp) {
return (bp->b_error);
}
void
buf_seterror(buf_t bp, errno_t error) {
if ((bp->b_error = error))
SET(bp->b_flags, B_ERROR);
else
CLR(bp->b_flags, B_ERROR);
}
void
buf_setflags(buf_t bp, int32_t flags) {
SET(bp->b_flags, (flags & BUF_X_WRFLAGS));
}
void
buf_clearflags(buf_t bp, int32_t flags) {
CLR(bp->b_flags, (flags & BUF_X_WRFLAGS));
}
int32_t
buf_flags(buf_t bp) {
return ((bp->b_flags & BUF_X_RDFLAGS));
}
void
buf_reset(buf_t bp, int32_t io_flags) {
CLR(bp->b_flags, (B_READ | B_WRITE | B_ERROR | B_DONE | B_INVAL | B_ASYNC | B_NOCACHE));
SET(bp->b_flags, (io_flags & (B_ASYNC | B_READ | B_WRITE | B_NOCACHE)));
bp->b_error = 0;
}
uint32_t
buf_count(buf_t bp) {
return (bp->b_bcount);
}
void
buf_setcount(buf_t bp, uint32_t bcount) {
bp->b_bcount = bcount;
}
uint32_t
buf_size(buf_t bp) {
return (bp->b_bufsize);
}
void
buf_setsize(buf_t bp, uint32_t bufsize) {
bp->b_bufsize = bufsize;
}
uint32_t
buf_resid(buf_t bp) {
return (bp->b_resid);
}
void
buf_setresid(buf_t bp, uint32_t resid) {
bp->b_resid = resid;
}
uint32_t
buf_dirtyoff(buf_t bp) {
return (bp->b_dirtyoff);
}
uint32_t
buf_dirtyend(buf_t bp) {
return (bp->b_dirtyend);
}
void
buf_setdirtyoff(buf_t bp, uint32_t dirtyoff) {
bp->b_dirtyoff = dirtyoff;
}
void
buf_setdirtyend(buf_t bp, uint32_t dirtyend) {
bp->b_dirtyend = dirtyend;
}
uintptr_t
buf_dataptr(buf_t bp) {
return (bp->b_datap);
}
void
buf_setdataptr(buf_t bp, uintptr_t data) {
bp->b_datap = data;
}
vnode_t
buf_vnode(buf_t bp) {
return (bp->b_vp);
}
void
buf_setvnode(buf_t bp, vnode_t vp) {
bp->b_vp = vp;
}
void *
buf_callback(buf_t bp)
{
if ( !(bp->b_lflags & BL_IOBUF) )
return ((void *) NULL);
if ( !(bp->b_flags & B_CALL) )
return ((void *) NULL);
return ((void *)bp->b_iodone);
}
errno_t
buf_setcallback(buf_t bp, void (*callback)(buf_t, void *), void *transaction)
{
if ( !(bp->b_lflags & BL_IOBUF) )
return (EINVAL);
if (callback)
bp->b_flags |= (B_CALL | B_ASYNC);
else
bp->b_flags &= ~B_CALL;
bp->b_transaction = transaction;
bp->b_iodone = callback;
return (0);
}
errno_t
buf_setupl(buf_t bp, upl_t upl, uint32_t offset)
{
if ( !(bp->b_lflags & BL_IOBUF) )
return (EINVAL);
if (upl)
bp->b_flags |= B_CLUSTER;
else
bp->b_flags &= ~B_CLUSTER;
bp->b_upl = upl;
bp->b_uploffset = offset;
return (0);
}
buf_t
buf_clone(buf_t bp, int io_offset, int io_size, void (*iodone)(buf_t, void *), void *arg)
{
buf_t io_bp;
if (io_offset < 0 || io_size < 0)
return (NULL);
if ((unsigned)(io_offset + io_size) > (unsigned)bp->b_bcount)
return (NULL);
if (bp->b_flags & B_CLUSTER) {
if (io_offset && ((bp->b_uploffset + io_offset) & PAGE_MASK))
return (NULL);
if (((bp->b_uploffset + io_offset + io_size) & PAGE_MASK) && ((io_offset + io_size) < bp->b_bcount))
return (NULL);
}
io_bp = alloc_io_buf(bp->b_vp, 0);
io_bp->b_flags = bp->b_flags & (B_COMMIT_UPL | B_META | B_PAGEIO | B_CLUSTER | B_PHYS | B_ASYNC | B_READ);
if (iodone) {
io_bp->b_transaction = arg;
io_bp->b_iodone = iodone;
io_bp->b_flags |= B_CALL;
}
if (bp->b_flags & B_CLUSTER) {
io_bp->b_upl = bp->b_upl;
io_bp->b_uploffset = bp->b_uploffset + io_offset;
} else {
io_bp->b_datap = (uintptr_t)(((char *)bp->b_datap) + io_offset);
}
io_bp->b_bcount = io_size;
return (io_bp);
}
void
buf_setfilter(buf_t bp, void (*filter)(buf_t, void *), void *transaction,
void **old_iodone, void **old_transaction)
{
if (old_iodone)
*old_iodone = (void *)(bp->b_iodone);
if (old_transaction)
*old_transaction = (void *)(bp->b_transaction);
bp->b_transaction = transaction;
bp->b_iodone = filter;
bp->b_flags |= B_FILTER;
}
daddr64_t
buf_blkno(buf_t bp) {
return (bp->b_blkno);
}
daddr64_t
buf_lblkno(buf_t bp) {
return (bp->b_lblkno);
}
void
buf_setblkno(buf_t bp, daddr64_t blkno) {
bp->b_blkno = blkno;
}
void
buf_setlblkno(buf_t bp, daddr64_t lblkno) {
bp->b_lblkno = lblkno;
}
dev_t
buf_device(buf_t bp) {
return (bp->b_dev);
}
errno_t
buf_setdevice(buf_t bp, vnode_t vp) {
if ((vp->v_type != VBLK) && (vp->v_type != VCHR))
return EINVAL;
bp->b_dev = vp->v_rdev;
return 0;
}
void *
buf_drvdata(buf_t bp) {
return (bp->b_drvdata);
}
void
buf_setdrvdata(buf_t bp, void *drvdata) {
bp->b_drvdata = drvdata;
}
void *
buf_fsprivate(buf_t bp) {
return (bp->b_fsprivate);
}
void
buf_setfsprivate(buf_t bp, void *fsprivate) {
bp->b_fsprivate = fsprivate;
}
ucred_t
buf_rcred(buf_t bp) {
return (bp->b_rcred);
}
ucred_t
buf_wcred(buf_t bp) {
return (bp->b_wcred);
}
void *
buf_upl(buf_t bp) {
return (bp->b_upl);
}
uint32_t
buf_uploffset(buf_t bp) {
return ((uint32_t)(bp->b_uploffset));
}
proc_t
buf_proc(buf_t bp) {
return (bp->b_proc);
}
errno_t
buf_map(buf_t bp, caddr_t *io_addr)
{
buf_t real_bp;
vm_offset_t vaddr;
kern_return_t kret;
if ( !(bp->b_flags & B_CLUSTER)) {
*io_addr = (caddr_t)bp->b_datap;
return (0);
}
real_bp = (buf_t)(bp->b_real_bp);
if (real_bp && real_bp->b_datap) {
*io_addr = (caddr_t)real_bp->b_datap;
return (0);
}
kret = ubc_upl_map(bp->b_upl, &vaddr);
if (kret != KERN_SUCCESS) {
*io_addr = 0;
return(ENOMEM);
}
vaddr += bp->b_uploffset;
*io_addr = (caddr_t)vaddr;
return (0);
}
errno_t
buf_unmap(buf_t bp)
{
buf_t real_bp;
kern_return_t kret;
if ( !(bp->b_flags & B_CLUSTER))
return (0);
real_bp = (buf_t)(bp->b_real_bp);
if (real_bp && real_bp->b_datap)
return (0);
if (bp->b_lflags & BL_IOBUF) {
bp->b_flags |= B_AGE;
}
kret = ubc_upl_unmap(bp->b_upl);
if (kret != KERN_SUCCESS)
return (EINVAL);
return (0);
}
void
buf_clear(buf_t bp) {
caddr_t baddr;
if (buf_map(bp, &baddr) == 0) {
bzero(baddr, bp->b_bcount);
buf_unmap(bp);
}
bp->b_resid = 0;
}
static int
buf_strategy_fragmented(vnode_t devvp, buf_t bp, off_t f_offset, size_t contig_bytes)
{
vnode_t vp = buf_vnode(bp);
buf_t io_bp;
int io_direction;
int io_resid;
size_t io_contig_bytes;
daddr64_t io_blkno;
int error = 0;
int bmap_flags;
io_blkno = bp->b_blkno;
bp->b_blkno = bp->b_lblkno;
io_bp = alloc_io_buf(devvp, 0);
io_bp->b_lblkno = bp->b_lblkno;
io_bp->b_datap = bp->b_datap;
io_resid = bp->b_bcount;
io_direction = bp->b_flags & B_READ;
io_contig_bytes = contig_bytes;
if (bp->b_flags & B_READ)
bmap_flags = VNODE_READ;
else
bmap_flags = VNODE_WRITE;
for (;;) {
if (io_blkno == -1)
bzero((caddr_t)io_bp->b_datap, (int)io_contig_bytes);
else {
io_bp->b_bcount = io_contig_bytes;
io_bp->b_bufsize = io_contig_bytes;
io_bp->b_resid = io_contig_bytes;
io_bp->b_blkno = io_blkno;
buf_reset(io_bp, io_direction);
if ((error = VNOP_STRATEGY(io_bp)))
break;
if ((error = (int)buf_biowait(io_bp)))
break;
if (io_bp->b_resid) {
io_resid -= (io_contig_bytes - io_bp->b_resid);
break;
}
}
if ((io_resid -= io_contig_bytes) == 0)
break;
f_offset += io_contig_bytes;
io_bp->b_datap += io_contig_bytes;
if ((error = VNOP_BLOCKMAP(vp, f_offset, io_resid, &io_blkno, &io_contig_bytes, NULL, bmap_flags, NULL)))
break;
}
buf_free(io_bp);
if (error)
buf_seterror(bp, error);
bp->b_resid = io_resid;
buf_biodone(bp);
return error;
}
errno_t
buf_strategy(vnode_t devvp, void *ap)
{
buf_t bp = ((struct vnop_strategy_args *)ap)->a_bp;
vnode_t vp = bp->b_vp;
int bmap_flags;
errno_t error;
if (vp == NULL || vp->v_type == VCHR || vp->v_type == VBLK)
panic("buf_strategy: b_vp == NULL || vtype == VCHR | VBLK\n");
bp->b_dev = devvp->v_rdev;
if (bp->b_flags & B_READ)
bmap_flags = VNODE_READ;
else
bmap_flags = VNODE_WRITE;
if ( !(bp->b_flags & B_CLUSTER)) {
if ( (bp->b_upl) ) {
return (cluster_bp(bp));
}
if (bp->b_blkno == bp->b_lblkno) {
off_t f_offset;
size_t contig_bytes;
if ((error = VNOP_BLKTOOFF(vp, bp->b_lblkno, &f_offset))) {
buf_seterror(bp, error);
buf_biodone(bp);
return (error);
}
if ((error = VNOP_BLOCKMAP(vp, f_offset, bp->b_bcount, &bp->b_blkno, &contig_bytes, NULL, bmap_flags, NULL))) {
buf_seterror(bp, error);
buf_biodone(bp);
return (error);
}
if (bp->b_blkno == -1)
buf_clear(bp);
else if ((long)contig_bytes < bp->b_bcount)
return (buf_strategy_fragmented(devvp, bp, f_offset, contig_bytes));
}
if (bp->b_blkno == -1) {
buf_biodone(bp);
return (0);
}
}
return (VOCALL(devvp->v_op, VOFFSET(vnop_strategy), ap));
}
buf_t
buf_alloc(vnode_t vp)
{
return(alloc_io_buf(vp, 0));
}
void
buf_free(buf_t bp) {
free_io_buf(bp);
}
void
buf_iterate(vnode_t vp, int (*callout)(buf_t, void *), int flags, void *arg) {
buf_t bp;
int retval;
struct buflists local_iterblkhd;
int lock_flags = BAC_NOWAIT | BAC_REMOVE;
if (flags & BUF_SKIP_LOCKED)
lock_flags |= BAC_SKIP_LOCKED;
if (flags & BUF_SKIP_NONLOCKED)
lock_flags |= BAC_SKIP_NONLOCKED;
lck_mtx_lock(buf_mtxp);
if (buf_iterprepare(vp, &local_iterblkhd, VBI_DIRTY)) {
lck_mtx_unlock(buf_mtxp);
return;
}
while (!LIST_EMPTY(&local_iterblkhd)) {
bp = LIST_FIRST(&local_iterblkhd);
LIST_REMOVE(bp, b_vnbufs);
LIST_INSERT_HEAD(&vp->v_dirtyblkhd, bp, b_vnbufs);
if (buf_acquire_locked(bp, lock_flags, 0, 0))
continue;
lck_mtx_unlock(buf_mtxp);
retval = callout(bp, arg);
switch (retval) {
case BUF_RETURNED:
buf_brelse(bp);
break;
case BUF_CLAIMED:
break;
case BUF_RETURNED_DONE:
buf_brelse(bp);
lck_mtx_lock(buf_mtxp);
goto out;
case BUF_CLAIMED_DONE:
lck_mtx_lock(buf_mtxp);
goto out;
}
lck_mtx_lock(buf_mtxp);
}
out:
buf_itercomplete(vp, &local_iterblkhd, VBI_DIRTY);
lck_mtx_unlock(buf_mtxp);
}
int
buf_invalidateblks(vnode_t vp, int flags, int slpflag, int slptimeo)
{
buf_t bp;
int error = 0;
int must_rescan = 1;
struct buflists local_iterblkhd;
lck_mtx_lock(buf_mtxp);
for (;;) {
if (must_rescan == 0)
break;
if (LIST_EMPTY(&vp->v_cleanblkhd) && LIST_EMPTY(&vp->v_dirtyblkhd))
break;
must_rescan = 0;
if (buf_iterprepare(vp, &local_iterblkhd, VBI_CLEAN)) {
goto try_dirty_list;
}
while (!LIST_EMPTY(&local_iterblkhd)) {
bp = LIST_FIRST(&local_iterblkhd);
LIST_REMOVE(bp, b_vnbufs);
LIST_INSERT_HEAD(&vp->v_cleanblkhd, bp, b_vnbufs);
if ((flags & BUF_SKIP_META) && (bp->b_lblkno < 0 || ISSET(bp->b_flags, B_META)))
continue;
if ( (error = (int)buf_acquire_locked(bp, BAC_REMOVE | BAC_SKIP_LOCKED, slpflag, slptimeo)) ) {
if (error == EDEADLK)
continue;
if (error == EAGAIN) {
must_rescan++;
continue;
}
buf_itercomplete(vp, &local_iterblkhd, VBI_CLEAN);
lck_mtx_unlock(buf_mtxp);
return (error);
}
lck_mtx_unlock(buf_mtxp);
SET(bp->b_flags, B_INVAL);
buf_brelse(bp);
lck_mtx_lock(buf_mtxp);
must_rescan++;
}
buf_itercomplete(vp, &local_iterblkhd, VBI_CLEAN);
try_dirty_list:
if (buf_iterprepare(vp, &local_iterblkhd, VBI_DIRTY)) {
continue;
}
while (!LIST_EMPTY(&local_iterblkhd)) {
bp = LIST_FIRST(&local_iterblkhd);
LIST_REMOVE(bp, b_vnbufs);
LIST_INSERT_HEAD(&vp->v_dirtyblkhd, bp, b_vnbufs);
if ((flags & BUF_SKIP_META) && (bp->b_lblkno < 0 || ISSET(bp->b_flags, B_META)))
continue;
if ( (error = (int)buf_acquire_locked(bp, BAC_REMOVE | BAC_SKIP_LOCKED, slpflag, slptimeo)) ) {
if (error == EDEADLK)
continue;
if (error == EAGAIN) {
must_rescan++;
continue;
}
buf_itercomplete(vp, &local_iterblkhd, VBI_DIRTY);
lck_mtx_unlock(buf_mtxp);
return (error);
}
lck_mtx_unlock(buf_mtxp);
SET(bp->b_flags, B_INVAL);
if (ISSET(bp->b_flags, B_DELWRI) && (flags & BUF_WRITE_DATA))
(void) VNOP_BWRITE(bp);
else
buf_brelse(bp);
lck_mtx_lock(buf_mtxp);
must_rescan++;
}
buf_itercomplete(vp, &local_iterblkhd, VBI_DIRTY);
}
lck_mtx_unlock(buf_mtxp);
return (0);
}
void
buf_flushdirtyblks(vnode_t vp, int wait, int flags, char *msg) {
buf_t bp;
int writes_issued = 0;
errno_t error;
int busy = 0;
struct buflists local_iterblkhd;
int lock_flags = BAC_NOWAIT | BAC_REMOVE;
if (flags & BUF_SKIP_LOCKED)
lock_flags |= BAC_SKIP_LOCKED;
if (flags & BUF_SKIP_NONLOCKED)
lock_flags |= BAC_SKIP_NONLOCKED;
loop:
lck_mtx_lock(buf_mtxp);
if (buf_iterprepare(vp, &local_iterblkhd, VBI_DIRTY) == 0) {
while (!LIST_EMPTY(&local_iterblkhd)) {
bp = LIST_FIRST(&local_iterblkhd);
LIST_REMOVE(bp, b_vnbufs);
LIST_INSERT_HEAD(&vp->v_dirtyblkhd, bp, b_vnbufs);
if ((error = buf_acquire_locked(bp, lock_flags, 0, 0)) == EBUSY)
busy++;
if (error)
continue;
lck_mtx_unlock(buf_mtxp);
bp->b_flags &= ~B_LOCKED;
if ((bp->b_vp == vp) || (wait == 0))
(void) buf_bawrite(bp);
else
(void) VNOP_BWRITE(bp);
writes_issued++;
lck_mtx_lock(buf_mtxp);
}
buf_itercomplete(vp, &local_iterblkhd, VBI_DIRTY);
}
lck_mtx_unlock(buf_mtxp);
if (wait) {
(void)vnode_waitforwrites(vp, 0, 0, 0, msg);
if (vp->v_dirtyblkhd.lh_first && busy) {
if (writes_issued == 0) {
(void)tsleep((caddr_t)&vp->v_numoutput,
PRIBIO + 1, "vnode_flushdirtyblks", hz/20);
}
writes_issued = 0;
busy = 0;
goto loop;
}
}
}
static int
buf_iterprepare(vnode_t vp, struct buflists *iterheadp, int flags)
{
struct buflists * listheadp;
if (flags & VBI_DIRTY)
listheadp = &vp->v_dirtyblkhd;
else
listheadp = &vp->v_cleanblkhd;
while (vp->v_iterblkflags & VBI_ITER) {
vp->v_iterblkflags |= VBI_ITERWANT;
msleep(&vp->v_iterblkflags, buf_mtxp, 0, "buf_iterprepare", 0);
}
if (LIST_EMPTY(listheadp)) {
LIST_INIT(iterheadp);
return(EINVAL);
}
vp->v_iterblkflags |= VBI_ITER;
iterheadp->lh_first = listheadp->lh_first;
listheadp->lh_first->b_vnbufs.le_prev = &iterheadp->lh_first;
LIST_INIT(listheadp);
return(0);
}
static void
buf_itercomplete(vnode_t vp, struct buflists *iterheadp, int flags)
{
struct buflists * listheadp;
buf_t bp;
if (flags & VBI_DIRTY)
listheadp = &vp->v_dirtyblkhd;
else
listheadp = &vp->v_cleanblkhd;
while (!LIST_EMPTY(iterheadp)) {
bp = LIST_FIRST(iterheadp);
LIST_REMOVE(bp, b_vnbufs);
LIST_INSERT_HEAD(listheadp, bp, b_vnbufs);
}
vp->v_iterblkflags &= ~VBI_ITER;
if (vp->v_iterblkflags & VBI_ITERWANT) {
vp->v_iterblkflags &= ~VBI_ITERWANT;
wakeup(&vp->v_iterblkflags);
}
}
static void
bremfree_locked(buf_t bp)
{
struct bqueues *dp = NULL;
int whichq = -1;
if (bp->b_freelist.tqe_next == NULL) {
for (dp = bufqueues; dp < &bufqueues[BQUEUES]; dp++)
if (dp->tqh_last == &bp->b_freelist.tqe_next)
break;
if (dp == &bufqueues[BQUEUES])
panic("bremfree: lost tail");
}
TAILQ_REMOVE(dp, bp, b_freelist);
whichq = bp->b_whichq;
#if BALANCE_QUEUES
bufqdec(whichq);
#endif
bp->b_whichq = -1;
bp->b_timestamp = 0;
}
static void
bgetvp(vnode_t vp, buf_t bp)
{
if (bp->b_vp != vp)
panic("bgetvp: not free");
if (vp->v_type == VBLK || vp->v_type == VCHR)
bp->b_dev = vp->v_rdev;
else
bp->b_dev = NODEV;
lck_mtx_lock(buf_mtxp);
bufinsvn(bp, &vp->v_cleanblkhd);
lck_mtx_unlock(buf_mtxp);
}
static void
brelvp(buf_t bp)
{
vnode_t vp;
if ((vp = bp->b_vp) == (vnode_t)NULL)
panic("brelvp: NULL vp");
lck_mtx_lock(buf_mtxp);
if (bp->b_vnbufs.le_next != NOLIST)
bufremvn(bp);
lck_mtx_unlock(buf_mtxp);
bp->b_vp = (vnode_t)NULL;
}
static void
buf_reassign(buf_t bp, vnode_t newvp)
{
register struct buflists *listheadp;
if (newvp == NULL) {
printf("buf_reassign: NULL");
return;
}
lck_mtx_lock(buf_mtxp);
if (bp->b_vnbufs.le_next != NOLIST)
bufremvn(bp);
if (ISSET(bp->b_flags, B_DELWRI))
listheadp = &newvp->v_dirtyblkhd;
else
listheadp = &newvp->v_cleanblkhd;
bufinsvn(bp, listheadp);
lck_mtx_unlock(buf_mtxp);
}
static __inline__ void
bufhdrinit(buf_t bp)
{
bzero((char *)bp, sizeof *bp);
bp->b_dev = NODEV;
bp->b_rcred = NOCRED;
bp->b_wcred = NOCRED;
bp->b_vnbufs.le_next = NOLIST;
bp->b_flags = B_INVAL;
return;
}
__private_extern__ void
bufinit()
{
buf_t bp;
struct bqueues *dp;
int i;
int metabuf;
long whichq;
nbuf = 0;
for (dp = bufqueues; dp < &bufqueues[BQUEUES]; dp++)
TAILQ_INIT(dp);
bufhashtbl = hashinit(nbuf_hashelements, M_CACHE, &bufhash);
metabuf = max_nbuf_headers/8;
for (i = 0; i < max_nbuf_headers; i++) {
nbuf++;
bp = &buf[i];
bufhdrinit(bp);
if (--metabuf)
whichq = BQ_META;
else
whichq = BQ_EMPTY;
BLISTNONE(bp);
dp = &bufqueues[whichq];
binsheadfree(bp, dp, whichq);
binshash(bp, &invalhash);
}
boot_nbuf = nbuf;
for (; i < nbuf + niobuf; i++) {
bp = &buf[i];
bufhdrinit(bp);
binsheadfree(bp, &iobufqueue, -1);
}
buf_mtx_grp_attr = lck_grp_attr_alloc_init();
buf_mtx_grp = lck_grp_alloc_init("buffer cache", buf_mtx_grp_attr);
buf_mtx_attr = lck_attr_alloc_init();
buf_mtxp = lck_mtx_alloc_init(buf_mtx_grp, buf_mtx_attr);
iobuffer_mtxp = lck_mtx_alloc_init(buf_mtx_grp, buf_mtx_attr);
if (iobuffer_mtxp == NULL)
panic("couldn't create iobuffer mutex");
if (buf_mtxp == NULL)
panic("couldn't create buf mutex");
cluster_init();
printf("using %d buffer headers and %d cluster IO buffer headers\n",
nbuf, niobuf);
bufzoneinit();
bcleanbuf_thread_init();
#if BALANCE_QUEUES
{
static void bufq_balance_thread_init();
bufq_balance_thread_init();
}
#endif
}
static struct buf *
bio_doread(vnode_t vp, daddr64_t blkno, int size, ucred_t cred, int async, int queuetype)
{
buf_t bp;
bp = buf_getblk(vp, blkno, size, 0, 0, queuetype);
if (!ISSET(bp->b_flags, (B_DONE | B_DELWRI))) {
struct proc *p;
p = current_proc();
SET(bp->b_flags, B_READ | async);
if (cred != NOCRED && bp->b_rcred == NOCRED) {
kauth_cred_ref(cred);
bp->b_rcred = cred;
}
VNOP_STRATEGY(bp);
trace(TR_BREADMISS, pack(vp, size), blkno);
if (p && p->p_stats)
p->p_stats->p_ru.ru_inblock++;
if (async) {
bp = NULL;
}
} else if (async) {
buf_brelse(bp);
bp = NULL;
}
trace(TR_BREADHIT, pack(vp, size), blkno);
return (bp);
}
static errno_t
do_breadn_for_type(vnode_t vp, daddr64_t blkno, int size, daddr64_t *rablks, int *rasizes,
int nrablks, ucred_t cred, buf_t *bpp, int queuetype)
{
buf_t bp;
int i;
bp = *bpp = bio_doread(vp, blkno, size, cred, 0, queuetype);
for (i = 0; i < nrablks; i++) {
if (incore(vp, rablks[i]))
continue;
(void) bio_doread(vp, rablks[i], rasizes[i], cred, B_ASYNC, queuetype);
}
return (buf_biowait(bp));
}
errno_t
buf_bread(vnode_t vp, daddr64_t blkno, int size, ucred_t cred, buf_t *bpp)
{
buf_t bp;
bp = *bpp = bio_doread(vp, blkno, size, cred, 0, BLK_READ);
return (buf_biowait(bp));
}
errno_t
buf_meta_bread(vnode_t vp, daddr64_t blkno, int size, ucred_t cred, buf_t *bpp)
{
buf_t bp;
bp = *bpp = bio_doread(vp, blkno, size, cred, 0, BLK_META);
return (buf_biowait(bp));
}
errno_t
buf_breadn(vnode_t vp, daddr64_t blkno, int size, daddr64_t *rablks, int *rasizes, int nrablks, ucred_t cred, buf_t *bpp)
{
return (do_breadn_for_type(vp, blkno, size, rablks, rasizes, nrablks, cred, bpp, BLK_READ));
}
errno_t
buf_meta_breadn(vnode_t vp, daddr64_t blkno, int size, daddr64_t *rablks, int *rasizes, int nrablks, ucred_t cred, buf_t *bpp)
{
return (do_breadn_for_type(vp, blkno, size, rablks, rasizes, nrablks, cred, bpp, BLK_META));
}
errno_t
buf_bwrite(buf_t bp)
{
int sync, wasdelayed;
errno_t rv;
proc_t p = current_proc();
vnode_t vp = bp->b_vp;
if (bp->b_datap == 0) {
if (brecover_data(bp) == 0)
return (0);
}
sync = !ISSET(bp->b_flags, B_ASYNC);
wasdelayed = ISSET(bp->b_flags, B_DELWRI);
CLR(bp->b_flags, (B_READ | B_DONE | B_ERROR | B_DELWRI));
if (wasdelayed)
OSAddAtomic(-1, &nbdwrite);
if (!sync) {
if (wasdelayed)
buf_reassign(bp, vp);
else
if (p && p->p_stats)
p->p_stats->p_ru.ru_oublock++;
}
trace(TR_BUFWRITE, pack(vp, bp->b_bcount), bp->b_lblkno);
OSAddAtomic(1, &vp->v_numoutput);
VNOP_STRATEGY(bp);
if (sync) {
rv = buf_biowait(bp);
if (wasdelayed)
buf_reassign(bp, vp);
else
if (p && p->p_stats)
p->p_stats->p_ru.ru_oublock++;
if (!ISSET(bp->b_flags, B_NORELSE)) {
buf_brelse(bp);
} else {
CLR(bp->b_flags, B_NORELSE);
}
return (rv);
} else {
return (0);
}
}
int
vn_bwrite(ap)
struct vnop_bwrite_args *ap;
{
return (buf_bwrite(ap->a_bp));
}
__private_extern__ int
bdwrite_internal(buf_t bp, int return_error)
{
proc_t p = current_proc();
vnode_t vp = bp->b_vp;
if (!ISSET(bp->b_flags, B_DELWRI)) {
SET(bp->b_flags, B_DELWRI);
if (p && p->p_stats)
p->p_stats->p_ru.ru_oublock++;
OSAddAtomic(1, &nbdwrite);
buf_reassign(bp, vp);
}
if (ISSET(bp->b_flags, B_TAPE)) {
VNOP_BWRITE(bp);
return (0);
}
if (!ISSET(bp->b_flags, B_LOCKED) && nbdwrite > ((nbuf/4)*3)) {
if (return_error)
return (EAGAIN);
(void)vnode_waitforwrites(vp, VNODE_ASYNC_THROTTLE, 0, 0, (char *)"buf_bdwrite");
return (buf_bawrite(bp));
}
SET(bp->b_flags, B_DONE);
buf_brelse(bp);
return (0);
}
errno_t
buf_bdwrite(buf_t bp)
{
return (bdwrite_internal(bp, 0));
}
static int
bawrite_internal(buf_t bp, int throttle)
{
vnode_t vp = bp->b_vp;
if (vp) {
if (throttle)
(void)vnode_waitforwrites(vp, VNODE_ASYNC_THROTTLE, 0, 0, (const char *)"buf_bawrite");
else if (vp->v_numoutput >= VNODE_ASYNC_THROTTLE)
return (EWOULDBLOCK);
}
SET(bp->b_flags, B_ASYNC);
return (VNOP_BWRITE(bp));
}
errno_t
buf_bawrite(buf_t bp)
{
return (bawrite_internal(bp, 1));
}
void
buf_brelse(buf_t bp)
{
struct bqueues *bufq;
long whichq;
upl_t upl;
int need_wakeup = 0;
int need_bp_wakeup = 0;
if (bp->b_whichq != -1 || !(bp->b_lflags & BL_BUSY))
panic("buf_brelse: bad buffer = %x\n", bp);
#ifdef JOE_DEBUG
bp->b_stackbrelse[0] = __builtin_return_address(0);
bp->b_stackbrelse[1] = __builtin_return_address(1);
bp->b_stackbrelse[2] = __builtin_return_address(2);
bp->b_stackbrelse[3] = __builtin_return_address(3);
bp->b_stackbrelse[4] = __builtin_return_address(4);
bp->b_stackbrelse[5] = __builtin_return_address(5);
bp->b_lastbrelse = current_thread();
bp->b_tag = 0;
#endif
if (bp->b_lflags & BL_IOBUF) {
free_io_buf(bp);
return;
}
KERNEL_DEBUG((FSDBG_CODE(DBG_FSRW, 388)) | DBG_FUNC_START,
bp->b_lblkno * PAGE_SIZE, (int)bp, (int)bp->b_datap,
bp->b_flags, 0);
trace(TR_BRELSE, pack(bp->b_vp, bp->b_bufsize), bp->b_lblkno);
if (ISSET(bp->b_flags, B_META) && ISSET(bp->b_flags, B_INVAL)) {
if (ISSET(bp->b_flags, B_FILTER)) {
void (*iodone_func)(struct buf *, void *) = bp->b_iodone;
void *arg = (void *)bp->b_transaction;
CLR(bp->b_flags, B_FILTER);
bp->b_iodone = NULL;
bp->b_transaction = NULL;
if (iodone_func == NULL) {
panic("brelse: bp @ 0x%x has NULL b_iodone!\n", bp);
}
(*iodone_func)(bp, arg);
}
}
upl = bp->b_upl;
if ( !ISSET(bp->b_flags, B_META) && UBCINFOEXISTS(bp->b_vp) && bp->b_bufsize) {
kern_return_t kret;
int upl_flags;
if ( (upl == NULL) ) {
if ( !ISSET(bp->b_flags, B_INVAL)) {
kret = ubc_create_upl(bp->b_vp,
ubc_blktooff(bp->b_vp, bp->b_lblkno),
bp->b_bufsize,
&upl,
NULL,
UPL_PRECIOUS);
if (kret != KERN_SUCCESS)
panic("brelse: Failed to create UPL");
#ifdef UPL_DEBUG
upl_ubc_alias_set(upl, bp, 5);
#endif
}
} else {
if (bp->b_datap) {
kret = ubc_upl_unmap(upl);
if (kret != KERN_SUCCESS)
panic("ubc_upl_unmap failed");
bp->b_datap = (uintptr_t)NULL;
}
}
if (upl) {
if (bp->b_flags & (B_ERROR | B_INVAL)) {
if (bp->b_flags & (B_READ | B_INVAL))
upl_flags = UPL_ABORT_DUMP_PAGES;
else
upl_flags = 0;
ubc_upl_abort(upl, upl_flags);
} else {
if (ISSET(bp->b_flags, B_DELWRI | B_WASDIRTY))
upl_flags = UPL_COMMIT_SET_DIRTY ;
else
upl_flags = UPL_COMMIT_CLEAR_DIRTY ;
ubc_upl_commit_range(upl, 0, bp->b_bufsize, upl_flags |
UPL_COMMIT_INACTIVATE | UPL_COMMIT_FREE_ON_EMPTY);
}
bp->b_upl = NULL;
}
} else {
if ( (upl) )
panic("brelse: UPL set for non VREG; vp=%x", bp->b_vp);
}
if (ISSET(bp->b_flags, (B_LOCKED|B_ERROR)) == (B_LOCKED|B_ERROR))
CLR(bp->b_flags, B_ERROR);
if (ISSET(bp->b_flags, (B_NOCACHE|B_ERROR)))
SET(bp->b_flags, B_INVAL);
if ((bp->b_bufsize <= 0) || ISSET(bp->b_flags, B_INVAL)) {
if (bp->b_vp)
brelvp(bp);
if (ISSET(bp->b_flags, B_DELWRI))
OSAddAtomic(-1, &nbdwrite);
CLR(bp->b_flags, (B_DELWRI | B_LOCKED | B_AGE | B_ASYNC | B_NOCACHE));
if (bp->b_bufsize <= 0)
whichq = BQ_EMPTY;
else if (ISSET(bp->b_flags, B_META))
whichq = BQ_META;
else
whichq = BQ_AGE;
bufq = &bufqueues[whichq];
lck_mtx_lock(buf_mtxp);
binsheadfree(bp, bufq, whichq);
} else {
if (ISSET(bp->b_flags, B_LOCKED))
whichq = BQ_LOCKED;
else if (ISSET(bp->b_flags, B_META))
whichq = BQ_META;
else if (ISSET(bp->b_flags, B_AGE))
whichq = BQ_AGE;
else
whichq = BQ_LRU;
bufq = &bufqueues[whichq];
CLR(bp->b_flags, (B_AGE | B_ASYNC | B_NOCACHE));
lck_mtx_lock(buf_mtxp);
binstailfree(bp, bufq, whichq);
}
if (needbuffer) {
needbuffer = 0;
need_wakeup = 1;
}
if (ISSET(bp->b_lflags, BL_WANTED)) {
need_bp_wakeup = 1;
}
CLR(bp->b_lflags, (BL_BUSY | BL_WANTED));
lck_mtx_unlock(buf_mtxp);
if (need_wakeup) {
wakeup(&needbuffer);
}
if (need_bp_wakeup) {
wakeup(bp);
}
KERNEL_DEBUG((FSDBG_CODE(DBG_FSRW, 388)) | DBG_FUNC_END,
(int)bp, (int)bp->b_datap, bp->b_flags, 0, 0);
}
static boolean_t
incore(vnode_t vp, daddr64_t blkno)
{
boolean_t retval;
lck_mtx_lock(buf_mtxp);
if (incore_locked(vp, blkno))
retval = TRUE;
else
retval = FALSE;
lck_mtx_unlock(buf_mtxp);
return (retval);
}
static buf_t
incore_locked(vnode_t vp, daddr64_t blkno)
{
struct buf *bp;
bp = BUFHASH(vp, blkno)->lh_first;
for (; bp != NULL; bp = bp->b_hash.le_next) {
if (bp->b_lblkno == blkno && bp->b_vp == vp &&
!ISSET(bp->b_flags, B_INVAL)) {
return (bp);
}
}
return (0);
}
buf_t
buf_getblk(vnode_t vp, daddr64_t blkno, int size, int slpflag, int slptimeo, int operation)
{
buf_t bp;
int err;
upl_t upl;
upl_page_info_t *pl;
kern_return_t kret;
int ret_only_valid;
struct timespec ts;
int upl_flags;
KERNEL_DEBUG((FSDBG_CODE(DBG_FSRW, 386)) | DBG_FUNC_START,
(int)(blkno * PAGE_SIZE), size, operation, 0, 0);
ret_only_valid = operation & BLK_ONLYVALID;
operation &= ~BLK_ONLYVALID;
start:
lck_mtx_lock(buf_mtxp);
start_locked:
if ((bp = incore_locked(vp, blkno))) {
if (ISSET(bp->b_lflags, BL_BUSY)) {
switch (operation) {
case BLK_READ:
case BLK_WRITE:
case BLK_META:
SET(bp->b_lflags, BL_WANTED);
bufstats.bufs_busyincore++;
ts.tv_sec = (slptimeo/1000);
ts.tv_nsec = (slptimeo % 1000) * 10 * NSEC_PER_USEC * 1000;
err = msleep(bp, buf_mtxp, slpflag | PDROP | (PRIBIO + 1), "buf_getblk", &ts);
if (err && ((slpflag & PCATCH) || ((err == EWOULDBLOCK) && slptimeo)))
return (NULL);
goto start;
break;
default:
panic("getblk: paging or unknown operation for incore busy buffer - %x\n", operation);
break;
}
} else {
if ( (bp->b_upl) )
panic("buffer has UPL, but not marked BUSY: %x", bp);
SET(bp->b_lflags, BL_BUSY);
SET(bp->b_flags, B_CACHE);
#ifdef JOE_DEBUG
bp->b_owner = current_thread();
bp->b_tag = 1;
#endif
bremfree_locked(bp);
bufstats.bufs_incore++;
lck_mtx_unlock(buf_mtxp);
if ( !ret_only_valid)
allocbuf(bp, size);
upl_flags = 0;
switch (operation) {
case BLK_WRITE:
upl_flags |= UPL_WILL_MODIFY;
case BLK_READ:
upl_flags |= UPL_PRECIOUS;
if (UBCINFOEXISTS(bp->b_vp) && bp->b_bufsize) {
kret = ubc_create_upl(vp,
ubc_blktooff(vp, bp->b_lblkno),
bp->b_bufsize,
&upl,
&pl,
upl_flags);
if (kret != KERN_SUCCESS)
panic("Failed to create UPL");
bp->b_upl = upl;
if (upl_valid_page(pl, 0)) {
if (upl_dirty_page(pl, 0))
SET(bp->b_flags, B_WASDIRTY);
else
CLR(bp->b_flags, B_WASDIRTY);
} else
CLR(bp->b_flags, (B_DONE | B_CACHE | B_WASDIRTY | B_DELWRI));
kret = ubc_upl_map(upl, (vm_address_t *)&(bp->b_datap));
if (kret != KERN_SUCCESS)
panic("getblk: ubc_upl_map() failed with (%d)", kret);
}
break;
case BLK_META:
break;
default:
panic("getblk: paging or unknown operation for incore buffer- %d\n", operation);
break;
}
}
} else {
int queue = BQ_EMPTY;
if (ret_only_valid) {
lck_mtx_unlock(buf_mtxp);
return (NULL);
}
if ((UBCINVALID(vp)) || !(UBCINFOEXISTS(vp)))
operation = BLK_META;
if ((bp = getnewbuf(slpflag, slptimeo, &queue)) == NULL)
goto start_locked;
if (incore_locked(vp, blkno)) {
SET(bp->b_flags, B_INVAL);
binshash(bp, &invalhash);
lck_mtx_unlock(buf_mtxp);
buf_brelse(bp);
goto start;
}
if (operation == BLK_META)
SET(bp->b_flags, B_META);
bp->b_blkno = bp->b_lblkno = blkno;
bp->b_vp = vp;
binshash(bp, BUFHASH(vp, blkno));
lck_mtx_unlock(buf_mtxp);
bgetvp(vp, bp);
allocbuf(bp, size);
upl_flags = 0;
switch (operation) {
case BLK_META:
OSAddAtomic(1, &bufstats.bufs_miss);
break;
case BLK_WRITE:
upl_flags |= UPL_WILL_MODIFY;
case BLK_READ:
{ off_t f_offset;
size_t contig_bytes;
int bmap_flags;
if ( (bp->b_upl) )
panic("bp already has UPL: %x",bp);
f_offset = ubc_blktooff(vp, blkno);
upl_flags |= UPL_PRECIOUS;
kret = ubc_create_upl(vp,
f_offset,
bp->b_bufsize,
&upl,
&pl,
upl_flags);
if (kret != KERN_SUCCESS)
panic("Failed to create UPL");
#ifdef UPL_DEBUG
upl_ubc_alias_set(upl, bp, 4);
#endif
bp->b_upl = upl;
if (upl_valid_page(pl, 0)) {
if (operation == BLK_READ)
bmap_flags = VNODE_READ;
else
bmap_flags = VNODE_WRITE;
SET(bp->b_flags, B_CACHE | B_DONE);
OSAddAtomic(1, &bufstats.bufs_vmhits);
bp->b_validoff = 0;
bp->b_dirtyoff = 0;
if (upl_dirty_page(pl, 0)) {
SET(bp->b_flags, B_WASDIRTY);
bp->b_validend = bp->b_bcount;
bp->b_dirtyend = bp->b_bcount;
} else {
bp->b_validend = bp->b_bcount;
bp->b_dirtyend = 0;
}
if (VNOP_BLOCKMAP(vp, f_offset, bp->b_bcount, &bp->b_blkno, &contig_bytes, NULL, bmap_flags, NULL))
panic("getblk: VNOP_BLOCKMAP failed");
if ((long)contig_bytes < bp->b_bcount)
bp->b_blkno = bp->b_lblkno;
} else {
OSAddAtomic(1, &bufstats.bufs_miss);
}
kret = ubc_upl_map(upl, (vm_address_t *)&(bp->b_datap));
if (kret != KERN_SUCCESS)
panic("getblk: ubc_upl_map() failed with (%d)", kret);
break;
}
default:
panic("getblk: paging or unknown operation - %x", operation);
break;
}
}
KERNEL_DEBUG((FSDBG_CODE(DBG_FSRW, 386)) | DBG_FUNC_END,
(int)bp, (int)bp->b_datap, bp->b_flags, 3, 0);
#ifdef JOE_DEBUG
bp->b_stackgetblk[0] = __builtin_return_address(0);
bp->b_stackgetblk[1] = __builtin_return_address(1);
bp->b_stackgetblk[2] = __builtin_return_address(2);
bp->b_stackgetblk[3] = __builtin_return_address(3);
bp->b_stackgetblk[4] = __builtin_return_address(4);
bp->b_stackgetblk[5] = __builtin_return_address(5);
#endif
return (bp);
}
buf_t
buf_geteblk(size)
int size;
{
buf_t bp;
int queue = BQ_EMPTY;
lck_mtx_lock(buf_mtxp);
while ((bp = getnewbuf(0, 0, &queue)) == 0)
;
SET(bp->b_flags, (B_META|B_INVAL));
#if DIAGNOSTIC
assert(queue == BQ_EMPTY);
#endif
binshash(bp, &invalhash);
bufstats.bufs_eblk++;
lck_mtx_unlock(buf_mtxp);
allocbuf(bp, size);
return (bp);
}
#define MINMETA 512
#define MAXMETA 4096
struct meta_zone_entry {
zone_t mz_zone;
vm_size_t mz_size;
vm_size_t mz_max;
char *mz_name;
};
struct meta_zone_entry meta_zones[] = {
{NULL, (MINMETA * 1), 128 * (MINMETA * 1), "buf.512" },
{NULL, (MINMETA * 2), 64 * (MINMETA * 2), "buf.1024" },
{NULL, (MINMETA * 4), 16 * (MINMETA * 4), "buf.2048" },
{NULL, (MINMETA * 8), 512 * (MINMETA * 8), "buf.4096" },
{NULL, 0, 0, "" }
};
static void
bufzoneinit(void)
{
int i;
for (i = 0; meta_zones[i].mz_size != 0; i++) {
meta_zones[i].mz_zone =
zinit(meta_zones[i].mz_size,
meta_zones[i].mz_max,
PAGE_SIZE,
meta_zones[i].mz_name);
}
buf_hdr_zone = zinit(sizeof(struct buf), 32, PAGE_SIZE, "buf headers");
}
static __inline__ zone_t
getbufzone(size_t size)
{
int i;
if ((size % 512) || (size < MINMETA) || (size > MAXMETA))
panic("getbufzone: incorect size = %d", size);
for (i = 0; meta_zones[i].mz_size != 0; i++) {
if (meta_zones[i].mz_size >= size)
break;
}
return (meta_zones[i].mz_zone);
}
int
allocbuf(buf_t bp, int size)
{
vm_size_t desired_size;
desired_size = roundup(size, CLBYTES);
if (desired_size < PAGE_SIZE)
desired_size = PAGE_SIZE;
if (desired_size > MAXBSIZE)
panic("allocbuf: buffer larger than MAXBSIZE requested");
if (ISSET(bp->b_flags, B_META)) {
zone_t zprev, z;
int nsize = roundup(size, MINMETA);
if (bp->b_datap) {
vm_offset_t elem = (vm_offset_t)bp->b_datap;
if (ISSET(bp->b_flags, B_ZALLOC)) {
if (bp->b_bufsize < nsize) {
zprev = getbufzone(bp->b_bufsize);
if (nsize <= MAXMETA) {
desired_size = nsize;
z = getbufzone(nsize);
bp->b_datap = (uintptr_t)zalloc(z);
} else {
bp->b_datap = (uintptr_t)NULL;
kmem_alloc_wired(kernel_map, (vm_offset_t *)&bp->b_datap, desired_size);
CLR(bp->b_flags, B_ZALLOC);
}
bcopy((void *)elem, (caddr_t)bp->b_datap, bp->b_bufsize);
zfree(zprev, (void *)elem);
} else {
desired_size = bp->b_bufsize;
}
} else {
if ((vm_size_t)bp->b_bufsize < desired_size) {
bp->b_datap = (uintptr_t)NULL;
kmem_alloc_wired(kernel_map, (vm_offset_t *)&bp->b_datap, desired_size);
bcopy((const void *)elem, (caddr_t)bp->b_datap, bp->b_bufsize);
kmem_free(kernel_map, elem, bp->b_bufsize);
} else {
desired_size = bp->b_bufsize;
}
}
} else {
if (nsize <= MAXMETA) {
desired_size = nsize;
z = getbufzone(nsize);
bp->b_datap = (uintptr_t)zalloc(z);
SET(bp->b_flags, B_ZALLOC);
} else
kmem_alloc_wired(kernel_map, (vm_offset_t *)&bp->b_datap, desired_size);
}
}
bp->b_bufsize = desired_size;
bp->b_bcount = size;
return (0);
}
static buf_t
getnewbuf(int slpflag, int slptimeo, int * queue)
{
buf_t bp;
buf_t lru_bp;
buf_t age_bp;
buf_t meta_bp;
int age_time, lru_time, bp_time, meta_time;
int req = *queue;
struct timespec ts;
start:
if ((*queue > BQUEUES) || (*queue < 0)
|| (*queue == BQ_LAUNDRY) || (*queue == BQ_LOCKED))
*queue = BQ_EMPTY;
if (nbuf < max_nbuf_headers) {
nbuf++;
goto add_newbufs;
}
if (*queue != BQUEUES) {
bp = bufqueues[*queue].tqh_first;
if (bp)
goto found;
}
age_bp = bufqueues[BQ_AGE].tqh_first;
lru_bp = bufqueues[BQ_LRU].tqh_first;
meta_bp = bufqueues[BQ_META].tqh_first;
if (!age_bp && !lru_bp && !meta_bp) {
bp = bufqueues[BQ_EMPTY].tqh_first;
if (bp) {
*queue = BQ_EMPTY;
goto found;
}
add_newbufs:
lck_mtx_unlock(buf_mtxp);
bp = (struct buf *)zalloc(buf_hdr_zone);
lck_mtx_lock(buf_mtxp);
if (bp) {
bufhdrinit(bp);
BLISTNONE(bp);
binshash(bp, &invalhash);
SET(bp->b_flags, B_HDRALLOC);
*queue = BQ_EMPTY;
binsheadfree(bp, &bufqueues[BQ_EMPTY], BQ_EMPTY);
buf_hdr_count++;
goto found;
}
nbuf--;
bufstats.bufs_sleeps++;
needbuffer = 1;
ts.tv_sec = (slptimeo/1000);
ts.tv_nsec = (slptimeo % 1000) * NSEC_PER_USEC * 1000 * 10;
msleep(&needbuffer, buf_mtxp, slpflag|(PRIBIO+1), (char *)"getnewbuf", &ts);
return (0);
}
bp = NULL;
*queue = -1;
if (!age_bp) {
bp = lru_bp;
*queue = BQ_LRU;
} else if (!lru_bp) {
bp = age_bp;
*queue = BQ_AGE;
} else {
int t = buf_timestamp();
age_time = t - age_bp->b_timestamp;
lru_time = t - lru_bp->b_timestamp;
if ((age_time < 0) || (lru_time < 0)) {
bp = age_bp;
*queue = BQ_AGE;
} else {
if ((lru_time >= lru_is_stale) && (age_time < age_is_stale)) {
bp = lru_bp;
*queue = BQ_LRU;
} else {
bp = age_bp;
*queue = BQ_AGE;
}
}
}
if (!bp) {
bp = meta_bp;
*queue = BQ_META;
} else if (meta_bp) {
int t = buf_timestamp();
bp_time = t - bp->b_timestamp;
meta_time = t - meta_bp->b_timestamp;
if (!(bp_time < 0) && !(meta_time < 0)) {
int bp_is_stale;
bp_is_stale = (*queue == BQ_LRU) ?
lru_is_stale : age_is_stale;
if ((meta_time >= meta_is_stale) &&
(bp_time < bp_is_stale)) {
bp = meta_bp;
*queue = BQ_META;
}
}
}
found:
if (ISSET(bp->b_flags, B_LOCKED) || ISSET(bp->b_lflags, BL_BUSY))
panic("getnewbuf: bp @ 0x%x is LOCKED or BUSY! (flags 0x%x)\n", bp, bp->b_flags);
if (bcleanbuf(bp)) {
*queue = req;
goto start;
}
return (bp);
}
static int
bcleanbuf(buf_t bp)
{
ucred_t cred;
bremfree_locked(bp);
SET(bp->b_lflags, BL_BUSY);
#ifdef JOE_DEBUG
bp->b_owner = current_thread();
bp->b_tag = 2;
#endif
if (ISSET(bp->b_flags, B_DELWRI)) {
binstailfree(bp, &bufqueues[BQ_LAUNDRY], BQ_LAUNDRY);
blaundrycnt++;
lck_mtx_unlock(buf_mtxp);
wakeup(&blaundrycnt);
(void)thread_block(THREAD_CONTINUE_NULL);
lck_mtx_lock(buf_mtxp);
return (1);
}
bremhash(bp);
lck_mtx_unlock(buf_mtxp);
BLISTNONE(bp);
if (bp->b_vp)
brelvp(bp);
if (ISSET(bp->b_flags, B_META)) {
vm_offset_t elem;
elem = (vm_offset_t)bp->b_datap;
bp->b_datap = (uintptr_t)0xdeadbeef;
if (ISSET(bp->b_flags, B_ZALLOC)) {
zone_t z;
z = getbufzone(bp->b_bufsize);
zfree(z, (void *)elem);
} else
kmem_free(kernel_map, elem, bp->b_bufsize);
}
trace(TR_BRELSE, pack(bp->b_vp, bp->b_bufsize), bp->b_lblkno);
bp->b_bufsize = 0;
bp->b_datap = (uintptr_t)NULL;
bp->b_upl = (void *)NULL;
#ifdef JOE_DEBUG
bp->b_owner = current_thread();
bp->b_tag = 3;
#endif
bp->b_lflags = BL_BUSY;
bp->b_flags = (bp->b_flags & B_HDRALLOC);
bp->b_dev = NODEV;
bp->b_blkno = bp->b_lblkno = 0;
bp->b_iodone = NULL;
bp->b_error = 0;
bp->b_resid = 0;
bp->b_bcount = 0;
bp->b_dirtyoff = bp->b_dirtyend = 0;
bp->b_validoff = bp->b_validend = 0;
cred = bp->b_rcred;
if (cred != NOCRED) {
bp->b_rcred = NOCRED;
kauth_cred_rele(cred);
}
cred = bp->b_wcred;
if (cred != NOCRED) {
bp->b_wcred = NOCRED;
kauth_cred_rele(cred);
}
lck_mtx_lock(buf_mtxp);
return (0);
}
errno_t
buf_invalblkno(vnode_t vp, daddr64_t lblkno, int flags)
{
buf_t bp;
errno_t error;
lck_mtx_lock(buf_mtxp);
relook:
if ((bp = incore_locked(vp, lblkno)) == (struct buf *)0) {
lck_mtx_unlock(buf_mtxp);
return (0);
}
if (ISSET(bp->b_lflags, BL_BUSY)) {
if ( !ISSET(flags, BUF_WAIT)) {
lck_mtx_unlock(buf_mtxp);
return (EBUSY);
}
SET(bp->b_lflags, BL_WANTED);
error = msleep((caddr_t)bp, buf_mtxp, (PRIBIO + 1), (char *)"buf_invalblkno", 0);
if (error)
return (error);
goto relook;
}
bremfree_locked(bp);
SET(bp->b_lflags, BL_BUSY);
SET(bp->b_flags, B_INVAL);
#ifdef JOE_DEBUG
bp->b_owner = current_thread();
bp->b_tag = 4;
#endif
lck_mtx_unlock(buf_mtxp);
buf_brelse(bp);
return (0);
}
void
buf_drop(buf_t bp)
{
int need_wakeup = 0;
lck_mtx_lock(buf_mtxp);
if (ISSET(bp->b_lflags, BL_WANTED)) {
need_wakeup = 1;
}
CLR(bp->b_lflags, (BL_BUSY | BL_WANTED));
lck_mtx_unlock(buf_mtxp);
if (need_wakeup) {
wakeup(bp);
}
}
errno_t
buf_acquire(buf_t bp, int flags, int slpflag, int slptimeo) {
errno_t error;
lck_mtx_lock(buf_mtxp);
error = buf_acquire_locked(bp, flags, slpflag, slptimeo);
lck_mtx_unlock(buf_mtxp);
return (error);
}
static errno_t
buf_acquire_locked(buf_t bp, int flags, int slpflag, int slptimeo)
{
errno_t error;
struct timespec ts;
if (ISSET(bp->b_flags, B_LOCKED)) {
if ((flags & BAC_SKIP_LOCKED))
return (EDEADLK);
} else {
if ((flags & BAC_SKIP_NONLOCKED))
return (EDEADLK);
}
if (ISSET(bp->b_lflags, BL_BUSY)) {
if (flags & BAC_NOWAIT)
return (EBUSY);
SET(bp->b_lflags, BL_WANTED);
ts.tv_sec = (slptimeo/100);
ts.tv_nsec = (slptimeo % 100) * 10 * NSEC_PER_USEC * 1000;
error = msleep((caddr_t)bp, buf_mtxp, slpflag | (PRIBIO + 1), (char *)"buf_acquire", &ts);
if (error)
return (error);
return (EAGAIN);
}
if (flags & BAC_REMOVE)
bremfree_locked(bp);
SET(bp->b_lflags, BL_BUSY);
#ifdef JOE_DEBUG
bp->b_owner = current_thread();
bp->b_tag = 5;
#endif
return (0);
}
errno_t
buf_biowait(buf_t bp)
{
lck_mtx_lock(buf_mtxp);
while (!ISSET(bp->b_flags, B_DONE))
(void) msleep(bp, buf_mtxp, (PRIBIO+1), (char *)"buf_biowait", 0);
lck_mtx_unlock(buf_mtxp);
if (ISSET(bp->b_flags, B_EINTR)) {
CLR(bp->b_flags, B_EINTR);
return (EINTR);
} else if (ISSET(bp->b_flags, B_ERROR))
return (bp->b_error ? bp->b_error : EIO);
else
return (0);
}
extern struct timeval priority_IO_timestamp_for_root;
extern int hard_throttle_on_root;
void
buf_biodone(buf_t bp)
{
KERNEL_DEBUG((FSDBG_CODE(DBG_FSRW, 387)) | DBG_FUNC_START,
(int)bp, (int)bp->b_datap, bp->b_flags, 0, 0);
if (ISSET(bp->b_flags, B_DONE))
panic("biodone already");
if (kdebug_enable) {
int code = DKIO_DONE;
if (bp->b_flags & B_READ)
code |= DKIO_READ;
if (bp->b_flags & B_ASYNC)
code |= DKIO_ASYNC;
if (bp->b_flags & B_META)
code |= DKIO_META;
else if (bp->b_flags & B_PAGEIO)
code |= DKIO_PAGING;
KERNEL_DEBUG_CONSTANT(FSDBG_CODE(DBG_DKRW, code) | DBG_FUNC_NONE,
(unsigned int)bp, (unsigned int)bp->b_vp,
bp->b_resid, bp->b_error, 0);
}
if ((bp->b_vp != NULLVP) &&
((bp->b_flags & (B_PAGEIO | B_READ)) == (B_PAGEIO | B_READ)) &&
(bp->b_vp->v_mount->mnt_kern_flag & MNTK_ROOTDEV)) {
microuptime(&priority_IO_timestamp_for_root);
hard_throttle_on_root = 0;
}
CLR(bp->b_flags, B_WASDIRTY);
if (!ISSET(bp->b_flags, B_READ) && !ISSET(bp->b_flags, B_RAW))
vnode_writedone(bp->b_vp);
if (ISSET(bp->b_flags, (B_CALL | B_FILTER))) {
void (*iodone_func)(struct buf *, void *) = bp->b_iodone;
void *arg = (void *)bp->b_transaction;
int callout = ISSET(bp->b_flags, B_CALL);
CLR(bp->b_flags, (B_CALL | B_FILTER));
bp->b_iodone = NULL;
bp->b_transaction = NULL;
if (iodone_func == NULL) {
panic("biodone: bp @ 0x%x has NULL b_iodone!\n", bp);
} else {
if (callout)
SET(bp->b_flags, B_DONE);
(*iodone_func)(bp, arg);
}
if (callout)
goto biodone_done;
}
if (ISSET(bp->b_flags, B_ASYNC)) {
SET(bp->b_flags, B_DONE);
buf_brelse(bp);
} else {
lck_mtx_lock(buf_mtxp);
CLR(bp->b_lflags, BL_WANTED);
SET(bp->b_flags, B_DONE);
lck_mtx_unlock(buf_mtxp);
wakeup(bp);
}
biodone_done:
KERNEL_DEBUG((FSDBG_CODE(DBG_FSRW, 387)) | DBG_FUNC_END,
(int)bp, (int)bp->b_datap, bp->b_flags, 0, 0);
}
int
count_lock_queue(void)
{
buf_t bp;
int n = 0;
lck_mtx_lock(buf_mtxp);
for (bp = bufqueues[BQ_LOCKED].tqh_first; bp;
bp = bp->b_freelist.tqe_next)
n++;
lck_mtx_unlock(buf_mtxp);
return (n);
}
int
count_busy_buffers(void)
{
buf_t bp;
int nbusy = 0;
lck_mtx_lock(buf_mtxp);
for (bp = &buf[boot_nbuf]; --bp >= buf; )
if (!ISSET(bp->b_flags, B_INVAL) && ISSET(bp->b_lflags, BL_BUSY))
nbusy++;
lck_mtx_unlock(buf_mtxp);
return (nbusy);
}
#if DIAGNOSTIC
void
vfs_bufstats()
{
int i, j, count;
register struct buf *bp;
register struct bqueues *dp;
int counts[MAXBSIZE/CLBYTES+1];
static char *bname[BQUEUES] =
{ "LOCKED", "LRU", "AGE", "EMPTY", "META", "LAUNDRY" };
for (dp = bufqueues, i = 0; dp < &bufqueues[BQUEUES]; dp++, i++) {
count = 0;
for (j = 0; j <= MAXBSIZE/CLBYTES; j++)
counts[j] = 0;
lck_mtx_lock(buf_mtxp);
for (bp = dp->tqh_first; bp; bp = bp->b_freelist.tqe_next) {
counts[bp->b_bufsize/CLBYTES]++;
count++;
}
lck_mtx_unlock(buf_mtxp);
printf("%s: total-%d", bname[i], count);
for (j = 0; j <= MAXBSIZE/CLBYTES; j++)
if (counts[j] != 0)
printf(", %d-%d", j * CLBYTES, counts[j]);
printf("\n");
}
}
#endif
#define NRESERVEDIOBUFS 64
buf_t
alloc_io_buf(vnode_t vp, int priv)
{
buf_t bp;
lck_mtx_lock(iobuffer_mtxp);
while (((niobuf - NRESERVEDIOBUFS < bufstats.bufs_iobufinuse) && !priv) ||
(bp = iobufqueue.tqh_first) == NULL) {
bufstats.bufs_iobufsleeps++;
need_iobuffer = 1;
(void) msleep(&need_iobuffer, iobuffer_mtxp, (PRIBIO+1), (const char *)"alloc_io_buf", 0);
}
TAILQ_REMOVE(&iobufqueue, bp, b_freelist);
bufstats.bufs_iobufinuse++;
if (bufstats.bufs_iobufinuse > bufstats.bufs_iobufmax)
bufstats.bufs_iobufmax = bufstats.bufs_iobufinuse;
lck_mtx_unlock(iobuffer_mtxp);
bp->b_timestamp = 0;
bp->b_proc = NULL;
bp->b_datap = 0;
bp->b_flags = 0;
bp->b_lflags = BL_BUSY | BL_IOBUF;
bp->b_blkno = bp->b_lblkno = 0;
#ifdef JOE_DEBUG
bp->b_owner = current_thread();
bp->b_tag = 6;
#endif
bp->b_iodone = NULL;
bp->b_error = 0;
bp->b_resid = 0;
bp->b_bcount = 0;
bp->b_bufsize = 0;
bp->b_upl = NULL;
bp->b_vp = vp;
if (vp && (vp->v_type == VBLK || vp->v_type == VCHR))
bp->b_dev = vp->v_rdev;
else
bp->b_dev = NODEV;
return (bp);
}
void
free_io_buf(buf_t bp)
{
int need_wakeup = 0;
bp->b_vp = NULL;
bp->b_flags = B_INVAL;
lck_mtx_lock(iobuffer_mtxp);
binsheadfree(bp, &iobufqueue, -1);
if (need_iobuffer) {
need_iobuffer = 0;
need_wakeup = 1;
}
bufstats.bufs_iobufinuse--;
lck_mtx_unlock(iobuffer_mtxp);
if (need_wakeup)
wakeup(&need_iobuffer);
}
#include <mach/mach_types.h>
#include <mach/memory_object_types.h>
#include <kern/sched_prim.h>
static void
bcleanbuf_thread_init(void)
{
kernel_thread(kernel_task, bcleanbuf_thread);
}
static void
bcleanbuf_thread(void)
{
struct buf *bp;
int error = 0;
int loopcnt = 0;
for (;;) {
lck_mtx_lock(buf_mtxp);
while (blaundrycnt == 0)
(void)msleep((void *)&blaundrycnt, buf_mtxp, PRIBIO, "blaundry", 0);
bp = TAILQ_FIRST(&bufqueues[BQ_LAUNDRY]);
bremfree_locked(bp);
blaundrycnt--;
lck_mtx_unlock(buf_mtxp);
error = bawrite_internal(bp, 0);
if (error) {
lck_mtx_lock(buf_mtxp);
binstailfree(bp, &bufqueues[BQ_LAUNDRY], BQ_LAUNDRY);
blaundrycnt++;
lck_mtx_unlock(buf_mtxp);
if (loopcnt > 10) {
(void)tsleep((void *)&blaundrycnt, PRIBIO, "blaundry", 1);
loopcnt = 0;
} else {
(void)thread_block(THREAD_CONTINUE_NULL);
loopcnt++;
}
}
}
}
static int
brecover_data(buf_t bp)
{
int upl_offset;
upl_t upl;
upl_page_info_t *pl;
kern_return_t kret;
vnode_t vp = bp->b_vp;
int upl_flags;
if ( !UBCINFOEXISTS(vp) || bp->b_bufsize == 0)
goto dump_buffer;
upl_flags = UPL_PRECIOUS;
if (! (buf_flags(bp) & B_READ)) {
upl_flags |= UPL_WILL_MODIFY;
}
kret = ubc_create_upl(vp,
ubc_blktooff(vp, bp->b_lblkno),
bp->b_bufsize,
&upl,
&pl,
upl_flags);
if (kret != KERN_SUCCESS)
panic("Failed to create UPL");
for (upl_offset = 0; upl_offset < bp->b_bufsize; upl_offset += PAGE_SIZE) {
if (!upl_valid_page(pl, upl_offset / PAGE_SIZE) || !upl_dirty_page(pl, upl_offset / PAGE_SIZE)) {
ubc_upl_abort(upl, 0);
goto dump_buffer;
}
}
bp->b_upl = upl;
kret = ubc_upl_map(upl, (vm_address_t *)&(bp->b_datap));
if (kret != KERN_SUCCESS)
panic("getblk: ubc_upl_map() failed with (%d)", kret);
return (1);
dump_buffer:
bp->b_bufsize = 0;
SET(bp->b_flags, B_INVAL);
buf_brelse(bp);
return(0);
}
#if FLUSH_QUEUES
#define NFLUSH 32
static int
bp_cmp(void *a, void *b)
{
buf_t *bp_a = *(buf_t **)a,
*bp_b = *(buf_t **)b;
daddr64_t res;
res = (bp_a->b_blkno - bp_b->b_blkno);
return (int)res;
}
int
bflushq(int whichq, mount_t mp)
{
buf_t bp, next;
int i, buf_count;
int total_writes = 0;
static buf_t flush_table[NFLUSH];
if (whichq < 0 || whichq >= BQUEUES) {
return (0);
}
restart:
lck_mtx_lock(buf_mtxp);
bp = TAILQ_FIRST(&bufqueues[whichq]);
for (buf_count = 0; bp; bp = next) {
next = bp->b_freelist.tqe_next;
if (bp->b_vp == NULL || bp->b_vp->v_mount != mp) {
continue;
}
if (ISSET(bp->b_flags, B_DELWRI) && !ISSET(bp->b_lflags, BL_BUSY)) {
bremfree_locked(bp);
#ifdef JOE_DEBUG
bp->b_owner = current_thread();
bp->b_tag = 7;
#endif
SET(bp->b_lflags, BL_BUSY);
flush_table[buf_count] = bp;
buf_count++;
total_writes++;
if (buf_count >= NFLUSH) {
lck_mtx_unlock(buf_mtxp);
qsort(flush_table, buf_count, sizeof(struct buf *), bp_cmp);
for (i = 0; i < buf_count; i++) {
buf_bawrite(flush_table[i]);
}
goto restart;
}
}
}
lck_mtx_unlock(buf_mtxp);
if (buf_count > 0) {
qsort(flush_table, buf_count, sizeof(struct buf *), bp_cmp);
for (i = 0; i < buf_count; i++) {
buf_bawrite(flush_table[i]);
}
}
return (total_writes);
}
#endif
#if BALANCE_QUEUES
typedef long long blsize_t;
blsize_t MAXNBUF;
blsize_t nbufh;
blsize_t nbuflow;
blsize_t nbufhigh;
blsize_t nbuftarget;
struct bufqlim {
blsize_t bl_nlow;
blsize_t bl_num;
blsize_t bl_nlhigh;
blsize_t bl_target;
long bl_stale;
} bufqlim[BQUEUES];
long bufqscanwait = 0;
static void bufqscan_thread();
static int balancebufq(int q);
static int btrimempty(int n);
static __inline__ int initbufqscan(void);
static __inline__ int nextbufq(int q);
static void buqlimprt(int all);
static __inline__ void
bufqinc(int q)
{
if ((q < 0) || (q >= BQUEUES))
return;
bufqlim[q].bl_num++;
return;
}
static __inline__ void
bufqdec(int q)
{
if ((q < 0) || (q >= BQUEUES))
return;
bufqlim[q].bl_num--;
return;
}
static void
bufq_balance_thread_init()
{
if (bufqscanwait++ == 0) {
MAXNBUF = (sane_size / PAGE_SIZE);
nbufh = nbuf;
nbuflow = min(nbufh, 100);
nbufhigh = min(MAXNBUF, max(nbufh, 2048));
nbuftarget = (sane_size >> 5) / PAGE_SIZE;
nbuftarget = max(nbuflow, nbuftarget);
nbuftarget = min(nbufhigh, nbuftarget);
bufqlim[BQ_LOCKED].bl_nlow = 0;
bufqlim[BQ_LOCKED].bl_nlhigh = 32;
bufqlim[BQ_LOCKED].bl_target = 0;
bufqlim[BQ_LOCKED].bl_stale = 30;
bufqlim[BQ_LRU].bl_nlow = 0;
bufqlim[BQ_LRU].bl_nlhigh = nbufhigh/4;
bufqlim[BQ_LRU].bl_target = nbuftarget/4;
bufqlim[BQ_LRU].bl_stale = LRU_IS_STALE;
bufqlim[BQ_AGE].bl_nlow = 0;
bufqlim[BQ_AGE].bl_nlhigh = nbufhigh/4;
bufqlim[BQ_AGE].bl_target = nbuftarget/4;
bufqlim[BQ_AGE].bl_stale = AGE_IS_STALE;
bufqlim[BQ_EMPTY].bl_nlow = 0;
bufqlim[BQ_EMPTY].bl_nlhigh = nbufhigh/4;
bufqlim[BQ_EMPTY].bl_target = nbuftarget/4;
bufqlim[BQ_EMPTY].bl_stale = 600000;
bufqlim[BQ_META].bl_nlow = 0;
bufqlim[BQ_META].bl_nlhigh = nbufhigh/4;
bufqlim[BQ_META].bl_target = nbuftarget/4;
bufqlim[BQ_META].bl_stale = META_IS_STALE;
bufqlim[BQ_LOCKED].bl_nlow = 0;
bufqlim[BQ_LOCKED].bl_nlhigh = 32;
bufqlim[BQ_LOCKED].bl_target = 0;
bufqlim[BQ_LOCKED].bl_stale = 30;
buqlimprt(1);
}
kernel_thread(kernel_task, bufqscan_thread);
}
static void
bufqscan_thread()
{
int moretodo = 0;
for(;;) {
do {
int q;
q = initbufqscan();
for (; q; ) {
moretodo |= balancebufq(q);
q = nextbufq(q);
}
} while (moretodo);
#if DIAGNOSTIC
vfs_bufstats();
buqlimprt(0);
#endif
(void)tsleep((void *)&bufqscanwait, PRIBIO, "bufqscanwait", 60 * hz);
moretodo = 0;
}
}
static __inline__ int
initbufqscan()
{
return (BQ_AGE);
}
static __inline__ int
nextbufq(int q)
{
int order[] = { BQ_AGE, BQ_LRU, BQ_META, BQ_EMPTY, 0 };
q++;
q %= sizeof(order);
return (order[q]);
}
static int
balancebufq(int q)
{
int moretodo = 0;
int s = splbio();
int n, t;
if ((q < 0) || (q >= BQUEUES))
goto out;
if ((q == BQ_LOCKED) || (q == BQ_LAUNDRY))
goto out;
n = (bufqlim[q].bl_num - bufqlim[q].bl_target);
if (n < 0)
goto out;
if ( n > 8 ) {
n >>= 3;
}
if (q == BQ_EMPTY) {
moretodo |= btrimempty(n);
goto out;
}
t = buf_timestamp():
for (; n > 0; n--) {
struct buf *bp = bufqueues[q].tqh_first;
if (!bp)
break;
if ((t - bp->b_timestamp) > bufqlim[q].bl_stale) {
if (bcleanbuf(bp)) {
moretodo = 1;
} else {
SET(bp->b_flags, B_INVAL);
buf_brelse(bp);
}
} else
break;
}
out:
splx(s);
return (moretodo);
}
static int
btrimempty(int n)
{
return (0);
}
static void
buqlimprt(int all)
{
int i;
static char *bname[BQUEUES] =
{ "LOCKED", "LRU", "AGE", "EMPTY", "META", "LAUNDRY" };
if (all)
for (i = 0; i < BQUEUES; i++) {
printf("%s : ", bname[i]);
printf("min = %ld, ", (long)bufqlim[i].bl_nlow);
printf("cur = %ld, ", (long)bufqlim[i].bl_num);
printf("max = %ld, ", (long)bufqlim[i].bl_nlhigh);
printf("target = %ld, ", (long)bufqlim[i].bl_target);
printf("stale after %ld seconds\n", bufqlim[i].bl_stale);
}
else
for (i = 0; i < BQUEUES; i++) {
printf("%s : ", bname[i]);
printf("cur = %ld, ", (long)bufqlim[i].bl_num);
}
}
#endif