1789Sahrens /* 2789Sahrens * CDDL HEADER START 3789Sahrens * 4789Sahrens * The contents of this file are subject to the terms of the 51669Sperrin * Common Development and Distribution License (the "License"). 61669Sperrin * You may not use this file except in compliance with the License. 7789Sahrens * 8789Sahrens * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE 9789Sahrens * or http://www.opensolaris.org/os/licensing. 10789Sahrens * See the License for the specific language governing permissions 11789Sahrens * and limitations under the License. 12789Sahrens * 13789Sahrens * When distributing Covered Code, include this CDDL HEADER in each 14789Sahrens * file and include the License file at usr/src/OPENSOLARIS.LICENSE. 15789Sahrens * If applicable, add the following below this CDDL HEADER, with the 16789Sahrens * fields enclosed by brackets "[]" replaced with your own identifying 17789Sahrens * information: Portions Copyright [yyyy] [name of copyright owner] 18789Sahrens * 19789Sahrens * CDDL HEADER END 20789Sahrens */ 21789Sahrens /* 229401SNeil.Perrin@Sun.COM * Copyright 2009 Sun Microsystems, Inc. All rights reserved. 23789Sahrens * Use is subject to license terms. 24789Sahrens */ 25789Sahrens 26789Sahrens #include <sys/types.h> 27789Sahrens #include <sys/param.h> 28789Sahrens #include <sys/systm.h> 29789Sahrens #include <sys/sysmacros.h> 30789Sahrens #include <sys/cmn_err.h> 31789Sahrens #include <sys/kmem.h> 32789Sahrens #include <sys/thread.h> 33789Sahrens #include <sys/file.h> 34789Sahrens #include <sys/vfs.h> 35789Sahrens #include <sys/zfs_znode.h> 36789Sahrens #include <sys/zfs_dir.h> 37789Sahrens #include <sys/zil.h> 384620Sperrin #include <sys/zil_impl.h> 39789Sahrens #include <sys/byteorder.h> 40789Sahrens #include <sys/policy.h> 41789Sahrens #include <sys/stat.h> 42789Sahrens #include <sys/mode.h> 43789Sahrens #include <sys/acl.h> 44789Sahrens #include <sys/dmu.h> 45789Sahrens #include <sys/spa.h> 465331Samw #include <sys/zfs_fuid.h> 47789Sahrens #include <sys/ddi.h> 488227SNeil.Perrin@Sun.COM #include <sys/dsl_dataset.h> 498227SNeil.Perrin@Sun.COM 50789Sahrens /* 518227SNeil.Perrin@Sun.COM * These zfs_log_* functions must be called within a dmu tx, in one 528227SNeil.Perrin@Sun.COM * of 2 contexts depending on zilog->z_replay: 538227SNeil.Perrin@Sun.COM * 548227SNeil.Perrin@Sun.COM * Non replay mode 558227SNeil.Perrin@Sun.COM * --------------- 568227SNeil.Perrin@Sun.COM * We need to record the transaction so that if it is committed to 578227SNeil.Perrin@Sun.COM * the Intent Log then it can be replayed. An intent log transaction 588227SNeil.Perrin@Sun.COM * structure (itx_t) is allocated and all the information necessary to 598227SNeil.Perrin@Sun.COM * possibly replay the transaction is saved in it. The itx is then assigned 608227SNeil.Perrin@Sun.COM * a sequence number and inserted in the in-memory list anchored in the zilog. 618227SNeil.Perrin@Sun.COM * 628227SNeil.Perrin@Sun.COM * Replay mode 638227SNeil.Perrin@Sun.COM * ----------- 648227SNeil.Perrin@Sun.COM * We need to mark the intent log record as replayed in the log header. 658227SNeil.Perrin@Sun.COM * This is done in the same transaction as the replay so that they 668227SNeil.Perrin@Sun.COM * commit atomically. 67789Sahrens */ 68789Sahrens 695331Samw int 705331Samw zfs_log_create_txtype(zil_create_t type, vsecattr_t *vsecp, vattr_t *vap) 715331Samw { 725331Samw int isxvattr = (vap->va_mask & AT_XVATTR); 735331Samw switch (type) { 745331Samw case Z_FILE: 755331Samw if (vsecp == NULL && !isxvattr) 765331Samw return (TX_CREATE); 775331Samw if (vsecp && isxvattr) 785331Samw return (TX_CREATE_ACL_ATTR); 795331Samw if (vsecp) 805331Samw return (TX_CREATE_ACL); 815331Samw else 825331Samw return (TX_CREATE_ATTR); 835331Samw /*NOTREACHED*/ 845331Samw case Z_DIR: 855331Samw if (vsecp == NULL && !isxvattr) 865331Samw return (TX_MKDIR); 875331Samw if (vsecp && isxvattr) 885331Samw return (TX_MKDIR_ACL_ATTR); 895331Samw if (vsecp) 905331Samw return (TX_MKDIR_ACL); 915331Samw else 925331Samw return (TX_MKDIR_ATTR); 935331Samw case Z_XATTRDIR: 945331Samw return (TX_MKXATTR); 955331Samw } 965331Samw ASSERT(0); 975331Samw return (TX_MAX_TYPE); 985331Samw } 995331Samw 100789Sahrens /* 1015331Samw * build up the log data necessary for logging xvattr_t 1025331Samw * First lr_attr_t is initialized. following the lr_attr_t 1035331Samw * is the mapsize and attribute bitmap copied from the xvattr_t. 1045331Samw * Following the bitmap and bitmapsize two 64 bit words are reserved 1055331Samw * for the create time which may be set. Following the create time 1065331Samw * records a single 64 bit integer which has the bits to set on 1075331Samw * replay for the xvattr. 1085331Samw */ 1095331Samw static void 1105331Samw zfs_log_xvattr(lr_attr_t *lrattr, xvattr_t *xvap) 1115331Samw { 1125331Samw uint32_t *bitmap; 1135331Samw uint64_t *attrs; 1145331Samw uint64_t *crtime; 1155331Samw xoptattr_t *xoap; 1165331Samw void *scanstamp; 1175331Samw int i; 1185331Samw 1195331Samw xoap = xva_getxoptattr(xvap); 1205331Samw ASSERT(xoap); 1215331Samw 1225331Samw lrattr->lr_attr_masksize = xvap->xva_mapsize; 1235331Samw bitmap = &lrattr->lr_attr_bitmap; 1245331Samw for (i = 0; i != xvap->xva_mapsize; i++, bitmap++) { 1255331Samw *bitmap = xvap->xva_reqattrmap[i]; 1265331Samw } 1275331Samw 1285331Samw /* Now pack the attributes up in a single uint64_t */ 1295331Samw attrs = (uint64_t *)bitmap; 1305331Samw crtime = attrs + 1; 1315331Samw scanstamp = (caddr_t)(crtime + 2); 1325331Samw *attrs = 0; 1335331Samw if (XVA_ISSET_REQ(xvap, XAT_READONLY)) 1345331Samw *attrs |= (xoap->xoa_readonly == 0) ? 0 : 1355331Samw XAT0_READONLY; 1365331Samw if (XVA_ISSET_REQ(xvap, XAT_HIDDEN)) 1375331Samw *attrs |= (xoap->xoa_hidden == 0) ? 0 : 1385331Samw XAT0_HIDDEN; 1395331Samw if (XVA_ISSET_REQ(xvap, XAT_SYSTEM)) 1405331Samw *attrs |= (xoap->xoa_system == 0) ? 0 : 1415331Samw XAT0_SYSTEM; 1425331Samw if (XVA_ISSET_REQ(xvap, XAT_ARCHIVE)) 1435331Samw *attrs |= (xoap->xoa_archive == 0) ? 0 : 1445331Samw XAT0_ARCHIVE; 1455331Samw if (XVA_ISSET_REQ(xvap, XAT_IMMUTABLE)) 1465331Samw *attrs |= (xoap->xoa_immutable == 0) ? 0 : 1475331Samw XAT0_IMMUTABLE; 1485331Samw if (XVA_ISSET_REQ(xvap, XAT_NOUNLINK)) 1495331Samw *attrs |= (xoap->xoa_nounlink == 0) ? 0 : 1505331Samw XAT0_NOUNLINK; 1515331Samw if (XVA_ISSET_REQ(xvap, XAT_APPENDONLY)) 1525331Samw *attrs |= (xoap->xoa_appendonly == 0) ? 0 : 1535331Samw XAT0_APPENDONLY; 1545331Samw if (XVA_ISSET_REQ(xvap, XAT_OPAQUE)) 1555331Samw *attrs |= (xoap->xoa_opaque == 0) ? 0 : 1565331Samw XAT0_APPENDONLY; 1575331Samw if (XVA_ISSET_REQ(xvap, XAT_NODUMP)) 1585331Samw *attrs |= (xoap->xoa_nodump == 0) ? 0 : 1595331Samw XAT0_NODUMP; 1605331Samw if (XVA_ISSET_REQ(xvap, XAT_AV_QUARANTINED)) 1615331Samw *attrs |= (xoap->xoa_av_quarantined == 0) ? 0 : 1625331Samw XAT0_AV_QUARANTINED; 1635331Samw if (XVA_ISSET_REQ(xvap, XAT_AV_MODIFIED)) 1645331Samw *attrs |= (xoap->xoa_av_modified == 0) ? 0 : 1655331Samw XAT0_AV_MODIFIED; 1665331Samw if (XVA_ISSET_REQ(xvap, XAT_CREATETIME)) 1675331Samw ZFS_TIME_ENCODE(&xoap->xoa_createtime, crtime); 1685331Samw if (XVA_ISSET_REQ(xvap, XAT_AV_SCANSTAMP)) 1695331Samw bcopy(xoap->xoa_av_scanstamp, scanstamp, AV_SCANSTAMP_SZ); 17010793Sdai.ngo@sun.com if (XVA_ISSET_REQ(xvap, XAT_REPARSE)) 17110793Sdai.ngo@sun.com *attrs |= (xoap->xoa_reparse == 0) ? 0 : 17210793Sdai.ngo@sun.com XAT0_REPARSE; 1735331Samw } 1745331Samw 1755331Samw static void * 1765331Samw zfs_log_fuid_ids(zfs_fuid_info_t *fuidp, void *start) 1775331Samw { 1785331Samw zfs_fuid_t *zfuid; 1795331Samw uint64_t *fuidloc = start; 1805331Samw 1815331Samw /* First copy in the ACE FUIDs */ 1825331Samw for (zfuid = list_head(&fuidp->z_fuids); zfuid; 1835331Samw zfuid = list_next(&fuidp->z_fuids, zfuid)) { 1845331Samw *fuidloc++ = zfuid->z_logfuid; 1855331Samw } 1865331Samw return (fuidloc); 1875331Samw } 1885331Samw 1895331Samw 1905331Samw static void * 1915331Samw zfs_log_fuid_domains(zfs_fuid_info_t *fuidp, void *start) 1925331Samw { 1935331Samw zfs_fuid_domain_t *zdomain; 1945331Samw 1955331Samw /* now copy in the domain info, if any */ 1965331Samw if (fuidp->z_domain_str_sz != 0) { 1975331Samw for (zdomain = list_head(&fuidp->z_domains); zdomain; 1985331Samw zdomain = list_next(&fuidp->z_domains, zdomain)) { 1995331Samw bcopy((void *)zdomain->z_domain, start, 2005331Samw strlen(zdomain->z_domain) + 1); 2015331Samw start = (caddr_t)start + 2025331Samw strlen(zdomain->z_domain) + 1; 2035331Samw } 2045331Samw } 2055331Samw return (start); 2065331Samw } 2075331Samw 2085331Samw /* 2095331Samw * zfs_log_create() is used to handle TX_CREATE, TX_CREATE_ATTR, TX_MKDIR, 2105331Samw * TX_MKDIR_ATTR and TX_MKXATTR 211789Sahrens * transactions. 2125331Samw * 2135331Samw * TX_CREATE and TX_MKDIR are standard creates, but they may have FUID 2145331Samw * domain information appended prior to the name. In this case the 2155331Samw * uid/gid in the log record will be a log centric FUID. 2165331Samw * 2175331Samw * TX_CREATE_ACL_ATTR and TX_MKDIR_ACL_ATTR handle special creates that 2185331Samw * may contain attributes, ACL and optional fuid information. 2195331Samw * 2205331Samw * TX_CREATE_ACL and TX_MKDIR_ACL handle special creates that specify 2215331Samw * and ACL and normal users/groups in the ACEs. 2225331Samw * 2235331Samw * There may be an optional xvattr attribute information similar 2245331Samw * to zfs_log_setattr. 2255331Samw * 2265331Samw * Also, after the file name "domain" strings may be appended. 227789Sahrens */ 2282638Sperrin void 2295331Samw zfs_log_create(zilog_t *zilog, dmu_tx_t *tx, uint64_t txtype, 2305331Samw znode_t *dzp, znode_t *zp, char *name, vsecattr_t *vsecp, 2315331Samw zfs_fuid_info_t *fuidp, vattr_t *vap) 232789Sahrens { 233789Sahrens itx_t *itx; 234789Sahrens uint64_t seq; 235789Sahrens lr_create_t *lr; 2365331Samw lr_acl_create_t *lracl; 2375331Samw size_t aclsize; 2385331Samw size_t xvatsize = 0; 2395331Samw size_t txsize; 2405331Samw xvattr_t *xvap = (xvattr_t *)vap; 2415331Samw void *end; 2425331Samw size_t lrsize; 243789Sahrens size_t namesize = strlen(name) + 1; 2445331Samw size_t fuidsz = 0; 245789Sahrens 246*10922SJeff.Bonwick@Sun.COM if (zil_replaying(zilog, tx)) 2472638Sperrin return; 248789Sahrens 2495331Samw /* 2505331Samw * If we have FUIDs present then add in space for 2515331Samw * domains and ACE fuid's if any. 2525331Samw */ 2535331Samw if (fuidp) { 2545331Samw fuidsz += fuidp->z_domain_str_sz; 2555331Samw fuidsz += fuidp->z_fuid_cnt * sizeof (uint64_t); 2565331Samw } 2575331Samw 2585331Samw if (vap->va_mask & AT_XVATTR) 2595331Samw xvatsize = ZIL_XVAT_SIZE(xvap->xva_mapsize); 2605331Samw 2615331Samw if ((int)txtype == TX_CREATE_ATTR || (int)txtype == TX_MKDIR_ATTR || 2625331Samw (int)txtype == TX_CREATE || (int)txtype == TX_MKDIR || 2635331Samw (int)txtype == TX_MKXATTR) { 2645331Samw txsize = sizeof (*lr) + namesize + fuidsz + xvatsize; 2655331Samw lrsize = sizeof (*lr); 2665331Samw } else { 2675331Samw aclsize = (vsecp) ? vsecp->vsa_aclentsz : 0; 2685331Samw txsize = 2695331Samw sizeof (lr_acl_create_t) + namesize + fuidsz + 2705435Smarks ZIL_ACE_LENGTH(aclsize) + xvatsize; 2715331Samw lrsize = sizeof (lr_acl_create_t); 2725331Samw } 2735331Samw 2745331Samw itx = zil_itx_create(txtype, txsize); 2755331Samw 276789Sahrens lr = (lr_create_t *)&itx->itx_lr; 277789Sahrens lr->lr_doid = dzp->z_id; 278789Sahrens lr->lr_foid = zp->z_id; 279789Sahrens lr->lr_mode = zp->z_phys->zp_mode; 2805331Samw if (!IS_EPHEMERAL(zp->z_phys->zp_uid)) { 2815331Samw lr->lr_uid = (uint64_t)zp->z_phys->zp_uid; 2825331Samw } else { 2835331Samw lr->lr_uid = fuidp->z_fuid_owner; 2845331Samw } 2855331Samw if (!IS_EPHEMERAL(zp->z_phys->zp_gid)) { 2865331Samw lr->lr_gid = (uint64_t)zp->z_phys->zp_gid; 2875331Samw } else { 2885331Samw lr->lr_gid = fuidp->z_fuid_group; 2895331Samw } 290789Sahrens lr->lr_gen = zp->z_phys->zp_gen; 291789Sahrens lr->lr_crtime[0] = zp->z_phys->zp_crtime[0]; 292789Sahrens lr->lr_crtime[1] = zp->z_phys->zp_crtime[1]; 293789Sahrens lr->lr_rdev = zp->z_phys->zp_rdev; 2945331Samw 2955331Samw /* 2965331Samw * Fill in xvattr info if any 2975331Samw */ 2985331Samw if (vap->va_mask & AT_XVATTR) { 2995331Samw zfs_log_xvattr((lr_attr_t *)((caddr_t)lr + lrsize), xvap); 3005331Samw end = (caddr_t)lr + lrsize + xvatsize; 3015331Samw } else { 3025331Samw end = (caddr_t)lr + lrsize; 3035331Samw } 3045331Samw 3055331Samw /* Now fill in any ACL info */ 3065331Samw 3075331Samw if (vsecp) { 3085331Samw lracl = (lr_acl_create_t *)&itx->itx_lr; 3095331Samw lracl->lr_aclcnt = vsecp->vsa_aclcnt; 3105331Samw lracl->lr_acl_bytes = aclsize; 3115331Samw lracl->lr_domcnt = fuidp ? fuidp->z_domain_cnt : 0; 3125331Samw lracl->lr_fuidcnt = fuidp ? fuidp->z_fuid_cnt : 0; 3135331Samw if (vsecp->vsa_aclflags & VSA_ACE_ACLFLAGS) 3145331Samw lracl->lr_acl_flags = (uint64_t)vsecp->vsa_aclflags; 3155331Samw else 3165331Samw lracl->lr_acl_flags = 0; 3175331Samw 3185331Samw bcopy(vsecp->vsa_aclentp, end, aclsize); 3195435Smarks end = (caddr_t)end + ZIL_ACE_LENGTH(aclsize); 3205331Samw } 3215331Samw 3225331Samw /* drop in FUID info */ 3235331Samw if (fuidp) { 3245331Samw end = zfs_log_fuid_ids(fuidp, end); 3255331Samw end = zfs_log_fuid_domains(fuidp, end); 3265331Samw } 3275331Samw /* 3285331Samw * Now place file name in log record 3295331Samw */ 3305331Samw bcopy(name, end, namesize); 331789Sahrens 332789Sahrens seq = zil_itx_assign(zilog, itx, tx); 333789Sahrens dzp->z_last_itx = seq; 334789Sahrens zp->z_last_itx = seq; 335789Sahrens } 336789Sahrens 337789Sahrens /* 338789Sahrens * zfs_log_remove() handles both TX_REMOVE and TX_RMDIR transactions. 339789Sahrens */ 3402638Sperrin void 3415331Samw zfs_log_remove(zilog_t *zilog, dmu_tx_t *tx, uint64_t txtype, 342789Sahrens znode_t *dzp, char *name) 343789Sahrens { 344789Sahrens itx_t *itx; 345789Sahrens uint64_t seq; 346789Sahrens lr_remove_t *lr; 347789Sahrens size_t namesize = strlen(name) + 1; 348789Sahrens 349*10922SJeff.Bonwick@Sun.COM if (zil_replaying(zilog, tx)) 3502638Sperrin return; 351789Sahrens 352789Sahrens itx = zil_itx_create(txtype, sizeof (*lr) + namesize); 353789Sahrens lr = (lr_remove_t *)&itx->itx_lr; 354789Sahrens lr->lr_doid = dzp->z_id; 355789Sahrens bcopy(name, (char *)(lr + 1), namesize); 356789Sahrens 357789Sahrens seq = zil_itx_assign(zilog, itx, tx); 358789Sahrens dzp->z_last_itx = seq; 359789Sahrens } 360789Sahrens 361789Sahrens /* 362789Sahrens * zfs_log_link() handles TX_LINK transactions. 363789Sahrens */ 3642638Sperrin void 3655331Samw zfs_log_link(zilog_t *zilog, dmu_tx_t *tx, uint64_t txtype, 366789Sahrens znode_t *dzp, znode_t *zp, char *name) 367789Sahrens { 368789Sahrens itx_t *itx; 369789Sahrens uint64_t seq; 370789Sahrens lr_link_t *lr; 371789Sahrens size_t namesize = strlen(name) + 1; 372789Sahrens 373*10922SJeff.Bonwick@Sun.COM if (zil_replaying(zilog, tx)) 3742638Sperrin return; 375789Sahrens 376789Sahrens itx = zil_itx_create(txtype, sizeof (*lr) + namesize); 377789Sahrens lr = (lr_link_t *)&itx->itx_lr; 378789Sahrens lr->lr_doid = dzp->z_id; 379789Sahrens lr->lr_link_obj = zp->z_id; 380789Sahrens bcopy(name, (char *)(lr + 1), namesize); 381789Sahrens 382789Sahrens seq = zil_itx_assign(zilog, itx, tx); 383789Sahrens dzp->z_last_itx = seq; 384789Sahrens zp->z_last_itx = seq; 385789Sahrens } 386789Sahrens 387789Sahrens /* 388789Sahrens * zfs_log_symlink() handles TX_SYMLINK transactions. 389789Sahrens */ 3902638Sperrin void 3915331Samw zfs_log_symlink(zilog_t *zilog, dmu_tx_t *tx, uint64_t txtype, 3925331Samw znode_t *dzp, znode_t *zp, char *name, char *link) 393789Sahrens { 394789Sahrens itx_t *itx; 395789Sahrens uint64_t seq; 396789Sahrens lr_create_t *lr; 397789Sahrens size_t namesize = strlen(name) + 1; 398789Sahrens size_t linksize = strlen(link) + 1; 399789Sahrens 400*10922SJeff.Bonwick@Sun.COM if (zil_replaying(zilog, tx)) 4012638Sperrin return; 402789Sahrens 403789Sahrens itx = zil_itx_create(txtype, sizeof (*lr) + namesize + linksize); 404789Sahrens lr = (lr_create_t *)&itx->itx_lr; 405789Sahrens lr->lr_doid = dzp->z_id; 406789Sahrens lr->lr_foid = zp->z_id; 407789Sahrens lr->lr_mode = zp->z_phys->zp_mode; 408789Sahrens lr->lr_uid = zp->z_phys->zp_uid; 409789Sahrens lr->lr_gid = zp->z_phys->zp_gid; 410789Sahrens lr->lr_gen = zp->z_phys->zp_gen; 411789Sahrens lr->lr_crtime[0] = zp->z_phys->zp_crtime[0]; 412789Sahrens lr->lr_crtime[1] = zp->z_phys->zp_crtime[1]; 413789Sahrens bcopy(name, (char *)(lr + 1), namesize); 414789Sahrens bcopy(link, (char *)(lr + 1) + namesize, linksize); 415789Sahrens 416789Sahrens seq = zil_itx_assign(zilog, itx, tx); 417789Sahrens dzp->z_last_itx = seq; 418789Sahrens zp->z_last_itx = seq; 419789Sahrens } 420789Sahrens 421789Sahrens /* 422789Sahrens * zfs_log_rename() handles TX_RENAME transactions. 423789Sahrens */ 4242638Sperrin void 4255331Samw zfs_log_rename(zilog_t *zilog, dmu_tx_t *tx, uint64_t txtype, 426789Sahrens znode_t *sdzp, char *sname, znode_t *tdzp, char *dname, znode_t *szp) 427789Sahrens { 428789Sahrens itx_t *itx; 429789Sahrens uint64_t seq; 430789Sahrens lr_rename_t *lr; 431789Sahrens size_t snamesize = strlen(sname) + 1; 432789Sahrens size_t dnamesize = strlen(dname) + 1; 433789Sahrens 434*10922SJeff.Bonwick@Sun.COM if (zil_replaying(zilog, tx)) 4352638Sperrin return; 436789Sahrens 437789Sahrens itx = zil_itx_create(txtype, sizeof (*lr) + snamesize + dnamesize); 438789Sahrens lr = (lr_rename_t *)&itx->itx_lr; 439789Sahrens lr->lr_sdoid = sdzp->z_id; 440789Sahrens lr->lr_tdoid = tdzp->z_id; 441789Sahrens bcopy(sname, (char *)(lr + 1), snamesize); 442789Sahrens bcopy(dname, (char *)(lr + 1) + snamesize, dnamesize); 443789Sahrens 444789Sahrens seq = zil_itx_assign(zilog, itx, tx); 445789Sahrens sdzp->z_last_itx = seq; 446789Sahrens tdzp->z_last_itx = seq; 447789Sahrens szp->z_last_itx = seq; 448789Sahrens } 449789Sahrens 450789Sahrens /* 451789Sahrens * zfs_log_write() handles TX_WRITE transactions. 452789Sahrens */ 4532237Smaybee ssize_t zfs_immediate_write_sz = 32768; 454789Sahrens 4552638Sperrin void 456789Sahrens zfs_log_write(zilog_t *zilog, dmu_tx_t *tx, int txtype, 4574620Sperrin znode_t *zp, offset_t off, ssize_t resid, int ioflag) 458789Sahrens { 4591669Sperrin itx_wr_state_t write_state; 4604620Sperrin boolean_t slogging; 4614720Sfr157268 uintptr_t fsync_cnt; 46210310SNeil.Perrin@Sun.COM ssize_t immediate_write_sz; 463789Sahrens 464*10922SJeff.Bonwick@Sun.COM if (zil_replaying(zilog, tx) || zp->z_unlinked) 4652638Sperrin return; 466789Sahrens 46710310SNeil.Perrin@Sun.COM immediate_write_sz = (zilog->zl_logbias == ZFS_LOGBIAS_THROUGHPUT) 46810310SNeil.Perrin@Sun.COM ? 0 : zfs_immediate_write_sz; 46910310SNeil.Perrin@Sun.COM 47010310SNeil.Perrin@Sun.COM slogging = spa_has_slogs(zilog->zl_spa) && 47110310SNeil.Perrin@Sun.COM (zilog->zl_logbias == ZFS_LOGBIAS_LATENCY); 47210310SNeil.Perrin@Sun.COM if (resid > immediate_write_sz && !slogging && resid <= zp->z_blksz) 4731669Sperrin write_state = WR_INDIRECT; 4746396Sperrin else if (ioflag & (FSYNC | FDSYNC)) 4751669Sperrin write_state = WR_COPIED; 4763638Sbillm else 4771669Sperrin write_state = WR_NEED_COPY; 4783638Sbillm 4794720Sfr157268 if ((fsync_cnt = (uintptr_t)tsd_get(zfs_fsyncer_key)) != 0) { 4804720Sfr157268 (void) tsd_set(zfs_fsyncer_key, (void *)(fsync_cnt - 1)); 4814720Sfr157268 } 4824720Sfr157268 4834620Sperrin while (resid) { 4844620Sperrin itx_t *itx; 4854620Sperrin lr_write_t *lr; 4864620Sperrin ssize_t len; 4874620Sperrin 4884620Sperrin /* 4897360SNeil.Perrin@Sun.COM * If the write would overflow the largest block then split it. 4904620Sperrin */ 4917360SNeil.Perrin@Sun.COM if (write_state != WR_INDIRECT && resid > ZIL_MAX_LOG_DATA) 4924620Sperrin len = SPA_MAXBLOCKSIZE >> 1; 4934620Sperrin else 4944620Sperrin len = resid; 4954620Sperrin 4964620Sperrin itx = zil_itx_create(txtype, sizeof (*lr) + 4974620Sperrin (write_state == WR_COPIED ? len : 0)); 4984620Sperrin lr = (lr_write_t *)&itx->itx_lr; 4994620Sperrin if (write_state == WR_COPIED && dmu_read(zp->z_zfsvfs->z_os, 5009512SNeil.Perrin@Sun.COM zp->z_id, off, len, lr + 1, DMU_READ_NO_PREFETCH) != 0) { 501*10922SJeff.Bonwick@Sun.COM zil_itx_destroy(itx); 5021669Sperrin itx = zil_itx_create(txtype, sizeof (*lr)); 5033638Sbillm lr = (lr_write_t *)&itx->itx_lr; 5041669Sperrin write_state = WR_NEED_COPY; 5051669Sperrin } 5064620Sperrin 5074620Sperrin itx->itx_wr_state = write_state; 5086101Sperrin if (write_state == WR_NEED_COPY) 5096101Sperrin itx->itx_sod += len; 5104620Sperrin lr->lr_foid = zp->z_id; 5114620Sperrin lr->lr_offset = off; 5124620Sperrin lr->lr_length = len; 5134620Sperrin lr->lr_blkoff = 0; 5144620Sperrin BP_ZERO(&lr->lr_blkptr); 5153638Sbillm 5164620Sperrin itx->itx_private = zp->z_zfsvfs; 517789Sahrens 5186396Sperrin if ((zp->z_sync_cnt != 0) || (fsync_cnt != 0) || 5196396Sperrin (ioflag & (FSYNC | FDSYNC))) 5204720Sfr157268 itx->itx_sync = B_TRUE; 5214720Sfr157268 else 5224720Sfr157268 itx->itx_sync = B_FALSE; 5234720Sfr157268 5244620Sperrin zp->z_last_itx = zil_itx_assign(zilog, itx, tx); 525789Sahrens 5264620Sperrin off += len; 5274620Sperrin resid -= len; 5284620Sperrin } 529789Sahrens } 530789Sahrens 531789Sahrens /* 532789Sahrens * zfs_log_truncate() handles TX_TRUNCATE transactions. 533789Sahrens */ 5342638Sperrin void 535789Sahrens zfs_log_truncate(zilog_t *zilog, dmu_tx_t *tx, int txtype, 536789Sahrens znode_t *zp, uint64_t off, uint64_t len) 537789Sahrens { 538789Sahrens itx_t *itx; 539789Sahrens uint64_t seq; 540789Sahrens lr_truncate_t *lr; 541789Sahrens 542*10922SJeff.Bonwick@Sun.COM if (zil_replaying(zilog, tx) || zp->z_unlinked) 5432638Sperrin return; 544789Sahrens 545789Sahrens itx = zil_itx_create(txtype, sizeof (*lr)); 546789Sahrens lr = (lr_truncate_t *)&itx->itx_lr; 547789Sahrens lr->lr_foid = zp->z_id; 548789Sahrens lr->lr_offset = off; 549789Sahrens lr->lr_length = len; 550789Sahrens 5513063Sperrin itx->itx_sync = (zp->z_sync_cnt != 0); 552789Sahrens seq = zil_itx_assign(zilog, itx, tx); 553789Sahrens zp->z_last_itx = seq; 554789Sahrens } 555789Sahrens 556789Sahrens /* 557789Sahrens * zfs_log_setattr() handles TX_SETATTR transactions. 558789Sahrens */ 5592638Sperrin void 560789Sahrens zfs_log_setattr(zilog_t *zilog, dmu_tx_t *tx, int txtype, 5615331Samw znode_t *zp, vattr_t *vap, uint_t mask_applied, zfs_fuid_info_t *fuidp) 562789Sahrens { 5635331Samw itx_t *itx; 5645331Samw uint64_t seq; 5655331Samw lr_setattr_t *lr; 5665331Samw xvattr_t *xvap = (xvattr_t *)vap; 5675331Samw size_t recsize = sizeof (lr_setattr_t); 5685331Samw void *start; 5695331Samw 570*10922SJeff.Bonwick@Sun.COM if (zil_replaying(zilog, tx) || zp->z_unlinked) 5712638Sperrin return; 572789Sahrens 5735331Samw /* 5745331Samw * If XVATTR set, then log record size needs to allow 5755331Samw * for lr_attr_t + xvattr mask, mapsize and create time 5765331Samw * plus actual attribute values 5775331Samw */ 5785331Samw if (vap->va_mask & AT_XVATTR) 5795331Samw recsize = sizeof (*lr) + ZIL_XVAT_SIZE(xvap->xva_mapsize); 5805331Samw 5815331Samw if (fuidp) 5825331Samw recsize += fuidp->z_domain_str_sz; 5835331Samw 5845331Samw itx = zil_itx_create(txtype, recsize); 585789Sahrens lr = (lr_setattr_t *)&itx->itx_lr; 586789Sahrens lr->lr_foid = zp->z_id; 587789Sahrens lr->lr_mask = (uint64_t)mask_applied; 588789Sahrens lr->lr_mode = (uint64_t)vap->va_mode; 5895331Samw if ((mask_applied & AT_UID) && IS_EPHEMERAL(vap->va_uid)) 5905331Samw lr->lr_uid = fuidp->z_fuid_owner; 5915331Samw else 5925331Samw lr->lr_uid = (uint64_t)vap->va_uid; 5935331Samw 5945331Samw if ((mask_applied & AT_GID) && IS_EPHEMERAL(vap->va_gid)) 5955331Samw lr->lr_gid = fuidp->z_fuid_group; 5965331Samw else 5975331Samw lr->lr_gid = (uint64_t)vap->va_gid; 5985331Samw 599789Sahrens lr->lr_size = (uint64_t)vap->va_size; 600789Sahrens ZFS_TIME_ENCODE(&vap->va_atime, lr->lr_atime); 601789Sahrens ZFS_TIME_ENCODE(&vap->va_mtime, lr->lr_mtime); 6025331Samw start = (lr_setattr_t *)(lr + 1); 6035331Samw if (vap->va_mask & AT_XVATTR) { 6045331Samw zfs_log_xvattr((lr_attr_t *)start, xvap); 6055331Samw start = (caddr_t)start + ZIL_XVAT_SIZE(xvap->xva_mapsize); 6065331Samw } 6075331Samw 6085331Samw /* 6095331Samw * Now stick on domain information if any on end 6105331Samw */ 6115331Samw 6125331Samw if (fuidp) 6135331Samw (void) zfs_log_fuid_domains(fuidp, start); 614789Sahrens 6153063Sperrin itx->itx_sync = (zp->z_sync_cnt != 0); 616789Sahrens seq = zil_itx_assign(zilog, itx, tx); 617789Sahrens zp->z_last_itx = seq; 618789Sahrens } 619789Sahrens 620789Sahrens /* 621789Sahrens * zfs_log_acl() handles TX_ACL transactions. 622789Sahrens */ 6232638Sperrin void 6245331Samw zfs_log_acl(zilog_t *zilog, dmu_tx_t *tx, znode_t *zp, 6255331Samw vsecattr_t *vsecp, zfs_fuid_info_t *fuidp) 626789Sahrens { 627789Sahrens itx_t *itx; 628789Sahrens uint64_t seq; 6295331Samw lr_acl_v0_t *lrv0; 630789Sahrens lr_acl_t *lr; 6315331Samw int txtype; 6325331Samw int lrsize; 6335331Samw size_t txsize; 6345331Samw size_t aclbytes = vsecp->vsa_aclentsz; 6355331Samw 636*10922SJeff.Bonwick@Sun.COM if (zil_replaying(zilog, tx) || zp->z_unlinked) 6376514Smarks return; 6386514Smarks 6396514Smarks txtype = (zp->z_zfsvfs->z_version < ZPL_VERSION_FUID) ? 6405331Samw TX_ACL_V0 : TX_ACL; 6415331Samw 6425331Samw if (txtype == TX_ACL) 6435331Samw lrsize = sizeof (*lr); 6445331Samw else 6455331Samw lrsize = sizeof (*lrv0); 646789Sahrens 6475435Smarks txsize = lrsize + 6485435Smarks ((txtype == TX_ACL) ? ZIL_ACE_LENGTH(aclbytes) : aclbytes) + 6495435Smarks (fuidp ? fuidp->z_domain_str_sz : 0) + 6506514Smarks sizeof (uint64_t) * (fuidp ? fuidp->z_fuid_cnt : 0); 6515331Samw 6525331Samw itx = zil_itx_create(txtype, txsize); 6535331Samw 654789Sahrens lr = (lr_acl_t *)&itx->itx_lr; 655789Sahrens lr->lr_foid = zp->z_id; 6565331Samw if (txtype == TX_ACL) { 6575331Samw lr->lr_acl_bytes = aclbytes; 6585331Samw lr->lr_domcnt = fuidp ? fuidp->z_domain_cnt : 0; 6595331Samw lr->lr_fuidcnt = fuidp ? fuidp->z_fuid_cnt : 0; 6605331Samw if (vsecp->vsa_mask & VSA_ACE_ACLFLAGS) 6615331Samw lr->lr_acl_flags = (uint64_t)vsecp->vsa_aclflags; 6625331Samw else 6635331Samw lr->lr_acl_flags = 0; 6645331Samw } 6655331Samw lr->lr_aclcnt = (uint64_t)vsecp->vsa_aclcnt; 6665331Samw 6675331Samw if (txtype == TX_ACL_V0) { 6685331Samw lrv0 = (lr_acl_v0_t *)lr; 6695331Samw bcopy(vsecp->vsa_aclentp, (ace_t *)(lrv0 + 1), aclbytes); 6705331Samw } else { 6715331Samw void *start = (ace_t *)(lr + 1); 6725331Samw 6735331Samw bcopy(vsecp->vsa_aclentp, start, aclbytes); 6745331Samw 6755435Smarks start = (caddr_t)start + ZIL_ACE_LENGTH(aclbytes); 6765331Samw 6775331Samw if (fuidp) { 6785331Samw start = zfs_log_fuid_ids(fuidp, start); 6795331Samw (void) zfs_log_fuid_domains(fuidp, start); 6805331Samw } 6815331Samw } 682789Sahrens 6833063Sperrin itx->itx_sync = (zp->z_sync_cnt != 0); 684789Sahrens seq = zil_itx_assign(zilog, itx, tx); 685789Sahrens zp->z_last_itx = seq; 686789Sahrens } 687