1N/A
1N/A/*
1N/A * Portions Copyright 1998 Sun Microsystems, Inc. All rights reserved.
1N/A * Use is subject to license terms.
1N/A */
1N/A
1N/A#pragma ident "%Z%%M% %I% %E% SMI"
1N/A
1N/A/*
1N/A * Copyright (c) 1990 Regents of the University of Michigan.
1N/A * All rights reserved.
1N/A *
1N/A * abandon.c
1N/A */
1N/A
1N/A#ifndef lint
1N/Astatic char copyright[] = "@(#) Copyright (c) 1990 Regents of the University of Michigan.\nAll rights reserved.\n";
1N/A#endif
1N/A
1N/A#include <stdio.h>
1N/A#include <string.h>
1N/A
1N/A#if !defined( MACOS ) && !defined( DOS )
1N/A#include <sys/types.h>
1N/A#include <sys/socket.h>
1N/A#endif
1N/A
1N/A#if defined( DOS ) || defined( _WIN32 )
1N/A#include <malloc.h>
1N/A#include "msdos.h"
1N/A#endif /* DOS */
1N/A
1N/A#ifdef MACOS
1N/A#include <stdlib.h>
1N/A#include "macos.h"
1N/A#endif /* MACOS */
1N/A
1N/A#include "lber.h"
1N/A#include "ldap.h"
1N/A#include "ldap-private.h"
1N/A#include "ldap-int.h"
1N/A
1N/A#ifdef NEEDPROTOS
1N/Astatic int do_abandon( LDAP *ld, int origid, int msgid, LDAPControl **serverctrls );
1N/A#else /* NEEDPROTOS */
1N/Astatic int do_abandon();
1N/A#endif /* NEEDPROTOS */
1N/A
1N/ABerElement * ldap_build_abandon_req( LDAP *ld, int msgid, LDAPControl ** serverctrls)
1N/A{
1N/A BerElement *ber;
1N/A int rc;
1N/A
1N/A /* create a message to send */
1N/A if ( (ber = alloc_ber_with_options( ld )) == NULLBER ) {
1N/A rc = -1;
1N/A ld->ld_errno = LDAP_NO_MEMORY;
1N/A return (NULLBER);
1N/A }
1N/A#ifdef CLDAP
1N/A if ( ld->ld_sb.sb_naddr > 0 ) {
1N/A rc = ber_printf( ber, "{isti",
1N/A ++ld->ld_msgid, ld->ld_cldapdn,
1N/A LDAP_REQ_ABANDON, msgid );
1N/A } else {
1N/A#endif /* CLDAP */
1N/A rc = ber_printf( ber, "{iti", ++ld->ld_msgid,
1N/A LDAP_REQ_ABANDON, msgid );
1N/A#ifdef CLDAP
1N/A }
1N/A#endif /* CLDAP */
1N/A
1N/A if ( rc == -1 ) {
1N/A ld->ld_errno = LDAP_ENCODING_ERROR;
1N/A ber_free( ber, 1 );
1N/A return (NULLBER);
1N/A }
1N/A /* LDAPv3 */
1N/A /* Code controls if any */
1N/A if (serverctrls && serverctrls[0]) {
1N/A if (ldap_controls_code(ber, serverctrls) != LDAP_SUCCESS){
1N/A ld->ld_errno = LDAP_ENCODING_ERROR;
1N/A return( NULLBER );
1N/A }
1N/A } else if (ld->ld_srvctrls && ld->ld_srvctrls[0]) {
1N/A /* Otherwise, is there any global server ctrls ? */
1N/A if (ldap_controls_code(ber, ld->ld_srvctrls) != LDAP_SUCCESS){
1N/A ld->ld_errno = LDAP_ENCODING_ERROR;
1N/A return( NULLBER );
1N/A }
1N/A }
1N/A
1N/A if ( ber_printf( ber, "}" ) == -1 ) {
1N/A ld->ld_errno = LDAP_ENCODING_ERROR;
1N/A ber_free( ber, 1 );
1N/A return( NULLBER );
1N/A }
1N/A return (ber);
1N/A}
1N/A
1N/A
1N/A/*
1N/A * ldap_abandon - perform an ldap (and X.500) abandon operation. Parameters:
1N/A *
1N/A * ld LDAP descriptor
1N/A * msgid The message id of the operation to abandon
1N/A *
1N/A * ldap_abandon returns 0 if everything went ok, -1 otherwise.
1N/A *
1N/A * Example:
1N/A * ldap_abandon( ld, msgid );
1N/A */
1N/Aint
1N/Aldap_abandon( LDAP *ld, int msgid )
1N/A{
1N/A int rv;
1N/A
1N/A#ifdef _REENTRANT
1N/A LOCK_LDAP( ld );
1N/A#endif
1N/A
1N/A Debug( LDAP_DEBUG_TRACE, catgets(slapdcat, 1, 85, "ldap_abandon %d\n"), msgid, 0, 0 );
1N/A
1N/A rv = do_abandon( ld, msgid, msgid , NULL);
1N/A#ifdef _REENTRANT
1N/A UNLOCK_LDAP( ld );
1N/A#endif
1N/A return (rv);
1N/A}
1N/A
1N/A/* ldapv3 API extensions */
1N/A
1N/Aint ldap_abandon_ext(LDAP *ld, int msgid, LDAPControl **serverctrls, LDAPControl **clientctrls)
1N/A{
1N/A int rv;
1N/A
1N/A#ifdef _REENTRANT
1N/A LOCK_LDAP( ld );
1N/A#endif
1N/A
1N/A Debug( LDAP_DEBUG_TRACE, catgets(slapdcat, 1, 85, "ldap_abandon %d\n"), msgid, 0, 0 );
1N/A
1N/A rv = do_abandon( ld, msgid, msgid , NULL);
1N/A if (rv == -1) {
1N/A rv = ld->ld_errno;
1N/A if (rv == LDAP_SUCCESS)
1N/A rv = LDAP_OTHER;
1N/A#ifdef _REENTRANT
1N/A UNLOCK_LDAP( ld );
1N/A#endif
1N/A return (rv);
1N/A }
1N/A#ifdef _REENTRANT
1N/A UNLOCK_LDAP( ld );
1N/A#endif
1N/A return (LDAP_SUCCESS);
1N/A}
1N/A
1N/A
1N/Astatic int
1N/Ado_abandon( LDAP *ld, int origid, int msgid , LDAPControl **serverctrls)
1N/A{
1N/A BerElement *ber;
1N/A int i, err, sendabandon;
1N/A Sockbuf *sb;
1N/A#ifdef LDAP_REFERRALS
1N/A LDAPRequest *lr;
1N/A#endif /* LDAP_REFERRALS */
1N/A
1N/A /*
1N/A * An abandon request looks like this:
1N/A * AbandonRequest ::= MessageID
1N/A */
1N/A
1N/A Debug( LDAP_DEBUG_TRACE, catgets(slapdcat, 1, 86, "do_abandon origid %1$d, msgid %2$d\n"),
1N/A origid, msgid, 0 );
1N/A
1N/A sendabandon = 1;
1N/A
1N/A#ifdef LDAP_REFERRALS
1N/A /* find the request that we are abandoning */
1N/A for ( lr = ld->ld_requests; lr != NULL; lr = lr->lr_next ) {
1N/A if ( lr->lr_msgid == msgid ) { /* this message */
1N/A break;
1N/A }
1N/A if ( lr->lr_origid == msgid ) { /* child: abandon it */
1N/A do_abandon( ld, msgid, lr->lr_msgid , serverctrls);
1N/A }
1N/A }
1N/A
1N/A if ( lr != NULL ) {
1N/A if ( origid == msgid && lr->lr_parent != NULL ) {
1N/A /* don't let caller abandon child requests! */
1N/A ld->ld_errno = LDAP_PARAM_ERROR;
1N/A return( -1 );
1N/A }
1N/A if ( lr->lr_status != LDAP_REQST_INPROGRESS ) {
1N/A /* no need to send abandon message */
1N/A sendabandon = 0;
1N/A }
1N/A }
1N/A#endif /* LDAP_REFERRALS */
1N/A
1N/A if ( ldap_msgdelete( ld, msgid ) == 0 ) {
1N/A ld->ld_errno = LDAP_SUCCESS;
1N/A return( 0 );
1N/A }
1N/A
1N/A err = 0;
1N/A if ( sendabandon ) {
1N/A if ((ber = ldap_build_abandon_req(ld, msgid, serverctrls)) == NULLBER){
1N/A return (-1);
1N/A }
1N/A
1N/A#ifdef LDAP_REFERRALS
1N/A if ( lr != NULL ) {
1N/A sb = lr->lr_conn->lconn_sb;
1N/A } else {
1N/A sb = &ld->ld_sb;
1N/A }
1N/A#else /* LDAP_REFERRALS */
1N/A sb = &ld->ld_sb;
1N/A#endif /* LDAP_REFERRALS */
1N/A if ( ber_flush( sb, ber, 1 ) != 0 ) {
1N/A ld->ld_errno = LDAP_SERVER_DOWN;
1N/A err = -1;
1N/A } else {
1N/A err = 0;
1N/A }
1N/A }
1N/A#ifdef LDAP_REFERRALS
1N/A if ( lr != NULL ) {
1N/A if ( sendabandon ) {
1N/A free_connection( ld, lr->lr_conn, 0, 1 );
1N/A }
1N/A if ( origid == msgid ) {
1N/A free_request( ld, lr );
1N/A }
1N/A }
1N/A#endif /* LDAP_REFERRALS */
1N/A
1N/A
1N/A if ( ld->ld_abandoned == NULL ) {
1N/A if ( (ld->ld_abandoned = (int *) malloc( 2 * sizeof(int) ))
1N/A == NULL ) {
1N/A ld->ld_errno = LDAP_NO_MEMORY;
1N/A return( -1 );
1N/A }
1N/A i = 0;
1N/A } else {
1N/A for ( i = 0; ld->ld_abandoned[i] != -1; i++ )
1N/A ; /* NULL */
1N/A if ( (ld->ld_abandoned = (int *) realloc( (char *)
1N/A ld->ld_abandoned, (i + 2) * sizeof(int) )) == NULL ) {
1N/A ld->ld_errno = LDAP_NO_MEMORY;
1N/A return( -1 );
1N/A }
1N/A }
1N/A ld->ld_abandoned[i] = msgid;
1N/A ld->ld_abandoned[i + 1] = -1;
1N/A
1N/A if ( err != -1 ) {
1N/A ld->ld_errno = LDAP_SUCCESS;
1N/A }
1N/A return( err );
1N/A}
1N/A