Commit 2e7a4641 authored by Trond Myklebust's avatar Trond Myklebust

NFS: Ensure contents of struct nfs_open_dir_context are consistent

Ensure that the contents of struct nfs_open_dir_context are consistent
by setting them under the file->f_lock from a private copy (that is
known to be consistent).
Signed-off-by: default avatarTrond Myklebust <trond.myklebust@hammerspace.com>
Reviewed-by: default avatarBenjamin Coddington <bcodding@redhat.com>
Tested-by: default avatarBenjamin Coddington <bcodding@redhat.com>
Tested-by: default avatarDave Wysochanski <dwysocha@redhat.com>
parent 05ad9175
...@@ -144,20 +144,23 @@ struct nfs_cache_array { ...@@ -144,20 +144,23 @@ struct nfs_cache_array {
struct nfs_cache_array_entry array[]; struct nfs_cache_array_entry array[];
}; };
typedef struct { typedef struct nfs_readdir_descriptor {
struct file *file; struct file *file;
struct page *page; struct page *page;
struct dir_context *ctx; struct dir_context *ctx;
unsigned long page_index; unsigned long page_index;
u64 *dir_cookie; u64 dir_cookie;
u64 last_cookie; u64 last_cookie;
u64 dup_cookie;
loff_t current_index; loff_t current_index;
loff_t prev_index; loff_t prev_index;
unsigned long dir_verifier; unsigned long dir_verifier;
unsigned long timestamp; unsigned long timestamp;
unsigned long gencount; unsigned long gencount;
unsigned long attr_gencount;
unsigned int cache_entry_index; unsigned int cache_entry_index;
signed char duped;
bool plus; bool plus;
bool eof; bool eof;
} nfs_readdir_descriptor_t; } nfs_readdir_descriptor_t;
...@@ -273,7 +276,7 @@ int nfs_readdir_search_for_pos(struct nfs_cache_array *array, nfs_readdir_descri ...@@ -273,7 +276,7 @@ int nfs_readdir_search_for_pos(struct nfs_cache_array *array, nfs_readdir_descri
} }
index = (unsigned int)diff; index = (unsigned int)diff;
*desc->dir_cookie = array->array[index].cookie; desc->dir_cookie = array->array[index].cookie;
desc->cache_entry_index = index; desc->cache_entry_index = index;
return 0; return 0;
out_eof: out_eof:
...@@ -298,33 +301,32 @@ int nfs_readdir_search_for_cookie(struct nfs_cache_array *array, nfs_readdir_des ...@@ -298,33 +301,32 @@ int nfs_readdir_search_for_cookie(struct nfs_cache_array *array, nfs_readdir_des
int status = -EAGAIN; int status = -EAGAIN;
for (i = 0; i < array->size; i++) { for (i = 0; i < array->size; i++) {
if (array->array[i].cookie == *desc->dir_cookie) { if (array->array[i].cookie == desc->dir_cookie) {
struct nfs_inode *nfsi = NFS_I(file_inode(desc->file)); struct nfs_inode *nfsi = NFS_I(file_inode(desc->file));
struct nfs_open_dir_context *ctx = desc->file->private_data;
new_pos = desc->current_index + i; new_pos = desc->current_index + i;
if (ctx->attr_gencount != nfsi->attr_gencount || if (desc->attr_gencount != nfsi->attr_gencount ||
!nfs_readdir_inode_mapping_valid(nfsi)) { !nfs_readdir_inode_mapping_valid(nfsi)) {
ctx->duped = 0; desc->duped = 0;
ctx->attr_gencount = nfsi->attr_gencount; desc->attr_gencount = nfsi->attr_gencount;
} else if (new_pos < desc->prev_index) { } else if (new_pos < desc->prev_index) {
if (ctx->duped > 0 if (desc->duped > 0
&& ctx->dup_cookie == *desc->dir_cookie) { && desc->dup_cookie == desc->dir_cookie) {
if (printk_ratelimit()) { if (printk_ratelimit()) {
pr_notice("NFS: directory %pD2 contains a readdir loop." pr_notice("NFS: directory %pD2 contains a readdir loop."
"Please contact your server vendor. " "Please contact your server vendor. "
"The file: %.*s has duplicate cookie %llu\n", "The file: %.*s has duplicate cookie %llu\n",
desc->file, array->array[i].string.len, desc->file, array->array[i].string.len,
array->array[i].string.name, *desc->dir_cookie); array->array[i].string.name, desc->dir_cookie);
} }
status = -ELOOP; status = -ELOOP;
goto out; goto out;
} }
ctx->dup_cookie = *desc->dir_cookie; desc->dup_cookie = desc->dir_cookie;
ctx->duped = -1; desc->duped = -1;
} }
if (nfs_readdir_use_cookie(desc->file)) if (nfs_readdir_use_cookie(desc->file))
desc->ctx->pos = *desc->dir_cookie; desc->ctx->pos = desc->dir_cookie;
else else
desc->ctx->pos = new_pos; desc->ctx->pos = new_pos;
desc->prev_index = new_pos; desc->prev_index = new_pos;
...@@ -334,7 +336,7 @@ int nfs_readdir_search_for_cookie(struct nfs_cache_array *array, nfs_readdir_des ...@@ -334,7 +336,7 @@ int nfs_readdir_search_for_cookie(struct nfs_cache_array *array, nfs_readdir_des
} }
if (array->eof_index >= 0) { if (array->eof_index >= 0) {
status = -EBADCOOKIE; status = -EBADCOOKIE;
if (*desc->dir_cookie == array->last_cookie) if (desc->dir_cookie == array->last_cookie)
desc->eof = true; desc->eof = true;
} }
out: out:
...@@ -349,7 +351,7 @@ int nfs_readdir_search_array(nfs_readdir_descriptor_t *desc) ...@@ -349,7 +351,7 @@ int nfs_readdir_search_array(nfs_readdir_descriptor_t *desc)
array = kmap(desc->page); array = kmap(desc->page);
if (*desc->dir_cookie == 0) if (desc->dir_cookie == 0)
status = nfs_readdir_search_for_pos(array, desc); status = nfs_readdir_search_for_pos(array, desc);
else else
status = nfs_readdir_search_for_cookie(array, desc); status = nfs_readdir_search_for_cookie(array, desc);
...@@ -801,7 +803,6 @@ int nfs_do_filldir(nfs_readdir_descriptor_t *desc) ...@@ -801,7 +803,6 @@ int nfs_do_filldir(nfs_readdir_descriptor_t *desc)
int i = 0; int i = 0;
int res = 0; int res = 0;
struct nfs_cache_array *array = NULL; struct nfs_cache_array *array = NULL;
struct nfs_open_dir_context *ctx = file->private_data;
array = kmap(desc->page); array = kmap(desc->page);
for (i = desc->cache_entry_index; i < array->size; i++) { for (i = desc->cache_entry_index; i < array->size; i++) {
...@@ -814,22 +815,22 @@ int nfs_do_filldir(nfs_readdir_descriptor_t *desc) ...@@ -814,22 +815,22 @@ int nfs_do_filldir(nfs_readdir_descriptor_t *desc)
break; break;
} }
if (i < (array->size-1)) if (i < (array->size-1))
*desc->dir_cookie = array->array[i+1].cookie; desc->dir_cookie = array->array[i+1].cookie;
else else
*desc->dir_cookie = array->last_cookie; desc->dir_cookie = array->last_cookie;
if (nfs_readdir_use_cookie(file)) if (nfs_readdir_use_cookie(file))
desc->ctx->pos = *desc->dir_cookie; desc->ctx->pos = desc->dir_cookie;
else else
desc->ctx->pos++; desc->ctx->pos++;
if (ctx->duped != 0) if (desc->duped != 0)
ctx->duped = 1; desc->duped = 1;
} }
if (array->eof_index >= 0) if (array->eof_index >= 0)
desc->eof = true; desc->eof = true;
kunmap(desc->page); kunmap(desc->page);
dfprintk(DIRCACHE, "NFS: nfs_do_filldir() filling ended @ cookie %Lu; returning = %d\n", dfprintk(DIRCACHE, "NFS: nfs_do_filldir() filling ended @ cookie %Lu; returning = %d\n",
(unsigned long long)*desc->dir_cookie, res); (unsigned long long)desc->dir_cookie, res);
return res; return res;
} }
...@@ -851,10 +852,9 @@ int uncached_readdir(nfs_readdir_descriptor_t *desc) ...@@ -851,10 +852,9 @@ int uncached_readdir(nfs_readdir_descriptor_t *desc)
struct page *page = NULL; struct page *page = NULL;
int status; int status;
struct inode *inode = file_inode(desc->file); struct inode *inode = file_inode(desc->file);
struct nfs_open_dir_context *ctx = desc->file->private_data;
dfprintk(DIRCACHE, "NFS: uncached_readdir() searching for cookie %Lu\n", dfprintk(DIRCACHE, "NFS: uncached_readdir() searching for cookie %Lu\n",
(unsigned long long)*desc->dir_cookie); (unsigned long long)desc->dir_cookie);
page = alloc_page(GFP_HIGHUSER); page = alloc_page(GFP_HIGHUSER);
if (!page) { if (!page) {
...@@ -863,9 +863,9 @@ int uncached_readdir(nfs_readdir_descriptor_t *desc) ...@@ -863,9 +863,9 @@ int uncached_readdir(nfs_readdir_descriptor_t *desc)
} }
desc->page_index = 0; desc->page_index = 0;
desc->last_cookie = *desc->dir_cookie; desc->last_cookie = desc->dir_cookie;
desc->page = page; desc->page = page;
ctx->duped = 0; desc->duped = 0;
status = nfs_readdir_xdr_to_array(desc, page, inode); status = nfs_readdir_xdr_to_array(desc, page, inode);
if (status < 0) if (status < 0)
...@@ -894,7 +894,6 @@ static int nfs_readdir(struct file *file, struct dir_context *ctx) ...@@ -894,7 +894,6 @@ static int nfs_readdir(struct file *file, struct dir_context *ctx)
nfs_readdir_descriptor_t my_desc = { nfs_readdir_descriptor_t my_desc = {
.file = file, .file = file,
.ctx = ctx, .ctx = ctx,
.dir_cookie = &dir_ctx->dir_cookie,
.plus = nfs_use_readdirplus(inode, ctx), .plus = nfs_use_readdirplus(inode, ctx),
}, },
*desc = &my_desc; *desc = &my_desc;
...@@ -915,13 +914,20 @@ static int nfs_readdir(struct file *file, struct dir_context *ctx) ...@@ -915,13 +914,20 @@ static int nfs_readdir(struct file *file, struct dir_context *ctx)
if (res < 0) if (res < 0)
goto out; goto out;
spin_lock(&file->f_lock);
desc->dir_cookie = dir_ctx->dir_cookie;
desc->dup_cookie = dir_ctx->dup_cookie;
desc->duped = dir_ctx->duped;
desc->attr_gencount = dir_ctx->attr_gencount;
spin_unlock(&file->f_lock);
do { do {
res = readdir_search_pagecache(desc); res = readdir_search_pagecache(desc);
if (res == -EBADCOOKIE) { if (res == -EBADCOOKIE) {
res = 0; res = 0;
/* This means either end of directory */ /* This means either end of directory */
if (*desc->dir_cookie && !desc->eof) { if (desc->dir_cookie && !desc->eof) {
/* Or that the server has 'lost' a cookie */ /* Or that the server has 'lost' a cookie */
res = uncached_readdir(desc); res = uncached_readdir(desc);
if (res == 0) if (res == 0)
...@@ -946,6 +952,14 @@ static int nfs_readdir(struct file *file, struct dir_context *ctx) ...@@ -946,6 +952,14 @@ static int nfs_readdir(struct file *file, struct dir_context *ctx)
if (res < 0) if (res < 0)
break; break;
} while (!desc->eof); } while (!desc->eof);
spin_lock(&file->f_lock);
dir_ctx->dir_cookie = desc->dir_cookie;
dir_ctx->dup_cookie = desc->dup_cookie;
dir_ctx->duped = desc->duped;
dir_ctx->attr_gencount = desc->attr_gencount;
spin_unlock(&file->f_lock);
out: out:
if (res > 0) if (res > 0)
res = 0; res = 0;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment