This source file includes following definitions.
- __clear_shadow_entry
- clear_shadow_entry
- truncate_exceptional_pvec_entries
- invalidate_exceptional_entry
- invalidate_exceptional_entry2
- do_invalidatepage
- truncate_cleanup_page
- invalidate_complete_page
- truncate_inode_page
- generic_error_remove_page
- invalidate_inode_page
- truncate_inode_pages_range
- truncate_inode_pages
- truncate_inode_pages_final
- invalidate_mapping_pages
- invalidate_complete_page2
- do_launder_page
- invalidate_inode_pages2_range
- invalidate_inode_pages2
- truncate_pagecache
- truncate_setsize
- pagecache_isize_extended
- truncate_pagecache_range
1
2
3
4
5
6
7
8
9
10
11 #include <linux/kernel.h>
12 #include <linux/backing-dev.h>
13 #include <linux/dax.h>
14 #include <linux/gfp.h>
15 #include <linux/mm.h>
16 #include <linux/swap.h>
17 #include <linux/export.h>
18 #include <linux/pagemap.h>
19 #include <linux/highmem.h>
20 #include <linux/pagevec.h>
21 #include <linux/task_io_accounting_ops.h>
22 #include <linux/buffer_head.h>
23
24 #include <linux/shmem_fs.h>
25 #include <linux/cleancache.h>
26 #include <linux/rmap.h>
27 #include "internal.h"
28
29
30
31
32
33
34 static inline void __clear_shadow_entry(struct address_space *mapping,
35 pgoff_t index, void *entry)
36 {
37 XA_STATE(xas, &mapping->i_pages, index);
38
39 xas_set_update(&xas, workingset_update_node);
40 if (xas_load(&xas) != entry)
41 return;
42 xas_store(&xas, NULL);
43 mapping->nrexceptional--;
44 }
45
46 static void clear_shadow_entry(struct address_space *mapping, pgoff_t index,
47 void *entry)
48 {
49 xa_lock_irq(&mapping->i_pages);
50 __clear_shadow_entry(mapping, index, entry);
51 xa_unlock_irq(&mapping->i_pages);
52 }
53
54
55
56
57
58
59 static void truncate_exceptional_pvec_entries(struct address_space *mapping,
60 struct pagevec *pvec, pgoff_t *indices,
61 pgoff_t end)
62 {
63 int i, j;
64 bool dax, lock;
65
66
67 if (shmem_mapping(mapping))
68 return;
69
70 for (j = 0; j < pagevec_count(pvec); j++)
71 if (xa_is_value(pvec->pages[j]))
72 break;
73
74 if (j == pagevec_count(pvec))
75 return;
76
77 dax = dax_mapping(mapping);
78 lock = !dax && indices[j] < end;
79 if (lock)
80 xa_lock_irq(&mapping->i_pages);
81
82 for (i = j; i < pagevec_count(pvec); i++) {
83 struct page *page = pvec->pages[i];
84 pgoff_t index = indices[i];
85
86 if (!xa_is_value(page)) {
87 pvec->pages[j++] = page;
88 continue;
89 }
90
91 if (index >= end)
92 continue;
93
94 if (unlikely(dax)) {
95 dax_delete_mapping_entry(mapping, index);
96 continue;
97 }
98
99 __clear_shadow_entry(mapping, index, page);
100 }
101
102 if (lock)
103 xa_unlock_irq(&mapping->i_pages);
104 pvec->nr = j;
105 }
106
107
108
109
110
111 static int invalidate_exceptional_entry(struct address_space *mapping,
112 pgoff_t index, void *entry)
113 {
114
115 if (shmem_mapping(mapping) || dax_mapping(mapping))
116 return 1;
117 clear_shadow_entry(mapping, index, entry);
118 return 1;
119 }
120
121
122
123
124
125 static int invalidate_exceptional_entry2(struct address_space *mapping,
126 pgoff_t index, void *entry)
127 {
128
129 if (shmem_mapping(mapping))
130 return 1;
131 if (dax_mapping(mapping))
132 return dax_invalidate_mapping_entry_sync(mapping, index);
133 clear_shadow_entry(mapping, index, entry);
134 return 1;
135 }
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152 void do_invalidatepage(struct page *page, unsigned int offset,
153 unsigned int length)
154 {
155 void (*invalidatepage)(struct page *, unsigned int, unsigned int);
156
157 invalidatepage = page->mapping->a_ops->invalidatepage;
158 #ifdef CONFIG_BLOCK
159 if (!invalidatepage)
160 invalidatepage = block_invalidatepage;
161 #endif
162 if (invalidatepage)
163 (*invalidatepage)(page, offset, length);
164 }
165
166
167
168
169
170
171
172
173
174
175
176 static void
177 truncate_cleanup_page(struct address_space *mapping, struct page *page)
178 {
179 if (page_mapped(page)) {
180 pgoff_t nr = PageTransHuge(page) ? HPAGE_PMD_NR : 1;
181 unmap_mapping_pages(mapping, page->index, nr, false);
182 }
183
184 if (page_has_private(page))
185 do_invalidatepage(page, 0, PAGE_SIZE);
186
187
188
189
190
191
192 cancel_dirty_page(page);
193 ClearPageMappedToDisk(page);
194 }
195
196
197
198
199
200
201
202
203
204 static int
205 invalidate_complete_page(struct address_space *mapping, struct page *page)
206 {
207 int ret;
208
209 if (page->mapping != mapping)
210 return 0;
211
212 if (page_has_private(page) && !try_to_release_page(page, 0))
213 return 0;
214
215 ret = remove_mapping(mapping, page);
216
217 return ret;
218 }
219
220 int truncate_inode_page(struct address_space *mapping, struct page *page)
221 {
222 VM_BUG_ON_PAGE(PageTail(page), page);
223
224 if (page->mapping != mapping)
225 return -EIO;
226
227 truncate_cleanup_page(mapping, page);
228 delete_from_page_cache(page);
229 return 0;
230 }
231
232
233
234
235 int generic_error_remove_page(struct address_space *mapping, struct page *page)
236 {
237 if (!mapping)
238 return -EINVAL;
239
240
241
242
243 if (!S_ISREG(mapping->host->i_mode))
244 return -EIO;
245 return truncate_inode_page(mapping, page);
246 }
247 EXPORT_SYMBOL(generic_error_remove_page);
248
249
250
251
252
253
254
255 int invalidate_inode_page(struct page *page)
256 {
257 struct address_space *mapping = page_mapping(page);
258 if (!mapping)
259 return 0;
260 if (PageDirty(page) || PageWriteback(page))
261 return 0;
262 if (page_mapped(page))
263 return 0;
264 return invalidate_complete_page(mapping, page);
265 }
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291 void truncate_inode_pages_range(struct address_space *mapping,
292 loff_t lstart, loff_t lend)
293 {
294 pgoff_t start;
295 pgoff_t end;
296 unsigned int partial_start;
297 unsigned int partial_end;
298 struct pagevec pvec;
299 pgoff_t indices[PAGEVEC_SIZE];
300 pgoff_t index;
301 int i;
302
303 if (mapping->nrpages == 0 && mapping->nrexceptional == 0)
304 goto out;
305
306
307 partial_start = lstart & (PAGE_SIZE - 1);
308 partial_end = (lend + 1) & (PAGE_SIZE - 1);
309
310
311
312
313
314
315
316 start = (lstart + PAGE_SIZE - 1) >> PAGE_SHIFT;
317 if (lend == -1)
318
319
320
321
322
323 end = -1;
324 else
325 end = (lend + 1) >> PAGE_SHIFT;
326
327 pagevec_init(&pvec);
328 index = start;
329 while (index < end && pagevec_lookup_entries(&pvec, mapping, index,
330 min(end - index, (pgoff_t)PAGEVEC_SIZE),
331 indices)) {
332
333
334
335
336
337 struct pagevec locked_pvec;
338
339 pagevec_init(&locked_pvec);
340 for (i = 0; i < pagevec_count(&pvec); i++) {
341 struct page *page = pvec.pages[i];
342
343
344 index = indices[i];
345 if (index >= end)
346 break;
347
348 if (xa_is_value(page))
349 continue;
350
351 if (!trylock_page(page))
352 continue;
353 WARN_ON(page_to_index(page) != index);
354 if (PageWriteback(page)) {
355 unlock_page(page);
356 continue;
357 }
358 if (page->mapping != mapping) {
359 unlock_page(page);
360 continue;
361 }
362 pagevec_add(&locked_pvec, page);
363 }
364 for (i = 0; i < pagevec_count(&locked_pvec); i++)
365 truncate_cleanup_page(mapping, locked_pvec.pages[i]);
366 delete_from_page_cache_batch(mapping, &locked_pvec);
367 for (i = 0; i < pagevec_count(&locked_pvec); i++)
368 unlock_page(locked_pvec.pages[i]);
369 truncate_exceptional_pvec_entries(mapping, &pvec, indices, end);
370 pagevec_release(&pvec);
371 cond_resched();
372 index++;
373 }
374 if (partial_start) {
375 struct page *page = find_lock_page(mapping, start - 1);
376 if (page) {
377 unsigned int top = PAGE_SIZE;
378 if (start > end) {
379
380 top = partial_end;
381 partial_end = 0;
382 }
383 wait_on_page_writeback(page);
384 zero_user_segment(page, partial_start, top);
385 cleancache_invalidate_page(mapping, page);
386 if (page_has_private(page))
387 do_invalidatepage(page, partial_start,
388 top - partial_start);
389 unlock_page(page);
390 put_page(page);
391 }
392 }
393 if (partial_end) {
394 struct page *page = find_lock_page(mapping, end);
395 if (page) {
396 wait_on_page_writeback(page);
397 zero_user_segment(page, 0, partial_end);
398 cleancache_invalidate_page(mapping, page);
399 if (page_has_private(page))
400 do_invalidatepage(page, 0,
401 partial_end);
402 unlock_page(page);
403 put_page(page);
404 }
405 }
406
407
408
409
410 if (start >= end)
411 goto out;
412
413 index = start;
414 for ( ; ; ) {
415 cond_resched();
416 if (!pagevec_lookup_entries(&pvec, mapping, index,
417 min(end - index, (pgoff_t)PAGEVEC_SIZE), indices)) {
418
419 if (index == start)
420 break;
421
422 index = start;
423 continue;
424 }
425 if (index == start && indices[0] >= end) {
426
427 pagevec_remove_exceptionals(&pvec);
428 pagevec_release(&pvec);
429 break;
430 }
431
432 for (i = 0; i < pagevec_count(&pvec); i++) {
433 struct page *page = pvec.pages[i];
434
435
436 index = indices[i];
437 if (index >= end) {
438
439 index = start - 1;
440 break;
441 }
442
443 if (xa_is_value(page))
444 continue;
445
446 lock_page(page);
447 WARN_ON(page_to_index(page) != index);
448 wait_on_page_writeback(page);
449 truncate_inode_page(mapping, page);
450 unlock_page(page);
451 }
452 truncate_exceptional_pvec_entries(mapping, &pvec, indices, end);
453 pagevec_release(&pvec);
454 index++;
455 }
456
457 out:
458 cleancache_invalidate_inode(mapping);
459 }
460 EXPORT_SYMBOL(truncate_inode_pages_range);
461
462
463
464
465
466
467
468
469
470
471
472
473
474 void truncate_inode_pages(struct address_space *mapping, loff_t lstart)
475 {
476 truncate_inode_pages_range(mapping, lstart, (loff_t)-1);
477 }
478 EXPORT_SYMBOL(truncate_inode_pages);
479
480
481
482
483
484
485
486
487
488
489 void truncate_inode_pages_final(struct address_space *mapping)
490 {
491 unsigned long nrexceptional;
492 unsigned long nrpages;
493
494
495
496
497
498
499
500
501 mapping_set_exiting(mapping);
502
503
504
505
506
507
508 nrpages = mapping->nrpages;
509 smp_rmb();
510 nrexceptional = mapping->nrexceptional;
511
512 if (nrpages || nrexceptional) {
513
514
515
516
517
518
519 xa_lock_irq(&mapping->i_pages);
520 xa_unlock_irq(&mapping->i_pages);
521 }
522
523
524
525
526
527 truncate_inode_pages(mapping, 0);
528 }
529 EXPORT_SYMBOL(truncate_inode_pages_final);
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546 unsigned long invalidate_mapping_pages(struct address_space *mapping,
547 pgoff_t start, pgoff_t end)
548 {
549 pgoff_t indices[PAGEVEC_SIZE];
550 struct pagevec pvec;
551 pgoff_t index = start;
552 unsigned long ret;
553 unsigned long count = 0;
554 int i;
555
556 pagevec_init(&pvec);
557 while (index <= end && pagevec_lookup_entries(&pvec, mapping, index,
558 min(end - index, (pgoff_t)PAGEVEC_SIZE - 1) + 1,
559 indices)) {
560 for (i = 0; i < pagevec_count(&pvec); i++) {
561 struct page *page = pvec.pages[i];
562
563
564 index = indices[i];
565 if (index > end)
566 break;
567
568 if (xa_is_value(page)) {
569 invalidate_exceptional_entry(mapping, index,
570 page);
571 continue;
572 }
573
574 if (!trylock_page(page))
575 continue;
576
577 WARN_ON(page_to_index(page) != index);
578
579
580 if (PageTransTail(page)) {
581 unlock_page(page);
582 continue;
583 } else if (PageTransHuge(page)) {
584 index += HPAGE_PMD_NR - 1;
585 i += HPAGE_PMD_NR - 1;
586
587
588
589
590
591 if (index > end) {
592 unlock_page(page);
593 continue;
594 }
595
596
597 get_page(page);
598
599
600
601
602
603 pagevec_remove_exceptionals(&pvec);
604 pagevec_release(&pvec);
605 }
606
607 ret = invalidate_inode_page(page);
608 unlock_page(page);
609
610
611
612
613 if (!ret)
614 deactivate_file_page(page);
615 if (PageTransHuge(page))
616 put_page(page);
617 count += ret;
618 }
619 pagevec_remove_exceptionals(&pvec);
620 pagevec_release(&pvec);
621 cond_resched();
622 index++;
623 }
624 return count;
625 }
626 EXPORT_SYMBOL(invalidate_mapping_pages);
627
628
629
630
631
632
633
634
635 static int
636 invalidate_complete_page2(struct address_space *mapping, struct page *page)
637 {
638 unsigned long flags;
639
640 if (page->mapping != mapping)
641 return 0;
642
643 if (page_has_private(page) && !try_to_release_page(page, GFP_KERNEL))
644 return 0;
645
646 xa_lock_irqsave(&mapping->i_pages, flags);
647 if (PageDirty(page))
648 goto failed;
649
650 BUG_ON(page_has_private(page));
651 __delete_from_page_cache(page, NULL);
652 xa_unlock_irqrestore(&mapping->i_pages, flags);
653
654 if (mapping->a_ops->freepage)
655 mapping->a_ops->freepage(page);
656
657 put_page(page);
658 return 1;
659 failed:
660 xa_unlock_irqrestore(&mapping->i_pages, flags);
661 return 0;
662 }
663
664 static int do_launder_page(struct address_space *mapping, struct page *page)
665 {
666 if (!PageDirty(page))
667 return 0;
668 if (page->mapping != mapping || mapping->a_ops->launder_page == NULL)
669 return 0;
670 return mapping->a_ops->launder_page(page);
671 }
672
673
674
675
676
677
678
679
680
681
682
683
684 int invalidate_inode_pages2_range(struct address_space *mapping,
685 pgoff_t start, pgoff_t end)
686 {
687 pgoff_t indices[PAGEVEC_SIZE];
688 struct pagevec pvec;
689 pgoff_t index;
690 int i;
691 int ret = 0;
692 int ret2 = 0;
693 int did_range_unmap = 0;
694
695 if (mapping->nrpages == 0 && mapping->nrexceptional == 0)
696 goto out;
697
698 pagevec_init(&pvec);
699 index = start;
700 while (index <= end && pagevec_lookup_entries(&pvec, mapping, index,
701 min(end - index, (pgoff_t)PAGEVEC_SIZE - 1) + 1,
702 indices)) {
703 for (i = 0; i < pagevec_count(&pvec); i++) {
704 struct page *page = pvec.pages[i];
705
706
707 index = indices[i];
708 if (index > end)
709 break;
710
711 if (xa_is_value(page)) {
712 if (!invalidate_exceptional_entry2(mapping,
713 index, page))
714 ret = -EBUSY;
715 continue;
716 }
717
718 lock_page(page);
719 WARN_ON(page_to_index(page) != index);
720 if (page->mapping != mapping) {
721 unlock_page(page);
722 continue;
723 }
724 wait_on_page_writeback(page);
725 if (page_mapped(page)) {
726 if (!did_range_unmap) {
727
728
729
730 unmap_mapping_pages(mapping, index,
731 (1 + end - index), false);
732 did_range_unmap = 1;
733 } else {
734
735
736
737 unmap_mapping_pages(mapping, index,
738 1, false);
739 }
740 }
741 BUG_ON(page_mapped(page));
742 ret2 = do_launder_page(mapping, page);
743 if (ret2 == 0) {
744 if (!invalidate_complete_page2(mapping, page))
745 ret2 = -EBUSY;
746 }
747 if (ret2 < 0)
748 ret = ret2;
749 unlock_page(page);
750 }
751 pagevec_remove_exceptionals(&pvec);
752 pagevec_release(&pvec);
753 cond_resched();
754 index++;
755 }
756
757
758
759
760
761
762
763 if (dax_mapping(mapping)) {
764 unmap_mapping_pages(mapping, start, end - start + 1, false);
765 }
766 out:
767 cleancache_invalidate_inode(mapping);
768 return ret;
769 }
770 EXPORT_SYMBOL_GPL(invalidate_inode_pages2_range);
771
772
773
774
775
776
777
778
779
780
781 int invalidate_inode_pages2(struct address_space *mapping)
782 {
783 return invalidate_inode_pages2_range(mapping, 0, -1);
784 }
785 EXPORT_SYMBOL_GPL(invalidate_inode_pages2);
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802 void truncate_pagecache(struct inode *inode, loff_t newsize)
803 {
804 struct address_space *mapping = inode->i_mapping;
805 loff_t holebegin = round_up(newsize, PAGE_SIZE);
806
807
808
809
810
811
812
813
814
815
816 unmap_mapping_range(mapping, holebegin, 0, 1);
817 truncate_inode_pages(mapping, newsize);
818 unmap_mapping_range(mapping, holebegin, 0, 1);
819 }
820 EXPORT_SYMBOL(truncate_pagecache);
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835 void truncate_setsize(struct inode *inode, loff_t newsize)
836 {
837 loff_t oldsize = inode->i_size;
838
839 i_size_write(inode, newsize);
840 if (newsize > oldsize)
841 pagecache_isize_extended(inode, oldsize, newsize);
842 truncate_pagecache(inode, newsize);
843 }
844 EXPORT_SYMBOL(truncate_setsize);
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865 void pagecache_isize_extended(struct inode *inode, loff_t from, loff_t to)
866 {
867 int bsize = i_blocksize(inode);
868 loff_t rounded_from;
869 struct page *page;
870 pgoff_t index;
871
872 WARN_ON(to > inode->i_size);
873
874 if (from >= to || bsize == PAGE_SIZE)
875 return;
876
877 rounded_from = round_up(from, bsize);
878 if (to <= rounded_from || !(rounded_from & (PAGE_SIZE - 1)))
879 return;
880
881 index = from >> PAGE_SHIFT;
882 page = find_lock_page(inode->i_mapping, index);
883
884 if (!page)
885 return;
886
887
888
889
890 if (page_mkclean(page))
891 set_page_dirty(page);
892 unlock_page(page);
893 put_page(page);
894 }
895 EXPORT_SYMBOL(pagecache_isize_extended);
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910 void truncate_pagecache_range(struct inode *inode, loff_t lstart, loff_t lend)
911 {
912 struct address_space *mapping = inode->i_mapping;
913 loff_t unmap_start = round_up(lstart, PAGE_SIZE);
914 loff_t unmap_end = round_down(1 + lend, PAGE_SIZE) - 1;
915
916
917
918
919
920
921
922
923
924
925
926
927
928 if ((u64)unmap_end > (u64)unmap_start)
929 unmap_mapping_range(mapping, unmap_start,
930 1 + unmap_end - unmap_start, 0);
931 truncate_inode_pages_range(mapping, lstart, lend);
932 }
933 EXPORT_SYMBOL(truncate_pagecache_range);