The Design and Implementation of the FreeBSD Operating System, Second Edition
Now available: The Design and Implementation of the FreeBSD Operating System (Second Edition)


[ source navigation ] [ diff markup ] [ identifier search ] [ freetext search ] [ file search ] [ list types ] [ track identifier ]

FreeBSD/Linux Kernel Cross Reference
sys/ufs/ffs/ffs_vnops.c

Version: -  FREEBSD  -  FREEBSD-13-STABLE  -  FREEBSD-13-0  -  FREEBSD-12-STABLE  -  FREEBSD-12-0  -  FREEBSD-11-STABLE  -  FREEBSD-11-0  -  FREEBSD-10-STABLE  -  FREEBSD-10-0  -  FREEBSD-9-STABLE  -  FREEBSD-9-0  -  FREEBSD-8-STABLE  -  FREEBSD-8-0  -  FREEBSD-7-STABLE  -  FREEBSD-7-0  -  FREEBSD-6-STABLE  -  FREEBSD-6-0  -  FREEBSD-5-STABLE  -  FREEBSD-5-0  -  FREEBSD-4-STABLE  -  FREEBSD-3-STABLE  -  FREEBSD22  -  l41  -  OPENBSD  -  linux-2.6  -  MK84  -  PLAN9  -  xnu-8792 
SearchContext: -  none  -  3  -  10 

    1 /*      $NetBSD: ffs_vnops.c,v 1.83 2006/11/16 01:33:53 christos Exp $  */
    2 
    3 /*
    4  * Copyright (c) 1982, 1986, 1989, 1993
    5  *      The Regents of the University of California.  All rights reserved.
    6  *
    7  * Redistribution and use in source and binary forms, with or without
    8  * modification, are permitted provided that the following conditions
    9  * are met:
   10  * 1. Redistributions of source code must retain the above copyright
   11  *    notice, this list of conditions and the following disclaimer.
   12  * 2. Redistributions in binary form must reproduce the above copyright
   13  *    notice, this list of conditions and the following disclaimer in the
   14  *    documentation and/or other materials provided with the distribution.
   15  * 3. Neither the name of the University nor the names of its contributors
   16  *    may be used to endorse or promote products derived from this software
   17  *    without specific prior written permission.
   18  *
   19  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
   20  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
   21  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
   22  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
   23  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
   24  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
   25  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
   26  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
   27  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
   28  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
   29  * SUCH DAMAGE.
   30  *
   31  *      @(#)ffs_vnops.c 8.15 (Berkeley) 5/14/95
   32  */
   33 
   34 #include <sys/cdefs.h>
   35 __KERNEL_RCSID(0, "$NetBSD: ffs_vnops.c,v 1.83 2006/11/16 01:33:53 christos Exp $");
   36 
   37 #include <sys/param.h>
   38 #include <sys/systm.h>
   39 #include <sys/resourcevar.h>
   40 #include <sys/kernel.h>
   41 #include <sys/file.h>
   42 #include <sys/stat.h>
   43 #include <sys/buf.h>
   44 #include <sys/event.h>
   45 #include <sys/proc.h>
   46 #include <sys/mount.h>
   47 #include <sys/vnode.h>
   48 #include <sys/pool.h>
   49 #include <sys/signalvar.h>
   50 #include <sys/kauth.h>
   51 
   52 #include <miscfs/fifofs/fifo.h>
   53 #include <miscfs/genfs/genfs.h>
   54 #include <miscfs/specfs/specdev.h>
   55 
   56 #include <ufs/ufs/inode.h>
   57 #include <ufs/ufs/dir.h>
   58 #include <ufs/ufs/ufs_extern.h>
   59 #include <ufs/ufs/ufsmount.h>
   60 
   61 #include <ufs/ffs/fs.h>
   62 #include <ufs/ffs/ffs_extern.h>
   63 
   64 #include <uvm/uvm.h>
   65 
   66 static int ffs_full_fsync(void *);
   67 
   68 /* Global vfs data structures for ufs. */
   69 int (**ffs_vnodeop_p)(void *);
   70 const struct vnodeopv_entry_desc ffs_vnodeop_entries[] = {
   71         { &vop_default_desc, vn_default_error },
   72         { &vop_lookup_desc, ufs_lookup },               /* lookup */
   73         { &vop_create_desc, ufs_create },               /* create */
   74         { &vop_whiteout_desc, ufs_whiteout },           /* whiteout */
   75         { &vop_mknod_desc, ufs_mknod },                 /* mknod */
   76         { &vop_open_desc, ufs_open },                   /* open */
   77         { &vop_close_desc, ufs_close },                 /* close */
   78         { &vop_access_desc, ufs_access },               /* access */
   79         { &vop_getattr_desc, ufs_getattr },             /* getattr */
   80         { &vop_setattr_desc, ufs_setattr },             /* setattr */
   81         { &vop_read_desc, ffs_read },                   /* read */
   82         { &vop_write_desc, ffs_write },                 /* write */
   83         { &vop_lease_desc, ufs_lease_check },           /* lease */
   84         { &vop_ioctl_desc, ufs_ioctl },                 /* ioctl */
   85         { &vop_fcntl_desc, ufs_fcntl },                 /* fcntl */
   86         { &vop_poll_desc, ufs_poll },                   /* poll */
   87         { &vop_kqfilter_desc, genfs_kqfilter },         /* kqfilter */
   88         { &vop_revoke_desc, ufs_revoke },               /* revoke */
   89         { &vop_mmap_desc, ufs_mmap },                   /* mmap */
   90         { &vop_fsync_desc, ffs_fsync },                 /* fsync */
   91         { &vop_seek_desc, ufs_seek },                   /* seek */
   92         { &vop_remove_desc, ufs_remove },               /* remove */
   93         { &vop_link_desc, ufs_link },                   /* link */
   94         { &vop_rename_desc, ufs_rename },               /* rename */
   95         { &vop_mkdir_desc, ufs_mkdir },                 /* mkdir */
   96         { &vop_rmdir_desc, ufs_rmdir },                 /* rmdir */
   97         { &vop_symlink_desc, ufs_symlink },             /* symlink */
   98         { &vop_readdir_desc, ufs_readdir },             /* readdir */
   99         { &vop_readlink_desc, ufs_readlink },           /* readlink */
  100         { &vop_abortop_desc, ufs_abortop },             /* abortop */
  101         { &vop_inactive_desc, ufs_inactive },           /* inactive */
  102         { &vop_reclaim_desc, ffs_reclaim },             /* reclaim */
  103         { &vop_lock_desc, ufs_lock },                   /* lock */
  104         { &vop_unlock_desc, ufs_unlock },               /* unlock */
  105         { &vop_bmap_desc, ufs_bmap },                   /* bmap */
  106         { &vop_strategy_desc, ufs_strategy },           /* strategy */
  107         { &vop_print_desc, ufs_print },                 /* print */
  108         { &vop_islocked_desc, ufs_islocked },           /* islocked */
  109         { &vop_pathconf_desc, ufs_pathconf },           /* pathconf */
  110         { &vop_advlock_desc, ufs_advlock },             /* advlock */
  111         { &vop_bwrite_desc, vn_bwrite },                /* bwrite */
  112         { &vop_getpages_desc, ffs_getpages },           /* getpages */
  113         { &vop_putpages_desc, genfs_putpages },         /* putpages */
  114         { &vop_openextattr_desc, ffs_openextattr },     /* openextattr */
  115         { &vop_closeextattr_desc, ffs_closeextattr },   /* closeextattr */
  116         { &vop_getextattr_desc, ffs_getextattr },       /* getextattr */
  117         { &vop_setextattr_desc, ffs_setextattr },       /* setextattr */
  118         { &vop_listextattr_desc, ffs_listextattr },     /* listextattr */
  119         { &vop_deleteextattr_desc, ffs_deleteextattr }, /* deleteextattr */
  120         { NULL, NULL }
  121 };
  122 const struct vnodeopv_desc ffs_vnodeop_opv_desc =
  123         { &ffs_vnodeop_p, ffs_vnodeop_entries };
  124 
  125 int (**ffs_specop_p)(void *);
  126 const struct vnodeopv_entry_desc ffs_specop_entries[] = {
  127         { &vop_default_desc, vn_default_error },
  128         { &vop_lookup_desc, spec_lookup },              /* lookup */
  129         { &vop_create_desc, spec_create },              /* create */
  130         { &vop_mknod_desc, spec_mknod },                /* mknod */
  131         { &vop_open_desc, spec_open },                  /* open */
  132         { &vop_close_desc, ufsspec_close },             /* close */
  133         { &vop_access_desc, ufs_access },               /* access */
  134         { &vop_getattr_desc, ufs_getattr },             /* getattr */
  135         { &vop_setattr_desc, ufs_setattr },             /* setattr */
  136         { &vop_read_desc, ufsspec_read },               /* read */
  137         { &vop_write_desc, ufsspec_write },             /* write */
  138         { &vop_lease_desc, spec_lease_check },          /* lease */
  139         { &vop_ioctl_desc, spec_ioctl },                /* ioctl */
  140         { &vop_fcntl_desc, ufs_fcntl },                 /* fcntl */
  141         { &vop_poll_desc, spec_poll },                  /* poll */
  142         { &vop_kqfilter_desc, spec_kqfilter },          /* kqfilter */
  143         { &vop_revoke_desc, spec_revoke },              /* revoke */
  144         { &vop_mmap_desc, spec_mmap },                  /* mmap */
  145         { &vop_fsync_desc, ffs_fsync },                 /* fsync */
  146         { &vop_seek_desc, spec_seek },                  /* seek */
  147         { &vop_remove_desc, spec_remove },              /* remove */
  148         { &vop_link_desc, spec_link },                  /* link */
  149         { &vop_rename_desc, spec_rename },              /* rename */
  150         { &vop_mkdir_desc, spec_mkdir },                /* mkdir */
  151         { &vop_rmdir_desc, spec_rmdir },                /* rmdir */
  152         { &vop_symlink_desc, spec_symlink },            /* symlink */
  153         { &vop_readdir_desc, spec_readdir },            /* readdir */
  154         { &vop_readlink_desc, spec_readlink },          /* readlink */
  155         { &vop_abortop_desc, spec_abortop },            /* abortop */
  156         { &vop_inactive_desc, ufs_inactive },           /* inactive */
  157         { &vop_reclaim_desc, ffs_reclaim },             /* reclaim */
  158         { &vop_lock_desc, ufs_lock },                   /* lock */
  159         { &vop_unlock_desc, ufs_unlock },               /* unlock */
  160         { &vop_bmap_desc, spec_bmap },                  /* bmap */
  161         { &vop_strategy_desc, spec_strategy },          /* strategy */
  162         { &vop_print_desc, ufs_print },                 /* print */
  163         { &vop_islocked_desc, ufs_islocked },           /* islocked */
  164         { &vop_pathconf_desc, spec_pathconf },          /* pathconf */
  165         { &vop_advlock_desc, spec_advlock },            /* advlock */
  166         { &vop_bwrite_desc, vn_bwrite },                /* bwrite */
  167         { &vop_getpages_desc, spec_getpages },          /* getpages */
  168         { &vop_putpages_desc, spec_putpages },          /* putpages */
  169         { &vop_openextattr_desc, ffs_openextattr },     /* openextattr */
  170         { &vop_closeextattr_desc, ffs_closeextattr },   /* closeextattr */
  171         { &vop_getextattr_desc, ffs_getextattr },       /* getextattr */
  172         { &vop_setextattr_desc, ffs_setextattr },       /* setextattr */
  173         { &vop_listextattr_desc, ffs_listextattr },     /* listextattr */
  174         { &vop_deleteextattr_desc, ffs_deleteextattr }, /* deleteextattr */
  175         { NULL, NULL }
  176 };
  177 const struct vnodeopv_desc ffs_specop_opv_desc =
  178         { &ffs_specop_p, ffs_specop_entries };
  179 
  180 int (**ffs_fifoop_p)(void *);
  181 const struct vnodeopv_entry_desc ffs_fifoop_entries[] = {
  182         { &vop_default_desc, vn_default_error },
  183         { &vop_lookup_desc, fifo_lookup },              /* lookup */
  184         { &vop_create_desc, fifo_create },              /* create */
  185         { &vop_mknod_desc, fifo_mknod },                /* mknod */
  186         { &vop_open_desc, fifo_open },                  /* open */
  187         { &vop_close_desc, ufsfifo_close },             /* close */
  188         { &vop_access_desc, ufs_access },               /* access */
  189         { &vop_getattr_desc, ufs_getattr },             /* getattr */
  190         { &vop_setattr_desc, ufs_setattr },             /* setattr */
  191         { &vop_read_desc, ufsfifo_read },               /* read */
  192         { &vop_write_desc, ufsfifo_write },             /* write */
  193         { &vop_lease_desc, fifo_lease_check },          /* lease */
  194         { &vop_ioctl_desc, fifo_ioctl },                /* ioctl */
  195         { &vop_fcntl_desc, ufs_fcntl },                 /* fcntl */
  196         { &vop_poll_desc, fifo_poll },                  /* poll */
  197         { &vop_kqfilter_desc, fifo_kqfilter },          /* kqfilter */
  198         { &vop_revoke_desc, fifo_revoke },              /* revoke */
  199         { &vop_mmap_desc, fifo_mmap },                  /* mmap */
  200         { &vop_fsync_desc, ffs_fsync },                 /* fsync */
  201         { &vop_seek_desc, fifo_seek },                  /* seek */
  202         { &vop_remove_desc, fifo_remove },              /* remove */
  203         { &vop_link_desc, fifo_link },                  /* link */
  204         { &vop_rename_desc, fifo_rename },              /* rename */
  205         { &vop_mkdir_desc, fifo_mkdir },                /* mkdir */
  206         { &vop_rmdir_desc, fifo_rmdir },                /* rmdir */
  207         { &vop_symlink_desc, fifo_symlink },            /* symlink */
  208         { &vop_readdir_desc, fifo_readdir },            /* readdir */
  209         { &vop_readlink_desc, fifo_readlink },          /* readlink */
  210         { &vop_abortop_desc, fifo_abortop },            /* abortop */
  211         { &vop_inactive_desc, ufs_inactive },           /* inactive */
  212         { &vop_reclaim_desc, ffs_reclaim },             /* reclaim */
  213         { &vop_lock_desc, ufs_lock },                   /* lock */
  214         { &vop_unlock_desc, ufs_unlock },               /* unlock */
  215         { &vop_bmap_desc, fifo_bmap },                  /* bmap */
  216         { &vop_strategy_desc, fifo_strategy },          /* strategy */
  217         { &vop_print_desc, ufs_print },                 /* print */
  218         { &vop_islocked_desc, ufs_islocked },           /* islocked */
  219         { &vop_pathconf_desc, fifo_pathconf },          /* pathconf */
  220         { &vop_advlock_desc, fifo_advlock },            /* advlock */
  221         { &vop_bwrite_desc, vn_bwrite },                /* bwrite */
  222         { &vop_putpages_desc, fifo_putpages },          /* putpages */
  223         { &vop_openextattr_desc, ffs_openextattr },     /* openextattr */
  224         { &vop_closeextattr_desc, ffs_closeextattr },   /* closeextattr */
  225         { &vop_getextattr_desc, ffs_getextattr },       /* getextattr */
  226         { &vop_setextattr_desc, ffs_setextattr },       /* setextattr */
  227         { &vop_listextattr_desc, ffs_listextattr },     /* listextattr */
  228         { &vop_deleteextattr_desc, ffs_deleteextattr }, /* deleteextattr */
  229         { NULL, NULL }
  230 };
  231 const struct vnodeopv_desc ffs_fifoop_opv_desc =
  232         { &ffs_fifoop_p, ffs_fifoop_entries };
  233 
  234 #include <ufs/ufs/ufs_readwrite.c>
  235 
  236 int
  237 ffs_fsync(void *v)
  238 {
  239         struct vop_fsync_args /* {
  240                 struct vnode *a_vp;
  241                 kauth_cred_t a_cred;
  242                 int a_flags;
  243                 off_t a_offlo;
  244                 off_t a_offhi;
  245                 struct lwp *a_l;
  246         } */ *ap = v;
  247         struct buf *bp;
  248         int s, num, error, i;
  249         struct indir ia[NIADDR + 1];
  250         int bsize;
  251         daddr_t blk_high;
  252         struct vnode *vp;
  253 
  254         /*
  255          * XXX no easy way to sync a range in a file with softdep.
  256          */
  257         if ((ap->a_offlo == 0 && ap->a_offhi == 0) || DOINGSOFTDEP(ap->a_vp) ||
  258                         (ap->a_vp->v_type != VREG))
  259                 return ffs_full_fsync(v);
  260 
  261         vp = ap->a_vp;
  262 
  263         bsize = ap->a_vp->v_mount->mnt_stat.f_iosize;
  264         blk_high = ap->a_offhi / bsize;
  265         if (ap->a_offhi % bsize != 0)
  266                 blk_high++;
  267 
  268         /*
  269          * First, flush all pages in range.
  270          */
  271 
  272         simple_lock(&vp->v_interlock);
  273         error = VOP_PUTPAGES(vp, trunc_page(ap->a_offlo),
  274             round_page(ap->a_offhi), PGO_CLEANIT |
  275             ((ap->a_flags & FSYNC_WAIT) ? PGO_SYNCIO : 0));
  276         if (error) {
  277                 return error;
  278         }
  279 
  280         /*
  281          * Then, flush indirect blocks.
  282          */
  283 
  284         s = splbio();
  285         if (blk_high >= NDADDR) {
  286                 error = ufs_getlbns(vp, blk_high, ia, &num);
  287                 if (error) {
  288                         splx(s);
  289                         return error;
  290                 }
  291                 for (i = 0; i < num; i++) {
  292                         bp = incore(vp, ia[i].in_lbn);
  293                         if (bp != NULL) {
  294                                 simple_lock(&bp->b_interlock);
  295                                 if (!(bp->b_flags & B_BUSY) && (bp->b_flags & B_DELWRI)) {
  296                                         bp->b_flags |= B_BUSY | B_VFLUSH;
  297                                         simple_unlock(&bp->b_interlock);
  298                                         splx(s);
  299                                         bawrite(bp);
  300                                         s = splbio();
  301                                 } else {
  302                                         simple_unlock(&bp->b_interlock);
  303                                 }
  304                         }
  305                 }
  306         }
  307 
  308         if (ap->a_flags & FSYNC_WAIT) {
  309                 simple_lock(&global_v_numoutput_slock);
  310                 while (vp->v_numoutput > 0) {
  311                         vp->v_flag |= VBWAIT;
  312                         ltsleep(&vp->v_numoutput, PRIBIO + 1, "fsync_range", 0,
  313                                 &global_v_numoutput_slock);
  314                 }
  315                 simple_unlock(&global_v_numoutput_slock);
  316         }
  317         splx(s);
  318 
  319         error = ffs_update(vp, NULL, NULL,
  320             ((ap->a_flags & (FSYNC_WAIT | FSYNC_DATAONLY)) == FSYNC_WAIT)
  321             ? UPDATE_WAIT : 0);
  322 
  323         if (error == 0 && ap->a_flags & FSYNC_CACHE) {
  324                 int l = 0;
  325                 VOP_IOCTL(VTOI(vp)->i_devvp, DIOCCACHESYNC, &l, FWRITE,
  326                         ap->a_l->l_cred, ap->a_l);
  327         }
  328 
  329         return error;
  330 }
  331 
  332 /*
  333  * Synch an open file.
  334  */
  335 /* ARGSUSED */
  336 static int
  337 ffs_full_fsync(void *v)
  338 {
  339         struct vop_fsync_args /* {
  340                 struct vnode *a_vp;
  341                 kauth_cred_t a_cred;
  342                 int a_flags;
  343                 off_t a_offlo;
  344                 off_t a_offhi;
  345                 struct lwp *a_l;
  346         } */ *ap = v;
  347         struct vnode *vp = ap->a_vp;
  348         struct buf *bp, *nbp;
  349         int s, error, passes, skipmeta, inodedeps_only, waitfor;
  350 
  351         if (vp->v_type == VBLK &&
  352             vp->v_specmountpoint != NULL &&
  353             (vp->v_specmountpoint->mnt_flag & MNT_SOFTDEP))
  354                 softdep_fsync_mountdev(vp);
  355 
  356         inodedeps_only = DOINGSOFTDEP(vp) && (ap->a_flags & FSYNC_RECLAIM)
  357             && vp->v_uobj.uo_npages == 0 && LIST_EMPTY(&vp->v_dirtyblkhd);
  358 
  359         /*
  360          * Flush all dirty data associated with a vnode.
  361          */
  362 
  363         if (vp->v_type == VREG || vp->v_type == VBLK) {
  364                 simple_lock(&vp->v_interlock);
  365                 error = VOP_PUTPAGES(vp, 0, 0, PGO_ALLPAGES | PGO_CLEANIT |
  366                     ((ap->a_flags & FSYNC_WAIT) ? PGO_SYNCIO : 0));
  367                 if (error) {
  368                         return error;
  369                 }
  370         }
  371 
  372         passes = NIADDR + 1;
  373         skipmeta = 0;
  374         if (ap->a_flags & FSYNC_WAIT)
  375                 skipmeta = 1;
  376         s = splbio();
  377 
  378 loop:
  379         LIST_FOREACH(bp, &vp->v_dirtyblkhd, b_vnbufs)
  380                 bp->b_flags &= ~B_SCANNED;
  381         for (bp = LIST_FIRST(&vp->v_dirtyblkhd); bp; bp = nbp) {
  382                 nbp = LIST_NEXT(bp, b_vnbufs);
  383                 simple_lock(&bp->b_interlock);
  384                 if (bp->b_flags & (B_BUSY | B_SCANNED)) {
  385                         simple_unlock(&bp->b_interlock);
  386                         continue;
  387                 }
  388                 if ((bp->b_flags & B_DELWRI) == 0)
  389                         panic("ffs_fsync: not dirty");
  390                 if (skipmeta && bp->b_lblkno < 0) {
  391                         simple_unlock(&bp->b_interlock);
  392                         continue;
  393                 }
  394                 simple_unlock(&bp->b_interlock);
  395                 bp->b_flags |= B_BUSY | B_VFLUSH | B_SCANNED;
  396                 splx(s);
  397                 /*
  398                  * On our final pass through, do all I/O synchronously
  399                  * so that we can find out if our flush is failing
  400                  * because of write errors.
  401                  */
  402                 if (passes > 0 || !(ap->a_flags & FSYNC_WAIT))
  403                         (void) bawrite(bp);
  404                 else if ((error = bwrite(bp)) != 0)
  405                         return (error);
  406                 s = splbio();
  407                 /*
  408                  * Since we may have slept during the I/O, we need
  409                  * to start from a known point.
  410                  */
  411                 nbp = LIST_FIRST(&vp->v_dirtyblkhd);
  412         }
  413         if (skipmeta) {
  414                 skipmeta = 0;
  415                 goto loop;
  416         }
  417         if (ap->a_flags & FSYNC_WAIT) {
  418                 simple_lock(&global_v_numoutput_slock);
  419                 while (vp->v_numoutput) {
  420                         vp->v_flag |= VBWAIT;
  421                         (void) ltsleep(&vp->v_numoutput, PRIBIO + 1,
  422                             "ffsfsync", 0, &global_v_numoutput_slock);
  423                 }
  424                 simple_unlock(&global_v_numoutput_slock);
  425                 splx(s);
  426 
  427                 /*
  428                  * Ensure that any filesystem metadata associated
  429                  * with the vnode has been written.
  430                  */
  431                 if ((error = softdep_sync_metadata(ap)) != 0)
  432                         return (error);
  433 
  434                 s = splbio();
  435                 if (!LIST_EMPTY(&vp->v_dirtyblkhd)) {
  436                         /*
  437                         * Block devices associated with filesystems may
  438                         * have new I/O requests posted for them even if
  439                         * the vnode is locked, so no amount of trying will
  440                         * get them clean. Thus we give block devices a
  441                         * good effort, then just give up. For all other file
  442                         * types, go around and try again until it is clean.
  443                         */
  444                         if (passes > 0) {
  445                                 passes--;
  446                                 goto loop;
  447                         }
  448 #ifdef DIAGNOSTIC
  449                         if (vp->v_type != VBLK)
  450                                 vprint("ffs_fsync: dirty", vp);
  451 #endif
  452                 }
  453         }
  454         splx(s);
  455 
  456         if (inodedeps_only)
  457                 waitfor = 0;
  458         else
  459                 waitfor = (ap->a_flags & FSYNC_WAIT) ? UPDATE_WAIT : 0;
  460         error = ffs_update(vp, NULL, NULL, waitfor);
  461 
  462         if (error == 0 && ap->a_flags & FSYNC_CACHE) {
  463                 int i = 0;
  464                 VOP_IOCTL(VTOI(vp)->i_devvp, DIOCCACHESYNC, &i, FWRITE,
  465                         ap->a_l->l_cred, ap->a_l);
  466         }
  467 
  468         return error;
  469 }
  470 
  471 /*
  472  * Reclaim an inode so that it can be used for other purposes.
  473  */
  474 int
  475 ffs_reclaim(void *v)
  476 {
  477         struct vop_reclaim_args /* {
  478                 struct vnode *a_vp;
  479                 struct lwp *a_l;
  480         } */ *ap = v;
  481         struct vnode *vp = ap->a_vp;
  482         struct inode *ip = VTOI(vp);
  483         struct ufsmount *ump = ip->i_ump;
  484         int error;
  485 
  486         if ((error = ufs_reclaim(vp, ap->a_l)) != 0)
  487                 return (error);
  488         if (ip->i_din.ffs1_din != NULL) {
  489                 if (ump->um_fstype == UFS1)
  490                         pool_put(&ffs_dinode1_pool, ip->i_din.ffs1_din);
  491                 else
  492                         pool_put(&ffs_dinode2_pool, ip->i_din.ffs2_din);
  493         }
  494         /*
  495          * XXX MFS ends up here, too, to free an inode.  Should we create
  496          * XXX a separate pool for MFS inodes?
  497          */
  498         pool_put(&ffs_inode_pool, vp->v_data);
  499         vp->v_data = NULL;
  500         return (0);
  501 }
  502 
  503 int
  504 ffs_getpages(void *v)
  505 {
  506         struct vop_getpages_args /* {
  507                 struct vnode *a_vp;
  508                 voff_t a_offset;
  509                 struct vm_page **a_m;
  510                 int *a_count;
  511                 int a_centeridx;
  512                 vm_prot_t a_access_type;
  513                 int a_advice;
  514                 int a_flags;
  515         } */ *ap = v;
  516         struct vnode *vp = ap->a_vp;
  517         struct inode *ip = VTOI(vp);
  518         struct fs *fs = ip->i_fs;
  519 
  520         /*
  521          * don't allow a softdep write to create pages for only part of a block.
  522          * the dependency tracking requires that all pages be in memory for
  523          * a block involved in a dependency.
  524          */
  525 
  526         if (ap->a_flags & PGO_OVERWRITE &&
  527             (blkoff(fs, ap->a_offset) != 0 ||
  528              blkoff(fs, *ap->a_count << PAGE_SHIFT) != 0) &&
  529             DOINGSOFTDEP(ap->a_vp)) {
  530                 if ((ap->a_flags & PGO_LOCKED) == 0) {
  531                         simple_unlock(&vp->v_interlock);
  532                 }
  533                 return EINVAL;
  534         }
  535         return genfs_getpages(v);
  536 }
  537 
  538 /*
  539  * Return the last logical file offset that should be written for this file
  540  * if we're doing a write that ends at "size".
  541  */
  542 
  543 void
  544 ffs_gop_size(struct vnode *vp, off_t size, off_t *eobp, int flags)
  545 {
  546         struct inode *ip = VTOI(vp);
  547         struct fs *fs = ip->i_fs;
  548         daddr_t olbn, nlbn;
  549 
  550         olbn = lblkno(fs, ip->i_size);
  551         nlbn = lblkno(fs, size);
  552         if (nlbn < NDADDR && olbn <= nlbn) {
  553                 *eobp = fragroundup(fs, size);
  554         } else {
  555                 *eobp = blkroundup(fs, size);
  556         }
  557 }
  558 
  559 int
  560 ffs_openextattr(void *v)
  561 {
  562         struct vop_openextattr_args /* {
  563                 struct vnode *a_vp;
  564                 kauth_cred_t a_cred;
  565                 struct proc *a_p;
  566         } */ *ap = v;
  567         struct inode *ip = VTOI(ap->a_vp);
  568         struct fs *fs = ip->i_fs;
  569 
  570         /* Not supported for UFS1 file systems. */
  571         if (fs->fs_magic == FS_UFS1_MAGIC)
  572                 return (EOPNOTSUPP);
  573 
  574         /* XXX Not implemented for UFS2 file systems. */
  575         return (EOPNOTSUPP);
  576 }
  577 
  578 int
  579 ffs_closeextattr(void *v)
  580 {
  581         struct vop_closeextattr_args /* {
  582                 struct vnode *a_vp;
  583                 int a_commit;
  584                 kauth_cred_t a_cred;
  585                 struct proc *a_p;
  586         } */ *ap = v;
  587         struct inode *ip = VTOI(ap->a_vp);
  588         struct fs *fs = ip->i_fs;
  589 
  590         /* Not supported for UFS1 file systems. */
  591         if (fs->fs_magic == FS_UFS1_MAGIC)
  592                 return (EOPNOTSUPP);
  593 
  594         /* XXX Not implemented for UFS2 file systems. */
  595         return (EOPNOTSUPP);
  596 }
  597 
  598 int
  599 ffs_getextattr(void *v)
  600 {
  601         struct vop_getextattr_args /* {
  602                 struct vnode *a_vp;
  603                 int a_attrnamespace;
  604                 const char *a_name;
  605                 struct uio *a_uio;
  606                 size_t *a_size;
  607                 kauth_cred_t a_cred;
  608                 struct proc *a_p;
  609         } */ *ap = v;
  610         struct inode *ip = VTOI(ap->a_vp);
  611         struct fs *fs = ip->i_fs;
  612 
  613         if (fs->fs_magic == FS_UFS1_MAGIC) {
  614 #ifdef UFS_EXTATTR
  615                 return (ufs_getextattr(ap));
  616 #else
  617                 return (EOPNOTSUPP);
  618 #endif
  619         }
  620 
  621         /* XXX Not implemented for UFS2 file systems. */
  622         return (EOPNOTSUPP);
  623 }
  624 
  625 int
  626 ffs_setextattr(void *v)
  627 {
  628         struct vop_setextattr_args /* {
  629                 struct vnode *a_vp;
  630                 int a_attrnamespace;
  631                 const char *a_name;
  632                 struct uio *a_uio;
  633                 kauth_cred_t a_cred;
  634                 struct proc *a_p;
  635         } */ *ap = v;
  636         struct inode *ip = VTOI(ap->a_vp);
  637         struct fs *fs = ip->i_fs;
  638 
  639         if (fs->fs_magic == FS_UFS1_MAGIC) {
  640 #ifdef UFS_EXTATTR
  641                 return (ufs_setextattr(ap));
  642 #else
  643                 return (EOPNOTSUPP);
  644 #endif
  645         }
  646 
  647         /* XXX Not implemented for UFS2 file systems. */
  648         return (EOPNOTSUPP);
  649 }
  650 
  651 int
  652 ffs_listextattr(void *v)
  653 {
  654         struct vop_listextattr_args /* {
  655                 struct vnode *a_vp;
  656                 int a_attrnamespace;
  657                 struct uio *a_uio;
  658                 size_t *a_size;
  659                 kauth_cred_t a_cred;
  660                 struct proc *a_p;
  661         } */ *ap = v;
  662         struct inode *ip = VTOI(ap->a_vp);
  663         struct fs *fs = ip->i_fs;
  664 
  665         /* Not supported for UFS1 file systems. */
  666         if (fs->fs_magic == FS_UFS1_MAGIC)
  667                 return (EOPNOTSUPP);
  668 
  669         /* XXX Not implemented for UFS2 file systems. */
  670         return (EOPNOTSUPP);
  671 }
  672 
  673 int
  674 ffs_deleteextattr(void *v)
  675 {
  676         struct vop_deleteextattr_args /* {
  677                 struct vnode *a_vp;
  678                 int a_attrnamespace;
  679                 kauth_cred_t a_cred;
  680                 struct proc *a_p;
  681         } */ *ap = v;
  682         struct inode *ip = VTOI(ap->a_vp);
  683         struct fs *fs = ip->i_fs;
  684 
  685         if (fs->fs_magic == FS_UFS1_MAGIC) {
  686 #ifdef UFS_EXTATTR
  687                 return (ufs_deleteextattr(ap));
  688 #else
  689                 return (EOPNOTSUPP);
  690 #endif
  691         }
  692 
  693         /* XXX Not implemented for UFS2 file systems. */
  694         return (EOPNOTSUPP);
  695 }

Cache object: 006d0295358456222c7cd46b3b5c5078


[ source navigation ] [ diff markup ] [ identifier search ] [ freetext search ] [ file search ] [ list types ] [ track identifier ]


This page is part of the FreeBSD/Linux Linux Kernel Cross-Reference, and was automatically generated using a modified version of the LXR engine.