fsync.c 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116
  1. /*
  2. * linux/fs/ext3/fsync.c
  3. *
  4. * Copyright (C) 1993 Stephen Tweedie (sct@redhat.com)
  5. * from
  6. * Copyright (C) 1992 Remy Card (card@masi.ibp.fr)
  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. * ext3fs fsync primitive
  13. *
  14. * Big-endian to little-endian byte-swapping/bitmaps by
  15. * David S. Miller (davem@caip.rutgers.edu), 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/blkdev.h>
  26. #include <linux/fs.h>
  27. #include <linux/sched.h>
  28. #include <linux/writeback.h>
  29. #include <linux/jbd.h>
  30. #include <linux/ext3_fs.h>
  31. #include <linux/ext3_jbd.h>
  32. #include <trace/events/ext3.h>
  33. /*
  34. * akpm: A new design for ext3_sync_file().
  35. *
  36. * This is only called from sys_fsync(), sys_fdatasync() and sys_msync().
  37. * There cannot be a transaction open by this task.
  38. * Another task could have dirtied this inode. Its data can be in any
  39. * state in the journalling system.
  40. *
  41. * What we do is just kick off a commit and wait on it. This will snapshot the
  42. * inode to disk.
  43. */
  44. int ext3_sync_file(struct file *file, loff_t start, loff_t end, int datasync)
  45. {
  46. struct inode *inode = file->f_mapping->host;
  47. struct ext3_inode_info *ei = EXT3_I(inode);
  48. journal_t *journal = EXT3_SB(inode->i_sb)->s_journal;
  49. int ret, needs_barrier = 0;
  50. tid_t commit_tid;
  51. trace_ext3_sync_file_enter(file, datasync);
  52. if (inode->i_sb->s_flags & MS_RDONLY)
  53. return 0;
  54. ret = filemap_write_and_wait_range(inode->i_mapping, start, end);
  55. if (ret)
  56. goto out;
  57. /*
  58. * Taking the mutex here just to keep consistent with how fsync was
  59. * called previously, however it looks like we don't need to take
  60. * i_mutex at all.
  61. */
  62. mutex_lock(&inode->i_mutex);
  63. J_ASSERT(ext3_journal_current_handle() == NULL);
  64. /*
  65. * data=writeback,ordered:
  66. * The caller's filemap_fdatawrite()/wait will sync the data.
  67. * Metadata is in the journal, we wait for a proper transaction
  68. * to commit here.
  69. *
  70. * data=journal:
  71. * filemap_fdatawrite won't do anything (the buffers are clean).
  72. * ext3_force_commit will write the file data into the journal and
  73. * will wait on that.
  74. * filemap_fdatawait() will encounter a ton of newly-dirtied pages
  75. * (they were dirtied by commit). But that's OK - the blocks are
  76. * safe in-journal, which is all fsync() needs to ensure.
  77. */
  78. if (ext3_should_journal_data(inode)) {
  79. mutex_unlock(&inode->i_mutex);
  80. ret = ext3_force_commit(inode->i_sb);
  81. goto out;
  82. }
  83. if (datasync)
  84. commit_tid = atomic_read(&ei->i_datasync_tid);
  85. else
  86. commit_tid = atomic_read(&ei->i_sync_tid);
  87. if (test_opt(inode->i_sb, BARRIER) &&
  88. !journal_trans_will_send_data_barrier(journal, commit_tid))
  89. needs_barrier = 1;
  90. log_start_commit(journal, commit_tid);
  91. ret = log_wait_commit(journal, commit_tid);
  92. /*
  93. * In case we didn't commit a transaction, we have to flush
  94. * disk caches manually so that data really is on persistent
  95. * storage
  96. */
  97. if (needs_barrier)
  98. blkdev_issue_flush(inode->i_sb->s_bdev, GFP_KERNEL, NULL);
  99. mutex_unlock(&inode->i_mutex);
  100. out:
  101. trace_ext3_sync_file_exit(inode, ret);
  102. return ret;
  103. }