Commit acc84b05 authored by Dave Kleikamp's avatar Dave Kleikamp Committed by Jan Kara

jfs: Handle error from dquot_initialize()

dquot_initialize() can now return error. Handle it where possible

Slightly modified by Dave Kleikamp due to needed jfs_rename() error path
fix.
Signed-off-by: default avatarJan Kara <jack@suse.com>
Reviewed-by: default avatarDave Kleikamp <dave.kleikamp@oracle.com>
parent 2e6c97ea
...@@ -107,8 +107,11 @@ int jfs_setattr(struct dentry *dentry, struct iattr *iattr) ...@@ -107,8 +107,11 @@ int jfs_setattr(struct dentry *dentry, struct iattr *iattr)
if (rc) if (rc)
return rc; return rc;
if (is_quota_modification(inode, iattr)) if (is_quota_modification(inode, iattr)) {
dquot_initialize(inode); rc = dquot_initialize(inode);
if (rc)
return rc;
}
if ((iattr->ia_valid & ATTR_UID && !uid_eq(iattr->ia_uid, inode->i_uid)) || if ((iattr->ia_valid & ATTR_UID && !uid_eq(iattr->ia_uid, inode->i_uid)) ||
(iattr->ia_valid & ATTR_GID && !gid_eq(iattr->ia_gid, inode->i_gid))) { (iattr->ia_valid & ATTR_GID && !gid_eq(iattr->ia_gid, inode->i_gid))) {
rc = dquot_transfer(inode, iattr); rc = dquot_transfer(inode, iattr);
......
...@@ -109,7 +109,9 @@ struct inode *ialloc(struct inode *parent, umode_t mode) ...@@ -109,7 +109,9 @@ struct inode *ialloc(struct inode *parent, umode_t mode)
/* /*
* Allocate inode to quota. * Allocate inode to quota.
*/ */
dquot_initialize(inode); rc = dquot_initialize(inode);
if (rc)
goto fail_drop;
rc = dquot_alloc_inode(inode); rc = dquot_alloc_inode(inode);
if (rc) if (rc)
goto fail_drop; goto fail_drop;
......
...@@ -86,7 +86,9 @@ static int jfs_create(struct inode *dip, struct dentry *dentry, umode_t mode, ...@@ -86,7 +86,9 @@ static int jfs_create(struct inode *dip, struct dentry *dentry, umode_t mode,
jfs_info("jfs_create: dip:0x%p name:%pd", dip, dentry); jfs_info("jfs_create: dip:0x%p name:%pd", dip, dentry);
dquot_initialize(dip); rc = dquot_initialize(dip);
if (rc)
goto out1;
/* /*
* search parent directory for entry/freespace * search parent directory for entry/freespace
...@@ -218,7 +220,9 @@ static int jfs_mkdir(struct inode *dip, struct dentry *dentry, umode_t mode) ...@@ -218,7 +220,9 @@ static int jfs_mkdir(struct inode *dip, struct dentry *dentry, umode_t mode)
jfs_info("jfs_mkdir: dip:0x%p name:%pd", dip, dentry); jfs_info("jfs_mkdir: dip:0x%p name:%pd", dip, dentry);
dquot_initialize(dip); rc = dquot_initialize(dip);
if (rc)
goto out1;
/* /*
* search parent directory for entry/freespace * search parent directory for entry/freespace
...@@ -355,8 +359,12 @@ static int jfs_rmdir(struct inode *dip, struct dentry *dentry) ...@@ -355,8 +359,12 @@ static int jfs_rmdir(struct inode *dip, struct dentry *dentry)
jfs_info("jfs_rmdir: dip:0x%p name:%pd", dip, dentry); jfs_info("jfs_rmdir: dip:0x%p name:%pd", dip, dentry);
/* Init inode for quota operations. */ /* Init inode for quota operations. */
dquot_initialize(dip); rc = dquot_initialize(dip);
dquot_initialize(ip); if (rc)
goto out;
rc = dquot_initialize(ip);
if (rc)
goto out;
/* directory must be empty to be removed */ /* directory must be empty to be removed */
if (!dtEmpty(ip)) { if (!dtEmpty(ip)) {
...@@ -483,8 +491,12 @@ static int jfs_unlink(struct inode *dip, struct dentry *dentry) ...@@ -483,8 +491,12 @@ static int jfs_unlink(struct inode *dip, struct dentry *dentry)
jfs_info("jfs_unlink: dip:0x%p name:%pd", dip, dentry); jfs_info("jfs_unlink: dip:0x%p name:%pd", dip, dentry);
/* Init inode for quota operations. */ /* Init inode for quota operations. */
dquot_initialize(dip); rc = dquot_initialize(dip);
dquot_initialize(ip); if (rc)
goto out;
rc = dquot_initialize(ip);
if (rc)
goto out;
if ((rc = get_UCSname(&dname, dentry))) if ((rc = get_UCSname(&dname, dentry)))
goto out; goto out;
...@@ -799,7 +811,9 @@ static int jfs_link(struct dentry *old_dentry, ...@@ -799,7 +811,9 @@ static int jfs_link(struct dentry *old_dentry,
jfs_info("jfs_link: %pd %pd", old_dentry, dentry); jfs_info("jfs_link: %pd %pd", old_dentry, dentry);
dquot_initialize(dir); rc = dquot_initialize(dir);
if (rc)
goto out;
tid = txBegin(ip->i_sb, 0); tid = txBegin(ip->i_sb, 0);
...@@ -810,7 +824,7 @@ static int jfs_link(struct dentry *old_dentry, ...@@ -810,7 +824,7 @@ static int jfs_link(struct dentry *old_dentry,
* scan parent directory for entry/freespace * scan parent directory for entry/freespace
*/ */
if ((rc = get_UCSname(&dname, dentry))) if ((rc = get_UCSname(&dname, dentry)))
goto out; goto out_tx;
if ((rc = dtSearch(dir, &dname, &ino, &btstack, JFS_CREATE))) if ((rc = dtSearch(dir, &dname, &ino, &btstack, JFS_CREATE)))
goto free_dname; goto free_dname;
...@@ -842,12 +856,13 @@ static int jfs_link(struct dentry *old_dentry, ...@@ -842,12 +856,13 @@ static int jfs_link(struct dentry *old_dentry,
free_dname: free_dname:
free_UCSname(&dname); free_UCSname(&dname);
out: out_tx:
txEnd(tid); txEnd(tid);
mutex_unlock(&JFS_IP(ip)->commit_mutex); mutex_unlock(&JFS_IP(ip)->commit_mutex);
mutex_unlock(&JFS_IP(dir)->commit_mutex); mutex_unlock(&JFS_IP(dir)->commit_mutex);
out:
jfs_info("jfs_link: rc:%d", rc); jfs_info("jfs_link: rc:%d", rc);
return rc; return rc;
} }
...@@ -891,7 +906,9 @@ static int jfs_symlink(struct inode *dip, struct dentry *dentry, ...@@ -891,7 +906,9 @@ static int jfs_symlink(struct inode *dip, struct dentry *dentry,
jfs_info("jfs_symlink: dip:0x%p name:%s", dip, name); jfs_info("jfs_symlink: dip:0x%p name:%s", dip, name);
dquot_initialize(dip); rc = dquot_initialize(dip);
if (rc)
goto out1;
ssize = strlen(name) + 1; ssize = strlen(name) + 1;
...@@ -1082,8 +1099,12 @@ static int jfs_rename(struct inode *old_dir, struct dentry *old_dentry, ...@@ -1082,8 +1099,12 @@ static int jfs_rename(struct inode *old_dir, struct dentry *old_dentry,
jfs_info("jfs_rename: %pd %pd", old_dentry, new_dentry); jfs_info("jfs_rename: %pd %pd", old_dentry, new_dentry);
dquot_initialize(old_dir); rc = dquot_initialize(old_dir);
dquot_initialize(new_dir); if (rc)
goto out1;
rc = dquot_initialize(new_dir);
if (rc)
goto out1;
old_ip = d_inode(old_dentry); old_ip = d_inode(old_dentry);
new_ip = d_inode(new_dentry); new_ip = d_inode(new_dentry);
...@@ -1130,7 +1151,9 @@ static int jfs_rename(struct inode *old_dir, struct dentry *old_dentry, ...@@ -1130,7 +1151,9 @@ static int jfs_rename(struct inode *old_dir, struct dentry *old_dentry,
} else if (new_ip) { } else if (new_ip) {
IWRITE_LOCK(new_ip, RDWRLOCK_NORMAL); IWRITE_LOCK(new_ip, RDWRLOCK_NORMAL);
/* Init inode for quota operations. */ /* Init inode for quota operations. */
dquot_initialize(new_ip); rc = dquot_initialize(new_ip);
if (rc)
goto out_unlock;
} }
/* /*
...@@ -1318,6 +1341,7 @@ static int jfs_rename(struct inode *old_dir, struct dentry *old_dentry, ...@@ -1318,6 +1341,7 @@ static int jfs_rename(struct inode *old_dir, struct dentry *old_dentry,
clear_cflag(COMMIT_Stale, old_dir); clear_cflag(COMMIT_Stale, old_dir);
} }
out_unlock:
if (new_ip && !S_ISDIR(new_ip->i_mode)) if (new_ip && !S_ISDIR(new_ip->i_mode))
IWRITE_UNLOCK(new_ip); IWRITE_UNLOCK(new_ip);
out3: out3:
...@@ -1353,7 +1377,9 @@ static int jfs_mknod(struct inode *dir, struct dentry *dentry, ...@@ -1353,7 +1377,9 @@ static int jfs_mknod(struct inode *dir, struct dentry *dentry,
jfs_info("jfs_mknod: %pd", dentry); jfs_info("jfs_mknod: %pd", dentry);
dquot_initialize(dir); rc = dquot_initialize(dir);
if (rc)
goto out;
if ((rc = get_UCSname(&dname, dentry))) if ((rc = get_UCSname(&dname, dentry)))
goto out; goto out;
......
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