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>
8 #include <linux/ceph/messenger.h>
11 struct ceph_mount_args
;
12 struct ceph_auth_client
;
15 * The monitor map enumerates the set of all monitors.
18 struct ceph_fsid fsid
;
21 struct ceph_entity_inst mon_inst
[0];
24 struct ceph_mon_client
;
25 struct ceph_mon_generic_request
;
29 * Generic mechanism for resending monitor requests.
31 typedef void (*ceph_monc_request_func_t
)(struct ceph_mon_client
*monc
,
34 /* a pending monitor request */
35 struct ceph_mon_request
{
36 struct ceph_mon_client
*monc
;
37 struct delayed_work delayed_work
;
39 ceph_monc_request_func_t do_request
;
43 * ceph_mon_generic_request is being used for the statfs and
44 * mon_get_version requests which are being done a bit differently
45 * because we need to get data back to the caller
47 struct ceph_mon_generic_request
{
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
, *m_auth_reply
, *m_subscribe
, *m_subscribe_ack
;
70 int cur_mon
; /* last monitor i contacted */
71 unsigned long sub_renew_after
;
72 unsigned long sub_renew_sent
;
73 struct ceph_connection con
;
75 bool had_a_connection
;
76 int hunt_mult
; /* [1..CEPH_MONC_HUNT_MAX_MULT] */
78 /* pending generic requests */
79 struct rb_root generic_request_tree
;
82 /* subs, indexed with CEPH_SUB_* */
84 struct ceph_mon_subscribe_item item
;
89 #ifdef CONFIG_DEBUG_FS
90 struct dentry
*debugfs_file
;
94 extern struct ceph_monmap
*ceph_monmap_decode(void *p
, void *end
);
95 extern int ceph_monmap_contains(struct ceph_monmap
*m
,
96 struct ceph_entity_addr
*addr
);
98 extern int ceph_monc_init(struct ceph_mon_client
*monc
, struct ceph_client
*cl
);
99 extern void ceph_monc_stop(struct ceph_mon_client
*monc
);
107 extern const char *ceph_sub_str
[];
110 * The model here is to indicate that we need a new map of at least
111 * epoch @epoch, and also call in when we receive a map. We will
112 * periodically rerequest the map from the monitor cluster until we
115 bool ceph_monc_want_map(struct ceph_mon_client
*monc
, int sub
, u32 epoch
,
117 void ceph_monc_got_map(struct ceph_mon_client
*monc
, int sub
, u32 epoch
);
119 extern void ceph_monc_request_next_osdmap(struct ceph_mon_client
*monc
);
120 extern int ceph_monc_wait_osdmap(struct ceph_mon_client
*monc
, u32 epoch
,
121 unsigned long timeout
);
123 extern int ceph_monc_do_statfs(struct ceph_mon_client
*monc
,
124 struct ceph_statfs
*buf
);
126 extern int ceph_monc_do_get_version(struct ceph_mon_client
*monc
,
127 const char *what
, u64
*newest
);
129 extern int ceph_monc_open_session(struct ceph_mon_client
*monc
);
131 extern int ceph_monc_validate_auth(struct ceph_mon_client
*monc
);