Commit e850301f authored by Eric Sandeen's avatar Eric Sandeen Committed by Darrick J. Wong

xfs: per-type quota timers and warn limits

Move timers and warnings out of xfs_quotainfo and into xfs_def_quota
so that we can utilize them on a per-type basis, rather than enforcing
them based on the values found in the first enabled quota type.
Signed-off-by: default avatarEric Sandeen <sandeen@redhat.com>
[zlang: new way to get defquota in xfs_qm_init_timelimits]
[zlang: remove redundant defq assign]
Signed-off-by: default avatarZorro Lang <zlang@redhat.com>
Signed-off-by: default avatarEric Sandeen <sandeen@redhat.com>
Reviewed-by: default avatarChristoph Hellwig <hch@lst.de>
Reviewed-by: default avatarDarrick J. Wong <darrick.wong@oracle.com>
Signed-off-by: default avatarDarrick J. Wong <darrick.wong@oracle.com>
parent ce6e7e79
...@@ -116,8 +116,12 @@ xfs_qm_adjust_dqtimers( ...@@ -116,8 +116,12 @@ xfs_qm_adjust_dqtimers(
struct xfs_mount *mp, struct xfs_mount *mp,
struct xfs_dquot *dq) struct xfs_dquot *dq)
{ {
struct xfs_quotainfo *qi = mp->m_quotainfo;
struct xfs_disk_dquot *d = &dq->q_core; struct xfs_disk_dquot *d = &dq->q_core;
struct xfs_def_quota *defq;
ASSERT(d->d_id); ASSERT(d->d_id);
defq = xfs_get_defquota(qi, xfs_dquot_type(dq));
#ifdef DEBUG #ifdef DEBUG
if (d->d_blk_hardlimit) if (d->d_blk_hardlimit)
...@@ -139,7 +143,7 @@ xfs_qm_adjust_dqtimers( ...@@ -139,7 +143,7 @@ xfs_qm_adjust_dqtimers(
(be64_to_cpu(d->d_bcount) > (be64_to_cpu(d->d_bcount) >
be64_to_cpu(d->d_blk_hardlimit)))) { be64_to_cpu(d->d_blk_hardlimit)))) {
d->d_btimer = cpu_to_be32(ktime_get_real_seconds() + d->d_btimer = cpu_to_be32(ktime_get_real_seconds() +
mp->m_quotainfo->qi_btimelimit); defq->btimelimit);
} else { } else {
d->d_bwarns = 0; d->d_bwarns = 0;
} }
...@@ -162,7 +166,7 @@ xfs_qm_adjust_dqtimers( ...@@ -162,7 +166,7 @@ xfs_qm_adjust_dqtimers(
(be64_to_cpu(d->d_icount) > (be64_to_cpu(d->d_icount) >
be64_to_cpu(d->d_ino_hardlimit)))) { be64_to_cpu(d->d_ino_hardlimit)))) {
d->d_itimer = cpu_to_be32(ktime_get_real_seconds() + d->d_itimer = cpu_to_be32(ktime_get_real_seconds() +
mp->m_quotainfo->qi_itimelimit); defq->itimelimit);
} else { } else {
d->d_iwarns = 0; d->d_iwarns = 0;
} }
...@@ -185,7 +189,7 @@ xfs_qm_adjust_dqtimers( ...@@ -185,7 +189,7 @@ xfs_qm_adjust_dqtimers(
(be64_to_cpu(d->d_rtbcount) > (be64_to_cpu(d->d_rtbcount) >
be64_to_cpu(d->d_rtb_hardlimit)))) { be64_to_cpu(d->d_rtb_hardlimit)))) {
d->d_rtbtimer = cpu_to_be32(ktime_get_real_seconds() + d->d_rtbtimer = cpu_to_be32(ktime_get_real_seconds() +
mp->m_quotainfo->qi_rtbtimelimit); defq->rtbtimelimit);
} else { } else {
d->d_rtbwarns = 0; d->d_rtbwarns = 0;
} }
......
...@@ -577,19 +577,22 @@ xfs_qm_set_defquota( ...@@ -577,19 +577,22 @@ xfs_qm_set_defquota(
static void static void
xfs_qm_init_timelimits( xfs_qm_init_timelimits(
struct xfs_mount *mp, struct xfs_mount *mp,
struct xfs_quotainfo *qinf) uint type)
{ {
struct xfs_quotainfo *qinf = mp->m_quotainfo;
struct xfs_def_quota *defq;
struct xfs_disk_dquot *ddqp; struct xfs_disk_dquot *ddqp;
struct xfs_dquot *dqp; struct xfs_dquot *dqp;
uint type;
int error; int error;
qinf->qi_btimelimit = XFS_QM_BTIMELIMIT; defq = xfs_get_defquota(qinf, type);
qinf->qi_itimelimit = XFS_QM_ITIMELIMIT;
qinf->qi_rtbtimelimit = XFS_QM_RTBTIMELIMIT; defq->btimelimit = XFS_QM_BTIMELIMIT;
qinf->qi_bwarnlimit = XFS_QM_BWARNLIMIT; defq->itimelimit = XFS_QM_ITIMELIMIT;
qinf->qi_iwarnlimit = XFS_QM_IWARNLIMIT; defq->rtbtimelimit = XFS_QM_RTBTIMELIMIT;
qinf->qi_rtbwarnlimit = XFS_QM_RTBWARNLIMIT; defq->bwarnlimit = XFS_QM_BWARNLIMIT;
defq->iwarnlimit = XFS_QM_IWARNLIMIT;
defq->rtbwarnlimit = XFS_QM_RTBWARNLIMIT;
/* /*
* We try to get the limits from the superuser's limits fields. * We try to get the limits from the superuser's limits fields.
...@@ -597,39 +600,30 @@ xfs_qm_init_timelimits( ...@@ -597,39 +600,30 @@ xfs_qm_init_timelimits(
* *
* Since we may not have done a quotacheck by this point, just read * Since we may not have done a quotacheck by this point, just read
* the dquot without attaching it to any hashtables or lists. * the dquot without attaching it to any hashtables or lists.
*
* Timers and warnings are globally set by the first timer found in
* user/group/proj quota types, otherwise a default value is used.
* This should be split into different fields per quota type.
*/ */
if (XFS_IS_UQUOTA_RUNNING(mp))
type = XFS_DQ_USER;
else if (XFS_IS_GQUOTA_RUNNING(mp))
type = XFS_DQ_GROUP;
else
type = XFS_DQ_PROJ;
error = xfs_qm_dqget_uncached(mp, 0, type, &dqp); error = xfs_qm_dqget_uncached(mp, 0, type, &dqp);
if (error) if (error)
return; return;
ddqp = &dqp->q_core; ddqp = &dqp->q_core;
/* /*
* The warnings and timers set the grace period given to * The warnings and timers set the grace period given to
* a user or group before he or she can not perform any * a user or group before he or she can not perform any
* more writing. If it is zero, a default is used. * more writing. If it is zero, a default is used.
*/ */
if (ddqp->d_btimer) if (ddqp->d_btimer)
qinf->qi_btimelimit = be32_to_cpu(ddqp->d_btimer); defq->btimelimit = be32_to_cpu(ddqp->d_btimer);
if (ddqp->d_itimer) if (ddqp->d_itimer)
qinf->qi_itimelimit = be32_to_cpu(ddqp->d_itimer); defq->itimelimit = be32_to_cpu(ddqp->d_itimer);
if (ddqp->d_rtbtimer) if (ddqp->d_rtbtimer)
qinf->qi_rtbtimelimit = be32_to_cpu(ddqp->d_rtbtimer); defq->rtbtimelimit = be32_to_cpu(ddqp->d_rtbtimer);
if (ddqp->d_bwarns) if (ddqp->d_bwarns)
qinf->qi_bwarnlimit = be16_to_cpu(ddqp->d_bwarns); defq->bwarnlimit = be16_to_cpu(ddqp->d_bwarns);
if (ddqp->d_iwarns) if (ddqp->d_iwarns)
qinf->qi_iwarnlimit = be16_to_cpu(ddqp->d_iwarns); defq->iwarnlimit = be16_to_cpu(ddqp->d_iwarns);
if (ddqp->d_rtbwarns) if (ddqp->d_rtbwarns)
qinf->qi_rtbwarnlimit = be16_to_cpu(ddqp->d_rtbwarns); defq->rtbwarnlimit = be16_to_cpu(ddqp->d_rtbwarns);
xfs_qm_dqdestroy(dqp); xfs_qm_dqdestroy(dqp);
} }
...@@ -675,7 +669,9 @@ xfs_qm_init_quotainfo( ...@@ -675,7 +669,9 @@ xfs_qm_init_quotainfo(
mp->m_qflags |= (mp->m_sb.sb_qflags & XFS_ALL_QUOTA_CHKD); mp->m_qflags |= (mp->m_sb.sb_qflags & XFS_ALL_QUOTA_CHKD);
xfs_qm_init_timelimits(mp, qinf); xfs_qm_init_timelimits(mp, XFS_DQ_USER);
xfs_qm_init_timelimits(mp, XFS_DQ_GROUP);
xfs_qm_init_timelimits(mp, XFS_DQ_PROJ);
if (XFS_IS_UQUOTA_RUNNING(mp)) if (XFS_IS_UQUOTA_RUNNING(mp))
xfs_qm_set_defquota(mp, XFS_DQ_USER, qinf); xfs_qm_set_defquota(mp, XFS_DQ_USER, qinf);
......
...@@ -41,7 +41,14 @@ extern struct kmem_zone *xfs_qm_dqtrxzone; ...@@ -41,7 +41,14 @@ extern struct kmem_zone *xfs_qm_dqtrxzone;
*/ */
#define XFS_DQUOT_CLUSTER_SIZE_FSB (xfs_filblks_t)1 #define XFS_DQUOT_CLUSTER_SIZE_FSB (xfs_filblks_t)1
/* Defaults for each quota type: time limits, warn limits, usage limits */
struct xfs_def_quota { struct xfs_def_quota {
time64_t btimelimit; /* limit for blks timer */
time64_t itimelimit; /* limit for inodes timer */
time64_t rtbtimelimit; /* limit for rt blks timer */
xfs_qwarncnt_t bwarnlimit; /* limit for blks warnings */
xfs_qwarncnt_t iwarnlimit; /* limit for inodes warnings */
xfs_qwarncnt_t rtbwarnlimit; /* limit for rt blks warnings */
xfs_qcnt_t bhardlimit; /* default data blk hard limit */ xfs_qcnt_t bhardlimit; /* default data blk hard limit */
xfs_qcnt_t bsoftlimit; /* default data blk soft limit */ xfs_qcnt_t bsoftlimit; /* default data blk soft limit */
xfs_qcnt_t ihardlimit; /* default inode count hard limit */ xfs_qcnt_t ihardlimit; /* default inode count hard limit */
...@@ -64,12 +71,6 @@ struct xfs_quotainfo { ...@@ -64,12 +71,6 @@ struct xfs_quotainfo {
struct xfs_inode *qi_pquotaip; /* project quota inode */ struct xfs_inode *qi_pquotaip; /* project quota inode */
struct list_lru qi_lru; struct list_lru qi_lru;
int qi_dquots; int qi_dquots;
time64_t qi_btimelimit; /* limit for blks timer */
time64_t qi_itimelimit; /* limit for inodes timer */
time64_t qi_rtbtimelimit;/* limit for rt blks timer */
xfs_qwarncnt_t qi_bwarnlimit; /* limit for blks warnings */
xfs_qwarncnt_t qi_iwarnlimit; /* limit for inodes warnings */
xfs_qwarncnt_t qi_rtbwarnlimit;/* limit for rt blks warnings */
struct mutex qi_quotaofflock;/* to serialize quotaoff */ struct mutex qi_quotaofflock;/* to serialize quotaoff */
xfs_filblks_t qi_dqchunklen; /* # BBs in a chunk of dqs */ xfs_filblks_t qi_dqchunklen; /* # BBs in a chunk of dqs */
uint qi_dqperchunk; /* # ondisk dq in above chunk */ uint qi_dqperchunk; /* # ondisk dq in above chunk */
......
...@@ -563,23 +563,23 @@ xfs_qm_scall_setqlim( ...@@ -563,23 +563,23 @@ xfs_qm_scall_setqlim(
* for warnings. * for warnings.
*/ */
if (newlim->d_fieldmask & QC_SPC_TIMER) { if (newlim->d_fieldmask & QC_SPC_TIMER) {
q->qi_btimelimit = newlim->d_spc_timer; defq->btimelimit = newlim->d_spc_timer;
ddq->d_btimer = cpu_to_be32(newlim->d_spc_timer); ddq->d_btimer = cpu_to_be32(newlim->d_spc_timer);
} }
if (newlim->d_fieldmask & QC_INO_TIMER) { if (newlim->d_fieldmask & QC_INO_TIMER) {
q->qi_itimelimit = newlim->d_ino_timer; defq->itimelimit = newlim->d_ino_timer;
ddq->d_itimer = cpu_to_be32(newlim->d_ino_timer); ddq->d_itimer = cpu_to_be32(newlim->d_ino_timer);
} }
if (newlim->d_fieldmask & QC_RT_SPC_TIMER) { if (newlim->d_fieldmask & QC_RT_SPC_TIMER) {
q->qi_rtbtimelimit = newlim->d_rt_spc_timer; defq->rtbtimelimit = newlim->d_rt_spc_timer;
ddq->d_rtbtimer = cpu_to_be32(newlim->d_rt_spc_timer); ddq->d_rtbtimer = cpu_to_be32(newlim->d_rt_spc_timer);
} }
if (newlim->d_fieldmask & QC_SPC_WARNS) if (newlim->d_fieldmask & QC_SPC_WARNS)
q->qi_bwarnlimit = newlim->d_spc_warns; defq->bwarnlimit = newlim->d_spc_warns;
if (newlim->d_fieldmask & QC_INO_WARNS) if (newlim->d_fieldmask & QC_INO_WARNS)
q->qi_iwarnlimit = newlim->d_ino_warns; defq->iwarnlimit = newlim->d_ino_warns;
if (newlim->d_fieldmask & QC_RT_SPC_WARNS) if (newlim->d_fieldmask & QC_RT_SPC_WARNS)
q->qi_rtbwarnlimit = newlim->d_rt_spc_warns; defq->rtbwarnlimit = newlim->d_rt_spc_warns;
} else { } else {
/* /*
* If the user is now over quota, start the timelimit. * If the user is now over quota, start the timelimit.
......
...@@ -21,9 +21,9 @@ xfs_qm_fill_state( ...@@ -21,9 +21,9 @@ xfs_qm_fill_state(
struct qc_type_state *tstate, struct qc_type_state *tstate,
struct xfs_mount *mp, struct xfs_mount *mp,
struct xfs_inode *ip, struct xfs_inode *ip,
xfs_ino_t ino) xfs_ino_t ino,
struct xfs_def_quota *defq)
{ {
struct xfs_quotainfo *q = mp->m_quotainfo;
bool tempqip = false; bool tempqip = false;
tstate->ino = ino; tstate->ino = ino;
...@@ -37,12 +37,12 @@ xfs_qm_fill_state( ...@@ -37,12 +37,12 @@ xfs_qm_fill_state(
tstate->flags |= QCI_SYSFILE; tstate->flags |= QCI_SYSFILE;
tstate->blocks = ip->i_d.di_nblocks; tstate->blocks = ip->i_d.di_nblocks;
tstate->nextents = ip->i_df.if_nextents; tstate->nextents = ip->i_df.if_nextents;
tstate->spc_timelimit = (u32)q->qi_btimelimit; tstate->spc_timelimit = (u32)defq->btimelimit;
tstate->ino_timelimit = (u32)q->qi_itimelimit; tstate->ino_timelimit = (u32)defq->itimelimit;
tstate->rt_spc_timelimit = (u32)q->qi_rtbtimelimit; tstate->rt_spc_timelimit = (u32)defq->rtbtimelimit;
tstate->spc_warnlimit = q->qi_bwarnlimit; tstate->spc_warnlimit = defq->bwarnlimit;
tstate->ino_warnlimit = q->qi_iwarnlimit; tstate->ino_warnlimit = defq->iwarnlimit;
tstate->rt_spc_warnlimit = q->qi_rtbwarnlimit; tstate->rt_spc_warnlimit = defq->rtbwarnlimit;
if (tempqip) if (tempqip)
xfs_irele(ip); xfs_irele(ip);
} }
...@@ -77,11 +77,11 @@ xfs_fs_get_quota_state( ...@@ -77,11 +77,11 @@ xfs_fs_get_quota_state(
state->s_state[PRJQUOTA].flags |= QCI_LIMITS_ENFORCED; state->s_state[PRJQUOTA].flags |= QCI_LIMITS_ENFORCED;
xfs_qm_fill_state(&state->s_state[USRQUOTA], mp, q->qi_uquotaip, xfs_qm_fill_state(&state->s_state[USRQUOTA], mp, q->qi_uquotaip,
mp->m_sb.sb_uquotino); mp->m_sb.sb_uquotino, &q->qi_usr_default);
xfs_qm_fill_state(&state->s_state[GRPQUOTA], mp, q->qi_gquotaip, xfs_qm_fill_state(&state->s_state[GRPQUOTA], mp, q->qi_gquotaip,
mp->m_sb.sb_gquotino); mp->m_sb.sb_gquotino, &q->qi_grp_default);
xfs_qm_fill_state(&state->s_state[PRJQUOTA], mp, q->qi_pquotaip, xfs_qm_fill_state(&state->s_state[PRJQUOTA], mp, q->qi_pquotaip,
mp->m_sb.sb_pquotino); mp->m_sb.sb_pquotino, &q->qi_prj_default);
return 0; return 0;
} }
......
...@@ -602,7 +602,7 @@ xfs_trans_dqresv( ...@@ -602,7 +602,7 @@ xfs_trans_dqresv(
softlimit = defq->bsoftlimit; softlimit = defq->bsoftlimit;
timer = be32_to_cpu(dqp->q_core.d_btimer); timer = be32_to_cpu(dqp->q_core.d_btimer);
warns = be16_to_cpu(dqp->q_core.d_bwarns); warns = be16_to_cpu(dqp->q_core.d_bwarns);
warnlimit = dqp->q_mount->m_quotainfo->qi_bwarnlimit; warnlimit = defq->bwarnlimit;
resbcountp = &dqp->q_res_bcount; resbcountp = &dqp->q_res_bcount;
} else { } else {
ASSERT(flags & XFS_TRANS_DQ_RES_RTBLKS); ASSERT(flags & XFS_TRANS_DQ_RES_RTBLKS);
...@@ -614,7 +614,7 @@ xfs_trans_dqresv( ...@@ -614,7 +614,7 @@ xfs_trans_dqresv(
softlimit = defq->rtbsoftlimit; softlimit = defq->rtbsoftlimit;
timer = be32_to_cpu(dqp->q_core.d_rtbtimer); timer = be32_to_cpu(dqp->q_core.d_rtbtimer);
warns = be16_to_cpu(dqp->q_core.d_rtbwarns); warns = be16_to_cpu(dqp->q_core.d_rtbwarns);
warnlimit = dqp->q_mount->m_quotainfo->qi_rtbwarnlimit; warnlimit = defq->rtbwarnlimit;
resbcountp = &dqp->q_res_rtbcount; resbcountp = &dqp->q_res_rtbcount;
} }
...@@ -650,7 +650,7 @@ xfs_trans_dqresv( ...@@ -650,7 +650,7 @@ xfs_trans_dqresv(
total_count = be64_to_cpu(dqp->q_core.d_icount) + ninos; total_count = be64_to_cpu(dqp->q_core.d_icount) + ninos;
timer = be32_to_cpu(dqp->q_core.d_itimer); timer = be32_to_cpu(dqp->q_core.d_itimer);
warns = be16_to_cpu(dqp->q_core.d_iwarns); warns = be16_to_cpu(dqp->q_core.d_iwarns);
warnlimit = dqp->q_mount->m_quotainfo->qi_iwarnlimit; warnlimit = defq->iwarnlimit;
hardlimit = be64_to_cpu(dqp->q_core.d_ino_hardlimit); hardlimit = be64_to_cpu(dqp->q_core.d_ino_hardlimit);
if (!hardlimit) if (!hardlimit)
hardlimit = defq->ihardlimit; hardlimit = defq->ihardlimit;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment