struct inode *inode,
loff_t offset,
struct xfs_bmbt_irec *imap,
- int type)
+ int type,
+ int nonblocking)
{
struct xfs_inode *ip = XFS_I(inode);
struct xfs_mount *mp = ip->i_mount;
if (type == XFS_IO_UNWRITTEN)
bmapi_flags |= XFS_BMAPI_IGSTATE;
- xfs_ilock(ip, XFS_ILOCK_SHARED);
+ if (!xfs_ilock_nowait(ip, XFS_ILOCK_SHARED)) {
+ if (nonblocking)
+ return -EAGAIN;
+ xfs_ilock(ip, XFS_ILOCK_SHARED);
+ }
+
ASSERT(ip->i_d.di_format != XFS_DINODE_FMT_BTREE ||
(ip->i_df.if_flags & XFS_IFEXTENTS));
ASSERT(offset <= mp->m_super->s_maxbytes);
ssize_t len;
int err, imap_valid = 0, uptodate = 1;
int count = 0;
+ int nonblocking = 0;
trace_xfs_writepage(inode, page, 0, 0);
offset = page_offset(page);
type = XFS_IO_OVERWRITE;
+ if (wbc->sync_mode == WB_SYNC_NONE)
+ nonblocking = 1;
+
do {
int new_ioend = 0;
* time.
*/
new_ioend = 1;
- err = xfs_map_blocks(inode, offset, &imap, type);
+ err = xfs_map_blocks(inode, offset, &imap, type,
+ nonblocking);
if (err)
goto error;
imap_valid = xfs_imap_valid(inode, &imap, offset);
if (iohead)
xfs_cancel_ioend(iohead);
+ if (err == -EAGAIN)
+ goto redirty;
+
xfs_aops_discard_page(page);
ClearPageUptodate(page);
unlock_page(page);