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 |
