diff options
Diffstat (limited to 'fs/xfs/linux-2.6/xfs_buf.c')
-rw-r--r-- | fs/xfs/linux-2.6/xfs_buf.c | 27 |
1 files changed, 12 insertions, 15 deletions
diff --git a/fs/xfs/linux-2.6/xfs_buf.c b/fs/xfs/linux-2.6/xfs_buf.c index 44c2b0ef9a41..f01de3c55c43 100644 --- a/fs/xfs/linux-2.6/xfs_buf.c +++ b/fs/xfs/linux-2.6/xfs_buf.c | |||
@@ -1007,25 +1007,20 @@ xfs_bwrite( | |||
1007 | struct xfs_mount *mp, | 1007 | struct xfs_mount *mp, |
1008 | struct xfs_buf *bp) | 1008 | struct xfs_buf *bp) |
1009 | { | 1009 | { |
1010 | int iowait = (bp->b_flags & XBF_ASYNC) == 0; | 1010 | int error; |
1011 | int error = 0; | ||
1012 | 1011 | ||
1013 | bp->b_strat = xfs_bdstrat_cb; | 1012 | bp->b_strat = xfs_bdstrat_cb; |
1014 | bp->b_mount = mp; | 1013 | bp->b_mount = mp; |
1015 | bp->b_flags |= XBF_WRITE; | 1014 | bp->b_flags |= XBF_WRITE; |
1016 | if (!iowait) | 1015 | bp->b_flags &= ~(XBF_ASYNC | XBF_READ); |
1017 | bp->b_flags |= _XBF_RUN_QUEUES; | ||
1018 | 1016 | ||
1019 | xfs_buf_delwri_dequeue(bp); | 1017 | xfs_buf_delwri_dequeue(bp); |
1020 | xfs_buf_iostrategy(bp); | 1018 | xfs_buf_iostrategy(bp); |
1021 | 1019 | ||
1022 | if (iowait) { | 1020 | error = xfs_buf_iowait(bp); |
1023 | error = xfs_buf_iowait(bp); | 1021 | if (error) |
1024 | if (error) | 1022 | xfs_force_shutdown(mp, SHUTDOWN_META_IO_ERROR); |
1025 | xfs_force_shutdown(mp, SHUTDOWN_META_IO_ERROR); | 1023 | xfs_buf_relse(bp); |
1026 | xfs_buf_relse(bp); | ||
1027 | } | ||
1028 | |||
1029 | return error; | 1024 | return error; |
1030 | } | 1025 | } |
1031 | 1026 | ||
@@ -1614,7 +1609,8 @@ xfs_mapping_buftarg( | |||
1614 | 1609 | ||
1615 | STATIC int | 1610 | STATIC int |
1616 | xfs_alloc_delwrite_queue( | 1611 | xfs_alloc_delwrite_queue( |
1617 | xfs_buftarg_t *btp) | 1612 | xfs_buftarg_t *btp, |
1613 | const char *fsname) | ||
1618 | { | 1614 | { |
1619 | int error = 0; | 1615 | int error = 0; |
1620 | 1616 | ||
@@ -1622,7 +1618,7 @@ xfs_alloc_delwrite_queue( | |||
1622 | INIT_LIST_HEAD(&btp->bt_delwrite_queue); | 1618 | INIT_LIST_HEAD(&btp->bt_delwrite_queue); |
1623 | spin_lock_init(&btp->bt_delwrite_lock); | 1619 | spin_lock_init(&btp->bt_delwrite_lock); |
1624 | btp->bt_flags = 0; | 1620 | btp->bt_flags = 0; |
1625 | btp->bt_task = kthread_run(xfsbufd, btp, "xfsbufd"); | 1621 | btp->bt_task = kthread_run(xfsbufd, btp, "xfsbufd/%s", fsname); |
1626 | if (IS_ERR(btp->bt_task)) { | 1622 | if (IS_ERR(btp->bt_task)) { |
1627 | error = PTR_ERR(btp->bt_task); | 1623 | error = PTR_ERR(btp->bt_task); |
1628 | goto out_error; | 1624 | goto out_error; |
@@ -1635,7 +1631,8 @@ out_error: | |||
1635 | xfs_buftarg_t * | 1631 | xfs_buftarg_t * |
1636 | xfs_alloc_buftarg( | 1632 | xfs_alloc_buftarg( |
1637 | struct block_device *bdev, | 1633 | struct block_device *bdev, |
1638 | int external) | 1634 | int external, |
1635 | const char *fsname) | ||
1639 | { | 1636 | { |
1640 | xfs_buftarg_t *btp; | 1637 | xfs_buftarg_t *btp; |
1641 | 1638 | ||
@@ -1647,7 +1644,7 @@ xfs_alloc_buftarg( | |||
1647 | goto error; | 1644 | goto error; |
1648 | if (xfs_mapping_buftarg(btp, bdev)) | 1645 | if (xfs_mapping_buftarg(btp, bdev)) |
1649 | goto error; | 1646 | goto error; |
1650 | if (xfs_alloc_delwrite_queue(btp)) | 1647 | if (xfs_alloc_delwrite_queue(btp, fsname)) |
1651 | goto error; | 1648 | goto error; |
1652 | xfs_alloc_bufhash(btp, external); | 1649 | xfs_alloc_bufhash(btp, external); |
1653 | return btp; | 1650 | return btp; |