]> git.sur5r.net Git - openldap/blob - servers/slapd/txn.c
Merge remote-tracking branch 'origin/mdb.master' into OPENLDAP_REL_ENG_2_5
[openldap] / 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-2014 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 */