diff options
author | Yehuda Sadeh <yehuda@hq.newdream.net> | 2010-04-06 18:14:15 -0400 |
---|---|---|
committer | Sage Weil <sage@newdream.net> | 2010-10-20 18:37:28 -0400 |
commit | 3d14c5d2b6e15c21d8e5467dc62d33127c23a644 (patch) | |
tree | 7d123c47847df9d1e865b6b78dc7da3fe739b704 /net/ceph/auth_none.c | |
parent | ae1533b62b3369e6ae32338f4a77d64d0e88f676 (diff) |
ceph: factor out libceph from Ceph file system
This factors out protocol and low-level storage parts of ceph into a
separate libceph module living in net/ceph and include/linux/ceph. This
is mostly a matter of moving files around. However, a few key pieces
of the interface change as well:
- ceph_client becomes ceph_fs_client and ceph_client, where the latter
captures the mon and osd clients, and the fs_client gets the mds client
and file system specific pieces.
- Mount option parsing and debugfs setup is correspondingly broken into
two pieces.
- The mon client gets a generic handler callback for otherwise unknown
messages (mds map, in this case).
- The basic supported/required feature bits can be expanded (and are by
ceph_fs_client).
No functional change, aside from some subtle error handling cases that got
cleaned up in the refactoring process.
Signed-off-by: Sage Weil <sage@newdream.net>
Diffstat (limited to 'net/ceph/auth_none.c')
-rw-r--r-- | net/ceph/auth_none.c | 132 |
1 files changed, 132 insertions, 0 deletions
diff --git a/net/ceph/auth_none.c b/net/ceph/auth_none.c new file mode 100644 index 00000000000..214c2bb43d6 --- /dev/null +++ b/net/ceph/auth_none.c | |||
@@ -0,0 +1,132 @@ | |||
1 | |||
2 | #include <linux/ceph/ceph_debug.h> | ||
3 | |||
4 | #include <linux/err.h> | ||
5 | #include <linux/module.h> | ||
6 | #include <linux/random.h> | ||
7 | #include <linux/slab.h> | ||
8 | |||
9 | #include <linux/ceph/decode.h> | ||
10 | #include <linux/ceph/auth.h> | ||
11 | |||
12 | #include "auth_none.h" | ||
13 | |||
14 | static void reset(struct ceph_auth_client *ac) | ||
15 | { | ||
16 | struct ceph_auth_none_info *xi = ac->private; | ||
17 | |||
18 | xi->starting = true; | ||
19 | xi->built_authorizer = false; | ||
20 | } | ||
21 | |||
22 | static void destroy(struct ceph_auth_client *ac) | ||
23 | { | ||
24 | kfree(ac->private); | ||
25 | ac->private = NULL; | ||
26 | } | ||
27 | |||
28 | static int is_authenticated(struct ceph_auth_client *ac) | ||
29 | { | ||
30 | struct ceph_auth_none_info *xi = ac->private; | ||
31 | |||
32 | return !xi->starting; | ||
33 | } | ||
34 | |||
35 | static int should_authenticate(struct ceph_auth_client *ac) | ||
36 | { | ||
37 | struct ceph_auth_none_info *xi = ac->private; | ||
38 | |||
39 | return xi->starting; | ||
40 | } | ||
41 | |||
42 | /* | ||
43 | * the generic auth code decode the global_id, and we carry no actual | ||
44 | * authenticate state, so nothing happens here. | ||
45 | */ | ||
46 | static int handle_reply(struct ceph_auth_client *ac, int result, | ||
47 | void *buf, void *end) | ||
48 | { | ||
49 | struct ceph_auth_none_info *xi = ac->private; | ||
50 | |||
51 | xi->starting = false; | ||
52 | return result; | ||
53 | } | ||
54 | |||
55 | /* | ||
56 | * build an 'authorizer' with our entity_name and global_id. we can | ||
57 | * reuse a single static copy since it is identical for all services | ||
58 | * we connect to. | ||
59 | */ | ||
60 | static int ceph_auth_none_create_authorizer( | ||
61 | struct ceph_auth_client *ac, int peer_type, | ||
62 | struct ceph_authorizer **a, | ||
63 | void **buf, size_t *len, | ||
64 | void **reply_buf, size_t *reply_len) | ||
65 | { | ||
66 | struct ceph_auth_none_info *ai = ac->private; | ||
67 | struct ceph_none_authorizer *au = &ai->au; | ||
68 | void *p, *end; | ||
69 | int ret; | ||
70 | |||
71 | if (!ai->built_authorizer) { | ||
72 | p = au->buf; | ||
73 | end = p + sizeof(au->buf); | ||
74 | ceph_encode_8(&p, 1); | ||
75 | ret = ceph_entity_name_encode(ac->name, &p, end - 8); | ||
76 | if (ret < 0) | ||
77 | goto bad; | ||
78 | ceph_decode_need(&p, end, sizeof(u64), bad2); | ||
79 | ceph_encode_64(&p, ac->global_id); | ||
80 | au->buf_len = p - (void *)au->buf; | ||
81 | ai->built_authorizer = true; | ||
82 | dout("built authorizer len %d\n", au->buf_len); | ||
83 | } | ||
84 | |||
85 | *a = (struct ceph_authorizer *)au; | ||
86 | *buf = au->buf; | ||
87 | *len = au->buf_len; | ||
88 | *reply_buf = au->reply_buf; | ||
89 | *reply_len = sizeof(au->reply_buf); | ||
90 | return 0; | ||
91 | |||
92 | bad2: | ||
93 | ret = -ERANGE; | ||
94 | bad: | ||
95 | return ret; | ||
96 | } | ||
97 | |||
98 | static void ceph_auth_none_destroy_authorizer(struct ceph_auth_client *ac, | ||
99 | struct ceph_authorizer *a) | ||
100 | { | ||
101 | /* nothing to do */ | ||
102 | } | ||
103 | |||
104 | static const struct ceph_auth_client_ops ceph_auth_none_ops = { | ||
105 | .name = "none", | ||
106 | .reset = reset, | ||
107 | .destroy = destroy, | ||
108 | .is_authenticated = is_authenticated, | ||
109 | .should_authenticate = should_authenticate, | ||
110 | .handle_reply = handle_reply, | ||
111 | .create_authorizer = ceph_auth_none_create_authorizer, | ||
112 | .destroy_authorizer = ceph_auth_none_destroy_authorizer, | ||
113 | }; | ||
114 | |||
115 | int ceph_auth_none_init(struct ceph_auth_client *ac) | ||
116 | { | ||
117 | struct ceph_auth_none_info *xi; | ||
118 | |||
119 | dout("ceph_auth_none_init %p\n", ac); | ||
120 | xi = kzalloc(sizeof(*xi), GFP_NOFS); | ||
121 | if (!xi) | ||
122 | return -ENOMEM; | ||
123 | |||
124 | xi->starting = true; | ||
125 | xi->built_authorizer = false; | ||
126 | |||
127 | ac->protocol = CEPH_AUTH_NONE; | ||
128 | ac->private = xi; | ||
129 | ac->ops = &ceph_auth_none_ops; | ||
130 | return 0; | ||
131 | } | ||
132 | |||