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

   1 /* txn.c - LDAP Transactions */
   2 /* $OpenLDAP$ */
   3 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
   4  *
   5  * Copyright 1998-2006 The OpenLDAP Foundation.
   6  * All rights reserved.
   7  *
   8  * Redistribution and use in source and binary forms, with or without
   9  * modification, are permitted only as authorized by the OpenLDAP
  10  * Public License.
  11  *
  12  * A copy of this license is available in the file LICENSE in the
  13  * top-level directory of the distribution or, alternatively, at
  14  * <http://www.OpenLDAP.org/license.html>.
  15  */
  16
  17 #include "portable.h"
  18
  19 #include <stdio.h>
  20
  21 #include <ac/krb.h>
  22 #include <ac/socket.h>
  23 #include <ac/string.h>
  24 #include <ac/unistd.h>
  25
  26 #include "slap.h"
  27
  28 #include <lber_pvt.h>
  29 #include <lutil.h>
  30
  31 #ifdef LDAP_X_TXN
  32 const struct berval slap_EXOP_TXN_START = BER_BVC(LDAP_EXOP_X_TXN_START);
  33 const struct berval slap_EXOP_TXN_END = BER_BVC(LDAP_EXOP_X_TXN_END);
  34
  35 int txn_start_extop(
  36         Operation *op, SlapReply *rs )
  37 {
  38         int rc;
  39         struct berval *bv;
  40
  41         Statslog( LDAP_DEBUG_STATS, "%s TXN START\n",
  42                 op->o_log_prefix, 0, 0, 0, 0 );
  43
  44         if( op->ore_reqdata != NULL ) {
  45                 rs->sr_text = "no request data expected";
  46                 return LDAP_PROTOCOL_ERROR;
  47         }
  48
  49         op->o_bd = op->o_conn->c_authz_backend;
  50         if( backend_check_restrictions( op, rs,
  51                 (struct berval *)&slap_EXOP_TXN_START ) != LDAP_SUCCESS )
  52         {
  53                 return rs->sr_err;
  54         }
  55
  56         /* acquire connection lock */
  57         ldap_pvt_thread_mutex_lock( &op->o_conn->c_mutex );
  58
  59         if( op->o_conn->c_txn ) {
  60                 rs->sr_text = "Too many transactions";
  61                 rc = LDAP_BUSY;
  62                 goto done;
  63         }
  64
  65         assert( op->o_conn->c_txn_backend == NULL );
  66         ++op->o_conn->c_txn;
  67
  68         bv = (struct berval *) ch_malloc( sizeof (struct berval) );
  69         bv->bv_len = 0;
  70         bv->bv_val = NULL;
  71
  72         rs->sr_rspdata = bv;
  73         rc = LDAP_SUCCESS;
  74
  75 done:
  76         /* release connection lock */
  77         ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex );
  78         return rc;
  79 }
  80
  81 int txn_spec_ctrl(
  82         Operation *op, SlapReply *rs, LDAPControl *ctrl )
  83 {
  84         if ( !ctrl->ldctl_iscritical ) {
  85                 rs->sr_text = "txnSpec control must be marked critical";
  86                 return LDAP_PROTOCOL_ERROR;
  87         }
  88         if( op->o_txnSpec ) {
  89                 rs->sr_text = "txnSpec control provided multiple times";
  90                 return LDAP_PROTOCOL_ERROR;
  91         }
  92
  93         if ( ctrl->ldctl_value.bv_val == NULL ) {
  94                 rs->sr_text = "no transaction identifier provided";
  95                 return LDAP_PROTOCOL_ERROR;
  96         }
  97         if ( ctrl->ldctl_value.bv_len != 0 ) {
  98                 rs->sr_text = "invalid transaction identifier";
  99                 return LDAP_X_TXN_ID_INVALID;
 100         }
 101
 102         op->o_txnSpec = SLAP_CONTROL_CRITICAL;
 103         return LDAP_SUCCESS;
 104 }
 105
 106 int txn_end_extop(
 107         Operation *op, SlapReply *rs )
 108 {
 109         int rc;
 110         BerElementBuffer berbuf;
 111         BerElement *ber = (BerElement *)&berbuf;
 112         ber_tag_t tag;
 113         ber_len_t len;
 114         ber_int_t commit=1;
 115         struct berval txnid;
 116
 117         Statslog( LDAP_DEBUG_STATS, "%s TXN END\n",
 118                 op->o_log_prefix, 0, 0, 0, 0 );
 119
 120         if( op->ore_reqdata == NULL ) {
 121                 rs->sr_text = "request data expected";
 122                 return LDAP_PROTOCOL_ERROR;
 123         }
 124         if( op->ore_reqdata->bv_len == 0 ) {
 125                 rs->sr_text = "empty request data";
 126                 return LDAP_PROTOCOL_ERROR;
 127         }
 128
 129         op->o_bd = op->o_conn->c_authz_backend;
 130         if( backend_check_restrictions( op, rs,
 131                 (struct berval *)&slap_EXOP_TXN_END ) != LDAP_SUCCESS )
 132         {
 133                 return rs->sr_err;
 134         }
 135
 136         ber_init2( ber, op->ore_reqdata, 0 );
 137
 138         tag = ber_scanf( ber, "{" /*}*/ );
 139         if( tag == LBER_ERROR ) {
 140                 rs->sr_text = "request data decoding error";
 141                 return LDAP_PROTOCOL_ERROR;
 142         }
 143
 144         tag = ber_peek_tag( ber, &len );
 145         assert( tag == LBER_BOOLEAN );
 146         if( tag == LBER_BOOLEAN ) {
 147                 tag = ber_scanf( ber, "b", &commit );
 148                 if( tag == LBER_ERROR ) {
 149                         rs->sr_text = "request data decoding error";
 150                         return LDAP_PROTOCOL_ERROR;
 151                 }
 152         }
 153
 154         tag = ber_scanf( ber, /*{*/ "m}", &txnid );
 155         if( tag == LBER_ERROR ) {
 156                 rs->sr_text = "request data decoding error";
 157                 return LDAP_PROTOCOL_ERROR;
 158         }
 159
 160         if( txnid.bv_len ) {
 161                 rs->sr_text = "invalid transaction identifier";
 162                 return LDAP_X_TXN_ID_INVALID;
 163         }
 164
 165         /* acquire connection lock */
 166         ldap_pvt_thread_mutex_lock( &op->o_conn->c_mutex );
 167
 168         if( op->o_conn->c_txn == 0 ) {
 169                 rs->sr_text = "invalid transaction identifier";
 170                 rc = LDAP_X_TXN_ID_INVALID;
 171                 goto done;
 172         }
 173
 174         if( commit ) {
 175                 rs->sr_text = "not yet implemented";
 176                 rc = LDAP_UNWILLING_TO_PERFORM;
 177
 178         } else {
 179                 rs->sr_text = "transaction aborted";
 180                 rc = LDAP_SUCCESS;;
 181         }
 182
 183         op->o_conn->c_txn = 0;
 184         op->o_conn->c_txn_backend = NULL;
 185
 186 done:
 187         /* release connection lock */
 188         ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex );
 189
 190         return rc;
 191 }
 192
 193 #endif /* LDAP_X_TXN */