ulfs_quota1.c revision 1.5.2.4
1 1.5.2.2 tls /* $NetBSD: ulfs_quota1.c,v 1.5.2.4 2017/12/03 11:39:22 jdolecek Exp $ */ 2 1.5.2.4 jdolecek /* from NetBSD: ufs_quota1.c,v 1.22 2016/06/20 00:52:04 dholland Exp */ 3 1.5.2.2 tls 4 1.5.2.2 tls /* 5 1.5.2.2 tls * Copyright (c) 1982, 1986, 1990, 1993, 1995 6 1.5.2.2 tls * The Regents of the University of California. All rights reserved. 7 1.5.2.2 tls * 8 1.5.2.2 tls * This code is derived from software contributed to Berkeley by 9 1.5.2.2 tls * Robert Elz at The University of Melbourne. 10 1.5.2.2 tls * 11 1.5.2.2 tls * Redistribution and use in source and binary forms, with or without 12 1.5.2.2 tls * modification, are permitted provided that the following conditions 13 1.5.2.2 tls * are met: 14 1.5.2.2 tls * 1. Redistributions of source code must retain the above copyright 15 1.5.2.2 tls * notice, this list of conditions and the following disclaimer. 16 1.5.2.2 tls * 2. Redistributions in binary form must reproduce the above copyright 17 1.5.2.2 tls * notice, this list of conditions and the following disclaimer in the 18 1.5.2.2 tls * documentation and/or other materials provided with the distribution. 19 1.5.2.2 tls * 3. Neither the name of the University nor the names of its contributors 20 1.5.2.2 tls * may be used to endorse or promote products derived from this software 21 1.5.2.2 tls * without specific prior written permission. 22 1.5.2.2 tls * 23 1.5.2.2 tls * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 24 1.5.2.2 tls * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 25 1.5.2.2 tls * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 26 1.5.2.2 tls * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 27 1.5.2.2 tls * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 28 1.5.2.2 tls * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 29 1.5.2.2 tls * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 30 1.5.2.2 tls * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 31 1.5.2.2 tls * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 32 1.5.2.2 tls * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 33 1.5.2.2 tls * SUCH DAMAGE. 34 1.5.2.2 tls * 35 1.5.2.2 tls * @(#)ufs_quota.c 8.5 (Berkeley) 5/20/95 36 1.5.2.2 tls */ 37 1.5.2.2 tls 38 1.5.2.2 tls #include <sys/cdefs.h> 39 1.5.2.2 tls __KERNEL_RCSID(0, "$NetBSD: ulfs_quota1.c,v 1.5.2.4 2017/12/03 11:39:22 jdolecek Exp $"); 40 1.5.2.2 tls 41 1.5.2.2 tls #include <sys/param.h> 42 1.5.2.2 tls #include <sys/kernel.h> 43 1.5.2.2 tls #include <sys/systm.h> 44 1.5.2.2 tls #include <sys/namei.h> 45 1.5.2.2 tls #include <sys/file.h> 46 1.5.2.2 tls #include <sys/proc.h> 47 1.5.2.2 tls #include <sys/vnode.h> 48 1.5.2.2 tls #include <sys/mount.h> 49 1.5.2.2 tls #include <sys/kauth.h> 50 1.5.2.2 tls 51 1.5.2.2 tls #include <ufs/lfs/ulfs_quota1.h> 52 1.5.2.2 tls #include <ufs/lfs/ulfs_inode.h> 53 1.5.2.2 tls #include <ufs/lfs/ulfsmount.h> 54 1.5.2.2 tls #include <ufs/lfs/ulfs_extern.h> 55 1.5.2.2 tls #include <ufs/lfs/ulfs_quota.h> 56 1.5.2.2 tls 57 1.5.2.2 tls static int chkdqchg(struct inode *, int64_t, kauth_cred_t, int); 58 1.5.2.2 tls static int chkiqchg(struct inode *, int32_t, kauth_cred_t, int); 59 1.5.2.2 tls 60 1.5.2.2 tls /* 61 1.5.2.2 tls * Update disk usage, and take corrective action. 62 1.5.2.2 tls */ 63 1.5.2.2 tls int 64 1.5.2.2 tls lfs_chkdq1(struct inode *ip, int64_t change, kauth_cred_t cred, int flags) 65 1.5.2.2 tls { 66 1.5.2.2 tls struct dquot *dq; 67 1.5.2.2 tls int i; 68 1.5.2.2 tls int ncurblocks, error; 69 1.5.2.2 tls 70 1.5.2.2 tls if ((error = lfs_getinoquota(ip)) != 0) 71 1.5.2.2 tls return error; 72 1.5.2.2 tls if (change == 0) 73 1.5.2.2 tls return (0); 74 1.5.2.2 tls if (change < 0) { 75 1.5.2.2 tls for (i = 0; i < ULFS_MAXQUOTAS; i++) { 76 1.5.2.2 tls if ((dq = ip->i_dquot[i]) == NODQUOT) 77 1.5.2.2 tls continue; 78 1.5.2.2 tls mutex_enter(&dq->dq_interlock); 79 1.5.2.2 tls ncurblocks = dq->dq_curblocks + change; 80 1.5.2.2 tls if (ncurblocks >= 0) 81 1.5.2.2 tls dq->dq_curblocks = ncurblocks; 82 1.5.2.2 tls else 83 1.5.2.2 tls dq->dq_curblocks = 0; 84 1.5.2.2 tls dq->dq_flags &= ~DQ_WARN(QL_BLOCK); 85 1.5.2.2 tls dq->dq_flags |= DQ_MOD; 86 1.5.2.2 tls mutex_exit(&dq->dq_interlock); 87 1.5.2.2 tls } 88 1.5.2.2 tls return (0); 89 1.5.2.2 tls } 90 1.5.2.2 tls for (i = 0; i < ULFS_MAXQUOTAS; i++) { 91 1.5.2.2 tls if ((dq = ip->i_dquot[i]) == NODQUOT) 92 1.5.2.2 tls continue; 93 1.5.2.2 tls if ((flags & FORCE) == 0 && 94 1.5.2.2 tls kauth_authorize_system(cred, KAUTH_SYSTEM_FS_QUOTA, 95 1.5.2.2 tls KAUTH_REQ_SYSTEM_FS_QUOTA_NOLIMIT, KAUTH_ARG(i), 96 1.5.2.2 tls KAUTH_ARG(QL_BLOCK), NULL) != 0) { 97 1.5.2.2 tls mutex_enter(&dq->dq_interlock); 98 1.5.2.2 tls error = chkdqchg(ip, change, cred, i); 99 1.5.2.2 tls mutex_exit(&dq->dq_interlock); 100 1.5.2.2 tls if (error != 0) 101 1.5.2.2 tls return (error); 102 1.5.2.2 tls } 103 1.5.2.2 tls } 104 1.5.2.2 tls for (i = 0; i < ULFS_MAXQUOTAS; i++) { 105 1.5.2.2 tls if ((dq = ip->i_dquot[i]) == NODQUOT) 106 1.5.2.2 tls continue; 107 1.5.2.2 tls mutex_enter(&dq->dq_interlock); 108 1.5.2.2 tls dq->dq_curblocks += change; 109 1.5.2.2 tls dq->dq_flags |= DQ_MOD; 110 1.5.2.2 tls mutex_exit(&dq->dq_interlock); 111 1.5.2.2 tls } 112 1.5.2.2 tls return (0); 113 1.5.2.2 tls } 114 1.5.2.2 tls 115 1.5.2.2 tls /* 116 1.5.2.2 tls * Check for a valid change to a users allocation. 117 1.5.2.2 tls * Issue an error message if appropriate. 118 1.5.2.2 tls */ 119 1.5.2.2 tls static int 120 1.5.2.2 tls chkdqchg(struct inode *ip, int64_t change, kauth_cred_t cred, int type) 121 1.5.2.2 tls { 122 1.5.2.2 tls struct dquot *dq = ip->i_dquot[type]; 123 1.5.2.2 tls long ncurblocks = dq->dq_curblocks + change; 124 1.5.2.2 tls 125 1.5.2.2 tls KASSERT(mutex_owned(&dq->dq_interlock)); 126 1.5.2.2 tls /* 127 1.5.2.2 tls * If user would exceed their hard limit, disallow space allocation. 128 1.5.2.2 tls */ 129 1.5.2.2 tls if (ncurblocks >= dq->dq_bhardlimit && dq->dq_bhardlimit) { 130 1.5.2.2 tls if ((dq->dq_flags & DQ_WARN(QL_BLOCK)) == 0 && 131 1.5.2.2 tls ip->i_uid == kauth_cred_geteuid(cred)) { 132 1.5.2.2 tls uprintf("\n%s: write failed, %s disk limit reached\n", 133 1.5.2.2 tls ITOV(ip)->v_mount->mnt_stat.f_mntonname, 134 1.5.2.2 tls lfs_quotatypes[type]); 135 1.5.2.2 tls dq->dq_flags |= DQ_WARN(QL_BLOCK); 136 1.5.2.2 tls } 137 1.5.2.2 tls return (EDQUOT); 138 1.5.2.2 tls } 139 1.5.2.2 tls /* 140 1.5.2.2 tls * If user is over their soft limit for too long, disallow space 141 1.5.2.2 tls * allocation. Reset time limit as they cross their soft limit. 142 1.5.2.2 tls */ 143 1.5.2.2 tls if (ncurblocks >= dq->dq_bsoftlimit && dq->dq_bsoftlimit) { 144 1.5.2.2 tls if (dq->dq_curblocks < dq->dq_bsoftlimit) { 145 1.5.2.2 tls dq->dq_btime = 146 1.5.2.2 tls time_second + ip->i_ump->umq1_btime[type]; 147 1.5.2.2 tls if (ip->i_uid == kauth_cred_geteuid(cred)) 148 1.5.2.2 tls uprintf("\n%s: warning, %s %s\n", 149 1.5.2.2 tls ITOV(ip)->v_mount->mnt_stat.f_mntonname, 150 1.5.2.2 tls lfs_quotatypes[type], "disk quota exceeded"); 151 1.5.2.2 tls return (0); 152 1.5.2.2 tls } 153 1.5.2.2 tls if (time_second > dq->dq_btime) { 154 1.5.2.2 tls if ((dq->dq_flags & DQ_WARN(QL_BLOCK)) == 0 && 155 1.5.2.2 tls ip->i_uid == kauth_cred_geteuid(cred)) { 156 1.5.2.2 tls uprintf("\n%s: write failed, %s %s\n", 157 1.5.2.2 tls ITOV(ip)->v_mount->mnt_stat.f_mntonname, 158 1.5.2.2 tls lfs_quotatypes[type], 159 1.5.2.2 tls "disk quota exceeded for too long"); 160 1.5.2.2 tls dq->dq_flags |= DQ_WARN(QL_BLOCK); 161 1.5.2.2 tls } 162 1.5.2.2 tls return (EDQUOT); 163 1.5.2.2 tls } 164 1.5.2.2 tls } 165 1.5.2.2 tls return (0); 166 1.5.2.2 tls } 167 1.5.2.2 tls 168 1.5.2.2 tls /* 169 1.5.2.2 tls * Check the inode limit, applying corrective action. 170 1.5.2.2 tls */ 171 1.5.2.2 tls int 172 1.5.2.2 tls lfs_chkiq1(struct inode *ip, int32_t change, kauth_cred_t cred, int flags) 173 1.5.2.2 tls { 174 1.5.2.2 tls struct dquot *dq; 175 1.5.2.2 tls int i; 176 1.5.2.2 tls int ncurinodes, error; 177 1.5.2.2 tls 178 1.5.2.2 tls if ((error = lfs_getinoquota(ip)) != 0) 179 1.5.2.2 tls return error; 180 1.5.2.2 tls if (change == 0) 181 1.5.2.2 tls return (0); 182 1.5.2.2 tls if (change < 0) { 183 1.5.2.2 tls for (i = 0; i < ULFS_MAXQUOTAS; i++) { 184 1.5.2.2 tls if ((dq = ip->i_dquot[i]) == NODQUOT) 185 1.5.2.2 tls continue; 186 1.5.2.2 tls mutex_enter(&dq->dq_interlock); 187 1.5.2.2 tls ncurinodes = dq->dq_curinodes + change; 188 1.5.2.2 tls if (ncurinodes >= 0) 189 1.5.2.2 tls dq->dq_curinodes = ncurinodes; 190 1.5.2.2 tls else 191 1.5.2.2 tls dq->dq_curinodes = 0; 192 1.5.2.2 tls dq->dq_flags &= ~DQ_WARN(QL_FILE); 193 1.5.2.2 tls dq->dq_flags |= DQ_MOD; 194 1.5.2.2 tls mutex_exit(&dq->dq_interlock); 195 1.5.2.2 tls } 196 1.5.2.2 tls return (0); 197 1.5.2.2 tls } 198 1.5.2.2 tls for (i = 0; i < ULFS_MAXQUOTAS; i++) { 199 1.5.2.2 tls if ((dq = ip->i_dquot[i]) == NODQUOT) 200 1.5.2.2 tls continue; 201 1.5.2.2 tls if ((flags & FORCE) == 0 && kauth_authorize_system(cred, 202 1.5.2.2 tls KAUTH_SYSTEM_FS_QUOTA, KAUTH_REQ_SYSTEM_FS_QUOTA_NOLIMIT, 203 1.5.2.2 tls KAUTH_ARG(i), KAUTH_ARG(QL_FILE), NULL) != 0) { 204 1.5.2.2 tls mutex_enter(&dq->dq_interlock); 205 1.5.2.2 tls error = chkiqchg(ip, change, cred, i); 206 1.5.2.2 tls mutex_exit(&dq->dq_interlock); 207 1.5.2.2 tls if (error != 0) 208 1.5.2.2 tls return (error); 209 1.5.2.2 tls } 210 1.5.2.2 tls } 211 1.5.2.2 tls for (i = 0; i < ULFS_MAXQUOTAS; i++) { 212 1.5.2.2 tls if ((dq = ip->i_dquot[i]) == NODQUOT) 213 1.5.2.2 tls continue; 214 1.5.2.2 tls mutex_enter(&dq->dq_interlock); 215 1.5.2.2 tls dq->dq_curinodes += change; 216 1.5.2.2 tls dq->dq_flags |= DQ_MOD; 217 1.5.2.2 tls mutex_exit(&dq->dq_interlock); 218 1.5.2.2 tls } 219 1.5.2.2 tls return (0); 220 1.5.2.2 tls } 221 1.5.2.2 tls 222 1.5.2.2 tls /* 223 1.5.2.2 tls * Check for a valid change to a users allocation. 224 1.5.2.2 tls * Issue an error message if appropriate. 225 1.5.2.2 tls */ 226 1.5.2.2 tls static int 227 1.5.2.2 tls chkiqchg(struct inode *ip, int32_t change, kauth_cred_t cred, int type) 228 1.5.2.2 tls { 229 1.5.2.2 tls struct dquot *dq = ip->i_dquot[type]; 230 1.5.2.2 tls long ncurinodes = dq->dq_curinodes + change; 231 1.5.2.2 tls 232 1.5.2.2 tls KASSERT(mutex_owned(&dq->dq_interlock)); 233 1.5.2.2 tls /* 234 1.5.2.2 tls * If user would exceed their hard limit, disallow inode allocation. 235 1.5.2.2 tls */ 236 1.5.2.2 tls if (ncurinodes >= dq->dq_ihardlimit && dq->dq_ihardlimit) { 237 1.5.2.2 tls if ((dq->dq_flags & DQ_WARN(QL_FILE)) == 0 && 238 1.5.2.2 tls ip->i_uid == kauth_cred_geteuid(cred)) { 239 1.5.2.2 tls uprintf("\n%s: write failed, %s inode limit reached\n", 240 1.5.2.2 tls ITOV(ip)->v_mount->mnt_stat.f_mntonname, 241 1.5.2.2 tls lfs_quotatypes[type]); 242 1.5.2.2 tls dq->dq_flags |= DQ_WARN(QL_FILE); 243 1.5.2.2 tls } 244 1.5.2.2 tls return (EDQUOT); 245 1.5.2.2 tls } 246 1.5.2.2 tls /* 247 1.5.2.2 tls * If user is over their soft limit for too long, disallow inode 248 1.5.2.2 tls * allocation. Reset time limit as they cross their soft limit. 249 1.5.2.2 tls */ 250 1.5.2.2 tls if (ncurinodes >= dq->dq_isoftlimit && dq->dq_isoftlimit) { 251 1.5.2.2 tls if (dq->dq_curinodes < dq->dq_isoftlimit) { 252 1.5.2.2 tls dq->dq_itime = 253 1.5.2.2 tls time_second + ip->i_ump->umq1_itime[type]; 254 1.5.2.2 tls if (ip->i_uid == kauth_cred_geteuid(cred)) 255 1.5.2.2 tls uprintf("\n%s: warning, %s %s\n", 256 1.5.2.2 tls ITOV(ip)->v_mount->mnt_stat.f_mntonname, 257 1.5.2.2 tls lfs_quotatypes[type], "inode quota exceeded"); 258 1.5.2.2 tls return (0); 259 1.5.2.2 tls } 260 1.5.2.2 tls if (time_second > dq->dq_itime) { 261 1.5.2.2 tls if ((dq->dq_flags & DQ_WARN(QL_FILE)) == 0 && 262 1.5.2.2 tls ip->i_uid == kauth_cred_geteuid(cred)) { 263 1.5.2.2 tls uprintf("\n%s: write failed, %s %s\n", 264 1.5.2.2 tls ITOV(ip)->v_mount->mnt_stat.f_mntonname, 265 1.5.2.2 tls lfs_quotatypes[type], 266 1.5.2.2 tls "inode quota exceeded for too long"); 267 1.5.2.2 tls dq->dq_flags |= DQ_WARN(QL_FILE); 268 1.5.2.2 tls } 269 1.5.2.2 tls return (EDQUOT); 270 1.5.2.2 tls } 271 1.5.2.2 tls } 272 1.5.2.2 tls return (0); 273 1.5.2.2 tls } 274 1.5.2.2 tls 275 1.5.2.2 tls int 276 1.5.2.2 tls lfsquota1_umount(struct mount *mp, int flags) 277 1.5.2.2 tls { 278 1.5.2.2 tls int i, error; 279 1.5.2.2 tls struct ulfsmount *ump = VFSTOULFS(mp); 280 1.5.2.3 tls struct lfs *fs = ump->um_lfs; 281 1.5.2.2 tls struct lwp *l = curlwp; 282 1.5.2.2 tls 283 1.5.2.3 tls if ((fs->um_flags & ULFS_QUOTA) == 0) 284 1.5.2.2 tls return 0; 285 1.5.2.2 tls 286 1.5.2.2 tls if ((error = vflush(mp, NULLVP, SKIPSYSTEM | flags)) != 0) 287 1.5.2.2 tls return (error); 288 1.5.2.2 tls 289 1.5.2.2 tls for (i = 0; i < ULFS_MAXQUOTAS; i++) { 290 1.5.2.2 tls if (ump->um_quotas[i] != NULLVP) { 291 1.5.2.2 tls lfsquota1_handle_cmd_quotaoff(l, ump, i); 292 1.5.2.2 tls } 293 1.5.2.2 tls } 294 1.5.2.2 tls return 0; 295 1.5.2.2 tls } 296 1.5.2.2 tls 297 1.5.2.2 tls /* 298 1.5.2.2 tls * Code to process quotactl commands. 299 1.5.2.2 tls */ 300 1.5.2.2 tls 301 1.5.2.2 tls /* 302 1.5.2.2 tls * set up a quota file for a particular file system. 303 1.5.2.2 tls */ 304 1.5.2.2 tls int 305 1.5.2.2 tls lfsquota1_handle_cmd_quotaon(struct lwp *l, struct ulfsmount *ump, int type, 306 1.5.2.2 tls const char *fname) 307 1.5.2.2 tls { 308 1.5.2.2 tls struct mount *mp = ump->um_mountp; 309 1.5.2.3 tls struct lfs *fs = ump->um_lfs; 310 1.5.2.3 tls struct vnode *vp, **vpp; 311 1.5.2.3 tls struct vnode_iterator *marker; 312 1.5.2.2 tls struct dquot *dq; 313 1.5.2.2 tls int error; 314 1.5.2.2 tls struct pathbuf *pb; 315 1.5.2.2 tls struct nameidata nd; 316 1.5.2.2 tls 317 1.5.2.3 tls if (fs->um_flags & ULFS_QUOTA2) { 318 1.5.2.2 tls uprintf("%s: quotas v2 already enabled\n", 319 1.5.2.2 tls mp->mnt_stat.f_mntonname); 320 1.5.2.2 tls return (EBUSY); 321 1.5.2.2 tls } 322 1.5.2.2 tls 323 1.5.2.2 tls vpp = &ump->um_quotas[type]; 324 1.5.2.2 tls 325 1.5.2.2 tls pb = pathbuf_create(fname); 326 1.5.2.2 tls if (pb == NULL) { 327 1.5.2.2 tls return ENOMEM; 328 1.5.2.2 tls } 329 1.5.2.2 tls NDINIT(&nd, LOOKUP, FOLLOW, pb); 330 1.5.2.2 tls if ((error = vn_open(&nd, FREAD|FWRITE, 0)) != 0) { 331 1.5.2.2 tls pathbuf_destroy(pb); 332 1.5.2.2 tls return error; 333 1.5.2.2 tls } 334 1.5.2.2 tls vp = nd.ni_vp; 335 1.5.2.2 tls pathbuf_destroy(pb); 336 1.5.2.2 tls 337 1.5.2.2 tls VOP_UNLOCK(vp); 338 1.5.2.2 tls if (vp->v_type != VREG) { 339 1.5.2.2 tls (void) vn_close(vp, FREAD|FWRITE, l->l_cred); 340 1.5.2.2 tls return (EACCES); 341 1.5.2.2 tls } 342 1.5.2.2 tls if (*vpp != vp) 343 1.5.2.2 tls lfsquota1_handle_cmd_quotaoff(l, ump, type); 344 1.5.2.2 tls mutex_enter(&lfs_dqlock); 345 1.5.2.2 tls while ((ump->umq1_qflags[type] & (QTF_CLOSING | QTF_OPENING)) != 0) 346 1.5.2.2 tls cv_wait(&lfs_dqcv, &lfs_dqlock); 347 1.5.2.2 tls ump->umq1_qflags[type] |= QTF_OPENING; 348 1.5.2.2 tls mutex_exit(&lfs_dqlock); 349 1.5.2.2 tls mp->mnt_flag |= MNT_QUOTA; 350 1.5.2.2 tls vp->v_vflag |= VV_SYSTEM; /* XXXSMP */ 351 1.5.2.2 tls *vpp = vp; 352 1.5.2.2 tls /* 353 1.5.2.2 tls * Save the credential of the process that turned on quotas. 354 1.5.2.2 tls * Set up the time limits for this quota. 355 1.5.2.2 tls */ 356 1.5.2.2 tls kauth_cred_hold(l->l_cred); 357 1.5.2.2 tls ump->um_cred[type] = l->l_cred; 358 1.5.2.2 tls ump->umq1_btime[type] = MAX_DQ_TIME; 359 1.5.2.2 tls ump->umq1_itime[type] = MAX_IQ_TIME; 360 1.5.2.2 tls if (lfs_dqget(NULLVP, 0, ump, type, &dq) == 0) { 361 1.5.2.2 tls if (dq->dq_btime > 0) 362 1.5.2.2 tls ump->umq1_btime[type] = dq->dq_btime; 363 1.5.2.2 tls if (dq->dq_itime > 0) 364 1.5.2.2 tls ump->umq1_itime[type] = dq->dq_itime; 365 1.5.2.2 tls lfs_dqrele(NULLVP, dq); 366 1.5.2.2 tls } 367 1.5.2.2 tls /* 368 1.5.2.2 tls * Search vnodes associated with this mount point, 369 1.5.2.2 tls * adding references to quota file being opened. 370 1.5.2.2 tls * NB: only need to add dquot's for inodes being modified. 371 1.5.2.2 tls */ 372 1.5.2.3 tls vfs_vnode_iterator_init(mp, &marker); 373 1.5.2.3 tls while ((vp = vfs_vnode_iterator_next(marker, NULL, NULL))) { 374 1.5.2.3 tls error = vn_lock(vp, LK_EXCLUSIVE); 375 1.5.2.3 tls if (error) { 376 1.5.2.3 tls vrele(vp); 377 1.5.2.3 tls continue; 378 1.5.2.3 tls } 379 1.5.2.2 tls mutex_enter(vp->v_interlock); 380 1.5.2.3 tls if (VTOI(vp) == NULL || vp->v_type == VNON || 381 1.5.2.3 tls vp->v_writecount == 0) { 382 1.5.2.2 tls mutex_exit(vp->v_interlock); 383 1.5.2.3 tls vput(vp); 384 1.5.2.2 tls continue; 385 1.5.2.2 tls } 386 1.5.2.3 tls mutex_exit(vp->v_interlock); 387 1.5.2.2 tls if ((error = lfs_getinoquota(VTOI(vp))) != 0) { 388 1.5.2.2 tls vput(vp); 389 1.5.2.2 tls break; 390 1.5.2.2 tls } 391 1.5.2.2 tls vput(vp); 392 1.5.2.2 tls } 393 1.5.2.3 tls vfs_vnode_iterator_destroy(marker); 394 1.5.2.2 tls 395 1.5.2.2 tls mutex_enter(&lfs_dqlock); 396 1.5.2.2 tls ump->umq1_qflags[type] &= ~QTF_OPENING; 397 1.5.2.2 tls cv_broadcast(&lfs_dqcv); 398 1.5.2.2 tls if (error == 0) 399 1.5.2.3 tls fs->um_flags |= ULFS_QUOTA; 400 1.5.2.2 tls mutex_exit(&lfs_dqlock); 401 1.5.2.2 tls if (error) 402 1.5.2.2 tls lfsquota1_handle_cmd_quotaoff(l, ump, type); 403 1.5.2.2 tls return (error); 404 1.5.2.2 tls } 405 1.5.2.2 tls 406 1.5.2.2 tls /* 407 1.5.2.2 tls * turn off disk quotas for a filesystem. 408 1.5.2.2 tls */ 409 1.5.2.2 tls int 410 1.5.2.2 tls lfsquota1_handle_cmd_quotaoff(struct lwp *l, struct ulfsmount *ump, int type) 411 1.5.2.2 tls { 412 1.5.2.2 tls struct mount *mp = ump->um_mountp; 413 1.5.2.3 tls struct lfs *fs = ump->um_lfs; 414 1.5.2.2 tls struct vnode *vp; 415 1.5.2.3 tls struct vnode *qvp; 416 1.5.2.3 tls struct vnode_iterator *marker; 417 1.5.2.2 tls struct dquot *dq; 418 1.5.2.2 tls struct inode *ip; 419 1.5.2.2 tls kauth_cred_t cred; 420 1.5.2.2 tls int i, error; 421 1.5.2.2 tls 422 1.5.2.2 tls mutex_enter(&lfs_dqlock); 423 1.5.2.2 tls while ((ump->umq1_qflags[type] & (QTF_CLOSING | QTF_OPENING)) != 0) 424 1.5.2.2 tls cv_wait(&lfs_dqcv, &lfs_dqlock); 425 1.5.2.2 tls if ((qvp = ump->um_quotas[type]) == NULLVP) { 426 1.5.2.2 tls mutex_exit(&lfs_dqlock); 427 1.5.2.2 tls return (0); 428 1.5.2.2 tls } 429 1.5.2.2 tls ump->umq1_qflags[type] |= QTF_CLOSING; 430 1.5.2.3 tls fs->um_flags &= ~ULFS_QUOTA; 431 1.5.2.2 tls mutex_exit(&lfs_dqlock); 432 1.5.2.2 tls /* 433 1.5.2.2 tls * Search vnodes associated with this mount point, 434 1.5.2.2 tls * deleting any references to quota file being closed. 435 1.5.2.2 tls */ 436 1.5.2.3 tls vfs_vnode_iterator_init(mp, &marker); 437 1.5.2.3 tls while ((vp = vfs_vnode_iterator_next(marker, NULL, NULL))) { 438 1.5.2.3 tls error = vn_lock(vp, LK_EXCLUSIVE); 439 1.5.2.3 tls if (error) { 440 1.5.2.3 tls vrele(vp); 441 1.5.2.2 tls continue; 442 1.5.2.2 tls } 443 1.5.2.2 tls ip = VTOI(vp); 444 1.5.2.3 tls if (ip == NULL || vp->v_type == VNON) { 445 1.5.2.3 tls vput(vp); 446 1.5.2.3 tls continue; 447 1.5.2.3 tls } 448 1.5.2.2 tls dq = ip->i_dquot[type]; 449 1.5.2.2 tls ip->i_dquot[type] = NODQUOT; 450 1.5.2.2 tls lfs_dqrele(vp, dq); 451 1.5.2.2 tls vput(vp); 452 1.5.2.2 tls } 453 1.5.2.3 tls vfs_vnode_iterator_destroy(marker); 454 1.5.2.2 tls #ifdef DIAGNOSTIC 455 1.5.2.2 tls lfs_dqflush(qvp); 456 1.5.2.2 tls #endif 457 1.5.2.2 tls qvp->v_vflag &= ~VV_SYSTEM; 458 1.5.2.2 tls error = vn_close(qvp, FREAD|FWRITE, l->l_cred); 459 1.5.2.2 tls mutex_enter(&lfs_dqlock); 460 1.5.2.2 tls ump->um_quotas[type] = NULLVP; 461 1.5.2.2 tls cred = ump->um_cred[type]; 462 1.5.2.2 tls ump->um_cred[type] = NOCRED; 463 1.5.2.2 tls for (i = 0; i < ULFS_MAXQUOTAS; i++) 464 1.5.2.2 tls if (ump->um_quotas[i] != NULLVP) 465 1.5.2.2 tls break; 466 1.5.2.2 tls ump->umq1_qflags[type] &= ~QTF_CLOSING; 467 1.5.2.2 tls cv_broadcast(&lfs_dqcv); 468 1.5.2.2 tls mutex_exit(&lfs_dqlock); 469 1.5.2.2 tls kauth_cred_free(cred); 470 1.5.2.2 tls if (i == ULFS_MAXQUOTAS) 471 1.5.2.2 tls mp->mnt_flag &= ~MNT_QUOTA; 472 1.5.2.2 tls return (error); 473 1.5.2.2 tls } 474 1.5.2.2 tls 475 1.5.2.2 tls int 476 1.5.2.2 tls lfsquota1_handle_cmd_get(struct ulfsmount *ump, const struct quotakey *qk, 477 1.5.2.2 tls struct quotaval *qv) 478 1.5.2.2 tls { 479 1.5.2.2 tls struct dquot *dq; 480 1.5.2.2 tls int error; 481 1.5.2.2 tls struct quotaval blocks, files; 482 1.5.2.2 tls int idtype; 483 1.5.2.2 tls id_t id; 484 1.5.2.2 tls 485 1.5.2.2 tls idtype = qk->qk_idtype; 486 1.5.2.2 tls id = qk->qk_id; 487 1.5.2.2 tls 488 1.5.2.2 tls if (ump->um_quotas[idtype] == NULLVP) 489 1.5.2.2 tls return ENODEV; 490 1.5.2.2 tls 491 1.5.2.2 tls if (id == QUOTA_DEFAULTID) { /* we want the grace period of id 0 */ 492 1.5.2.2 tls if ((error = lfs_dqget(NULLVP, 0, ump, idtype, &dq)) != 0) 493 1.5.2.2 tls return error; 494 1.5.2.2 tls 495 1.5.2.2 tls } else { 496 1.5.2.2 tls if ((error = lfs_dqget(NULLVP, id, ump, idtype, &dq)) != 0) 497 1.5.2.2 tls return error; 498 1.5.2.2 tls } 499 1.5.2.2 tls lfs_dqblk_to_quotavals(&dq->dq_un.dq1_dqb, &blocks, &files); 500 1.5.2.2 tls lfs_dqrele(NULLVP, dq); 501 1.5.2.2 tls if (id == QUOTA_DEFAULTID) { 502 1.5.2.2 tls if (blocks.qv_expiretime > 0) 503 1.5.2.2 tls blocks.qv_grace = blocks.qv_expiretime; 504 1.5.2.2 tls else 505 1.5.2.2 tls blocks.qv_grace = MAX_DQ_TIME; 506 1.5.2.2 tls if (files.qv_expiretime > 0) 507 1.5.2.2 tls files.qv_grace = files.qv_expiretime; 508 1.5.2.2 tls else 509 1.5.2.2 tls files.qv_grace = MAX_DQ_TIME; 510 1.5.2.2 tls } 511 1.5.2.2 tls 512 1.5.2.2 tls switch (qk->qk_objtype) { 513 1.5.2.2 tls case QUOTA_OBJTYPE_BLOCKS: 514 1.5.2.2 tls *qv = blocks; 515 1.5.2.2 tls break; 516 1.5.2.2 tls case QUOTA_OBJTYPE_FILES: 517 1.5.2.2 tls *qv = files; 518 1.5.2.2 tls break; 519 1.5.2.2 tls default: 520 1.5.2.2 tls return EINVAL; 521 1.5.2.2 tls } 522 1.5.2.2 tls 523 1.5.2.2 tls return 0; 524 1.5.2.2 tls } 525 1.5.2.2 tls 526 1.5.2.2 tls static uint32_t 527 1.5.2.2 tls quota1_encode_limit(uint64_t lim) 528 1.5.2.2 tls { 529 1.5.2.2 tls if (lim == QUOTA_NOLIMIT || lim >= 0xffffffff) { 530 1.5.2.2 tls return 0; 531 1.5.2.2 tls } 532 1.5.2.2 tls return lim; 533 1.5.2.2 tls } 534 1.5.2.2 tls 535 1.5.2.2 tls int 536 1.5.2.2 tls lfsquota1_handle_cmd_put(struct ulfsmount *ump, const struct quotakey *key, 537 1.5.2.2 tls const struct quotaval *val) 538 1.5.2.2 tls { 539 1.5.2.2 tls struct dquot *dq; 540 1.5.2.2 tls struct dqblk dqb; 541 1.5.2.2 tls int error; 542 1.5.2.2 tls 543 1.5.2.2 tls switch (key->qk_idtype) { 544 1.5.2.2 tls case QUOTA_IDTYPE_USER: 545 1.5.2.2 tls case QUOTA_IDTYPE_GROUP: 546 1.5.2.2 tls break; 547 1.5.2.2 tls default: 548 1.5.2.2 tls return EINVAL; 549 1.5.2.2 tls } 550 1.5.2.2 tls 551 1.5.2.2 tls switch (key->qk_objtype) { 552 1.5.2.2 tls case QUOTA_OBJTYPE_BLOCKS: 553 1.5.2.2 tls case QUOTA_OBJTYPE_FILES: 554 1.5.2.2 tls break; 555 1.5.2.2 tls default: 556 1.5.2.2 tls return EINVAL; 557 1.5.2.2 tls } 558 1.5.2.2 tls 559 1.5.2.2 tls if (ump->um_quotas[key->qk_idtype] == NULLVP) 560 1.5.2.2 tls return ENODEV; 561 1.5.2.2 tls 562 1.5.2.2 tls if (key->qk_id == QUOTA_DEFAULTID) { 563 1.5.2.2 tls /* just update grace times */ 564 1.5.2.2 tls id_t id = 0; 565 1.5.2.2 tls 566 1.5.2.2 tls if ((error = lfs_dqget(NULLVP, id, ump, key->qk_idtype, &dq)) != 0) 567 1.5.2.2 tls return error; 568 1.5.2.2 tls mutex_enter(&dq->dq_interlock); 569 1.5.2.2 tls if (val->qv_grace != QUOTA_NOTIME) { 570 1.5.2.2 tls if (key->qk_objtype == QUOTA_OBJTYPE_BLOCKS) 571 1.5.2.2 tls ump->umq1_btime[key->qk_idtype] = dq->dq_btime = 572 1.5.2.2 tls val->qv_grace; 573 1.5.2.2 tls if (key->qk_objtype == QUOTA_OBJTYPE_FILES) 574 1.5.2.2 tls ump->umq1_itime[key->qk_idtype] = dq->dq_itime = 575 1.5.2.2 tls val->qv_grace; 576 1.5.2.2 tls } 577 1.5.2.2 tls dq->dq_flags |= DQ_MOD; 578 1.5.2.2 tls mutex_exit(&dq->dq_interlock); 579 1.5.2.2 tls lfs_dqrele(NULLVP, dq); 580 1.5.2.2 tls return 0; 581 1.5.2.2 tls } 582 1.5.2.2 tls 583 1.5.2.2 tls if ((error = lfs_dqget(NULLVP, key->qk_id, ump, key->qk_idtype, &dq)) != 0) 584 1.5.2.2 tls return (error); 585 1.5.2.2 tls mutex_enter(&dq->dq_interlock); 586 1.5.2.2 tls /* 587 1.5.2.2 tls * Copy all but the current values. 588 1.5.2.2 tls * Reset time limit if previously had no soft limit or were 589 1.5.2.2 tls * under it, but now have a soft limit and are over it. 590 1.5.2.2 tls */ 591 1.5.2.2 tls dqb.dqb_curblocks = dq->dq_curblocks; 592 1.5.2.2 tls dqb.dqb_curinodes = dq->dq_curinodes; 593 1.5.2.2 tls dqb.dqb_btime = dq->dq_btime; 594 1.5.2.2 tls dqb.dqb_itime = dq->dq_itime; 595 1.5.2.2 tls if (key->qk_objtype == QUOTA_OBJTYPE_BLOCKS) { 596 1.5.2.2 tls dqb.dqb_bsoftlimit = quota1_encode_limit(val->qv_softlimit); 597 1.5.2.2 tls dqb.dqb_bhardlimit = quota1_encode_limit(val->qv_hardlimit); 598 1.5.2.2 tls dqb.dqb_isoftlimit = dq->dq_isoftlimit; 599 1.5.2.2 tls dqb.dqb_ihardlimit = dq->dq_ihardlimit; 600 1.5.2.2 tls } else { 601 1.5.2.2 tls KASSERT(key->qk_objtype == QUOTA_OBJTYPE_FILES); 602 1.5.2.2 tls dqb.dqb_bsoftlimit = dq->dq_bsoftlimit; 603 1.5.2.2 tls dqb.dqb_bhardlimit = dq->dq_bhardlimit; 604 1.5.2.2 tls dqb.dqb_isoftlimit = quota1_encode_limit(val->qv_softlimit); 605 1.5.2.2 tls dqb.dqb_ihardlimit = quota1_encode_limit(val->qv_hardlimit); 606 1.5.2.2 tls } 607 1.5.2.2 tls if (dq->dq_id == 0 && val->qv_grace != QUOTA_NOTIME) { 608 1.5.2.2 tls /* also update grace time if available */ 609 1.5.2.2 tls if (key->qk_objtype == QUOTA_OBJTYPE_BLOCKS) { 610 1.5.2.2 tls ump->umq1_btime[key->qk_idtype] = dqb.dqb_btime = 611 1.5.2.2 tls val->qv_grace; 612 1.5.2.2 tls } 613 1.5.2.2 tls if (key->qk_objtype == QUOTA_OBJTYPE_FILES) { 614 1.5.2.2 tls ump->umq1_itime[key->qk_idtype] = dqb.dqb_itime = 615 1.5.2.2 tls val->qv_grace; 616 1.5.2.2 tls } 617 1.5.2.2 tls } 618 1.5.2.2 tls if (dqb.dqb_bsoftlimit && 619 1.5.2.2 tls dq->dq_curblocks >= dqb.dqb_bsoftlimit && 620 1.5.2.2 tls (dq->dq_bsoftlimit == 0 || dq->dq_curblocks < dq->dq_bsoftlimit)) 621 1.5.2.2 tls dqb.dqb_btime = time_second + ump->umq1_btime[key->qk_idtype]; 622 1.5.2.2 tls if (dqb.dqb_isoftlimit && 623 1.5.2.2 tls dq->dq_curinodes >= dqb.dqb_isoftlimit && 624 1.5.2.2 tls (dq->dq_isoftlimit == 0 || dq->dq_curinodes < dq->dq_isoftlimit)) 625 1.5.2.2 tls dqb.dqb_itime = time_second + ump->umq1_itime[key->qk_idtype]; 626 1.5.2.2 tls dq->dq_un.dq1_dqb = dqb; 627 1.5.2.2 tls if (dq->dq_curblocks < dq->dq_bsoftlimit) 628 1.5.2.2 tls dq->dq_flags &= ~DQ_WARN(QL_BLOCK); 629 1.5.2.2 tls if (dq->dq_curinodes < dq->dq_isoftlimit) 630 1.5.2.2 tls dq->dq_flags &= ~DQ_WARN(QL_FILE); 631 1.5.2.2 tls if (dq->dq_isoftlimit == 0 && dq->dq_bsoftlimit == 0 && 632 1.5.2.2 tls dq->dq_ihardlimit == 0 && dq->dq_bhardlimit == 0) 633 1.5.2.2 tls dq->dq_flags |= DQ_FAKE; 634 1.5.2.2 tls else 635 1.5.2.2 tls dq->dq_flags &= ~DQ_FAKE; 636 1.5.2.2 tls dq->dq_flags |= DQ_MOD; 637 1.5.2.2 tls mutex_exit(&dq->dq_interlock); 638 1.5.2.2 tls lfs_dqrele(NULLVP, dq); 639 1.5.2.2 tls return (0); 640 1.5.2.2 tls } 641 1.5.2.2 tls 642 1.5.2.2 tls 643 1.5.2.2 tls #if 0 644 1.5.2.2 tls /* 645 1.5.2.2 tls * Q_SETQUOTA - assign an entire dqblk structure. 646 1.5.2.2 tls */ 647 1.5.2.2 tls int 648 1.5.2.2 tls setquota1(struct mount *mp, u_long id, int type, struct dqblk *dqb) 649 1.5.2.2 tls { 650 1.5.2.2 tls struct dquot *dq; 651 1.5.2.2 tls struct dquot *ndq; 652 1.5.2.2 tls struct ulfsmount *ump = VFSTOULFS(mp); 653 1.5.2.2 tls 654 1.5.2.2 tls 655 1.5.2.2 tls if ((error = lfs_dqget(NULLVP, id, ump, type, &ndq)) != 0) 656 1.5.2.2 tls return (error); 657 1.5.2.2 tls dq = ndq; 658 1.5.2.2 tls mutex_enter(&dq->dq_interlock); 659 1.5.2.2 tls /* 660 1.5.2.2 tls * Copy all but the current values. 661 1.5.2.2 tls * Reset time limit if previously had no soft limit or were 662 1.5.2.2 tls * under it, but now have a soft limit and are over it. 663 1.5.2.2 tls */ 664 1.5.2.2 tls dqb->dqb_curblocks = dq->dq_curblocks; 665 1.5.2.2 tls dqb->dqb_curinodes = dq->dq_curinodes; 666 1.5.2.2 tls if (dq->dq_id != 0) { 667 1.5.2.2 tls dqb->dqb_btime = dq->dq_btime; 668 1.5.2.2 tls dqb->dqb_itime = dq->dq_itime; 669 1.5.2.2 tls } 670 1.5.2.2 tls if (dqb->dqb_bsoftlimit && 671 1.5.2.2 tls dq->dq_curblocks >= dqb->dqb_bsoftlimit && 672 1.5.2.2 tls (dq->dq_bsoftlimit == 0 || dq->dq_curblocks < dq->dq_bsoftlimit)) 673 1.5.2.2 tls dqb->dqb_btime = time_second + ump->umq1_btime[type]; 674 1.5.2.2 tls if (dqb->dqb_isoftlimit && 675 1.5.2.2 tls dq->dq_curinodes >= dqb->dqb_isoftlimit && 676 1.5.2.2 tls (dq->dq_isoftlimit == 0 || dq->dq_curinodes < dq->dq_isoftlimit)) 677 1.5.2.2 tls dqb->dqb_itime = time_second + ump->umq1_itime[type]; 678 1.5.2.2 tls dq->dq_un.dq1_dqb = *dqb; 679 1.5.2.2 tls if (dq->dq_curblocks < dq->dq_bsoftlimit) 680 1.5.2.2 tls dq->dq_flags &= ~DQ_WARN(QL_BLOCK); 681 1.5.2.2 tls if (dq->dq_curinodes < dq->dq_isoftlimit) 682 1.5.2.2 tls dq->dq_flags &= ~DQ_WARN(QL_FILE); 683 1.5.2.2 tls if (dq->dq_isoftlimit == 0 && dq->dq_bsoftlimit == 0 && 684 1.5.2.2 tls dq->dq_ihardlimit == 0 && dq->dq_bhardlimit == 0) 685 1.5.2.2 tls dq->dq_flags |= DQ_FAKE; 686 1.5.2.2 tls else 687 1.5.2.2 tls dq->dq_flags &= ~DQ_FAKE; 688 1.5.2.2 tls dq->dq_flags |= DQ_MOD; 689 1.5.2.2 tls mutex_exit(&dq->dq_interlock); 690 1.5.2.2 tls lfs_dqrele(NULLVP, dq); 691 1.5.2.2 tls return (0); 692 1.5.2.2 tls } 693 1.5.2.2 tls 694 1.5.2.2 tls /* 695 1.5.2.2 tls * Q_SETUSE - set current inode and block usage. 696 1.5.2.2 tls */ 697 1.5.2.2 tls int 698 1.5.2.2 tls setuse(struct mount *mp, u_long id, int type, void *addr) 699 1.5.2.2 tls { 700 1.5.2.2 tls struct dquot *dq; 701 1.5.2.2 tls struct ulfsmount *ump = VFSTOULFS(mp); 702 1.5.2.2 tls struct dquot *ndq; 703 1.5.2.2 tls struct dqblk usage; 704 1.5.2.2 tls int error; 705 1.5.2.2 tls 706 1.5.2.2 tls error = copyin(addr, (void *)&usage, sizeof (struct dqblk)); 707 1.5.2.2 tls if (error) 708 1.5.2.2 tls return (error); 709 1.5.2.2 tls if ((error = lfs_dqget(NULLVP, id, ump, type, &ndq)) != 0) 710 1.5.2.2 tls return (error); 711 1.5.2.2 tls dq = ndq; 712 1.5.2.2 tls mutex_enter(&dq->dq_interlock); 713 1.5.2.2 tls /* 714 1.5.2.2 tls * Reset time limit if have a soft limit and were 715 1.5.2.2 tls * previously under it, but are now over it. 716 1.5.2.2 tls */ 717 1.5.2.2 tls if (dq->dq_bsoftlimit && dq->dq_curblocks < dq->dq_bsoftlimit && 718 1.5.2.2 tls usage.dqb_curblocks >= dq->dq_bsoftlimit) 719 1.5.2.2 tls dq->dq_btime = time_second + ump->umq1_btime[type]; 720 1.5.2.2 tls if (dq->dq_isoftlimit && dq->dq_curinodes < dq->dq_isoftlimit && 721 1.5.2.2 tls usage.dqb_curinodes >= dq->dq_isoftlimit) 722 1.5.2.2 tls dq->dq_itime = time_second + ump->umq1_itime[type]; 723 1.5.2.2 tls dq->dq_curblocks = usage.dqb_curblocks; 724 1.5.2.2 tls dq->dq_curinodes = usage.dqb_curinodes; 725 1.5.2.2 tls if (dq->dq_curblocks < dq->dq_bsoftlimit) 726 1.5.2.2 tls dq->dq_flags &= ~DQ_WARN(QL_BLOCK); 727 1.5.2.2 tls if (dq->dq_curinodes < dq->dq_isoftlimit) 728 1.5.2.2 tls dq->dq_flags &= ~DQ_WARN(QL_FILE); 729 1.5.2.2 tls dq->dq_flags |= DQ_MOD; 730 1.5.2.2 tls mutex_exit(&dq->dq_interlock); 731 1.5.2.2 tls lfs_dqrele(NULLVP, dq); 732 1.5.2.2 tls return (0); 733 1.5.2.2 tls } 734 1.5.2.2 tls #endif 735 1.5.2.2 tls 736 1.5.2.2 tls /* 737 1.5.2.2 tls * Q_SYNC - sync quota files to disk. 738 1.5.2.2 tls */ 739 1.5.2.2 tls int 740 1.5.2.2 tls lfs_q1sync(struct mount *mp) 741 1.5.2.2 tls { 742 1.5.2.2 tls struct ulfsmount *ump = VFSTOULFS(mp); 743 1.5.2.3 tls struct vnode *vp; 744 1.5.2.3 tls struct vnode_iterator *marker; 745 1.5.2.2 tls struct dquot *dq; 746 1.5.2.2 tls int i, error; 747 1.5.2.2 tls 748 1.5.2.2 tls /* 749 1.5.2.2 tls * Check if the mount point has any quotas. 750 1.5.2.2 tls * If not, simply return. 751 1.5.2.2 tls */ 752 1.5.2.2 tls for (i = 0; i < ULFS_MAXQUOTAS; i++) 753 1.5.2.2 tls if (ump->um_quotas[i] != NULLVP) 754 1.5.2.2 tls break; 755 1.5.2.2 tls if (i == ULFS_MAXQUOTAS) 756 1.5.2.2 tls return (0); 757 1.5.2.2 tls 758 1.5.2.2 tls /* 759 1.5.2.2 tls * Search vnodes associated with this mount point, 760 1.5.2.2 tls * synchronizing any modified dquot structures. 761 1.5.2.2 tls */ 762 1.5.2.3 tls vfs_vnode_iterator_init(mp, &marker); 763 1.5.2.3 tls while ((vp = vfs_vnode_iterator_next(marker, NULL, NULL))) { 764 1.5.2.3 tls error = vn_lock(vp, LK_EXCLUSIVE); 765 1.5.2.3 tls if (error) { 766 1.5.2.3 tls vrele(vp); 767 1.5.2.2 tls continue; 768 1.5.2.2 tls } 769 1.5.2.3 tls if (VTOI(vp) == NULL || vp->v_type == VNON) { 770 1.5.2.3 tls vput(vp); 771 1.5.2.2 tls continue; 772 1.5.2.2 tls } 773 1.5.2.2 tls for (i = 0; i < ULFS_MAXQUOTAS; i++) { 774 1.5.2.2 tls dq = VTOI(vp)->i_dquot[i]; 775 1.5.2.2 tls if (dq == NODQUOT) 776 1.5.2.2 tls continue; 777 1.5.2.2 tls mutex_enter(&dq->dq_interlock); 778 1.5.2.2 tls if (dq->dq_flags & DQ_MOD) 779 1.5.2.2 tls lfs_dq1sync(vp, dq); 780 1.5.2.2 tls mutex_exit(&dq->dq_interlock); 781 1.5.2.2 tls } 782 1.5.2.2 tls vput(vp); 783 1.5.2.2 tls } 784 1.5.2.3 tls vfs_vnode_iterator_destroy(marker); 785 1.5.2.2 tls return (0); 786 1.5.2.2 tls } 787 1.5.2.2 tls 788 1.5.2.2 tls /* 789 1.5.2.2 tls * Obtain a dquot structure for the specified identifier and quota file 790 1.5.2.2 tls * reading the information from the file if necessary. 791 1.5.2.2 tls */ 792 1.5.2.2 tls int 793 1.5.2.2 tls lfs_dq1get(struct vnode *dqvp, u_long id, struct ulfsmount *ump, int type, 794 1.5.2.2 tls struct dquot *dq) 795 1.5.2.2 tls { 796 1.5.2.2 tls struct iovec aiov; 797 1.5.2.2 tls struct uio auio; 798 1.5.2.2 tls int error; 799 1.5.2.2 tls 800 1.5.2.2 tls KASSERT(mutex_owned(&dq->dq_interlock)); 801 1.5.2.2 tls vn_lock(dqvp, LK_EXCLUSIVE | LK_RETRY); 802 1.5.2.2 tls auio.uio_iov = &aiov; 803 1.5.2.2 tls auio.uio_iovcnt = 1; 804 1.5.2.2 tls aiov.iov_base = (void *)&dq->dq_un.dq1_dqb; 805 1.5.2.2 tls aiov.iov_len = sizeof (struct dqblk); 806 1.5.2.2 tls auio.uio_resid = sizeof (struct dqblk); 807 1.5.2.4 jdolecek auio.uio_offset = (off_t)id * sizeof (struct dqblk); 808 1.5.2.2 tls auio.uio_rw = UIO_READ; 809 1.5.2.2 tls UIO_SETUP_SYSSPACE(&auio); 810 1.5.2.2 tls error = VOP_READ(dqvp, &auio, 0, ump->um_cred[type]); 811 1.5.2.2 tls if (auio.uio_resid == sizeof(struct dqblk) && error == 0) 812 1.5.2.2 tls memset((void *)&dq->dq_un.dq1_dqb, 0, sizeof(struct dqblk)); 813 1.5.2.2 tls VOP_UNLOCK(dqvp); 814 1.5.2.2 tls /* 815 1.5.2.2 tls * I/O error in reading quota file, release 816 1.5.2.2 tls * quota structure and reflect problem to caller. 817 1.5.2.2 tls */ 818 1.5.2.2 tls if (error) 819 1.5.2.2 tls return (error); 820 1.5.2.2 tls /* 821 1.5.2.2 tls * Check for no limit to enforce. 822 1.5.2.2 tls * Initialize time values if necessary. 823 1.5.2.2 tls */ 824 1.5.2.2 tls if (dq->dq_isoftlimit == 0 && dq->dq_bsoftlimit == 0 && 825 1.5.2.2 tls dq->dq_ihardlimit == 0 && dq->dq_bhardlimit == 0) 826 1.5.2.2 tls dq->dq_flags |= DQ_FAKE; 827 1.5.2.2 tls if (dq->dq_id != 0) { 828 1.5.2.2 tls if (dq->dq_btime == 0) 829 1.5.2.2 tls dq->dq_btime = time_second + ump->umq1_btime[type]; 830 1.5.2.2 tls if (dq->dq_itime == 0) 831 1.5.2.2 tls dq->dq_itime = time_second + ump->umq1_itime[type]; 832 1.5.2.2 tls } 833 1.5.2.2 tls return (0); 834 1.5.2.2 tls } 835 1.5.2.2 tls 836 1.5.2.2 tls /* 837 1.5.2.2 tls * Update the disk quota in the quota file. 838 1.5.2.2 tls */ 839 1.5.2.2 tls int 840 1.5.2.2 tls lfs_dq1sync(struct vnode *vp, struct dquot *dq) 841 1.5.2.2 tls { 842 1.5.2.2 tls struct vnode *dqvp; 843 1.5.2.2 tls struct iovec aiov; 844 1.5.2.2 tls struct uio auio; 845 1.5.2.2 tls int error; 846 1.5.2.2 tls 847 1.5.2.2 tls if (dq == NODQUOT) 848 1.5.2.2 tls panic("dq1sync: dquot"); 849 1.5.2.2 tls KASSERT(mutex_owned(&dq->dq_interlock)); 850 1.5.2.2 tls if ((dq->dq_flags & DQ_MOD) == 0) 851 1.5.2.2 tls return (0); 852 1.5.2.2 tls if ((dqvp = dq->dq_ump->um_quotas[dq->dq_type]) == NULLVP) 853 1.5.2.2 tls panic("dq1sync: file"); 854 1.5.2.2 tls KASSERT(dqvp != vp); 855 1.5.2.2 tls vn_lock(dqvp, LK_EXCLUSIVE | LK_RETRY); 856 1.5.2.2 tls auio.uio_iov = &aiov; 857 1.5.2.2 tls auio.uio_iovcnt = 1; 858 1.5.2.2 tls aiov.iov_base = (void *)&dq->dq_un.dq1_dqb; 859 1.5.2.2 tls aiov.iov_len = sizeof (struct dqblk); 860 1.5.2.2 tls auio.uio_resid = sizeof (struct dqblk); 861 1.5.2.4 jdolecek auio.uio_offset = (off_t)dq->dq_id * sizeof (struct dqblk); 862 1.5.2.2 tls auio.uio_rw = UIO_WRITE; 863 1.5.2.2 tls UIO_SETUP_SYSSPACE(&auio); 864 1.5.2.2 tls error = VOP_WRITE(dqvp, &auio, 0, dq->dq_ump->um_cred[dq->dq_type]); 865 1.5.2.2 tls if (auio.uio_resid && error == 0) 866 1.5.2.2 tls error = EIO; 867 1.5.2.2 tls dq->dq_flags &= ~DQ_MOD; 868 1.5.2.2 tls VOP_UNLOCK(dqvp); 869 1.5.2.2 tls return (error); 870 1.5.2.2 tls } 871
Indexes created Thu Oct 23 22:10:10 GMT 2025