xref: /linux/include/linux/ceph/mon_client.h (revision 905e46acd3272d04566fec49afbd7ad9e2ed9ae3)
1 #ifndef _FS_CEPH_MON_CLIENT_H
2 #define _FS_CEPH_MON_CLIENT_H
3 
4 #include <linux/completion.h>
5 #include <linux/kref.h>
6 #include <linux/rbtree.h>
7 
8 #include <linux/ceph/messenger.h>
9 
10 struct ceph_client;
11 struct ceph_mount_args;
12 struct ceph_auth_client;
13 
14 /*
15  * The monitor map enumerates the set of all monitors.
16  */
17 struct ceph_monmap {
18 	struct ceph_fsid fsid;
19 	u32 epoch;
20 	u32 num_mon;
21 	struct ceph_entity_inst mon_inst[0];
22 };
23 
24 struct ceph_mon_client;
25 struct ceph_mon_generic_request;
26 
27 
28 /*
29  * Generic mechanism for resending monitor requests.
30  */
31 typedef void (*ceph_monc_request_func_t)(struct ceph_mon_client *monc,
32 					 int newmon);
33 
34 /* a pending monitor request */
35 struct ceph_mon_request {
36 	struct ceph_mon_client *monc;
37 	struct delayed_work delayed_work;
38 	unsigned long delay;
39 	ceph_monc_request_func_t do_request;
40 };
41 
42 typedef void (*ceph_monc_callback_t)(struct ceph_mon_generic_request *);
43 
44 /*
45  * ceph_mon_generic_request is being used for the statfs and
46  * mon_get_version requests which are being done a bit differently
47  * because we need to get data back to the caller
48  */
49 struct ceph_mon_generic_request {
50 	struct ceph_mon_client *monc;
51 	struct kref kref;
52 	u64 tid;
53 	struct rb_node node;
54 	int result;
55 
56 	struct completion completion;
57 	ceph_monc_callback_t complete_cb;
58 	u64 private_data;          /* r_tid/linger_id */
59 
60 	struct ceph_msg *request;  /* original request */
61 	struct ceph_msg *reply;    /* and reply */
62 
63 	union {
64 		struct ceph_statfs *st;
65 		u64 newest;
66 	} u;
67 };
68 
69 struct ceph_mon_client {
70 	struct ceph_client *client;
71 	struct ceph_monmap *monmap;
72 
73 	struct mutex mutex;
74 	struct delayed_work delayed_work;
75 
76 	struct ceph_auth_client *auth;
77 	struct ceph_msg *m_auth, *m_auth_reply, *m_subscribe, *m_subscribe_ack;
78 	int pending_auth;
79 
80 	bool hunting;
81 	int cur_mon;                       /* last monitor i contacted */
82 	unsigned long sub_renew_after;
83 	unsigned long sub_renew_sent;
84 	struct ceph_connection con;
85 
86 	bool had_a_connection;
87 	int hunt_mult; /* [1..CEPH_MONC_HUNT_MAX_MULT] */
88 
89 	/* pending generic requests */
90 	struct rb_root generic_request_tree;
91 	u64 last_tid;
92 
93 	/* subs, indexed with CEPH_SUB_* */
94 	struct {
95 		struct ceph_mon_subscribe_item item;
96 		bool want;
97 		u32 have; /* epoch */
98 	} subs[4];
99 	int fs_cluster_id; /* "mdsmap.<id>" sub */
100 
101 #ifdef CONFIG_DEBUG_FS
102 	struct dentry *debugfs_file;
103 #endif
104 };
105 
106 extern struct ceph_monmap *ceph_monmap_decode(void *p, void *end);
107 extern int ceph_monmap_contains(struct ceph_monmap *m,
108 				struct ceph_entity_addr *addr);
109 
110 extern int ceph_monc_init(struct ceph_mon_client *monc, struct ceph_client *cl);
111 extern void ceph_monc_stop(struct ceph_mon_client *monc);
112 
113 enum {
114 	CEPH_SUB_MONMAP = 0,
115 	CEPH_SUB_OSDMAP,
116 	CEPH_SUB_FSMAP,
117 	CEPH_SUB_MDSMAP,
118 };
119 
120 extern const char *ceph_sub_str[];
121 
122 /*
123  * The model here is to indicate that we need a new map of at least
124  * epoch @epoch, and also call in when we receive a map.  We will
125  * periodically rerequest the map from the monitor cluster until we
126  * get what we want.
127  */
128 bool ceph_monc_want_map(struct ceph_mon_client *monc, int sub, u32 epoch,
129 			bool continuous);
130 void ceph_monc_got_map(struct ceph_mon_client *monc, int sub, u32 epoch);
131 void ceph_monc_renew_subs(struct ceph_mon_client *monc);
132 
133 extern int ceph_monc_wait_osdmap(struct ceph_mon_client *monc, u32 epoch,
134 				 unsigned long timeout);
135 
136 extern int ceph_monc_do_statfs(struct ceph_mon_client *monc,
137 			       struct ceph_statfs *buf);
138 
139 int ceph_monc_get_version(struct ceph_mon_client *monc, const char *what,
140 			  u64 *newest);
141 int ceph_monc_get_version_async(struct ceph_mon_client *monc, const char *what,
142 				ceph_monc_callback_t cb, u64 private_data);
143 
144 int ceph_monc_blacklist_add(struct ceph_mon_client *monc,
145 			    struct ceph_entity_addr *client_addr);
146 
147 extern int ceph_monc_open_session(struct ceph_mon_client *monc);
148 
149 extern int ceph_monc_validate_auth(struct ceph_mon_client *monc);
150 
151 #endif
152