xfs: remove SYNC_TRYLOCK from inode reclaim
All background reclaim is SYNC_TRYLOCK already, and even blocking reclaim (SYNC_WAIT) can use trylock mechanisms as xfs_reclaim_inodes_ag() will keep cycling until there are no more reclaimable inodes. Hence we can kill SYNC_TRYLOCK from inode reclaim and make everything unconditionally non-blocking. We remove all the optimistic "avoid blocking on locks" checks done in xfs_reclaim_inode_grab() as nothing blocks on locks anymore. Further, checking XFS_IFLOCK optimistically can result in detecting inodes in the process of being cleaned (i.e. between being removed from the AIL and having the flush lock dropped), so for xfs_reclaim_inodes() to reliably reclaim all inodes we need to drop these checks anyway. Signed-off-by: Dave Chinner <dchinner@redhat.com> Reviewed-by: Darrick J. Wong <darrick.wong@oracle.com> Reviewed-by: Brian Foster <bfoster@redhat.com> Signed-off-by: Darrick J. Wong <darrick.wong@oracle.com>
This commit is contained in:
parent
9552e14d3e
commit
50718b8d73
@ -174,7 +174,7 @@ xfs_reclaim_worker(
|
|||||||
struct xfs_mount *mp = container_of(to_delayed_work(work),
|
struct xfs_mount *mp = container_of(to_delayed_work(work),
|
||||||
struct xfs_mount, m_reclaim_work);
|
struct xfs_mount, m_reclaim_work);
|
||||||
|
|
||||||
xfs_reclaim_inodes(mp, SYNC_TRYLOCK);
|
xfs_reclaim_inodes(mp, 0);
|
||||||
xfs_reclaim_work_queue(mp);
|
xfs_reclaim_work_queue(mp);
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -1028,48 +1028,37 @@ xfs_cowblocks_worker(
|
|||||||
|
|
||||||
/*
|
/*
|
||||||
* Grab the inode for reclaim exclusively.
|
* Grab the inode for reclaim exclusively.
|
||||||
* Return 0 if we grabbed it, non-zero otherwise.
|
*
|
||||||
|
* We have found this inode via a lookup under RCU, so the inode may have
|
||||||
|
* already been freed, or it may be in the process of being recycled by
|
||||||
|
* xfs_iget(). In both cases, the inode will have XFS_IRECLAIM set. If the inode
|
||||||
|
* has been fully recycled by the time we get the i_flags_lock, XFS_IRECLAIMABLE
|
||||||
|
* will not be set. Hence we need to check for both these flag conditions to
|
||||||
|
* avoid inodes that are no longer reclaim candidates.
|
||||||
|
*
|
||||||
|
* Note: checking for other state flags here, under the i_flags_lock or not, is
|
||||||
|
* racy and should be avoided. Those races should be resolved only after we have
|
||||||
|
* ensured that we are able to reclaim this inode and the world can see that we
|
||||||
|
* are going to reclaim it.
|
||||||
|
*
|
||||||
|
* Return true if we grabbed it, false otherwise.
|
||||||
*/
|
*/
|
||||||
STATIC int
|
static bool
|
||||||
xfs_reclaim_inode_grab(
|
xfs_reclaim_inode_grab(
|
||||||
struct xfs_inode *ip,
|
struct xfs_inode *ip)
|
||||||
int flags)
|
|
||||||
{
|
{
|
||||||
ASSERT(rcu_read_lock_held());
|
ASSERT(rcu_read_lock_held());
|
||||||
|
|
||||||
/* quick check for stale RCU freed inode */
|
|
||||||
if (!ip->i_ino)
|
|
||||||
return 1;
|
|
||||||
|
|
||||||
/*
|
|
||||||
* If we are asked for non-blocking operation, do unlocked checks to
|
|
||||||
* see if the inode already is being flushed or in reclaim to avoid
|
|
||||||
* lock traffic.
|
|
||||||
*/
|
|
||||||
if ((flags & SYNC_TRYLOCK) &&
|
|
||||||
__xfs_iflags_test(ip, XFS_IFLOCK | XFS_IRECLAIM))
|
|
||||||
return 1;
|
|
||||||
|
|
||||||
/*
|
|
||||||
* The radix tree lock here protects a thread in xfs_iget from racing
|
|
||||||
* with us starting reclaim on the inode. Once we have the
|
|
||||||
* XFS_IRECLAIM flag set it will not touch us.
|
|
||||||
*
|
|
||||||
* Due to RCU lookup, we may find inodes that have been freed and only
|
|
||||||
* have XFS_IRECLAIM set. Indeed, we may see reallocated inodes that
|
|
||||||
* aren't candidates for reclaim at all, so we must check the
|
|
||||||
* XFS_IRECLAIMABLE is set first before proceeding to reclaim.
|
|
||||||
*/
|
|
||||||
spin_lock(&ip->i_flags_lock);
|
spin_lock(&ip->i_flags_lock);
|
||||||
if (!__xfs_iflags_test(ip, XFS_IRECLAIMABLE) ||
|
if (!__xfs_iflags_test(ip, XFS_IRECLAIMABLE) ||
|
||||||
__xfs_iflags_test(ip, XFS_IRECLAIM)) {
|
__xfs_iflags_test(ip, XFS_IRECLAIM)) {
|
||||||
/* not a reclaim candidate. */
|
/* not a reclaim candidate. */
|
||||||
spin_unlock(&ip->i_flags_lock);
|
spin_unlock(&ip->i_flags_lock);
|
||||||
return 1;
|
return false;
|
||||||
}
|
}
|
||||||
__xfs_iflags_set(ip, XFS_IRECLAIM);
|
__xfs_iflags_set(ip, XFS_IRECLAIM);
|
||||||
spin_unlock(&ip->i_flags_lock);
|
spin_unlock(&ip->i_flags_lock);
|
||||||
return 0;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@ -1114,8 +1103,7 @@ xfs_reclaim_inode_grab(
|
|||||||
static bool
|
static bool
|
||||||
xfs_reclaim_inode(
|
xfs_reclaim_inode(
|
||||||
struct xfs_inode *ip,
|
struct xfs_inode *ip,
|
||||||
struct xfs_perag *pag,
|
struct xfs_perag *pag)
|
||||||
int sync_mode)
|
|
||||||
{
|
{
|
||||||
xfs_ino_t ino = ip->i_ino; /* for radix_tree_delete */
|
xfs_ino_t ino = ip->i_ino; /* for radix_tree_delete */
|
||||||
|
|
||||||
@ -1209,7 +1197,6 @@ out:
|
|||||||
static int
|
static int
|
||||||
xfs_reclaim_inodes_ag(
|
xfs_reclaim_inodes_ag(
|
||||||
struct xfs_mount *mp,
|
struct xfs_mount *mp,
|
||||||
int flags,
|
|
||||||
int *nr_to_scan)
|
int *nr_to_scan)
|
||||||
{
|
{
|
||||||
struct xfs_perag *pag;
|
struct xfs_perag *pag;
|
||||||
@ -1254,7 +1241,7 @@ xfs_reclaim_inodes_ag(
|
|||||||
for (i = 0; i < nr_found; i++) {
|
for (i = 0; i < nr_found; i++) {
|
||||||
struct xfs_inode *ip = batch[i];
|
struct xfs_inode *ip = batch[i];
|
||||||
|
|
||||||
if (done || xfs_reclaim_inode_grab(ip, flags))
|
if (done || !xfs_reclaim_inode_grab(ip))
|
||||||
batch[i] = NULL;
|
batch[i] = NULL;
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@ -1285,7 +1272,7 @@ xfs_reclaim_inodes_ag(
|
|||||||
for (i = 0; i < nr_found; i++) {
|
for (i = 0; i < nr_found; i++) {
|
||||||
if (!batch[i])
|
if (!batch[i])
|
||||||
continue;
|
continue;
|
||||||
if (!xfs_reclaim_inode(batch[i], pag, flags))
|
if (!xfs_reclaim_inode(batch[i], pag))
|
||||||
skipped++;
|
skipped++;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -1311,13 +1298,13 @@ xfs_reclaim_inodes(
|
|||||||
int nr_to_scan = INT_MAX;
|
int nr_to_scan = INT_MAX;
|
||||||
int skipped;
|
int skipped;
|
||||||
|
|
||||||
xfs_reclaim_inodes_ag(mp, mode, &nr_to_scan);
|
xfs_reclaim_inodes_ag(mp, &nr_to_scan);
|
||||||
if (!(mode & SYNC_WAIT))
|
if (!(mode & SYNC_WAIT))
|
||||||
return 0;
|
return 0;
|
||||||
|
|
||||||
do {
|
do {
|
||||||
xfs_ail_push_all_sync(mp->m_ail);
|
xfs_ail_push_all_sync(mp->m_ail);
|
||||||
skipped = xfs_reclaim_inodes_ag(mp, mode, &nr_to_scan);
|
skipped = xfs_reclaim_inodes_ag(mp, &nr_to_scan);
|
||||||
} while (skipped > 0);
|
} while (skipped > 0);
|
||||||
|
|
||||||
return 0;
|
return 0;
|
||||||
@ -1341,7 +1328,7 @@ xfs_reclaim_inodes_nr(
|
|||||||
xfs_reclaim_work_queue(mp);
|
xfs_reclaim_work_queue(mp);
|
||||||
xfs_ail_push_all(mp->m_ail);
|
xfs_ail_push_all(mp->m_ail);
|
||||||
|
|
||||||
xfs_reclaim_inodes_ag(mp, SYNC_TRYLOCK, &nr_to_scan);
|
xfs_reclaim_inodes_ag(mp, &nr_to_scan);
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user