
kadm5_get_principals() is not online. If you have... many principals, it will be slow. At least it's no longer quadratic, but it, it's still slow. Time to add a version that uses a callback: kadm5_ret_t kadm5_iter_principals(void *server_handle, const char *expression, int (*cb)(void *, const char *), void *cbdata) The callback gets called with the given callback data and one principal name (unparsed). Note that the callback MUST NOT re-enter the kadm5 library with the *same* kadm handle. For example, the kadmin protocol doesn't really multiplex requests well, though it could pipeline them, but it can't pipeline when LIST is running, not with the protocol implemented here, so a separate connection is needed, and that requires a separate kadm handle. We add kadm5_dup_context() to deal with this.
918 lines
23 KiB
C
918 lines
23 KiB
C
/*
|
||
* Copyright (c) 1997 - 2006 Kungliga Tekniska Högskolan
|
||
* (Royal Institute of Technology, Stockholm, Sweden).
|
||
* All rights reserved.
|
||
*
|
||
* Redistribution and use in source and binary forms, with or without
|
||
* modification, are permitted provided that the following conditions
|
||
* are met:
|
||
*
|
||
* 1. Redistributions of source code must retain the above copyright
|
||
* notice, this list of conditions and the following disclaimer.
|
||
*
|
||
* 2. Redistributions in binary form must reproduce the above copyright
|
||
* notice, this list of conditions and the following disclaimer in the
|
||
* documentation and/or other materials provided with the distribution.
|
||
*
|
||
* 3. Neither the name of the Institute nor the names of its contributors
|
||
* may be used to endorse or promote products derived from this software
|
||
* without specific prior written permission.
|
||
*
|
||
* THIS SOFTWARE IS PROVIDED BY THE INSTITUTE AND CONTRIBUTORS ``AS IS'' AND
|
||
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
||
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
||
* ARE DISCLAIMED. IN NO EVENT SHALL THE INSTITUTE OR CONTRIBUTORS BE LIABLE
|
||
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
|
||
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
|
||
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
|
||
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
|
||
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
|
||
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
|
||
* SUCH DAMAGE.
|
||
*/
|
||
|
||
#include "kadm5_locl.h"
|
||
#include <sys/types.h>
|
||
#ifdef HAVE_SYS_SOCKET_H
|
||
#include <sys/socket.h>
|
||
#endif
|
||
#ifdef HAVE_NETINET_IN_H
|
||
#include <netinet/in.h>
|
||
#endif
|
||
#ifdef HAVE_NETDB_H
|
||
#include <netdb.h>
|
||
#endif
|
||
|
||
RCSID("$Id$");
|
||
|
||
static kadm5_ret_t
|
||
kadm5_c_lock(void *server_handle)
|
||
{
|
||
return ENOTSUP;
|
||
}
|
||
|
||
static kadm5_ret_t
|
||
kadm5_c_unlock(void *server_handle)
|
||
{
|
||
return ENOTSUP;
|
||
}
|
||
|
||
static void
|
||
set_funcs(kadm5_client_context *c)
|
||
{
|
||
#define SET(C, F) (C)->funcs.F = kadm5 ## _c_ ## F
|
||
#define SETNOTIMP(C, F) (C)->funcs.F = 0
|
||
SET(c, chpass_principal);
|
||
SET(c, chpass_principal_with_key);
|
||
SET(c, create_principal);
|
||
SET(c, delete_principal);
|
||
SET(c, destroy);
|
||
SET(c, flush);
|
||
SET(c, get_principal);
|
||
SET(c, get_principals);
|
||
SET(c, get_privs);
|
||
SET(c, modify_principal);
|
||
SET(c, prune_principal);
|
||
SET(c, randkey_principal);
|
||
SET(c, rename_principal);
|
||
SET(c, lock);
|
||
SET(c, unlock);
|
||
SETNOTIMP(c, setkey_principal_3);
|
||
SET(c, iter_principals);
|
||
SET(c, dup_context);
|
||
}
|
||
|
||
kadm5_ret_t
|
||
_kadm5_c_init_context(kadm5_client_context **ctx,
|
||
kadm5_config_params *params,
|
||
krb5_context context)
|
||
{
|
||
krb5_error_code ret;
|
||
char *colon;
|
||
|
||
*ctx = malloc(sizeof(**ctx));
|
||
if (*ctx == NULL)
|
||
return krb5_enomem(context);
|
||
memset(*ctx, 0, sizeof(**ctx));
|
||
krb5_add_et_list(context, initialize_kadm5_error_table_r);
|
||
set_funcs(*ctx);
|
||
(*ctx)->context = context;
|
||
if (params->mask & KADM5_CONFIG_REALM) {
|
||
ret = 0;
|
||
(*ctx)->realm = strdup(params->realm);
|
||
if ((*ctx)->realm == NULL)
|
||
ret = krb5_enomem(context);
|
||
} else
|
||
ret = krb5_get_default_realm((*ctx)->context, &(*ctx)->realm);
|
||
if (ret) {
|
||
free(*ctx);
|
||
return ret;
|
||
}
|
||
|
||
/*
|
||
* FIXME: If we have a hostlist, we should use the hostlist so that if we
|
||
* can't reach one server we try another.
|
||
*/
|
||
if (params->mask & KADM5_CONFIG_ADMIN_SERVER)
|
||
(*ctx)->admin_server = strdup(params->admin_server);
|
||
else {
|
||
char **hostlist;
|
||
|
||
ret = krb5_get_krb_admin_hst(context, &(*ctx)->realm, &hostlist);
|
||
if (ret) {
|
||
free((*ctx)->realm);
|
||
free(*ctx);
|
||
return ret;
|
||
}
|
||
(*ctx)->admin_server = strdup(*hostlist);
|
||
krb5_free_krbhst(context, hostlist);
|
||
}
|
||
|
||
if ((*ctx)->admin_server == NULL) {
|
||
free((*ctx)->realm);
|
||
free(*ctx);
|
||
return krb5_enomem(context);
|
||
}
|
||
colon = strchr((*ctx)->admin_server, ':');
|
||
if (colon != NULL)
|
||
*colon++ = '\0';
|
||
|
||
(*ctx)->kadmind_port = 0;
|
||
|
||
if (params->mask & KADM5_CONFIG_KADMIND_PORT)
|
||
(*ctx)->kadmind_port = params->kadmind_port;
|
||
else if (colon != NULL) {
|
||
char *end;
|
||
|
||
(*ctx)->kadmind_port = htons(strtol(colon, &end, 0));
|
||
}
|
||
if ((*ctx)->kadmind_port == 0)
|
||
(*ctx)->kadmind_port = krb5_getportbyname(context, "kerberos-adm",
|
||
"tcp", 749);
|
||
|
||
if (params->mask & KADM5_CONFIG_READONLY_ADMIN_SERVER) {
|
||
(*ctx)->readonly_admin_server = strdup(params->readonly_admin_server);
|
||
if ((*ctx)->readonly_admin_server == NULL) {
|
||
free((*ctx)->realm);
|
||
free(*ctx);
|
||
return krb5_enomem(context);
|
||
}
|
||
} else {
|
||
char **hostlist;
|
||
|
||
ret = krb5_get_krb_readonly_admin_hst(context, &(*ctx)->realm,
|
||
&hostlist);
|
||
if (ret == 0) {
|
||
(*ctx)->readonly_admin_server = strdup(*hostlist);
|
||
krb5_free_krbhst(context, hostlist);
|
||
if ((*ctx)->readonly_admin_server == NULL) {
|
||
free((*ctx)->realm);
|
||
free(*ctx);
|
||
return krb5_enomem(context);
|
||
}
|
||
}
|
||
}
|
||
if ((*ctx)->readonly_admin_server) {
|
||
colon = strchr((*ctx)->readonly_admin_server, ':');
|
||
if (colon != NULL)
|
||
*colon++ = '\0';
|
||
|
||
} else {
|
||
colon = NULL;
|
||
}
|
||
|
||
(*ctx)->readonly_kadmind_port = 0;
|
||
if (params->mask & KADM5_CONFIG_READONLY_KADMIN_PORT)
|
||
(*ctx)->readonly_kadmind_port = params->readonly_kadmind_port;
|
||
else if (colon != NULL) {
|
||
char *end;
|
||
|
||
(*ctx)->readonly_kadmind_port = htons(strtol(colon, &end, 0));
|
||
}
|
||
if ((*ctx)->readonly_kadmind_port == 0)
|
||
(*ctx)->readonly_kadmind_port = (*ctx)->kadmind_port;
|
||
return 0;
|
||
}
|
||
|
||
kadm5_ret_t
|
||
kadm5_c_dup_context(void *vin, void **out)
|
||
{
|
||
krb5_error_code ret;
|
||
kadm5_client_context *in = vin;
|
||
krb5_context context = in->context;
|
||
kadm5_client_context *ctx;
|
||
|
||
*out = NULL;
|
||
ctx = malloc(sizeof(*ctx));
|
||
if (ctx == NULL)
|
||
return krb5_enomem(in->context);
|
||
|
||
|
||
memset(ctx, 0, sizeof(*ctx));
|
||
set_funcs(ctx);
|
||
ctx->readonly_kadmind_port = in->readonly_kadmind_port;
|
||
ctx->kadmind_port = in->kadmind_port;
|
||
|
||
ret = krb5_copy_context(context, &(ctx->context));
|
||
if (ret == 0)
|
||
ret = krb5_add_et_list(ctx->context, initialize_kadm5_error_table_r);
|
||
if (ret == 0 && (ctx->realm = strdup(in->realm)) == NULL)
|
||
ret = krb5_enomem(context);
|
||
if (ret == 0 &&
|
||
(ctx->admin_server = strdup(in->admin_server)) == NULL)
|
||
ret = krb5_enomem(context);
|
||
if (in->readonly_admin_server &&
|
||
(ctx->readonly_admin_server = strdup(in->readonly_admin_server)) == NULL)
|
||
ret = krb5_enomem(context);
|
||
if (in->keytab && (ctx->keytab = strdup(in->keytab)) == NULL)
|
||
ret = krb5_enomem(context);
|
||
if (in->ccache) {
|
||
char *fullname = NULL;
|
||
|
||
ret = krb5_cc_get_full_name(context, in->ccache, &fullname);
|
||
if (ret == 0)
|
||
ret = krb5_cc_resolve(context, fullname, &ctx->ccache);
|
||
free(fullname);
|
||
}
|
||
if (ret == 0)
|
||
*out = ctx;
|
||
else
|
||
kadm5_c_destroy(ctx);
|
||
return ret;
|
||
}
|
||
|
||
static krb5_error_code
|
||
get_kadm_ticket(krb5_context context,
|
||
krb5_ccache id,
|
||
krb5_principal client,
|
||
const char *server_name)
|
||
{
|
||
krb5_error_code ret;
|
||
krb5_creds in, *out;
|
||
|
||
memset(&in, 0, sizeof(in));
|
||
in.client = client;
|
||
ret = krb5_parse_name(context, server_name, &in.server);
|
||
if(ret)
|
||
return ret;
|
||
ret = krb5_get_credentials(context, 0, id, &in, &out);
|
||
if(ret == 0)
|
||
krb5_free_creds(context, out);
|
||
krb5_free_principal(context, in.server);
|
||
return ret;
|
||
}
|
||
|
||
static krb5_error_code
|
||
get_new_cache(krb5_context context,
|
||
krb5_principal client,
|
||
const char *password,
|
||
krb5_prompter_fct prompter,
|
||
const char *keytab,
|
||
const char *server_name,
|
||
krb5_ccache *ret_cache)
|
||
{
|
||
krb5_error_code ret;
|
||
krb5_creds cred;
|
||
krb5_get_init_creds_opt *opt;
|
||
krb5_ccache id;
|
||
|
||
ret = krb5_get_init_creds_opt_alloc (context, &opt);
|
||
if (ret)
|
||
return ret;
|
||
|
||
krb5_get_init_creds_opt_set_default_flags(context, "kadmin",
|
||
krb5_principal_get_realm(context,
|
||
client),
|
||
opt);
|
||
|
||
|
||
krb5_get_init_creds_opt_set_forwardable (opt, FALSE);
|
||
krb5_get_init_creds_opt_set_proxiable (opt, FALSE);
|
||
|
||
if(password == NULL && prompter == NULL) {
|
||
krb5_keytab kt;
|
||
if(keytab == NULL)
|
||
ret = krb5_kt_default(context, &kt);
|
||
else
|
||
ret = krb5_kt_resolve(context, keytab, &kt);
|
||
if(ret) {
|
||
krb5_get_init_creds_opt_free(context, opt);
|
||
return ret;
|
||
}
|
||
ret = krb5_get_init_creds_keytab (context,
|
||
&cred,
|
||
client,
|
||
kt,
|
||
0,
|
||
server_name,
|
||
opt);
|
||
krb5_kt_close(context, kt);
|
||
} else {
|
||
ret = krb5_get_init_creds_password (context,
|
||
&cred,
|
||
client,
|
||
password,
|
||
prompter,
|
||
NULL,
|
||
0,
|
||
server_name,
|
||
opt);
|
||
}
|
||
krb5_get_init_creds_opt_free(context, opt);
|
||
switch(ret){
|
||
case 0:
|
||
break;
|
||
case KRB5_LIBOS_PWDINTR: /* don't print anything if it was just C-c:ed */
|
||
case KRB5KRB_AP_ERR_BAD_INTEGRITY:
|
||
case KRB5KRB_AP_ERR_MODIFIED:
|
||
return KADM5_BAD_PASSWORD;
|
||
default:
|
||
return ret;
|
||
}
|
||
ret = krb5_cc_new_unique(context, krb5_cc_type_memory, NULL, &id);
|
||
if(ret)
|
||
return ret;
|
||
ret = krb5_cc_initialize (context, id, cred.client);
|
||
if (ret)
|
||
return ret;
|
||
ret = krb5_cc_store_cred (context, id, &cred);
|
||
if (ret)
|
||
return ret;
|
||
krb5_free_cred_contents (context, &cred);
|
||
*ret_cache = id;
|
||
return 0;
|
||
}
|
||
|
||
/*
|
||
* Check the credential cache `id´ to figure out what principal to use
|
||
* when talking to the kadmind. If there is a initial kadmin/admin@
|
||
* credential in the cache, use that client principal. Otherwise, use
|
||
* the client principals first component and add /admin to the
|
||
* principal.
|
||
*/
|
||
|
||
static krb5_error_code
|
||
get_cache_principal(krb5_context context,
|
||
krb5_ccache *id,
|
||
krb5_principal *client)
|
||
{
|
||
krb5_error_code ret;
|
||
const char *name, *inst;
|
||
krb5_principal p1, p2;
|
||
|
||
ret = krb5_cc_default(context, id);
|
||
if(ret) {
|
||
*id = NULL;
|
||
return ret;
|
||
}
|
||
|
||
ret = krb5_cc_get_principal(context, *id, &p1);
|
||
if(ret) {
|
||
krb5_cc_close(context, *id);
|
||
*id = NULL;
|
||
return ret;
|
||
}
|
||
|
||
ret = krb5_make_principal(context, &p2, NULL,
|
||
"kadmin", "admin", NULL);
|
||
if (ret) {
|
||
krb5_cc_close(context, *id);
|
||
*id = NULL;
|
||
krb5_free_principal(context, p1);
|
||
return ret;
|
||
}
|
||
|
||
{
|
||
krb5_creds in, *out;
|
||
krb5_kdc_flags flags;
|
||
|
||
flags.i = 0;
|
||
memset(&in, 0, sizeof(in));
|
||
|
||
in.client = p1;
|
||
in.server = p2;
|
||
|
||
/* check for initial ticket kadmin/admin */
|
||
ret = krb5_get_credentials_with_flags(context, KRB5_GC_CACHED, flags,
|
||
*id, &in, &out);
|
||
krb5_free_principal(context, p2);
|
||
if (ret == 0) {
|
||
if (out->flags.b.initial) {
|
||
*client = p1;
|
||
krb5_free_creds(context, out);
|
||
return 0;
|
||
}
|
||
krb5_free_creds(context, out);
|
||
}
|
||
}
|
||
krb5_cc_close(context, *id);
|
||
*id = NULL;
|
||
|
||
name = krb5_principal_get_comp_string(context, p1, 0);
|
||
inst = krb5_principal_get_comp_string(context, p1, 1);
|
||
if(inst == NULL || strcmp(inst, "admin") != 0) {
|
||
ret = krb5_make_principal(context, &p2, NULL, name, "admin", NULL);
|
||
krb5_free_principal(context, p1);
|
||
if(ret != 0)
|
||
return ret;
|
||
|
||
*client = p2;
|
||
return 0;
|
||
}
|
||
|
||
*client = p1;
|
||
|
||
return 0;
|
||
}
|
||
|
||
krb5_error_code
|
||
_kadm5_c_get_cred_cache(krb5_context context,
|
||
const char *client_name,
|
||
const char *server_name,
|
||
const char *password,
|
||
krb5_prompter_fct prompter,
|
||
const char *keytab,
|
||
krb5_ccache ccache,
|
||
krb5_ccache *ret_cache)
|
||
{
|
||
krb5_error_code ret;
|
||
krb5_ccache id = NULL;
|
||
krb5_principal default_client = NULL, client = NULL;
|
||
|
||
/* treat empty password as NULL */
|
||
if(password && *password == '\0')
|
||
password = NULL;
|
||
if(server_name == NULL)
|
||
server_name = KADM5_ADMIN_SERVICE;
|
||
|
||
if(client_name != NULL) {
|
||
ret = krb5_parse_name(context, client_name, &client);
|
||
if(ret)
|
||
return ret;
|
||
}
|
||
|
||
if(ccache != NULL) {
|
||
id = ccache;
|
||
ret = krb5_cc_get_principal(context, id, &client);
|
||
if(ret)
|
||
return ret;
|
||
} else {
|
||
/* get principal from default cache, ok if this doesn't work */
|
||
|
||
ret = get_cache_principal(context, &id, &default_client);
|
||
if (ret) {
|
||
/*
|
||
* No client was specified by the caller and we cannot
|
||
* determine the client from a credentials cache.
|
||
*/
|
||
char userbuf[128];
|
||
const char *user = NULL;
|
||
|
||
#ifndef WIN32
|
||
if (geteuid() == 0)
|
||
user = roken_get_loginname(userbuf, sizeof(userbuf));
|
||
#endif
|
||
if (user == NULL)
|
||
user = roken_get_username(userbuf, sizeof(userbuf));
|
||
if (user == NULL) {
|
||
krb5_set_error_message(context, KADM5_FAILURE, "Unable to find local user name");
|
||
krb5_free_principal(context, client);
|
||
return KADM5_FAILURE;
|
||
}
|
||
ret = krb5_make_principal(context, &default_client,
|
||
NULL, user, "admin", NULL);
|
||
if (ret) {
|
||
krb5_free_principal(context, client);
|
||
return ret;
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
/*
|
||
* No client was specified by the caller, but we have a client
|
||
* from the default credentials cache.
|
||
*/
|
||
if (client == NULL && default_client != NULL)
|
||
client = default_client;
|
||
|
||
|
||
if(id && client && (default_client == NULL ||
|
||
krb5_principal_compare(context, client, default_client) != 0)) {
|
||
ret = get_kadm_ticket(context, id, client, server_name);
|
||
if(ret == 0) {
|
||
*ret_cache = id;
|
||
krb5_free_principal(context, default_client);
|
||
if (default_client != client)
|
||
krb5_free_principal(context, client);
|
||
return 0;
|
||
}
|
||
if(ccache != NULL)
|
||
/* couldn't get ticket from cache */
|
||
return -1;
|
||
}
|
||
/* get creds via AS request */
|
||
if(id && (id != ccache))
|
||
krb5_cc_close(context, id);
|
||
if (client != default_client)
|
||
krb5_free_principal(context, default_client);
|
||
|
||
ret = get_new_cache(context, client, password, prompter, keytab,
|
||
server_name, ret_cache);
|
||
krb5_free_principal(context, client);
|
||
return ret;
|
||
}
|
||
|
||
static kadm5_ret_t
|
||
kadm_connect(kadm5_client_context *ctx)
|
||
{
|
||
kadm5_ret_t ret;
|
||
krb5_principal server = NULL;
|
||
krb5_ccache cc = NULL;
|
||
rk_socket_t s = rk_INVALID_SOCKET;
|
||
struct addrinfo *ai, *a;
|
||
struct addrinfo hints;
|
||
int free_ai = 0;
|
||
int error;
|
||
int kadmin_port = 0;
|
||
const char *admin_server = NULL;
|
||
char portstr[NI_MAXSERV];
|
||
const char *hostname, *slash;
|
||
char *service_name = NULL;
|
||
krb5_context context = ctx->context;
|
||
int writable = 0;
|
||
|
||
if (ctx->ac)
|
||
krb5_auth_con_free(context, ctx->ac);
|
||
ctx->ac = NULL;
|
||
|
||
if (!ctx->want_write) {
|
||
admin_server = ctx->readonly_admin_server;
|
||
kadmin_port = ctx->readonly_kadmind_port;
|
||
}
|
||
if (admin_server == NULL) {
|
||
admin_server = ctx->admin_server;
|
||
writable = 1;
|
||
}
|
||
if (kadmin_port < 1)
|
||
kadmin_port = ctx->kadmind_port;
|
||
|
||
memset(&hints, 0, sizeof(hints));
|
||
hints.ai_socktype = SOCK_STREAM;
|
||
hints.ai_protocol = IPPROTO_TCP;
|
||
|
||
snprintf(portstr, sizeof(portstr), "%u", ntohs(kadmin_port));
|
||
|
||
hostname = admin_server;
|
||
slash = strchr(hostname, '/');
|
||
if (slash != NULL)
|
||
hostname = slash + 1;
|
||
|
||
error = getaddrinfo(hostname, portstr, &hints, &ai);
|
||
if (error) {
|
||
ret = KADM5_BAD_SERVER_NAME;
|
||
goto out;
|
||
}
|
||
|
||
free_ai = 1;
|
||
for (a = ai; a != NULL; a = a->ai_next) {
|
||
s = socket(a->ai_family, a->ai_socktype, a->ai_protocol);
|
||
if (s < 0)
|
||
continue;
|
||
if (connect(s, a->ai_addr, a->ai_addrlen) < 0) {
|
||
krb5_warn(context, errno, "connect(%s)", hostname);
|
||
rk_closesocket(s);
|
||
s = rk_INVALID_SOCKET;
|
||
continue;
|
||
}
|
||
break;
|
||
}
|
||
if (a == NULL) {
|
||
krb5_set_error_message(context, ret = KADM5_FAILURE,
|
||
"failed to contact %s", hostname);
|
||
goto out;
|
||
}
|
||
ret = _kadm5_c_get_cred_cache(context,
|
||
ctx->client_name,
|
||
ctx->service_name,
|
||
NULL, ctx->prompter, ctx->keytab,
|
||
ctx->ccache, &cc);
|
||
if (ret)
|
||
goto out;
|
||
|
||
if (ctx->realm)
|
||
error = asprintf(&service_name, "%s@%s", KADM5_ADMIN_SERVICE,
|
||
ctx->realm);
|
||
else
|
||
error = asprintf(&service_name, "%s", KADM5_ADMIN_SERVICE);
|
||
|
||
if (error == -1 || service_name == NULL) {
|
||
ret = krb5_enomem(context);
|
||
goto out;
|
||
}
|
||
|
||
ret = krb5_parse_name(context, service_name, &server);
|
||
if (ret)
|
||
goto out;
|
||
|
||
ret = krb5_sendauth(context, &ctx->ac, &s,
|
||
KADMIN_APPL_VERSION, NULL,
|
||
server, AP_OPTS_MUTUAL_REQUIRED,
|
||
NULL, NULL, cc, NULL, NULL, NULL);
|
||
if (ret == 0) {
|
||
krb5_data params;
|
||
kadm5_config_params p;
|
||
memset(&p, 0, sizeof(p));
|
||
if(ctx->realm) {
|
||
p.mask |= KADM5_CONFIG_REALM;
|
||
p.realm = ctx->realm;
|
||
}
|
||
ret = _kadm5_marshal_params(context, &p, ¶ms);
|
||
if (ret == 0) {
|
||
ret = krb5_write_priv_message(context, ctx->ac, &s, ¶ms);
|
||
krb5_data_free(¶ms);
|
||
}
|
||
}
|
||
|
||
if (ret == 0) {
|
||
ctx->sock = s;
|
||
ctx->connected_to_writable = !!writable;
|
||
}
|
||
|
||
out:
|
||
free(service_name);
|
||
krb5_cc_close(context, cc);
|
||
krb5_free_principal(context, server);
|
||
if (free_ai)
|
||
freeaddrinfo(ai);
|
||
if (ret) {
|
||
if (s != rk_INVALID_SOCKET)
|
||
rk_closesocket(s);
|
||
krb5_auth_con_free(context, ctx->ac);
|
||
ctx->ac = NULL;
|
||
}
|
||
return ret;
|
||
}
|
||
|
||
kadm5_ret_t
|
||
_kadm5_connect(void *handle, int want_write)
|
||
{
|
||
kadm5_client_context *ctx = handle;
|
||
|
||
/*
|
||
* Reconnect? Note that we don't reconnect to read-only kadmin servers if
|
||
* we're already connected to a writable kadmin server because we sometimes
|
||
* get a principal record after writing it. We really need the application
|
||
* upstairs to tell us when to stop hogging writable kadmin servers.
|
||
*
|
||
* FIXME: Add an API for marking a kadm5_client_context as not needing to
|
||
* connect to writable kadmin servers.
|
||
*/
|
||
ctx->want_write = !!want_write;
|
||
if (ctx->sock != rk_INVALID_SOCKET && want_write &&
|
||
!ctx->connected_to_writable) {
|
||
rk_closesocket(ctx->sock);
|
||
ctx->sock = rk_INVALID_SOCKET;
|
||
}
|
||
if (ctx->sock == rk_INVALID_SOCKET)
|
||
return kadm_connect(ctx);
|
||
return 0;
|
||
}
|
||
|
||
static kadm5_ret_t
|
||
kadm5_c_init_with_context(krb5_context context,
|
||
const char *client_name,
|
||
const char *password,
|
||
krb5_prompter_fct prompter,
|
||
const char *keytab,
|
||
krb5_ccache ccache,
|
||
const char *service_name,
|
||
kadm5_config_params *realm_params,
|
||
unsigned long struct_version,
|
||
unsigned long api_version,
|
||
void **server_handle)
|
||
{
|
||
kadm5_ret_t ret;
|
||
kadm5_client_context *ctx = NULL;
|
||
krb5_ccache cc;
|
||
|
||
ret = _kadm5_c_init_context(&ctx, realm_params, context);
|
||
if (ret)
|
||
return ret;
|
||
|
||
if (password != NULL && *password != '\0') {
|
||
ret = _kadm5_c_get_cred_cache(context,
|
||
client_name,
|
||
service_name,
|
||
password, prompter, keytab, ccache, &cc);
|
||
if (ret) {
|
||
kadm5_c_destroy(ctx);
|
||
return ret;
|
||
}
|
||
ccache = cc;
|
||
}
|
||
|
||
|
||
if (client_name != NULL)
|
||
ctx->client_name = strdup(client_name);
|
||
else
|
||
ctx->client_name = NULL;
|
||
if (service_name != NULL)
|
||
ctx->service_name = strdup(service_name);
|
||
else
|
||
ctx->service_name = NULL;
|
||
ctx->prompter = prompter;
|
||
ctx->keytab = keytab;
|
||
ctx->ccache = ccache;
|
||
/* maybe we should copy the params here */
|
||
ctx->sock = -1;
|
||
|
||
*server_handle = ctx;
|
||
return 0;
|
||
}
|
||
|
||
static kadm5_ret_t
|
||
init_context(const char *client_name,
|
||
const char *password,
|
||
krb5_prompter_fct prompter,
|
||
const char *keytab,
|
||
krb5_ccache ccache,
|
||
const char *service_name,
|
||
kadm5_config_params *realm_params,
|
||
unsigned long struct_version,
|
||
unsigned long api_version,
|
||
void **server_handle)
|
||
{
|
||
krb5_context context;
|
||
kadm5_ret_t ret;
|
||
kadm5_server_context *ctx;
|
||
|
||
ret = krb5_init_context(&context);
|
||
if (ret)
|
||
return ret;
|
||
ret = kadm5_c_init_with_context(context,
|
||
client_name,
|
||
password,
|
||
prompter,
|
||
keytab,
|
||
ccache,
|
||
service_name,
|
||
realm_params,
|
||
struct_version,
|
||
api_version,
|
||
server_handle);
|
||
if(ret){
|
||
krb5_free_context(context);
|
||
return ret;
|
||
}
|
||
ctx = *server_handle;
|
||
ctx->my_context = 1;
|
||
return 0;
|
||
}
|
||
|
||
kadm5_ret_t
|
||
kadm5_c_init_with_password_ctx(krb5_context context,
|
||
const char *client_name,
|
||
const char *password,
|
||
const char *service_name,
|
||
kadm5_config_params *realm_params,
|
||
unsigned long struct_version,
|
||
unsigned long api_version,
|
||
void **server_handle)
|
||
{
|
||
return kadm5_c_init_with_context(context,
|
||
client_name,
|
||
password,
|
||
krb5_prompter_posix,
|
||
NULL,
|
||
NULL,
|
||
service_name,
|
||
realm_params,
|
||
struct_version,
|
||
api_version,
|
||
server_handle);
|
||
}
|
||
|
||
kadm5_ret_t
|
||
kadm5_c_init_with_password(const char *client_name,
|
||
const char *password,
|
||
const char *service_name,
|
||
kadm5_config_params *realm_params,
|
||
unsigned long struct_version,
|
||
unsigned long api_version,
|
||
void **server_handle)
|
||
{
|
||
return init_context(client_name,
|
||
password,
|
||
krb5_prompter_posix,
|
||
NULL,
|
||
NULL,
|
||
service_name,
|
||
realm_params,
|
||
struct_version,
|
||
api_version,
|
||
server_handle);
|
||
}
|
||
|
||
kadm5_ret_t
|
||
kadm5_c_init_with_skey_ctx(krb5_context context,
|
||
const char *client_name,
|
||
const char *keytab,
|
||
const char *service_name,
|
||
kadm5_config_params *realm_params,
|
||
unsigned long struct_version,
|
||
unsigned long api_version,
|
||
void **server_handle)
|
||
{
|
||
return kadm5_c_init_with_context(context,
|
||
client_name,
|
||
NULL,
|
||
NULL,
|
||
keytab,
|
||
NULL,
|
||
service_name,
|
||
realm_params,
|
||
struct_version,
|
||
api_version,
|
||
server_handle);
|
||
}
|
||
|
||
|
||
kadm5_ret_t
|
||
kadm5_c_init_with_skey(const char *client_name,
|
||
const char *keytab,
|
||
const char *service_name,
|
||
kadm5_config_params *realm_params,
|
||
unsigned long struct_version,
|
||
unsigned long api_version,
|
||
void **server_handle)
|
||
{
|
||
return init_context(client_name,
|
||
NULL,
|
||
NULL,
|
||
keytab,
|
||
NULL,
|
||
service_name,
|
||
realm_params,
|
||
struct_version,
|
||
api_version,
|
||
server_handle);
|
||
}
|
||
|
||
kadm5_ret_t
|
||
kadm5_c_init_with_creds_ctx(krb5_context context,
|
||
const char *client_name,
|
||
krb5_ccache ccache,
|
||
const char *service_name,
|
||
kadm5_config_params *realm_params,
|
||
unsigned long struct_version,
|
||
unsigned long api_version,
|
||
void **server_handle)
|
||
{
|
||
return kadm5_c_init_with_context(context,
|
||
client_name,
|
||
NULL,
|
||
NULL,
|
||
NULL,
|
||
ccache,
|
||
service_name,
|
||
realm_params,
|
||
struct_version,
|
||
api_version,
|
||
server_handle);
|
||
}
|
||
|
||
kadm5_ret_t
|
||
kadm5_c_init_with_creds(const char *client_name,
|
||
krb5_ccache ccache,
|
||
const char *service_name,
|
||
kadm5_config_params *realm_params,
|
||
unsigned long struct_version,
|
||
unsigned long api_version,
|
||
void **server_handle)
|
||
{
|
||
return init_context(client_name,
|
||
NULL,
|
||
NULL,
|
||
NULL,
|
||
ccache,
|
||
service_name,
|
||
realm_params,
|
||
struct_version,
|
||
api_version,
|
||
server_handle);
|
||
}
|
||
|
||
#if 0
|
||
kadm5_ret_t
|
||
kadm5_init(char *client_name, char *pass,
|
||
char *service_name,
|
||
kadm5_config_params *realm_params,
|
||
unsigned long struct_version,
|
||
unsigned long api_version,
|
||
void **server_handle)
|
||
{
|
||
}
|
||
#endif
|
||
|