1 #ifndef _FS_CEPH_MON_CLIENT_H
2 #define _FS_CEPH_MON_CLIENT_H
4 #include <linux/completion.h>
5 #include <linux/kref.h>
6 #include <linux/rbtree.h>
12 struct ceph_mount_args
;
13 struct ceph_auth_client
;
16 * The monitor map enumerates the set of all monitors.
19 struct ceph_fsid fsid
;
22 struct ceph_entity_inst mon_inst
[0];
25 struct ceph_mon_client
;
26 struct ceph_mon_statfs_request
;
30 * Generic mechanism for resending monitor requests.
32 typedef void (*ceph_monc_request_func_t
)(struct ceph_mon_client
*monc
,
35 /* a pending monitor request */
36 struct ceph_mon_request
{
37 struct ceph_mon_client
*monc
;
38 struct delayed_work delayed_work
;
40 ceph_monc_request_func_t do_request
;
44 * statfs() is done a bit differently because we need to get data back
47 struct ceph_mon_statfs_request
{
52 struct ceph_statfs
*buf
;
53 struct completion completion
;
54 struct ceph_msg
*request
; /* original request */
55 struct ceph_msg
*reply
; /* and reply */
58 struct ceph_mon_client
{
59 struct ceph_client
*client
;
60 struct ceph_monmap
*monmap
;
63 struct delayed_work delayed_work
;
65 struct ceph_auth_client
*auth
;
66 struct ceph_msg
*m_auth
;
70 int cur_mon
; /* last monitor i contacted */
71 unsigned long sub_sent
, sub_renew_after
;
72 struct ceph_connection
*con
;
76 struct ceph_msgpool msgpool_subscribe_ack
;
77 struct ceph_msgpool msgpool_auth_reply
;
79 /* pending statfs requests */
80 struct rb_root statfs_request_tree
;
81 int num_statfs_requests
;
85 int want_next_osdmap
; /* 1 = want, 2 = want+asked */
86 u32 have_osdmap
, have_mdsmap
;
88 #ifdef CONFIG_DEBUG_FS
89 struct dentry
*debugfs_file
;
93 extern struct ceph_monmap
*ceph_monmap_decode(void *p
, void *end
);
94 extern int ceph_monmap_contains(struct ceph_monmap
*m
,
95 struct ceph_entity_addr
*addr
);
97 extern int ceph_monc_init(struct ceph_mon_client
*monc
, struct ceph_client
*cl
);
98 extern void ceph_monc_stop(struct ceph_mon_client
*monc
);
101 * The model here is to indicate that we need a new map of at least
102 * epoch @want, and also call in when we receive a map. We will
103 * periodically rerequest the map from the monitor cluster until we
106 extern int ceph_monc_got_mdsmap(struct ceph_mon_client
*monc
, u32 have
);
107 extern int ceph_monc_got_osdmap(struct ceph_mon_client
*monc
, u32 have
);
109 extern void ceph_monc_request_next_osdmap(struct ceph_mon_client
*monc
);
111 extern int ceph_monc_do_statfs(struct ceph_mon_client
*monc
,
112 struct ceph_statfs
*buf
);
114 extern int ceph_monc_open_session(struct ceph_mon_client
*monc
);
116 extern int ceph_monc_validate_auth(struct ceph_mon_client
*monc
);