git.sur5r.net Git - openldap/blob - servers/slapd/abandon.c

   1 /* abandon.c - decode and handle an ldap abandon operation */
   2 /* $OpenLDAP$ */
   3 /*
   4  * Copyright 1998-2002 The OpenLDAP Foundation, All Rights Reserved.
   5  * COPYING RESTRICTIONS APPLY, see COPYRIGHT file
   6  */
   7
   8 /*
   9  * Copyright (c) 1995 Regents of the University of Michigan.
  10  * All rights reserved.
  11  *
  12  * Redistribution and use in source and binary forms are permitted
  13  * provided that this notice is preserved and that due credit is given
  14  * to the University of Michigan at Ann Arbor. The name of the University
  15  * may not be used to endorse or promote products derived from this
  16  * software without specific prior written permission. This software
  17  * is provided ``as is'' without express or implied warranty.
  18  */
  19
  20 #include "portable.h"
  21
  22 #include <stdio.h>
  23 #include <ac/socket.h>
  24
  25 #include "slap.h"
  26
  27 int
  28 do_abandon(
  29     Connection  *conn,
  30     Operation   *op
  31 )
  32 {
  33         ber_int_t               id;
  34         Operation       *o;
  35         int rc;
  36
  37 #ifdef NEW_LOGGING
  38         LDAP_LOG(( "operation", LDAP_LEVEL_ENTRY, "conn: %d do_abandon\n",
  39                 conn->c_connid));
  40 #else
  41         Debug( LDAP_DEBUG_TRACE, "do_abandon\n", 0, 0, 0 );
  42 #endif
  43
  44         /*
  45          * Parse the abandon request.  It looks like this:
  46          *
  47          *      AbandonRequest := MessageID
  48          */
  49
  50         if ( ber_scanf( op->o_ber, "i", &id ) == LBER_ERROR ) {
  51 #ifdef NEW_LOGGING
  52                 LDAP_LOG(( "operation", LDAP_LEVEL_ERR,
  53                        "conn: %d do_abandon: ber_scanf failed\n",
  54                        conn->c_connid ));
  55 #else
  56                 Debug( LDAP_DEBUG_ANY, "do_abandon: ber_scanf failed\n", 0, 0 ,0 );
  57 #endif
  58                 send_ldap_disconnect( conn, op,
  59                         LDAP_PROTOCOL_ERROR, "decoding error" );
  60                 return -1;
  61         }
  62
  63         if( (rc = get_ctrls( conn, op, 0 )) != LDAP_SUCCESS ) {
  64                 Debug( LDAP_DEBUG_ANY, "do_abandon: get_ctrls failed\n", 0, 0 ,0 );
  65                 return rc;
  66         }
  67
  68 #ifdef NEW_LOGGING
  69         LDAP_LOG(( "operation", LDAP_LEVEL_ARGS,
  70                 "do_abandon: conn: %d  id=%ld\n", conn->c_connid, (long) id ));
  71 #else
  72         Debug( LDAP_DEBUG_ARGS, "do_abandon: id=%ld\n", (long) id, 0 ,0 );
  73 #endif
  74
  75         if( id <= 0 ) {
  76 #ifdef NEW_LOGGING
  77                 LDAP_LOG(( "operation", LDAP_LEVEL_ERR,
  78                     "do_abandon: conn: %d bad msgid %ld\n", conn->c_connid, (long) id ));
  79 #else
  80                 Debug( LDAP_DEBUG_ANY,
  81                         "do_abandon: bad msgid %ld\n", (long) id, 0, 0 );
  82 #endif
  83                 return LDAP_SUCCESS;
  84         }
  85
  86         ldap_pvt_thread_mutex_lock( &conn->c_mutex );
  87         /*
  88          * find the operation being abandoned and set the o_abandon
  89          * flag.  It's up to the backend to periodically check this
  90          * flag and abort the operation at a convenient time.
  91          */
  92
  93         LDAP_STAILQ_FOREACH( o, &conn->c_ops, o_next ) {
  94                 if ( o->o_msgid == id ) {
  95                         ldap_pvt_thread_mutex_lock( &o->o_abandonmutex );
  96                         o->o_abandon = 1;
  97                         ldap_pvt_thread_mutex_unlock( &o->o_abandonmutex );
  98                         goto done;
  99                 }
 100         }
 101
 102         LDAP_STAILQ_FOREACH( o, &conn->c_pending_ops, o_next ) {
 103                 if ( o->o_msgid == id ) {
 104                         LDAP_STAILQ_REMOVE( &conn->c_pending_ops, o, slap_op, o_next );
 105                         slap_op_free( o );
 106                         goto done;
 107                 }
 108         }
 109
 110 done:
 111         ldap_pvt_thread_mutex_unlock( &conn->c_mutex );
 112
 113 #ifdef NEW_LOGGING
 114         LDAP_LOG(( "operation", LDAP_LEVEL_ENTRY,
 115                 "do_abandon: conn: %d op=%ld %sfound\n",
 116                 conn->c_connid, (long)id, o ? "" : "not " ));
 117 #else
 118         Debug( LDAP_DEBUG_TRACE, "do_abandon: op=%ld %sfound\n",
 119                 (long) id, o ? "" : "not ", 0 );
 120 #endif
 121         return LDAP_SUCCESS;
 122 }