Commit a8455110 authored by Chuck Lever's avatar Chuck Lever

NFSD: Refactor __nfsd_file_close_inode()

The code that computes the hashval is the same in both callers.

To prevent them from going stale, reframe the documenting comments
to remove descriptions of the underlying hash table structure, which
is about to be replaced.
Reviewed-by: default avatarJeff Layton <jlayton@kernel.org>
Signed-off-by: default avatarChuck Lever <chuck.lever@oracle.com>
parent 87553263
...@@ -559,39 +559,44 @@ static struct shrinker nfsd_file_shrinker = { ...@@ -559,39 +559,44 @@ static struct shrinker nfsd_file_shrinker = {
.seeks = 1, .seeks = 1,
}; };
static void /*
__nfsd_file_close_inode(struct inode *inode, unsigned int hashval, * Find all cache items across all net namespaces that match @inode and
struct list_head *dispose) * move them to @dispose. The lookup is atomic wrt nfsd_file_acquire().
*/
static unsigned int
__nfsd_file_close_inode(struct inode *inode, struct list_head *dispose)
{ {
unsigned int hashval = (unsigned int)hash_long(inode->i_ino,
NFSD_FILE_HASH_BITS);
unsigned int count = 0;
struct nfsd_file *nf; struct nfsd_file *nf;
struct hlist_node *tmp; struct hlist_node *tmp;
spin_lock(&nfsd_file_hashtbl[hashval].nfb_lock); spin_lock(&nfsd_file_hashtbl[hashval].nfb_lock);
hlist_for_each_entry_safe(nf, tmp, &nfsd_file_hashtbl[hashval].nfb_head, nf_node) { hlist_for_each_entry_safe(nf, tmp, &nfsd_file_hashtbl[hashval].nfb_head, nf_node) {
if (inode == nf->nf_inode) if (inode == nf->nf_inode) {
nfsd_file_unhash_and_release_locked(nf, dispose); nfsd_file_unhash_and_release_locked(nf, dispose);
count++;
}
} }
spin_unlock(&nfsd_file_hashtbl[hashval].nfb_lock); spin_unlock(&nfsd_file_hashtbl[hashval].nfb_lock);
return count;
} }
/** /**
* nfsd_file_close_inode_sync - attempt to forcibly close a nfsd_file * nfsd_file_close_inode_sync - attempt to forcibly close a nfsd_file
* @inode: inode of the file to attempt to remove * @inode: inode of the file to attempt to remove
* *
* Walk the whole hash bucket, looking for any files that correspond to "inode". * Unhash and put, then flush and fput all cache items associated with @inode.
* If any do, then unhash them and put the hashtable reference to them and
* destroy any that had their last reference put. Also ensure that any of the
* fputs also have their final __fput done as well.
*/ */
void void
nfsd_file_close_inode_sync(struct inode *inode) nfsd_file_close_inode_sync(struct inode *inode)
{ {
unsigned int hashval = (unsigned int)hash_long(inode->i_ino,
NFSD_FILE_HASH_BITS);
LIST_HEAD(dispose); LIST_HEAD(dispose);
unsigned int count;
__nfsd_file_close_inode(inode, hashval, &dispose); count = __nfsd_file_close_inode(inode, &dispose);
trace_nfsd_file_close_inode_sync(inode, !list_empty(&dispose)); trace_nfsd_file_close_inode_sync(inode, count);
nfsd_file_dispose_list_sync(&dispose); nfsd_file_dispose_list_sync(&dispose);
} }
...@@ -599,19 +604,16 @@ nfsd_file_close_inode_sync(struct inode *inode) ...@@ -599,19 +604,16 @@ nfsd_file_close_inode_sync(struct inode *inode)
* nfsd_file_close_inode - attempt a delayed close of a nfsd_file * nfsd_file_close_inode - attempt a delayed close of a nfsd_file
* @inode: inode of the file to attempt to remove * @inode: inode of the file to attempt to remove
* *
* Walk the whole hash bucket, looking for any files that correspond to "inode". * Unhash and put all cache item associated with @inode.
* If any do, then unhash them and put the hashtable reference to them and
* destroy any that had their last reference put.
*/ */
static void static void
nfsd_file_close_inode(struct inode *inode) nfsd_file_close_inode(struct inode *inode)
{ {
unsigned int hashval = (unsigned int)hash_long(inode->i_ino,
NFSD_FILE_HASH_BITS);
LIST_HEAD(dispose); LIST_HEAD(dispose);
unsigned int count;
__nfsd_file_close_inode(inode, hashval, &dispose); count = __nfsd_file_close_inode(inode, &dispose);
trace_nfsd_file_close_inode(inode, !list_empty(&dispose)); trace_nfsd_file_close_inode(inode, count);
nfsd_file_dispose_list_delayed(&dispose); nfsd_file_dispose_list_delayed(&dispose);
} }
......
...@@ -848,30 +848,52 @@ TRACE_EVENT(nfsd_file_open, ...@@ -848,30 +848,52 @@ TRACE_EVENT(nfsd_file_open,
DECLARE_EVENT_CLASS(nfsd_file_search_class, DECLARE_EVENT_CLASS(nfsd_file_search_class,
TP_PROTO( TP_PROTO(
struct inode *inode, const struct inode *inode,
int found unsigned int count
), ),
TP_ARGS(inode, found), TP_ARGS(inode, count),
TP_STRUCT__entry( TP_STRUCT__entry(
__field(struct inode *, inode) __field(const struct inode *, inode)
__field(int, found) __field(unsigned int, count)
), ),
TP_fast_assign( TP_fast_assign(
__entry->inode = inode; __entry->inode = inode;
__entry->found = found; __entry->count = count;
), ),
TP_printk("inode=%p found=%d", TP_printk("inode=%p count=%u",
__entry->inode, __entry->found) __entry->inode, __entry->count)
); );
#define DEFINE_NFSD_FILE_SEARCH_EVENT(name) \ #define DEFINE_NFSD_FILE_SEARCH_EVENT(name) \
DEFINE_EVENT(nfsd_file_search_class, name, \ DEFINE_EVENT(nfsd_file_search_class, name, \
TP_PROTO(struct inode *inode, int found), \ TP_PROTO( \
TP_ARGS(inode, found)) const struct inode *inode, \
unsigned int count \
), \
TP_ARGS(inode, count))
DEFINE_NFSD_FILE_SEARCH_EVENT(nfsd_file_close_inode_sync); DEFINE_NFSD_FILE_SEARCH_EVENT(nfsd_file_close_inode_sync);
DEFINE_NFSD_FILE_SEARCH_EVENT(nfsd_file_close_inode); DEFINE_NFSD_FILE_SEARCH_EVENT(nfsd_file_close_inode);
DEFINE_NFSD_FILE_SEARCH_EVENT(nfsd_file_is_cached);
TRACE_EVENT(nfsd_file_is_cached,
TP_PROTO(
const struct inode *inode,
int found
),
TP_ARGS(inode, found),
TP_STRUCT__entry(
__field(const struct inode *, inode)
__field(int, found)
),
TP_fast_assign(
__entry->inode = inode;
__entry->found = found;
),
TP_printk("inode=%p is %scached",
__entry->inode,
__entry->found ? "" : "not "
)
);
TRACE_EVENT(nfsd_file_fsnotify_handle_event, TRACE_EVENT(nfsd_file_fsnotify_handle_event,
TP_PROTO(struct inode *inode, u32 mask), TP_PROTO(struct inode *inode, u32 mask),
......
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