fsync.c 4.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168
  1. // SPDX-License-Identifier: GPL-2.0
  2. /*
  3. * linux/fs/ext4/fsync.c
  4. *
  5. * Copyright (C) 1993 Stephen Tweedie (sct@redhat.com)
  6. * from
  7. * Copyright (C) 1992 Remy Card (card@masi.ibp.fr)
  8. * Laboratoire MASI - Institut Blaise Pascal
  9. * Universite Pierre et Marie Curie (Paris VI)
  10. * from
  11. * linux/fs/minix/truncate.c Copyright (C) 1991, 1992 Linus Torvalds
  12. *
  13. * ext4fs fsync primitive
  14. *
  15. * Big-endian to little-endian byte-swapping/bitmaps by
  16. * David S. Miller (davem@caip.rutgers.edu), 1995
  17. *
  18. * Removed unnecessary code duplication for little endian machines
  19. * and excessive __inline__s.
  20. * Andi Kleen, 1997
  21. *
  22. * Major simplications and cleanup - we only need to do the metadata, because
  23. * we can depend on generic_block_fdatasync() to sync the data blocks.
  24. */
  25. #include <linux/time.h>
  26. #include <linux/fs.h>
  27. #include <linux/sched.h>
  28. #include <linux/writeback.h>
  29. #include <linux/blkdev.h>
  30. #include "ext4.h"
  31. #include "ext4_jbd2.h"
  32. #include <trace/events/ext4.h>
  33. /*
  34. * If we're not journaling and this is a just-created file, we have to
  35. * sync our parent directory (if it was freshly created) since
  36. * otherwise it will only be written by writeback, leaving a huge
  37. * window during which a crash may lose the file. This may apply for
  38. * the parent directory's parent as well, and so on recursively, if
  39. * they are also freshly created.
  40. */
  41. static int ext4_sync_parent(struct inode *inode)
  42. {
  43. struct dentry *dentry = NULL;
  44. struct inode *next;
  45. int ret = 0;
  46. if (!ext4_test_inode_state(inode, EXT4_STATE_NEWENTRY))
  47. return 0;
  48. inode = igrab(inode);
  49. while (ext4_test_inode_state(inode, EXT4_STATE_NEWENTRY)) {
  50. ext4_clear_inode_state(inode, EXT4_STATE_NEWENTRY);
  51. dentry = d_find_any_alias(inode);
  52. if (!dentry)
  53. break;
  54. next = igrab(d_inode(dentry->d_parent));
  55. dput(dentry);
  56. if (!next)
  57. break;
  58. iput(inode);
  59. inode = next;
  60. /*
  61. * The directory inode may have gone through rmdir by now. But
  62. * the inode itself and its blocks are still allocated (we hold
  63. * a reference to the inode so it didn't go through
  64. * ext4_evict_inode()) and so we are safe to flush metadata
  65. * blocks and the inode.
  66. */
  67. ret = sync_mapping_buffers(inode->i_mapping);
  68. if (ret)
  69. break;
  70. ret = sync_inode_metadata(inode, 1);
  71. if (ret)
  72. break;
  73. }
  74. iput(inode);
  75. return ret;
  76. }
  77. /*
  78. * akpm: A new design for ext4_sync_file().
  79. *
  80. * This is only called from sys_fsync(), sys_fdatasync() and sys_msync().
  81. * There cannot be a transaction open by this task.
  82. * Another task could have dirtied this inode. Its data can be in any
  83. * state in the journalling system.
  84. *
  85. * What we do is just kick off a commit and wait on it. This will snapshot the
  86. * inode to disk.
  87. */
  88. int ext4_sync_file(struct file *file, loff_t start, loff_t end, int datasync)
  89. {
  90. struct inode *inode = file->f_mapping->host;
  91. struct ext4_inode_info *ei = EXT4_I(inode);
  92. journal_t *journal = EXT4_SB(inode->i_sb)->s_journal;
  93. int ret = 0, err;
  94. tid_t commit_tid;
  95. bool needs_barrier = false;
  96. if (unlikely(ext4_forced_shutdown(EXT4_SB(inode->i_sb))))
  97. return -EIO;
  98. J_ASSERT(ext4_journal_current_handle() == NULL);
  99. trace_ext4_sync_file_enter(file, datasync);
  100. if (sb_rdonly(inode->i_sb)) {
  101. /* Make sure that we read updated s_mount_flags value */
  102. smp_rmb();
  103. if (EXT4_SB(inode->i_sb)->s_mount_flags & EXT4_MF_FS_ABORTED)
  104. ret = -EROFS;
  105. goto out;
  106. }
  107. if (!journal) {
  108. ret = __generic_file_fsync(file, start, end, datasync);
  109. if (!ret)
  110. ret = ext4_sync_parent(inode);
  111. if (test_opt(inode->i_sb, BARRIER))
  112. goto issue_flush;
  113. goto out;
  114. }
  115. ret = file_write_and_wait_range(file, start, end);
  116. if (ret)
  117. return ret;
  118. /*
  119. * data=writeback,ordered:
  120. * The caller's filemap_fdatawrite()/wait will sync the data.
  121. * Metadata is in the journal, we wait for proper transaction to
  122. * commit here.
  123. *
  124. * data=journal:
  125. * filemap_fdatawrite won't do anything (the buffers are clean).
  126. * ext4_force_commit will write the file data into the journal and
  127. * will wait on that.
  128. * filemap_fdatawait() will encounter a ton of newly-dirtied pages
  129. * (they were dirtied by commit). But that's OK - the blocks are
  130. * safe in-journal, which is all fsync() needs to ensure.
  131. */
  132. if (ext4_should_journal_data(inode)) {
  133. ret = ext4_force_commit(inode->i_sb);
  134. goto out;
  135. }
  136. commit_tid = datasync ? ei->i_datasync_tid : ei->i_sync_tid;
  137. if (journal->j_flags & JBD2_BARRIER &&
  138. !jbd2_trans_will_send_data_barrier(journal, commit_tid))
  139. needs_barrier = true;
  140. ret = jbd2_complete_transaction(journal, commit_tid);
  141. if (needs_barrier) {
  142. issue_flush:
  143. err = blkdev_issue_flush(inode->i_sb->s_bdev, GFP_KERNEL, NULL);
  144. if (!ret)
  145. ret = err;
  146. }
  147. out:
  148. err = file_check_and_advance_wb_err(file);
  149. if (ret == 0)
  150. ret = err;
  151. trace_ext4_sync_file_exit(inode, ret);
  152. return ret;
  153. }