Release 4.11 net/ceph/auth.c

#include <linux/ceph/ceph_debug.h>

#include <linux/module.h>
#include <linux/err.h>
#include <linux/slab.h>

#include <linux/ceph/types.h>
#include <linux/ceph/decode.h>
#include <linux/ceph/libceph.h>
#include <linux/ceph/messenger.h>
#include "auth_none.h"
#include "auth_x.h"


/*
 * get protocol handler
 */

static u32 supported_protocols[] = {
	CEPH_AUTH_NONE,
	CEPH_AUTH_CEPHX
};



static int ceph_auth_init_protocol(struct ceph_auth_client *ac, int protocol)
{
	switch (protocol) {
	case CEPH_AUTH_NONE:
		return ceph_auth_none_init(ac);
	case CEPH_AUTH_CEPHX:
		return ceph_x_init(ac);
	default:
		return -ENOENT;
	}
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
42
97.67%
2
66.67%
Yehuda Sadeh Weinraub
1
2.33%
1
33.33%
Total
43
100.00%
3
100.00%

/*
 * setup, teardown.
 */


struct ceph_auth_client *ceph_auth_init(const char *name, const struct ceph_crypto_key *key)
{
	struct ceph_auth_client *ac;
	int ret;

	dout("auth_init name '%s'\n", name);

	ret = -ENOMEM;
	ac = kzalloc(sizeof(*ac), GFP_NOFS);
	if (!ac)
		goto out;

	mutex_init(&ac->mutex);
	ac->negotiating = true;
	if (name)
		ac->name = name;
	else
		ac->name = CEPH_AUTH_NAME_DEFAULT;
	dout("auth_init name %s\n", ac->name);
	ac->key = key;
	return ac;

out:
	return ERR_PTR(ret);
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
109
93.97%
2
66.67%
Tommi Virtanen
7
6.03%
1
33.33%
Total
116
100.00%
3
100.00%



void ceph_auth_destroy(struct ceph_auth_client *ac)
{
	dout("auth_destroy %p\n", ac);
	if (ac->ops)
		ac->ops->destroy(ac);
	kfree(ac);
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
37
100.00%
1
100.00%
Total
37
100.00%
1
100.00%

/*
 * Reset occurs when reconnecting to the monitor.
 */


void ceph_auth_reset(struct ceph_auth_client *ac)
{
	mutex_lock(&ac->mutex);
	dout("auth_reset %p\n", ac);
	if (ac->ops && !ac->negotiating)
		ac->ops->reset(ac);
	ac->negotiating = true;
	mutex_unlock(&ac->mutex);
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
59
100.00%
2
100.00%
Total
59
100.00%
2
100.00%

/*
 * EntityName, not to be confused with entity_name_t
 */


int ceph_auth_entity_name_encode(const char *name, void **p, void *end)
{
	int len = strlen(name);

	if (*p + 2*sizeof(u32) + len > end)
		return -ERANGE;
	ceph_encode_32(p, CEPH_ENTITY_TYPE_CLIENT);
	ceph_encode_32(p, len);
	ceph_encode_copy(p, name, len);
	return 0;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
72
98.63%
1
50.00%
Ilya Dryomov
1
1.37%
1
50.00%
Total
73
100.00%
2
100.00%

/*
 * Initiate protocol negotiation with monitor.  Include entity name
 * and list supported protocols.
 */


int ceph_auth_build_hello(struct ceph_auth_client *ac, void *buf, size_t len)
{
	struct ceph_mon_request_header *monhdr = buf;
	void *p = monhdr + 1, *end = buf + len, *lenp;
	int i, num;
	int ret;

	mutex_lock(&ac->mutex);
	dout("auth_build_hello\n");
	monhdr->have_version = 0;
	monhdr->session_mon = cpu_to_le16(-1);
	monhdr->session_mon_tid = 0;

	ceph_encode_32(&p, CEPH_AUTH_UNKNOWN);  /* no protocol, yet */

	lenp = p;
	p += sizeof(u32);

	ceph_decode_need(&p, end, 1 + sizeof(u32), bad);
	ceph_encode_8(&p, 1);
	num = ARRAY_SIZE(supported_protocols);
	ceph_encode_32(&p, num);
	ceph_decode_need(&p, end, num * sizeof(u32), bad);
	for (i = 0; i < num; i++)
		ceph_encode_32(&p, supported_protocols[i]);

	ret = ceph_auth_entity_name_encode(ac->name, &p, end);
	if (ret < 0)
		goto out;
	ceph_decode_need(&p, end, sizeof(u64), bad);
	ceph_encode_64(&p, ac->global_id);

	ceph_encode_32(&lenp, p - lenp - sizeof(u32));
	ret = p - buf;
out:
	mutex_unlock(&ac->mutex);
	return ret;

bad:
	ret = -ERANGE;
	goto out;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
276
99.28%
3
60.00%
Ilya Dryomov
2
0.72%
2
40.00%
Total
278
100.00%
5
100.00%



static int ceph_build_auth_request(struct ceph_auth_client *ac,
				   void *msg_buf, size_t msg_len)
{
	struct ceph_mon_request_header *monhdr = msg_buf;
	void *p = monhdr + 1;
	void *end = msg_buf + msg_len;
	int ret;

	monhdr->have_version = 0;
	monhdr->session_mon = cpu_to_le16(-1);
	monhdr->session_mon_tid = 0;

	ceph_encode_32(&p, ac->protocol);

	ret = ac->ops->build_request(ac, p + sizeof(u32), end);
	if (ret < 0) {
		pr_err("error %d building auth method %s request\n", ret,
		       ac->ops->name);
		goto out;
	}
	dout(" built request %d bytes\n", ret);
	ceph_encode_32(&p, ret);
	ret = p + ret - msg_buf;
out:
	return ret;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
147
99.32%
3
75.00%
Yehuda Sadeh Weinraub
1
0.68%
1
25.00%
Total
148
100.00%
4
100.00%

/*
 * Handle auth message from monitor.
 */


int ceph_handle_auth_reply(struct ceph_auth_client *ac,
			   void *buf, size_t len,
			   void *reply_buf, size_t reply_len)
{
	void *p = buf;
	void *end = buf + len;
	int protocol;
	s32 result;
	u64 global_id;
	void *payload, *payload_end;
	int payload_len;
	char *result_msg;
	int result_msg_len;
	int ret = -EINVAL;

	mutex_lock(&ac->mutex);
	dout("handle_auth_reply %p %p\n", p, end);
	ceph_decode_need(&p, end, sizeof(u32) * 3 + sizeof(u64), bad);
	protocol = ceph_decode_32(&p);
	result = ceph_decode_32(&p);
	global_id = ceph_decode_64(&p);
	payload_len = ceph_decode_32(&p);
	payload = p;
	p += payload_len;
	ceph_decode_need(&p, end, sizeof(u32), bad);
	result_msg_len = ceph_decode_32(&p);
	result_msg = p;
	p += result_msg_len;
	if (p != end)
		goto bad;

	dout(" result %d '%.*s' gid %llu len %d\n", result, result_msg_len,
	     result_msg, global_id, payload_len);

	payload_end = payload + payload_len;

	if (global_id && ac->global_id != global_id) {
		dout(" set global_id %lld -> %lld\n", ac->global_id, global_id);
		ac->global_id = global_id;
	}

	if (ac->negotiating) {
		/* server does not support our protocols? */
		if (!protocol && result < 0) {
			ret = result;
			goto out;
		}
		/* set up (new) protocol handler? */
		if (ac->protocol && ac->protocol != protocol) {
			ac->ops->destroy(ac);
			ac->protocol = 0;
			ac->ops = NULL;
		}
		if (ac->protocol != protocol) {
			ret = ceph_auth_init_protocol(ac, protocol);
			if (ret) {
				pr_err("error %d on auth protocol %d init\n",
				       ret, protocol);
				goto out;
			}
		}

		ac->negotiating = false;
	}

	ret = ac->ops->handle_reply(ac, result, payload, payload_end);
	if (ret == -EAGAIN) {
		ret = ceph_build_auth_request(ac, reply_buf, reply_len);
	} else if (ret) {
		pr_err("auth method '%s' error %d\n", ac->ops->name, ret);
	}

out:
	mutex_unlock(&ac->mutex);
	return ret;

bad:
	pr_err("failed to decode auth msg\n");
	ret = -EINVAL;
	goto out;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
411
95.58%
5
83.33%
Yehuda Sadeh Weinraub
19
4.42%
1
16.67%
Total
430
100.00%
6
100.00%



int ceph_build_auth(struct ceph_auth_client *ac,
		    void *msg_buf, size_t msg_len)
{
	int ret = 0;

	mutex_lock(&ac->mutex);
	if (ac->ops->should_authenticate(ac))
		ret = ceph_build_auth_request(ac, msg_buf, msg_len);
	mutex_unlock(&ac->mutex);
	return ret;
}

Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
63
100.00%
4
100.00%
Total
63
100.00%
4
100.00%



int ceph_auth_is_authenticated(struct ceph_auth_client *ac)
{
	int ret = 0;

	mutex_lock(&ac->mutex);
	if (ac->ops)
		ret = ac->ops->is_authenticated(ac);
	mutex_unlock(&ac->mutex);
	return ret;
}
Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
51
100.00%
3
100.00%
Total
51
100.00%
3
100.00%


EXPORT_SYMBOL(ceph_auth_is_authenticated);



int ceph_auth_create_authorizer(struct ceph_auth_client *ac,
				int peer_type,
				struct ceph_auth_handshake *auth)
{
	int ret = 0;

	mutex_lock(&ac->mutex);
	if (ac->ops && ac->ops->create_authorizer)
		ret = ac->ops->create_authorizer(ac, peer_type, auth);
	mutex_unlock(&ac->mutex);
	return ret;
}
Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
69
100.00%
2
100.00%
Total
69
100.00%
2
100.00%


EXPORT_SYMBOL(ceph_auth_create_authorizer);



void ceph_auth_destroy_authorizer(struct ceph_authorizer *a)
{
	a->destroy(a);
}
Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
15
88.24%
1
50.00%
Ilya Dryomov
2
11.76%
1
50.00%
Total
17
100.00%
2
100.00%


EXPORT_SYMBOL(ceph_auth_destroy_authorizer);



int ceph_auth_update_authorizer(struct ceph_auth_client *ac,
				int peer_type,
				struct ceph_auth_handshake *a)
{
	int ret = 0;

	mutex_lock(&ac->mutex);
	if (ac->ops && ac->ops->update_authorizer)
		ret = ac->ops->update_authorizer(ac, peer_type, a);
	mutex_unlock(&ac->mutex);
	return ret;
}
Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
69
100.00%
2
100.00%
Total
69
100.00%
2
100.00%


EXPORT_SYMBOL(ceph_auth_update_authorizer);



int ceph_auth_verify_authorizer_reply(struct ceph_auth_client *ac,
				      struct ceph_authorizer *a)
{
	int ret = 0;

	mutex_lock(&ac->mutex);
	if (ac->ops && ac->ops->verify_authorizer_reply)
		ret = ac->ops->verify_authorizer_reply(ac, a);
	mutex_unlock(&ac->mutex);
	return ret;
}
Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
64
100.00%
2
100.00%
Total
64
100.00%
2
100.00%


EXPORT_SYMBOL(ceph_auth_verify_authorizer_reply);



void ceph_auth_invalidate_authorizer(struct ceph_auth_client *ac, int peer_type)
{
	mutex_lock(&ac->mutex);
	if (ac->ops && ac->ops->invalidate_authorizer)
		ac->ops->invalidate_authorizer(ac, peer_type);
	mutex_unlock(&ac->mutex);
}
Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
52
100.00%
2
100.00%
Total
52
100.00%
2
100.00%


EXPORT_SYMBOL(ceph_auth_invalidate_authorizer);
Overall Contributors
Person
Tokens
Prop
Commits
CommitProp
Sage Weil
1605
97.51%
10
58.82%
Yehuda Sadeh Weinraub
28
1.70%
3
17.65%
Tommi Virtanen
7
0.43%
1
5.88%
Ilya Dryomov
6
0.36%
3
17.65%
Total
1646
100.00%
17
100.00%
Directory: net/ceph

Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.