| blob | 2b230e9b3badcf1454ca485986ed333a6c6c74a1 |
1 /*
2 * Copyright (C) 2007 Oracle. All rights reserved.
3 *
4 * This program is free software; you can redistribute it and/or
5 * modify it under the terms of the GNU General Public
6 * License v2 as published by the Free Software Foundation.
7 *
8 * This program is distributed in the hope that it will be useful,
9 * but WITHOUT ANY WARRANTY; without even the implied warranty of
10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
11 * General Public License for more details.
12 *
13 * You should have received a copy of the GNU General Public
14 * License along with this program; if not, write to the
15 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
16 * Boston, MA 021110-1307, USA.
17 */
19 #include <linux/fs.h>
20 #include <linux/pagemap.h>
21 #include <linux/highmem.h>
22 #include <linux/time.h>
23 #include <linux/init.h>
24 #include <linux/string.h>
25 #include <linux/backing-dev.h>
26 #include <linux/mpage.h>
27 #include <linux/falloc.h>
28 #include <linux/swap.h>
29 #include <linux/writeback.h>
30 #include <linux/statfs.h>
31 #include <linux/compat.h>
32 #include <linux/slab.h>
33 #include <linux/btrfs.h>
34 #include <linux/uio.h>
46 /*
47 * when auto defrag is enabled we
48 * queue up these defrag structs to remember which
49 * inodes need defragging passes
50 */
53 /* objectid */
54 u64 ino;
55 /*
56 * transid where the defrag was added, we search for
57 * extents newer than this
58 */
59 u64 transid;
61 /* root objectid */
62 u64 root;
64 /* last offset we were able to defrag */
65 u64 last_offset;
67 /* if we've wrapped around back to zero once already */
69 };
73 {
82 else
84 }
86 /* pop a record for an inode into the defrag tree. The lock
87 * must be held already
88 *
89 * If you're inserting a record for an older transid than an
90 * existing record, the transid already in the tree is lowered
91 *
92 * If an existing record is found the defrag item you
93 * pass in is freed
94 */
97 {
115 /* if we're reinserting an entry for
116 * an old defrag run, make sure to
117 * lower the transid of our existing record
118 */
124 }
125 }
130 }
133 {
141 }
143 /*
144 * insert a defrag record for this inode if auto defrag is
145 * enabled
146 */
149 {
152 u64 transid;
163 else
176 /*
177 * If we set IN_DEFRAG flag and evict the inode from memory,
178 * and then re-read this inode, this new inode doesn't have
179 * IN_DEFRAG flag. At the case, we may find the existed defrag.
180 */
186 }
189 }
191 /*
192 * Requeue the defrag object. If there is a defrag object that points to
193 * the same inode in the tree, we will merge them together (by
194 * __btrfs_add_inode_defrag()) and free the one that we want to requeue.
195 */
198 {
205 /*
206 * Here we don't check the IN_DEFRAG flag, because we need merge
207 * them together.
208 */
215 out:
217 }
219 /*
220 * pick the defragable inode that we want, if it doesn't exist, we will get
221 * the next one.
222 */
225 {
246 else
248 }
254 else
256 }
257 out:
262 }
265 {
279 }
281 }
283 #define BTRFS_DEFRAG_BATCH 1024
287 {
296 /* get the inode */
307 }
316 }
319 /* do a chunk of defrag */
327 BTRFS_DEFRAG_BATCH);
329 /*
330 * if we filled the whole defrag batch, there
331 * must be more work to do. Queue this defrag
332 * again
333 */
338 /*
339 * we didn't fill our defrag batch, but
340 * we didn't start at zero. Make sure we loop
341 * around to the start of the file.
342 */
348 }
352 cleanup:
356 }
358 /*
359 * run through the list of inodes in the FS that need
360 * defragging
361 */
363 {
370 /* Pause the auto defragger. */
378 /* find an inode to defrag */
380 first_ino);
388 }
389 }
395 }
398 /*
399 * during unmount, we use the transaction_wait queue to
400 * wait for the defragger to stop
401 */
404 }
406 /* simple helper to fault in pages and copy. This should go away
407 * and be replaced with calls into generic code.
408 */
413 {
423 /*
424 * Copy data from userspace to the current page
425 */
428 /* Flush processor's dcache for this page */
431 /*
432 * if we get a partial write, we can end up with
433 * partially up to date pages. These add
434 * a lot of complexity, so make sure they don't
435 * happen by forcing this copy to be retried.
436 *
437 * The rest of the btrfs_file_write code will fall
438 * back to page at a time copies after we return 0.
439 */
447 /* Return to btrfs_file_write_iter to fault page */
454 pg++;
456 }
457 }
459 }
461 /*
462 * unlocks pages after btrfs_file_write is done with them
463 */
465 {
468 /* page checked is some magic around finding pages that
469 * have been modified without going through btrfs_set_page_dirty
470 * clear it here. There should be no need to mark the pages
471 * accessed as prepare_pages should have marked them accessed
472 * in prepare_pages via find_or_create_page()
473 */
477 }
478 }
480 /*
481 * after copy_from_user, pages need to be dirtied and we need to make
482 * sure holes are created between the current EOF and the start of
483 * any next extents (if required).
484 *
485 * this also makes the decision about creating an inline extent vs
486 * doing real data extents, marking pages dirty and delalloc as required.
487 */
492 {
495 u64 num_bytes;
496 u64 start_pos;
497 u64 end_of_last_block;
506 cached);
515 }
517 /*
518 * we've only changed i_size in ram, and we haven't updated
519 * the disk i_size. There is no need to log the inode
520 * at this time.
521 */
525 }
527 /*
528 * this drops all the extents in the cache that intersect the range
529 * [start, end]. Existing extents are split as required.
530 */
533 {
539 u64 gen;
550 }
567 }
575 }
582 }
600 else
611 }
621 }
646 }
653 }
657 modified);
660 modified);
662 }
665 }
666 next:
671 /* once for us */
673 /* once for the tree*/
675 }
680 }
682 /*
683 * this is very complex, but the basic idea is to drop all extents
684 * in the range start - end. hint_block is filled in with a block number
685 * that would be a good hint to the block allocator for this file.
686 *
687 * If an extent intersects the range but is not entirely inside the range
688 * it is either truncated or split. Anything entirely inside the range
689 * is deleted from the tree.
690 */
696 u32 extent_item_size,
698 {
739 }
741 leafs_visited++;
742 next_slot:
752 }
753 leafs_visited++;
756 }
767 }
787 /* can't happen */
789 }
791 /*
792 * Don't skip extent items representing 0 byte lengths. They
793 * used to be created (bug) if while punching holes we hit
794 * -ENOSPC condition. So if we find one here, just ensure we
795 * delete it, otherwise we would insert a new file extent item
796 * with the same key (offset) as that 0 bytes length file
797 * extent item in the call to setup_items_for_insert() later
798 * in this function.
799 */
806 }
814 }
816 /*
817 * | - range to drop - |
818 * | -------- extent -------- |
819 */
825 }
834 }
860 }
862 }
863 /*
864 * | ---- range to drop ----- |
865 * | -------- extent -------- |
866 */
871 }
885 }
888 /*
889 * | ---- range to drop ----- |
890 * | -------- extent -------- |
891 */
897 }
909 }
911 /*
912 * | ---- range to drop ----- |
913 * | ------ extent ------ |
914 */
916 delete_extent_item:
922 del_nr++;
923 }
940 }
948 }
951 del_nr);
955 }
962 }
965 }
968 /*
969 * Set path->slots[0] to first slot, so that after the delete
970 * if items are move off from our leaf to its immediate left or
971 * right neighbor leafs, we end up with a correct and adjusted
972 * path->slots[0] for our insertion (if replace_extent != 0).
973 */
978 }
981 /*
982 * If btrfs_del_items() was called, it might have deleted a leaf, in
983 * which case it unlocked our path, so check path->locks[0] matches a
984 * write lock.
985 */
1001 }
1004 extent_item_size,
1008 }
1015 }
1020 {
1031 }
1036 {
1039 u64 extent_end;
1064 }
1066 /*
1067 * Mark extent in the range start - end as written.
1068 *
1069 * This changes extent type from 'pre-allocated' to 'regular'. If only
1070 * part of extent is marked as written, the extent will be split into
1071 * two or three.
1072 */
1075 {
1082 u64 bytenr;
1083 u64 num_bytes;
1084 u64 extent_end;
1085 u64 orig_offset;
1086 u64 other_start;
1087 u64 other_end;
1088 u64 split;
1098 again:
1117 BTRFS_FILE_EXTENT_PREALLOC);
1150 }
1151 }
1179 }
1180 }
1191 }
1195 }
1224 }
1226 }
1236 }
1239 del_nr++;
1244 }
1253 }
1256 del_nr++;
1261 }
1266 BTRFS_FILE_EXTENT_REG);
1273 BTRFS_FILE_EXTENT_REG);
1283 }
1284 }
1285 out:
1288 }
1290 /*
1291 * on error we return an unlocked page and the error value
1292 * on success we return a locked page and 0
1293 */
1296 {
1308 }
1309 }
1311 }
1313 /*
1314 * this just gets pages into the page cache and locks them down.
1315 */
1319 {
1333 }
1337 force_uptodate);
1345 }
1347 }
1350 fail:
1354 faili--;
1355 }
1358 }
1360 /*
1361 * This function locks the extent and properly waits for data=ordered extents
1362 * to finish before allowing the pages to be modified if need.
1363 *
1364 * The return value:
1365 * 1 - the extent is locked
1366 * 0 - the extent is not locked, and everything is OK
1367 * -EAGAIN - need re-prepare the pages
1368 * the other < 0 number - Something wrong happens
1369 */
1375 {
1376 u64 start_pos;
1377 u64 last_pos;
1399 }
1403 }
1414 }
1421 }
1424 }
1428 {
1432 u64 num_bytes;
1448 }
1452 }
1462 }
1467 }
1471 loff_t pos)
1472 {
1478 u64 lockstart;
1479 u64 lockend;
1502 offset);
1504 PAGE_CACHE_SIZE);
1511 /*
1512 * Fault pages before locking them in prepare_pages
1513 * to avoid recursive lock
1514 */
1518 }
1524 BTRFS_INODE_PREALLOC))) {
1528 /*
1529 * our prealloc extent may be smaller than
1530 * write_bytes, so scale down.
1531 */
1533 PAGE_CACHE_SIZE);
1538 }
1539 }
1548 reserve_bytes);
1549 else
1552 }
1556 again:
1557 /*
1558 * This is going to setup the pages array with the number of
1559 * pages we want, so we don't really need to worry about the
1560 * contents of pages from loop to loop
1561 */
1564 force_page_uptodate);
1578 }
1583 /*
1584 * if we have trouble faulting in the pages, fall
1585 * back to one page at a time
1586 */
1596 PAGE_CACHE_SIZE);
1597 }
1599 /*
1600 * If we had a short copy we need to release the excess delaloc
1601 * bytes we reserved. We need to increment outstanding_extents
1602 * because btrfs_delalloc_release_space will decrement it, but
1603 * we still have an outstanding extent for the chunk we actually
1604 * managed to copy.
1605 */
1608 PAGE_CACHE_SHIFT;
1613 }
1616 release_bytes);
1617 else
1619 release_bytes);
1620 }
1627 NULL);
1631 GFP_NOFS);
1635 }
1650 }
1662 }
1672 }
1673 }
1676 }
1680 loff_t pos)
1681 {
1684 ssize_t written;
1685 ssize_t written_buffered;
1686 loff_t endbyte;
1699 }
1700 /*
1701 * Ensure all data is persisted. We want the next direct IO read to be
1702 * able to read what was just written.
1703 */
1715 out:
1717 }
1720 {
1735 }
1739 {
1743 u64 start_pos;
1744 u64 end_pos;
1747 ssize_t err;
1748 loff_t pos;
1756 }
1763 }
1765 /*
1766 * If BTRFS flips readonly due to some impossible error
1767 * (fs_info->fs_state now has BTRFS_SUPER_FLAG_ERROR),
1768 * although we have opened a file as writable, we have
1769 * to stop this write operation to ensure FS consistency.
1770 */
1775 }
1777 /*
1778 * We reserve space for updating the inode when we reserve space for the
1779 * extent we are going to write, so we will enospc out there. We don't
1780 * need to start yet another transaction to update the inode as we will
1781 * update the inode when we finish writing whatever data we write.
1782 */
1789 /* Expand hole size to cover write data, preventing empty gap */
1795 }
1796 }
1807 }
1811 /*
1812 * We also have to set last_sub_trans to the current log transid,
1813 * otherwise subsequent syncs to a file that's been synced in this
1814 * transaction will appear to have already occured.
1815 */
1823 }
1827 out:
1830 }
1833 {
1836 /*
1837 * ordered_data_close is set by settattr when we are about to truncate
1838 * a file from a non-zero size to a zero size. This tries to
1839 * flush down new bytes that may have been written if the
1840 * application were using truncate to replace a file in place.
1841 */
1846 }
1849 {
1857 }
1859 /*
1860 * fsync call for both files and directories. This logs the inode into
1861 * the tree log instead of forcing full commits whenever possible.
1862 *
1863 * It needs to call filemap_fdatawait so that all ordered extent updates are
1864 * in the metadata btree are up to date for copying to the log.
1865 *
1866 * It drops the inode mutex before doing the tree log commit. This is an
1867 * important optimization for directories because holding the mutex prevents
1868 * new operations on the dir while we write to disk.
1869 */
1871 {
1882 /*
1883 * We write the dirty pages in the range and wait until they complete
1884 * out of the ->i_mutex. If so, we can flush the dirty pages by
1885 * multi-task, and make the performance up. See
1886 * btrfs_wait_ordered_range for an explanation of the ASYNC check.
1887 */
1896 /*
1897 * We might have have had more pages made dirty after calling
1898 * start_ordered_ops and before acquiring the inode's i_mutex.
1899 */
1901 /*
1902 * For a full sync, we need to make sure any ordered operations
1903 * start and finish before we start logging the inode, so that
1904 * all extents are persisted and the respective file extent
1905 * items are in the fs/subvol btree.
1906 */
1909 /*
1910 * Start any new ordered operations before starting to log the
1911 * inode. We will wait for them to finish in btrfs_sync_log().
1912 *
1913 * Right before acquiring the inode's mutex, we might have new
1914 * writes dirtying pages, which won't immediately start the
1915 * respective ordered operations - that is done through the
1916 * fill_delalloc callbacks invoked from the writepage and
1917 * writepages address space operations. So make sure we start
1918 * all ordered operations before starting to log our inode. Not
1919 * doing this means that while logging the inode, writeback
1920 * could start and invoke writepage/writepages, which would call
1921 * the fill_delalloc callbacks (cow_file_range,
1922 * submit_compressed_extents). These callbacks add first an
1923 * extent map to the modified list of extents and then create
1924 * the respective ordered operation, which means in
1925 * tree-log.c:btrfs_log_inode() we might capture all existing
1926 * ordered operations (with btrfs_get_logged_extents()) before
1927 * the fill_delalloc callback adds its ordered operation, and by
1928 * the time we visit the modified list of extent maps (with
1929 * btrfs_log_changed_extents()), we see and process the extent
1930 * map they created. We then use the extent map to construct a
1931 * file extent item for logging without waiting for the
1932 * respective ordered operation to finish - this file extent
1933 * item points to a disk location that might not have yet been
1934 * written to, containing random data - so after a crash a log
1935 * replay will make our inode have file extent items that point
1936 * to disk locations containing invalid data, as we returned
1937 * success to userspace without waiting for the respective
1938 * ordered operation to finish, because it wasn't captured by
1939 * btrfs_get_logged_extents().
1940 */
1942 }
1946 }
1949 /*
1950 * If the last transaction that changed this file was before the current
1951 * transaction and we have the full sync flag set in our inode, we can
1952 * bail out now without any syncing.
1953 *
1954 * Note that we can't bail out if the full sync flag isn't set. This is
1955 * because when the full sync flag is set we start all ordered extents
1956 * and wait for them to fully complete - when they complete they update
1957 * the inode's last_trans field through:
1958 *
1959 * btrfs_finish_ordered_io() ->
1960 * btrfs_update_inode_fallback() ->
1961 * btrfs_update_inode() ->
1962 * btrfs_set_inode_last_trans()
1963 *
1964 * So we are sure that last_trans is up to date and can do this check to
1965 * bail out safely. For the fast path, when the full sync flag is not
1966 * set in our inode, we can not do it because we start only our ordered
1967 * extents and don't wait for them to complete (that is when
1968 * btrfs_finish_ordered_io runs), so here at this point their last_trans
1969 * value might be less than or equals to fs_info->last_trans_committed,
1970 * and setting a speculative last_trans for an inode when a buffered
1971 * write is made (such as fs_info->generation + 1 for example) would not
1972 * be reliable since after setting the value and before fsync is called
1973 * any number of transactions can start and commit (transaction kthread
1974 * commits the current transaction periodically), and a transaction
1975 * commit does not start nor waits for ordered extents to complete.
1976 */
1981 /*
1982 * We'v had everything committed since the last time we were
1983 * modified so clear this flag in case it was set for whatever
1984 * reason, it's no longer relevant.
1985 */
1990 }
1992 /*
1993 * ok we haven't committed the transaction yet, lets do a commit
1994 */
1998 /*
1999 * We use start here because we will need to wait on the IO to complete
2000 * in btrfs_sync_log, which could require joining a transaction (for
2001 * example checking cross references in the nocow path). If we use join
2002 * here we could get into a situation where we're waiting on IO to
2003 * happen that is blocked on a transaction trying to commit. With start
2004 * we inc the extwriter counter, so we wait for all extwriters to exit
2005 * before we start blocking join'ers. This comment is to keep somebody
2006 * from thinking they are super smart and changing this to
2007 * btrfs_join_transaction *cough*Josef*cough*.
2008 */
2014 }
2021 /* Fallthrough and commit/free transaction. */
2023 }
2025 /* we've logged all the items and now have a consistent
2026 * version of the file in the log. It is possible that
2027 * someone will come in and modify the file, but that's
2028 * fine because the log is consistent on disk, and we
2029 * have references to all of the file's extents
2030 *
2031 * It is possible that someone will come in and log the
2032 * file again, but that will end up using the synchronization
2033 * inside btrfs_sync_log to keep things safe.
2034 */
2037 /*
2038 * If any of the ordered extents had an error, just return it to user
2039 * space, so that the application knows some writes didn't succeed and
2040 * can take proper action (retry for e.g.). Blindly committing the
2041 * transaction in this case, would fool userspace that everything was
2042 * successful. And we also want to make sure our log doesn't contain
2043 * file extent items pointing to extents that weren't fully written to -
2044 * just like in the non fast fsync path, where we check for the ordered
2045 * operation's error flag before writing to the log tree and return -EIO
2046 * if any of them had this flag set (btrfs_wait_ordered_range) -
2047 * therefore we need to check for errors in the ordered operations,
2048 * which are indicated by ctx.io_err.
2049 */
2054 }
2062 }
2063 }
2070 }
2071 }
2075 }
2076 out:
2078 }
2084 };
2087 {
2097 }
2101 {
2126 }
2130 {
2153 u64 num_bytes;
2165 }
2168 u64 num_bytes;
2175 offset;
2181 }
2190 out:
2221 }
2224 }
2226 /*
2227 * Find a hole extent on given inode and change start/len to the end of hole
2228 * extent.(hole/vacuum extent whose em->start <= start &&
2229 * em->start + em->len > start)
2230 * When a hole extent is found, return 1 and modify start/len.
2231 */
2233 {
2241 else
2244 }
2246 /* Hole or vacuum extent(only exists in no-hole mode) */
2252 }
2255 }
2258 {
2264 u64 lockstart;
2265 u64 lockend;
2266 u64 tail_start;
2267 u64 tail_len;
2269 u64 cur_offset;
2271 u64 drop_end;
2277 u64 ino_size;
2291 /* Already in a large hole */
2294 }
2302 /*
2303 * We needn't truncate any page which is beyond the end of the file
2304 * because we are sure there is no data there.
2305 */
2306 /*
2307 * Only do this if we are in the same page and we aren't doing the
2308 * entire page.
2309 */
2316 }
2318 }
2320 /* zero back part of the first page */
2327 }
2328 }
2330 /* Check the aligned pages after the first unaligned page,
2331 * if offset != orig_start, which means the first unaligned page
2332 * including serveral following pages are already in holes,
2333 * the extra check can be skipped */
2335 /* after truncate page, check hole again */
2344 }
2346 }
2348 /* Check the tail unaligned part is in a hole */
2356 /* zero the front end of the last page */
2363 }
2364 }
2365 }
2370 }
2381 /*
2382 * We need to make sure we have no ordered extents in this range
2383 * and nobody raced in and read a page in this range, if we did
2384 * we need to try again.
2385 */
2393 }
2403 }
2404 }
2410 }
2416 }
2420 /*
2421 * 1 - update the inode
2422 * 1 - removing the extents in the range
2423 * 1 - adding the hole extent if no_holes isn't set
2424 */
2430 }
2433 min_size);
2450 drop_end);
2454 }
2455 }
2463 }
2473 }
2486 }
2487 }
2492 }
2495 /*
2496 * Don't insert file hole extent item if it's for a range beyond eof
2497 * (because it's useless) or if it represents a 0 bytes range (when
2498 * cur_offset == drop_end).
2499 */
2505 }
2506 }
2508 out_trans:
2520 out_free:
2523 out:
2526 out_only_mutex:
2528 /*
2529 * If we only end up zeroing part of a page, we still need to
2530 * update the inode item, so that all the time fields are
2531 * updated as well as the necessary btrfs inode in memory fields
2532 * for detecting, at fsync time, if the inode isn't yet in the
2533 * log tree or it's there but not up to date.
2534 */
2541 }
2542 }
2547 }
2551 {
2554 u64 cur_offset;
2555 u64 last_byte;
2556 u64 alloc_start;
2557 u64 alloc_end;
2559 u64 locked_end;
2567 /* Make sure we aren't being give some crap mode */
2574 /*
2575 * Make sure we have enough space before we do the
2576 * allocation.
2577 */
2589 alloc_start);
2593 /*
2594 * If we are fallocating from the end of the file onward we
2595 * need to zero out the end of the page if i_size lands in the
2596 * middle of a page.
2597 */
2601 }
2603 /*
2604 * wait for ordered IO before we have any locks. We'll loop again
2605 * below with the locks held.
2606 */
2616 /* the extent lock is ordered inside the running
2617 * transaction
2618 */
2630 /*
2631 * we can't wait on the range with the transaction
2632 * running or with the extent lock held
2633 */
2642 }
2643 }
2647 u64 actual_end;
2654 else
2657 }
2675 /*
2676 * We didn't need to allocate any more space, but we
2677 * still extended the size of the file so we need to
2678 * update i_size and the inode item.
2679 */
2687 NULL);
2691 else
2693 root);
2694 }
2695 }
2704 }
2705 }
2708 out:
2710 /* Let go of our reservation. */
2713 }
2716 {
2720 u64 lockstart;
2721 u64 lockend;
2722 u64 start;
2723 u64 len;
2729 /*
2730 * *offset can be negative, in this case we start finding DATA/HOLE from
2731 * the very start of the file.
2732 */
2739 lockend--;
2751 }
2766 }
2771 else
2773 }
2777 }
2780 {
2795 }
2801 }
2802 }
2805 out:
2808 }
2821 #ifdef CONFIG_COMPAT
2823 #endif
2824 };
2827 {
2830 }
2833 {
2837 NULL);
2842 }
2845 {
2848 /*
2849 * So with compression we will find and lock a dirty page and clear the
2850 * first one as dirty, setup an async extent, and immediately return
2851 * with the entire range locked but with nobody actually marked with
2852 * writeback. So we can't just filemap_write_and_wait_range() and
2853 * expect it to work since it will just kick off a thread to do the
2854 * actual work. So we need to call filemap_fdatawrite_range _again_
2855 * since it will wait on the page lock, which won't be unlocked until
2856 * after the pages have been marked as writeback and so we're good to go
2857 * from there. We have to do this otherwise we'll miss the ordered
2858 * extents and that results in badness. Please Josef, do not think you
2859 * know better and pull this out at some point in the future, it is
2860 * right and you are wrong.
2861 */
2868 }