Loading...
1// SPDX-License-Identifier: GPL-2.0
2#include <linux/ceph/ceph_debug.h>
3
4#include <linux/module.h>
5#include <linux/err.h>
6#include <linux/slab.h>
7
8#include <linux/ceph/types.h>
9#include <linux/ceph/decode.h>
10#include <linux/ceph/libceph.h>
11#include <linux/ceph/messenger.h>
12#include "auth_none.h"
13#include "auth_x.h"
14
15
16/*
17 * get protocol handler
18 */
19static u32 supported_protocols[] = {
20 CEPH_AUTH_NONE,
21 CEPH_AUTH_CEPHX
22};
23
24static int ceph_auth_init_protocol(struct ceph_auth_client *ac, int protocol)
25{
26 switch (protocol) {
27 case CEPH_AUTH_NONE:
28 return ceph_auth_none_init(ac);
29 case CEPH_AUTH_CEPHX:
30 return ceph_x_init(ac);
31 default:
32 return -ENOENT;
33 }
34}
35
36/*
37 * setup, teardown.
38 */
39struct ceph_auth_client *ceph_auth_init(const char *name, const struct ceph_crypto_key *key)
40{
41 struct ceph_auth_client *ac;
42 int ret;
43
44 dout("auth_init name '%s'\n", name);
45
46 ret = -ENOMEM;
47 ac = kzalloc(sizeof(*ac), GFP_NOFS);
48 if (!ac)
49 goto out;
50
51 mutex_init(&ac->mutex);
52 ac->negotiating = true;
53 if (name)
54 ac->name = name;
55 else
56 ac->name = CEPH_AUTH_NAME_DEFAULT;
57 dout("auth_init name %s\n", ac->name);
58 ac->key = key;
59 return ac;
60
61out:
62 return ERR_PTR(ret);
63}
64
65void ceph_auth_destroy(struct ceph_auth_client *ac)
66{
67 dout("auth_destroy %p\n", ac);
68 if (ac->ops)
69 ac->ops->destroy(ac);
70 kfree(ac);
71}
72
73/*
74 * Reset occurs when reconnecting to the monitor.
75 */
76void ceph_auth_reset(struct ceph_auth_client *ac)
77{
78 mutex_lock(&ac->mutex);
79 dout("auth_reset %p\n", ac);
80 if (ac->ops && !ac->negotiating)
81 ac->ops->reset(ac);
82 ac->negotiating = true;
83 mutex_unlock(&ac->mutex);
84}
85
86/*
87 * EntityName, not to be confused with entity_name_t
88 */
89int ceph_auth_entity_name_encode(const char *name, void **p, void *end)
90{
91 int len = strlen(name);
92
93 if (*p + 2*sizeof(u32) + len > end)
94 return -ERANGE;
95 ceph_encode_32(p, CEPH_ENTITY_TYPE_CLIENT);
96 ceph_encode_32(p, len);
97 ceph_encode_copy(p, name, len);
98 return 0;
99}
100
101/*
102 * Initiate protocol negotiation with monitor. Include entity name
103 * and list supported protocols.
104 */
105int ceph_auth_build_hello(struct ceph_auth_client *ac, void *buf, size_t len)
106{
107 struct ceph_mon_request_header *monhdr = buf;
108 void *p = monhdr + 1, *end = buf + len, *lenp;
109 int i, num;
110 int ret;
111
112 mutex_lock(&ac->mutex);
113 dout("auth_build_hello\n");
114 monhdr->have_version = 0;
115 monhdr->session_mon = cpu_to_le16(-1);
116 monhdr->session_mon_tid = 0;
117
118 ceph_encode_32(&p, CEPH_AUTH_UNKNOWN); /* no protocol, yet */
119
120 lenp = p;
121 p += sizeof(u32);
122
123 ceph_decode_need(&p, end, 1 + sizeof(u32), bad);
124 ceph_encode_8(&p, 1);
125 num = ARRAY_SIZE(supported_protocols);
126 ceph_encode_32(&p, num);
127 ceph_decode_need(&p, end, num * sizeof(u32), bad);
128 for (i = 0; i < num; i++)
129 ceph_encode_32(&p, supported_protocols[i]);
130
131 ret = ceph_auth_entity_name_encode(ac->name, &p, end);
132 if (ret < 0)
133 goto out;
134 ceph_decode_need(&p, end, sizeof(u64), bad);
135 ceph_encode_64(&p, ac->global_id);
136
137 ceph_encode_32(&lenp, p - lenp - sizeof(u32));
138 ret = p - buf;
139out:
140 mutex_unlock(&ac->mutex);
141 return ret;
142
143bad:
144 ret = -ERANGE;
145 goto out;
146}
147
148static int ceph_build_auth_request(struct ceph_auth_client *ac,
149 void *msg_buf, size_t msg_len)
150{
151 struct ceph_mon_request_header *monhdr = msg_buf;
152 void *p = monhdr + 1;
153 void *end = msg_buf + msg_len;
154 int ret;
155
156 monhdr->have_version = 0;
157 monhdr->session_mon = cpu_to_le16(-1);
158 monhdr->session_mon_tid = 0;
159
160 ceph_encode_32(&p, ac->protocol);
161
162 ret = ac->ops->build_request(ac, p + sizeof(u32), end);
163 if (ret < 0) {
164 pr_err("error %d building auth method %s request\n", ret,
165 ac->ops->name);
166 goto out;
167 }
168 dout(" built request %d bytes\n", ret);
169 ceph_encode_32(&p, ret);
170 ret = p + ret - msg_buf;
171out:
172 return ret;
173}
174
175/*
176 * Handle auth message from monitor.
177 */
178int ceph_handle_auth_reply(struct ceph_auth_client *ac,
179 void *buf, size_t len,
180 void *reply_buf, size_t reply_len)
181{
182 void *p = buf;
183 void *end = buf + len;
184 int protocol;
185 s32 result;
186 u64 global_id;
187 void *payload, *payload_end;
188 int payload_len;
189 char *result_msg;
190 int result_msg_len;
191 int ret = -EINVAL;
192
193 mutex_lock(&ac->mutex);
194 dout("handle_auth_reply %p %p\n", p, end);
195 ceph_decode_need(&p, end, sizeof(u32) * 3 + sizeof(u64), bad);
196 protocol = ceph_decode_32(&p);
197 result = ceph_decode_32(&p);
198 global_id = ceph_decode_64(&p);
199 payload_len = ceph_decode_32(&p);
200 payload = p;
201 p += payload_len;
202 ceph_decode_need(&p, end, sizeof(u32), bad);
203 result_msg_len = ceph_decode_32(&p);
204 result_msg = p;
205 p += result_msg_len;
206 if (p != end)
207 goto bad;
208
209 dout(" result %d '%.*s' gid %llu len %d\n", result, result_msg_len,
210 result_msg, global_id, payload_len);
211
212 payload_end = payload + payload_len;
213
214 if (global_id && ac->global_id != global_id) {
215 dout(" set global_id %lld -> %lld\n", ac->global_id, global_id);
216 ac->global_id = global_id;
217 }
218
219 if (ac->negotiating) {
220 /* server does not support our protocols? */
221 if (!protocol && result < 0) {
222 ret = result;
223 goto out;
224 }
225 /* set up (new) protocol handler? */
226 if (ac->protocol && ac->protocol != protocol) {
227 ac->ops->destroy(ac);
228 ac->protocol = 0;
229 ac->ops = NULL;
230 }
231 if (ac->protocol != protocol) {
232 ret = ceph_auth_init_protocol(ac, protocol);
233 if (ret) {
234 pr_err("error %d on auth protocol %d init\n",
235 ret, protocol);
236 goto out;
237 }
238 }
239
240 ac->negotiating = false;
241 }
242
243 ret = ac->ops->handle_reply(ac, result, payload, payload_end);
244 if (ret == -EAGAIN) {
245 ret = ceph_build_auth_request(ac, reply_buf, reply_len);
246 } else if (ret) {
247 pr_err("auth method '%s' error %d\n", ac->ops->name, ret);
248 }
249
250out:
251 mutex_unlock(&ac->mutex);
252 return ret;
253
254bad:
255 pr_err("failed to decode auth msg\n");
256 ret = -EINVAL;
257 goto out;
258}
259
260int ceph_build_auth(struct ceph_auth_client *ac,
261 void *msg_buf, size_t msg_len)
262{
263 int ret = 0;
264
265 mutex_lock(&ac->mutex);
266 if (ac->ops->should_authenticate(ac))
267 ret = ceph_build_auth_request(ac, msg_buf, msg_len);
268 mutex_unlock(&ac->mutex);
269 return ret;
270}
271
272int ceph_auth_is_authenticated(struct ceph_auth_client *ac)
273{
274 int ret = 0;
275
276 mutex_lock(&ac->mutex);
277 if (ac->ops)
278 ret = ac->ops->is_authenticated(ac);
279 mutex_unlock(&ac->mutex);
280 return ret;
281}
282EXPORT_SYMBOL(ceph_auth_is_authenticated);
283
284int ceph_auth_create_authorizer(struct ceph_auth_client *ac,
285 int peer_type,
286 struct ceph_auth_handshake *auth)
287{
288 int ret = 0;
289
290 mutex_lock(&ac->mutex);
291 if (ac->ops && ac->ops->create_authorizer)
292 ret = ac->ops->create_authorizer(ac, peer_type, auth);
293 mutex_unlock(&ac->mutex);
294 return ret;
295}
296EXPORT_SYMBOL(ceph_auth_create_authorizer);
297
298void ceph_auth_destroy_authorizer(struct ceph_authorizer *a)
299{
300 a->destroy(a);
301}
302EXPORT_SYMBOL(ceph_auth_destroy_authorizer);
303
304int ceph_auth_update_authorizer(struct ceph_auth_client *ac,
305 int peer_type,
306 struct ceph_auth_handshake *a)
307{
308 int ret = 0;
309
310 mutex_lock(&ac->mutex);
311 if (ac->ops && ac->ops->update_authorizer)
312 ret = ac->ops->update_authorizer(ac, peer_type, a);
313 mutex_unlock(&ac->mutex);
314 return ret;
315}
316EXPORT_SYMBOL(ceph_auth_update_authorizer);
317
318int ceph_auth_verify_authorizer_reply(struct ceph_auth_client *ac,
319 struct ceph_authorizer *a)
320{
321 int ret = 0;
322
323 mutex_lock(&ac->mutex);
324 if (ac->ops && ac->ops->verify_authorizer_reply)
325 ret = ac->ops->verify_authorizer_reply(ac, a);
326 mutex_unlock(&ac->mutex);
327 return ret;
328}
329EXPORT_SYMBOL(ceph_auth_verify_authorizer_reply);
330
331void ceph_auth_invalidate_authorizer(struct ceph_auth_client *ac, int peer_type)
332{
333 mutex_lock(&ac->mutex);
334 if (ac->ops && ac->ops->invalidate_authorizer)
335 ac->ops->invalidate_authorizer(ac, peer_type);
336 mutex_unlock(&ac->mutex);
337}
338EXPORT_SYMBOL(ceph_auth_invalidate_authorizer);
1#include <linux/ceph/ceph_debug.h>
2
3#include <linux/module.h>
4#include <linux/err.h>
5#include <linux/slab.h>
6
7#include <linux/ceph/types.h>
8#include <linux/ceph/decode.h>
9#include <linux/ceph/libceph.h>
10#include <linux/ceph/messenger.h>
11#include "auth_none.h"
12#include "auth_x.h"
13
14
15/*
16 * get protocol handler
17 */
18static u32 supported_protocols[] = {
19 CEPH_AUTH_NONE,
20 CEPH_AUTH_CEPHX
21};
22
23static int ceph_auth_init_protocol(struct ceph_auth_client *ac, int protocol)
24{
25 switch (protocol) {
26 case CEPH_AUTH_NONE:
27 return ceph_auth_none_init(ac);
28 case CEPH_AUTH_CEPHX:
29 return ceph_x_init(ac);
30 default:
31 return -ENOENT;
32 }
33}
34
35/*
36 * setup, teardown.
37 */
38struct ceph_auth_client *ceph_auth_init(const char *name, const struct ceph_crypto_key *key)
39{
40 struct ceph_auth_client *ac;
41 int ret;
42
43 dout("auth_init name '%s'\n", name);
44
45 ret = -ENOMEM;
46 ac = kzalloc(sizeof(*ac), GFP_NOFS);
47 if (!ac)
48 goto out;
49
50 mutex_init(&ac->mutex);
51 ac->negotiating = true;
52 if (name)
53 ac->name = name;
54 else
55 ac->name = CEPH_AUTH_NAME_DEFAULT;
56 dout("auth_init name %s\n", ac->name);
57 ac->key = key;
58 return ac;
59
60out:
61 return ERR_PTR(ret);
62}
63
64void ceph_auth_destroy(struct ceph_auth_client *ac)
65{
66 dout("auth_destroy %p\n", ac);
67 if (ac->ops)
68 ac->ops->destroy(ac);
69 kfree(ac);
70}
71
72/*
73 * Reset occurs when reconnecting to the monitor.
74 */
75void ceph_auth_reset(struct ceph_auth_client *ac)
76{
77 mutex_lock(&ac->mutex);
78 dout("auth_reset %p\n", ac);
79 if (ac->ops && !ac->negotiating)
80 ac->ops->reset(ac);
81 ac->negotiating = true;
82 mutex_unlock(&ac->mutex);
83}
84
85int ceph_entity_name_encode(const char *name, void **p, void *end)
86{
87 int len = strlen(name);
88
89 if (*p + 2*sizeof(u32) + len > end)
90 return -ERANGE;
91 ceph_encode_32(p, CEPH_ENTITY_TYPE_CLIENT);
92 ceph_encode_32(p, len);
93 ceph_encode_copy(p, name, len);
94 return 0;
95}
96
97/*
98 * Initiate protocol negotiation with monitor. Include entity name
99 * and list supported protocols.
100 */
101int ceph_auth_build_hello(struct ceph_auth_client *ac, void *buf, size_t len)
102{
103 struct ceph_mon_request_header *monhdr = buf;
104 void *p = monhdr + 1, *end = buf + len, *lenp;
105 int i, num;
106 int ret;
107
108 mutex_lock(&ac->mutex);
109 dout("auth_build_hello\n");
110 monhdr->have_version = 0;
111 monhdr->session_mon = cpu_to_le16(-1);
112 monhdr->session_mon_tid = 0;
113
114 ceph_encode_32(&p, 0); /* no protocol, yet */
115
116 lenp = p;
117 p += sizeof(u32);
118
119 ceph_decode_need(&p, end, 1 + sizeof(u32), bad);
120 ceph_encode_8(&p, 1);
121 num = ARRAY_SIZE(supported_protocols);
122 ceph_encode_32(&p, num);
123 ceph_decode_need(&p, end, num * sizeof(u32), bad);
124 for (i = 0; i < num; i++)
125 ceph_encode_32(&p, supported_protocols[i]);
126
127 ret = ceph_entity_name_encode(ac->name, &p, end);
128 if (ret < 0)
129 goto out;
130 ceph_decode_need(&p, end, sizeof(u64), bad);
131 ceph_encode_64(&p, ac->global_id);
132
133 ceph_encode_32(&lenp, p - lenp - sizeof(u32));
134 ret = p - buf;
135out:
136 mutex_unlock(&ac->mutex);
137 return ret;
138
139bad:
140 ret = -ERANGE;
141 goto out;
142}
143
144static int ceph_build_auth_request(struct ceph_auth_client *ac,
145 void *msg_buf, size_t msg_len)
146{
147 struct ceph_mon_request_header *monhdr = msg_buf;
148 void *p = monhdr + 1;
149 void *end = msg_buf + msg_len;
150 int ret;
151
152 monhdr->have_version = 0;
153 monhdr->session_mon = cpu_to_le16(-1);
154 monhdr->session_mon_tid = 0;
155
156 ceph_encode_32(&p, ac->protocol);
157
158 ret = ac->ops->build_request(ac, p + sizeof(u32), end);
159 if (ret < 0) {
160 pr_err("error %d building auth method %s request\n", ret,
161 ac->ops->name);
162 goto out;
163 }
164 dout(" built request %d bytes\n", ret);
165 ceph_encode_32(&p, ret);
166 ret = p + ret - msg_buf;
167out:
168 return ret;
169}
170
171/*
172 * Handle auth message from monitor.
173 */
174int ceph_handle_auth_reply(struct ceph_auth_client *ac,
175 void *buf, size_t len,
176 void *reply_buf, size_t reply_len)
177{
178 void *p = buf;
179 void *end = buf + len;
180 int protocol;
181 s32 result;
182 u64 global_id;
183 void *payload, *payload_end;
184 int payload_len;
185 char *result_msg;
186 int result_msg_len;
187 int ret = -EINVAL;
188
189 mutex_lock(&ac->mutex);
190 dout("handle_auth_reply %p %p\n", p, end);
191 ceph_decode_need(&p, end, sizeof(u32) * 3 + sizeof(u64), bad);
192 protocol = ceph_decode_32(&p);
193 result = ceph_decode_32(&p);
194 global_id = ceph_decode_64(&p);
195 payload_len = ceph_decode_32(&p);
196 payload = p;
197 p += payload_len;
198 ceph_decode_need(&p, end, sizeof(u32), bad);
199 result_msg_len = ceph_decode_32(&p);
200 result_msg = p;
201 p += result_msg_len;
202 if (p != end)
203 goto bad;
204
205 dout(" result %d '%.*s' gid %llu len %d\n", result, result_msg_len,
206 result_msg, global_id, payload_len);
207
208 payload_end = payload + payload_len;
209
210 if (global_id && ac->global_id != global_id) {
211 dout(" set global_id %lld -> %lld\n", ac->global_id, global_id);
212 ac->global_id = global_id;
213 }
214
215 if (ac->negotiating) {
216 /* server does not support our protocols? */
217 if (!protocol && result < 0) {
218 ret = result;
219 goto out;
220 }
221 /* set up (new) protocol handler? */
222 if (ac->protocol && ac->protocol != protocol) {
223 ac->ops->destroy(ac);
224 ac->protocol = 0;
225 ac->ops = NULL;
226 }
227 if (ac->protocol != protocol) {
228 ret = ceph_auth_init_protocol(ac, protocol);
229 if (ret) {
230 pr_err("error %d on auth protocol %d init\n",
231 ret, protocol);
232 goto out;
233 }
234 }
235
236 ac->negotiating = false;
237 }
238
239 ret = ac->ops->handle_reply(ac, result, payload, payload_end);
240 if (ret == -EAGAIN) {
241 ret = ceph_build_auth_request(ac, reply_buf, reply_len);
242 } else if (ret) {
243 pr_err("auth method '%s' error %d\n", ac->ops->name, ret);
244 }
245
246out:
247 mutex_unlock(&ac->mutex);
248 return ret;
249
250bad:
251 pr_err("failed to decode auth msg\n");
252 ret = -EINVAL;
253 goto out;
254}
255
256int ceph_build_auth(struct ceph_auth_client *ac,
257 void *msg_buf, size_t msg_len)
258{
259 int ret = 0;
260
261 mutex_lock(&ac->mutex);
262 if (!ac->protocol)
263 ret = ceph_auth_build_hello(ac, msg_buf, msg_len);
264 else if (ac->ops->should_authenticate(ac))
265 ret = ceph_build_auth_request(ac, msg_buf, msg_len);
266 mutex_unlock(&ac->mutex);
267 return ret;
268}
269
270int ceph_auth_is_authenticated(struct ceph_auth_client *ac)
271{
272 int ret = 0;
273
274 mutex_lock(&ac->mutex);
275 if (ac->ops)
276 ret = ac->ops->is_authenticated(ac);
277 mutex_unlock(&ac->mutex);
278 return ret;
279}
280EXPORT_SYMBOL(ceph_auth_is_authenticated);
281
282int ceph_auth_create_authorizer(struct ceph_auth_client *ac,
283 int peer_type,
284 struct ceph_auth_handshake *auth)
285{
286 int ret = 0;
287
288 mutex_lock(&ac->mutex);
289 if (ac->ops && ac->ops->create_authorizer)
290 ret = ac->ops->create_authorizer(ac, peer_type, auth);
291 mutex_unlock(&ac->mutex);
292 return ret;
293}
294EXPORT_SYMBOL(ceph_auth_create_authorizer);
295
296void ceph_auth_destroy_authorizer(struct ceph_auth_client *ac,
297 struct ceph_authorizer *a)
298{
299 mutex_lock(&ac->mutex);
300 if (ac->ops && ac->ops->destroy_authorizer)
301 ac->ops->destroy_authorizer(ac, a);
302 mutex_unlock(&ac->mutex);
303}
304EXPORT_SYMBOL(ceph_auth_destroy_authorizer);
305
306int ceph_auth_update_authorizer(struct ceph_auth_client *ac,
307 int peer_type,
308 struct ceph_auth_handshake *a)
309{
310 int ret = 0;
311
312 mutex_lock(&ac->mutex);
313 if (ac->ops && ac->ops->update_authorizer)
314 ret = ac->ops->update_authorizer(ac, peer_type, a);
315 mutex_unlock(&ac->mutex);
316 return ret;
317}
318EXPORT_SYMBOL(ceph_auth_update_authorizer);
319
320int ceph_auth_verify_authorizer_reply(struct ceph_auth_client *ac,
321 struct ceph_authorizer *a, size_t len)
322{
323 int ret = 0;
324
325 mutex_lock(&ac->mutex);
326 if (ac->ops && ac->ops->verify_authorizer_reply)
327 ret = ac->ops->verify_authorizer_reply(ac, a, len);
328 mutex_unlock(&ac->mutex);
329 return ret;
330}
331EXPORT_SYMBOL(ceph_auth_verify_authorizer_reply);
332
333void ceph_auth_invalidate_authorizer(struct ceph_auth_client *ac, int peer_type)
334{
335 mutex_lock(&ac->mutex);
336 if (ac->ops && ac->ops->invalidate_authorizer)
337 ac->ops->invalidate_authorizer(ac, peer_type);
338 mutex_unlock(&ac->mutex);
339}
340EXPORT_SYMBOL(ceph_auth_invalidate_authorizer);