libceph: fix socket write error handling
[linux-2.6.git] / net / ceph / auth_none.c
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