0001
0002
0003
0004
0005
0006 #include "xfs.h"
0007 #include "xfs_fs.h"
0008 #include "xfs_shared.h"
0009 #include "xfs_format.h"
0010 #include "xfs_log_format.h"
0011 #include "xfs_trans_resv.h"
0012 #include "xfs_bit.h"
0013 #include "xfs_sb.h"
0014 #include "xfs_mount.h"
0015 #include "xfs_inode.h"
0016 #include "xfs_iwalk.h"
0017 #include "xfs_quota.h"
0018 #include "xfs_bmap.h"
0019 #include "xfs_bmap_util.h"
0020 #include "xfs_trans.h"
0021 #include "xfs_trans_space.h"
0022 #include "xfs_qm.h"
0023 #include "xfs_trace.h"
0024 #include "xfs_icache.h"
0025 #include "xfs_error.h"
0026 #include "xfs_ag.h"
0027 #include "xfs_ialloc.h"
0028 #include "xfs_log_priv.h"
0029
0030
0031
0032
0033
0034
0035
0036 STATIC int xfs_qm_init_quotainos(struct xfs_mount *mp);
0037 STATIC int xfs_qm_init_quotainfo(struct xfs_mount *mp);
0038
0039 STATIC void xfs_qm_destroy_quotainos(struct xfs_quotainfo *qi);
0040 STATIC void xfs_qm_dqfree_one(struct xfs_dquot *dqp);
0041
0042
0043
0044
0045
0046
0047
0048 #define XFS_DQ_LOOKUP_BATCH 32
0049
0050 STATIC int
0051 xfs_qm_dquot_walk(
0052 struct xfs_mount *mp,
0053 xfs_dqtype_t type,
0054 int (*execute)(struct xfs_dquot *dqp, void *data),
0055 void *data)
0056 {
0057 struct xfs_quotainfo *qi = mp->m_quotainfo;
0058 struct radix_tree_root *tree = xfs_dquot_tree(qi, type);
0059 uint32_t next_index;
0060 int last_error = 0;
0061 int skipped;
0062 int nr_found;
0063
0064 restart:
0065 skipped = 0;
0066 next_index = 0;
0067 nr_found = 0;
0068
0069 while (1) {
0070 struct xfs_dquot *batch[XFS_DQ_LOOKUP_BATCH];
0071 int error = 0;
0072 int i;
0073
0074 mutex_lock(&qi->qi_tree_lock);
0075 nr_found = radix_tree_gang_lookup(tree, (void **)batch,
0076 next_index, XFS_DQ_LOOKUP_BATCH);
0077 if (!nr_found) {
0078 mutex_unlock(&qi->qi_tree_lock);
0079 break;
0080 }
0081
0082 for (i = 0; i < nr_found; i++) {
0083 struct xfs_dquot *dqp = batch[i];
0084
0085 next_index = dqp->q_id + 1;
0086
0087 error = execute(batch[i], data);
0088 if (error == -EAGAIN) {
0089 skipped++;
0090 continue;
0091 }
0092 if (error && last_error != -EFSCORRUPTED)
0093 last_error = error;
0094 }
0095
0096 mutex_unlock(&qi->qi_tree_lock);
0097
0098
0099 if (last_error == -EFSCORRUPTED) {
0100 skipped = 0;
0101 break;
0102 }
0103
0104 if (!next_index)
0105 break;
0106 }
0107
0108 if (skipped) {
0109 delay(1);
0110 goto restart;
0111 }
0112
0113 return last_error;
0114 }
0115
0116
0117
0118
0119
0120 STATIC int
0121 xfs_qm_dqpurge(
0122 struct xfs_dquot *dqp,
0123 void *data)
0124 {
0125 struct xfs_quotainfo *qi = dqp->q_mount->m_quotainfo;
0126 int error = -EAGAIN;
0127
0128 xfs_dqlock(dqp);
0129 if ((dqp->q_flags & XFS_DQFLAG_FREEING) || dqp->q_nrefs != 0)
0130 goto out_unlock;
0131
0132 dqp->q_flags |= XFS_DQFLAG_FREEING;
0133
0134 xfs_dqflock(dqp);
0135
0136
0137
0138
0139
0140
0141 if (XFS_DQ_IS_DIRTY(dqp)) {
0142 struct xfs_buf *bp = NULL;
0143
0144
0145
0146
0147
0148 error = xfs_qm_dqflush(dqp, &bp);
0149 if (!error) {
0150 error = xfs_bwrite(bp);
0151 xfs_buf_relse(bp);
0152 } else if (error == -EAGAIN) {
0153 dqp->q_flags &= ~XFS_DQFLAG_FREEING;
0154 goto out_unlock;
0155 }
0156 xfs_dqflock(dqp);
0157 }
0158
0159 ASSERT(atomic_read(&dqp->q_pincount) == 0);
0160 ASSERT(xlog_is_shutdown(dqp->q_logitem.qli_item.li_log) ||
0161 !test_bit(XFS_LI_IN_AIL, &dqp->q_logitem.qli_item.li_flags));
0162
0163 xfs_dqfunlock(dqp);
0164 xfs_dqunlock(dqp);
0165
0166 radix_tree_delete(xfs_dquot_tree(qi, xfs_dquot_type(dqp)), dqp->q_id);
0167 qi->qi_dquots--;
0168
0169
0170
0171
0172
0173 ASSERT(!list_empty(&dqp->q_lru));
0174 list_lru_del(&qi->qi_lru, &dqp->q_lru);
0175 XFS_STATS_DEC(dqp->q_mount, xs_qm_dquot_unused);
0176
0177 xfs_qm_dqdestroy(dqp);
0178 return 0;
0179
0180 out_unlock:
0181 xfs_dqunlock(dqp);
0182 return error;
0183 }
0184
0185
0186
0187
0188 static void
0189 xfs_qm_dqpurge_all(
0190 struct xfs_mount *mp)
0191 {
0192 xfs_qm_dquot_walk(mp, XFS_DQTYPE_USER, xfs_qm_dqpurge, NULL);
0193 xfs_qm_dquot_walk(mp, XFS_DQTYPE_GROUP, xfs_qm_dqpurge, NULL);
0194 xfs_qm_dquot_walk(mp, XFS_DQTYPE_PROJ, xfs_qm_dqpurge, NULL);
0195 }
0196
0197
0198
0199
0200 void
0201 xfs_qm_unmount(
0202 struct xfs_mount *mp)
0203 {
0204 if (mp->m_quotainfo) {
0205 xfs_qm_dqpurge_all(mp);
0206 xfs_qm_destroy_quotainfo(mp);
0207 }
0208 }
0209
0210
0211
0212
0213 void
0214 xfs_qm_unmount_quotas(
0215 xfs_mount_t *mp)
0216 {
0217
0218
0219
0220
0221 ASSERT(mp->m_rootip);
0222 xfs_qm_dqdetach(mp->m_rootip);
0223 if (mp->m_rbmip)
0224 xfs_qm_dqdetach(mp->m_rbmip);
0225 if (mp->m_rsumip)
0226 xfs_qm_dqdetach(mp->m_rsumip);
0227
0228
0229
0230
0231 if (mp->m_quotainfo) {
0232 if (mp->m_quotainfo->qi_uquotaip) {
0233 xfs_irele(mp->m_quotainfo->qi_uquotaip);
0234 mp->m_quotainfo->qi_uquotaip = NULL;
0235 }
0236 if (mp->m_quotainfo->qi_gquotaip) {
0237 xfs_irele(mp->m_quotainfo->qi_gquotaip);
0238 mp->m_quotainfo->qi_gquotaip = NULL;
0239 }
0240 if (mp->m_quotainfo->qi_pquotaip) {
0241 xfs_irele(mp->m_quotainfo->qi_pquotaip);
0242 mp->m_quotainfo->qi_pquotaip = NULL;
0243 }
0244 }
0245 }
0246
0247 STATIC int
0248 xfs_qm_dqattach_one(
0249 struct xfs_inode *ip,
0250 xfs_dqtype_t type,
0251 bool doalloc,
0252 struct xfs_dquot **IO_idqpp)
0253 {
0254 struct xfs_dquot *dqp;
0255 int error;
0256
0257 ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL));
0258 error = 0;
0259
0260
0261
0262
0263
0264
0265 dqp = *IO_idqpp;
0266 if (dqp) {
0267 trace_xfs_dqattach_found(dqp);
0268 return 0;
0269 }
0270
0271
0272
0273
0274
0275
0276
0277 error = xfs_qm_dqget_inode(ip, type, doalloc, &dqp);
0278 if (error)
0279 return error;
0280
0281 trace_xfs_dqattach_get(dqp);
0282
0283
0284
0285
0286
0287 *IO_idqpp = dqp;
0288 xfs_dqunlock(dqp);
0289 return 0;
0290 }
0291
0292 static bool
0293 xfs_qm_need_dqattach(
0294 struct xfs_inode *ip)
0295 {
0296 struct xfs_mount *mp = ip->i_mount;
0297
0298 if (!XFS_IS_QUOTA_ON(mp))
0299 return false;
0300 if (!XFS_NOT_DQATTACHED(mp, ip))
0301 return false;
0302 if (xfs_is_quota_inode(&mp->m_sb, ip->i_ino))
0303 return false;
0304 return true;
0305 }
0306
0307
0308
0309
0310
0311
0312
0313
0314 int
0315 xfs_qm_dqattach_locked(
0316 xfs_inode_t *ip,
0317 bool doalloc)
0318 {
0319 xfs_mount_t *mp = ip->i_mount;
0320 int error = 0;
0321
0322 if (!xfs_qm_need_dqattach(ip))
0323 return 0;
0324
0325 ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL));
0326
0327 if (XFS_IS_UQUOTA_ON(mp) && !ip->i_udquot) {
0328 error = xfs_qm_dqattach_one(ip, XFS_DQTYPE_USER,
0329 doalloc, &ip->i_udquot);
0330 if (error)
0331 goto done;
0332 ASSERT(ip->i_udquot);
0333 }
0334
0335 if (XFS_IS_GQUOTA_ON(mp) && !ip->i_gdquot) {
0336 error = xfs_qm_dqattach_one(ip, XFS_DQTYPE_GROUP,
0337 doalloc, &ip->i_gdquot);
0338 if (error)
0339 goto done;
0340 ASSERT(ip->i_gdquot);
0341 }
0342
0343 if (XFS_IS_PQUOTA_ON(mp) && !ip->i_pdquot) {
0344 error = xfs_qm_dqattach_one(ip, XFS_DQTYPE_PROJ,
0345 doalloc, &ip->i_pdquot);
0346 if (error)
0347 goto done;
0348 ASSERT(ip->i_pdquot);
0349 }
0350
0351 done:
0352
0353
0354
0355
0356 ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL));
0357 return error;
0358 }
0359
0360 int
0361 xfs_qm_dqattach(
0362 struct xfs_inode *ip)
0363 {
0364 int error;
0365
0366 if (!xfs_qm_need_dqattach(ip))
0367 return 0;
0368
0369 xfs_ilock(ip, XFS_ILOCK_EXCL);
0370 error = xfs_qm_dqattach_locked(ip, false);
0371 xfs_iunlock(ip, XFS_ILOCK_EXCL);
0372
0373 return error;
0374 }
0375
0376
0377
0378
0379
0380
0381 void
0382 xfs_qm_dqdetach(
0383 xfs_inode_t *ip)
0384 {
0385 if (!(ip->i_udquot || ip->i_gdquot || ip->i_pdquot))
0386 return;
0387
0388 trace_xfs_dquot_dqdetach(ip);
0389
0390 ASSERT(!xfs_is_quota_inode(&ip->i_mount->m_sb, ip->i_ino));
0391 if (ip->i_udquot) {
0392 xfs_qm_dqrele(ip->i_udquot);
0393 ip->i_udquot = NULL;
0394 }
0395 if (ip->i_gdquot) {
0396 xfs_qm_dqrele(ip->i_gdquot);
0397 ip->i_gdquot = NULL;
0398 }
0399 if (ip->i_pdquot) {
0400 xfs_qm_dqrele(ip->i_pdquot);
0401 ip->i_pdquot = NULL;
0402 }
0403 }
0404
0405 struct xfs_qm_isolate {
0406 struct list_head buffers;
0407 struct list_head dispose;
0408 };
0409
0410 static enum lru_status
0411 xfs_qm_dquot_isolate(
0412 struct list_head *item,
0413 struct list_lru_one *lru,
0414 spinlock_t *lru_lock,
0415 void *arg)
0416 __releases(lru_lock) __acquires(lru_lock)
0417 {
0418 struct xfs_dquot *dqp = container_of(item,
0419 struct xfs_dquot, q_lru);
0420 struct xfs_qm_isolate *isol = arg;
0421
0422 if (!xfs_dqlock_nowait(dqp))
0423 goto out_miss_busy;
0424
0425
0426
0427
0428
0429 if (dqp->q_nrefs) {
0430 xfs_dqunlock(dqp);
0431 XFS_STATS_INC(dqp->q_mount, xs_qm_dqwants);
0432
0433 trace_xfs_dqreclaim_want(dqp);
0434 list_lru_isolate(lru, &dqp->q_lru);
0435 XFS_STATS_DEC(dqp->q_mount, xs_qm_dquot_unused);
0436 return LRU_REMOVED;
0437 }
0438
0439
0440
0441
0442
0443
0444 if (!xfs_dqflock_nowait(dqp)) {
0445 xfs_dqunlock(dqp);
0446 goto out_miss_busy;
0447 }
0448
0449 if (XFS_DQ_IS_DIRTY(dqp)) {
0450 struct xfs_buf *bp = NULL;
0451 int error;
0452
0453 trace_xfs_dqreclaim_dirty(dqp);
0454
0455
0456 spin_unlock(lru_lock);
0457
0458 error = xfs_qm_dqflush(dqp, &bp);
0459 if (error)
0460 goto out_unlock_dirty;
0461
0462 xfs_buf_delwri_queue(bp, &isol->buffers);
0463 xfs_buf_relse(bp);
0464 goto out_unlock_dirty;
0465 }
0466 xfs_dqfunlock(dqp);
0467
0468
0469
0470
0471 dqp->q_flags |= XFS_DQFLAG_FREEING;
0472 xfs_dqunlock(dqp);
0473
0474 ASSERT(dqp->q_nrefs == 0);
0475 list_lru_isolate_move(lru, &dqp->q_lru, &isol->dispose);
0476 XFS_STATS_DEC(dqp->q_mount, xs_qm_dquot_unused);
0477 trace_xfs_dqreclaim_done(dqp);
0478 XFS_STATS_INC(dqp->q_mount, xs_qm_dqreclaims);
0479 return LRU_REMOVED;
0480
0481 out_miss_busy:
0482 trace_xfs_dqreclaim_busy(dqp);
0483 XFS_STATS_INC(dqp->q_mount, xs_qm_dqreclaim_misses);
0484 return LRU_SKIP;
0485
0486 out_unlock_dirty:
0487 trace_xfs_dqreclaim_busy(dqp);
0488 XFS_STATS_INC(dqp->q_mount, xs_qm_dqreclaim_misses);
0489 xfs_dqunlock(dqp);
0490 spin_lock(lru_lock);
0491 return LRU_RETRY;
0492 }
0493
0494 static unsigned long
0495 xfs_qm_shrink_scan(
0496 struct shrinker *shrink,
0497 struct shrink_control *sc)
0498 {
0499 struct xfs_quotainfo *qi = container_of(shrink,
0500 struct xfs_quotainfo, qi_shrinker);
0501 struct xfs_qm_isolate isol;
0502 unsigned long freed;
0503 int error;
0504
0505 if ((sc->gfp_mask & (__GFP_FS|__GFP_DIRECT_RECLAIM)) != (__GFP_FS|__GFP_DIRECT_RECLAIM))
0506 return 0;
0507
0508 INIT_LIST_HEAD(&isol.buffers);
0509 INIT_LIST_HEAD(&isol.dispose);
0510
0511 freed = list_lru_shrink_walk(&qi->qi_lru, sc,
0512 xfs_qm_dquot_isolate, &isol);
0513
0514 error = xfs_buf_delwri_submit(&isol.buffers);
0515 if (error)
0516 xfs_warn(NULL, "%s: dquot reclaim failed", __func__);
0517
0518 while (!list_empty(&isol.dispose)) {
0519 struct xfs_dquot *dqp;
0520
0521 dqp = list_first_entry(&isol.dispose, struct xfs_dquot, q_lru);
0522 list_del_init(&dqp->q_lru);
0523 xfs_qm_dqfree_one(dqp);
0524 }
0525
0526 return freed;
0527 }
0528
0529 static unsigned long
0530 xfs_qm_shrink_count(
0531 struct shrinker *shrink,
0532 struct shrink_control *sc)
0533 {
0534 struct xfs_quotainfo *qi = container_of(shrink,
0535 struct xfs_quotainfo, qi_shrinker);
0536
0537 return list_lru_shrink_count(&qi->qi_lru, sc);
0538 }
0539
0540 STATIC void
0541 xfs_qm_set_defquota(
0542 struct xfs_mount *mp,
0543 xfs_dqtype_t type,
0544 struct xfs_quotainfo *qinf)
0545 {
0546 struct xfs_dquot *dqp;
0547 struct xfs_def_quota *defq;
0548 int error;
0549
0550 error = xfs_qm_dqget_uncached(mp, 0, type, &dqp);
0551 if (error)
0552 return;
0553
0554 defq = xfs_get_defquota(qinf, xfs_dquot_type(dqp));
0555
0556
0557
0558
0559
0560 defq->blk.hard = dqp->q_blk.hardlimit;
0561 defq->blk.soft = dqp->q_blk.softlimit;
0562 defq->ino.hard = dqp->q_ino.hardlimit;
0563 defq->ino.soft = dqp->q_ino.softlimit;
0564 defq->rtb.hard = dqp->q_rtb.hardlimit;
0565 defq->rtb.soft = dqp->q_rtb.softlimit;
0566 xfs_qm_dqdestroy(dqp);
0567 }
0568
0569
0570 static void
0571 xfs_qm_init_timelimits(
0572 struct xfs_mount *mp,
0573 xfs_dqtype_t type)
0574 {
0575 struct xfs_quotainfo *qinf = mp->m_quotainfo;
0576 struct xfs_def_quota *defq;
0577 struct xfs_dquot *dqp;
0578 int error;
0579
0580 defq = xfs_get_defquota(qinf, type);
0581
0582 defq->blk.time = XFS_QM_BTIMELIMIT;
0583 defq->ino.time = XFS_QM_ITIMELIMIT;
0584 defq->rtb.time = XFS_QM_RTBTIMELIMIT;
0585
0586
0587
0588
0589
0590
0591
0592
0593 error = xfs_qm_dqget_uncached(mp, 0, type, &dqp);
0594 if (error)
0595 return;
0596
0597
0598
0599
0600
0601
0602 if (dqp->q_blk.timer)
0603 defq->blk.time = dqp->q_blk.timer;
0604 if (dqp->q_ino.timer)
0605 defq->ino.time = dqp->q_ino.timer;
0606 if (dqp->q_rtb.timer)
0607 defq->rtb.time = dqp->q_rtb.timer;
0608
0609 xfs_qm_dqdestroy(dqp);
0610 }
0611
0612
0613
0614
0615
0616 STATIC int
0617 xfs_qm_init_quotainfo(
0618 struct xfs_mount *mp)
0619 {
0620 struct xfs_quotainfo *qinf;
0621 int error;
0622
0623 ASSERT(XFS_IS_QUOTA_ON(mp));
0624
0625 qinf = mp->m_quotainfo = kmem_zalloc(sizeof(struct xfs_quotainfo), 0);
0626
0627 error = list_lru_init(&qinf->qi_lru);
0628 if (error)
0629 goto out_free_qinf;
0630
0631
0632
0633
0634
0635 error = xfs_qm_init_quotainos(mp);
0636 if (error)
0637 goto out_free_lru;
0638
0639 INIT_RADIX_TREE(&qinf->qi_uquota_tree, GFP_NOFS);
0640 INIT_RADIX_TREE(&qinf->qi_gquota_tree, GFP_NOFS);
0641 INIT_RADIX_TREE(&qinf->qi_pquota_tree, GFP_NOFS);
0642 mutex_init(&qinf->qi_tree_lock);
0643
0644
0645 mutex_init(&qinf->qi_quotaofflock);
0646
0647
0648 qinf->qi_dqchunklen = XFS_FSB_TO_BB(mp, XFS_DQUOT_CLUSTER_SIZE_FSB);
0649 qinf->qi_dqperchunk = xfs_calc_dquots_per_chunk(qinf->qi_dqchunklen);
0650 if (xfs_has_bigtime(mp)) {
0651 qinf->qi_expiry_min =
0652 xfs_dq_bigtime_to_unix(XFS_DQ_BIGTIME_EXPIRY_MIN);
0653 qinf->qi_expiry_max =
0654 xfs_dq_bigtime_to_unix(XFS_DQ_BIGTIME_EXPIRY_MAX);
0655 } else {
0656 qinf->qi_expiry_min = XFS_DQ_LEGACY_EXPIRY_MIN;
0657 qinf->qi_expiry_max = XFS_DQ_LEGACY_EXPIRY_MAX;
0658 }
0659 trace_xfs_quota_expiry_range(mp, qinf->qi_expiry_min,
0660 qinf->qi_expiry_max);
0661
0662 mp->m_qflags |= (mp->m_sb.sb_qflags & XFS_ALL_QUOTA_CHKD);
0663
0664 xfs_qm_init_timelimits(mp, XFS_DQTYPE_USER);
0665 xfs_qm_init_timelimits(mp, XFS_DQTYPE_GROUP);
0666 xfs_qm_init_timelimits(mp, XFS_DQTYPE_PROJ);
0667
0668 if (XFS_IS_UQUOTA_ON(mp))
0669 xfs_qm_set_defquota(mp, XFS_DQTYPE_USER, qinf);
0670 if (XFS_IS_GQUOTA_ON(mp))
0671 xfs_qm_set_defquota(mp, XFS_DQTYPE_GROUP, qinf);
0672 if (XFS_IS_PQUOTA_ON(mp))
0673 xfs_qm_set_defquota(mp, XFS_DQTYPE_PROJ, qinf);
0674
0675 qinf->qi_shrinker.count_objects = xfs_qm_shrink_count;
0676 qinf->qi_shrinker.scan_objects = xfs_qm_shrink_scan;
0677 qinf->qi_shrinker.seeks = DEFAULT_SEEKS;
0678 qinf->qi_shrinker.flags = SHRINKER_NUMA_AWARE;
0679
0680 error = register_shrinker(&qinf->qi_shrinker, "xfs-qm:%s",
0681 mp->m_super->s_id);
0682 if (error)
0683 goto out_free_inos;
0684
0685 return 0;
0686
0687 out_free_inos:
0688 mutex_destroy(&qinf->qi_quotaofflock);
0689 mutex_destroy(&qinf->qi_tree_lock);
0690 xfs_qm_destroy_quotainos(qinf);
0691 out_free_lru:
0692 list_lru_destroy(&qinf->qi_lru);
0693 out_free_qinf:
0694 kmem_free(qinf);
0695 mp->m_quotainfo = NULL;
0696 return error;
0697 }
0698
0699
0700
0701
0702
0703
0704 void
0705 xfs_qm_destroy_quotainfo(
0706 struct xfs_mount *mp)
0707 {
0708 struct xfs_quotainfo *qi;
0709
0710 qi = mp->m_quotainfo;
0711 ASSERT(qi != NULL);
0712
0713 unregister_shrinker(&qi->qi_shrinker);
0714 list_lru_destroy(&qi->qi_lru);
0715 xfs_qm_destroy_quotainos(qi);
0716 mutex_destroy(&qi->qi_tree_lock);
0717 mutex_destroy(&qi->qi_quotaofflock);
0718 kmem_free(qi);
0719 mp->m_quotainfo = NULL;
0720 }
0721
0722
0723
0724
0725
0726 STATIC int
0727 xfs_qm_qino_alloc(
0728 struct xfs_mount *mp,
0729 struct xfs_inode **ipp,
0730 unsigned int flags)
0731 {
0732 struct xfs_trans *tp;
0733 int error;
0734 bool need_alloc = true;
0735
0736 *ipp = NULL;
0737
0738
0739
0740
0741
0742
0743
0744 if (!xfs_has_pquotino(mp) &&
0745 (flags & (XFS_QMOPT_PQUOTA|XFS_QMOPT_GQUOTA))) {
0746 xfs_ino_t ino = NULLFSINO;
0747
0748 if ((flags & XFS_QMOPT_PQUOTA) &&
0749 (mp->m_sb.sb_gquotino != NULLFSINO)) {
0750 ino = mp->m_sb.sb_gquotino;
0751 if (XFS_IS_CORRUPT(mp,
0752 mp->m_sb.sb_pquotino != NULLFSINO))
0753 return -EFSCORRUPTED;
0754 } else if ((flags & XFS_QMOPT_GQUOTA) &&
0755 (mp->m_sb.sb_pquotino != NULLFSINO)) {
0756 ino = mp->m_sb.sb_pquotino;
0757 if (XFS_IS_CORRUPT(mp,
0758 mp->m_sb.sb_gquotino != NULLFSINO))
0759 return -EFSCORRUPTED;
0760 }
0761 if (ino != NULLFSINO) {
0762 error = xfs_iget(mp, NULL, ino, 0, 0, ipp);
0763 if (error)
0764 return error;
0765 mp->m_sb.sb_gquotino = NULLFSINO;
0766 mp->m_sb.sb_pquotino = NULLFSINO;
0767 need_alloc = false;
0768 }
0769 }
0770
0771 error = xfs_trans_alloc(mp, &M_RES(mp)->tr_create,
0772 need_alloc ? XFS_QM_QINOCREATE_SPACE_RES(mp) : 0,
0773 0, 0, &tp);
0774 if (error)
0775 return error;
0776
0777 if (need_alloc) {
0778 xfs_ino_t ino;
0779
0780 error = xfs_dialloc(&tp, 0, S_IFREG, &ino);
0781 if (!error)
0782 error = xfs_init_new_inode(&init_user_ns, tp, NULL, ino,
0783 S_IFREG, 1, 0, 0, false, ipp);
0784 if (error) {
0785 xfs_trans_cancel(tp);
0786 return error;
0787 }
0788 }
0789
0790
0791
0792
0793
0794
0795 spin_lock(&mp->m_sb_lock);
0796 if (flags & XFS_QMOPT_SBVERSION) {
0797 ASSERT(!xfs_has_quota(mp));
0798
0799 xfs_add_quota(mp);
0800 mp->m_sb.sb_uquotino = NULLFSINO;
0801 mp->m_sb.sb_gquotino = NULLFSINO;
0802 mp->m_sb.sb_pquotino = NULLFSINO;
0803
0804
0805 mp->m_sb.sb_qflags = mp->m_qflags & XFS_ALL_QUOTA_ACCT;
0806 }
0807 if (flags & XFS_QMOPT_UQUOTA)
0808 mp->m_sb.sb_uquotino = (*ipp)->i_ino;
0809 else if (flags & XFS_QMOPT_GQUOTA)
0810 mp->m_sb.sb_gquotino = (*ipp)->i_ino;
0811 else
0812 mp->m_sb.sb_pquotino = (*ipp)->i_ino;
0813 spin_unlock(&mp->m_sb_lock);
0814 xfs_log_sb(tp);
0815
0816 error = xfs_trans_commit(tp);
0817 if (error) {
0818 ASSERT(xfs_is_shutdown(mp));
0819 xfs_alert(mp, "%s failed (error %d)!", __func__, error);
0820 }
0821 if (need_alloc)
0822 xfs_finish_inode_setup(*ipp);
0823 return error;
0824 }
0825
0826
0827 STATIC void
0828 xfs_qm_reset_dqcounts(
0829 struct xfs_mount *mp,
0830 struct xfs_buf *bp,
0831 xfs_dqid_t id,
0832 xfs_dqtype_t type)
0833 {
0834 struct xfs_dqblk *dqb;
0835 int j;
0836
0837 trace_xfs_reset_dqcounts(bp, _RET_IP_);
0838
0839
0840
0841
0842
0843 #ifdef DEBUG
0844 j = (int)XFS_FSB_TO_B(mp, XFS_DQUOT_CLUSTER_SIZE_FSB) /
0845 sizeof(struct xfs_dqblk);
0846 ASSERT(mp->m_quotainfo->qi_dqperchunk == j);
0847 #endif
0848 dqb = bp->b_addr;
0849 for (j = 0; j < mp->m_quotainfo->qi_dqperchunk; j++) {
0850 struct xfs_disk_dquot *ddq;
0851
0852 ddq = (struct xfs_disk_dquot *)&dqb[j];
0853
0854
0855
0856
0857
0858
0859
0860 if (xfs_dqblk_verify(mp, &dqb[j], id + j) ||
0861 (dqb[j].dd_diskdq.d_type & XFS_DQTYPE_REC_MASK) != type)
0862 xfs_dqblk_repair(mp, &dqb[j], id + j, type);
0863
0864
0865
0866
0867
0868 ddq->d_type = type;
0869 ddq->d_bcount = 0;
0870 ddq->d_icount = 0;
0871 ddq->d_rtbcount = 0;
0872
0873
0874
0875
0876
0877
0878 if (ddq->d_id != 0) {
0879 ddq->d_btimer = 0;
0880 ddq->d_itimer = 0;
0881 ddq->d_rtbtimer = 0;
0882 ddq->d_bwarns = 0;
0883 ddq->d_iwarns = 0;
0884 ddq->d_rtbwarns = 0;
0885 if (xfs_has_bigtime(mp))
0886 ddq->d_type |= XFS_DQTYPE_BIGTIME;
0887 }
0888
0889 if (xfs_has_crc(mp)) {
0890 xfs_update_cksum((char *)&dqb[j],
0891 sizeof(struct xfs_dqblk),
0892 XFS_DQUOT_CRC_OFF);
0893 }
0894 }
0895 }
0896
0897 STATIC int
0898 xfs_qm_reset_dqcounts_all(
0899 struct xfs_mount *mp,
0900 xfs_dqid_t firstid,
0901 xfs_fsblock_t bno,
0902 xfs_filblks_t blkcnt,
0903 xfs_dqtype_t type,
0904 struct list_head *buffer_list)
0905 {
0906 struct xfs_buf *bp;
0907 int error = 0;
0908
0909 ASSERT(blkcnt > 0);
0910
0911
0912
0913
0914
0915
0916
0917
0918
0919
0920 while (blkcnt--) {
0921 error = xfs_trans_read_buf(mp, NULL, mp->m_ddev_targp,
0922 XFS_FSB_TO_DADDR(mp, bno),
0923 mp->m_quotainfo->qi_dqchunklen, 0, &bp,
0924 &xfs_dquot_buf_ops);
0925
0926
0927
0928
0929
0930
0931
0932
0933 if (error == -EFSCORRUPTED) {
0934 error = xfs_trans_read_buf(mp, NULL, mp->m_ddev_targp,
0935 XFS_FSB_TO_DADDR(mp, bno),
0936 mp->m_quotainfo->qi_dqchunklen, 0, &bp,
0937 NULL);
0938 }
0939
0940 if (error)
0941 break;
0942
0943
0944
0945
0946
0947
0948 bp->b_ops = &xfs_dquot_buf_ops;
0949 xfs_qm_reset_dqcounts(mp, bp, firstid, type);
0950 xfs_buf_delwri_queue(bp, buffer_list);
0951 xfs_buf_relse(bp);
0952
0953
0954 bno++;
0955 firstid += mp->m_quotainfo->qi_dqperchunk;
0956 }
0957
0958 return error;
0959 }
0960
0961
0962
0963
0964
0965 STATIC int
0966 xfs_qm_reset_dqcounts_buf(
0967 struct xfs_mount *mp,
0968 struct xfs_inode *qip,
0969 xfs_dqtype_t type,
0970 struct list_head *buffer_list)
0971 {
0972 struct xfs_bmbt_irec *map;
0973 int i, nmaps;
0974 int error;
0975 xfs_fileoff_t lblkno;
0976 xfs_filblks_t maxlblkcnt;
0977 xfs_dqid_t firstid;
0978 xfs_fsblock_t rablkno;
0979 xfs_filblks_t rablkcnt;
0980
0981 error = 0;
0982
0983
0984
0985
0986
0987 if (qip->i_nblocks == 0)
0988 return 0;
0989
0990 map = kmem_alloc(XFS_DQITER_MAP_SIZE * sizeof(*map), 0);
0991
0992 lblkno = 0;
0993 maxlblkcnt = XFS_B_TO_FSB(mp, mp->m_super->s_maxbytes);
0994 do {
0995 uint lock_mode;
0996
0997 nmaps = XFS_DQITER_MAP_SIZE;
0998
0999
1000
1001
1002
1003 lock_mode = xfs_ilock_data_map_shared(qip);
1004 error = xfs_bmapi_read(qip, lblkno, maxlblkcnt - lblkno,
1005 map, &nmaps, 0);
1006 xfs_iunlock(qip, lock_mode);
1007 if (error)
1008 break;
1009
1010 ASSERT(nmaps <= XFS_DQITER_MAP_SIZE);
1011 for (i = 0; i < nmaps; i++) {
1012 ASSERT(map[i].br_startblock != DELAYSTARTBLOCK);
1013 ASSERT(map[i].br_blockcount);
1014
1015
1016 lblkno += map[i].br_blockcount;
1017
1018 if (map[i].br_startblock == HOLESTARTBLOCK)
1019 continue;
1020
1021 firstid = (xfs_dqid_t) map[i].br_startoff *
1022 mp->m_quotainfo->qi_dqperchunk;
1023
1024
1025
1026 if ((i+1 < nmaps) &&
1027 (map[i+1].br_startblock != HOLESTARTBLOCK)) {
1028 rablkcnt = map[i+1].br_blockcount;
1029 rablkno = map[i+1].br_startblock;
1030 while (rablkcnt--) {
1031 xfs_buf_readahead(mp->m_ddev_targp,
1032 XFS_FSB_TO_DADDR(mp, rablkno),
1033 mp->m_quotainfo->qi_dqchunklen,
1034 &xfs_dquot_buf_ops);
1035 rablkno++;
1036 }
1037 }
1038
1039
1040
1041
1042 error = xfs_qm_reset_dqcounts_all(mp, firstid,
1043 map[i].br_startblock,
1044 map[i].br_blockcount,
1045 type, buffer_list);
1046 if (error)
1047 goto out;
1048 }
1049 } while (nmaps > 0);
1050
1051 out:
1052 kmem_free(map);
1053 return error;
1054 }
1055
1056
1057
1058
1059
1060
1061
1062
1063
1064 STATIC int
1065 xfs_qm_quotacheck_dqadjust(
1066 struct xfs_inode *ip,
1067 xfs_dqtype_t type,
1068 xfs_qcnt_t nblks,
1069 xfs_qcnt_t rtblks)
1070 {
1071 struct xfs_mount *mp = ip->i_mount;
1072 struct xfs_dquot *dqp;
1073 xfs_dqid_t id;
1074 int error;
1075
1076 id = xfs_qm_id_for_quotatype(ip, type);
1077 error = xfs_qm_dqget(mp, id, type, true, &dqp);
1078 if (error) {
1079
1080
1081
1082 ASSERT(error != -ESRCH);
1083 ASSERT(error != -ENOENT);
1084 return error;
1085 }
1086
1087 trace_xfs_dqadjust(dqp);
1088
1089
1090
1091
1092
1093 dqp->q_ino.count++;
1094 dqp->q_ino.reserved++;
1095 if (nblks) {
1096 dqp->q_blk.count += nblks;
1097 dqp->q_blk.reserved += nblks;
1098 }
1099 if (rtblks) {
1100 dqp->q_rtb.count += rtblks;
1101 dqp->q_rtb.reserved += rtblks;
1102 }
1103
1104
1105
1106
1107
1108
1109 if (dqp->q_id) {
1110 xfs_qm_adjust_dqlimits(dqp);
1111 xfs_qm_adjust_dqtimers(dqp);
1112 }
1113
1114 dqp->q_flags |= XFS_DQFLAG_DIRTY;
1115 xfs_qm_dqput(dqp);
1116 return 0;
1117 }
1118
1119
1120
1121
1122
1123
1124 STATIC int
1125 xfs_qm_dqusage_adjust(
1126 struct xfs_mount *mp,
1127 struct xfs_trans *tp,
1128 xfs_ino_t ino,
1129 void *data)
1130 {
1131 struct xfs_inode *ip;
1132 xfs_qcnt_t nblks;
1133 xfs_filblks_t rtblks = 0;
1134 int error;
1135
1136 ASSERT(XFS_IS_QUOTA_ON(mp));
1137
1138
1139
1140
1141
1142 if (xfs_is_quota_inode(&mp->m_sb, ino))
1143 return 0;
1144
1145
1146
1147
1148
1149 error = xfs_iget(mp, tp, ino, XFS_IGET_DONTCACHE, 0, &ip);
1150 if (error == -EINVAL || error == -ENOENT)
1151 return 0;
1152 if (error)
1153 return error;
1154
1155 ASSERT(ip->i_delayed_blks == 0);
1156
1157 if (XFS_IS_REALTIME_INODE(ip)) {
1158 struct xfs_ifork *ifp = xfs_ifork_ptr(ip, XFS_DATA_FORK);
1159
1160 error = xfs_iread_extents(tp, ip, XFS_DATA_FORK);
1161 if (error)
1162 goto error0;
1163
1164 xfs_bmap_count_leaves(ifp, &rtblks);
1165 }
1166
1167 nblks = (xfs_qcnt_t)ip->i_nblocks - rtblks;
1168
1169
1170
1171
1172
1173
1174
1175
1176
1177
1178
1179
1180
1181 if (XFS_IS_UQUOTA_ON(mp)) {
1182 error = xfs_qm_quotacheck_dqadjust(ip, XFS_DQTYPE_USER, nblks,
1183 rtblks);
1184 if (error)
1185 goto error0;
1186 }
1187
1188 if (XFS_IS_GQUOTA_ON(mp)) {
1189 error = xfs_qm_quotacheck_dqadjust(ip, XFS_DQTYPE_GROUP, nblks,
1190 rtblks);
1191 if (error)
1192 goto error0;
1193 }
1194
1195 if (XFS_IS_PQUOTA_ON(mp)) {
1196 error = xfs_qm_quotacheck_dqadjust(ip, XFS_DQTYPE_PROJ, nblks,
1197 rtblks);
1198 if (error)
1199 goto error0;
1200 }
1201
1202 error0:
1203 xfs_irele(ip);
1204 return error;
1205 }
1206
1207 STATIC int
1208 xfs_qm_flush_one(
1209 struct xfs_dquot *dqp,
1210 void *data)
1211 {
1212 struct xfs_mount *mp = dqp->q_mount;
1213 struct list_head *buffer_list = data;
1214 struct xfs_buf *bp = NULL;
1215 int error = 0;
1216
1217 xfs_dqlock(dqp);
1218 if (dqp->q_flags & XFS_DQFLAG_FREEING)
1219 goto out_unlock;
1220 if (!XFS_DQ_IS_DIRTY(dqp))
1221 goto out_unlock;
1222
1223
1224
1225
1226
1227
1228
1229
1230
1231 if (!xfs_dqflock_nowait(dqp)) {
1232
1233 error = xfs_buf_incore(mp->m_ddev_targp, dqp->q_blkno,
1234 mp->m_quotainfo->qi_dqchunklen, 0, &bp);
1235 if (error)
1236 goto out_unlock;
1237
1238 if (!(bp->b_flags & _XBF_DELWRI_Q)) {
1239 error = -EAGAIN;
1240 xfs_buf_relse(bp);
1241 goto out_unlock;
1242 }
1243 xfs_buf_unlock(bp);
1244
1245 xfs_buf_delwri_pushbuf(bp, buffer_list);
1246 xfs_buf_rele(bp);
1247
1248 error = -EAGAIN;
1249 goto out_unlock;
1250 }
1251
1252 error = xfs_qm_dqflush(dqp, &bp);
1253 if (error)
1254 goto out_unlock;
1255
1256 xfs_buf_delwri_queue(bp, buffer_list);
1257 xfs_buf_relse(bp);
1258 out_unlock:
1259 xfs_dqunlock(dqp);
1260 return error;
1261 }
1262
1263
1264
1265
1266
1267 STATIC int
1268 xfs_qm_quotacheck(
1269 xfs_mount_t *mp)
1270 {
1271 int error, error2;
1272 uint flags;
1273 LIST_HEAD (buffer_list);
1274 struct xfs_inode *uip = mp->m_quotainfo->qi_uquotaip;
1275 struct xfs_inode *gip = mp->m_quotainfo->qi_gquotaip;
1276 struct xfs_inode *pip = mp->m_quotainfo->qi_pquotaip;
1277
1278 flags = 0;
1279
1280 ASSERT(uip || gip || pip);
1281 ASSERT(XFS_IS_QUOTA_ON(mp));
1282
1283 xfs_notice(mp, "Quotacheck needed: Please wait.");
1284
1285
1286
1287
1288
1289
1290 if (uip) {
1291 error = xfs_qm_reset_dqcounts_buf(mp, uip, XFS_DQTYPE_USER,
1292 &buffer_list);
1293 if (error)
1294 goto error_return;
1295 flags |= XFS_UQUOTA_CHKD;
1296 }
1297
1298 if (gip) {
1299 error = xfs_qm_reset_dqcounts_buf(mp, gip, XFS_DQTYPE_GROUP,
1300 &buffer_list);
1301 if (error)
1302 goto error_return;
1303 flags |= XFS_GQUOTA_CHKD;
1304 }
1305
1306 if (pip) {
1307 error = xfs_qm_reset_dqcounts_buf(mp, pip, XFS_DQTYPE_PROJ,
1308 &buffer_list);
1309 if (error)
1310 goto error_return;
1311 flags |= XFS_PQUOTA_CHKD;
1312 }
1313
1314 error = xfs_iwalk_threaded(mp, 0, 0, xfs_qm_dqusage_adjust, 0, true,
1315 NULL);
1316 if (error) {
1317
1318
1319
1320
1321
1322 xfs_qm_dqpurge_all(mp);
1323 goto error_return;
1324 }
1325
1326
1327
1328
1329
1330 if (XFS_IS_UQUOTA_ON(mp)) {
1331 error = xfs_qm_dquot_walk(mp, XFS_DQTYPE_USER, xfs_qm_flush_one,
1332 &buffer_list);
1333 }
1334 if (XFS_IS_GQUOTA_ON(mp)) {
1335 error2 = xfs_qm_dquot_walk(mp, XFS_DQTYPE_GROUP, xfs_qm_flush_one,
1336 &buffer_list);
1337 if (!error)
1338 error = error2;
1339 }
1340 if (XFS_IS_PQUOTA_ON(mp)) {
1341 error2 = xfs_qm_dquot_walk(mp, XFS_DQTYPE_PROJ, xfs_qm_flush_one,
1342 &buffer_list);
1343 if (!error)
1344 error = error2;
1345 }
1346
1347 error2 = xfs_buf_delwri_submit(&buffer_list);
1348 if (!error)
1349 error = error2;
1350
1351
1352
1353
1354
1355
1356
1357
1358 if (error) {
1359 xfs_qm_dqpurge_all(mp);
1360 goto error_return;
1361 }
1362
1363
1364
1365
1366
1367
1368 mp->m_qflags &= ~XFS_ALL_QUOTA_CHKD;
1369 mp->m_qflags |= flags;
1370
1371 error_return:
1372 xfs_buf_delwri_cancel(&buffer_list);
1373
1374 if (error) {
1375 xfs_warn(mp,
1376 "Quotacheck: Unsuccessful (Error %d): Disabling quotas.",
1377 error);
1378
1379
1380
1381 ASSERT(mp->m_quotainfo != NULL);
1382 xfs_qm_destroy_quotainfo(mp);
1383 if (xfs_mount_reset_sbqflags(mp)) {
1384 xfs_warn(mp,
1385 "Quotacheck: Failed to reset quota flags.");
1386 }
1387 } else
1388 xfs_notice(mp, "Quotacheck: Done.");
1389 return error;
1390 }
1391
1392
1393
1394
1395
1396
1397
1398
1399
1400
1401 void
1402 xfs_qm_mount_quotas(
1403 struct xfs_mount *mp)
1404 {
1405 int error = 0;
1406 uint sbf;
1407
1408
1409
1410
1411
1412 if (mp->m_sb.sb_rextents) {
1413 xfs_notice(mp, "Cannot turn on quotas for realtime filesystem");
1414 mp->m_qflags = 0;
1415 goto write_changes;
1416 }
1417
1418 ASSERT(XFS_IS_QUOTA_ON(mp));
1419
1420
1421
1422
1423
1424 error = xfs_qm_init_quotainfo(mp);
1425 if (error) {
1426
1427
1428
1429 ASSERT(mp->m_quotainfo == NULL);
1430 mp->m_qflags = 0;
1431 goto write_changes;
1432 }
1433
1434
1435
1436 if (XFS_QM_NEED_QUOTACHECK(mp)) {
1437 error = xfs_qm_quotacheck(mp);
1438 if (error) {
1439
1440 return;
1441 }
1442 }
1443
1444
1445
1446
1447
1448 if (!XFS_IS_UQUOTA_ON(mp))
1449 mp->m_qflags &= ~XFS_UQUOTA_CHKD;
1450 if (!XFS_IS_GQUOTA_ON(mp))
1451 mp->m_qflags &= ~XFS_GQUOTA_CHKD;
1452 if (!XFS_IS_PQUOTA_ON(mp))
1453 mp->m_qflags &= ~XFS_PQUOTA_CHKD;
1454
1455 write_changes:
1456
1457
1458
1459
1460 spin_lock(&mp->m_sb_lock);
1461 sbf = mp->m_sb.sb_qflags;
1462 mp->m_sb.sb_qflags = mp->m_qflags & XFS_MOUNT_QUOTA_ALL;
1463 spin_unlock(&mp->m_sb_lock);
1464
1465 if (sbf != (mp->m_qflags & XFS_MOUNT_QUOTA_ALL)) {
1466 if (xfs_sync_sb(mp, false)) {
1467
1468
1469
1470
1471
1472
1473 ASSERT(!(XFS_IS_QUOTA_ON(mp)));
1474 xfs_alert(mp, "%s: Superblock update failed!",
1475 __func__);
1476 }
1477 }
1478
1479 if (error) {
1480 xfs_warn(mp, "Failed to initialize disk quotas.");
1481 return;
1482 }
1483 }
1484
1485
1486
1487
1488
1489 STATIC int
1490 xfs_qm_init_quotainos(
1491 xfs_mount_t *mp)
1492 {
1493 struct xfs_inode *uip = NULL;
1494 struct xfs_inode *gip = NULL;
1495 struct xfs_inode *pip = NULL;
1496 int error;
1497 uint flags = 0;
1498
1499 ASSERT(mp->m_quotainfo);
1500
1501
1502
1503
1504 if (xfs_has_quota(mp)) {
1505 if (XFS_IS_UQUOTA_ON(mp) &&
1506 mp->m_sb.sb_uquotino != NULLFSINO) {
1507 ASSERT(mp->m_sb.sb_uquotino > 0);
1508 error = xfs_iget(mp, NULL, mp->m_sb.sb_uquotino,
1509 0, 0, &uip);
1510 if (error)
1511 return error;
1512 }
1513 if (XFS_IS_GQUOTA_ON(mp) &&
1514 mp->m_sb.sb_gquotino != NULLFSINO) {
1515 ASSERT(mp->m_sb.sb_gquotino > 0);
1516 error = xfs_iget(mp, NULL, mp->m_sb.sb_gquotino,
1517 0, 0, &gip);
1518 if (error)
1519 goto error_rele;
1520 }
1521 if (XFS_IS_PQUOTA_ON(mp) &&
1522 mp->m_sb.sb_pquotino != NULLFSINO) {
1523 ASSERT(mp->m_sb.sb_pquotino > 0);
1524 error = xfs_iget(mp, NULL, mp->m_sb.sb_pquotino,
1525 0, 0, &pip);
1526 if (error)
1527 goto error_rele;
1528 }
1529 } else {
1530 flags |= XFS_QMOPT_SBVERSION;
1531 }
1532
1533
1534
1535
1536
1537
1538
1539 if (XFS_IS_UQUOTA_ON(mp) && uip == NULL) {
1540 error = xfs_qm_qino_alloc(mp, &uip,
1541 flags | XFS_QMOPT_UQUOTA);
1542 if (error)
1543 goto error_rele;
1544
1545 flags &= ~XFS_QMOPT_SBVERSION;
1546 }
1547 if (XFS_IS_GQUOTA_ON(mp) && gip == NULL) {
1548 error = xfs_qm_qino_alloc(mp, &gip,
1549 flags | XFS_QMOPT_GQUOTA);
1550 if (error)
1551 goto error_rele;
1552
1553 flags &= ~XFS_QMOPT_SBVERSION;
1554 }
1555 if (XFS_IS_PQUOTA_ON(mp) && pip == NULL) {
1556 error = xfs_qm_qino_alloc(mp, &pip,
1557 flags | XFS_QMOPT_PQUOTA);
1558 if (error)
1559 goto error_rele;
1560 }
1561
1562 mp->m_quotainfo->qi_uquotaip = uip;
1563 mp->m_quotainfo->qi_gquotaip = gip;
1564 mp->m_quotainfo->qi_pquotaip = pip;
1565
1566 return 0;
1567
1568 error_rele:
1569 if (uip)
1570 xfs_irele(uip);
1571 if (gip)
1572 xfs_irele(gip);
1573 if (pip)
1574 xfs_irele(pip);
1575 return error;
1576 }
1577
1578 STATIC void
1579 xfs_qm_destroy_quotainos(
1580 struct xfs_quotainfo *qi)
1581 {
1582 if (qi->qi_uquotaip) {
1583 xfs_irele(qi->qi_uquotaip);
1584 qi->qi_uquotaip = NULL;
1585 }
1586 if (qi->qi_gquotaip) {
1587 xfs_irele(qi->qi_gquotaip);
1588 qi->qi_gquotaip = NULL;
1589 }
1590 if (qi->qi_pquotaip) {
1591 xfs_irele(qi->qi_pquotaip);
1592 qi->qi_pquotaip = NULL;
1593 }
1594 }
1595
1596 STATIC void
1597 xfs_qm_dqfree_one(
1598 struct xfs_dquot *dqp)
1599 {
1600 struct xfs_mount *mp = dqp->q_mount;
1601 struct xfs_quotainfo *qi = mp->m_quotainfo;
1602
1603 mutex_lock(&qi->qi_tree_lock);
1604 radix_tree_delete(xfs_dquot_tree(qi, xfs_dquot_type(dqp)), dqp->q_id);
1605
1606 qi->qi_dquots--;
1607 mutex_unlock(&qi->qi_tree_lock);
1608
1609 xfs_qm_dqdestroy(dqp);
1610 }
1611
1612
1613
1614
1615
1616
1617
1618
1619
1620
1621
1622
1623
1624
1625 int
1626 xfs_qm_vop_dqalloc(
1627 struct xfs_inode *ip,
1628 kuid_t uid,
1629 kgid_t gid,
1630 prid_t prid,
1631 uint flags,
1632 struct xfs_dquot **O_udqpp,
1633 struct xfs_dquot **O_gdqpp,
1634 struct xfs_dquot **O_pdqpp)
1635 {
1636 struct xfs_mount *mp = ip->i_mount;
1637 struct inode *inode = VFS_I(ip);
1638 struct user_namespace *user_ns = inode->i_sb->s_user_ns;
1639 struct xfs_dquot *uq = NULL;
1640 struct xfs_dquot *gq = NULL;
1641 struct xfs_dquot *pq = NULL;
1642 int error;
1643 uint lockflags;
1644
1645 if (!XFS_IS_QUOTA_ON(mp))
1646 return 0;
1647
1648 lockflags = XFS_ILOCK_EXCL;
1649 xfs_ilock(ip, lockflags);
1650
1651 if ((flags & XFS_QMOPT_INHERIT) && XFS_INHERIT_GID(ip))
1652 gid = inode->i_gid;
1653
1654
1655
1656
1657
1658 if (XFS_NOT_DQATTACHED(mp, ip)) {
1659 error = xfs_qm_dqattach_locked(ip, true);
1660 if (error) {
1661 xfs_iunlock(ip, lockflags);
1662 return error;
1663 }
1664 }
1665
1666 if ((flags & XFS_QMOPT_UQUOTA) && XFS_IS_UQUOTA_ON(mp)) {
1667 ASSERT(O_udqpp);
1668 if (!uid_eq(inode->i_uid, uid)) {
1669
1670
1671
1672
1673
1674
1675
1676
1677
1678 xfs_iunlock(ip, lockflags);
1679 error = xfs_qm_dqget(mp, from_kuid(user_ns, uid),
1680 XFS_DQTYPE_USER, true, &uq);
1681 if (error) {
1682 ASSERT(error != -ENOENT);
1683 return error;
1684 }
1685
1686
1687
1688 xfs_dqunlock(uq);
1689 lockflags = XFS_ILOCK_SHARED;
1690 xfs_ilock(ip, lockflags);
1691 } else {
1692
1693
1694
1695
1696 ASSERT(ip->i_udquot);
1697 uq = xfs_qm_dqhold(ip->i_udquot);
1698 }
1699 }
1700 if ((flags & XFS_QMOPT_GQUOTA) && XFS_IS_GQUOTA_ON(mp)) {
1701 ASSERT(O_gdqpp);
1702 if (!gid_eq(inode->i_gid, gid)) {
1703 xfs_iunlock(ip, lockflags);
1704 error = xfs_qm_dqget(mp, from_kgid(user_ns, gid),
1705 XFS_DQTYPE_GROUP, true, &gq);
1706 if (error) {
1707 ASSERT(error != -ENOENT);
1708 goto error_rele;
1709 }
1710 xfs_dqunlock(gq);
1711 lockflags = XFS_ILOCK_SHARED;
1712 xfs_ilock(ip, lockflags);
1713 } else {
1714 ASSERT(ip->i_gdquot);
1715 gq = xfs_qm_dqhold(ip->i_gdquot);
1716 }
1717 }
1718 if ((flags & XFS_QMOPT_PQUOTA) && XFS_IS_PQUOTA_ON(mp)) {
1719 ASSERT(O_pdqpp);
1720 if (ip->i_projid != prid) {
1721 xfs_iunlock(ip, lockflags);
1722 error = xfs_qm_dqget(mp, prid,
1723 XFS_DQTYPE_PROJ, true, &pq);
1724 if (error) {
1725 ASSERT(error != -ENOENT);
1726 goto error_rele;
1727 }
1728 xfs_dqunlock(pq);
1729 lockflags = XFS_ILOCK_SHARED;
1730 xfs_ilock(ip, lockflags);
1731 } else {
1732 ASSERT(ip->i_pdquot);
1733 pq = xfs_qm_dqhold(ip->i_pdquot);
1734 }
1735 }
1736 trace_xfs_dquot_dqalloc(ip);
1737
1738 xfs_iunlock(ip, lockflags);
1739 if (O_udqpp)
1740 *O_udqpp = uq;
1741 else
1742 xfs_qm_dqrele(uq);
1743 if (O_gdqpp)
1744 *O_gdqpp = gq;
1745 else
1746 xfs_qm_dqrele(gq);
1747 if (O_pdqpp)
1748 *O_pdqpp = pq;
1749 else
1750 xfs_qm_dqrele(pq);
1751 return 0;
1752
1753 error_rele:
1754 xfs_qm_dqrele(gq);
1755 xfs_qm_dqrele(uq);
1756 return error;
1757 }
1758
1759
1760
1761
1762
1763 struct xfs_dquot *
1764 xfs_qm_vop_chown(
1765 struct xfs_trans *tp,
1766 struct xfs_inode *ip,
1767 struct xfs_dquot **IO_olddq,
1768 struct xfs_dquot *newdq)
1769 {
1770 struct xfs_dquot *prevdq;
1771 uint bfield = XFS_IS_REALTIME_INODE(ip) ?
1772 XFS_TRANS_DQ_RTBCOUNT : XFS_TRANS_DQ_BCOUNT;
1773
1774
1775 ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL));
1776 ASSERT(XFS_IS_QUOTA_ON(ip->i_mount));
1777
1778
1779 prevdq = *IO_olddq;
1780 ASSERT(prevdq);
1781 ASSERT(prevdq != newdq);
1782
1783 xfs_trans_mod_dquot(tp, prevdq, bfield, -(ip->i_nblocks));
1784 xfs_trans_mod_dquot(tp, prevdq, XFS_TRANS_DQ_ICOUNT, -1);
1785
1786
1787 xfs_trans_mod_dquot(tp, newdq, bfield, ip->i_nblocks);
1788 xfs_trans_mod_dquot(tp, newdq, XFS_TRANS_DQ_ICOUNT, 1);
1789
1790
1791
1792
1793
1794
1795
1796
1797 xfs_trans_mod_dquot(tp, newdq, XFS_TRANS_DQ_RES_BLKS,
1798 -ip->i_delayed_blks);
1799
1800
1801
1802
1803
1804
1805
1806
1807 tp->t_flags |= XFS_TRANS_DIRTY;
1808 xfs_dqlock(prevdq);
1809 ASSERT(prevdq->q_blk.reserved >= ip->i_delayed_blks);
1810 prevdq->q_blk.reserved -= ip->i_delayed_blks;
1811 xfs_dqunlock(prevdq);
1812
1813
1814
1815
1816
1817 *IO_olddq = xfs_qm_dqhold(newdq);
1818
1819 return prevdq;
1820 }
1821
1822 int
1823 xfs_qm_vop_rename_dqattach(
1824 struct xfs_inode **i_tab)
1825 {
1826 struct xfs_mount *mp = i_tab[0]->i_mount;
1827 int i;
1828
1829 if (!XFS_IS_QUOTA_ON(mp))
1830 return 0;
1831
1832 for (i = 0; (i < 4 && i_tab[i]); i++) {
1833 struct xfs_inode *ip = i_tab[i];
1834 int error;
1835
1836
1837
1838
1839 if (i == 0 || ip != i_tab[i-1]) {
1840 if (XFS_NOT_DQATTACHED(mp, ip)) {
1841 error = xfs_qm_dqattach(ip);
1842 if (error)
1843 return error;
1844 }
1845 }
1846 }
1847 return 0;
1848 }
1849
1850 void
1851 xfs_qm_vop_create_dqattach(
1852 struct xfs_trans *tp,
1853 struct xfs_inode *ip,
1854 struct xfs_dquot *udqp,
1855 struct xfs_dquot *gdqp,
1856 struct xfs_dquot *pdqp)
1857 {
1858 struct xfs_mount *mp = tp->t_mountp;
1859
1860 if (!XFS_IS_QUOTA_ON(mp))
1861 return;
1862
1863 ASSERT(xfs_isilocked(ip, XFS_ILOCK_EXCL));
1864
1865 if (udqp && XFS_IS_UQUOTA_ON(mp)) {
1866 ASSERT(ip->i_udquot == NULL);
1867 ASSERT(i_uid_read(VFS_I(ip)) == udqp->q_id);
1868
1869 ip->i_udquot = xfs_qm_dqhold(udqp);
1870 xfs_trans_mod_dquot(tp, udqp, XFS_TRANS_DQ_ICOUNT, 1);
1871 }
1872 if (gdqp && XFS_IS_GQUOTA_ON(mp)) {
1873 ASSERT(ip->i_gdquot == NULL);
1874 ASSERT(i_gid_read(VFS_I(ip)) == gdqp->q_id);
1875
1876 ip->i_gdquot = xfs_qm_dqhold(gdqp);
1877 xfs_trans_mod_dquot(tp, gdqp, XFS_TRANS_DQ_ICOUNT, 1);
1878 }
1879 if (pdqp && XFS_IS_PQUOTA_ON(mp)) {
1880 ASSERT(ip->i_pdquot == NULL);
1881 ASSERT(ip->i_projid == pdqp->q_id);
1882
1883 ip->i_pdquot = xfs_qm_dqhold(pdqp);
1884 xfs_trans_mod_dquot(tp, pdqp, XFS_TRANS_DQ_ICOUNT, 1);
1885 }
1886 }
1887
1888
1889 bool
1890 xfs_inode_near_dquot_enforcement(
1891 struct xfs_inode *ip,
1892 xfs_dqtype_t type)
1893 {
1894 struct xfs_dquot *dqp;
1895 int64_t freesp;
1896
1897
1898 dqp = xfs_inode_dquot(ip, type);
1899 if (!dqp || !xfs_dquot_is_enforced(dqp))
1900 return false;
1901
1902 if (xfs_dquot_res_over_limits(&dqp->q_ino) ||
1903 xfs_dquot_res_over_limits(&dqp->q_rtb))
1904 return true;
1905
1906
1907 if (!dqp->q_prealloc_hi_wmark)
1908 return false;
1909
1910 if (dqp->q_blk.reserved < dqp->q_prealloc_lo_wmark)
1911 return false;
1912
1913 if (dqp->q_blk.reserved >= dqp->q_prealloc_hi_wmark)
1914 return true;
1915
1916 freesp = dqp->q_prealloc_hi_wmark - dqp->q_blk.reserved;
1917 if (freesp < dqp->q_low_space[XFS_QLOWSP_5_PCNT])
1918 return true;
1919
1920 return false;
1921 }