Commit 390600f8 authored by Darrick J. Wong's avatar Darrick J. Wong

xfs: remove flags argument from xfs_inode_ag_walk

The incore inode walk code passes a flags argument and a pointer from
the xfs_inode_ag_iterator caller all the way to the iteration function.
We can reduce the function complexity by passing flags through the
private pointer.
Signed-off-by: default avatarDarrick J. Wong <darrick.wong@oracle.com>
Reviewed-by: default avatarChristoph Hellwig <hch@lst.de>
Reviewed-by: default avatarBrian Foster <bfoster@redhat.com>
parent 9be05904
...@@ -810,9 +810,7 @@ STATIC int ...@@ -810,9 +810,7 @@ STATIC int
xfs_inode_ag_walk( xfs_inode_ag_walk(
struct xfs_mount *mp, struct xfs_mount *mp,
struct xfs_perag *pag, struct xfs_perag *pag,
int (*execute)(struct xfs_inode *ip, int flags, int (*execute)(struct xfs_inode *ip, void *args),
void *args),
int flags,
void *args, void *args,
int tag, int tag,
int iter_flags) int iter_flags)
...@@ -888,7 +886,7 @@ xfs_inode_ag_walk( ...@@ -888,7 +886,7 @@ xfs_inode_ag_walk(
if ((iter_flags & XFS_AGITER_INEW_WAIT) && if ((iter_flags & XFS_AGITER_INEW_WAIT) &&
xfs_iflags_test(batch[i], XFS_INEW)) xfs_iflags_test(batch[i], XFS_INEW))
xfs_inew_wait(batch[i]); xfs_inew_wait(batch[i]);
error = execute(batch[i], flags, args); error = execute(batch[i], args);
xfs_irele(batch[i]); xfs_irele(batch[i]);
if (error == -EAGAIN) { if (error == -EAGAIN) {
skipped++; skipped++;
...@@ -992,9 +990,7 @@ int ...@@ -992,9 +990,7 @@ int
xfs_inode_ag_iterator( xfs_inode_ag_iterator(
struct xfs_mount *mp, struct xfs_mount *mp,
int iter_flags, int iter_flags,
int (*execute)(struct xfs_inode *ip, int flags, int (*execute)(struct xfs_inode *ip, void *args),
void *args),
int flags,
void *args, void *args,
int tag) int tag)
{ {
...@@ -1006,7 +1002,7 @@ xfs_inode_ag_iterator( ...@@ -1006,7 +1002,7 @@ xfs_inode_ag_iterator(
ag = 0; ag = 0;
while ((pag = xfs_inode_walk_get_perag(mp, ag, tag))) { while ((pag = xfs_inode_walk_get_perag(mp, ag, tag))) {
ag = pag->pag_agno + 1; ag = pag->pag_agno + 1;
error = xfs_inode_ag_walk(mp, pag, execute, flags, args, tag, error = xfs_inode_ag_walk(mp, pag, execute, args, tag,
iter_flags); iter_flags);
xfs_perag_put(pag); xfs_perag_put(pag);
if (error) { if (error) {
...@@ -1463,12 +1459,14 @@ xfs_inode_match_id_union( ...@@ -1463,12 +1459,14 @@ xfs_inode_match_id_union(
STATIC int STATIC int
xfs_inode_free_eofblocks( xfs_inode_free_eofblocks(
struct xfs_inode *ip, struct xfs_inode *ip,
int flags,
void *args) void *args)
{ {
int ret = 0; struct xfs_eofblocks *eofb = args;
struct xfs_eofblocks *eofb = args; bool wait;
int match; int match;
int ret;
wait = eofb && (eofb->eof_flags & XFS_EOF_FLAGS_SYNC);
if (!xfs_can_free_eofblocks(ip, false)) { if (!xfs_can_free_eofblocks(ip, false)) {
/* inode could be preallocated or append-only */ /* inode could be preallocated or append-only */
...@@ -1481,8 +1479,7 @@ xfs_inode_free_eofblocks( ...@@ -1481,8 +1479,7 @@ xfs_inode_free_eofblocks(
* If the mapping is dirty the operation can block and wait for some * If the mapping is dirty the operation can block and wait for some
* time. Unless we are waiting, skip it. * time. Unless we are waiting, skip it.
*/ */
if (!(flags & SYNC_WAIT) && if (!wait && mapping_tagged(VFS_I(ip)->i_mapping, PAGECACHE_TAG_DIRTY))
mapping_tagged(VFS_I(ip)->i_mapping, PAGECACHE_TAG_DIRTY))
return 0; return 0;
if (eofb) { if (eofb) {
...@@ -1504,10 +1501,11 @@ xfs_inode_free_eofblocks( ...@@ -1504,10 +1501,11 @@ xfs_inode_free_eofblocks(
* scanner moving and revisit the inode in a subsequent pass. * scanner moving and revisit the inode in a subsequent pass.
*/ */
if (!xfs_ilock_nowait(ip, XFS_IOLOCK_EXCL)) { if (!xfs_ilock_nowait(ip, XFS_IOLOCK_EXCL)) {
if (flags & SYNC_WAIT) if (wait)
ret = -EAGAIN; return -EAGAIN;
return ret; return 0;
} }
ret = xfs_free_eofblocks(ip); ret = xfs_free_eofblocks(ip);
xfs_iunlock(ip, XFS_IOLOCK_EXCL); xfs_iunlock(ip, XFS_IOLOCK_EXCL);
...@@ -1518,16 +1516,10 @@ static int ...@@ -1518,16 +1516,10 @@ static int
__xfs_icache_free_eofblocks( __xfs_icache_free_eofblocks(
struct xfs_mount *mp, struct xfs_mount *mp,
struct xfs_eofblocks *eofb, struct xfs_eofblocks *eofb,
int (*execute)(struct xfs_inode *ip, int flags, int (*execute)(struct xfs_inode *ip, void *args),
void *args),
int tag) int tag)
{ {
int flags = SYNC_TRYLOCK; return xfs_inode_ag_iterator(mp, 0, execute, eofb, tag);
if (eofb && (eofb->eof_flags & XFS_EOF_FLAGS_SYNC))
flags = SYNC_WAIT;
return xfs_inode_ag_iterator(mp, 0, execute, flags, eofb, tag);
} }
int int
...@@ -1752,7 +1744,6 @@ xfs_prep_free_cowblocks( ...@@ -1752,7 +1744,6 @@ xfs_prep_free_cowblocks(
STATIC int STATIC int
xfs_inode_free_cowblocks( xfs_inode_free_cowblocks(
struct xfs_inode *ip, struct xfs_inode *ip,
int flags,
void *args) void *args)
{ {
struct xfs_eofblocks *eofb = args; struct xfs_eofblocks *eofb = args;
......
...@@ -72,8 +72,8 @@ void xfs_cowblocks_worker(struct work_struct *); ...@@ -72,8 +72,8 @@ void xfs_cowblocks_worker(struct work_struct *);
void xfs_queue_cowblocks(struct xfs_mount *); void xfs_queue_cowblocks(struct xfs_mount *);
int xfs_inode_ag_iterator(struct xfs_mount *mp, int iter_flags, int xfs_inode_ag_iterator(struct xfs_mount *mp, int iter_flags,
int (*execute)(struct xfs_inode *ip, int flags, void *args), int (*execute)(struct xfs_inode *ip, void *args),
int flags, void *args, int tag); void *args, int tag);
int xfs_icache_inode_is_allocated(struct xfs_mount *mp, struct xfs_trans *tp, int xfs_icache_inode_is_allocated(struct xfs_mount *mp, struct xfs_trans *tp,
xfs_ino_t ino, bool *inuse); xfs_ino_t ino, bool *inuse);
......
...@@ -737,9 +737,10 @@ xfs_qm_scall_getquota_next( ...@@ -737,9 +737,10 @@ xfs_qm_scall_getquota_next(
STATIC int STATIC int
xfs_dqrele_inode( xfs_dqrele_inode(
struct xfs_inode *ip, struct xfs_inode *ip,
int flags,
void *args) void *args)
{ {
uint *flags = args;
/* skip quota inodes */ /* skip quota inodes */
if (ip == ip->i_mount->m_quotainfo->qi_uquotaip || if (ip == ip->i_mount->m_quotainfo->qi_uquotaip ||
ip == ip->i_mount->m_quotainfo->qi_gquotaip || ip == ip->i_mount->m_quotainfo->qi_gquotaip ||
...@@ -751,15 +752,15 @@ xfs_dqrele_inode( ...@@ -751,15 +752,15 @@ xfs_dqrele_inode(
} }
xfs_ilock(ip, XFS_ILOCK_EXCL); xfs_ilock(ip, XFS_ILOCK_EXCL);
if ((flags & XFS_UQUOTA_ACCT) && ip->i_udquot) { if ((*flags & XFS_UQUOTA_ACCT) && ip->i_udquot) {
xfs_qm_dqrele(ip->i_udquot); xfs_qm_dqrele(ip->i_udquot);
ip->i_udquot = NULL; ip->i_udquot = NULL;
} }
if ((flags & XFS_GQUOTA_ACCT) && ip->i_gdquot) { if ((*flags & XFS_GQUOTA_ACCT) && ip->i_gdquot) {
xfs_qm_dqrele(ip->i_gdquot); xfs_qm_dqrele(ip->i_gdquot);
ip->i_gdquot = NULL; ip->i_gdquot = NULL;
} }
if ((flags & XFS_PQUOTA_ACCT) && ip->i_pdquot) { if ((*flags & XFS_PQUOTA_ACCT) && ip->i_pdquot) {
xfs_qm_dqrele(ip->i_pdquot); xfs_qm_dqrele(ip->i_pdquot);
ip->i_pdquot = NULL; ip->i_pdquot = NULL;
} }
...@@ -776,10 +777,10 @@ xfs_dqrele_inode( ...@@ -776,10 +777,10 @@ xfs_dqrele_inode(
*/ */
void void
xfs_qm_dqrele_all_inodes( xfs_qm_dqrele_all_inodes(
struct xfs_mount *mp, struct xfs_mount *mp,
uint flags) uint flags)
{ {
ASSERT(mp->m_quotainfo); ASSERT(mp->m_quotainfo);
xfs_inode_ag_iterator(mp, XFS_AGITER_INEW_WAIT, xfs_dqrele_inode, xfs_inode_ag_iterator(mp, XFS_AGITER_INEW_WAIT, xfs_dqrele_inode,
flags, NULL, XFS_ICI_NO_TAG); &flags, XFS_ICI_NO_TAG);
} }
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