diff options
Diffstat (limited to '')
| -rw-r--r-- | servers/slapd/operation.c | 252 |
1 files changed, 252 insertions, 0 deletions
diff --git a/servers/slapd/operation.c b/servers/slapd/operation.c new file mode 100644 index 0000000..b4b4830 --- /dev/null +++ b/servers/slapd/operation.c @@ -0,0 +1,252 @@ +/* operation.c - routines to deal with pending ldap operations */ +/* $OpenLDAP$ */ +/* This work is part of OpenLDAP Software <http://www.openldap.org/>. + * + * Copyright 1998-2022 The OpenLDAP Foundation. + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted only as authorized by the OpenLDAP + * Public License. + * + * A copy of this license is available in the file LICENSE in the + * top-level directory of the distribution or, alternatively, at + * <http://www.OpenLDAP.org/license.html>. + */ +/* Portions Copyright (c) 1995 Regents of the University of Michigan. + * All rights reserved. + * + * Redistribution and use in source and binary forms are permitted + * provided that this notice is preserved and that due credit is given + * to the University of Michigan at Ann Arbor. The name of the University + * may not be used to endorse or promote products derived from this + * software without specific prior written permission. This software + * is provided ``as is'' without express or implied warranty. + */ + +#include "portable.h" + +#include <stdio.h> + +#include <ac/string.h> +#include <ac/socket.h> + +#include "slap.h" + +#ifdef LDAP_SLAPI +#include "slapi/slapi.h" +#endif + +static ldap_pvt_thread_mutex_t slap_op_mutex; +static time_t last_time; +static int last_incr; + +void slap_op_init(void) +{ + struct timeval tv; + ldap_pvt_thread_mutex_init( &slap_op_mutex ); + gettimeofday( &tv, NULL ); + last_time = tv.tv_sec; + last_incr = tv.tv_usec; +} + +void slap_op_destroy(void) +{ + ldap_pvt_thread_mutex_destroy( &slap_op_mutex ); +} + +static void +slap_op_q_destroy( void *key, void *data ) +{ + Operation *op, *op2; + for ( op = data; op; op = op2 ) { + op2 = LDAP_STAILQ_NEXT( op, o_next ); + ber_memfree_x( op, NULL ); + } +} + +void +slap_op_groups_free( Operation *op ) +{ + GroupAssertion *g, *n; + for ( g = op->o_groups; g; g = n ) { + n = g->ga_next; + slap_sl_free( g, op->o_tmpmemctx ); + } + op->o_groups = NULL; +} + +void +slap_op_free( Operation *op, void *ctx ) +{ + OperationBuffer *opbuf; + + assert( LDAP_STAILQ_NEXT(op, o_next) == NULL ); + + /* paranoia */ + op->o_abandon = 1; + + if ( op->o_ber != NULL ) { + ber_free( op->o_ber, 1 ); + } + if ( !BER_BVISNULL( &op->o_dn ) ) { + ch_free( op->o_dn.bv_val ); + } + if ( !BER_BVISNULL( &op->o_ndn ) ) { + ch_free( op->o_ndn.bv_val ); + } + if ( !BER_BVISNULL( &op->o_authmech ) ) { + ch_free( op->o_authmech.bv_val ); + } + if ( op->o_ctrls != NULL ) { + slap_free_ctrls( op, op->o_ctrls ); + } + +#ifdef LDAP_CONNECTIONLESS + if ( op->o_res_ber != NULL ) { + ber_free( op->o_res_ber, 1 ); + } +#endif + + if ( op->o_groups ) { + slap_op_groups_free( op ); + } + +#if defined( LDAP_SLAPI ) + if ( slapi_plugins_used ) { + slapi_int_free_object_extensions( SLAPI_X_EXT_OPERATION, op ); + } +#endif /* defined( LDAP_SLAPI ) */ + + if ( !BER_BVISNULL( &op->o_csn ) ) { + op->o_tmpfree( op->o_csn.bv_val, op->o_tmpmemctx ); + } + + if ( op->o_pagedresults_state != NULL ) { + op->o_tmpfree( op->o_pagedresults_state, op->o_tmpmemctx ); + } + + /* Selectively zero out the struct. Ignore fields that will + * get explicitly initialized later anyway. Keep o_abandon intact. + */ + opbuf = (OperationBuffer *) op; + op->o_bd = NULL; + BER_BVZERO( &op->o_req_dn ); + BER_BVZERO( &op->o_req_ndn ); + memset( op->o_hdr, 0, sizeof( *op->o_hdr )); + memset( &op->o_request, 0, sizeof( op->o_request )); + memset( &op->o_do_not_cache, 0, sizeof( Operation ) - offsetof( Operation, o_do_not_cache )); + memset( opbuf->ob_controls, 0, sizeof( opbuf->ob_controls )); + op->o_controls = opbuf->ob_controls; + + if ( ctx ) { + Operation *op2 = NULL; + ldap_pvt_thread_pool_setkey( ctx, (void *)slap_op_free, + op, slap_op_q_destroy, (void **)&op2, NULL ); + LDAP_STAILQ_NEXT( op, o_next ) = op2; + if ( op2 ) { + op->o_tincr = op2->o_tincr + 1; + /* No more than 10 ops on per-thread free list */ + if ( op->o_tincr > 10 ) { + ldap_pvt_thread_pool_setkey( ctx, (void *)slap_op_free, + op2, slap_op_q_destroy, NULL, NULL ); + ber_memfree_x( op, NULL ); + } + } else { + op->o_tincr = 1; + } + } else { + ber_memfree_x( op, NULL ); + } +} + +void +slap_op_time(time_t *t, int *nop) +{ + struct timeval tv; + ldap_pvt_thread_mutex_lock( &slap_op_mutex ); + gettimeofday( &tv, NULL ); + *t = tv.tv_sec; + if ( *t == last_time ) { + *nop = ++last_incr; + } else { + last_time = *t; + last_incr = 0; + *nop = 0; + } + ldap_pvt_thread_mutex_unlock( &slap_op_mutex ); + nop[1] = tv.tv_usec; +} + +Operation * +slap_op_alloc( + BerElement *ber, + ber_int_t msgid, + ber_tag_t tag, + ber_int_t id, + void *ctx ) +{ + Operation *op = NULL; + + if ( ctx ) { + void *otmp = NULL; + ldap_pvt_thread_pool_getkey( ctx, (void *)slap_op_free, &otmp, NULL ); + if ( otmp ) { + op = otmp; + otmp = LDAP_STAILQ_NEXT( op, o_next ); + ldap_pvt_thread_pool_setkey( ctx, (void *)slap_op_free, + otmp, slap_op_q_destroy, NULL, NULL ); + op->o_abandon = 0; + op->o_cancel = 0; + } + } + if (!op) { + op = (Operation *) ch_calloc( 1, sizeof(OperationBuffer) ); + op->o_hdr = &((OperationBuffer *) op)->ob_hdr; + op->o_controls = ((OperationBuffer *) op)->ob_controls; + } + + op->o_ber = ber; + op->o_msgid = msgid; + op->o_tag = tag; + + slap_op_time( &op->o_time, &op->o_tincr ); + op->o_opid = id; + +#if defined( LDAP_SLAPI ) + if ( slapi_plugins_used ) { + slapi_int_create_object_extensions( SLAPI_X_EXT_OPERATION, op ); + } +#endif /* defined( LDAP_SLAPI ) */ + + return( op ); +} + +slap_op_t +slap_req2op( ber_tag_t tag ) +{ + switch ( tag ) { + case LDAP_REQ_BIND: + return SLAP_OP_BIND; + case LDAP_REQ_UNBIND: + return SLAP_OP_UNBIND; + case LDAP_REQ_ADD: + return SLAP_OP_ADD; + case LDAP_REQ_DELETE: + return SLAP_OP_DELETE; + case LDAP_REQ_MODRDN: + return SLAP_OP_MODRDN; + case LDAP_REQ_MODIFY: + return SLAP_OP_MODIFY; + case LDAP_REQ_COMPARE: + return SLAP_OP_COMPARE; + case LDAP_REQ_SEARCH: + return SLAP_OP_SEARCH; + case LDAP_REQ_ABANDON: + return SLAP_OP_ABANDON; + case LDAP_REQ_EXTENDED: + return SLAP_OP_EXTENDED; + } + + return SLAP_OP_LAST; +} |