Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit ac055fee authored by Darrick J. Wong's avatar Darrick J. Wong Committed by Greg Kroah-Hartman
Browse files

xfs: move inode flush to the sync workqueue 



commit f0f7a674d4df1510d8ca050a669e1420cf7d7fab upstream.

[ Modify fs/xfs/xfs_super.c to include the changes at locations suitable for
 5.4-lts kernel ]

Move the inode dirty data flushing to a workqueue so that multiple
threads can take advantage of a single thread's flushing work.  The
ratelimiting technique used in bdd4ee4 was not successful, because
threads that skipped the inode flush scan due to ratelimiting would
ENOSPC early, which caused occasional (but noticeable) changes in
behavior and sporadic fstest regressions.

Therefore, make all the writer threads wait on a single inode flush,
which eliminates both the stampeding hordes of flushers and the small
window in which a write could fail with ENOSPC because it lost the
ratelimit race after even another thread freed space.

Fixes: c6425702f21e ("xfs: ratelimit inode flush on buffered write ENOSPC")
Signed-off-by: default avatarDarrick J. Wong <darrick.wong@oracle.com>
Reviewed-by: default avatarBrian Foster <bfoster@redhat.com>
Acked-by: default avatarDarrick J. Wong <djwong@kernel.org>
Signed-off-by: default avatarChandan Babu R <chandan.babu@oracle.com>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent d3eb14b8

fs/xfs/xfs_mount.h

+5 −0
Original line number Diff line number Diff line
@@ -179,6 +179,11 @@ typedef struct xfs_mount { 
	struct xfs_error_cfg	m_error_cfg[XFS_ERR_CLASS_MAX][XFS_ERR_ERRNO_MAX];

	struct xstats		m_stats;	/* per-fs stats */



	/*

	 * Workqueue item so that we can coalesce multiple inode flush attempts

	 * into a single flush.

	 */

	struct work_struct	m_flush_inodes_work;

	struct workqueue_struct *m_buf_workqueue;

	struct workqueue_struct	*m_unwritten_workqueue;

	struct workqueue_struct	*m_cil_workqueue;

fs/xfs/xfs_super.c

+23 −5
Original line number Diff line number Diff line
@@ -840,6 +840,20 @@ xfs_destroy_mount_workqueues( 
	destroy_workqueue(mp->m_buf_workqueue);

}



static void

xfs_flush_inodes_worker(

	struct work_struct	*work)

{

	struct xfs_mount	*mp = container_of(work, struct xfs_mount,

						   m_flush_inodes_work);

	struct super_block	*sb = mp->m_super;



	if (down_read_trylock(&sb->s_umount)) {

		sync_inodes_sb(sb);

		up_read(&sb->s_umount);

	}

}



/*

 * Flush all dirty data to disk. Must not be called while holding an XFS_ILOCK

 * or a page lock. We use sync_inodes_sb() here to ensure we block while waiting
@@ -850,12 +864,15 @@ void 
xfs_flush_inodes(

	struct xfs_mount	*mp)

{

	struct super_block	*sb = mp->m_super;

	/*

	 * If flush_work() returns true then that means we waited for a flush

	 * which was already in progress.  Don't bother running another scan.

	 */

	if (flush_work(&mp->m_flush_inodes_work))

		return;



	if (down_read_trylock(&sb->s_umount)) {

		sync_inodes_sb(sb);

		up_read(&sb->s_umount);

	}

	queue_work(mp->m_sync_workqueue, &mp->m_flush_inodes_work);

	flush_work(&mp->m_flush_inodes_work);

}



/* Catch misguided souls that try to use this interface on XFS */
@@ -1532,6 +1549,7 @@ xfs_mount_alloc( 
	spin_lock_init(&mp->m_perag_lock);

	mutex_init(&mp->m_growlock);

	atomic_set(&mp->m_active_trans, 0);

	INIT_WORK(&mp->m_flush_inodes_work, xfs_flush_inodes_worker);

	INIT_DELAYED_WORK(&mp->m_reclaim_work, xfs_reclaim_worker);

	INIT_DELAYED_WORK(&mp->m_eofblocks_work, xfs_eofblocks_worker);

	INIT_DELAYED_WORK(&mp->m_cowblocks_work, xfs_cowblocks_worker);