ufs_quota.c revision 1.78
1 1.78 dholland /* $NetBSD: ufs_quota.c,v 1.78 2012/01/29 06:41:41 dholland Exp $ */ 2 1.2 cgd 3 1.1 mycroft /* 4 1.11 fvdl * Copyright (c) 1982, 1986, 1990, 1993, 1995 5 1.1 mycroft * The Regents of the University of California. All rights reserved. 6 1.1 mycroft * 7 1.1 mycroft * This code is derived from software contributed to Berkeley by 8 1.1 mycroft * Robert Elz at The University of Melbourne. 9 1.1 mycroft * 10 1.1 mycroft * Redistribution and use in source and binary forms, with or without 11 1.1 mycroft * modification, are permitted provided that the following conditions 12 1.1 mycroft * are met: 13 1.1 mycroft * 1. Redistributions of source code must retain the above copyright 14 1.1 mycroft * notice, this list of conditions and the following disclaimer. 15 1.1 mycroft * 2. Redistributions in binary form must reproduce the above copyright 16 1.1 mycroft * notice, this list of conditions and the following disclaimer in the 17 1.1 mycroft * documentation and/or other materials provided with the distribution. 18 1.28 agc * 3. Neither the name of the University nor the names of its contributors 19 1.1 mycroft * may be used to endorse or promote products derived from this software 20 1.1 mycroft * without specific prior written permission. 21 1.1 mycroft * 22 1.1 mycroft * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 23 1.1 mycroft * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 24 1.1 mycroft * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 25 1.1 mycroft * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 26 1.1 mycroft * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 27 1.1 mycroft * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 28 1.1 mycroft * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 29 1.1 mycroft * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 30 1.1 mycroft * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 31 1.1 mycroft * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 32 1.1 mycroft * SUCH DAMAGE. 33 1.1 mycroft * 34 1.11 fvdl * @(#)ufs_quota.c 8.5 (Berkeley) 5/20/95 35 1.1 mycroft */ 36 1.22 lukem 37 1.22 lukem #include <sys/cdefs.h> 38 1.78 dholland __KERNEL_RCSID(0, "$NetBSD: ufs_quota.c,v 1.78 2012/01/29 06:41:41 dholland Exp $"); 39 1.22 lukem 40 1.69 bouyer #if defined(_KERNEL_OPT) 41 1.69 bouyer #include "opt_quota.h" 42 1.69 bouyer #endif 43 1.1 mycroft #include <sys/param.h> 44 1.1 mycroft #include <sys/kernel.h> 45 1.1 mycroft #include <sys/systm.h> 46 1.1 mycroft #include <sys/namei.h> 47 1.1 mycroft #include <sys/file.h> 48 1.1 mycroft #include <sys/proc.h> 49 1.1 mycroft #include <sys/vnode.h> 50 1.1 mycroft #include <sys/mount.h> 51 1.39 elad #include <sys/kauth.h> 52 1.1 mycroft 53 1.71 dholland #include <sys/quotactl.h> 54 1.1 mycroft #include <ufs/ufs/quota.h> 55 1.1 mycroft #include <ufs/ufs/inode.h> 56 1.1 mycroft #include <ufs/ufs/ufsmount.h> 57 1.1 mycroft #include <ufs/ufs/ufs_extern.h> 58 1.69 bouyer #include <ufs/ufs/ufs_quota.h> 59 1.70 bouyer #include <quota/quotaprop.h> 60 1.1 mycroft 61 1.69 bouyer kmutex_t dqlock; 62 1.69 bouyer kcondvar_t dqcv; 63 1.48 hannken 64 1.48 hannken /* 65 1.69 bouyer * Code pertaining to management of the in-core dquot data structures. 66 1.1 mycroft */ 67 1.69 bouyer #define DQHASH(dqvp, id) \ 68 1.69 bouyer (((((long)(dqvp)) >> 8) + id) & dqhash) 69 1.69 bouyer static LIST_HEAD(dqhashhead, dquot) *dqhashtbl; 70 1.69 bouyer static u_long dqhash; 71 1.69 bouyer static pool_cache_t dquot_cache; 72 1.1 mycroft 73 1.1 mycroft 74 1.69 bouyer static int quota_handle_cmd_get_version(struct mount *, struct lwp *, 75 1.72 dholland struct vfs_quotactl_args *args); 76 1.69 bouyer static int quota_handle_cmd_get(struct mount *, struct lwp *, 77 1.72 dholland struct vfs_quotactl_args *args); 78 1.69 bouyer static int quota_handle_cmd_set(struct mount *, struct lwp *, 79 1.72 dholland struct vfs_quotactl_args *args); 80 1.69 bouyer static int quota_handle_cmd_getall(struct mount *, struct lwp *, 81 1.72 dholland struct vfs_quotactl_args *args); 82 1.69 bouyer static int quota_handle_cmd_clear(struct mount *, struct lwp *, 83 1.72 dholland struct vfs_quotactl_args *args); 84 1.69 bouyer static int quota_handle_cmd_quotaon(struct mount *, struct lwp *, 85 1.72 dholland struct vfs_quotactl_args *args); 86 1.69 bouyer static int quota_handle_cmd_quotaoff(struct mount *, struct lwp *, 87 1.72 dholland struct vfs_quotactl_args *args); 88 1.72 dholland 89 1.1 mycroft /* 90 1.48 hannken * Initialize the quota fields of an inode. 91 1.48 hannken */ 92 1.48 hannken void 93 1.48 hannken ufsquota_init(struct inode *ip) 94 1.48 hannken { 95 1.48 hannken int i; 96 1.48 hannken 97 1.48 hannken for (i = 0; i < MAXQUOTAS; i++) 98 1.48 hannken ip->i_dquot[i] = NODQUOT; 99 1.48 hannken } 100 1.48 hannken 101 1.48 hannken /* 102 1.48 hannken * Release the quota fields from an inode. 103 1.48 hannken */ 104 1.48 hannken void 105 1.48 hannken ufsquota_free(struct inode *ip) 106 1.48 hannken { 107 1.48 hannken int i; 108 1.48 hannken 109 1.48 hannken for (i = 0; i < MAXQUOTAS; i++) { 110 1.48 hannken dqrele(ITOV(ip), ip->i_dquot[i]); 111 1.48 hannken ip->i_dquot[i] = NODQUOT; 112 1.48 hannken } 113 1.48 hannken } 114 1.48 hannken 115 1.48 hannken /* 116 1.1 mycroft * Update disk usage, and take corrective action. 117 1.1 mycroft */ 118 1.1 mycroft int 119 1.39 elad chkdq(struct inode *ip, int64_t change, kauth_cred_t cred, int flags) 120 1.1 mycroft { 121 1.69 bouyer /* do not track snapshot usage, or we will deadlock */ 122 1.69 bouyer if ((ip->i_flags & SF_SNAPSHOT) != 0) 123 1.69 bouyer return 0; 124 1.1 mycroft 125 1.69 bouyer #ifdef QUOTA 126 1.69 bouyer if (ip->i_ump->um_flags & UFS_QUOTA) 127 1.69 bouyer return chkdq1(ip, change, cred, flags); 128 1.69 bouyer #endif 129 1.69 bouyer #ifdef QUOTA2 130 1.69 bouyer if (ip->i_ump->um_flags & UFS_QUOTA2) 131 1.69 bouyer return chkdq2(ip, change, cred, flags); 132 1.69 bouyer #endif 133 1.69 bouyer return 0; 134 1.1 mycroft } 135 1.1 mycroft 136 1.1 mycroft /* 137 1.69 bouyer * Check the inode limit, applying corrective action. 138 1.1 mycroft */ 139 1.69 bouyer int 140 1.69 bouyer chkiq(struct inode *ip, int32_t change, kauth_cred_t cred, int flags) 141 1.1 mycroft { 142 1.69 bouyer /* do not track snapshot usage, or we will deadlock */ 143 1.69 bouyer if ((ip->i_flags & SF_SNAPSHOT) != 0) 144 1.69 bouyer return 0; 145 1.69 bouyer #ifdef QUOTA 146 1.69 bouyer if (ip->i_ump->um_flags & UFS_QUOTA) 147 1.69 bouyer return chkiq1(ip, change, cred, flags); 148 1.69 bouyer #endif 149 1.69 bouyer #ifdef QUOTA2 150 1.69 bouyer if (ip->i_ump->um_flags & UFS_QUOTA2) 151 1.69 bouyer return chkiq2(ip, change, cred, flags); 152 1.69 bouyer #endif 153 1.69 bouyer return 0; 154 1.1 mycroft } 155 1.1 mycroft 156 1.1 mycroft int 157 1.71 dholland quota_handle_cmd(struct mount *mp, struct lwp *l, int op, 158 1.72 dholland struct vfs_quotactl_args *args) 159 1.69 bouyer { 160 1.69 bouyer int error = 0; 161 1.69 bouyer 162 1.71 dholland switch (op) { 163 1.71 dholland case QUOTACTL_GETVERSION: 164 1.72 dholland error = quota_handle_cmd_get_version(mp, l, args); 165 1.71 dholland break; 166 1.71 dholland case QUOTACTL_QUOTAON: 167 1.72 dholland error = quota_handle_cmd_quotaon(mp, l, args); 168 1.71 dholland break; 169 1.71 dholland case QUOTACTL_QUOTAOFF: 170 1.72 dholland error = quota_handle_cmd_quotaoff(mp, l, args); 171 1.71 dholland break; 172 1.71 dholland case QUOTACTL_GET: 173 1.72 dholland error = quota_handle_cmd_get(mp, l, args); 174 1.71 dholland break; 175 1.71 dholland case QUOTACTL_SET: 176 1.72 dholland error = quota_handle_cmd_set(mp, l, args); 177 1.71 dholland break; 178 1.71 dholland case QUOTACTL_GETALL: 179 1.72 dholland error = quota_handle_cmd_getall(mp, l, args); 180 1.71 dholland break; 181 1.71 dholland case QUOTACTL_CLEAR: 182 1.72 dholland error = quota_handle_cmd_clear(mp, l, args); 183 1.71 dholland break; 184 1.71 dholland default: 185 1.71 dholland panic("Invalid quotactl operation %d\n", op); 186 1.69 bouyer } 187 1.71 dholland 188 1.69 bouyer return error; 189 1.69 bouyer } 190 1.69 bouyer 191 1.69 bouyer static int 192 1.69 bouyer quota_handle_cmd_get_version(struct mount *mp, struct lwp *l, 193 1.72 dholland struct vfs_quotactl_args *args) 194 1.1 mycroft { 195 1.69 bouyer struct ufsmount *ump = VFSTOUFS(mp); 196 1.73 dholland int *version_ret; 197 1.72 dholland 198 1.73 dholland KASSERT(args->qc_type == QCT_GETVERSION); 199 1.73 dholland version_ret = args->u.getversion.qc_version_ret; 200 1.69 bouyer 201 1.69 bouyer if ((ump->um_flags & (UFS_QUOTA|UFS_QUOTA2)) == 0) 202 1.69 bouyer return EOPNOTSUPP; 203 1.69 bouyer 204 1.69 bouyer #ifdef QUOTA 205 1.69 bouyer if (ump->um_flags & UFS_QUOTA) { 206 1.73 dholland *version_ret = 1; 207 1.69 bouyer } else 208 1.69 bouyer #endif 209 1.69 bouyer #ifdef QUOTA2 210 1.69 bouyer if (ump->um_flags & UFS_QUOTA2) { 211 1.73 dholland *version_ret = 2; 212 1.69 bouyer } else 213 1.69 bouyer #endif 214 1.73 dholland return EOPNOTSUPP; 215 1.73 dholland 216 1.73 dholland return 0; 217 1.1 mycroft } 218 1.1 mycroft 219 1.69 bouyer /* XXX shouldn't all this be in kauth ? */ 220 1.48 hannken static int 221 1.69 bouyer quota_get_auth(struct mount *mp, struct lwp *l, uid_t id) { 222 1.69 bouyer /* The user can always query about his own quota. */ 223 1.69 bouyer if (id == kauth_cred_getuid(l->l_cred)) 224 1.69 bouyer return 0; 225 1.69 bouyer return kauth_authorize_system(l->l_cred, KAUTH_SYSTEM_FS_QUOTA, 226 1.69 bouyer KAUTH_REQ_SYSTEM_FS_QUOTA_GET, mp, KAUTH_ARG(id), NULL); 227 1.69 bouyer } 228 1.69 bouyer 229 1.69 bouyer static int 230 1.69 bouyer quota_handle_cmd_get(struct mount *mp, struct lwp *l, 231 1.72 dholland struct vfs_quotactl_args *args) 232 1.69 bouyer { 233 1.69 bouyer struct ufsmount *ump = VFSTOUFS(mp); 234 1.74 dholland int error; 235 1.78 dholland const struct quotakey *qk; 236 1.77 dholland struct quotaval *ret; 237 1.72 dholland 238 1.74 dholland KASSERT(args->qc_type == QCT_GET); 239 1.78 dholland qk = args->u.get.qc_key; 240 1.77 dholland ret = args->u.get.qc_ret; 241 1.69 bouyer 242 1.69 bouyer if ((ump->um_flags & (UFS_QUOTA|UFS_QUOTA2)) == 0) 243 1.69 bouyer return EOPNOTSUPP; 244 1.69 bouyer 245 1.74 dholland /* avoid whitespace diffs */ { 246 1.78 dholland error = quota_get_auth(mp, l, qk->qk_id); 247 1.69 bouyer if (error != 0) 248 1.74 dholland return error; 249 1.69 bouyer #ifdef QUOTA 250 1.75 dholland if (ump->um_flags & UFS_QUOTA) { 251 1.78 dholland error = quota1_handle_cmd_get(ump, qk, ret); 252 1.75 dholland } else 253 1.69 bouyer #endif 254 1.69 bouyer #ifdef QUOTA2 255 1.69 bouyer if (ump->um_flags & UFS_QUOTA2) { 256 1.78 dholland error = quota2_handle_cmd_get(ump, qk, ret); 257 1.69 bouyer } else 258 1.69 bouyer #endif 259 1.69 bouyer panic("quota_handle_cmd_get: no support ?"); 260 1.69 bouyer 261 1.69 bouyer if (error != 0) 262 1.74 dholland return error; 263 1.69 bouyer } 264 1.74 dholland 265 1.69 bouyer return error; 266 1.69 bouyer } 267 1.69 bouyer 268 1.69 bouyer static int 269 1.69 bouyer quota_handle_cmd_set(struct mount *mp, struct lwp *l, 270 1.72 dholland struct vfs_quotactl_args *args) 271 1.69 bouyer { 272 1.69 bouyer prop_array_t replies; 273 1.69 bouyer prop_object_iterator_t iter; 274 1.69 bouyer prop_dictionary_t data; 275 1.69 bouyer uint32_t id; 276 1.11 fvdl struct ufsmount *ump = VFSTOUFS(mp); 277 1.69 bouyer int error, defaultq = 0; 278 1.69 bouyer const char *idstr; 279 1.72 dholland prop_dictionary_t cmddict; 280 1.72 dholland int q2type; 281 1.72 dholland prop_array_t datas; 282 1.72 dholland 283 1.72 dholland KASSERT(args->qc_type == QCT_PROPLIB); 284 1.72 dholland cmddict = args->u.proplib.qc_cmddict; 285 1.72 dholland q2type = args->u.proplib.qc_q2type; 286 1.72 dholland datas = args->u.proplib.qc_datas; 287 1.72 dholland 288 1.72 dholland KASSERT(prop_object_type(cmddict) == PROP_TYPE_DICTIONARY); 289 1.72 dholland KASSERT(prop_object_type(datas) == PROP_TYPE_ARRAY); 290 1.1 mycroft 291 1.69 bouyer if ((ump->um_flags & (UFS_QUOTA|UFS_QUOTA2)) == 0) 292 1.69 bouyer return EOPNOTSUPP; 293 1.69 bouyer 294 1.69 bouyer replies = prop_array_create(); 295 1.69 bouyer if (replies == NULL) 296 1.69 bouyer return ENOMEM; 297 1.61 ad 298 1.69 bouyer iter = prop_array_iterator(datas); 299 1.69 bouyer if (iter == NULL) { 300 1.69 bouyer prop_object_release(replies); 301 1.69 bouyer return ENOMEM; 302 1.68 dholland } 303 1.69 bouyer while ((data = prop_object_iterator_next(iter)) != NULL) { 304 1.69 bouyer if (!prop_dictionary_get_uint32(data, "id", &id)) { 305 1.69 bouyer if (!prop_dictionary_get_cstring_nocopy(data, "id", 306 1.69 bouyer &idstr)) 307 1.69 bouyer continue; 308 1.69 bouyer if (strcmp(idstr, "default")) 309 1.69 bouyer continue; 310 1.69 bouyer id = 0; 311 1.69 bouyer defaultq = 1; 312 1.69 bouyer } else { 313 1.69 bouyer defaultq = 0; 314 1.69 bouyer } 315 1.69 bouyer error = kauth_authorize_system(l->l_cred, KAUTH_SYSTEM_FS_QUOTA, 316 1.69 bouyer KAUTH_REQ_SYSTEM_FS_QUOTA_MANAGE, mp, KAUTH_ARG(id), NULL); 317 1.69 bouyer if (error != 0) 318 1.69 bouyer goto err; 319 1.69 bouyer #ifdef QUOTA 320 1.69 bouyer if (ump->um_flags & UFS_QUOTA) 321 1.72 dholland error = quota1_handle_cmd_set(ump, q2type, id, defaultq, 322 1.69 bouyer data); 323 1.69 bouyer else 324 1.69 bouyer #endif 325 1.69 bouyer #ifdef QUOTA2 326 1.69 bouyer if (ump->um_flags & UFS_QUOTA2) { 327 1.72 dholland error = quota2_handle_cmd_set(ump, q2type, id, defaultq, 328 1.69 bouyer data); 329 1.69 bouyer } else 330 1.69 bouyer #endif 331 1.69 bouyer panic("quota_handle_cmd_get: no support ?"); 332 1.69 bouyer 333 1.69 bouyer if (error && error != ENOENT) 334 1.69 bouyer goto err; 335 1.1 mycroft } 336 1.69 bouyer prop_object_iterator_release(iter); 337 1.69 bouyer if (!prop_dictionary_set_and_rel(cmddict, "data", replies)) { 338 1.53 ad error = ENOMEM; 339 1.69 bouyer } else { 340 1.69 bouyer error = 0; 341 1.1 mycroft } 342 1.69 bouyer return error; 343 1.69 bouyer err: 344 1.69 bouyer prop_object_iterator_release(iter); 345 1.69 bouyer prop_object_release(replies); 346 1.69 bouyer return error; 347 1.69 bouyer } 348 1.69 bouyer 349 1.69 bouyer static int 350 1.69 bouyer quota_handle_cmd_clear(struct mount *mp, struct lwp *l, 351 1.72 dholland struct vfs_quotactl_args *args) 352 1.69 bouyer { 353 1.69 bouyer prop_array_t replies; 354 1.69 bouyer prop_object_iterator_t iter; 355 1.69 bouyer prop_dictionary_t data; 356 1.69 bouyer uint32_t id; 357 1.1 mycroft struct ufsmount *ump = VFSTOUFS(mp); 358 1.69 bouyer int error, defaultq = 0; 359 1.69 bouyer const char *idstr; 360 1.72 dholland prop_dictionary_t cmddict; 361 1.72 dholland int q2type; 362 1.72 dholland prop_array_t datas; 363 1.72 dholland 364 1.72 dholland KASSERT(args->qc_type == QCT_PROPLIB); 365 1.72 dholland cmddict = args->u.proplib.qc_cmddict; 366 1.72 dholland q2type = args->u.proplib.qc_q2type; 367 1.72 dholland datas = args->u.proplib.qc_datas; 368 1.72 dholland 369 1.72 dholland KASSERT(prop_object_type(cmddict) == PROP_TYPE_DICTIONARY); 370 1.72 dholland KASSERT(prop_object_type(datas) == PROP_TYPE_ARRAY); 371 1.33 perry 372 1.69 bouyer if ((ump->um_flags & UFS_QUOTA2) == 0) 373 1.69 bouyer return EOPNOTSUPP; 374 1.69 bouyer 375 1.69 bouyer replies = prop_array_create(); 376 1.69 bouyer if (replies == NULL) 377 1.53 ad return ENOMEM; 378 1.53 ad 379 1.69 bouyer iter = prop_array_iterator(datas); 380 1.69 bouyer if (iter == NULL) { 381 1.69 bouyer prop_object_release(replies); 382 1.69 bouyer return ENOMEM; 383 1.69 bouyer } 384 1.69 bouyer while ((data = prop_object_iterator_next(iter)) != NULL) { 385 1.69 bouyer if (!prop_dictionary_get_uint32(data, "id", &id)) { 386 1.69 bouyer if (!prop_dictionary_get_cstring_nocopy(data, "id", 387 1.69 bouyer &idstr)) 388 1.69 bouyer continue; 389 1.69 bouyer if (strcmp(idstr, "default")) 390 1.69 bouyer continue; 391 1.69 bouyer id = 0; 392 1.69 bouyer defaultq = 1; 393 1.69 bouyer } else { 394 1.69 bouyer defaultq = 0; 395 1.69 bouyer } 396 1.69 bouyer error = kauth_authorize_system(l->l_cred, KAUTH_SYSTEM_FS_QUOTA, 397 1.69 bouyer KAUTH_REQ_SYSTEM_FS_QUOTA_MANAGE, mp, KAUTH_ARG(id), NULL); 398 1.69 bouyer if (error != 0) 399 1.69 bouyer goto err; 400 1.69 bouyer #ifdef QUOTA2 401 1.69 bouyer if (ump->um_flags & UFS_QUOTA2) { 402 1.72 dholland error = quota2_handle_cmd_clear(ump, q2type, id, defaultq, 403 1.69 bouyer data); 404 1.69 bouyer } else 405 1.69 bouyer #endif 406 1.69 bouyer panic("quota_handle_cmd_get: no support ?"); 407 1.69 bouyer 408 1.69 bouyer if (error && error != ENOENT) 409 1.69 bouyer goto err; 410 1.50 hannken } 411 1.69 bouyer prop_object_iterator_release(iter); 412 1.69 bouyer if (!prop_dictionary_set_and_rel(cmddict, "data", replies)) { 413 1.69 bouyer error = ENOMEM; 414 1.69 bouyer } else { 415 1.69 bouyer error = 0; 416 1.1 mycroft } 417 1.69 bouyer return error; 418 1.69 bouyer err: 419 1.69 bouyer prop_object_iterator_release(iter); 420 1.69 bouyer prop_object_release(replies); 421 1.69 bouyer return error; 422 1.1 mycroft } 423 1.1 mycroft 424 1.69 bouyer static int 425 1.69 bouyer quota_handle_cmd_getall(struct mount *mp, struct lwp *l, 426 1.72 dholland struct vfs_quotactl_args *args) 427 1.1 mycroft { 428 1.69 bouyer prop_array_t replies; 429 1.1 mycroft struct ufsmount *ump = VFSTOUFS(mp); 430 1.1 mycroft int error; 431 1.72 dholland prop_dictionary_t cmddict; 432 1.72 dholland int q2type; 433 1.72 dholland prop_array_t datas; 434 1.72 dholland 435 1.72 dholland KASSERT(args->qc_type == QCT_PROPLIB); 436 1.72 dholland cmddict = args->u.proplib.qc_cmddict; 437 1.72 dholland q2type = args->u.proplib.qc_q2type; 438 1.72 dholland datas = args->u.proplib.qc_datas; 439 1.72 dholland 440 1.72 dholland KASSERT(prop_object_type(cmddict) == PROP_TYPE_DICTIONARY); 441 1.72 dholland KASSERT(prop_object_type(datas) == PROP_TYPE_ARRAY); 442 1.1 mycroft 443 1.69 bouyer if ((ump->um_flags & UFS_QUOTA2) == 0) 444 1.69 bouyer return EOPNOTSUPP; 445 1.69 bouyer 446 1.69 bouyer error = kauth_authorize_system(l->l_cred, KAUTH_SYSTEM_FS_QUOTA, 447 1.69 bouyer KAUTH_REQ_SYSTEM_FS_QUOTA_GET, mp, NULL, NULL); 448 1.8 christos if (error) 449 1.69 bouyer return error; 450 1.69 bouyer 451 1.69 bouyer replies = prop_array_create(); 452 1.69 bouyer if (replies == NULL) 453 1.69 bouyer return ENOMEM; 454 1.69 bouyer 455 1.69 bouyer #ifdef QUOTA2 456 1.69 bouyer if (ump->um_flags & UFS_QUOTA2) { 457 1.72 dholland error = quota2_handle_cmd_getall(ump, q2type, replies); 458 1.69 bouyer } else 459 1.69 bouyer #endif 460 1.69 bouyer panic("quota_handle_cmd_getall: no support ?"); 461 1.69 bouyer if (!prop_dictionary_set_and_rel(cmddict, "data", replies)) { 462 1.69 bouyer error = ENOMEM; 463 1.69 bouyer } else { 464 1.69 bouyer error = 0; 465 1.69 bouyer } 466 1.69 bouyer return error; 467 1.1 mycroft } 468 1.1 mycroft 469 1.69 bouyer static int 470 1.69 bouyer quota_handle_cmd_quotaon(struct mount *mp, struct lwp *l, 471 1.72 dholland struct vfs_quotactl_args *args) 472 1.1 mycroft { 473 1.69 bouyer prop_dictionary_t data; 474 1.1 mycroft struct ufsmount *ump = VFSTOUFS(mp); 475 1.1 mycroft int error; 476 1.69 bouyer const char *qfile; 477 1.72 dholland prop_dictionary_t cmddict; 478 1.72 dholland int q2type; 479 1.72 dholland prop_array_t datas; 480 1.72 dholland 481 1.72 dholland KASSERT(args->qc_type == QCT_PROPLIB); 482 1.72 dholland cmddict = args->u.proplib.qc_cmddict; 483 1.72 dholland q2type = args->u.proplib.qc_q2type; 484 1.72 dholland datas = args->u.proplib.qc_datas; 485 1.72 dholland 486 1.72 dholland KASSERT(prop_object_type(cmddict) == PROP_TYPE_DICTIONARY); 487 1.72 dholland KASSERT(prop_object_type(datas) == PROP_TYPE_ARRAY); 488 1.69 bouyer 489 1.69 bouyer if ((ump->um_flags & UFS_QUOTA2) != 0) 490 1.69 bouyer return EBUSY; 491 1.69 bouyer 492 1.69 bouyer if (prop_array_count(datas) != 1) 493 1.69 bouyer return EINVAL; 494 1.1 mycroft 495 1.69 bouyer data = prop_array_get(datas, 0); 496 1.69 bouyer if (data == NULL) 497 1.69 bouyer return ENOMEM; 498 1.69 bouyer if (!prop_dictionary_get_cstring_nocopy(data, "quotafile", 499 1.69 bouyer &qfile)) 500 1.69 bouyer return EINVAL; 501 1.69 bouyer 502 1.69 bouyer error = kauth_authorize_system(l->l_cred, KAUTH_SYSTEM_FS_QUOTA, 503 1.69 bouyer KAUTH_REQ_SYSTEM_FS_QUOTA_ONOFF, mp, NULL, NULL); 504 1.69 bouyer if (error != 0) { 505 1.69 bouyer return error; 506 1.69 bouyer } 507 1.69 bouyer #ifdef QUOTA 508 1.72 dholland error = quota1_handle_cmd_quotaon(l, ump, q2type, qfile); 509 1.69 bouyer #else 510 1.69 bouyer error = EOPNOTSUPP; 511 1.69 bouyer #endif 512 1.69 bouyer 513 1.69 bouyer return error; 514 1.1 mycroft } 515 1.1 mycroft 516 1.69 bouyer static int 517 1.69 bouyer quota_handle_cmd_quotaoff(struct mount *mp, struct lwp *l, 518 1.72 dholland struct vfs_quotactl_args *args) 519 1.1 mycroft { 520 1.1 mycroft struct ufsmount *ump = VFSTOUFS(mp); 521 1.69 bouyer int error; 522 1.72 dholland prop_dictionary_t cmddict; 523 1.72 dholland int q2type; 524 1.72 dholland prop_array_t datas; 525 1.72 dholland 526 1.72 dholland KASSERT(args->qc_type == QCT_PROPLIB); 527 1.72 dholland cmddict = args->u.proplib.qc_cmddict; 528 1.72 dholland q2type = args->u.proplib.qc_q2type; 529 1.72 dholland datas = args->u.proplib.qc_datas; 530 1.72 dholland 531 1.72 dholland KASSERT(prop_object_type(cmddict) == PROP_TYPE_DICTIONARY); 532 1.72 dholland KASSERT(prop_object_type(datas) == PROP_TYPE_ARRAY); 533 1.1 mycroft 534 1.69 bouyer if ((ump->um_flags & UFS_QUOTA2) != 0) 535 1.69 bouyer return EOPNOTSUPP; 536 1.69 bouyer 537 1.69 bouyer if (prop_array_count(datas) != 0) 538 1.69 bouyer return EINVAL; 539 1.69 bouyer 540 1.69 bouyer error = kauth_authorize_system(l->l_cred, KAUTH_SYSTEM_FS_QUOTA, 541 1.69 bouyer KAUTH_REQ_SYSTEM_FS_QUOTA_ONOFF, mp, NULL, NULL); 542 1.69 bouyer if (error != 0) { 543 1.69 bouyer return error; 544 1.1 mycroft } 545 1.69 bouyer #ifdef QUOTA 546 1.72 dholland error = quota1_handle_cmd_quotaoff(l, ump, q2type); 547 1.69 bouyer #else 548 1.69 bouyer error = EOPNOTSUPP; 549 1.69 bouyer #endif 550 1.69 bouyer 551 1.69 bouyer return error; 552 1.1 mycroft } 553 1.1 mycroft 554 1.1 mycroft /* 555 1.1 mycroft * Initialize the quota system. 556 1.1 mycroft */ 557 1.1 mycroft void 558 1.35 thorpej dqinit(void) 559 1.1 mycroft { 560 1.47 pooka 561 1.50 hannken mutex_init(&dqlock, MUTEX_DEFAULT, IPL_NONE); 562 1.50 hannken cv_init(&dqcv, "quota"); 563 1.60 ad dqhashtbl = hashinit(desiredvnodes, HASH_LIST, true, &dqhash); 564 1.55 ad dquot_cache = pool_cache_init(sizeof(struct dquot), 0, 0, 0, "ufsdq", 565 1.55 ad NULL, IPL_NONE, NULL, NULL, NULL); 566 1.14 jdolecek } 567 1.14 jdolecek 568 1.21 chs void 569 1.35 thorpej dqreinit(void) 570 1.21 chs { 571 1.21 chs struct dquot *dq; 572 1.21 chs struct dqhashhead *oldhash, *hash; 573 1.21 chs struct vnode *dqvp; 574 1.21 chs u_long oldmask, mask, hashval; 575 1.21 chs int i; 576 1.21 chs 577 1.60 ad hash = hashinit(desiredvnodes, HASH_LIST, true, &mask); 578 1.50 hannken mutex_enter(&dqlock); 579 1.21 chs oldhash = dqhashtbl; 580 1.21 chs oldmask = dqhash; 581 1.21 chs dqhashtbl = hash; 582 1.21 chs dqhash = mask; 583 1.21 chs for (i = 0; i <= oldmask; i++) { 584 1.21 chs while ((dq = LIST_FIRST(&oldhash[i])) != NULL) { 585 1.21 chs dqvp = dq->dq_ump->um_quotas[dq->dq_type]; 586 1.21 chs LIST_REMOVE(dq, dq_hash); 587 1.21 chs hashval = DQHASH(dqvp, dq->dq_id); 588 1.21 chs LIST_INSERT_HEAD(&dqhashtbl[hashval], dq, dq_hash); 589 1.21 chs } 590 1.21 chs } 591 1.50 hannken mutex_exit(&dqlock); 592 1.60 ad hashdone(oldhash, HASH_LIST, oldmask); 593 1.21 chs } 594 1.21 chs 595 1.14 jdolecek /* 596 1.14 jdolecek * Free resources held by quota system. 597 1.14 jdolecek */ 598 1.14 jdolecek void 599 1.35 thorpej dqdone(void) 600 1.14 jdolecek { 601 1.47 pooka 602 1.55 ad pool_cache_destroy(dquot_cache); 603 1.60 ad hashdone(dqhashtbl, HASH_LIST, dqhash); 604 1.50 hannken cv_destroy(&dqcv); 605 1.50 hannken mutex_destroy(&dqlock); 606 1.1 mycroft } 607 1.1 mycroft 608 1.1 mycroft /* 609 1.69 bouyer * Set up the quotas for an inode. 610 1.69 bouyer * 611 1.69 bouyer * This routine completely defines the semantics of quotas. 612 1.69 bouyer * If other criterion want to be used to establish quotas, the 613 1.69 bouyer * MAXQUOTAS value in quotas.h should be increased, and the 614 1.69 bouyer * additional dquots set up here. 615 1.69 bouyer */ 616 1.69 bouyer int 617 1.69 bouyer getinoquota(struct inode *ip) 618 1.69 bouyer { 619 1.69 bouyer struct ufsmount *ump = ip->i_ump; 620 1.69 bouyer struct vnode *vp = ITOV(ip); 621 1.69 bouyer int i, error; 622 1.69 bouyer u_int32_t ino_ids[MAXQUOTAS]; 623 1.69 bouyer 624 1.69 bouyer /* 625 1.69 bouyer * To avoid deadlocks never update quotas for quota files 626 1.69 bouyer * on the same file system 627 1.69 bouyer */ 628 1.69 bouyer for (i = 0; i < MAXQUOTAS; i++) 629 1.69 bouyer if (vp == ump->um_quotas[i]) 630 1.69 bouyer return 0; 631 1.69 bouyer 632 1.69 bouyer ino_ids[USRQUOTA] = ip->i_uid; 633 1.69 bouyer ino_ids[GRPQUOTA] = ip->i_gid; 634 1.69 bouyer for (i = 0; i < MAXQUOTAS; i++) { 635 1.69 bouyer /* 636 1.69 bouyer * If the file id changed the quota needs update. 637 1.69 bouyer */ 638 1.69 bouyer if (ip->i_dquot[i] != NODQUOT && 639 1.69 bouyer ip->i_dquot[i]->dq_id != ino_ids[i]) { 640 1.69 bouyer dqrele(ITOV(ip), ip->i_dquot[i]); 641 1.69 bouyer ip->i_dquot[i] = NODQUOT; 642 1.69 bouyer } 643 1.69 bouyer /* 644 1.69 bouyer * Set up the quota based on file id. 645 1.69 bouyer * ENODEV means that quotas are not enabled. 646 1.69 bouyer */ 647 1.69 bouyer if (ip->i_dquot[i] == NODQUOT && 648 1.69 bouyer (error = dqget(vp, ino_ids[i], ump, i, &ip->i_dquot[i])) && 649 1.69 bouyer error != ENODEV) 650 1.69 bouyer return (error); 651 1.69 bouyer } 652 1.69 bouyer return 0; 653 1.69 bouyer } 654 1.69 bouyer 655 1.69 bouyer /* 656 1.1 mycroft * Obtain a dquot structure for the specified identifier and quota file 657 1.1 mycroft * reading the information from the file if necessary. 658 1.1 mycroft */ 659 1.69 bouyer int 660 1.35 thorpej dqget(struct vnode *vp, u_long id, struct ufsmount *ump, int type, 661 1.35 thorpej struct dquot **dqp) 662 1.1 mycroft { 663 1.50 hannken struct dquot *dq, *ndq; 664 1.21 chs struct dqhashhead *dqh; 665 1.11 fvdl struct vnode *dqvp; 666 1.69 bouyer int error = 0; /* XXX gcc */ 667 1.1 mycroft 668 1.50 hannken /* Lock to see an up to date value for QTF_CLOSING. */ 669 1.50 hannken mutex_enter(&dqlock); 670 1.69 bouyer if ((ump->um_flags & (UFS_QUOTA|UFS_QUOTA2)) == 0) { 671 1.50 hannken mutex_exit(&dqlock); 672 1.1 mycroft *dqp = NODQUOT; 673 1.69 bouyer return (ENODEV); 674 1.69 bouyer } 675 1.69 bouyer dqvp = ump->um_quotas[type]; 676 1.69 bouyer #ifdef QUOTA 677 1.69 bouyer if (ump->um_flags & UFS_QUOTA) { 678 1.69 bouyer if (dqvp == NULLVP || (ump->umq1_qflags[type] & QTF_CLOSING)) { 679 1.69 bouyer mutex_exit(&dqlock); 680 1.69 bouyer *dqp = NODQUOT; 681 1.69 bouyer return (ENODEV); 682 1.69 bouyer } 683 1.1 mycroft } 684 1.69 bouyer #endif 685 1.69 bouyer #ifdef QUOTA2 686 1.69 bouyer if (ump->um_flags & UFS_QUOTA2) { 687 1.69 bouyer if (dqvp == NULLVP) { 688 1.69 bouyer mutex_exit(&dqlock); 689 1.69 bouyer *dqp = NODQUOT; 690 1.69 bouyer return (ENODEV); 691 1.69 bouyer } 692 1.69 bouyer } 693 1.69 bouyer #endif 694 1.50 hannken KASSERT(dqvp != vp); 695 1.1 mycroft /* 696 1.1 mycroft * Check the cache first. 697 1.1 mycroft */ 698 1.21 chs dqh = &dqhashtbl[DQHASH(dqvp, id)]; 699 1.21 chs LIST_FOREACH(dq, dqh, dq_hash) { 700 1.1 mycroft if (dq->dq_id != id || 701 1.1 mycroft dq->dq_ump->um_quotas[dq->dq_type] != dqvp) 702 1.1 mycroft continue; 703 1.50 hannken KASSERT(dq->dq_cnt > 0); 704 1.37 chs dqref(dq); 705 1.50 hannken mutex_exit(&dqlock); 706 1.1 mycroft *dqp = dq; 707 1.1 mycroft return (0); 708 1.1 mycroft } 709 1.1 mycroft /* 710 1.1 mycroft * Not in cache, allocate a new one. 711 1.1 mycroft */ 712 1.50 hannken mutex_exit(&dqlock); 713 1.55 ad ndq = pool_cache_get(dquot_cache, PR_WAITOK); 714 1.1 mycroft /* 715 1.1 mycroft * Initialize the contents of the dquot structure. 716 1.1 mycroft */ 717 1.50 hannken memset((char *)ndq, 0, sizeof *ndq); 718 1.50 hannken ndq->dq_flags = 0; 719 1.50 hannken ndq->dq_id = id; 720 1.50 hannken ndq->dq_ump = ump; 721 1.50 hannken ndq->dq_type = type; 722 1.50 hannken mutex_init(&ndq->dq_interlock, MUTEX_DEFAULT, IPL_NONE); 723 1.50 hannken mutex_enter(&dqlock); 724 1.49 hannken dqh = &dqhashtbl[DQHASH(dqvp, id)]; 725 1.50 hannken LIST_FOREACH(dq, dqh, dq_hash) { 726 1.50 hannken if (dq->dq_id != id || 727 1.50 hannken dq->dq_ump->um_quotas[dq->dq_type] != dqvp) 728 1.50 hannken continue; 729 1.50 hannken /* 730 1.50 hannken * Another thread beat us allocating this dquot. 731 1.50 hannken */ 732 1.50 hannken KASSERT(dq->dq_cnt > 0); 733 1.50 hannken dqref(dq); 734 1.50 hannken mutex_exit(&dqlock); 735 1.64 bouyer mutex_destroy(&ndq->dq_interlock); 736 1.55 ad pool_cache_put(dquot_cache, ndq); 737 1.50 hannken *dqp = dq; 738 1.50 hannken return 0; 739 1.50 hannken } 740 1.50 hannken dq = ndq; 741 1.5 mycroft LIST_INSERT_HEAD(dqh, dq, dq_hash); 742 1.37 chs dqref(dq); 743 1.50 hannken mutex_enter(&dq->dq_interlock); 744 1.50 hannken mutex_exit(&dqlock); 745 1.69 bouyer #ifdef QUOTA 746 1.69 bouyer if (ump->um_flags & UFS_QUOTA) 747 1.69 bouyer error = dq1get(dqvp, id, ump, type, dq); 748 1.69 bouyer #endif 749 1.69 bouyer #ifdef QUOTA2 750 1.69 bouyer if (ump->um_flags & UFS_QUOTA2) 751 1.69 bouyer error = dq2get(dqvp, id, ump, type, dq); 752 1.69 bouyer #endif 753 1.1 mycroft /* 754 1.1 mycroft * I/O error in reading quota file, release 755 1.1 mycroft * quota structure and reflect problem to caller. 756 1.1 mycroft */ 757 1.1 mycroft if (error) { 758 1.50 hannken mutex_enter(&dqlock); 759 1.5 mycroft LIST_REMOVE(dq, dq_hash); 760 1.50 hannken mutex_exit(&dqlock); 761 1.49 hannken mutex_exit(&dq->dq_interlock); 762 1.1 mycroft dqrele(vp, dq); 763 1.1 mycroft *dqp = NODQUOT; 764 1.1 mycroft return (error); 765 1.1 mycroft } 766 1.49 hannken mutex_exit(&dq->dq_interlock); 767 1.1 mycroft *dqp = dq; 768 1.1 mycroft return (0); 769 1.1 mycroft } 770 1.1 mycroft 771 1.1 mycroft /* 772 1.1 mycroft * Obtain a reference to a dquot. 773 1.1 mycroft */ 774 1.69 bouyer void 775 1.35 thorpej dqref(struct dquot *dq) 776 1.1 mycroft { 777 1.1 mycroft 778 1.50 hannken KASSERT(mutex_owned(&dqlock)); 779 1.1 mycroft dq->dq_cnt++; 780 1.46 hannken KASSERT(dq->dq_cnt > 0); 781 1.1 mycroft } 782 1.1 mycroft 783 1.1 mycroft /* 784 1.1 mycroft * Release a reference to a dquot. 785 1.1 mycroft */ 786 1.69 bouyer void 787 1.35 thorpej dqrele(struct vnode *vp, struct dquot *dq) 788 1.1 mycroft { 789 1.1 mycroft 790 1.1 mycroft if (dq == NODQUOT) 791 1.1 mycroft return; 792 1.50 hannken mutex_enter(&dq->dq_interlock); 793 1.50 hannken for (;;) { 794 1.50 hannken mutex_enter(&dqlock); 795 1.50 hannken if (dq->dq_cnt > 1) { 796 1.50 hannken dq->dq_cnt--; 797 1.50 hannken mutex_exit(&dqlock); 798 1.50 hannken mutex_exit(&dq->dq_interlock); 799 1.50 hannken return; 800 1.50 hannken } 801 1.50 hannken if ((dq->dq_flags & DQ_MOD) == 0) 802 1.50 hannken break; 803 1.50 hannken mutex_exit(&dqlock); 804 1.69 bouyer #ifdef QUOTA 805 1.69 bouyer if (dq->dq_ump->um_flags & UFS_QUOTA) 806 1.69 bouyer (void) dq1sync(vp, dq); 807 1.69 bouyer #endif 808 1.69 bouyer #ifdef QUOTA2 809 1.69 bouyer if (dq->dq_ump->um_flags & UFS_QUOTA2) 810 1.69 bouyer (void) dq2sync(vp, dq); 811 1.69 bouyer #endif 812 1.1 mycroft } 813 1.50 hannken KASSERT(dq->dq_cnt == 1 && (dq->dq_flags & DQ_MOD) == 0); 814 1.50 hannken LIST_REMOVE(dq, dq_hash); 815 1.50 hannken mutex_exit(&dqlock); 816 1.50 hannken mutex_exit(&dq->dq_interlock); 817 1.50 hannken mutex_destroy(&dq->dq_interlock); 818 1.55 ad pool_cache_put(dquot_cache, dq); 819 1.1 mycroft } 820 1.1 mycroft 821 1.69 bouyer int 822 1.69 bouyer qsync(struct mount *mp) 823 1.1 mycroft { 824 1.69 bouyer struct ufsmount *ump = VFSTOUFS(mp); 825 1.69 bouyer #ifdef QUOTA 826 1.69 bouyer if (ump->um_flags & UFS_QUOTA) 827 1.69 bouyer return q1sync(mp); 828 1.69 bouyer #endif 829 1.69 bouyer #ifdef QUOTA2 830 1.69 bouyer if (ump->um_flags & UFS_QUOTA2) 831 1.69 bouyer return q2sync(mp); 832 1.69 bouyer #endif 833 1.69 bouyer return 0; 834 1.1 mycroft } 835 1.1 mycroft 836 1.50 hannken #ifdef DIAGNOSTIC 837 1.1 mycroft /* 838 1.50 hannken * Check the hash chains for stray dquot's. 839 1.1 mycroft */ 840 1.69 bouyer void 841 1.35 thorpej dqflush(struct vnode *vp) 842 1.1 mycroft { 843 1.50 hannken struct dquot *dq; 844 1.50 hannken int i; 845 1.1 mycroft 846 1.50 hannken mutex_enter(&dqlock); 847 1.50 hannken for (i = 0; i <= dqhash; i++) 848 1.50 hannken LIST_FOREACH(dq, &dqhashtbl[i], dq_hash) 849 1.50 hannken KASSERT(dq->dq_ump->um_quotas[dq->dq_type] != vp); 850 1.50 hannken mutex_exit(&dqlock); 851 1.1 mycroft } 852 1.50 hannken #endif 853
Indexes created Sat Oct 11 14:09:46 GMT 2025