1 #include "ceph_debug.h"
3 #include <linux/module.h>
4 #include <linux/slab.h>
6 #include <linux/slab.h>
14 #include "messenger.h"
17 * get protocol handler
19 static u32 supported_protocols[] = {
24 int ceph_auth_init_protocol(struct ceph_auth_client *ac, int protocol)
28 return ceph_auth_none_init(ac);
30 return ceph_x_init(ac);
39 struct ceph_auth_client *ceph_auth_init(const char *name, const char *secret)
41 struct ceph_auth_client *ac;
44 dout("auth_init name '%s' secret '%s'\n", name, secret);
47 ac = kzalloc(sizeof(*ac), GFP_NOFS);
51 ac->negotiating = true;
55 ac->name = CEPH_AUTH_NAME_DEFAULT;
56 dout("auth_init name %s secret %s\n", ac->name, secret);
64 void ceph_auth_destroy(struct ceph_auth_client *ac)
66 dout("auth_destroy %p\n", ac);
73 * Reset occurs when reconnecting to the monitor.
75 void ceph_auth_reset(struct ceph_auth_client *ac)
77 dout("auth_reset %p\n", ac);
78 if (ac->ops && !ac->negotiating)
80 ac->negotiating = true;
83 int ceph_entity_name_encode(const char *name, void **p, void *end)
85 int len = strlen(name);
87 if (*p + 2*sizeof(u32) + len > end)
89 ceph_encode_32(p, CEPH_ENTITY_TYPE_CLIENT);
90 ceph_encode_32(p, len);
91 ceph_encode_copy(p, name, len);
96 * Initiate protocol negotiation with monitor. Include entity name
97 * and list supported protocols.
99 int ceph_auth_build_hello(struct ceph_auth_client *ac, void *buf, size_t len)
101 struct ceph_mon_request_header *monhdr = buf;
102 void *p = monhdr + 1, *end = buf + len, *lenp;
106 dout("auth_build_hello\n");
107 monhdr->have_version = 0;
108 monhdr->session_mon = cpu_to_le16(-1);
109 monhdr->session_mon_tid = 0;
111 ceph_encode_32(&p, 0); /* no protocol, yet */
116 ceph_decode_need(&p, end, 1 + sizeof(u32), bad);
117 ceph_encode_8(&p, 1);
118 num = ARRAY_SIZE(supported_protocols);
119 ceph_encode_32(&p, num);
120 ceph_decode_need(&p, end, num * sizeof(u32), bad);
121 for (i = 0; i < num; i++)
122 ceph_encode_32(&p, supported_protocols[i]);
124 ret = ceph_entity_name_encode(ac->name, &p, end);
127 ceph_decode_need(&p, end, sizeof(u64), bad);
128 ceph_encode_64(&p, ac->global_id);
130 ceph_encode_32(&lenp, p - lenp - sizeof(u32));
137 int ceph_build_auth_request(struct ceph_auth_client *ac,
138 void *msg_buf, size_t msg_len)
140 struct ceph_mon_request_header *monhdr = msg_buf;
141 void *p = monhdr + 1;
142 void *end = msg_buf + msg_len;
145 monhdr->have_version = 0;
146 monhdr->session_mon = cpu_to_le16(-1);
147 monhdr->session_mon_tid = 0;
149 ceph_encode_32(&p, ac->protocol);
151 ret = ac->ops->build_request(ac, p + sizeof(u32), end);
153 pr_err("error %d building auth method %s request\n", ret,
157 dout(" built request %d bytes\n", ret);
158 ceph_encode_32(&p, ret);
159 return p + ret - msg_buf;
163 * Handle auth message from monitor.
165 int ceph_handle_auth_reply(struct ceph_auth_client *ac,
166 void *buf, size_t len,
167 void *reply_buf, size_t reply_len)
170 void *end = buf + len;
174 void *payload, *payload_end;
180 dout("handle_auth_reply %p %p\n", p, end);
181 ceph_decode_need(&p, end, sizeof(u32) * 3 + sizeof(u64), bad);
182 protocol = ceph_decode_32(&p);
183 result = ceph_decode_32(&p);
184 global_id = ceph_decode_64(&p);
185 payload_len = ceph_decode_32(&p);
188 ceph_decode_need(&p, end, sizeof(u32), bad);
189 result_msg_len = ceph_decode_32(&p);
195 dout(" result %d '%.*s' gid %llu len %d\n", result, result_msg_len,
196 result_msg, global_id, payload_len);
198 payload_end = payload + payload_len;
200 if (global_id && ac->global_id != global_id) {
201 dout(" set global_id %lld -> %lld\n", ac->global_id, global_id);
202 ac->global_id = global_id;
205 if (ac->negotiating) {
206 /* server does not support our protocols? */
207 if (!protocol && result < 0) {
211 /* set up (new) protocol handler? */
212 if (ac->protocol && ac->protocol != protocol) {
213 ac->ops->destroy(ac);
217 if (ac->protocol != protocol) {
218 ret = ceph_auth_init_protocol(ac, protocol);
220 pr_err("error %d on auth method %s init\n",
226 ac->negotiating = false;
229 ret = ac->ops->handle_reply(ac, result, payload, payload_end);
230 if (ret == -EAGAIN) {
231 return ceph_build_auth_request(ac, reply_buf, reply_len);
233 pr_err("auth method '%s' error %d\n", ac->ops->name, ret);
239 pr_err("failed to decode auth msg\n");
244 int ceph_build_auth(struct ceph_auth_client *ac,
245 void *msg_buf, size_t msg_len)
248 return ceph_auth_build_hello(ac, msg_buf, msg_len);
250 if (!ac->ops->is_authenticated(ac))
251 return ceph_build_auth_request(ac, msg_buf, msg_len);
255 int ceph_auth_is_authenticated(struct ceph_auth_client *ac)
259 return ac->ops->is_authenticated(ac);