@@ -105,7 +105,7 @@ static inline void exp_put(struct svc_export *exp)
static inline struct svc_export *exp_get(struct svc_export *exp)
{
- cache_get(&exp->h);
+ cache_get(&exp->h, exp->cd);
return exp;
}
struct svc_export * rqst_exp_find(struct svc_rqst *, int, u32 *);
@@ -101,6 +101,8 @@ struct cache_detail {
int (*match)(struct cache_head *orig, struct cache_head *new);
void (*init)(struct cache_head *orig, struct cache_head *new);
void (*update)(struct cache_head *orig, struct cache_head *new);
+ void (*validate)(struct cache_head *h);
+ void (*invalidate)(struct cache_head *h);
/* fields below this comment are for internal use
* and should not be touched by cache owners
@@ -185,8 +187,11 @@ sunrpc_cache_pipe_upcall(struct cache_detail *detail, struct cache_head *h);
extern void cache_clean_deferred(void *owner);
-static inline struct cache_head *cache_get(struct cache_head *h)
+static inline struct cache_head *cache_get(struct cache_head *h, struct cache_detail *cd)
{
+ if (cd && cd->validate)
+ cd->validate(h);
+
kref_get(&h->ref);
return h;
}
@@ -197,6 +202,10 @@ static inline void cache_put(struct cache_head *h, struct cache_detail *cd)
if (atomic_read(&h->ref.refcount) <= 2 &&
h->expiry_time < cd->nextcheck)
cd->nextcheck = h->expiry_time;
+
+ if (cd->invalidate)
+ cd->invalidate(h);
+
kref_put(&h->ref, cd->cache_put);
}
@@ -1520,7 +1520,7 @@ svcauth_gss_accept(struct svc_rqst *rqstp, __be32 *authp)
goto auth_err;
}
svcdata->rsci = rsci;
- cache_get(&rsci->h);
+ cache_get(&rsci->h, NULL);
rqstp->rq_cred.cr_flavor = gss_svc_to_pseudoflavor(
rsci->mechctx->mech_type,
GSS_C_QOP_DEFAULT,
@@ -68,7 +68,7 @@ struct cache_head *sunrpc_cache_lookup(struct cache_detail *detail,
if (cache_is_expired(detail, tmp))
/* This entry is expired, we will discard it. */
break;
- cache_get(tmp);
+ cache_get(tmp, detail);
read_unlock(&detail->hash_lock);
return tmp;
}
@@ -98,7 +98,7 @@ struct cache_head *sunrpc_cache_lookup(struct cache_detail *detail,
freeme = tmp;
break;
}
- cache_get(tmp);
+ cache_get(tmp, detail);
write_unlock(&detail->hash_lock);
cache_put(new, detail);
return tmp;
@@ -107,7 +107,7 @@ struct cache_head *sunrpc_cache_lookup(struct cache_detail *detail,
list_add(&new->cache_list, head);
detail->entries++;
- cache_get(new);
+ cache_get(new, detail);
write_unlock(&detail->hash_lock);
if (freeme)
@@ -175,7 +175,7 @@ struct cache_head *sunrpc_cache_update(struct cache_detail *detail,
detail->update(tmp, new);
list_add(&tmp->cache_list, &detail->hash_table[hash]);
detail->entries++;
- cache_get(tmp);
+ cache_get(tmp, detail);
cache_fresh_locked(tmp, new->expiry_time);
cache_fresh_locked(old, 0);
write_unlock(&detail->hash_lock);
@@ -1204,7 +1204,7 @@ int sunrpc_cache_pipe_upcall(struct cache_detail *detail, struct cache_head *h)
}
crq->q.reader = 0;
- crq->item = cache_get(h);
+ crq->item = cache_get(h, detail);
crq->buf = buf;
crq->len = 0;
crq->readers = 0;
@@ -1382,7 +1382,7 @@ static int c_show(struct seq_file *m, void *p)
seq_printf(m, "# expiry=%ld refcnt=%d flags=%lx\n",
convert_to_wallclock(cp->expiry_time),
atomic_read(&cp->ref.refcount), cp->flags);
- cache_get(cp);
+ cache_get(cp, cd);
if (cache_check(cd, cp, NULL))
/* cache_check does a cache_put on failure */
seq_printf(m, "# ");
@@ -359,7 +359,7 @@ ip_map_cached_get(struct svc_xprt *xprt)
cache_put(&ipm->h, sn->ip_map_cache);
return NULL;
}
- cache_get(&ipm->h);
+ cache_get(&ipm->h, NULL);
}
spin_unlock(&xprt->xpt_lock);
}
Add validate/invalidate functions in cache_detail for processing reference change (increase/decrease, both are before change!) Signed-off-by: Kinglong Mee <kinglongmee@gmail.com> --- fs/nfsd/export.h | 2 +- include/linux/sunrpc/cache.h | 11 ++++++++++- net/sunrpc/auth_gss/svcauth_gss.c | 2 +- net/sunrpc/cache.c | 12 ++++++------ net/sunrpc/svcauth_unix.c | 2 +- 5 files changed, 19 insertions(+), 10 deletions(-)