X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;ds=sidebyside;f=servers%2Fslapd%2Foperation.c;h=49c1a7b58c50815c7506a5fef15d79119f1d3c93;hb=08059f1633bfd9d0a709761b026bdb8e4441c6e6;hp=9a06f97fbd3b543cbe4d367843a95f2425bbde32;hpb=7e6ad5100c2702b1d56a285bdfb341ddf38c0d76;p=openldap diff --git a/servers/slapd/operation.c b/servers/slapd/operation.c index 9a06f97fbd..49c1a7b58c 100644 --- a/servers/slapd/operation.c +++ b/servers/slapd/operation.c @@ -1,4 +1,9 @@ /* operation.c - routines to deal with pending ldap operations */ +/* $OpenLDAP$ */ +/* + * Copyright 1998-2002 The OpenLDAP Foundation, All Rights Reserved. + * COPYING RESTRICTIONS APPLY, see COPYRIGHT file + */ #include "portable.h" @@ -11,65 +16,47 @@ void -op_free( Operation *op ) +slap_op_free( Operation *op ) { - if ( op->o_ber != NULL ) + assert( LDAP_STAILQ_NEXT(op, o_next) == NULL ); + + if ( op->o_ber != NULL ) { ber_free( op->o_ber, 1 ); - if ( op->o_dn != NULL ) { - free( op->o_dn ); } - /* pthread_mutex_destroy( &op->o_abandonmutex ); */ + if ( op->o_dn.bv_val != NULL ) { + free( op->o_dn.bv_val ); + } + if ( op->o_ndn.bv_val != NULL ) { + free( op->o_ndn.bv_val ); + } + if ( op->o_authmech.bv_val != NULL ) { + free( op->o_authmech.bv_val ); + } + if ( op->o_ctrls != NULL ) { + ldap_controls_free( op->o_ctrls ); + } + free( (char *) op ); } Operation * -op_add( - Operation **olist, +slap_op_alloc( BerElement *ber, - unsigned long msgid, - unsigned long tag, - char *dn, - int id, - int connid + ber_int_t msgid, + ber_tag_t tag, + ber_int_t id ) { - Operation **tmp; + Operation *op; - for ( tmp = olist; *tmp != NULL; tmp = &(*tmp)->o_next ) - ; /* NULL */ + op = (Operation *) ch_calloc( 1, sizeof(Operation) ); - *tmp = (Operation *) calloc( 1, sizeof(Operation) ); - pthread_mutex_init( &(*tmp)->o_abandonmutex, - pthread_mutexattr_default ); - (*tmp)->o_ber = ber; - (*tmp)->o_msgid = msgid; - (*tmp)->o_tag = tag; - (*tmp)->o_abandon = 0; - (*tmp)->o_dn = strdup( dn != NULL ? dn : "" ); - pthread_mutex_lock( ¤ttime_mutex ); - (*tmp)->o_time = currenttime; - pthread_mutex_unlock( ¤ttime_mutex ); - (*tmp)->o_opid = id; - (*tmp)->o_connid = connid; - (*tmp)->o_next = NULL; + op->o_ber = ber; + op->o_msgid = msgid; + op->o_tag = tag; - return( *tmp ); -} - -void -op_delete( Operation **olist, Operation *op ) -{ - Operation **tmp; - - for ( tmp = olist; *tmp != NULL && *tmp != op; tmp = &(*tmp)->o_next ) - ; /* NULL */ - - if ( *tmp == NULL ) { - Debug( LDAP_DEBUG_ANY, "op_delete: can't find op %ld\n", - op->o_msgid, 0, 0 ); - return; - } + op->o_time = slap_get_time(); + op->o_opid = id; - *tmp = (*tmp)->o_next; - op_free( op ); + return( op ); }