Commit 5c8ed202 authored by Dave Chinner's avatar Dave Chinner Committed by Alex Elder
Browse files

xfs: introduce xfs_bmapi_read() 



xfs_bmapi() currently handles both extent map reading and
allocation. As a result, the code is littered with "if (wr)"
branches to conditionally do allocation operations if required.
This makes the code much harder to follow and causes significant
indent issues with the code.

Given that read mapping is much simpler than allocation, we can
split out read mapping from xfs_bmapi() and reuse the logic that
we have already factored out do do all the hard work of handling the
extent map manipulations. The results in a much simpler function for
the common extent read operations, and will allow the allocation
code to be simplified in another commit.

Once xfs_bmapi_read() is implemented, convert all the callers of
xfs_bmapi() that are only reading extents to use the new function.

Signed-off-by: default avatarDave Chinner <dchinner@redhat.com>
Signed-off-by: default avatarChristoph Hellwig <hch@lst.de>
Signed-off-by: default avatarAlex Elder <aelder@sgi.com>
parent aef9a895

fs/xfs/xfs_aops.c

+4 −4
Original line number Diff line number Diff line
@@ -315,8 +315,8 @@ xfs_map_blocks( 
		count = mp->m_maxioffset - offset;

	end_fsb = XFS_B_TO_FSB(mp, (xfs_ufsize_t)offset + count);

	offset_fsb = XFS_B_TO_FSBT(mp, offset);

	error = xfs_bmapi(NULL, ip, offset_fsb, end_fsb - offset_fsb,

			  bmapi_flags,  NULL, 0, imap, &nimaps, NULL);

	error = xfs_bmapi_read(ip, offset_fsb, end_fsb - offset_fsb,

				imap, &nimaps, bmapi_flags);

	xfs_iunlock(ip, XFS_ILOCK_SHARED);



	if (error)
@@ -1138,8 +1138,8 @@ __xfs_get_blocks( 
	end_fsb = XFS_B_TO_FSB(mp, (xfs_ufsize_t)offset + size);

	offset_fsb = XFS_B_TO_FSBT(mp, offset);



	error = xfs_bmapi(NULL, ip, offset_fsb, end_fsb - offset_fsb,

			  XFS_BMAPI_ENTIRE,  NULL, 0, &imap, &nimaps, NULL);

	error = xfs_bmapi_read(ip, offset_fsb, end_fsb - offset_fsb,

				&imap, &nimaps, XFS_BMAPI_ENTIRE);

	if (error)

		goto out_unlock;

fs/xfs/xfs_attr.c

+11 −19
Original line number Diff line number Diff line
@@ -1963,10 +1963,9 @@ xfs_attr_rmtval_get(xfs_da_args_t *args) 
	lblkno = args->rmtblkno;

	while (valuelen > 0) {

		nmap = ATTR_RMTVALUE_MAPSIZE;

		error = xfs_bmapi(args->trans, args->dp, (xfs_fileoff_t)lblkno,

				  args->rmtblkcnt,

				  XFS_BMAPI_ATTRFORK | XFS_BMAPI_METADATA,

				  NULL, 0, map, &nmap, NULL);

		error = xfs_bmapi_read(args->dp, (xfs_fileoff_t)lblkno,

				       args->rmtblkcnt, map, &nmap,

				       XFS_BMAPI_ATTRFORK);

		if (error)

			return(error);

		ASSERT(nmap >= 1);
@@ -2092,14 +2091,11 @@ xfs_attr_rmtval_set(xfs_da_args_t *args) 
		 */

		xfs_bmap_init(args->flist, args->firstblock);

		nmap = 1;

		error = xfs_bmapi(NULL, dp, (xfs_fileoff_t)lblkno,

				  args->rmtblkcnt,

				  XFS_BMAPI_ATTRFORK | XFS_BMAPI_METADATA,

				  args->firstblock, 0, &map, &nmap,

				  NULL);

		if (error) {

		error = xfs_bmapi_read(dp, (xfs_fileoff_t)lblkno,

				       args->rmtblkcnt, &map, &nmap,

				       XFS_BMAPI_ATTRFORK);

		if (error)

			return(error);

		}

		ASSERT(nmap == 1);

		ASSERT((map.br_startblock != DELAYSTARTBLOCK) &&

		       (map.br_startblock != HOLESTARTBLOCK));
@@ -2155,16 +2151,12 @@ xfs_attr_rmtval_remove(xfs_da_args_t *args) 
		/*

		 * Try to remember where we decided to put the value.

		 */

		xfs_bmap_init(args->flist, args->firstblock);

		nmap = 1;

		error = xfs_bmapi(NULL, args->dp, (xfs_fileoff_t)lblkno,

					args->rmtblkcnt,

					XFS_BMAPI_ATTRFORK | XFS_BMAPI_METADATA,

					args->firstblock, 0, &map, &nmap,

					args->flist);

		if (error) {

		error = xfs_bmapi_read(args->dp, (xfs_fileoff_t)lblkno,

				       args->rmtblkcnt, &map, &nmap,

				       XFS_BMAPI_ATTRFORK);

		if (error)

			return(error);

		}

		ASSERT(nmap == 1);

		ASSERT((map.br_startblock != DELAYSTARTBLOCK) &&

		       (map.br_startblock != HOLESTARTBLOCK));

fs/xfs/xfs_attr_leaf.c

+2 −3
Original line number Diff line number Diff line
@@ -2926,9 +2926,8 @@ xfs_attr_leaf_freextent(xfs_trans_t **trans, xfs_inode_t *dp, 
		 * Try to remember where we decided to put the value.

		 */

		nmap = 1;

		error = xfs_bmapi(*trans, dp, (xfs_fileoff_t)tblkno, tblkcnt,

					XFS_BMAPI_ATTRFORK | XFS_BMAPI_METADATA,

					NULL, 0, &map, &nmap, NULL);

		error = xfs_bmapi_read(dp, (xfs_fileoff_t)tblkno, tblkcnt,

				       &map, &nmap, XFS_BMAPI_ATTRFORK);

		if (error) {

			return(error);

		}

fs/xfs/xfs_bmap.c

+97 −7
Original line number Diff line number Diff line
@@ -4349,6 +4349,98 @@ xfs_bmapi_update_map( 
	*map = mval;

}



/*

 * Map file blocks to filesystem blocks without allocation.

 */

int

xfs_bmapi_read(

	struct xfs_inode	*ip,

	xfs_fileoff_t		bno,

	xfs_filblks_t		len,

	struct xfs_bmbt_irec	*mval,

	int			*nmap,

	int			flags)

{

	struct xfs_mount	*mp = ip->i_mount;

	struct xfs_ifork	*ifp;

	struct xfs_bmbt_irec	got;

	struct xfs_bmbt_irec	prev;

	xfs_fileoff_t		obno;

	xfs_fileoff_t		end;

	xfs_extnum_t		lastx;

	int			error;

	int			eof;

	int			n = 0;

	int			whichfork = (flags & XFS_BMAPI_ATTRFORK) ?

						XFS_ATTR_FORK : XFS_DATA_FORK;



	ASSERT(*nmap >= 1);

	ASSERT(!(flags & ~(XFS_BMAPI_ATTRFORK|XFS_BMAPI_ENTIRE|

			   XFS_BMAPI_IGSTATE)));



	if (unlikely(XFS_TEST_ERROR(

	    (XFS_IFORK_FORMAT(ip, whichfork) != XFS_DINODE_FMT_EXTENTS &&

	     XFS_IFORK_FORMAT(ip, whichfork) != XFS_DINODE_FMT_BTREE),

	     mp, XFS_ERRTAG_BMAPIFORMAT, XFS_RANDOM_BMAPIFORMAT))) {

		XFS_ERROR_REPORT("xfs_bmapi_read", XFS_ERRLEVEL_LOW, mp);

		return XFS_ERROR(EFSCORRUPTED);

	}



	if (XFS_FORCED_SHUTDOWN(mp))

		return XFS_ERROR(EIO);



	XFS_STATS_INC(xs_blk_mapr);



	ifp = XFS_IFORK_PTR(ip, whichfork);

	ASSERT(ifp->if_ext_max ==

	       XFS_IFORK_SIZE(ip, whichfork) / (uint)sizeof(xfs_bmbt_rec_t));



	if (!(ifp->if_flags & XFS_IFEXTENTS)) {

		error = xfs_iread_extents(NULL, ip, whichfork);

		if (error)

			return error;

	}



	xfs_bmap_search_extents(ip, bno, whichfork, &eof, &lastx, &got, &prev);

	end = bno + len;

	obno = bno;



	while (bno < end && n < *nmap) {

		/* Reading past eof, act as though there's a hole up to end. */

		if (eof)

			got.br_startoff = end;

		if (got.br_startoff > bno) {

			/* Reading in a hole.  */

			mval->br_startoff = bno;

			mval->br_startblock = HOLESTARTBLOCK;

			mval->br_blockcount =

				XFS_FILBLKS_MIN(len, got.br_startoff - bno);

			mval->br_state = XFS_EXT_NORM;

			bno += mval->br_blockcount;

			len -= mval->br_blockcount;

			mval++;

			n++;

			continue;

		}



		/* set up the extent map to return. */

		xfs_bmapi_trim_map(mval, &got, &bno, len, obno, end, n, flags);

		xfs_bmapi_update_map(&mval, &bno, &len, obno, end, &n, flags);



		/* If we're done, stop now. */

		if (bno >= end || n >= *nmap)

			break;



		/* Else go on to the next record. */

		if (++lastx < ifp->if_bytes / sizeof(xfs_bmbt_rec_t))

			xfs_bmbt_get_all(xfs_iext_get_ext(ifp, lastx), &got);

		else

			eof = 1;

	}

	*nmap = n;

	return 0;

}



/*

 * Map file blocks to filesystem blocks.

 * File range is given by the bno/len pair.
@@ -5490,10 +5582,9 @@ xfs_getbmap( 


	do {

		nmap = (nexleft > subnex) ? subnex : nexleft;

		error = xfs_bmapi(NULL, ip, XFS_BB_TO_FSBT(mp, bmv->bmv_offset),

		error = xfs_bmapi_read(ip, XFS_BB_TO_FSBT(mp, bmv->bmv_offset),

				       XFS_BB_TO_FSB(mp, bmv->bmv_length),

				  bmapi_flags, NULL, 0, map, &nmap,

				  NULL);

				       map, &nmap, bmapi_flags);

		if (error)

			goto out_free_map;

		ASSERT(nmap <= subnex);
@@ -6084,9 +6175,8 @@ xfs_bmap_punch_delalloc_range( 
		 * trying to remove a real extent (which requires a

		 * transaction) or a hole, which is probably a bad idea...

		 */

		error = xfs_bmapi(NULL, ip, start_fsb, 1,

				XFS_BMAPI_ENTIRE,  NULL, 0, &imap,

				&nimaps, NULL);

		error = xfs_bmapi_read(ip, start_fsb, 1, &imap, &nimaps,

				       XFS_BMAPI_ENTIRE);



		if (error) {

			/* something screwed, just bail */

fs/xfs/xfs_bmap.h

+4 −0
Original line number Diff line number Diff line
@@ -294,6 +294,10 @@ xfs_bmapi( 
	int			*nmap,		/* i/o: mval size/count */

	xfs_bmap_free_t		*flist);	/* i/o: list extents to free */



int	xfs_bmapi_read(struct xfs_inode *ip, xfs_fileoff_t bno,

		xfs_filblks_t len, struct xfs_bmbt_irec *mval,

		int *nmap, int flags);



/*

 * Map file blocks to filesystem blocks, simple version.

 * One block only, read-only.

CRA Git | Maintained and supported by SUSTech CRA and CCSE