8158 Want named threads API

[unleashed.git] / usr / src / cmd / ldapcachemgr / cachemgr_discovery.c

/*
 * CDDL HEADER START
 *
 * The contents of this file are subject to the terms of the
 * Common Development and Distribution License (the "License").
 * You may not use this file except in compliance with the License.
 *
 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
 * or http://www.opensolaris.org/os/licensing.
 * See the License for the specific language governing permissions
 * and limitations under the License.
 *
 * When distributing Covered Code, include this CDDL HEADER in each
 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
 * If applicable, add the following below this CDDL HEADER, with the
 * fields enclosed by brackets "[]" replaced with your own identifying
 * information: Portions Copyright [yyyy] [name of copyright owner]
 *
 * CDDL HEADER END
 */
/*
 * Copyright 2009 Sun Microsystems, Inc.  All rights reserved.
 * Use is subject to license terms.
 *
 * Copyright 2018 Joyent, Inc.
 */

#ifdef SLP

/*
 * This file contains all the dynamic server discovery functionality
 * for ldap_cachemgr. SLP is used to query the network for any changes
 * in the set of deployed LDAP servers.
 *
 * The algorithm used is outlined here:
 *
 *   1. Find all naming contexts with SLPFindAttrs. (See
 *      find_all_contexts())
 *   2. For each context, find all servers which serve that context
 *      with SLPFindSrvs. (See foreach_context())
 *   3. For each server, retrieve that server's attributes with
 *      SLPFindAttributes. (See foreach_server())
 *   4. Aggregate the servers' attributes into a config object. There
 *      is one config object associated with each context found in
 *      step 1. (See aggregate_attrs())
 *   5. Update the global config cache for each found context and its
 *      associated servers and attributes. (See update_config())
 *
 * The entry point for ldap_cachemgr is discover(). The actual entry
 * point into the discovery routine is find_all_contexts(); the
 * code thereafter is actually not specific to LDAP, and could also
 * be used to discover YP, or any other server which conforms
 * to the SLP Naming and Directory abstract service type.
 *
 * find_all_attributes() takes as parameters three callback routines
 * which are used to report all information back to the caller. The
 * signatures and synopses of these routines are:
 *
 * void *get_cfghandle(const char *domain);
 *
 *   Returns an opaque handle to a configuration object specific
 *   to the 'domain' parameter. 'domain' will be a naming context
 *   string, i.e. foo.bar.sun.com ( i.e. a secure-RPC domain-
 *   name).
 *
 * void aggregate(void *handle, const char *tag, const char *value);
 *
 *   Adds this tag / value pair to the set of aggregated attributes
 *   associated with the given handle.
 *
 * void set_cfghandle(void *handle);
 *
 *   Sets and destroys the config object; SLP will no longer attempt
 *   to use this handle after this call. Thus, this call marks the
 *   end of configuration information for this handle.
 */

#include <stdio.h>
#include <slp.h>
#include <stdlib.h>
#include <string.h>
#include <door.h>
#include <unistd.h>
#include "ns_sldap.h"
#include "ns_internal.h"
#include "cachemgr.h"

#define ABSTYPE         "service:naming-directory"
#define CONTEXT_ATTR    "naming-context"
#define LDAP_DOMAIN_ATTR "x-sun-rpcdomain"

/* The configuration cookie passed along through all SLP callbacks. */
struct config_cookie {
        SLPHandle       h;              /* An open SLPHandle */
        const char      *type;          /* The full service type to use */
        char            *scopes;        /* A list of scopes to use */
        const char      *context_attr;  /* Which attr to use for the ctx */
        void            *cache_cfg;     /* caller-supplied config object */
        void *(*get_cfghandle)(const char *);
        void (*aggregate)(void *, const char *, const char *);
        void (*set_cfghandle)(void *);
};

extern admin_t current_admin;   /* ldap_cachemgr's admin struct */

/*
 * Utility routine: getlocale():
 * Returns the locale specified by the SLP locale property, or just
 * returns the default SLP locale if the property was not set.
 */
static const char *getlocale() {
        const char *locale = SLPGetProperty("net.slp.locale");
        return (locale ? locale : "en");
}

/*
 * Utility routine: next_attr():
 * Parses an SLP attribute string. On the first call, *type
 * must be set to 0, and *s_inout must point to the beginning
 * of the attr string. The following results are possible:
 *
 *   If the term is of the form 'tag' only, *t_inout is set to tag,
 *     and *v_inout is set to NULL.
 *   If the term is of the form '(tag=val)', *t_inout and *v_inout
 *     are set to the tag and val strings, respectively.
 *   If the term is of the form '(tag=val1,val2,..,valN)', on each
 *     successive call, next_attr will return the next value. On the
 *     first invocation, tag is set to 'tag'; on successive invocations,
 *     tag is set to *t_inout.
 *
 * The string passed in *s_inout is destructively modified; all values
 * returned simply point into the initial string. Hence the caller
 * is responsible for all memory management. The type parameter is
 * for internal use only and should be set to 0 by the caller only
 * on the first invocation.
 *
 * If more attrs are available, returns SLP_TRUE, otherwise returns
 * SLP_FALSE. If SLP_FALSE is returned, all value-result parameters
 * will be undefined, and should not be used.
 */
static SLPBoolean next_attr(char **t_inout, char **v_inout,
                            char **s_inout, int *type) {
        char *end = NULL;
        char *tag = NULL;
        char *val = NULL;
        char *state = NULL;

        if (!t_inout || !v_inout)
            return (SLP_FALSE);

        if (!s_inout || !*s_inout || !**s_inout)
            return (SLP_FALSE);

        state = *s_inout;

        /* type: 0 = start, 1 = '(tag=val)' type, 2 = 'tag' type */
        switch (*type) {
        case 0:
            switch (*state) {
            case '(':
                *type = 1;
                break;
            case ',':
                state++;
                *type = 0;
                break;
            default:
                *type = 2;
            }
            *s_inout = state;
            return (next_attr(t_inout, v_inout, s_inout, type));
            break;
        case 1:
            switch (*state) {
            case '(':
                /* start of attr of the form (tag=val[,val]) */
                state++;
                tag = state;
                end = strchr(state, ')');       /* for sanity checking */
                if (!end)
                    return (SLP_FALSE); /* fatal parse error */

                state = strchr(tag, '=');
                if (state) {
                    if (state > end)
                        return (SLP_FALSE);  /* fatal parse err */
                    *state++ = 0;
                } else {
                    return (SLP_FALSE); /* fatal parse error */
                }
                /* fallthru to default case, which handles multivals */
            default:
                /* somewhere in a multivalued attr */
                if (!end) {     /* did not fallthru from '(' case */
                    tag = *t_inout;     /* leave tag as it was */
                    end = strchr(state, ')');
                    if (!end)
                        return (SLP_FALSE);     /* fatal parse error */
                }

                val = state;
                state = strchr(val, ',');       /* is this attr multivalued? */
                if (!state || state > end) {
                    /* no, so skip to the next attr */
                    state = end;
                    *type = 0;
                }       /* else attr is multivalued */
                *state++ = 0;
                break;
            }
            break;
        case 2:
            /* attr term with tag only */
            tag = state;
            state = strchr(tag, ',');
            if (state) {
                *state++ = 0;
            }
            val = NULL;
            *type = 0;
            break;
        default:
            return (SLP_FALSE);
        }

        *t_inout = tag;
        *v_inout = val;
        *s_inout = state;

        return (SLP_TRUE);
}

/*
 * The SLP callback routine for foreach_server(). Aggregates each
 * server's attributes into the caller-specified config object.
 */
/*ARGSUSED*/
static SLPBoolean aggregate_attrs(SLPHandle h, const char *attrs_in,
                                    SLPError errin, void *cookie) {
        char *tag, *val, *state;
        char *unesc_tag, *unesc_val;
        int type = 0;
        char *attrs;
        SLPError err;
        struct config_cookie *cfg = (struct config_cookie *)cookie;

        if (errin != SLP_OK) {
            return (SLP_TRUE);
        }

        attrs = strdup(attrs_in);
        state = attrs;

        while (next_attr(&tag, &val, &state, &type)) {
            unesc_tag = unesc_val = NULL;

            if (tag) {
                if ((err = SLPUnescape(tag, &unesc_tag, SLP_TRUE)) != SLP_OK) {
                    unesc_tag = NULL;
                    if (current_admin.debug_level >= DBG_ALL) {
                        (void) logit("aggregate_attrs: ",
                                "could not unescape attr tag %s:%s\n",
                                tag, slp_strerror(err));
                    }
                }
            }
            if (val) {
                if ((err = SLPUnescape(val, &unesc_val, SLP_FALSE))
                    != SLP_OK) {
                    unesc_val = NULL;
                    if (current_admin.debug_level >= DBG_ALL) {
                        (void) logit("aggregate_attrs: ",
                                "could not unescape attr val %s:%s\n",
                                val, slp_strerror(err));
                    }
                }
            }

            if (current_admin.debug_level >= DBG_ALL) {
                (void) logit("discovery:\t\t%s=%s\n",
                        (unesc_tag ? unesc_tag : "NULL"),
                        (unesc_val ? unesc_val : "NULL"));
            }

            cfg->aggregate(cfg->cache_cfg, unesc_tag, unesc_val);

            if (unesc_tag) free(unesc_tag);
            if (unesc_val) free(unesc_val);
        }

        if (attrs) free(attrs);

        return (SLP_TRUE);
}

/*
 * The SLP callback routine for update_config(). For each
 * server found, retrieves that server's attributes.
 */
/*ARGSUSED*/
static SLPBoolean foreach_server(SLPHandle hin, const char *u,
                                unsigned short life,
                                SLPError errin, void *cookie) {
        SLPError err;
        struct config_cookie *cfg = (struct config_cookie *)cookie;
        SLPHandle h = cfg->h;   /* an open handle */
        SLPSrvURL *surl = NULL;
        char *url = NULL;

        if (errin != SLP_OK) {
            return (SLP_TRUE);
        }

        /* dup url so we can slice 'n dice */
        if (!(url = strdup(u))) {
            (void) logit("foreach_server: no memory");
            return (SLP_FALSE);
        }

        if ((err = SLPParseSrvURL(url, &surl)) != SLP_OK) {
            free(url);
            if (current_admin.debug_level >= DBG_NETLOOKUPS) {
                (void) logit("foreach_server: ",
                                "dropping unparsable URL %s: %s\n",
                                url, slp_strerror(err));
                return (SLP_TRUE);
            }
        }

        if (current_admin.debug_level >= DBG_ALL) {
            (void) logit("discovery:\tserver: %s\n", surl->s_pcHost);
        }

        /* retrieve all attrs for this server */
        err = SLPFindAttrs(h, u, cfg->scopes, "", aggregate_attrs, cookie);
        if (err != SLP_OK) {
            if (current_admin.debug_level >= DBG_NETLOOKUPS) {
                (void) logit("foreach_server: FindAttrs failed: %s\n",
                                slp_strerror(err));
            }
            goto cleanup;
        }

        /* add this server and its attrs to the config object */
        cfg->aggregate(cfg->cache_cfg, "_,_xservers_,_", surl->s_pcHost);

cleanup:
        if (url) free(url);
        if (surl) SLPFree(surl);

        return (SLP_TRUE);
}

/*
 * This routine does the dirty work of finding all servers for a
 * given domain and injecting this information into the caller's
 * configuration namespace via callbacks.
 */
static void update_config(const char *context, struct config_cookie *cookie) {
        SLPHandle h = NULL;
        SLPHandle persrv_h = NULL;
        SLPError err;
        char *search = NULL;
        char *unesc_domain = NULL;

        /* Unescape the naming context string */
        if ((err = SLPUnescape(context, &unesc_domain, SLP_FALSE)) != SLP_OK) {
            if (current_admin.debug_level >= DBG_ALL) {
                (void) logit("update_config: ",
                                "dropping unparsable domain: %s: %s\n",
                                context, slp_strerror(err));
            }
            return;
        }

        cookie->cache_cfg = cookie->get_cfghandle(unesc_domain);

        /* Open a handle which all attrs calls can use */
        if ((err = SLPOpen(getlocale(), SLP_FALSE, &persrv_h)) != SLP_OK) {
            if (current_admin.debug_level >= DBG_NETLOOKUPS) {
                (void) logit("update_config: SLPOpen failed: %s\n",
                                slp_strerror(err));
            }
            goto cleanup;
        }

        cookie->h = persrv_h;

        if (current_admin.debug_level >= DBG_ALL) {
            (void) logit("discovery: found naming context %s\n", context);
        }

        /* (re)construct the search filter form the input context */
        search = malloc(strlen(cookie->context_attr) +
                        strlen(context) +
                        strlen("(=)") + 1);
        if (!search) {
            (void) logit("update_config: no memory\n");
            goto cleanup;
        }
        (void) sprintf(search, "(%s=%s)", cookie->context_attr, context);

        /* Find all servers which serve this context */
        if ((err = SLPOpen(getlocale(), SLP_FALSE, &h)) != SLP_OK) {
            if (current_admin.debug_level >= DBG_NETLOOKUPS) {
                (void) logit("upate_config: SLPOpen failed: %s\n",
                                slp_strerror(err));
            }
            goto cleanup;
        }

        err = SLPFindSrvs(h, cookie->type, cookie->scopes,
                                search, foreach_server, cookie);
        if (err != SLP_OK) {
            if (current_admin.debug_level >= DBG_NETLOOKUPS) {
                (void) logit("update_config: SLPFindSrvs failed: %s\n",
                                slp_strerror(err));
            }
            goto cleanup;
        }

        /* update the config cache with the new info */
        cookie->set_cfghandle(cookie->cache_cfg);

cleanup:
        if (h) SLPClose(h);
        if (persrv_h) SLPClose(persrv_h);
        if (search) free(search);
        if (unesc_domain) free(unesc_domain);
}

/*
 * The SLP callback routine for find_all_contexts(). For each context
 * found, finds all the servers and their attributes.
 */
/*ARGSUSED*/
static SLPBoolean foreach_context(SLPHandle h, const char *attrs_in,
                                    SLPError err, void *cookie) {
        char *attrs, *tag, *val, *state;
        int type = 0;

        if (err != SLP_OK) {
            return (SLP_TRUE);
        }

        /*
         * Parse out each context. Attrs will be of the following form:
         *   (naming-context=dc\3deng\2c dc\3dsun\2c dc\3dcom)
         * Note that ',' and '=' are reserved in SLP, so they are escaped.
         */
        attrs = strdup(attrs_in);       /* so we can slice'n'dice */
        if (!attrs) {
            (void) logit("foreach_context: no memory\n");
            return (SLP_FALSE);
        }
        state = attrs;

        while (next_attr(&tag, &val, &state, &type)) {
            update_config(val, cookie);
        }

        free(attrs);

        return (SLP_TRUE);
}

/*
 * Initiates server and attribute discovery for the concrete type
 * 'type'. Currently the only useful type is "ldap", but perhaps
 * "nis" and "nisplus" will also be useful in the future.
 *
 * get_cfghandle, aggregate, and set_cfghandle are callback routines
 * used to pass any discovered configuration information back to the
 * caller. See the introduction at the top of this file for more info.
 */
static void find_all_contexts(const char *type,
                                void *(*get_cfghandle)(const char *),
                                void (*aggregate)(
                                        void *, const char *, const char *),
                                void (*set_cfghandle)(void *)) {
        SLPHandle h = NULL;
        SLPError err;
        struct config_cookie cookie[1];
        char *fulltype = NULL;
        char *scope = (char *)SLPGetProperty("net.slp.useScopes");

        if (!scope || !*scope) {
            scope = "default";
        }

        /* construct the full type from the partial type parameter */
        fulltype = malloc(strlen(ABSTYPE) + strlen(type) + 2);
        if (!fulltype) {
            (void) logit("find_all_contexts: no memory");
            goto done;
        }
        (void) sprintf(fulltype, "%s:%s", ABSTYPE, type);

        /* set up the cookie for this discovery operation */
        memset(cookie, 0, sizeof (*cookie));
        cookie->type = fulltype;
        cookie->scopes = scope;
        if (strcasecmp(type, "ldap") == 0) {
                /* Sun LDAP is special */
            cookie->context_attr = LDAP_DOMAIN_ATTR;
        } else {
            cookie->context_attr = CONTEXT_ATTR;
        }
        cookie->get_cfghandle = get_cfghandle;
        cookie->aggregate = aggregate;
        cookie->set_cfghandle = set_cfghandle;

        if ((err = SLPOpen(getlocale(), SLP_FALSE, &h)) != SLP_OK) {
            if (current_admin.debug_level >= DBG_CANT_FIND) {
                (void) logit("discover: %s",
                            "Aborting discovery: SLPOpen failed: %s\n",
                            slp_strerror(err));
            }
            goto done;
        }

        /* use find attrs to get a list of all available contexts */
        err = SLPFindAttrs(h, fulltype, scope, cookie->context_attr,
                            foreach_context, cookie);
        if (err != SLP_OK) {
            if (current_admin.debug_level >= DBG_CANT_FIND) {
                (void) logit(
                "discover: Aborting discovery: SLPFindAttrs failed: %s\n",
                        slp_strerror(err));
            }
            goto done;
        }

done:
        if (h) SLPClose(h);
        if (fulltype) free(fulltype);
}

/*
 * This is the ldap_cachemgr entry point into SLP dynamic discovery. The
 * parameter 'r' should be a pointer to an unsigned int containing
 * the requested interval at which the network should be queried.
 */
void
discover(void *r) {
        unsigned short reqrefresh = *((unsigned int *)r);

        (void) pthread_setname_np(pthread_self(), "discover");

        for (;;) {
            find_all_contexts("ldap",
                                __cache_get_cfghandle,
                                __cache_aggregate_params,
                                __cache_set_cfghandle);

            if (current_admin.debug_level >= DBG_ALL) {
                (void) logit(
                        "dynamic discovery: using refresh interval %d\n",
                        reqrefresh);
            }

            (void) sleep(reqrefresh);
        }
}

#endif /* SLP */