diff options
Diffstat (limited to 'fs/nfs/objlayout/objio_osd.c')
| -rw-r--r-- | fs/nfs/objlayout/objio_osd.c | 25 | 
1 files changed, 20 insertions, 5 deletions
diff --git a/fs/nfs/objlayout/objio_osd.c b/fs/nfs/objlayout/objio_osd.c index b47277baeba..f50d3e8d6f2 100644 --- a/fs/nfs/objlayout/objio_osd.c +++ b/fs/nfs/objlayout/objio_osd.c @@ -454,7 +454,10 @@ int objio_read_pagelist(struct nfs_read_data *rdata)  	objios->ios->done = _read_done;  	dprintk("%s: offset=0x%llx length=0x%x\n", __func__,  		rdata->args.offset, rdata->args.count); -	return ore_read(objios->ios); +	ret = ore_read(objios->ios); +	if (unlikely(ret)) +		objio_free_result(&objios->oir); +	return ret;  }  /* @@ -486,8 +489,16 @@ static struct page *__r4w_get_page(void *priv, u64 offset, bool *uptodate)  	struct nfs_write_data *wdata = objios->oir.rpcdata;  	struct address_space *mapping = wdata->header->inode->i_mapping;  	pgoff_t index = offset / PAGE_SIZE; -	struct page *page = find_get_page(mapping, index); +	struct page *page; +	loff_t i_size = i_size_read(wdata->header->inode); + +	if (offset >= i_size) { +		*uptodate = true; +		dprintk("%s: g_zero_page index=0x%lx\n", __func__, index); +		return ZERO_PAGE(0); +	} +	page = find_get_page(mapping, index);  	if (!page) {  		page = find_or_create_page(mapping, index, GFP_NOFS);  		if (unlikely(!page)) { @@ -507,8 +518,10 @@ static struct page *__r4w_get_page(void *priv, u64 offset, bool *uptodate)  static void __r4w_put_page(void *priv, struct page *page)  { -	dprintk("%s: index=0x%lx\n", __func__, page->index); -	page_cache_release(page); +	dprintk("%s: index=0x%lx\n", __func__, +		(page == ZERO_PAGE(0)) ? -1UL : page->index); +	if (ZERO_PAGE(0) != page) +		page_cache_release(page);  	return;  } @@ -539,8 +552,10 @@ int objio_write_pagelist(struct nfs_write_data *wdata, int how)  	dprintk("%s: offset=0x%llx length=0x%x\n", __func__,  		wdata->args.offset, wdata->args.count);  	ret = ore_write(objios->ios); -	if (unlikely(ret)) +	if (unlikely(ret)) { +		objio_free_result(&objios->oir);  		return ret; +	}  	if (objios->sync)  		_write_done(objios->ios, objios);  |