aboutsummaryrefslogtreecommitdiffstats
path: root/net/ceph
diff options
context:
space:
mode:
authorIlya Dryomov <idryomov@gmail.com>2016-04-28 10:07:28 -0400
committerIlya Dryomov <idryomov@gmail.com>2016-05-25 19:15:30 -0400
commit7cca78c9dcd1afa243e46edc31896730df85d2b5 (patch)
tree1d3b677c6196ace6c87fae54c00e415e28e9bb67 /net/ceph
parentb4f34795697de9d1ee84a10c8439b4b9970ebd96 (diff)
libceph: replace ceph_monc_request_next_osdmap()
... with a wrapper around maybe_request_map() - no need for two osdmap-specific functions. Signed-off-by: Ilya Dryomov <idryomov@gmail.com>
Diffstat (limited to 'net/ceph')
-rw-r--r--net/ceph/mon_client.c14
-rw-r--r--net/ceph/osd_client.c7
2 files changed, 7 insertions, 14 deletions
diff --git a/net/ceph/mon_client.c b/net/ceph/mon_client.c
index 4e49b2296920..72a910bf7819 100644
--- a/net/ceph/mon_client.c
+++ b/net/ceph/mon_client.c
@@ -385,20 +385,6 @@ void ceph_monc_renew_subs(struct ceph_mon_client *monc)
385EXPORT_SYMBOL(ceph_monc_renew_subs); 385EXPORT_SYMBOL(ceph_monc_renew_subs);
386 386
387/* 387/*
388 * Register interest in the next osdmap
389 */
390void ceph_monc_request_next_osdmap(struct ceph_mon_client *monc)
391{
392 dout("%s have %u\n", __func__, monc->subs[CEPH_SUB_OSDMAP].have);
393 mutex_lock(&monc->mutex);
394 if (__ceph_monc_want_map(monc, CEPH_SUB_OSDMAP,
395 monc->subs[CEPH_SUB_OSDMAP].have + 1, false))
396 __send_subscribe(monc);
397 mutex_unlock(&monc->mutex);
398}
399EXPORT_SYMBOL(ceph_monc_request_next_osdmap);
400
401/*
402 * Wait for an osdmap with a given epoch. 388 * Wait for an osdmap with a given epoch.
403 * 389 *
404 * @epoch: epoch to wait for 390 * @epoch: epoch to wait for
diff --git a/net/ceph/osd_client.c b/net/ceph/osd_client.c
index ece2d10a1208..55cafd3a2ff0 100644
--- a/net/ceph/osd_client.c
+++ b/net/ceph/osd_client.c
@@ -3869,6 +3869,13 @@ void ceph_osdc_flush_notifies(struct ceph_osd_client *osdc)
3869} 3869}
3870EXPORT_SYMBOL(ceph_osdc_flush_notifies); 3870EXPORT_SYMBOL(ceph_osdc_flush_notifies);
3871 3871
3872void ceph_osdc_maybe_request_map(struct ceph_osd_client *osdc)
3873{
3874 down_read(&osdc->lock);
3875 maybe_request_map(osdc);
3876 up_read(&osdc->lock);
3877}
3878EXPORT_SYMBOL(ceph_osdc_maybe_request_map);
3872 3879
3873/* 3880/*
3874 * init, shutdown 3881 * init, shutdown