]>
Commit | Line | Data |
---|---|---|
d475c634 MW |
1 | /* |
2 | * fs/dax.c - Direct Access filesystem code | |
3 | * Copyright (c) 2013-2014 Intel Corporation | |
4 | * Author: Matthew Wilcox <[email protected]> | |
5 | * Author: Ross Zwisler <[email protected]> | |
6 | * | |
7 | * This program is free software; you can redistribute it and/or modify it | |
8 | * under the terms and conditions of the GNU General Public License, | |
9 | * version 2, as published by the Free Software Foundation. | |
10 | * | |
11 | * This program is distributed in the hope it will be useful, but WITHOUT | |
12 | * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or | |
13 | * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for | |
14 | * more details. | |
15 | */ | |
16 | ||
17 | #include <linux/atomic.h> | |
18 | #include <linux/blkdev.h> | |
19 | #include <linux/buffer_head.h> | |
20 | #include <linux/fs.h> | |
21 | #include <linux/genhd.h> | |
f7ca90b1 MW |
22 | #include <linux/highmem.h> |
23 | #include <linux/memcontrol.h> | |
24 | #include <linux/mm.h> | |
d475c634 | 25 | #include <linux/mutex.h> |
289c6aed | 26 | #include <linux/sched.h> |
d475c634 | 27 | #include <linux/uio.h> |
f7ca90b1 | 28 | #include <linux/vmstat.h> |
d475c634 | 29 | |
289c6aed MW |
30 | int dax_clear_blocks(struct inode *inode, sector_t block, long size) |
31 | { | |
32 | struct block_device *bdev = inode->i_sb->s_bdev; | |
33 | sector_t sector = block << (inode->i_blkbits - 9); | |
34 | ||
35 | might_sleep(); | |
36 | do { | |
37 | void *addr; | |
38 | unsigned long pfn; | |
39 | long count; | |
40 | ||
41 | count = bdev_direct_access(bdev, sector, &addr, &pfn, size); | |
42 | if (count < 0) | |
43 | return count; | |
44 | BUG_ON(size < count); | |
45 | while (count > 0) { | |
46 | unsigned pgsz = PAGE_SIZE - offset_in_page(addr); | |
47 | if (pgsz > count) | |
48 | pgsz = count; | |
49 | if (pgsz < PAGE_SIZE) | |
50 | memset(addr, 0, pgsz); | |
51 | else | |
52 | clear_page(addr); | |
53 | addr += pgsz; | |
54 | size -= pgsz; | |
55 | count -= pgsz; | |
56 | BUG_ON(pgsz & 511); | |
57 | sector += pgsz / 512; | |
58 | cond_resched(); | |
59 | } | |
60 | } while (size); | |
61 | ||
62 | return 0; | |
63 | } | |
64 | EXPORT_SYMBOL_GPL(dax_clear_blocks); | |
65 | ||
d475c634 MW |
66 | static long dax_get_addr(struct buffer_head *bh, void **addr, unsigned blkbits) |
67 | { | |
68 | unsigned long pfn; | |
69 | sector_t sector = bh->b_blocknr << (blkbits - 9); | |
70 | return bdev_direct_access(bh->b_bdev, sector, addr, &pfn, bh->b_size); | |
71 | } | |
72 | ||
73 | static void dax_new_buf(void *addr, unsigned size, unsigned first, loff_t pos, | |
74 | loff_t end) | |
75 | { | |
76 | loff_t final = end - pos + first; /* The final byte of the buffer */ | |
77 | ||
78 | if (first > 0) | |
79 | memset(addr, 0, first); | |
80 | if (final < size) | |
81 | memset(addr + final, 0, size - final); | |
82 | } | |
83 | ||
84 | static bool buffer_written(struct buffer_head *bh) | |
85 | { | |
86 | return buffer_mapped(bh) && !buffer_unwritten(bh); | |
87 | } | |
88 | ||
89 | /* | |
90 | * When ext4 encounters a hole, it returns without modifying the buffer_head | |
91 | * which means that we can't trust b_size. To cope with this, we set b_state | |
92 | * to 0 before calling get_block and, if any bit is set, we know we can trust | |
93 | * b_size. Unfortunate, really, since ext4 knows precisely how long a hole is | |
94 | * and would save us time calling get_block repeatedly. | |
95 | */ | |
96 | static bool buffer_size_valid(struct buffer_head *bh) | |
97 | { | |
98 | return bh->b_state != 0; | |
99 | } | |
100 | ||
a95cd631 OS |
101 | static ssize_t dax_io(struct inode *inode, struct iov_iter *iter, |
102 | loff_t start, loff_t end, get_block_t get_block, | |
103 | struct buffer_head *bh) | |
d475c634 MW |
104 | { |
105 | ssize_t retval = 0; | |
106 | loff_t pos = start; | |
107 | loff_t max = start; | |
108 | loff_t bh_max = start; | |
109 | void *addr; | |
110 | bool hole = false; | |
111 | ||
a95cd631 | 112 | if (iov_iter_rw(iter) != WRITE) |
d475c634 MW |
113 | end = min(end, i_size_read(inode)); |
114 | ||
115 | while (pos < end) { | |
116 | unsigned len; | |
117 | if (pos == max) { | |
118 | unsigned blkbits = inode->i_blkbits; | |
119 | sector_t block = pos >> blkbits; | |
120 | unsigned first = pos - (block << blkbits); | |
121 | long size; | |
122 | ||
123 | if (pos == bh_max) { | |
124 | bh->b_size = PAGE_ALIGN(end - pos); | |
125 | bh->b_state = 0; | |
126 | retval = get_block(inode, block, bh, | |
a95cd631 | 127 | iov_iter_rw(iter) == WRITE); |
d475c634 MW |
128 | if (retval) |
129 | break; | |
130 | if (!buffer_size_valid(bh)) | |
131 | bh->b_size = 1 << blkbits; | |
132 | bh_max = pos - first + bh->b_size; | |
133 | } else { | |
134 | unsigned done = bh->b_size - | |
135 | (bh_max - (pos - first)); | |
136 | bh->b_blocknr += done >> blkbits; | |
137 | bh->b_size -= done; | |
138 | } | |
139 | ||
a95cd631 | 140 | hole = iov_iter_rw(iter) != WRITE && !buffer_written(bh); |
d475c634 MW |
141 | if (hole) { |
142 | addr = NULL; | |
143 | size = bh->b_size - first; | |
144 | } else { | |
145 | retval = dax_get_addr(bh, &addr, blkbits); | |
146 | if (retval < 0) | |
147 | break; | |
148 | if (buffer_unwritten(bh) || buffer_new(bh)) | |
149 | dax_new_buf(addr, retval, first, pos, | |
150 | end); | |
151 | addr += first; | |
152 | size = retval - first; | |
153 | } | |
154 | max = min(pos + size, end); | |
155 | } | |
156 | ||
a95cd631 | 157 | if (iov_iter_rw(iter) == WRITE) |
872eb127 | 158 | len = copy_from_iter_nocache(addr, max - pos, iter); |
d475c634 MW |
159 | else if (!hole) |
160 | len = copy_to_iter(addr, max - pos, iter); | |
161 | else | |
162 | len = iov_iter_zero(max - pos, iter); | |
163 | ||
164 | if (!len) | |
165 | break; | |
166 | ||
167 | pos += len; | |
168 | addr += len; | |
169 | } | |
170 | ||
171 | return (pos == start) ? retval : pos - start; | |
172 | } | |
173 | ||
174 | /** | |
175 | * dax_do_io - Perform I/O to a DAX file | |
d475c634 MW |
176 | * @iocb: The control block for this I/O |
177 | * @inode: The file which the I/O is directed at | |
178 | * @iter: The addresses to do I/O from or to | |
179 | * @pos: The file offset where the I/O starts | |
180 | * @get_block: The filesystem method used to translate file offsets to blocks | |
181 | * @end_io: A filesystem callback for I/O completion | |
182 | * @flags: See below | |
183 | * | |
184 | * This function uses the same locking scheme as do_blockdev_direct_IO: | |
185 | * If @flags has DIO_LOCKING set, we assume that the i_mutex is held by the | |
186 | * caller for writes. For reads, we take and release the i_mutex ourselves. | |
187 | * If DIO_LOCKING is not set, the filesystem takes care of its own locking. | |
188 | * As with do_blockdev_direct_IO(), we increment i_dio_count while the I/O | |
189 | * is in progress. | |
190 | */ | |
a95cd631 OS |
191 | ssize_t dax_do_io(struct kiocb *iocb, struct inode *inode, |
192 | struct iov_iter *iter, loff_t pos, get_block_t get_block, | |
193 | dio_iodone_t end_io, int flags) | |
d475c634 MW |
194 | { |
195 | struct buffer_head bh; | |
196 | ssize_t retval = -EINVAL; | |
197 | loff_t end = pos + iov_iter_count(iter); | |
198 | ||
199 | memset(&bh, 0, sizeof(bh)); | |
200 | ||
a95cd631 | 201 | if ((flags & DIO_LOCKING) && iov_iter_rw(iter) == READ) { |
d475c634 MW |
202 | struct address_space *mapping = inode->i_mapping; |
203 | mutex_lock(&inode->i_mutex); | |
204 | retval = filemap_write_and_wait_range(mapping, pos, end - 1); | |
205 | if (retval) { | |
206 | mutex_unlock(&inode->i_mutex); | |
207 | goto out; | |
208 | } | |
209 | } | |
210 | ||
211 | /* Protects against truncate */ | |
bbab37dd MW |
212 | if (!(flags & DIO_SKIP_DIO_COUNT)) |
213 | inode_dio_begin(inode); | |
d475c634 | 214 | |
a95cd631 | 215 | retval = dax_io(inode, iter, pos, end, get_block, &bh); |
d475c634 | 216 | |
a95cd631 | 217 | if ((flags & DIO_LOCKING) && iov_iter_rw(iter) == READ) |
d475c634 MW |
218 | mutex_unlock(&inode->i_mutex); |
219 | ||
220 | if ((retval > 0) && end_io) | |
221 | end_io(iocb, pos, retval, bh.b_private); | |
222 | ||
bbab37dd MW |
223 | if (!(flags & DIO_SKIP_DIO_COUNT)) |
224 | inode_dio_end(inode); | |
d475c634 MW |
225 | out: |
226 | return retval; | |
227 | } | |
228 | EXPORT_SYMBOL_GPL(dax_do_io); | |
f7ca90b1 MW |
229 | |
230 | /* | |
231 | * The user has performed a load from a hole in the file. Allocating | |
232 | * a new page in the file would cause excessive storage usage for | |
233 | * workloads with sparse files. We allocate a page cache page instead. | |
234 | * We'll kick it out of the page cache if it's ever written to, | |
235 | * otherwise it will simply fall out of the page cache under memory | |
236 | * pressure without ever having been dirtied. | |
237 | */ | |
238 | static int dax_load_hole(struct address_space *mapping, struct page *page, | |
239 | struct vm_fault *vmf) | |
240 | { | |
241 | unsigned long size; | |
242 | struct inode *inode = mapping->host; | |
243 | if (!page) | |
244 | page = find_or_create_page(mapping, vmf->pgoff, | |
245 | GFP_KERNEL | __GFP_ZERO); | |
246 | if (!page) | |
247 | return VM_FAULT_OOM; | |
248 | /* Recheck i_size under page lock to avoid truncate race */ | |
249 | size = (i_size_read(inode) + PAGE_SIZE - 1) >> PAGE_SHIFT; | |
250 | if (vmf->pgoff >= size) { | |
251 | unlock_page(page); | |
252 | page_cache_release(page); | |
253 | return VM_FAULT_SIGBUS; | |
254 | } | |
255 | ||
256 | vmf->page = page; | |
257 | return VM_FAULT_LOCKED; | |
258 | } | |
259 | ||
260 | static int copy_user_bh(struct page *to, struct buffer_head *bh, | |
261 | unsigned blkbits, unsigned long vaddr) | |
262 | { | |
263 | void *vfrom, *vto; | |
264 | if (dax_get_addr(bh, &vfrom, blkbits) < 0) | |
265 | return -EIO; | |
266 | vto = kmap_atomic(to); | |
267 | copy_user_page(vto, vfrom, vaddr, to); | |
268 | kunmap_atomic(vto); | |
269 | return 0; | |
270 | } | |
271 | ||
272 | static int dax_insert_mapping(struct inode *inode, struct buffer_head *bh, | |
273 | struct vm_area_struct *vma, struct vm_fault *vmf) | |
274 | { | |
f7ca90b1 MW |
275 | sector_t sector = bh->b_blocknr << (inode->i_blkbits - 9); |
276 | unsigned long vaddr = (unsigned long)vmf->virtual_address; | |
277 | void *addr; | |
278 | unsigned long pfn; | |
279 | pgoff_t size; | |
280 | int error; | |
281 | ||
f7ca90b1 MW |
282 | /* |
283 | * Check truncate didn't happen while we were allocating a block. | |
284 | * If it did, this block may or may not be still allocated to the | |
285 | * file. We can't tell the filesystem to free it because we can't | |
286 | * take i_mutex here. In the worst case, the file still has blocks | |
287 | * allocated past the end of the file. | |
288 | */ | |
289 | size = (i_size_read(inode) + PAGE_SIZE - 1) >> PAGE_SHIFT; | |
290 | if (unlikely(vmf->pgoff >= size)) { | |
291 | error = -EIO; | |
292 | goto out; | |
293 | } | |
294 | ||
295 | error = bdev_direct_access(bh->b_bdev, sector, &addr, &pfn, bh->b_size); | |
296 | if (error < 0) | |
297 | goto out; | |
298 | if (error < PAGE_SIZE) { | |
299 | error = -EIO; | |
300 | goto out; | |
301 | } | |
302 | ||
303 | if (buffer_unwritten(bh) || buffer_new(bh)) | |
304 | clear_page(addr); | |
305 | ||
306 | error = vm_insert_mixed(vma, vaddr, pfn); | |
307 | ||
308 | out: | |
f7ca90b1 MW |
309 | return error; |
310 | } | |
311 | ||
ce5c5d55 DC |
312 | /** |
313 | * __dax_fault - handle a page fault on a DAX file | |
314 | * @vma: The virtual memory area where the fault occurred | |
315 | * @vmf: The description of the fault | |
316 | * @get_block: The filesystem method used to translate file offsets to blocks | |
b2442c5a DC |
317 | * @complete_unwritten: The filesystem method used to convert unwritten blocks |
318 | * to written so the data written to them is exposed. This is required for | |
319 | * required by write faults for filesystems that will return unwritten | |
320 | * extent mappings from @get_block, but it is optional for reads as | |
321 | * dax_insert_mapping() will always zero unwritten blocks. If the fs does | |
322 | * not support unwritten extents, the it should pass NULL. | |
ce5c5d55 DC |
323 | * |
324 | * When a page fault occurs, filesystems may call this helper in their | |
325 | * fault handler for DAX files. __dax_fault() assumes the caller has done all | |
326 | * the necessary locking for the page fault to proceed successfully. | |
327 | */ | |
328 | int __dax_fault(struct vm_area_struct *vma, struct vm_fault *vmf, | |
e842f290 | 329 | get_block_t get_block, dax_iodone_t complete_unwritten) |
f7ca90b1 MW |
330 | { |
331 | struct file *file = vma->vm_file; | |
332 | struct address_space *mapping = file->f_mapping; | |
333 | struct inode *inode = mapping->host; | |
334 | struct page *page; | |
335 | struct buffer_head bh; | |
336 | unsigned long vaddr = (unsigned long)vmf->virtual_address; | |
337 | unsigned blkbits = inode->i_blkbits; | |
338 | sector_t block; | |
339 | pgoff_t size; | |
340 | int error; | |
341 | int major = 0; | |
342 | ||
343 | size = (i_size_read(inode) + PAGE_SIZE - 1) >> PAGE_SHIFT; | |
344 | if (vmf->pgoff >= size) | |
345 | return VM_FAULT_SIGBUS; | |
346 | ||
347 | memset(&bh, 0, sizeof(bh)); | |
348 | block = (sector_t)vmf->pgoff << (PAGE_SHIFT - blkbits); | |
349 | bh.b_size = PAGE_SIZE; | |
350 | ||
351 | repeat: | |
352 | page = find_get_page(mapping, vmf->pgoff); | |
353 | if (page) { | |
354 | if (!lock_page_or_retry(page, vma->vm_mm, vmf->flags)) { | |
355 | page_cache_release(page); | |
356 | return VM_FAULT_RETRY; | |
357 | } | |
358 | if (unlikely(page->mapping != mapping)) { | |
359 | unlock_page(page); | |
360 | page_cache_release(page); | |
361 | goto repeat; | |
362 | } | |
363 | size = (i_size_read(inode) + PAGE_SIZE - 1) >> PAGE_SHIFT; | |
364 | if (unlikely(vmf->pgoff >= size)) { | |
365 | /* | |
366 | * We have a struct page covering a hole in the file | |
367 | * from a read fault and we've raced with a truncate | |
368 | */ | |
369 | error = -EIO; | |
84317297 | 370 | goto unlock; |
f7ca90b1 | 371 | } |
84317297 MW |
372 | } else { |
373 | i_mmap_lock_write(mapping); | |
f7ca90b1 MW |
374 | } |
375 | ||
376 | error = get_block(inode, block, &bh, 0); | |
377 | if (!error && (bh.b_size < PAGE_SIZE)) | |
378 | error = -EIO; /* fs corruption? */ | |
379 | if (error) | |
84317297 | 380 | goto unlock; |
f7ca90b1 MW |
381 | |
382 | if (!buffer_mapped(&bh) && !buffer_unwritten(&bh) && !vmf->cow_page) { | |
383 | if (vmf->flags & FAULT_FLAG_WRITE) { | |
384 | error = get_block(inode, block, &bh, 1); | |
385 | count_vm_event(PGMAJFAULT); | |
386 | mem_cgroup_count_vm_event(vma->vm_mm, PGMAJFAULT); | |
387 | major = VM_FAULT_MAJOR; | |
388 | if (!error && (bh.b_size < PAGE_SIZE)) | |
389 | error = -EIO; | |
390 | if (error) | |
84317297 | 391 | goto unlock; |
f7ca90b1 | 392 | } else { |
84317297 | 393 | i_mmap_unlock_write(mapping); |
f7ca90b1 MW |
394 | return dax_load_hole(mapping, page, vmf); |
395 | } | |
396 | } | |
397 | ||
398 | if (vmf->cow_page) { | |
399 | struct page *new_page = vmf->cow_page; | |
400 | if (buffer_written(&bh)) | |
401 | error = copy_user_bh(new_page, &bh, blkbits, vaddr); | |
402 | else | |
403 | clear_user_highpage(new_page, vaddr); | |
404 | if (error) | |
84317297 | 405 | goto unlock; |
f7ca90b1 MW |
406 | vmf->page = page; |
407 | if (!page) { | |
f7ca90b1 MW |
408 | /* Check we didn't race with truncate */ |
409 | size = (i_size_read(inode) + PAGE_SIZE - 1) >> | |
410 | PAGE_SHIFT; | |
411 | if (vmf->pgoff >= size) { | |
f7ca90b1 | 412 | error = -EIO; |
84317297 | 413 | goto unlock; |
f7ca90b1 MW |
414 | } |
415 | } | |
416 | return VM_FAULT_LOCKED; | |
417 | } | |
418 | ||
419 | /* Check we didn't race with a read fault installing a new page */ | |
420 | if (!page && major) | |
421 | page = find_lock_page(mapping, vmf->pgoff); | |
422 | ||
423 | if (page) { | |
424 | unmap_mapping_range(mapping, vmf->pgoff << PAGE_SHIFT, | |
425 | PAGE_CACHE_SIZE, 0); | |
426 | delete_from_page_cache(page); | |
427 | unlock_page(page); | |
428 | page_cache_release(page); | |
429 | } | |
430 | ||
e842f290 DC |
431 | /* |
432 | * If we successfully insert the new mapping over an unwritten extent, | |
433 | * we need to ensure we convert the unwritten extent. If there is an | |
434 | * error inserting the mapping, the filesystem needs to leave it as | |
435 | * unwritten to prevent exposure of the stale underlying data to | |
436 | * userspace, but we still need to call the completion function so | |
437 | * the private resources on the mapping buffer can be released. We | |
438 | * indicate what the callback should do via the uptodate variable, same | |
439 | * as for normal BH based IO completions. | |
440 | */ | |
f7ca90b1 | 441 | error = dax_insert_mapping(inode, &bh, vma, vmf); |
b2442c5a DC |
442 | if (buffer_unwritten(&bh)) { |
443 | if (complete_unwritten) | |
444 | complete_unwritten(&bh, !error); | |
445 | else | |
446 | WARN_ON_ONCE(!(vmf->flags & FAULT_FLAG_WRITE)); | |
447 | } | |
f7ca90b1 | 448 | |
84317297 MW |
449 | if (!page) |
450 | i_mmap_unlock_write(mapping); | |
f7ca90b1 MW |
451 | out: |
452 | if (error == -ENOMEM) | |
453 | return VM_FAULT_OOM | major; | |
454 | /* -EBUSY is fine, somebody else faulted on the same PTE */ | |
455 | if ((error < 0) && (error != -EBUSY)) | |
456 | return VM_FAULT_SIGBUS | major; | |
457 | return VM_FAULT_NOPAGE | major; | |
458 | ||
84317297 | 459 | unlock: |
f7ca90b1 MW |
460 | if (page) { |
461 | unlock_page(page); | |
462 | page_cache_release(page); | |
84317297 MW |
463 | } else { |
464 | i_mmap_unlock_write(mapping); | |
f7ca90b1 | 465 | } |
84317297 | 466 | |
f7ca90b1 MW |
467 | goto out; |
468 | } | |
ce5c5d55 | 469 | EXPORT_SYMBOL(__dax_fault); |
f7ca90b1 MW |
470 | |
471 | /** | |
472 | * dax_fault - handle a page fault on a DAX file | |
473 | * @vma: The virtual memory area where the fault occurred | |
474 | * @vmf: The description of the fault | |
475 | * @get_block: The filesystem method used to translate file offsets to blocks | |
476 | * | |
477 | * When a page fault occurs, filesystems may call this helper in their | |
478 | * fault handler for DAX files. | |
479 | */ | |
480 | int dax_fault(struct vm_area_struct *vma, struct vm_fault *vmf, | |
e842f290 | 481 | get_block_t get_block, dax_iodone_t complete_unwritten) |
f7ca90b1 MW |
482 | { |
483 | int result; | |
484 | struct super_block *sb = file_inode(vma->vm_file)->i_sb; | |
485 | ||
486 | if (vmf->flags & FAULT_FLAG_WRITE) { | |
487 | sb_start_pagefault(sb); | |
488 | file_update_time(vma->vm_file); | |
489 | } | |
ce5c5d55 | 490 | result = __dax_fault(vma, vmf, get_block, complete_unwritten); |
f7ca90b1 MW |
491 | if (vmf->flags & FAULT_FLAG_WRITE) |
492 | sb_end_pagefault(sb); | |
493 | ||
494 | return result; | |
495 | } | |
496 | EXPORT_SYMBOL_GPL(dax_fault); | |
4c0ccfef | 497 | |
844f35db MW |
498 | #ifdef CONFIG_TRANSPARENT_HUGEPAGE |
499 | /* | |
500 | * The 'colour' (ie low bits) within a PMD of a page offset. This comes up | |
501 | * more often than one might expect in the below function. | |
502 | */ | |
503 | #define PG_PMD_COLOUR ((PMD_SIZE >> PAGE_SHIFT) - 1) | |
504 | ||
505 | int __dax_pmd_fault(struct vm_area_struct *vma, unsigned long address, | |
506 | pmd_t *pmd, unsigned int flags, get_block_t get_block, | |
507 | dax_iodone_t complete_unwritten) | |
508 | { | |
509 | struct file *file = vma->vm_file; | |
510 | struct address_space *mapping = file->f_mapping; | |
511 | struct inode *inode = mapping->host; | |
512 | struct buffer_head bh; | |
513 | unsigned blkbits = inode->i_blkbits; | |
514 | unsigned long pmd_addr = address & PMD_MASK; | |
515 | bool write = flags & FAULT_FLAG_WRITE; | |
516 | long length; | |
517 | void *kaddr; | |
518 | pgoff_t size, pgoff; | |
519 | sector_t block, sector; | |
520 | unsigned long pfn; | |
521 | int result = 0; | |
522 | ||
523 | /* Fall back to PTEs if we're going to COW */ | |
524 | if (write && !(vma->vm_flags & VM_SHARED)) | |
525 | return VM_FAULT_FALLBACK; | |
526 | /* If the PMD would extend outside the VMA */ | |
527 | if (pmd_addr < vma->vm_start) | |
528 | return VM_FAULT_FALLBACK; | |
529 | if ((pmd_addr + PMD_SIZE) > vma->vm_end) | |
530 | return VM_FAULT_FALLBACK; | |
531 | ||
532 | pgoff = ((pmd_addr - vma->vm_start) >> PAGE_SHIFT) + vma->vm_pgoff; | |
533 | size = (i_size_read(inode) + PAGE_SIZE - 1) >> PAGE_SHIFT; | |
534 | if (pgoff >= size) | |
535 | return VM_FAULT_SIGBUS; | |
536 | /* If the PMD would cover blocks out of the file */ | |
537 | if ((pgoff | PG_PMD_COLOUR) >= size) | |
538 | return VM_FAULT_FALLBACK; | |
539 | ||
540 | memset(&bh, 0, sizeof(bh)); | |
541 | block = (sector_t)pgoff << (PAGE_SHIFT - blkbits); | |
542 | ||
543 | bh.b_size = PMD_SIZE; | |
84317297 | 544 | i_mmap_lock_write(mapping); |
844f35db MW |
545 | length = get_block(inode, block, &bh, write); |
546 | if (length) | |
547 | return VM_FAULT_SIGBUS; | |
844f35db MW |
548 | |
549 | /* | |
550 | * If the filesystem isn't willing to tell us the length of a hole, | |
551 | * just fall back to PTEs. Calling get_block 512 times in a loop | |
552 | * would be silly. | |
553 | */ | |
554 | if (!buffer_size_valid(&bh) || bh.b_size < PMD_SIZE) | |
555 | goto fallback; | |
556 | ||
84c4e5e6 MW |
557 | /* |
558 | * If a truncate happened while we were allocating blocks, we may | |
559 | * leave blocks allocated to the file that are beyond EOF. We can't | |
560 | * take i_mutex here, so just leave them hanging; they'll be freed | |
561 | * when the file is deleted. | |
562 | */ | |
844f35db MW |
563 | size = (i_size_read(inode) + PAGE_SIZE - 1) >> PAGE_SHIFT; |
564 | if (pgoff >= size) { | |
565 | result = VM_FAULT_SIGBUS; | |
566 | goto out; | |
567 | } | |
568 | if ((pgoff | PG_PMD_COLOUR) >= size) | |
569 | goto fallback; | |
570 | ||
571 | if (is_huge_zero_pmd(*pmd)) | |
572 | unmap_mapping_range(mapping, pgoff << PAGE_SHIFT, PMD_SIZE, 0); | |
573 | ||
574 | if (!write && !buffer_mapped(&bh) && buffer_uptodate(&bh)) { | |
575 | bool set; | |
576 | spinlock_t *ptl; | |
577 | struct mm_struct *mm = vma->vm_mm; | |
578 | struct page *zero_page = get_huge_zero_page(); | |
579 | if (unlikely(!zero_page)) | |
580 | goto fallback; | |
581 | ||
582 | ptl = pmd_lock(mm, pmd); | |
583 | set = set_huge_zero_page(NULL, mm, vma, pmd_addr, pmd, | |
584 | zero_page); | |
585 | spin_unlock(ptl); | |
586 | result = VM_FAULT_NOPAGE; | |
587 | } else { | |
588 | sector = bh.b_blocknr << (blkbits - 9); | |
589 | length = bdev_direct_access(bh.b_bdev, sector, &kaddr, &pfn, | |
590 | bh.b_size); | |
591 | if (length < 0) { | |
592 | result = VM_FAULT_SIGBUS; | |
593 | goto out; | |
594 | } | |
595 | if ((length < PMD_SIZE) || (pfn & PG_PMD_COLOUR)) | |
596 | goto fallback; | |
597 | ||
598 | if (buffer_unwritten(&bh) || buffer_new(&bh)) { | |
599 | int i; | |
600 | for (i = 0; i < PTRS_PER_PMD; i++) | |
601 | clear_page(kaddr + i * PAGE_SIZE); | |
602 | count_vm_event(PGMAJFAULT); | |
603 | mem_cgroup_count_vm_event(vma->vm_mm, PGMAJFAULT); | |
604 | result |= VM_FAULT_MAJOR; | |
605 | } | |
606 | ||
607 | result |= vmf_insert_pfn_pmd(vma, address, pmd, pfn, write); | |
608 | } | |
609 | ||
610 | out: | |
844f35db MW |
611 | if (buffer_unwritten(&bh)) |
612 | complete_unwritten(&bh, !(result & VM_FAULT_ERROR)); | |
613 | ||
84317297 MW |
614 | i_mmap_unlock_write(mapping); |
615 | ||
844f35db MW |
616 | return result; |
617 | ||
618 | fallback: | |
619 | count_vm_event(THP_FAULT_FALLBACK); | |
620 | result = VM_FAULT_FALLBACK; | |
621 | goto out; | |
622 | } | |
623 | EXPORT_SYMBOL_GPL(__dax_pmd_fault); | |
624 | ||
625 | /** | |
626 | * dax_pmd_fault - handle a PMD fault on a DAX file | |
627 | * @vma: The virtual memory area where the fault occurred | |
628 | * @vmf: The description of the fault | |
629 | * @get_block: The filesystem method used to translate file offsets to blocks | |
630 | * | |
631 | * When a page fault occurs, filesystems may call this helper in their | |
632 | * pmd_fault handler for DAX files. | |
633 | */ | |
634 | int dax_pmd_fault(struct vm_area_struct *vma, unsigned long address, | |
635 | pmd_t *pmd, unsigned int flags, get_block_t get_block, | |
636 | dax_iodone_t complete_unwritten) | |
637 | { | |
638 | int result; | |
639 | struct super_block *sb = file_inode(vma->vm_file)->i_sb; | |
640 | ||
641 | if (flags & FAULT_FLAG_WRITE) { | |
642 | sb_start_pagefault(sb); | |
643 | file_update_time(vma->vm_file); | |
644 | } | |
645 | result = __dax_pmd_fault(vma, address, pmd, flags, get_block, | |
646 | complete_unwritten); | |
647 | if (flags & FAULT_FLAG_WRITE) | |
648 | sb_end_pagefault(sb); | |
649 | ||
650 | return result; | |
651 | } | |
652 | EXPORT_SYMBOL_GPL(dax_pmd_fault); | |
dd8a2b6c | 653 | #endif /* CONFIG_TRANSPARENT_HUGEPAGE */ |
844f35db | 654 | |
0e3b210c BH |
655 | /** |
656 | * dax_pfn_mkwrite - handle first write to DAX page | |
657 | * @vma: The virtual memory area where the fault occurred | |
658 | * @vmf: The description of the fault | |
659 | * | |
660 | */ | |
661 | int dax_pfn_mkwrite(struct vm_area_struct *vma, struct vm_fault *vmf) | |
662 | { | |
663 | struct super_block *sb = file_inode(vma->vm_file)->i_sb; | |
664 | ||
665 | sb_start_pagefault(sb); | |
666 | file_update_time(vma->vm_file); | |
667 | sb_end_pagefault(sb); | |
668 | return VM_FAULT_NOPAGE; | |
669 | } | |
670 | EXPORT_SYMBOL_GPL(dax_pfn_mkwrite); | |
671 | ||
4c0ccfef | 672 | /** |
25726bc1 | 673 | * dax_zero_page_range - zero a range within a page of a DAX file |
4c0ccfef MW |
674 | * @inode: The file being truncated |
675 | * @from: The file offset that is being truncated to | |
25726bc1 | 676 | * @length: The number of bytes to zero |
4c0ccfef MW |
677 | * @get_block: The filesystem method used to translate file offsets to blocks |
678 | * | |
25726bc1 MW |
679 | * This function can be called by a filesystem when it is zeroing part of a |
680 | * page in a DAX file. This is intended for hole-punch operations. If | |
681 | * you are truncating a file, the helper function dax_truncate_page() may be | |
682 | * more convenient. | |
4c0ccfef MW |
683 | * |
684 | * We work in terms of PAGE_CACHE_SIZE here for commonality with | |
685 | * block_truncate_page(), but we could go down to PAGE_SIZE if the filesystem | |
686 | * took care of disposing of the unnecessary blocks. Even if the filesystem | |
687 | * block size is smaller than PAGE_SIZE, we have to zero the rest of the page | |
25726bc1 | 688 | * since the file might be mmapped. |
4c0ccfef | 689 | */ |
25726bc1 MW |
690 | int dax_zero_page_range(struct inode *inode, loff_t from, unsigned length, |
691 | get_block_t get_block) | |
4c0ccfef MW |
692 | { |
693 | struct buffer_head bh; | |
694 | pgoff_t index = from >> PAGE_CACHE_SHIFT; | |
695 | unsigned offset = from & (PAGE_CACHE_SIZE-1); | |
4c0ccfef MW |
696 | int err; |
697 | ||
698 | /* Block boundary? Nothing to do */ | |
699 | if (!length) | |
700 | return 0; | |
25726bc1 | 701 | BUG_ON((offset + length) > PAGE_CACHE_SIZE); |
4c0ccfef MW |
702 | |
703 | memset(&bh, 0, sizeof(bh)); | |
704 | bh.b_size = PAGE_CACHE_SIZE; | |
705 | err = get_block(inode, index, &bh, 0); | |
706 | if (err < 0) | |
707 | return err; | |
708 | if (buffer_written(&bh)) { | |
709 | void *addr; | |
710 | err = dax_get_addr(&bh, &addr, inode->i_blkbits); | |
711 | if (err < 0) | |
712 | return err; | |
713 | memset(addr + offset, 0, length); | |
714 | } | |
715 | ||
716 | return 0; | |
717 | } | |
25726bc1 MW |
718 | EXPORT_SYMBOL_GPL(dax_zero_page_range); |
719 | ||
720 | /** | |
721 | * dax_truncate_page - handle a partial page being truncated in a DAX file | |
722 | * @inode: The file being truncated | |
723 | * @from: The file offset that is being truncated to | |
724 | * @get_block: The filesystem method used to translate file offsets to blocks | |
725 | * | |
726 | * Similar to block_truncate_page(), this function can be called by a | |
727 | * filesystem when it is truncating a DAX file to handle the partial page. | |
728 | * | |
729 | * We work in terms of PAGE_CACHE_SIZE here for commonality with | |
730 | * block_truncate_page(), but we could go down to PAGE_SIZE if the filesystem | |
731 | * took care of disposing of the unnecessary blocks. Even if the filesystem | |
732 | * block size is smaller than PAGE_SIZE, we have to zero the rest of the page | |
733 | * since the file might be mmapped. | |
734 | */ | |
735 | int dax_truncate_page(struct inode *inode, loff_t from, get_block_t get_block) | |
736 | { | |
737 | unsigned length = PAGE_CACHE_ALIGN(from) - from; | |
738 | return dax_zero_page_range(inode, from, length, get_block); | |
739 | } | |
4c0ccfef | 740 | EXPORT_SYMBOL_GPL(dax_truncate_page); |