/*
- * Copyright (c) 2000-2004 Apple Computer, Inc. All rights reserved.
+ * Copyright (c) 2000-2006 Apple Computer, Inc. All rights reserved.
*
* @APPLE_OSREFERENCE_LICENSE_HEADER_START@
*
#include <mach/mach_types.h>
#include <mach/memory_object_types.h>
+#include <mach/sdt.h>
#include <vm/vm_map.h>
#include <vm/vm_kern.h>
return (vm_object_offset_t) ubc_getsize(vp);
}
+kern_return_t
+vnode_pager_get_pathname(
+ struct vnode *vp,
+ char *pathname,
+ vm_size_t *length_p)
+{
+ int error, len;
+
+ len = (int) *length_p;
+ error = vn_getpath(vp, pathname, &len);
+ if (error != 0) {
+ return KERN_FAILURE;
+ }
+ *length_p = (vm_size_t) len;
+ return KERN_SUCCESS;
+}
+
+kern_return_t
+vnode_pager_get_filename(
+ struct vnode *vp,
+ const char **filename)
+{
+ *filename = vp->v_name;
+ return KERN_SUCCESS;
+}
+
+kern_return_t
+vnode_pager_get_cs_blobs(
+ struct vnode *vp,
+ void **blobs)
+{
+ *blobs = ubc_get_cs_blobs(vp);
+ return KERN_SUCCESS;
+}
+
pager_return_t
vnode_pageout(struct vnode *vp,
upl_t upl,
int flags,
int *errorp)
{
- struct proc *p = current_proc();
int result = PAGER_SUCCESS;
int error = 0;
int error_ret = 0;
int base_index;
int offset;
upl_page_info_t *pl;
- struct vfs_context context;
-
- context.vc_proc = p;
- context.vc_ucred = kauth_cred_get();
+ vfs_context_t ctx = vfs_context_current(); /* pager context */
isize = (int)size;
error_ret = EINVAL;
goto out;
}
- UBCINFOCHECK("vnode_pageout", vp);
- if (UBCINVALID(vp)) {
+ if (UBCINFOEXISTS(vp) == 0) {
result = PAGER_ERROR;
error_ret = EINVAL;
size, 1, 0, 0, 0);
if ( (error_ret = VNOP_PAGEOUT(vp, upl, upl_offset, (off_t)f_offset,
- (size_t)size, flags, &context)) )
+ (size_t)size, flags, ctx)) )
result = PAGER_ERROR;
KERNEL_DEBUG_CONSTANT((MACHDBG_CODE(DBG_MACH_VM, 1)) | DBG_FUNC_END,
goto out;
}
}
- isize = (pg_index + 1) * PAGE_SIZE;
+ isize = ((pg_index + 1) - base_index) * PAGE_SIZE;
offset = upl_offset;
pg_index = base_index;
* to get back empty slots in the UPL
* just skip over them
*/
- offset += PAGE_SIZE;
- isize -= PAGE_SIZE;
+ f_offset += PAGE_SIZE;
+ offset += PAGE_SIZE;
+ isize -= PAGE_SIZE;
pg_index++;
continue;
#if NFSCLIENT
if (vp->v_tag == VT_NFS)
/* check with nfs if page is OK to drop */
- error = nfs_buf_page_inval(vp, (off_t)(f_offset + offset));
+ error = nfs_buf_page_inval(vp, (off_t)f_offset);
else
#endif
{
- blkno = ubc_offtoblk(vp, (off_t)(f_offset + offset));
+ blkno = ubc_offtoblk(vp, (off_t)f_offset);
error = buf_invalblkno(vp, blkno, 0);
}
if (error) {
} else if ( !(flags & UPL_NOCOMMIT)) {
ubc_upl_commit_range(upl, offset, PAGE_SIZE, UPL_COMMIT_FREE_ON_EMPTY);
}
- offset += PAGE_SIZE;
- isize -= PAGE_SIZE;
+ f_offset += PAGE_SIZE;
+ offset += PAGE_SIZE;
+ isize -= PAGE_SIZE;
pg_index++;
continue;
xsize = num_of_pages * PAGE_SIZE;
KERNEL_DEBUG_CONSTANT((MACHDBG_CODE(DBG_MACH_VM, 1)) | DBG_FUNC_START,
- xsize, (int)(f_offset + offset), 0, 0, 0);
+ xsize, (int)f_offset, 0, 0, 0);
- if ( (error = VNOP_PAGEOUT(vp, upl, (vm_offset_t)offset,
- (off_t)(f_offset + offset), xsize,
- flags, &context)) ) {
+ if ( (error = VNOP_PAGEOUT(vp, upl, (vm_offset_t)offset, (off_t)f_offset,
+ xsize, flags, ctx)) ) {
if (error_ret == 0)
error_ret = error;
result = PAGER_ERROR;
KERNEL_DEBUG_CONSTANT((MACHDBG_CODE(DBG_MACH_VM, 1)) | DBG_FUNC_END,
xsize, 0, 0, 0, 0);
- offset += xsize;
- isize -= xsize;
+ f_offset += xsize;
+ offset += xsize;
+ isize -= xsize;
pg_index += num_of_pages;
}
out:
}
-void IOSleep(int);
+extern void throttle_lowpri_io(int *lowpri_window,mount_t v_mount);
pager_return_t
vnode_pagein(
int flags,
int *errorp)
{
- struct proc *p = current_proc();
struct uthread *ut;
upl_page_info_t *pl;
int result = PAGER_SUCCESS;
int last_pg;
int first_pg;
int xsize;
- int abort_needed = 1;
-
+ int must_commit = 1;
- UBCINFOCHECK("vnode_pagein", vp);
+ if (flags & UPL_NOCOMMIT)
+ must_commit = 0;
- if (UBCINVALID(vp)) {
+ if (UBCINFOEXISTS(vp) == 0) {
result = PAGER_ERROR;
error = PAGER_ERROR;
- if (upl && !(flags & UPL_NOCOMMIT)) {
+
+ if (upl && must_commit)
ubc_upl_abort_range(upl, upl_offset, size, UPL_ABORT_FREE_ON_EMPTY | UPL_ABORT_ERROR);
- }
+
goto out;
}
if (upl == (upl_t)NULL) {
- if (size > (MAX_UPL_TRANSFER * PAGE_SIZE)) {
+ if (size > (MAX_UPL_SIZE * PAGE_SIZE)) {
+
+ panic("vnode_pagein: size = %x\n", size);
+
result = PAGER_ERROR;
error = PAGER_ERROR;
goto out;
}
- ubc_create_upl(vp, f_offset, size, &upl, &pl, UPL_RET_ONLY_ABSENT | UPL_SET_LITE);
+ ubc_create_upl(vp, f_offset, size, &upl, &pl, UPL_NOBLOCK | UPL_RET_ONLY_ABSENT | UPL_SET_LITE);
if (upl == (upl_t)NULL) {
+
+ panic("vnode_pagein: ubc_create_upl failed\n");
+
result = PAGER_ABSENT;
error = PAGER_ABSENT;
goto out;
}
upl_offset = 0;
+ first_pg = 0;
+
/*
* if we get here, we've created the upl and
* are responsible for commiting/aborting it
* regardless of what the caller has passed in
*/
flags &= ~UPL_NOCOMMIT;
+ must_commit = 1;
vp_pagein++;
} else {
pl = ubc_upl_pageinfo(upl);
+ first_pg = upl_offset / PAGE_SIZE;
dp_pgins++;
}
pages_in_upl = size / PAGE_SIZE;
- first_pg = upl_offset / PAGE_SIZE;
+ DTRACE_VM2(pgpgin, int, pages_in_upl, (uint64_t *), NULL);
/*
* before we start marching forward, we must make sure we end on
for (last_pg = pages_in_upl - 1; last_pg >= first_pg; last_pg--) {
if (upl_page_present(pl, last_pg))
break;
+ if (last_pg == first_pg) {
+ /*
+ * empty UPL, no pages are present
+ */
+ if (must_commit)
+ ubc_upl_abort_range(upl, upl_offset, size, UPL_ABORT_FREE_ON_EMPTY);
+ goto out;
+ }
}
pages_in_upl = last_pg + 1;
+ last_pg = first_pg;
- for (last_pg = first_pg; last_pg < pages_in_upl;) {
+ while (last_pg < pages_in_upl) {
/*
- * scan the upl looking for the next
- * page that is present.... if all of the
- * pages are absent, we're done
+ * skip over missing pages...
*/
- for (start_pg = last_pg; last_pg < pages_in_upl; last_pg++) {
+ for ( ; last_pg < pages_in_upl; last_pg++) {
if (upl_page_present(pl, last_pg))
break;
}
- if (last_pg == pages_in_upl)
- break;
-
/*
- * if we get here, we've sitting on a page
- * that is present... we want to skip over
- * any range of 'valid' pages... if this takes
- * us to the end of the request, than we're done
+ * skip over 'valid' pages... we don't want to issue I/O for these
*/
for (start_pg = last_pg; last_pg < pages_in_upl; last_pg++) {
- if (!upl_valid_page(pl, last_pg) || !upl_page_present(pl, last_pg))
+ if (!upl_valid_page(pl, last_pg))
break;
}
if (last_pg > start_pg) {
*/
xsize = (last_pg - start_pg) * PAGE_SIZE;
- if (!(flags & UPL_NOCOMMIT))
+ if (must_commit)
ubc_upl_abort_range(upl, start_pg * PAGE_SIZE, xsize, UPL_ABORT_FREE_ON_EMPTY);
-
- abort_needed = 0;
}
if (last_pg == pages_in_upl)
+ /*
+ * we're done... all pages that were present
+ * have either had I/O issued on them or
+ * were aborted unchanged...
+ */
break;
- if (!upl_page_present(pl, last_pg))
+ if (!upl_page_present(pl, last_pg)) {
/*
- * if we found a range of valid pages
- * terminated by a non-present page
- * than start over
+ * we found a range of valid pages
+ * terminated by a missing page...
+ * bump index to the next page and continue on
*/
+ last_pg++;
continue;
-
+ }
/*
* scan from the found invalid page looking for a valid
* or non-present page before the end of the upl is reached, if we
}
if (last_pg > start_pg) {
int xoff;
- struct vfs_context context;
-
- context.vc_proc = p;
- context.vc_ucred = kauth_cred_get();
xsize = (last_pg - start_pg) * PAGE_SIZE;
xoff = start_pg * PAGE_SIZE;
if ( (error = VNOP_PAGEIN(vp, upl, (vm_offset_t) xoff,
(off_t)f_offset + xoff,
- xsize, flags, &context)) ) {
+ xsize, flags, vfs_context_current())) ) {
result = PAGER_ERROR;
error = PAGER_ERROR;
}
- abort_needed = 0;
}
}
- if (!(flags & UPL_NOCOMMIT) && abort_needed)
- ubc_upl_abort_range(upl, upl_offset, size, UPL_ABORT_FREE_ON_EMPTY);
out:
if (errorp)
*errorp = result;
ut = get_bsdthread_info(current_thread());
- if (ut->uu_lowpri_delay) {
+ if (ut->uu_lowpri_window && ut->v_mount) {
/*
* task is marked as a low priority I/O type
* and the I/O we issued while in this system call
* delay in order to mitigate the impact of this
* task on the normal operation of the system
*/
- IOSleep(ut->uu_lowpri_delay);
- ut->uu_lowpri_delay = 0;
+ throttle_lowpri_io(&ut->uu_lowpri_window,ut->v_mount);
}
return (error);
}
projects / apple / xnu.git / blobdiff