blob: 420cada6569d5a8aa7ea500d1809cee2aa83336d [file] [log] [blame]
/* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#include "apr.h"
#include "apu.h"
#include "apr_atomic.h"
#include "apr_ldap.h"
#include "apr_ldap_internal.h"
#include "apu_internal.h"
#include "apr_dso.h"
#include "apr_errno.h"
#include "apr_pools.h"
#include "apr_strings.h"
#include "apu_version.h"
#include "apr_private.h"
#if APR_HAS_LDAP
#if APR_HAVE_MODULAR_DSO
static apr_pool_t *global;
static struct apr__ldap_dso_fntable *lfn = NULL;
static apr_uint32_t in_init = 0, initialised = 0;
static apr_status_t apr_ldap_term(void *ptr)
{
if (apr_atomic_inc32(&in_init)) {
while (apr_atomic_read32(&in_init) > 1); /* wait until we get fully inited */
}
/* Reference count - cleanup when last reference is cleaned up */
if (!apr_atomic_dec32(&initialised)) {
apr_pool_destroy(global);
/* set statics to NULL so init can work again */
global = NULL;
lfn = NULL;
}
apr_atomic_dec32(&in_init);
/* Everything else we need is handled by cleanups registered
* when we created mutexes and loaded DSOs
*/
return APR_SUCCESS;
}
static apr_status_t load_ldap(apr_pool_t *pool, const apr_ldap_driver_t **driver, apu_err_t *err)
{
char *modname;
apr_dso_handle_t *dlhandle;
apr_dso_handle_sym_t symbol;
apr_status_t rv;
/* deprecate in 2.0 - permit implicit initialization */
apu_dso_init(pool);
rv = apu_dso_mutex_lock();
if (rv) {
return rv;
}
#if defined(WIN32)
modname = "apr_ldap-" APR_STRINGIFY(APR_MAJOR_VERSION) ".dll";
#else
modname = "apr_ldap-" APR_STRINGIFY(APR_MAJOR_VERSION) ".so";
#endif
rv = apu_dso_load(&dlhandle, &symbol, modname, "apr__ldap_fns", pool, err);
if (rv == APR_SUCCESS) {
lfn = symbol;
}
if (driver) {
*driver = (apr_ldap_driver_t *)lfn;
}
apu_dso_mutex_unlock();
return rv;
}
#define LOAD_LDAP_STUB(pool, err, failres) \
if (!lfn && (apr_ldap_get_driver(pool, NULL, err) != APR_SUCCESS)) \
return failres;
#define CHECK_LDAP_STUB(failres) \
if (!lfn) \
return failres;
APR_DECLARE(apr_status_t) apr_ldap_get_driver(apr_pool_t *pool,
const apr_ldap_driver_t **driver,
apu_err_t *err)
{
apr_status_t status = APR_EREINIT;
if (apr_atomic_inc32(&in_init)) {
while (apr_atomic_read32(&in_init) > 1); /* wait until we get fully inited */
}
/* Reference count increment... */
if (!apr_atomic_inc32(&initialised)) {
apr_pool_create_unmanaged(&global);
status = load_ldap(global, driver, err);
}
apr_pool_cleanup_register(pool, NULL, apr_ldap_term,
apr_pool_cleanup_null);
apr_atomic_dec32(&in_init);
return status;
}
APU_DECLARE_LDAP(apr_status_t) apr_ldap_info(apr_pool_t *pool,
apu_err_t **result_err)
{
*result_err = (apu_err_t *)apr_pcalloc(pool, sizeof(apu_err_t));
LOAD_LDAP_STUB(pool, *result_err, APR_EINIT);
return lfn->info(pool, result_err);
}
APU_DECLARE_LDAP(apr_status_t) apr_ldap_initialise(apr_pool_t *pool,
apr_ldap_t **ldap,
apu_err_t *err)
{
LOAD_LDAP_STUB(pool, err, APR_EINIT);
return lfn->initialise(pool, ldap, err);
}
APU_DECLARE_LDAP(apr_status_t) apr_ldap_option_get(apr_pool_t *pool,
apr_ldap_t *ldap,
int option,
apr_ldap_opt_t *outvalue,
apu_err_t *err)
{
LOAD_LDAP_STUB(pool, err, APR_EINIT);
return lfn->option_get(pool, ldap, option, outvalue, err);
}
APU_DECLARE_LDAP(apr_status_t) apr_ldap_option_set(apr_pool_t *pool,
apr_ldap_t *ldap,
int option,
const apr_ldap_opt_t *invalue,
apu_err_t *err)
{
LOAD_LDAP_STUB(pool, err, APR_EINIT);
return lfn->option_set(pool, ldap, option, invalue, err);
}
APU_DECLARE_LDAP(apr_status_t) apr_ldap_connect(apr_pool_t *pool,
apr_ldap_t *ldap,
apr_interval_time_t timeout,
apu_err_t *err)
{
CHECK_LDAP_STUB(APR_EINIT);
return lfn->connect(pool, ldap, timeout, err);
}
APU_DECLARE_LDAP(apr_status_t) apr_ldap_prepare(apr_pool_t *pool,
apr_ldap_t *ldap,
apr_ldap_prepare_cb prepare_cb,
void *prepare_ctx)
{
CHECK_LDAP_STUB(APR_EINIT);
return lfn->prepare(pool, ldap, prepare_cb, prepare_ctx);
}
APU_DECLARE_LDAP(apr_status_t) apr_ldap_process(apr_pool_t *pool,
apr_ldap_t *ldap,
apr_interval_time_t timeout,
apu_err_t *err)
{
CHECK_LDAP_STUB(APR_EINIT);
return lfn->process(pool, ldap, timeout, err);
}
APU_DECLARE_LDAP(apr_status_t) apr_ldap_result(apr_pool_t *pool,
apr_ldap_t *ldap,
apr_interval_time_t timeout,
apu_err_t *err)
{
CHECK_LDAP_STUB(APR_EINIT);
return lfn->result(pool, ldap, timeout, err);
}
APU_DECLARE_LDAP(apr_status_t) apr_ldap_poll(apr_pool_t *pool,
apr_ldap_t *ldap,
apr_pollcb_t *poll,
apr_interval_time_t timeout,
apu_err_t *err)
{
CHECK_LDAP_STUB(APR_EINIT);
return lfn->poll(pool, ldap, poll, timeout, err);
}
APU_DECLARE_LDAP(apr_status_t) apr_ldap_bind(apr_pool_t *pool,
apr_ldap_t *ldap,
const char *mech,
apr_ldap_bind_interact_cb *interact_cb,
void *interact_ctx,
apr_interval_time_t timeout,
apr_ldap_bind_cb bind_cb, void *bind_ctx,
apu_err_t *err)
{
CHECK_LDAP_STUB(APR_EINIT);
return lfn->bind(pool, ldap, mech, interact_cb, interact_ctx, timeout, bind_cb, bind_ctx, err);
}
APU_DECLARE_LDAP(apr_status_t) apr_ldap_compare(apr_pool_t *pool,
apr_ldap_t *ldap,
const char *dn,
const char *attr,
const apr_buffer_t *bval,
apr_ldap_control_t **serverctrls,
apr_ldap_control_t **clientctrls,
apr_interval_time_t timeout,
apr_ldap_compare_cb compare_cb, void *ctx,
apu_err_t *err)
{
CHECK_LDAP_STUB(APR_EINIT);
return lfn->compare(pool, ldap, dn, attr, bval, serverctrls, clientctrls, timeout, compare_cb, ctx, err);
}
APU_DECLARE_LDAP(apr_status_t) apr_ldap_search(apr_pool_t *pool,
apr_ldap_t *ldap,
const char *dn,
apr_ldap_search_scope_e scope,
const char *filter,
const char **attrs,
apr_ldap_switch_e attrsonly,
apr_ldap_control_t **serverctrls,
apr_ldap_control_t **clientctrls,
apr_interval_time_t timeout,
apr_ssize_t sizelimit,
apr_ldap_search_result_cb search_result_cb,
apr_ldap_search_entry_cb search_entry_cb,
void *search_ctx,
apu_err_t *err)
{
CHECK_LDAP_STUB(APR_EINIT);
return lfn->search(pool, ldap, dn, scope, filter, attrs, attrsonly, serverctrls, clientctrls, timeout, sizelimit, search_result_cb, search_entry_cb, search_ctx, err);
}
APU_DECLARE_LDAP(apr_status_t) apr_ldap_unbind(apr_ldap_t *ldap,
apr_ldap_control_t **serverctrls,
apr_ldap_control_t **clientctrls,
apu_err_t *err)
{
CHECK_LDAP_STUB(APR_EINIT);
return lfn->unbind(ldap, serverctrls, clientctrls, err);
}
#endif /* APR_HAVE_MODULAR_DSO */
#endif /* APR_HAS_LDAP */