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

   1 /* $OpenLDAP$ */
   2 /* cancel.c - LDAP cancel extended operation */
   3 /*
   4  * Copyright 1998-2002 The OpenLDAP Foundation, All Rights Reserved.
   5  * COPYING RESTRICTIONS APPLY, see COPYRIGHT file
   6  */
   7
   8 #include "portable.h"
   9
  10 #include <stdio.h>
  11
  12 #include <ac/krb.h>
  13 #include <ac/socket.h>
  14 #include <ac/string.h>
  15 #include <ac/unistd.h>
  16
  17 #include "slap.h"
  18
  19 #ifdef LDAP_EXOP_X_CANCEL
  20
  21 #include <lber_pvt.h>
  22 #include <lutil.h>
  23
  24 int cancel_extop(
  25         Connection *conn,
  26         Operation *op,
  27         const char *reqoid,
  28         struct berval *reqdata,
  29         char **rspoid,
  30         struct berval **rspdata,
  31         LDAPControl ***rspctrls,
  32         const char **text,
  33         BerVarray *refs )
  34 {
  35         Backend *be;
  36         int rc;
  37         int found = 0;
  38         int opid;
  39         BerElement *ber;
  40         int i;
  41
  42         assert( reqoid != NULL );
  43         assert( strcmp( LDAP_EXOP_X_CANCEL, reqoid ) == 0 );
  44
  45         if ( reqdata == NULL ) {
  46                 *text = "no message ID supplied";
  47                 return LDAP_PROTOCOL_ERROR;
  48         }
  49
  50         ber = ber_init( reqdata );
  51         if ( ber == NULL ) {
  52                 *text = "internal error";
  53                 return LDAP_OTHER;
  54         }
  55
  56         if ( ber_scanf( ber, "{i}", &opid ) == LBER_ERROR ) {
  57                 *text = "message ID parse failed";
  58                 return LDAP_PROTOCOL_ERROR;
  59         }
  60
  61         (void) ber_free( ber, 1 );
  62
  63         if ( opid < 0 ) {
  64                 *text = "message ID invalid";
  65                 return LDAP_PROTOCOL_ERROR;
  66         }
  67
  68         ldap_pvt_thread_mutex_lock( &conn->c_mutex );
  69         LDAP_STAILQ_FOREACH( op, &conn->c_pending_ops, o_next ) {
  70                 if ( op->o_msgid == opid ) {
  71                         LDAP_STAILQ_REMOVE( &conn->c_pending_ops, op, slap_op, o_next );
  72                         slap_op_free( op );
  73                         found = 1;
  74                         break;
  75                 }
  76         }
  77         ldap_pvt_thread_mutex_unlock( &conn->c_mutex );
  78
  79         if ( found )
  80                 return LDAP_SUCCESS;
  81
  82         found = 0;
  83         ldap_pvt_thread_mutex_lock( &conn->c_mutex );
  84         LDAP_STAILQ_FOREACH( op, &conn->c_ops, o_next ) {
  85                 if ( op->o_msgid == opid ) {
  86                         found = 1;
  87                         break;
  88                 }
  89         }
  90
  91         if ( !found ) {
  92 #ifdef LDAP_SYNC
  93                 for ( i = 0; i < nbackends; i++ ) {
  94                         if ( strncmp( backends[i].be_type, "bdb", 3 ) ) continue;
  95                         ldap_pvt_thread_mutex_unlock( &conn->c_mutex );
  96                         if ( bdb_cancel( &backends[i], conn, opid ) == LDAP_SUCCESS ) {
  97                                 return LDAP_SUCCESS;
  98                         } else {
  99                                 *text = "message ID not found";
 100                                 return LDAP_NO_SUCH_OPERATION;
 101                         }
 102                 }
 103 #else
 104                 *text = "message ID not found";
 105                 ldap_pvt_thread_mutex_unlock( &conn->c_mutex );
 106                 return LDAP_NO_SUCH_OPERATION;
 107 #endif
 108         }
 109
 110         if ( op->o_cancel != LDAP_CANCEL_NONE ) {
 111                 *text = "message ID already being cancelled";
 112                 ldap_pvt_thread_mutex_unlock( &conn->c_mutex );
 113                 return LDAP_PROTOCOL_ERROR;
 114         }
 115
 116         op->o_cancel = LDAP_CANCEL_REQ;
 117         ldap_pvt_thread_mutex_unlock( &conn->c_mutex );
 118
 119         while ( op->o_cancel == LDAP_CANCEL_REQ ) {
 120                 ldap_pvt_thread_yield();
 121         }
 122
 123         if ( op->o_cancel == LDAP_CANCEL_ACK ) {
 124                 rc = LDAP_SUCCESS;
 125         } else {
 126                 rc = op->o_cancel;
 127         }
 128
 129         op->o_cancel = LDAP_CANCEL_DONE;
 130
 131         return rc;
 132 }
 133
 134 #endif /* LDAP_EXOP_X_CANCEL */