diff options
Diffstat (limited to 'fs/nfs/pagelist.c')
-rw-r--r-- | fs/nfs/pagelist.c | 47 |
1 files changed, 28 insertions, 19 deletions
diff --git a/fs/nfs/pagelist.c b/fs/nfs/pagelist.c index 106aca388ebc..656481c0daa3 100644 --- a/fs/nfs/pagelist.c +++ b/fs/nfs/pagelist.c | |||
@@ -325,6 +325,7 @@ out: | |||
325 | 325 | ||
326 | /** | 326 | /** |
327 | * nfs_scan_list - Scan a list for matching requests | 327 | * nfs_scan_list - Scan a list for matching requests |
328 | * @nfsi: NFS inode | ||
328 | * @head: One of the NFS inode request lists | 329 | * @head: One of the NFS inode request lists |
329 | * @dst: Destination list | 330 | * @dst: Destination list |
330 | * @idx_start: lower bound of page->index to scan | 331 | * @idx_start: lower bound of page->index to scan |
@@ -336,14 +337,15 @@ out: | |||
336 | * The requests are *not* checked to ensure that they form a contiguous set. | 337 | * The requests are *not* checked to ensure that they form a contiguous set. |
337 | * You must be holding the inode's req_lock when calling this function | 338 | * You must be holding the inode's req_lock when calling this function |
338 | */ | 339 | */ |
339 | int | 340 | int nfs_scan_list(struct nfs_inode *nfsi, struct list_head *head, |
340 | nfs_scan_list(struct list_head *head, struct list_head *dst, | 341 | struct list_head *dst, unsigned long idx_start, |
341 | unsigned long idx_start, unsigned int npages) | 342 | unsigned int npages) |
342 | { | 343 | { |
343 | struct list_head *pos, *tmp; | 344 | struct nfs_page *pgvec[NFS_SCAN_MAXENTRIES]; |
344 | struct nfs_page *req; | 345 | struct nfs_page *req; |
345 | unsigned long idx_end; | 346 | unsigned long idx_end; |
346 | int res; | 347 | int found, i; |
348 | int res; | ||
347 | 349 | ||
348 | res = 0; | 350 | res = 0; |
349 | if (npages == 0) | 351 | if (npages == 0) |
@@ -351,21 +353,28 @@ nfs_scan_list(struct list_head *head, struct list_head *dst, | |||
351 | else | 353 | else |
352 | idx_end = idx_start + npages - 1; | 354 | idx_end = idx_start + npages - 1; |
353 | 355 | ||
354 | list_for_each_safe(pos, tmp, head) { | 356 | for (;;) { |
355 | 357 | found = radix_tree_gang_lookup(&nfsi->nfs_page_tree, | |
356 | req = nfs_list_entry(pos); | 358 | (void **)&pgvec[0], idx_start, |
357 | 359 | NFS_SCAN_MAXENTRIES); | |
358 | if (req->wb_index < idx_start) | 360 | if (found <= 0) |
359 | continue; | ||
360 | if (req->wb_index > idx_end) | ||
361 | break; | 361 | break; |
362 | for (i = 0; i < found; i++) { | ||
363 | req = pgvec[i]; | ||
364 | if (req->wb_index > idx_end) | ||
365 | goto out; | ||
366 | idx_start = req->wb_index + 1; | ||
367 | if (req->wb_list_head != head) | ||
368 | continue; | ||
369 | if (nfs_set_page_writeback_locked(req)) { | ||
370 | nfs_list_remove_request(req); | ||
371 | nfs_list_add_request(req, dst); | ||
372 | res++; | ||
373 | } | ||
374 | } | ||
362 | 375 | ||
363 | if (!nfs_set_page_writeback_locked(req)) | ||
364 | continue; | ||
365 | nfs_list_remove_request(req); | ||
366 | nfs_list_add_request(req, dst); | ||
367 | res++; | ||
368 | } | 376 | } |
377 | out: | ||
369 | return res; | 378 | return res; |
370 | } | 379 | } |
371 | 380 | ||