fsync.c 4.6 KB

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