file.c 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165
  1. // SPDX-License-Identifier: GPL-2.0+
  2. /*
  3. * NILFS regular file handling primitives including fsync().
  4. *
  5. * Copyright (C) 2005-2008 Nippon Telegraph and Telephone Corporation.
  6. *
  7. * Written by Amagai Yoshiji and Ryusuke Konishi.
  8. */
  9. #include <linux/fs.h>
  10. #include <linux/filelock.h>
  11. #include <linux/mm.h>
  12. #include <linux/writeback.h>
  13. #include "nilfs.h"
  14. #include "segment.h"
  15. int nilfs_sync_file(struct file *file, loff_t start, loff_t end, int datasync)
  16. {
  17. /*
  18. * Called from fsync() system call
  19. * This is the only entry point that can catch write and synch
  20. * timing for both data blocks and intermediate blocks.
  21. *
  22. * This function should be implemented when the writeback function
  23. * will be implemented.
  24. */
  25. struct the_nilfs *nilfs;
  26. struct inode *inode = file->f_mapping->host;
  27. int err = 0;
  28. if (nilfs_inode_dirty(inode)) {
  29. if (datasync)
  30. err = nilfs_construct_dsync_segment(inode->i_sb, inode,
  31. start, end);
  32. else
  33. err = nilfs_construct_segment(inode->i_sb);
  34. }
  35. nilfs = inode->i_sb->s_fs_info;
  36. if (!err)
  37. err = nilfs_flush_device(nilfs);
  38. return err;
  39. }
  40. static vm_fault_t nilfs_page_mkwrite(struct vm_fault *vmf)
  41. {
  42. struct vm_area_struct *vma = vmf->vma;
  43. struct folio *folio = page_folio(vmf->page);
  44. struct inode *inode = file_inode(vma->vm_file);
  45. struct nilfs_transaction_info ti;
  46. struct buffer_head *bh, *head;
  47. int ret = 0;
  48. if (unlikely(nilfs_near_disk_full(inode->i_sb->s_fs_info)))
  49. return VM_FAULT_SIGBUS; /* -ENOSPC */
  50. sb_start_pagefault(inode->i_sb);
  51. folio_lock(folio);
  52. if (folio->mapping != inode->i_mapping ||
  53. folio_pos(folio) >= i_size_read(inode) ||
  54. !folio_test_uptodate(folio)) {
  55. folio_unlock(folio);
  56. ret = -EFAULT; /* make the VM retry the fault */
  57. goto out;
  58. }
  59. /*
  60. * check to see if the folio is mapped already (no holes)
  61. */
  62. if (folio_test_mappedtodisk(folio))
  63. goto mapped;
  64. head = folio_buffers(folio);
  65. if (head) {
  66. int fully_mapped = 1;
  67. bh = head;
  68. do {
  69. if (!buffer_mapped(bh)) {
  70. fully_mapped = 0;
  71. break;
  72. }
  73. } while (bh = bh->b_this_page, bh != head);
  74. if (fully_mapped) {
  75. folio_set_mappedtodisk(folio);
  76. goto mapped;
  77. }
  78. }
  79. folio_unlock(folio);
  80. /*
  81. * fill hole blocks
  82. */
  83. ret = nilfs_transaction_begin(inode->i_sb, &ti, 1);
  84. /* never returns -ENOMEM, but may return -ENOSPC */
  85. if (unlikely(ret))
  86. goto out;
  87. file_update_time(vma->vm_file);
  88. ret = block_page_mkwrite(vma, vmf, nilfs_get_block);
  89. if (ret) {
  90. nilfs_transaction_abort(inode->i_sb);
  91. goto out;
  92. }
  93. nilfs_set_file_dirty(inode, 1 << (PAGE_SHIFT - inode->i_blkbits));
  94. nilfs_transaction_commit(inode->i_sb);
  95. mapped:
  96. /*
  97. * Since checksumming including data blocks is performed to determine
  98. * the validity of the log to be written and used for recovery, it is
  99. * necessary to wait for writeback to finish here, regardless of the
  100. * stable write requirement of the backing device.
  101. */
  102. folio_wait_writeback(folio);
  103. out:
  104. sb_end_pagefault(inode->i_sb);
  105. return vmf_fs_error(ret);
  106. }
  107. static const struct vm_operations_struct nilfs_file_vm_ops = {
  108. .fault = filemap_fault,
  109. .map_pages = filemap_map_pages,
  110. .page_mkwrite = nilfs_page_mkwrite,
  111. };
  112. static int nilfs_file_mmap_prepare(struct vm_area_desc *desc)
  113. {
  114. file_accessed(desc->file);
  115. desc->vm_ops = &nilfs_file_vm_ops;
  116. return 0;
  117. }
  118. /*
  119. * We have mostly NULL's here: the current defaults are ok for
  120. * the nilfs filesystem.
  121. */
  122. const struct file_operations nilfs_file_operations = {
  123. .llseek = generic_file_llseek,
  124. .read_iter = generic_file_read_iter,
  125. .write_iter = generic_file_write_iter,
  126. .unlocked_ioctl = nilfs_ioctl,
  127. #ifdef CONFIG_COMPAT
  128. .compat_ioctl = nilfs_compat_ioctl,
  129. #endif /* CONFIG_COMPAT */
  130. .mmap_prepare = nilfs_file_mmap_prepare,
  131. .open = generic_file_open,
  132. /* .release = nilfs_release_file, */
  133. .fsync = nilfs_sync_file,
  134. .splice_read = filemap_splice_read,
  135. .splice_write = iter_file_splice_write,
  136. .setlease = generic_setlease,
  137. };
  138. const struct inode_operations nilfs_file_inode_operations = {
  139. .setattr = nilfs_setattr,
  140. .permission = nilfs_permission,
  141. .fiemap = nilfs_fiemap,
  142. .fileattr_get = nilfs_fileattr_get,
  143. .fileattr_set = nilfs_fileattr_set,
  144. };
  145. /* end of file */