diff options
author | Ilya Dryomov <idryomov@gmail.com> | 2016-04-28 10:07:28 -0400 |
---|---|---|
committer | Ilya Dryomov <idryomov@gmail.com> | 2016-05-25 19:15:30 -0400 |
commit | 7cca78c9dcd1afa243e46edc31896730df85d2b5 (patch) | |
tree | 1d3b677c6196ace6c87fae54c00e415e28e9bb67 /net/ceph | |
parent | b4f34795697de9d1ee84a10c8439b4b9970ebd96 (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.c | 14 | ||||
-rw-r--r-- | net/ceph/osd_client.c | 7 |
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) | |||
385 | EXPORT_SYMBOL(ceph_monc_renew_subs); | 385 | EXPORT_SYMBOL(ceph_monc_renew_subs); |
386 | 386 | ||
387 | /* | 387 | /* |
388 | * Register interest in the next osdmap | ||
389 | */ | ||
390 | void 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 | } | ||
399 | EXPORT_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 | } |
3870 | EXPORT_SYMBOL(ceph_osdc_flush_notifies); | 3870 | EXPORT_SYMBOL(ceph_osdc_flush_notifies); |
3871 | 3871 | ||
3872 | void 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 | } | ||
3878 | EXPORT_SYMBOL(ceph_osdc_maybe_request_map); | ||
3872 | 3879 | ||
3873 | /* | 3880 | /* |
3874 | * init, shutdown | 3881 | * init, shutdown |