diff options
author | Alex Elder <elder@inktank.com> | 2012-05-16 16:16:39 -0400 |
---|---|---|
committer | Alex Elder <elder@dreamhost.com> | 2012-05-17 09:18:13 -0400 |
commit | a3530df33eb91d787d08c7383a0a9982690e42d0 (patch) | |
tree | 3022fc82ea661654bfca48fae32a7a1584dba1e8 /net | |
parent | a255651d4cad89f1a606edd36135af892ada4f20 (diff) |
ceph: have get_authorizer methods return pointers
Have the get_authorizer auth_client method return a ceph_auth
pointer rather than an integer, pointer-encoding any returned
error value. This is to pave the way for making use of the
returned value in an upcoming patch.
Signed-off-by: Alex Elder <elder@inktank.com>
Reviewed-by: Sage Weil <sage@inktank.com>
Diffstat (limited to 'net')
-rw-r--r-- | net/ceph/messenger.c | 8 | ||||
-rw-r--r-- | net/ceph/osd_client.c | 19 |
2 files changed, 16 insertions, 11 deletions
diff --git a/net/ceph/messenger.c b/net/ceph/messenger.c index e0532d5b22f5..ac27a2c0694a 100644 --- a/net/ceph/messenger.c +++ b/net/ceph/messenger.c | |||
@@ -658,7 +658,7 @@ static int prepare_connect_authorizer(struct ceph_connection *con) | |||
658 | void *auth_buf; | 658 | void *auth_buf; |
659 | int auth_len; | 659 | int auth_len; |
660 | int auth_protocol; | 660 | int auth_protocol; |
661 | int ret; | 661 | struct ceph_auth_handshake *auth; |
662 | 662 | ||
663 | if (!con->ops->get_authorizer) { | 663 | if (!con->ops->get_authorizer) { |
664 | con->out_connect.authorizer_protocol = CEPH_AUTH_UNKNOWN; | 664 | con->out_connect.authorizer_protocol = CEPH_AUTH_UNKNOWN; |
@@ -674,13 +674,13 @@ static int prepare_connect_authorizer(struct ceph_connection *con) | |||
674 | auth_buf = NULL; | 674 | auth_buf = NULL; |
675 | auth_len = 0; | 675 | auth_len = 0; |
676 | auth_protocol = CEPH_AUTH_UNKNOWN; | 676 | auth_protocol = CEPH_AUTH_UNKNOWN; |
677 | ret = con->ops->get_authorizer(con, &auth_buf, &auth_len, | 677 | auth = con->ops->get_authorizer(con, &auth_buf, &auth_len, |
678 | &auth_protocol, &con->auth_reply_buf, | 678 | &auth_protocol, &con->auth_reply_buf, |
679 | &con->auth_reply_buf_len, con->auth_retry); | 679 | &con->auth_reply_buf_len, con->auth_retry); |
680 | mutex_lock(&con->mutex); | 680 | mutex_lock(&con->mutex); |
681 | 681 | ||
682 | if (ret) | 682 | if (IS_ERR(auth)) |
683 | return ret; | 683 | return PTR_ERR(auth); |
684 | 684 | ||
685 | if (test_bit(CLOSED, &con->state) || test_bit(OPENING, &con->state)) | 685 | if (test_bit(CLOSED, &con->state) || test_bit(OPENING, &con->state)) |
686 | return -EAGAIN; | 686 | return -EAGAIN; |
diff --git a/net/ceph/osd_client.c b/net/ceph/osd_client.c index f640bdf027e7..fa74ae0ea910 100644 --- a/net/ceph/osd_client.c +++ b/net/ceph/osd_client.c | |||
@@ -2108,15 +2108,19 @@ static void put_osd_con(struct ceph_connection *con) | |||
2108 | /* | 2108 | /* |
2109 | * authentication | 2109 | * authentication |
2110 | */ | 2110 | */ |
2111 | static int get_authorizer(struct ceph_connection *con, | 2111 | /* |
2112 | void **buf, int *len, int *proto, | 2112 | * Note: returned pointer is the address of a structure that's |
2113 | void **reply_buf, int *reply_len, int force_new) | 2113 | * managed separately. Caller must *not* attempt to free it. |
2114 | */ | ||
2115 | static struct ceph_auth_handshake *get_authorizer(struct ceph_connection *con, | ||
2116 | void **buf, int *len, int *proto, | ||
2117 | void **reply_buf, int *reply_len, | ||
2118 | int force_new) | ||
2114 | { | 2119 | { |
2115 | struct ceph_osd *o = con->private; | 2120 | struct ceph_osd *o = con->private; |
2116 | struct ceph_osd_client *osdc = o->o_osdc; | 2121 | struct ceph_osd_client *osdc = o->o_osdc; |
2117 | struct ceph_auth_client *ac = osdc->client->monc.auth; | 2122 | struct ceph_auth_client *ac = osdc->client->monc.auth; |
2118 | struct ceph_auth_handshake *auth = &o->o_auth; | 2123 | struct ceph_auth_handshake *auth = &o->o_auth; |
2119 | int ret = 0; | ||
2120 | 2124 | ||
2121 | if (force_new && auth->authorizer) { | 2125 | if (force_new && auth->authorizer) { |
2122 | if (ac->ops && ac->ops->destroy_authorizer) | 2126 | if (ac->ops && ac->ops->destroy_authorizer) |
@@ -2124,9 +2128,10 @@ static int get_authorizer(struct ceph_connection *con, | |||
2124 | auth->authorizer = NULL; | 2128 | auth->authorizer = NULL; |
2125 | } | 2129 | } |
2126 | if (!auth->authorizer && ac->ops && ac->ops->create_authorizer) { | 2130 | if (!auth->authorizer && ac->ops && ac->ops->create_authorizer) { |
2127 | ret = ac->ops->create_authorizer(ac, CEPH_ENTITY_TYPE_OSD, auth); | 2131 | int ret = ac->ops->create_authorizer(ac, CEPH_ENTITY_TYPE_OSD, |
2132 | auth); | ||
2128 | if (ret) | 2133 | if (ret) |
2129 | return ret; | 2134 | return ERR_PTR(ret); |
2130 | } | 2135 | } |
2131 | 2136 | ||
2132 | *proto = ac->protocol; | 2137 | *proto = ac->protocol; |
@@ -2135,7 +2140,7 @@ static int get_authorizer(struct ceph_connection *con, | |||
2135 | *reply_buf = auth->authorizer_reply_buf; | 2140 | *reply_buf = auth->authorizer_reply_buf; |
2136 | *reply_len = auth->authorizer_reply_buf_len; | 2141 | *reply_len = auth->authorizer_reply_buf_len; |
2137 | 2142 | ||
2138 | return 0; | 2143 | return auth; |
2139 | } | 2144 | } |
2140 | 2145 | ||
2141 | 2146 | ||