Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 30126
b: refs/heads/master
c: 9c93ab7
h: refs/heads/master
v: v3
  • Loading branch information
Chuck Lever authored and Trond Myklebust committed Jun 24, 2006
1 parent 7e9d751 commit e4aeb1a
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 9 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: 51a7bc6caec94bab256b272bffd24d00ea81c698
refs/heads/master: 9c93ab7dff5eb22027ab15010557bb73f9b44c99
23 changes: 15 additions & 8 deletions trunk/fs/nfs/direct.c
Original file line number Diff line number Diff line change
Expand Up @@ -126,16 +126,21 @@ ssize_t nfs_direct_IO(int rw, struct kiocb *iocb, const struct iovec *iov, loff_
return -EINVAL;
}

static void nfs_free_user_pages(struct page **pages, int npages, int do_dirty)
static void nfs_direct_dirty_pages(struct page **pages, int npages)
{
int i;
for (i = 0; i < npages; i++) {
struct page *page = pages[i];
if (do_dirty && !PageCompound(page))
if (!PageCompound(page))
set_page_dirty_lock(page);
page_cache_release(page);
}
kfree(pages);
}

static void nfs_direct_release_pages(struct page **pages, int npages)
{
int i;
for (i = 0; i < npages; i++)
page_cache_release(pages[i]);
}

static inline int nfs_get_user_pages(int rw, unsigned long user_addr, size_t size, struct page ***pages)
Expand All @@ -162,7 +167,7 @@ static inline int nfs_get_user_pages(int rw, unsigned long user_addr, size_t siz
* end of a mapping; return EFAULT.
*/
if (result >= 0) {
nfs_free_user_pages(*pages, result, 0);
nfs_direct_release_pages(*pages, result);
result = -EFAULT;
} else
kfree(*pages);
Expand Down Expand Up @@ -238,8 +243,6 @@ static ssize_t nfs_direct_wait(struct nfs_direct_req *dreq)
*/
static void nfs_direct_complete(struct nfs_direct_req *dreq)
{
nfs_free_user_pages(dreq->pages, dreq->npages, 1);

if (dreq->iocb) {
long res = (long) dreq->error;
if (!res)
Expand Down Expand Up @@ -311,8 +314,11 @@ static void nfs_direct_read_result(struct rpc_task *task, void *calldata)

spin_unlock(&dreq->lock);

if (put_dreq(dreq))
if (put_dreq(dreq)) {
nfs_direct_dirty_pages(dreq->pages, dreq->npages);
nfs_direct_release_pages(dreq->pages, dreq->npages);
nfs_direct_complete(dreq);
}
}

static const struct rpc_call_ops nfs_read_direct_ops = {
Expand Down Expand Up @@ -422,6 +428,7 @@ static void nfs_direct_free_writedata(struct nfs_direct_req *dreq)
list_del(&data->pages);
nfs_writedata_release(data);
}
nfs_direct_release_pages(dreq->pages, dreq->npages);
}

#if defined(CONFIG_NFS_V3) || defined(CONFIG_NFS_V4)
Expand Down

0 comments on commit e4aeb1a

Please sign in to comment.