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, ENTRY, "conn: %d do_abandon\n", conn->c_connid, 0, 0);
  39 #else
  40         Debug( LDAP_DEBUG_TRACE, "do_abandon\n", 0, 0, 0 );
  41 #endif
  42
  43         /*
  44          * Parse the abandon request.  It looks like this:
  45          *
  46          *      AbandonRequest := MessageID
  47          */
  48
  49         if ( ber_scanf( op->o_ber, "i", &id ) == LBER_ERROR ) {
  50 #ifdef NEW_LOGGING
  51                 LDAP_LOG( OPERATION, ERR,
  52                         "conn: %d do_abandon: ber_scanf failed\n", conn->c_connid, 0, 0 );
  53 #else
  54                 Debug( LDAP_DEBUG_ANY, "do_abandon: ber_scanf failed\n", 0, 0 ,0 );
  55 #endif
  56                 send_ldap_disconnect( conn, op,
  57                         LDAP_PROTOCOL_ERROR, "decoding error" );
  58                 return -1;
  59         }
  60
  61         if( (rc = get_ctrls( conn, op, 0 )) != LDAP_SUCCESS ) {
  62                 Debug( LDAP_DEBUG_ANY, "do_abandon: get_ctrls failed\n", 0, 0 ,0 );
  63                 return rc;
  64         }
  65
  66 #ifdef NEW_LOGGING
  67         LDAP_LOG( OPERATION, ARGS, "do_abandon: conn: %d  id=%ld\n",
  68                 conn->c_connid, (long) id, 0 );
  69 #else
  70         Debug( LDAP_DEBUG_ARGS, "do_abandon: id=%ld\n", (long) id, 0 ,0 );
  71 #endif
  72
  73         if( id <= 0 ) {
  74 #ifdef NEW_LOGGING
  75                 LDAP_LOG( OPERATION, ERR,
  76                         "do_abandon: conn: %d bad msgid %ld\n",
  77                         conn->c_connid, (long) id, 0 );
  78 #else
  79                 Debug( LDAP_DEBUG_ANY,
  80                         "do_abandon: bad msgid %ld\n", (long) id, 0, 0 );
  81 #endif
  82                 return LDAP_SUCCESS;
  83         }
  84
  85         ldap_pvt_thread_mutex_lock( &conn->c_mutex );
  86         /*
  87          * find the operation being abandoned and set the o_abandon
  88          * flag.  It's up to the backend to periodically check this
  89          * flag and abort the operation at a convenient time.
  90          */
  91
  92         LDAP_STAILQ_FOREACH( o, &conn->c_ops, o_next ) {
  93                 if ( o->o_msgid == id ) {
  94                         o->o_abandon = 1;
  95                         goto done;
  96                 }
  97         }
  98
  99         LDAP_STAILQ_FOREACH( o, &conn->c_pending_ops, o_next ) {
 100                 if ( o->o_msgid == id ) {
 101                         LDAP_STAILQ_REMOVE( &conn->c_pending_ops, o, slap_op, o_next );
 102                         slap_op_free( o );
 103                         goto done;
 104                 }
 105         }
 106
 107 done:
 108         ldap_pvt_thread_mutex_unlock( &conn->c_mutex );
 109
 110 #ifdef NEW_LOGGING
 111         LDAP_LOG( OPERATION, ENTRY,
 112                 "do_abandon: conn: %d op=%ld %sfound\n",
 113                 conn->c_connid, (long)id, o ? "" : "not " );
 114 #else
 115         Debug( LDAP_DEBUG_TRACE, "do_abandon: op=%ld %sfound\n",
 116                 (long) id, o ? "" : "not ", 0 );
 117 #endif
 118         return LDAP_SUCCESS;
 119 }