aboutsummaryrefslogtreecommitdiffstats
path: root/fs/lockd/mon.c
diff options
context:
space:
mode:
authorChuck Lever <chuck.lever@oracle.com>2008-12-05 19:03:46 -0500
committerJ. Bruce Fields <bfields@citi.umich.edu>2009-01-06 11:53:54 -0500
commit3420a8c4359a189f7d854ed7075d151257415447 (patch)
treedbcfbcdd9383bc4a9bb832f6b4a8876461495dc8 /fs/lockd/mon.c
parent576df4634e37e46b441fefb91915184edb13bb94 (diff)
NSM: Add nsm_lookup() function
Introduce a new API to fs/lockd/mon.c that allows nlm_host_rebooted() to lookup up nsm_handles via the contents of an nlm_reboot struct. The new function is equivalent to calling nsm_find() with @create set to zero, but it takes a struct nlm_reboot instead of separate arguments. Signed-off-by: Chuck Lever <chuck.lever@oracle.com> Signed-off-by: J. Bruce Fields <bfields@citi.umich.edu>
Diffstat (limited to 'fs/lockd/mon.c')
-rw-r--r--fs/lockd/mon.c64
1 files changed, 64 insertions, 0 deletions
diff --git a/fs/lockd/mon.c b/fs/lockd/mon.c
index 4424b0a5a51f..e46903995c99 100644
--- a/fs/lockd/mon.c
+++ b/fs/lockd/mon.c
@@ -201,6 +201,29 @@ void nsm_unmonitor(const struct nlm_host *host)
201 } 201 }
202} 202}
203 203
204static struct nsm_handle *nsm_lookup_hostname(const char *hostname,
205 const size_t len)
206{
207 struct nsm_handle *nsm;
208
209 list_for_each_entry(nsm, &nsm_handles, sm_link)
210 if (strlen(nsm->sm_name) == len &&
211 memcmp(nsm->sm_name, hostname, len) == 0)
212 return nsm;
213 return NULL;
214}
215
216static struct nsm_handle *nsm_lookup_priv(const struct nsm_private *priv)
217{
218 struct nsm_handle *nsm;
219
220 list_for_each_entry(nsm, &nsm_handles, sm_link)
221 if (memcmp(nsm->sm_priv.data, priv->data,
222 sizeof(priv->data)) == 0)
223 return nsm;
224 return NULL;
225}
226
204/* 227/*
205 * Construct a unique cookie to match this nsm_handle to this monitored 228 * Construct a unique cookie to match this nsm_handle to this monitored
206 * host. It is passed to the local rpc.statd via NSMPROC_MON, and 229 * host. It is passed to the local rpc.statd via NSMPROC_MON, and
@@ -298,6 +321,47 @@ found:
298} 321}
299 322
300/** 323/**
324 * nsm_reboot_lookup - match NLMPROC_SM_NOTIFY arguments to an nsm_handle
325 * @info: pointer to NLMPROC_SM_NOTIFY arguments
326 *
327 * Returns a matching nsm_handle if found in the nsm cache; the returned
328 * nsm_handle's reference count is bumped and sm_monitored is cleared.
329 * Otherwise returns NULL if some error occurred.
330 */
331struct nsm_handle *nsm_reboot_lookup(const struct nlm_reboot *info)
332{
333 struct nsm_handle *cached;
334
335 spin_lock(&nsm_lock);
336
337 if (nsm_use_hostnames && info->mon != NULL)
338 cached = nsm_lookup_hostname(info->mon, info->len);
339 else
340 cached = nsm_lookup_priv(&info->priv);
341
342 if (unlikely(cached == NULL)) {
343 spin_unlock(&nsm_lock);
344 dprintk("lockd: never saw rebooted peer '%.*s' before\n",
345 info->len, info->mon);
346 return cached;
347 }
348
349 atomic_inc(&cached->sm_count);
350 spin_unlock(&nsm_lock);
351
352 /*
353 * During subsequent lock activity, force a fresh
354 * notification to be set up for this host.
355 */
356 cached->sm_monitored = 0;
357
358 dprintk("lockd: host %s (%s) rebooted, cnt %d\n",
359 cached->sm_name, cached->sm_addrbuf,
360 atomic_read(&cached->sm_count));
361 return cached;
362}
363
364/**
301 * nsm_release - Release an NSM handle 365 * nsm_release - Release an NSM handle
302 * @nsm: pointer to handle to be released 366 * @nsm: pointer to handle to be released
303 * 367 *