mirror of
https://git.proxmox.com/git/mirror_zfs.git
synced 2026-05-22 10:37:35 +03:00
Share zfs_fsync, zfs_read, zfs_write, et al between Linux and FreeBSD
The zfs_fsync, zfs_read, and zfs_write function are almost identical between Linux and FreeBSD. With a little refactoring they can be moved to the common code which is what is done by this commit. Reviewed-by: Brian Behlendorf <behlendorf1@llnl.gov> Reviewed-by: Ryan Moeller <ryan@iXsystems.com> Signed-off-by: Matt Macy <mmacy@FreeBSD.org> Closes #11078
This commit is contained in:
committed by
Brian Behlendorf
parent
fa7b558bef
commit
3d40b65540
@@ -24,7 +24,7 @@ $(MODULE)-objs += ../os/linux/zfs/zfs_file_os.o
|
||||
$(MODULE)-objs += ../os/linux/zfs/zfs_ioctl_os.o
|
||||
$(MODULE)-objs += ../os/linux/zfs/zfs_sysfs.o
|
||||
$(MODULE)-objs += ../os/linux/zfs/zfs_vfsops.o
|
||||
$(MODULE)-objs += ../os/linux/zfs/zfs_vnops.o
|
||||
$(MODULE)-objs += ../os/linux/zfs/zfs_vnops_os.o
|
||||
$(MODULE)-objs += ../os/linux/zfs/zfs_znode.o
|
||||
$(MODULE)-objs += ../os/linux/zfs/zio_crypt.o
|
||||
$(MODULE)-objs += ../os/linux/zfs/zpl_ctldir.o
|
||||
|
||||
@@ -204,7 +204,8 @@ secpolicy_vnode_setdac(const cred_t *cr, uid_t owner)
|
||||
* Enforced in the Linux VFS.
|
||||
*/
|
||||
int
|
||||
secpolicy_vnode_setid_retain(const cred_t *cr, boolean_t issuidroot)
|
||||
secpolicy_vnode_setid_retain(struct znode *zp __maybe_unused, const cred_t *cr,
|
||||
boolean_t issuidroot)
|
||||
{
|
||||
return (priv_policy_user(cr, CAP_FSETID, EPERM));
|
||||
}
|
||||
@@ -271,7 +272,7 @@ void
|
||||
secpolicy_setid_clear(vattr_t *vap, cred_t *cr)
|
||||
{
|
||||
if ((vap->va_mode & (S_ISUID | S_ISGID)) != 0 &&
|
||||
secpolicy_vnode_setid_retain(cr,
|
||||
secpolicy_vnode_setid_retain(NULL, cr,
|
||||
(vap->va_mode & S_ISUID) != 0 &&
|
||||
(vap->va_mask & AT_UID) != 0 && vap->va_uid == 0) != 0) {
|
||||
vap->va_mask |= AT_MODE;
|
||||
|
||||
@@ -320,10 +320,11 @@ zfs_holey(struct inode *ip, int cmd, loff_t *off)
|
||||
* On Write: If we find a memory mapped page, we write to *both*
|
||||
* the page and the dmu buffer.
|
||||
*/
|
||||
static void
|
||||
update_pages(struct inode *ip, int64_t start, int len,
|
||||
void
|
||||
update_pages(znode_t *zp, int64_t start, int len,
|
||||
objset_t *os, uint64_t oid)
|
||||
{
|
||||
struct inode *ip = ZTOI(zp);
|
||||
struct address_space *mp = ip->i_mapping;
|
||||
struct page *pp;
|
||||
uint64_t nbytes;
|
||||
@@ -369,12 +370,12 @@ update_pages(struct inode *ip, int64_t start, int len,
|
||||
* NOTE: We will always "break up" the IO into PAGESIZE uiomoves when
|
||||
* the file is memory mapped.
|
||||
*/
|
||||
static int
|
||||
mappedread(struct inode *ip, int nbytes, uio_t *uio)
|
||||
int
|
||||
mappedread(znode_t *zp, int nbytes, uio_t *uio)
|
||||
{
|
||||
struct inode *ip = ZTOI(zp);
|
||||
struct address_space *mp = ip->i_mapping;
|
||||
struct page *pp;
|
||||
znode_t *zp = ITOZ(ip);
|
||||
int64_t start, off;
|
||||
uint64_t bytes;
|
||||
int len = nbytes;
|
||||
@@ -414,574 +415,8 @@ mappedread(struct inode *ip, int nbytes, uio_t *uio)
|
||||
}
|
||||
#endif /* _KERNEL */
|
||||
|
||||
unsigned long zfs_read_chunk_size = 1024 * 1024; /* Tunable */
|
||||
unsigned long zfs_delete_blocks = DMU_MAX_DELETEBLKCNT;
|
||||
|
||||
/*
|
||||
* Read bytes from specified file into supplied buffer.
|
||||
*
|
||||
* IN: ip - inode of file to be read from.
|
||||
* uio - structure supplying read location, range info,
|
||||
* and return buffer.
|
||||
* ioflag - O_SYNC flags; used to provide FRSYNC semantics.
|
||||
* O_DIRECT flag; used to bypass page cache.
|
||||
* cr - credentials of caller.
|
||||
*
|
||||
* OUT: uio - updated offset and range, buffer filled.
|
||||
*
|
||||
* RETURN: 0 on success, error code on failure.
|
||||
*
|
||||
* Side Effects:
|
||||
* inode - atime updated if byte count > 0
|
||||
*/
|
||||
/* ARGSUSED */
|
||||
int
|
||||
zfs_read(struct inode *ip, uio_t *uio, int ioflag, cred_t *cr)
|
||||
{
|
||||
int error = 0;
|
||||
boolean_t frsync = B_FALSE;
|
||||
|
||||
znode_t *zp = ITOZ(ip);
|
||||
zfsvfs_t *zfsvfs = ITOZSB(ip);
|
||||
ZFS_ENTER(zfsvfs);
|
||||
ZFS_VERIFY_ZP(zp);
|
||||
|
||||
if (zp->z_pflags & ZFS_AV_QUARANTINED) {
|
||||
ZFS_EXIT(zfsvfs);
|
||||
return (SET_ERROR(EACCES));
|
||||
}
|
||||
|
||||
/*
|
||||
* Validate file offset
|
||||
*/
|
||||
if (uio->uio_loffset < (offset_t)0) {
|
||||
ZFS_EXIT(zfsvfs);
|
||||
return (SET_ERROR(EINVAL));
|
||||
}
|
||||
|
||||
/*
|
||||
* Fasttrack empty reads
|
||||
*/
|
||||
if (uio->uio_resid == 0) {
|
||||
ZFS_EXIT(zfsvfs);
|
||||
return (0);
|
||||
}
|
||||
|
||||
#ifdef FRSYNC
|
||||
/*
|
||||
* If we're in FRSYNC mode, sync out this znode before reading it.
|
||||
* Only do this for non-snapshots.
|
||||
*
|
||||
* Some platforms do not support FRSYNC and instead map it
|
||||
* to O_SYNC, which results in unnecessary calls to zil_commit. We
|
||||
* only honor FRSYNC requests on platforms which support it.
|
||||
*/
|
||||
frsync = !!(ioflag & FRSYNC);
|
||||
#endif
|
||||
if (zfsvfs->z_log &&
|
||||
(frsync || zfsvfs->z_os->os_sync == ZFS_SYNC_ALWAYS))
|
||||
zil_commit(zfsvfs->z_log, zp->z_id);
|
||||
|
||||
/*
|
||||
* Lock the range against changes.
|
||||
*/
|
||||
zfs_locked_range_t *lr = zfs_rangelock_enter(&zp->z_rangelock,
|
||||
uio->uio_loffset, uio->uio_resid, RL_READER);
|
||||
|
||||
/*
|
||||
* If we are reading past end-of-file we can skip
|
||||
* to the end; but we might still need to set atime.
|
||||
*/
|
||||
if (uio->uio_loffset >= zp->z_size) {
|
||||
error = 0;
|
||||
goto out;
|
||||
}
|
||||
|
||||
ASSERT(uio->uio_loffset < zp->z_size);
|
||||
ssize_t n = MIN(uio->uio_resid, zp->z_size - uio->uio_loffset);
|
||||
ssize_t start_resid = n;
|
||||
|
||||
#ifdef HAVE_UIO_ZEROCOPY
|
||||
xuio_t *xuio = NULL;
|
||||
if ((uio->uio_extflg == UIO_XUIO) &&
|
||||
(((xuio_t *)uio)->xu_type == UIOTYPE_ZEROCOPY)) {
|
||||
int nblk;
|
||||
int blksz = zp->z_blksz;
|
||||
uint64_t offset = uio->uio_loffset;
|
||||
|
||||
xuio = (xuio_t *)uio;
|
||||
if ((ISP2(blksz))) {
|
||||
nblk = (P2ROUNDUP(offset + n, blksz) - P2ALIGN(offset,
|
||||
blksz)) / blksz;
|
||||
} else {
|
||||
ASSERT(offset + n <= blksz);
|
||||
nblk = 1;
|
||||
}
|
||||
(void) dmu_xuio_init(xuio, nblk);
|
||||
|
||||
if (vn_has_cached_data(ip)) {
|
||||
/*
|
||||
* For simplicity, we always allocate a full buffer
|
||||
* even if we only expect to read a portion of a block.
|
||||
*/
|
||||
while (--nblk >= 0) {
|
||||
(void) dmu_xuio_add(xuio,
|
||||
dmu_request_arcbuf(sa_get_db(zp->z_sa_hdl),
|
||||
blksz), 0, blksz);
|
||||
}
|
||||
}
|
||||
}
|
||||
#endif /* HAVE_UIO_ZEROCOPY */
|
||||
|
||||
while (n > 0) {
|
||||
ssize_t nbytes = MIN(n, zfs_read_chunk_size -
|
||||
P2PHASE(uio->uio_loffset, zfs_read_chunk_size));
|
||||
|
||||
if (zp->z_is_mapped && !(ioflag & O_DIRECT)) {
|
||||
error = mappedread(ip, nbytes, uio);
|
||||
} else {
|
||||
error = dmu_read_uio_dbuf(sa_get_db(zp->z_sa_hdl),
|
||||
uio, nbytes);
|
||||
}
|
||||
|
||||
if (error) {
|
||||
/* convert checksum errors into IO errors */
|
||||
if (error == ECKSUM)
|
||||
error = SET_ERROR(EIO);
|
||||
break;
|
||||
}
|
||||
|
||||
n -= nbytes;
|
||||
}
|
||||
|
||||
int64_t nread = start_resid - n;
|
||||
dataset_kstats_update_read_kstats(&zfsvfs->z_kstat, nread);
|
||||
task_io_account_read(nread);
|
||||
out:
|
||||
zfs_rangelock_exit(lr);
|
||||
|
||||
ZFS_EXIT(zfsvfs);
|
||||
return (error);
|
||||
}
|
||||
|
||||
/*
|
||||
* Write the bytes to a file.
|
||||
*
|
||||
* IN: ip - inode of file to be written to.
|
||||
* uio - structure supplying write location, range info,
|
||||
* and data buffer.
|
||||
* ioflag - O_APPEND flag set if in append mode.
|
||||
* O_DIRECT flag; used to bypass page cache.
|
||||
* cr - credentials of caller.
|
||||
*
|
||||
* OUT: uio - updated offset and range.
|
||||
*
|
||||
* RETURN: 0 if success
|
||||
* error code if failure
|
||||
*
|
||||
* Timestamps:
|
||||
* ip - ctime|mtime updated if byte count > 0
|
||||
*/
|
||||
|
||||
/* ARGSUSED */
|
||||
int
|
||||
zfs_write(struct inode *ip, uio_t *uio, int ioflag, cred_t *cr)
|
||||
{
|
||||
int error = 0;
|
||||
ssize_t start_resid = uio->uio_resid;
|
||||
|
||||
/*
|
||||
* Fasttrack empty write
|
||||
*/
|
||||
ssize_t n = start_resid;
|
||||
if (n == 0)
|
||||
return (0);
|
||||
|
||||
rlim64_t limit = uio->uio_limit;
|
||||
if (limit == RLIM64_INFINITY || limit > MAXOFFSET_T)
|
||||
limit = MAXOFFSET_T;
|
||||
|
||||
znode_t *zp = ITOZ(ip);
|
||||
zfsvfs_t *zfsvfs = ZTOZSB(zp);
|
||||
ZFS_ENTER(zfsvfs);
|
||||
ZFS_VERIFY_ZP(zp);
|
||||
|
||||
sa_bulk_attr_t bulk[4];
|
||||
int count = 0;
|
||||
uint64_t mtime[2], ctime[2];
|
||||
SA_ADD_BULK_ATTR(bulk, count, SA_ZPL_MTIME(zfsvfs), NULL, &mtime, 16);
|
||||
SA_ADD_BULK_ATTR(bulk, count, SA_ZPL_CTIME(zfsvfs), NULL, &ctime, 16);
|
||||
SA_ADD_BULK_ATTR(bulk, count, SA_ZPL_SIZE(zfsvfs), NULL,
|
||||
&zp->z_size, 8);
|
||||
SA_ADD_BULK_ATTR(bulk, count, SA_ZPL_FLAGS(zfsvfs), NULL,
|
||||
&zp->z_pflags, 8);
|
||||
|
||||
/*
|
||||
* Callers might not be able to detect properly that we are read-only,
|
||||
* so check it explicitly here.
|
||||
*/
|
||||
if (zfs_is_readonly(zfsvfs)) {
|
||||
ZFS_EXIT(zfsvfs);
|
||||
return (SET_ERROR(EROFS));
|
||||
}
|
||||
|
||||
/*
|
||||
* If immutable or not appending then return EPERM
|
||||
*/
|
||||
if ((zp->z_pflags & (ZFS_IMMUTABLE | ZFS_READONLY)) ||
|
||||
((zp->z_pflags & ZFS_APPENDONLY) && !(ioflag & O_APPEND) &&
|
||||
(uio->uio_loffset < zp->z_size))) {
|
||||
ZFS_EXIT(zfsvfs);
|
||||
return (SET_ERROR(EPERM));
|
||||
}
|
||||
|
||||
/*
|
||||
* Validate file offset
|
||||
*/
|
||||
offset_t woff = ioflag & O_APPEND ? zp->z_size : uio->uio_loffset;
|
||||
if (woff < 0) {
|
||||
ZFS_EXIT(zfsvfs);
|
||||
return (SET_ERROR(EINVAL));
|
||||
}
|
||||
|
||||
int max_blksz = zfsvfs->z_max_blksz;
|
||||
xuio_t *xuio = NULL;
|
||||
|
||||
/*
|
||||
* Pre-fault the pages to ensure slow (eg NFS) pages
|
||||
* don't hold up txg.
|
||||
* Skip this if uio contains loaned arc_buf.
|
||||
*/
|
||||
#ifdef HAVE_UIO_ZEROCOPY
|
||||
if ((uio->uio_extflg == UIO_XUIO) &&
|
||||
(((xuio_t *)uio)->xu_type == UIOTYPE_ZEROCOPY))
|
||||
xuio = (xuio_t *)uio;
|
||||
else
|
||||
#endif
|
||||
if (uio_prefaultpages(MIN(n, max_blksz), uio)) {
|
||||
ZFS_EXIT(zfsvfs);
|
||||
return (SET_ERROR(EFAULT));
|
||||
}
|
||||
|
||||
/*
|
||||
* If in append mode, set the io offset pointer to eof.
|
||||
*/
|
||||
zfs_locked_range_t *lr;
|
||||
if (ioflag & O_APPEND) {
|
||||
/*
|
||||
* Obtain an appending range lock to guarantee file append
|
||||
* semantics. We reset the write offset once we have the lock.
|
||||
*/
|
||||
lr = zfs_rangelock_enter(&zp->z_rangelock, 0, n, RL_APPEND);
|
||||
woff = lr->lr_offset;
|
||||
if (lr->lr_length == UINT64_MAX) {
|
||||
/*
|
||||
* We overlocked the file because this write will cause
|
||||
* the file block size to increase.
|
||||
* Note that zp_size cannot change with this lock held.
|
||||
*/
|
||||
woff = zp->z_size;
|
||||
}
|
||||
uio->uio_loffset = woff;
|
||||
} else {
|
||||
/*
|
||||
* Note that if the file block size will change as a result of
|
||||
* this write, then this range lock will lock the entire file
|
||||
* so that we can re-write the block safely.
|
||||
*/
|
||||
lr = zfs_rangelock_enter(&zp->z_rangelock, woff, n, RL_WRITER);
|
||||
}
|
||||
|
||||
if (woff >= limit) {
|
||||
zfs_rangelock_exit(lr);
|
||||
ZFS_EXIT(zfsvfs);
|
||||
return (SET_ERROR(EFBIG));
|
||||
}
|
||||
|
||||
if ((woff + n) > limit || woff > (limit - n))
|
||||
n = limit - woff;
|
||||
|
||||
/* Will this write extend the file length? */
|
||||
int write_eof = (woff + n > zp->z_size);
|
||||
|
||||
uint64_t end_size = MAX(zp->z_size, woff + n);
|
||||
zilog_t *zilog = zfsvfs->z_log;
|
||||
#ifdef HAVE_UIO_ZEROCOPY
|
||||
int i_iov = 0;
|
||||
const iovec_t *iovp = uio->uio_iov;
|
||||
int iovcnt __maybe_unused = uio->uio_iovcnt;
|
||||
#endif
|
||||
|
||||
|
||||
/*
|
||||
* Write the file in reasonable size chunks. Each chunk is written
|
||||
* in a separate transaction; this keeps the intent log records small
|
||||
* and allows us to do more fine-grained space accounting.
|
||||
*/
|
||||
while (n > 0) {
|
||||
woff = uio->uio_loffset;
|
||||
|
||||
if (zfs_id_overblockquota(zfsvfs, DMU_USERUSED_OBJECT,
|
||||
KUID_TO_SUID(ip->i_uid)) ||
|
||||
zfs_id_overblockquota(zfsvfs, DMU_GROUPUSED_OBJECT,
|
||||
KGID_TO_SGID(ip->i_gid)) ||
|
||||
(zp->z_projid != ZFS_DEFAULT_PROJID &&
|
||||
zfs_id_overblockquota(zfsvfs, DMU_PROJECTUSED_OBJECT,
|
||||
zp->z_projid))) {
|
||||
error = SET_ERROR(EDQUOT);
|
||||
break;
|
||||
}
|
||||
|
||||
arc_buf_t *abuf = NULL;
|
||||
const iovec_t *aiov = NULL;
|
||||
if (xuio) {
|
||||
#ifdef HAVE_UIO_ZEROCOPY
|
||||
ASSERT(i_iov < iovcnt);
|
||||
ASSERT3U(uio->uio_segflg, !=, UIO_BVEC);
|
||||
aiov = &iovp[i_iov];
|
||||
abuf = dmu_xuio_arcbuf(xuio, i_iov);
|
||||
dmu_xuio_clear(xuio, i_iov);
|
||||
ASSERT((aiov->iov_base == abuf->b_data) ||
|
||||
((char *)aiov->iov_base - (char *)abuf->b_data +
|
||||
aiov->iov_len == arc_buf_size(abuf)));
|
||||
i_iov++;
|
||||
#endif
|
||||
} else if (n >= max_blksz && woff >= zp->z_size &&
|
||||
P2PHASE(woff, max_blksz) == 0 &&
|
||||
zp->z_blksz == max_blksz) {
|
||||
/*
|
||||
* This write covers a full block. "Borrow" a buffer
|
||||
* from the dmu so that we can fill it before we enter
|
||||
* a transaction. This avoids the possibility of
|
||||
* holding up the transaction if the data copy hangs
|
||||
* up on a pagefault (e.g., from an NFS server mapping).
|
||||
*/
|
||||
size_t cbytes;
|
||||
|
||||
abuf = dmu_request_arcbuf(sa_get_db(zp->z_sa_hdl),
|
||||
max_blksz);
|
||||
ASSERT(abuf != NULL);
|
||||
ASSERT(arc_buf_size(abuf) == max_blksz);
|
||||
if ((error = uiocopy(abuf->b_data, max_blksz,
|
||||
UIO_WRITE, uio, &cbytes))) {
|
||||
dmu_return_arcbuf(abuf);
|
||||
break;
|
||||
}
|
||||
ASSERT(cbytes == max_blksz);
|
||||
}
|
||||
|
||||
/*
|
||||
* Start a transaction.
|
||||
*/
|
||||
dmu_tx_t *tx = dmu_tx_create(zfsvfs->z_os);
|
||||
dmu_tx_hold_sa(tx, zp->z_sa_hdl, B_FALSE);
|
||||
dmu_buf_impl_t *db = (dmu_buf_impl_t *)sa_get_db(zp->z_sa_hdl);
|
||||
DB_DNODE_ENTER(db);
|
||||
dmu_tx_hold_write_by_dnode(tx, DB_DNODE(db), woff,
|
||||
MIN(n, max_blksz));
|
||||
DB_DNODE_EXIT(db);
|
||||
zfs_sa_upgrade_txholds(tx, zp);
|
||||
error = dmu_tx_assign(tx, TXG_WAIT);
|
||||
if (error) {
|
||||
dmu_tx_abort(tx);
|
||||
if (abuf != NULL)
|
||||
dmu_return_arcbuf(abuf);
|
||||
break;
|
||||
}
|
||||
|
||||
/*
|
||||
* If rangelock_enter() over-locked we grow the blocksize
|
||||
* and then reduce the lock range. This will only happen
|
||||
* on the first iteration since rangelock_reduce() will
|
||||
* shrink down lr_length to the appropriate size.
|
||||
*/
|
||||
if (lr->lr_length == UINT64_MAX) {
|
||||
uint64_t new_blksz;
|
||||
|
||||
if (zp->z_blksz > max_blksz) {
|
||||
/*
|
||||
* File's blocksize is already larger than the
|
||||
* "recordsize" property. Only let it grow to
|
||||
* the next power of 2.
|
||||
*/
|
||||
ASSERT(!ISP2(zp->z_blksz));
|
||||
new_blksz = MIN(end_size,
|
||||
1 << highbit64(zp->z_blksz));
|
||||
} else {
|
||||
new_blksz = MIN(end_size, max_blksz);
|
||||
}
|
||||
zfs_grow_blocksize(zp, new_blksz, tx);
|
||||
zfs_rangelock_reduce(lr, woff, n);
|
||||
}
|
||||
|
||||
/*
|
||||
* XXX - should we really limit each write to z_max_blksz?
|
||||
* Perhaps we should use SPA_MAXBLOCKSIZE chunks?
|
||||
*/
|
||||
ssize_t nbytes = MIN(n, max_blksz - P2PHASE(woff, max_blksz));
|
||||
|
||||
ssize_t tx_bytes;
|
||||
if (abuf == NULL) {
|
||||
tx_bytes = uio->uio_resid;
|
||||
uio->uio_fault_disable = B_TRUE;
|
||||
error = dmu_write_uio_dbuf(sa_get_db(zp->z_sa_hdl),
|
||||
uio, nbytes, tx);
|
||||
uio->uio_fault_disable = B_FALSE;
|
||||
if (error == EFAULT) {
|
||||
dmu_tx_commit(tx);
|
||||
/*
|
||||
* Account for partial writes before
|
||||
* continuing the loop.
|
||||
* Update needs to occur before the next
|
||||
* uio_prefaultpages, or prefaultpages may
|
||||
* error, and we may break the loop early.
|
||||
*/
|
||||
if (tx_bytes != uio->uio_resid)
|
||||
n -= tx_bytes - uio->uio_resid;
|
||||
if (uio_prefaultpages(MIN(n, max_blksz), uio)) {
|
||||
break;
|
||||
}
|
||||
continue;
|
||||
} else if (error != 0) {
|
||||
dmu_tx_commit(tx);
|
||||
break;
|
||||
}
|
||||
tx_bytes -= uio->uio_resid;
|
||||
} else {
|
||||
tx_bytes = nbytes;
|
||||
ASSERT(xuio == NULL || tx_bytes == aiov->iov_len);
|
||||
/*
|
||||
* If this is not a full block write, but we are
|
||||
* extending the file past EOF and this data starts
|
||||
* block-aligned, use assign_arcbuf(). Otherwise,
|
||||
* write via dmu_write().
|
||||
*/
|
||||
if (tx_bytes < max_blksz && (!write_eof ||
|
||||
aiov->iov_base != abuf->b_data)) {
|
||||
ASSERT(xuio);
|
||||
dmu_write(zfsvfs->z_os, zp->z_id, woff,
|
||||
/* cppcheck-suppress nullPointer */
|
||||
aiov->iov_len, aiov->iov_base, tx);
|
||||
dmu_return_arcbuf(abuf);
|
||||
xuio_stat_wbuf_copied();
|
||||
} else {
|
||||
ASSERT(xuio || tx_bytes == max_blksz);
|
||||
error = dmu_assign_arcbuf_by_dbuf(
|
||||
sa_get_db(zp->z_sa_hdl), woff, abuf, tx);
|
||||
if (error != 0) {
|
||||
dmu_return_arcbuf(abuf);
|
||||
dmu_tx_commit(tx);
|
||||
break;
|
||||
}
|
||||
}
|
||||
ASSERT(tx_bytes <= uio->uio_resid);
|
||||
uioskip(uio, tx_bytes);
|
||||
}
|
||||
if (tx_bytes && zp->z_is_mapped && !(ioflag & O_DIRECT)) {
|
||||
update_pages(ip, woff,
|
||||
tx_bytes, zfsvfs->z_os, zp->z_id);
|
||||
}
|
||||
|
||||
/*
|
||||
* If we made no progress, we're done. If we made even
|
||||
* partial progress, update the znode and ZIL accordingly.
|
||||
*/
|
||||
if (tx_bytes == 0) {
|
||||
(void) sa_update(zp->z_sa_hdl, SA_ZPL_SIZE(zfsvfs),
|
||||
(void *)&zp->z_size, sizeof (uint64_t), tx);
|
||||
dmu_tx_commit(tx);
|
||||
ASSERT(error != 0);
|
||||
break;
|
||||
}
|
||||
|
||||
/*
|
||||
* Clear Set-UID/Set-GID bits on successful write if not
|
||||
* privileged and at least one of the execute bits is set.
|
||||
*
|
||||
* It would be nice to do this after all writes have
|
||||
* been done, but that would still expose the ISUID/ISGID
|
||||
* to another app after the partial write is committed.
|
||||
*
|
||||
* Note: we don't call zfs_fuid_map_id() here because
|
||||
* user 0 is not an ephemeral uid.
|
||||
*/
|
||||
mutex_enter(&zp->z_acl_lock);
|
||||
uint32_t uid = KUID_TO_SUID(ip->i_uid);
|
||||
if ((zp->z_mode & (S_IXUSR | (S_IXUSR >> 3) |
|
||||
(S_IXUSR >> 6))) != 0 &&
|
||||
(zp->z_mode & (S_ISUID | S_ISGID)) != 0 &&
|
||||
secpolicy_vnode_setid_retain(cr,
|
||||
((zp->z_mode & S_ISUID) != 0 && uid == 0)) != 0) {
|
||||
uint64_t newmode;
|
||||
zp->z_mode &= ~(S_ISUID | S_ISGID);
|
||||
ip->i_mode = newmode = zp->z_mode;
|
||||
(void) sa_update(zp->z_sa_hdl, SA_ZPL_MODE(zfsvfs),
|
||||
(void *)&newmode, sizeof (uint64_t), tx);
|
||||
}
|
||||
mutex_exit(&zp->z_acl_lock);
|
||||
|
||||
zfs_tstamp_update_setup(zp, CONTENT_MODIFIED, mtime, ctime);
|
||||
|
||||
/*
|
||||
* Update the file size (zp_size) if it has changed;
|
||||
* account for possible concurrent updates.
|
||||
*/
|
||||
while ((end_size = zp->z_size) < uio->uio_loffset) {
|
||||
(void) atomic_cas_64(&zp->z_size, end_size,
|
||||
uio->uio_loffset);
|
||||
ASSERT(error == 0);
|
||||
}
|
||||
/*
|
||||
* If we are replaying and eof is non zero then force
|
||||
* the file size to the specified eof. Note, there's no
|
||||
* concurrency during replay.
|
||||
*/
|
||||
if (zfsvfs->z_replay && zfsvfs->z_replay_eof != 0)
|
||||
zp->z_size = zfsvfs->z_replay_eof;
|
||||
|
||||
error = sa_bulk_update(zp->z_sa_hdl, bulk, count, tx);
|
||||
|
||||
zfs_log_write(zilog, tx, TX_WRITE, zp, woff, tx_bytes, ioflag,
|
||||
NULL, NULL);
|
||||
dmu_tx_commit(tx);
|
||||
|
||||
if (error != 0)
|
||||
break;
|
||||
ASSERT(tx_bytes == nbytes);
|
||||
n -= nbytes;
|
||||
|
||||
if (!xuio && n > 0) {
|
||||
if (uio_prefaultpages(MIN(n, max_blksz), uio)) {
|
||||
error = EFAULT;
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
zfs_inode_update(zp);
|
||||
zfs_rangelock_exit(lr);
|
||||
|
||||
/*
|
||||
* If we're in replay mode, or we made no progress, return error.
|
||||
* Otherwise, it's at least a partial write, so it's successful.
|
||||
*/
|
||||
if (zfsvfs->z_replay || uio->uio_resid == start_resid) {
|
||||
ZFS_EXIT(zfsvfs);
|
||||
return (error);
|
||||
}
|
||||
|
||||
if (ioflag & (O_SYNC | O_DSYNC) ||
|
||||
zfsvfs->z_os->os_sync == ZFS_SYNC_ALWAYS)
|
||||
zil_commit(zilog, zp->z_id);
|
||||
|
||||
int64_t nwritten = start_resid - uio->uio_resid;
|
||||
dataset_kstats_update_write_kstats(&zfsvfs->z_kstat, nwritten);
|
||||
task_io_account_write(nwritten);
|
||||
|
||||
ZFS_EXIT(zfsvfs);
|
||||
return (0);
|
||||
}
|
||||
|
||||
/*
|
||||
* Write the bytes to a file.
|
||||
*
|
||||
@@ -2440,26 +1875,6 @@ out:
|
||||
return (error);
|
||||
}
|
||||
|
||||
ulong_t zfs_fsync_sync_cnt = 4;
|
||||
|
||||
int
|
||||
zfs_fsync(znode_t *zp, int syncflag, cred_t *cr)
|
||||
{
|
||||
zfsvfs_t *zfsvfs = ZTOZSB(zp);
|
||||
|
||||
(void) tsd_set(zfs_fsyncer_key, (void *)zfs_fsync_sync_cnt);
|
||||
|
||||
if (zfsvfs->z_os->os_sync != ZFS_SYNC_DISABLED) {
|
||||
ZFS_ENTER(zfsvfs);
|
||||
ZFS_VERIFY_ZP(zp);
|
||||
zil_commit(zfsvfs->z_log, zp->z_id);
|
||||
ZFS_EXIT(zfsvfs);
|
||||
}
|
||||
tsd_set(zfs_fsyncer_key, NULL);
|
||||
|
||||
return (0);
|
||||
}
|
||||
|
||||
/*
|
||||
* Get the basic file attributes and place them in the provided kstat
|
||||
* structure. The inode is assumed to be the authoritative source
|
||||
@@ -4796,44 +4211,6 @@ zfs_fid(struct inode *ip, fid_t *fidp)
|
||||
return (0);
|
||||
}
|
||||
|
||||
/*ARGSUSED*/
|
||||
int
|
||||
zfs_getsecattr(struct inode *ip, vsecattr_t *vsecp, int flag, cred_t *cr)
|
||||
{
|
||||
znode_t *zp = ITOZ(ip);
|
||||
zfsvfs_t *zfsvfs = ITOZSB(ip);
|
||||
int error;
|
||||
boolean_t skipaclchk = (flag & ATTR_NOACLCHECK) ? B_TRUE : B_FALSE;
|
||||
|
||||
ZFS_ENTER(zfsvfs);
|
||||
ZFS_VERIFY_ZP(zp);
|
||||
error = zfs_getacl(zp, vsecp, skipaclchk, cr);
|
||||
ZFS_EXIT(zfsvfs);
|
||||
|
||||
return (error);
|
||||
}
|
||||
|
||||
/*ARGSUSED*/
|
||||
int
|
||||
zfs_setsecattr(znode_t *zp, vsecattr_t *vsecp, int flag, cred_t *cr)
|
||||
{
|
||||
zfsvfs_t *zfsvfs = ZTOZSB(zp);
|
||||
int error;
|
||||
boolean_t skipaclchk = (flag & ATTR_NOACLCHECK) ? B_TRUE : B_FALSE;
|
||||
zilog_t *zilog = zfsvfs->z_log;
|
||||
|
||||
ZFS_ENTER(zfsvfs);
|
||||
ZFS_VERIFY_ZP(zp);
|
||||
|
||||
error = zfs_setacl(zp, vsecp, skipaclchk, cr);
|
||||
|
||||
if (zfsvfs->z_os->os_sync == ZFS_SYNC_ALWAYS)
|
||||
zil_commit(zilog, 0);
|
||||
|
||||
ZFS_EXIT(zfsvfs);
|
||||
return (error);
|
||||
}
|
||||
|
||||
#ifdef HAVE_UIO_ZEROCOPY
|
||||
/*
|
||||
* The smallest read we may consider to loan out an arcbuf.
|
||||
@@ -4846,6 +4223,7 @@ int zcr_blksz_min = (1 << 10); /* 1K */
|
||||
*/
|
||||
int zcr_blksz_max = (1 << 17); /* 128K */
|
||||
|
||||
|
||||
/*ARGSUSED*/
|
||||
static int
|
||||
zfs_reqzcbuf(struct inode *ip, enum uio_rw ioflag, xuio_t *xuio, cred_t *cr)
|
||||
@@ -4994,8 +4372,6 @@ zfs_retzcbuf(struct inode *ip, xuio_t *xuio, cred_t *cr)
|
||||
#if defined(_KERNEL)
|
||||
EXPORT_SYMBOL(zfs_open);
|
||||
EXPORT_SYMBOL(zfs_close);
|
||||
EXPORT_SYMBOL(zfs_read);
|
||||
EXPORT_SYMBOL(zfs_write);
|
||||
EXPORT_SYMBOL(zfs_access);
|
||||
EXPORT_SYMBOL(zfs_lookup);
|
||||
EXPORT_SYMBOL(zfs_create);
|
||||
@@ -5004,7 +4380,6 @@ EXPORT_SYMBOL(zfs_remove);
|
||||
EXPORT_SYMBOL(zfs_mkdir);
|
||||
EXPORT_SYMBOL(zfs_rmdir);
|
||||
EXPORT_SYMBOL(zfs_readdir);
|
||||
EXPORT_SYMBOL(zfs_fsync);
|
||||
EXPORT_SYMBOL(zfs_getattr_fast);
|
||||
EXPORT_SYMBOL(zfs_setattr);
|
||||
EXPORT_SYMBOL(zfs_rename);
|
||||
@@ -5014,8 +4389,6 @@ EXPORT_SYMBOL(zfs_link);
|
||||
EXPORT_SYMBOL(zfs_inactive);
|
||||
EXPORT_SYMBOL(zfs_space);
|
||||
EXPORT_SYMBOL(zfs_fid);
|
||||
EXPORT_SYMBOL(zfs_getsecattr);
|
||||
EXPORT_SYMBOL(zfs_setsecattr);
|
||||
EXPORT_SYMBOL(zfs_getpage);
|
||||
EXPORT_SYMBOL(zfs_putpage);
|
||||
EXPORT_SYMBOL(zfs_dirty_inode);
|
||||
@@ -5024,8 +4397,6 @@ EXPORT_SYMBOL(zfs_map);
|
||||
/* BEGIN CSTYLED */
|
||||
module_param(zfs_delete_blocks, ulong, 0644);
|
||||
MODULE_PARM_DESC(zfs_delete_blocks, "Delete files larger than N blocks async");
|
||||
module_param(zfs_read_chunk_size, ulong, 0644);
|
||||
MODULE_PARM_DESC(zfs_read_chunk_size, "Bytes to read per chunk");
|
||||
/* END CSTYLED */
|
||||
|
||||
#endif
|
||||
@@ -504,6 +504,7 @@ zfs_inode_update(znode_t *zp)
|
||||
dmu_object_size_from_db(sa_get_db(zp->z_sa_hdl), &blksize, &i_blocks);
|
||||
|
||||
spin_lock(&ip->i_lock);
|
||||
ip->i_mode = zp->z_mode;
|
||||
ip->i_blocks = i_blocks;
|
||||
i_size_write(ip, zp->z_size);
|
||||
spin_unlock(&ip->i_lock);
|
||||
|
||||
@@ -226,12 +226,11 @@ zpl_read_common_iovec(struct inode *ip, const struct iovec *iovp, size_t count,
|
||||
uio.uio_iovcnt = nr_segs;
|
||||
uio.uio_loffset = *ppos;
|
||||
uio.uio_segflg = segment;
|
||||
uio.uio_limit = MAXOFFSET_T;
|
||||
uio.uio_resid = count;
|
||||
uio.uio_skip = skip;
|
||||
|
||||
cookie = spl_fstrans_mark();
|
||||
error = -zfs_read(ip, &uio, flags, cr);
|
||||
error = -zfs_read(ITOZ(ip), &uio, flags, cr);
|
||||
spl_fstrans_unmark(cookie);
|
||||
if (error < 0)
|
||||
return (error);
|
||||
@@ -339,12 +338,11 @@ zpl_write_common_iovec(struct inode *ip, const struct iovec *iovp, size_t count,
|
||||
uio.uio_iovcnt = nr_segs;
|
||||
uio.uio_loffset = *ppos;
|
||||
uio.uio_segflg = segment;
|
||||
uio.uio_limit = MAXOFFSET_T;
|
||||
uio.uio_resid = count;
|
||||
uio.uio_skip = skip;
|
||||
|
||||
cookie = spl_fstrans_mark();
|
||||
error = -zfs_write(ip, &uio, flags, cr);
|
||||
error = -zfs_write(ITOZ(ip), &uio, flags, cr);
|
||||
spl_fstrans_unmark(cookie);
|
||||
if (error < 0)
|
||||
return (error);
|
||||
|
||||
@@ -91,7 +91,6 @@ uio_from_bio(uio_t *uio, struct bio *bio)
|
||||
uio->uio_iovcnt = bio->bi_vcnt - BIO_BI_IDX(bio);
|
||||
uio->uio_loffset = BIO_BI_SECTOR(bio) << 9;
|
||||
uio->uio_segflg = UIO_BVEC;
|
||||
uio->uio_limit = MAXOFFSET_T;
|
||||
uio->uio_resid = BIO_BI_SIZE(bio);
|
||||
uio->uio_skip = BIO_BI_SKIP(bio);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user