Commit 9a8ae30e authored by Jan Kara's avatar Jan Kara

quota: Push dqio_sem down to ->write_file_info()

Push down acquisition of dqio_sem into ->write_file_info() callback.
Mostly for consistency with other operations.
Reviewed-by: default avatarAndreas Dilger <adilger@dilger.ca>
Signed-off-by: default avatarJan Kara <jack@suse.cz>
parent f14618c6
...@@ -443,13 +443,17 @@ static int __ocfs2_global_write_info(struct super_block *sb, int type) ...@@ -443,13 +443,17 @@ static int __ocfs2_global_write_info(struct super_block *sb, int type)
int ocfs2_global_write_info(struct super_block *sb, int type) int ocfs2_global_write_info(struct super_block *sb, int type)
{ {
int err; int err;
struct ocfs2_mem_dqinfo *info = sb_dqinfo(sb, type)->dqi_priv; struct quota_info *dqopt = sb_dqopt(sb);
struct ocfs2_mem_dqinfo *info = dqopt->info[type].dqi_priv;
down_write(&dqopt->dqio_sem);
err = ocfs2_qinfo_lock(info, 1); err = ocfs2_qinfo_lock(info, 1);
if (err < 0) if (err < 0)
return err; goto out_sem;
err = __ocfs2_global_write_info(sb, type); err = __ocfs2_global_write_info(sb, type);
ocfs2_qinfo_unlock(info, 1); ocfs2_qinfo_unlock(info, 1);
out_sem:
up_write(&dqopt->dqio_sem);
return err; return err;
} }
......
...@@ -415,10 +415,8 @@ int dquot_acquire(struct dquot *dquot) ...@@ -415,10 +415,8 @@ int dquot_acquire(struct dquot *dquot)
ret = dqopt->ops[dquot->dq_id.type]->commit_dqblk(dquot); ret = dqopt->ops[dquot->dq_id.type]->commit_dqblk(dquot);
/* Write the info if needed */ /* Write the info if needed */
if (info_dirty(&dqopt->info[dquot->dq_id.type])) { if (info_dirty(&dqopt->info[dquot->dq_id.type])) {
down_write(&dqopt->dqio_sem);
ret2 = dqopt->ops[dquot->dq_id.type]->write_file_info( ret2 = dqopt->ops[dquot->dq_id.type]->write_file_info(
dquot->dq_sb, dquot->dq_id.type); dquot->dq_sb, dquot->dq_id.type);
up_write(&dqopt->dqio_sem);
} }
if (ret < 0) if (ret < 0)
goto out_iolock; goto out_iolock;
...@@ -482,10 +480,8 @@ int dquot_release(struct dquot *dquot) ...@@ -482,10 +480,8 @@ int dquot_release(struct dquot *dquot)
ret = dqopt->ops[dquot->dq_id.type]->release_dqblk(dquot); ret = dqopt->ops[dquot->dq_id.type]->release_dqblk(dquot);
/* Write the info */ /* Write the info */
if (info_dirty(&dqopt->info[dquot->dq_id.type])) { if (info_dirty(&dqopt->info[dquot->dq_id.type])) {
down_write(&dqopt->dqio_sem);
ret2 = dqopt->ops[dquot->dq_id.type]->write_file_info( ret2 = dqopt->ops[dquot->dq_id.type]->write_file_info(
dquot->dq_sb, dquot->dq_id.type); dquot->dq_sb, dquot->dq_id.type);
up_write(&dqopt->dqio_sem);
} }
if (ret >= 0) if (ret >= 0)
ret = ret2; ret = ret2;
...@@ -2054,13 +2050,9 @@ EXPORT_SYMBOL(dquot_transfer); ...@@ -2054,13 +2050,9 @@ EXPORT_SYMBOL(dquot_transfer);
*/ */
int dquot_commit_info(struct super_block *sb, int type) int dquot_commit_info(struct super_block *sb, int type)
{ {
int ret;
struct quota_info *dqopt = sb_dqopt(sb); struct quota_info *dqopt = sb_dqopt(sb);
down_write(&dqopt->dqio_sem); return dqopt->ops[type]->write_file_info(sb, type);
ret = dqopt->ops[type]->write_file_info(sb, type);
up_write(&dqopt->dqio_sem);
return ret;
} }
EXPORT_SYMBOL(dquot_commit_info); EXPORT_SYMBOL(dquot_commit_info);
......
...@@ -186,6 +186,7 @@ static int v1_write_file_info(struct super_block *sb, int type) ...@@ -186,6 +186,7 @@ static int v1_write_file_info(struct super_block *sb, int type)
struct v1_disk_dqblk dqblk; struct v1_disk_dqblk dqblk;
int ret; int ret;
down_write(&dqopt->dqio_sem);
dqopt->info[type].dqi_flags &= ~DQF_INFO_DIRTY; dqopt->info[type].dqi_flags &= ~DQF_INFO_DIRTY;
ret = sb->s_op->quota_read(sb, type, (char *)&dqblk, ret = sb->s_op->quota_read(sb, type, (char *)&dqblk,
sizeof(struct v1_disk_dqblk), v1_dqoff(0)); sizeof(struct v1_disk_dqblk), v1_dqoff(0));
...@@ -203,6 +204,7 @@ static int v1_write_file_info(struct super_block *sb, int type) ...@@ -203,6 +204,7 @@ static int v1_write_file_info(struct super_block *sb, int type)
else if (ret > 0) else if (ret > 0)
ret = -EIO; ret = -EIO;
out: out:
up_write(&dqopt->dqio_sem);
return ret; return ret;
} }
......
...@@ -154,10 +154,12 @@ static int v2_read_file_info(struct super_block *sb, int type) ...@@ -154,10 +154,12 @@ static int v2_read_file_info(struct super_block *sb, int type)
static int v2_write_file_info(struct super_block *sb, int type) static int v2_write_file_info(struct super_block *sb, int type)
{ {
struct v2_disk_dqinfo dinfo; struct v2_disk_dqinfo dinfo;
struct mem_dqinfo *info = sb_dqinfo(sb, type); struct quota_info *dqopt = sb_dqopt(sb);
struct mem_dqinfo *info = &dqopt->info[type];
struct qtree_mem_dqinfo *qinfo = info->dqi_priv; struct qtree_mem_dqinfo *qinfo = info->dqi_priv;
ssize_t size; ssize_t size;
down_write(&dqopt->dqio_sem);
spin_lock(&dq_data_lock); spin_lock(&dq_data_lock);
info->dqi_flags &= ~DQF_INFO_DIRTY; info->dqi_flags &= ~DQF_INFO_DIRTY;
dinfo.dqi_bgrace = cpu_to_le32(info->dqi_bgrace); dinfo.dqi_bgrace = cpu_to_le32(info->dqi_bgrace);
...@@ -170,6 +172,7 @@ static int v2_write_file_info(struct super_block *sb, int type) ...@@ -170,6 +172,7 @@ static int v2_write_file_info(struct super_block *sb, int type)
dinfo.dqi_free_entry = cpu_to_le32(qinfo->dqi_free_entry); dinfo.dqi_free_entry = cpu_to_le32(qinfo->dqi_free_entry);
size = sb->s_op->quota_write(sb, type, (char *)&dinfo, size = sb->s_op->quota_write(sb, type, (char *)&dinfo,
sizeof(struct v2_disk_dqinfo), V2_DQINFOOFF); sizeof(struct v2_disk_dqinfo), V2_DQINFOOFF);
up_write(&dqopt->dqio_sem);
if (size != sizeof(struct v2_disk_dqinfo)) { if (size != sizeof(struct v2_disk_dqinfo)) {
quota_error(sb, "Can't write info structure"); quota_error(sb, "Can't write info structure");
return -1; return -1;
......
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