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-2013 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/socket.h>
  22 #include <ac/string.h>
  23 #include <ac/unistd.h>
  24
  25 #include "slap.h"
  26
  27 #include <lber_pvt.h>
  28 #include <lutil.h>
  29
  30 #ifdef LDAP_X_TXN
  31 const struct berval slap_EXOP_TXN_START = BER_BVC(LDAP_EXOP_X_TXN_START);
  32 const struct berval slap_EXOP_TXN_END = BER_BVC(LDAP_EXOP_X_TXN_END);
  33
  34 int txn_start_extop(
  35         Operation *op, SlapReply *rs )
  36 {
  37         int rc;
  38         struct berval *bv;
  39
  40         Statslog( LDAP_DEBUG_STATS, "%s TXN START\n",
  41                 op->o_log_prefix, 0, 0, 0, 0 );
  42
  43         if( op->ore_reqdata != NULL ) {
  44                 rs->sr_text = "no request data expected";
  45                 return LDAP_PROTOCOL_ERROR;
  46         }
  47
  48         op->o_bd = op->o_conn->c_authz_backend;
  49         if( backend_check_restrictions( op, rs,
  50                 (struct berval *)&slap_EXOP_TXN_START ) != LDAP_SUCCESS )
  51         {
  52                 return rs->sr_err;
  53         }
  54
  55         /* acquire connection lock */
  56         ldap_pvt_thread_mutex_lock( &op->o_conn->c_mutex );
  57
  58         if( op->o_conn->c_txn != CONN_TXN_INACTIVE ) {
  59                 rs->sr_text = "Too many transactions";
  60                 rc = LDAP_BUSY;
  61                 goto done;
  62         }
  63
  64         assert( op->o_conn->c_txn_backend == NULL );
  65         op->o_conn->c_txn = CONN_TXN_SPECIFY;
  66
  67         bv = (struct berval *) ch_malloc( sizeof (struct berval) );
  68         bv->bv_len = 0;
  69         bv->bv_val = NULL;
  70
  71         rs->sr_rspdata = bv;
  72         rc = LDAP_SUCCESS;
  73
  74 done:
  75         /* release connection lock */
  76         ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex );
  77         return rc;
  78 }
  79
  80 int txn_spec_ctrl(
  81         Operation *op, SlapReply *rs, LDAPControl *ctrl )
  82 {
  83         if ( !ctrl->ldctl_iscritical ) {
  84                 rs->sr_text = "txnSpec control must be marked critical";
  85                 return LDAP_PROTOCOL_ERROR;
  86         }
  87         if( op->o_txnSpec ) {
  88                 rs->sr_text = "txnSpec control provided multiple times";
  89                 return LDAP_PROTOCOL_ERROR;
  90         }
  91
  92         if ( ctrl->ldctl_value.bv_val == NULL ) {
  93                 rs->sr_text = "no transaction identifier provided";
  94                 return LDAP_PROTOCOL_ERROR;
  95         }
  96         if ( ctrl->ldctl_value.bv_len != 0 ) {
  97                 rs->sr_text = "invalid transaction identifier";
  98                 return LDAP_X_TXN_ID_INVALID;
  99         }
 100
 101         if ( op->o_preread ) { /* temporary limitation */
 102                 rs->sr_text = "cannot perform pre-read in transaction";
 103                 return LDAP_UNWILLING_TO_PERFORM;
 104         }
 105         if ( op->o_postread ) { /* temporary limitation */
 106                 rs->sr_text = "cannot perform post-read in transaction";
 107                 return LDAP_UNWILLING_TO_PERFORM;
 108         }
 109
 110         op->o_txnSpec = SLAP_CONTROL_CRITICAL;
 111         return LDAP_SUCCESS;
 112 }
 113
 114 int txn_end_extop(
 115         Operation *op, SlapReply *rs )
 116 {
 117         int rc;
 118         BerElementBuffer berbuf;
 119         BerElement *ber = (BerElement *)&berbuf;
 120         ber_tag_t tag;
 121         ber_len_t len;
 122         ber_int_t commit=1;
 123         struct berval txnid;
 124
 125         Statslog( LDAP_DEBUG_STATS, "%s TXN END\n",
 126                 op->o_log_prefix, 0, 0, 0, 0 );
 127
 128         if( op->ore_reqdata == NULL ) {
 129                 rs->sr_text = "request data expected";
 130                 return LDAP_PROTOCOL_ERROR;
 131         }
 132         if( op->ore_reqdata->bv_len == 0 ) {
 133                 rs->sr_text = "empty request data";
 134                 return LDAP_PROTOCOL_ERROR;
 135         }
 136
 137         op->o_bd = op->o_conn->c_authz_backend;
 138         if( backend_check_restrictions( op, rs,
 139                 (struct berval *)&slap_EXOP_TXN_END ) != LDAP_SUCCESS )
 140         {
 141                 return rs->sr_err;
 142         }
 143
 144         ber_init2( ber, op->ore_reqdata, 0 );
 145
 146         tag = ber_scanf( ber, "{" /*}*/ );
 147         if( tag == LBER_ERROR ) {
 148                 rs->sr_text = "request data decoding error";
 149                 return LDAP_PROTOCOL_ERROR;
 150         }
 151
 152         tag = ber_peek_tag( ber, &len );
 153         if( tag == LBER_BOOLEAN ) {
 154                 tag = ber_scanf( ber, "b", &commit );
 155                 if( tag == LBER_ERROR ) {
 156                         rs->sr_text = "request data decoding error";
 157                         return LDAP_PROTOCOL_ERROR;
 158                 }
 159         }
 160
 161         tag = ber_scanf( ber, /*{*/ "m}", &txnid );
 162         if( tag == LBER_ERROR ) {
 163                 rs->sr_text = "request data decoding error";
 164                 return LDAP_PROTOCOL_ERROR;
 165         }
 166
 167         if( txnid.bv_len ) {
 168                 rs->sr_text = "invalid transaction identifier";
 169                 return LDAP_X_TXN_ID_INVALID;
 170         }
 171
 172         /* acquire connection lock */
 173         ldap_pvt_thread_mutex_lock( &op->o_conn->c_mutex );
 174
 175         if( op->o_conn->c_txn != CONN_TXN_SPECIFY ) {
 176                 rs->sr_text = "invalid transaction identifier";
 177                 rc = LDAP_X_TXN_ID_INVALID;
 178                 goto done;
 179         }
 180         op->o_conn->c_txn = CONN_TXN_SETTLE;
 181
 182         if( commit ) {
 183                 if ( op->o_abandon ) {
 184                 }
 185
 186                 if( LDAP_STAILQ_EMPTY(&op->o_conn->c_txn_ops) ) {
 187                         /* no updates to commit */
 188                         rs->sr_text = "no updates to commit";
 189                         rc = LDAP_OPERATIONS_ERROR;
 190                         goto settled;
 191                 }
 192
 193                 rs->sr_text = "not yet implemented";
 194                 rc = LDAP_UNWILLING_TO_PERFORM;
 195
 196         } else {
 197                 rs->sr_text = "transaction aborted";
 198                 rc = LDAP_SUCCESS;;
 199         }
 200
 201 drain:
 202         /* drain txn ops list */
 203
 204 settled:
 205         assert( LDAP_STAILQ_EMPTY(&op->o_conn->c_txn_ops) );
 206         assert( op->o_conn->c_txn == CONN_TXN_SETTLE );
 207         op->o_conn->c_txn = CONN_TXN_INACTIVE;
 208         op->o_conn->c_txn_backend = NULL;
 209
 210 done:
 211         /* release connection lock */
 212         ldap_pvt_thread_mutex_unlock( &op->o_conn->c_mutex );
 213
 214         return rc;
 215 }
 216
 217 #endif /* LDAP_X_TXN */