libceph: support for CEPH_OSD_OP_LIST_WATCHERS

Add support for this Ceph OSD op, needed to support the RBD exclusive
lock feature.

Signed-off-by: Douglas Fuller <dfuller@redhat.com>
[idryomov@gmail.com: refactor, misc fixes throughout]
Signed-off-by: Ilya Dryomov <idryomov@gmail.com>
Reviewed-by: Mike Christie <mchristi@redhat.com>
Reviewed-by: Alex Elder <elder@linaro.org>

1 files changed, 14 insertions, 1 deletions

diff --git a/include/linux/ceph/osd_client.h b/include/linux/ceph/osd_client.h
index 858932304260..19821a191732 100644
--- a/include/linux/ceph/osd_client.h
+++ b/include/linux/ceph/osd_client.h
@@ -121,6 +121,9 @@ struct ceph_osd_req_op {
                         struct ceph_osd_data response_data;
                 } notify;
                 struct {
+                        struct ceph_osd_data response_data;
+                } list_watchers;
+                struct {
                         u64 expected_object_size;
                         u64 expected_write_size;
                 } alloc_hint;
@@ -249,6 +252,12 @@ struct ceph_osd_linger_request {
         size_t *preply_len;
 };
 
+struct ceph_watch_item {
+        struct ceph_entity_name name;
+        u64 cookie;
+        struct ceph_entity_addr addr;
+};
+
 struct ceph_osd_client {
         struct ceph_client     *client;
 
@@ -346,7 +355,6 @@ extern void osd_req_op_cls_response_data_pages(struct ceph_osd_request *,
                                         struct page **pages, u64 length,
                                         u32 alignment, bool pages_from_pool,
                                         bool own_pages);
-
 extern void osd_req_op_cls_init(struct ceph_osd_request *osd_req,
                                         unsigned int which, u16 opcode,
                                         const char *class, const char *method);
@@ -434,5 +442,10 @@ int ceph_osdc_notify(struct ceph_osd_client *osdc,
                      size_t *preply_len);
 int ceph_osdc_watch_check(struct ceph_osd_client *osdc,
                           struct ceph_osd_linger_request *lreq);
+int ceph_osdc_list_watchers(struct ceph_osd_client *osdc,
+                            struct ceph_object_id *oid,
+                            struct ceph_object_locator *oloc,
+                            struct ceph_watch_item **watchers,
+                            u32 *num_watchers);
 #endif