diff options
author | Christoph Hellwig <hch@infradead.org> | 2010-04-28 08:28:57 -0400 |
---|---|---|
committer | Alex Elder <aelder@sgi.com> | 2010-05-19 10:58:17 -0400 |
commit | 34a52c6c064fb9f1fd1310407ce076a4bb049734 (patch) | |
tree | 2b05a8d21f644ab733f7e242971bd0314c46b355 /fs/xfs | |
parent | 207d041602cead1c1a16288f6225aea9da1f5bc4 (diff) |
xfs: move I/O type flags into xfs_aops.c
The IOMAP_ flags are now only used inside xfs_aops.c for extent
probing and I/O completion tracking, so more them here, and rename
them to IO_* as there's no mapping involved at all.
Signed-off-by: Christoph Hellwig <hch@lst.de>
Signed-off-by: Alex Elder <aelder@sgi.com>
Diffstat (limited to 'fs/xfs')
-rw-r--r-- | fs/xfs/linux-2.6/xfs_aops.c | 51 | ||||
-rw-r--r-- | fs/xfs/xfs_iomap.h | 8 |
2 files changed, 30 insertions, 29 deletions
diff --git a/fs/xfs/linux-2.6/xfs_aops.c b/fs/xfs/linux-2.6/xfs_aops.c index 70ce1da73d01..f1dd70e201cf 100644 --- a/fs/xfs/linux-2.6/xfs_aops.c +++ b/fs/xfs/linux-2.6/xfs_aops.c | |||
@@ -45,6 +45,15 @@ | |||
45 | #include <linux/pagevec.h> | 45 | #include <linux/pagevec.h> |
46 | #include <linux/writeback.h> | 46 | #include <linux/writeback.h> |
47 | 47 | ||
48 | /* | ||
49 | * Types of I/O for bmap clustering and I/O completion tracking. | ||
50 | */ | ||
51 | enum { | ||
52 | IO_READ, /* mapping for a read */ | ||
53 | IO_DELAY, /* mapping covers delalloc region */ | ||
54 | IO_UNWRITTEN, /* mapping covers allocated but uninitialized data */ | ||
55 | IO_NEW /* just allocated */ | ||
56 | }; | ||
48 | 57 | ||
49 | /* | 58 | /* |
50 | * Prime number of hash buckets since address is used as the key. | 59 | * Prime number of hash buckets since address is used as the key. |
@@ -184,7 +193,7 @@ xfs_setfilesize( | |||
184 | xfs_fsize_t isize; | 193 | xfs_fsize_t isize; |
185 | 194 | ||
186 | ASSERT((ip->i_d.di_mode & S_IFMT) == S_IFREG); | 195 | ASSERT((ip->i_d.di_mode & S_IFMT) == S_IFREG); |
187 | ASSERT(ioend->io_type != IOMAP_READ); | 196 | ASSERT(ioend->io_type != IO_READ); |
188 | 197 | ||
189 | if (unlikely(ioend->io_error)) | 198 | if (unlikely(ioend->io_error)) |
190 | return 0; | 199 | return 0; |
@@ -215,7 +224,7 @@ xfs_finish_ioend( | |||
215 | if (atomic_dec_and_test(&ioend->io_remaining)) { | 224 | if (atomic_dec_and_test(&ioend->io_remaining)) { |
216 | struct workqueue_struct *wq; | 225 | struct workqueue_struct *wq; |
217 | 226 | ||
218 | wq = (ioend->io_type == IOMAP_UNWRITTEN) ? | 227 | wq = (ioend->io_type == IO_UNWRITTEN) ? |
219 | xfsconvertd_workqueue : xfsdatad_workqueue; | 228 | xfsconvertd_workqueue : xfsdatad_workqueue; |
220 | queue_work(wq, &ioend->io_work); | 229 | queue_work(wq, &ioend->io_work); |
221 | if (wait) | 230 | if (wait) |
@@ -238,7 +247,7 @@ xfs_end_io( | |||
238 | * For unwritten extents we need to issue transactions to convert a | 247 | * For unwritten extents we need to issue transactions to convert a |
239 | * range to normal written extens after the data I/O has finished. | 248 | * range to normal written extens after the data I/O has finished. |
240 | */ | 249 | */ |
241 | if (ioend->io_type == IOMAP_UNWRITTEN && | 250 | if (ioend->io_type == IO_UNWRITTEN && |
242 | likely(!ioend->io_error && !XFS_FORCED_SHUTDOWN(ip->i_mount))) { | 251 | likely(!ioend->io_error && !XFS_FORCED_SHUTDOWN(ip->i_mount))) { |
243 | 252 | ||
244 | error = xfs_iomap_write_unwritten(ip, ioend->io_offset, | 253 | error = xfs_iomap_write_unwritten(ip, ioend->io_offset, |
@@ -251,7 +260,7 @@ xfs_end_io( | |||
251 | * We might have to update the on-disk file size after extending | 260 | * We might have to update the on-disk file size after extending |
252 | * writes. | 261 | * writes. |
253 | */ | 262 | */ |
254 | if (ioend->io_type != IOMAP_READ) { | 263 | if (ioend->io_type != IO_READ) { |
255 | error = xfs_setfilesize(ioend); | 264 | error = xfs_setfilesize(ioend); |
256 | ASSERT(!error || error == EAGAIN); | 265 | ASSERT(!error || error == EAGAIN); |
257 | } | 266 | } |
@@ -724,11 +733,11 @@ xfs_is_delayed_page( | |||
724 | bh = head = page_buffers(page); | 733 | bh = head = page_buffers(page); |
725 | do { | 734 | do { |
726 | if (buffer_unwritten(bh)) | 735 | if (buffer_unwritten(bh)) |
727 | acceptable = (type == IOMAP_UNWRITTEN); | 736 | acceptable = (type == IO_UNWRITTEN); |
728 | else if (buffer_delay(bh)) | 737 | else if (buffer_delay(bh)) |
729 | acceptable = (type == IOMAP_DELAY); | 738 | acceptable = (type == IO_DELAY); |
730 | else if (buffer_dirty(bh) && buffer_mapped(bh)) | 739 | else if (buffer_dirty(bh) && buffer_mapped(bh)) |
731 | acceptable = (type == IOMAP_NEW); | 740 | acceptable = (type == IO_NEW); |
732 | else | 741 | else |
733 | break; | 742 | break; |
734 | } while ((bh = bh->b_this_page) != head); | 743 | } while ((bh = bh->b_this_page) != head); |
@@ -812,9 +821,9 @@ xfs_convert_page( | |||
812 | 821 | ||
813 | if (buffer_unwritten(bh) || buffer_delay(bh)) { | 822 | if (buffer_unwritten(bh) || buffer_delay(bh)) { |
814 | if (buffer_unwritten(bh)) | 823 | if (buffer_unwritten(bh)) |
815 | type = IOMAP_UNWRITTEN; | 824 | type = IO_UNWRITTEN; |
816 | else | 825 | else |
817 | type = IOMAP_DELAY; | 826 | type = IO_DELAY; |
818 | 827 | ||
819 | if (!xfs_iomap_valid(inode, imap, offset)) { | 828 | if (!xfs_iomap_valid(inode, imap, offset)) { |
820 | done = 1; | 829 | done = 1; |
@@ -836,7 +845,7 @@ xfs_convert_page( | |||
836 | page_dirty--; | 845 | page_dirty--; |
837 | count++; | 846 | count++; |
838 | } else { | 847 | } else { |
839 | type = IOMAP_NEW; | 848 | type = IO_NEW; |
840 | if (buffer_mapped(bh) && all_bh && startio) { | 849 | if (buffer_mapped(bh) && all_bh && startio) { |
841 | lock_buffer(bh); | 850 | lock_buffer(bh); |
842 | xfs_add_to_ioend(inode, bh, offset, | 851 | xfs_add_to_ioend(inode, bh, offset, |
@@ -940,7 +949,7 @@ xfs_aops_discard_page( | |||
940 | loff_t offset = page_offset(page); | 949 | loff_t offset = page_offset(page); |
941 | ssize_t len = 1 << inode->i_blkbits; | 950 | ssize_t len = 1 << inode->i_blkbits; |
942 | 951 | ||
943 | if (!xfs_is_delayed_page(page, IOMAP_DELAY)) | 952 | if (!xfs_is_delayed_page(page, IO_DELAY)) |
944 | goto out_invalidate; | 953 | goto out_invalidate; |
945 | 954 | ||
946 | if (XFS_FORCED_SHUTDOWN(ip->i_mount)) | 955 | if (XFS_FORCED_SHUTDOWN(ip->i_mount)) |
@@ -1107,7 +1116,7 @@ xfs_page_state_convert( | |||
1107 | bh = head = page_buffers(page); | 1116 | bh = head = page_buffers(page); |
1108 | offset = page_offset(page); | 1117 | offset = page_offset(page); |
1109 | flags = BMAPI_READ; | 1118 | flags = BMAPI_READ; |
1110 | type = IOMAP_NEW; | 1119 | type = IO_NEW; |
1111 | 1120 | ||
1112 | /* TODO: cleanup count and page_dirty */ | 1121 | /* TODO: cleanup count and page_dirty */ |
1113 | 1122 | ||
@@ -1150,13 +1159,13 @@ xfs_page_state_convert( | |||
1150 | iomap_valid = 0; | 1159 | iomap_valid = 0; |
1151 | 1160 | ||
1152 | if (buffer_unwritten(bh)) { | 1161 | if (buffer_unwritten(bh)) { |
1153 | type = IOMAP_UNWRITTEN; | 1162 | type = IO_UNWRITTEN; |
1154 | flags = BMAPI_WRITE | BMAPI_IGNSTATE; | 1163 | flags = BMAPI_WRITE | BMAPI_IGNSTATE; |
1155 | } else if (buffer_delay(bh)) { | 1164 | } else if (buffer_delay(bh)) { |
1156 | type = IOMAP_DELAY; | 1165 | type = IO_DELAY; |
1157 | flags = BMAPI_ALLOCATE | trylock; | 1166 | flags = BMAPI_ALLOCATE | trylock; |
1158 | } else { | 1167 | } else { |
1159 | type = IOMAP_NEW; | 1168 | type = IO_NEW; |
1160 | flags = BMAPI_WRITE | BMAPI_MMAP; | 1169 | flags = BMAPI_WRITE | BMAPI_MMAP; |
1161 | } | 1170 | } |
1162 | 1171 | ||
@@ -1170,7 +1179,7 @@ xfs_page_state_convert( | |||
1170 | * for unwritten extent conversion. | 1179 | * for unwritten extent conversion. |
1171 | */ | 1180 | */ |
1172 | new_ioend = 1; | 1181 | new_ioend = 1; |
1173 | if (type == IOMAP_NEW) { | 1182 | if (type == IO_NEW) { |
1174 | size = xfs_probe_cluster(inode, | 1183 | size = xfs_probe_cluster(inode, |
1175 | page, bh, head, 0); | 1184 | page, bh, head, 0); |
1176 | } else { | 1185 | } else { |
@@ -1215,14 +1224,14 @@ xfs_page_state_convert( | |||
1215 | } | 1224 | } |
1216 | 1225 | ||
1217 | /* | 1226 | /* |
1218 | * We set the type to IOMAP_NEW in case we are doing a | 1227 | * We set the type to IO_NEW in case we are doing a |
1219 | * small write at EOF that is extending the file but | 1228 | * small write at EOF that is extending the file but |
1220 | * without needing an allocation. We need to update the | 1229 | * without needing an allocation. We need to update the |
1221 | * file size on I/O completion in this case so it is | 1230 | * file size on I/O completion in this case so it is |
1222 | * the same case as having just allocated a new extent | 1231 | * the same case as having just allocated a new extent |
1223 | * that we are writing into for the first time. | 1232 | * that we are writing into for the first time. |
1224 | */ | 1233 | */ |
1225 | type = IOMAP_NEW; | 1234 | type = IO_NEW; |
1226 | if (trylock_buffer(bh)) { | 1235 | if (trylock_buffer(bh)) { |
1227 | ASSERT(buffer_mapped(bh)); | 1236 | ASSERT(buffer_mapped(bh)); |
1228 | if (iomap_valid) | 1237 | if (iomap_valid) |
@@ -1594,7 +1603,7 @@ xfs_end_io_direct( | |||
1594 | */ | 1603 | */ |
1595 | ioend->io_offset = offset; | 1604 | ioend->io_offset = offset; |
1596 | ioend->io_size = size; | 1605 | ioend->io_size = size; |
1597 | if (ioend->io_type == IOMAP_READ) { | 1606 | if (ioend->io_type == IO_READ) { |
1598 | xfs_finish_ioend(ioend, 0); | 1607 | xfs_finish_ioend(ioend, 0); |
1599 | } else if (private && size > 0) { | 1608 | } else if (private && size > 0) { |
1600 | xfs_finish_ioend(ioend, is_sync_kiocb(iocb)); | 1609 | xfs_finish_ioend(ioend, is_sync_kiocb(iocb)); |
@@ -1605,7 +1614,7 @@ xfs_end_io_direct( | |||
1605 | * didn't map an unwritten extent so switch it's completion | 1614 | * didn't map an unwritten extent so switch it's completion |
1606 | * handler. | 1615 | * handler. |
1607 | */ | 1616 | */ |
1608 | ioend->io_type = IOMAP_NEW; | 1617 | ioend->io_type = IO_NEW; |
1609 | xfs_finish_ioend(ioend, 0); | 1618 | xfs_finish_ioend(ioend, 0); |
1610 | } | 1619 | } |
1611 | 1620 | ||
@@ -1633,7 +1642,7 @@ xfs_vm_direct_IO( | |||
1633 | bdev = xfs_find_bdev_for_inode(inode); | 1642 | bdev = xfs_find_bdev_for_inode(inode); |
1634 | 1643 | ||
1635 | iocb->private = xfs_alloc_ioend(inode, rw == WRITE ? | 1644 | iocb->private = xfs_alloc_ioend(inode, rw == WRITE ? |
1636 | IOMAP_UNWRITTEN : IOMAP_READ); | 1645 | IO_UNWRITTEN : IO_READ); |
1637 | 1646 | ||
1638 | ret = blockdev_direct_IO_no_locking(rw, iocb, inode, bdev, iov, | 1647 | ret = blockdev_direct_IO_no_locking(rw, iocb, inode, bdev, iov, |
1639 | offset, nr_segs, | 1648 | offset, nr_segs, |
diff --git a/fs/xfs/xfs_iomap.h b/fs/xfs/xfs_iomap.h index ba49a4fd1b3f..41e32d20a405 100644 --- a/fs/xfs/xfs_iomap.h +++ b/fs/xfs/xfs_iomap.h | |||
@@ -18,14 +18,6 @@ | |||
18 | #ifndef __XFS_IOMAP_H__ | 18 | #ifndef __XFS_IOMAP_H__ |
19 | #define __XFS_IOMAP_H__ | 19 | #define __XFS_IOMAP_H__ |
20 | 20 | ||
21 | typedef enum { /* iomap_flags values */ | ||
22 | IOMAP_READ = 0, /* mapping for a read */ | ||
23 | IOMAP_DELAY = 0x04, /* mapping covers delalloc region */ | ||
24 | IOMAP_UNWRITTEN = 0x20, /* mapping covers allocated */ | ||
25 | /* but uninitialized file data */ | ||
26 | IOMAP_NEW = 0x40 /* just allocate */ | ||
27 | } iomap_flags_t; | ||
28 | |||
29 | typedef enum { | 21 | typedef enum { |
30 | /* base extent manipulation calls */ | 22 | /* base extent manipulation calls */ |
31 | BMAPI_READ = (1 << 0), /* read extents */ | 23 | BMAPI_READ = (1 << 0), /* read extents */ |