]> git.sur5r.net Git - openldap/blob - servers/slapd/modify.c
allow to programmatically register new response code names
[openldap] / servers / slapd / modify.c
1 /* $OpenLDAP$ */
2 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
3  *
4  * Copyright 1998-2007 The OpenLDAP Foundation.
5  * All rights reserved.
6  *
7  * Redistribution and use in source and binary forms, with or without
8  * modification, are permitted only as authorized by the OpenLDAP
9  * Public License.
10  *
11  * A copy of this license is available in the file LICENSE in the
12  * top-level directory of the distribution or, alternatively, at
13  * <http://www.OpenLDAP.org/license.html>.
14  */
15 /* Portions Copyright (c) 1995 Regents of the University of Michigan.
16  * All rights reserved.
17  *
18  * Redistribution and use in source and binary forms are permitted
19  * provided that this notice is preserved and that due credit is given
20  * to the University of Michigan at Ann Arbor. The name of the University
21  * may not be used to endorse or promote products derived from this
22  * software without specific prior written permission. This software
23  * is provided ``as is'' without express or implied warranty.
24  */
25
26 #include "portable.h"
27
28 #include <stdio.h>
29
30 #include <ac/socket.h>
31 #include <ac/string.h>
32 #include <ac/time.h>
33
34 #include "slap.h"
35 #include "lutil.h"
36
37
38 int
39 do_modify(
40     Operation   *op,
41     SlapReply   *rs )
42 {
43         struct berval dn = BER_BVNULL;
44         char            textbuf[ SLAP_TEXT_BUFLEN ];
45         size_t          textlen = sizeof( textbuf );
46 #ifdef LDAP_DEBUG
47         Modifications   *tmp;
48 #endif
49
50         Debug( LDAP_DEBUG_TRACE, "%s do_modify\n",
51                 op->o_log_prefix, 0, 0 );
52         /*
53          * Parse the modify request.  It looks like this:
54          *
55          *      ModifyRequest := [APPLICATION 6] SEQUENCE {
56          *              name    DistinguishedName,
57          *              mods    SEQUENCE OF SEQUENCE {
58          *                      operation       ENUMERATED {
59          *                              add     (0),
60          *                              delete  (1),
61          *                              replace (2)
62          *                      },
63          *                      modification    SEQUENCE {
64          *                              type    AttributeType,
65          *                              values  SET OF AttributeValue
66          *                      }
67          *              }
68          *      }
69          */
70
71         if ( ber_scanf( op->o_ber, "{m" /*}*/, &dn ) == LBER_ERROR ) {
72                 Debug( LDAP_DEBUG_ANY, "%s do_modify: ber_scanf failed\n",
73                         op->o_log_prefix, 0, 0 );
74                 send_ldap_discon( op, rs, LDAP_PROTOCOL_ERROR, "decoding error" );
75                 return SLAPD_DISCONNECT;
76         }
77
78         Debug( LDAP_DEBUG_ARGS, "%s do_modify: dn (%s)\n",
79                 op->o_log_prefix, dn.bv_val, 0 );
80
81         rs->sr_err = slap_parse_modlist( op, rs, op->o_ber, &op->oq_modify );
82         if ( rs->sr_err != LDAP_SUCCESS ) {
83                 Debug( LDAP_DEBUG_ANY, "%s do_modify: slap_parse_modlist failed err=%d msg=%s\n",
84                         op->o_log_prefix, rs->sr_err, rs->sr_text );
85                 goto cleanup;
86         }
87
88         if( get_ctrls( op, rs, 1 ) != LDAP_SUCCESS ) {
89                 Debug( LDAP_DEBUG_ANY, "%s do_modify: get_ctrls failed\n",
90                         op->o_log_prefix, 0, 0 );
91                 goto cleanup;
92         }
93
94         rs->sr_err = dnPrettyNormal( NULL, &dn, &op->o_req_dn, &op->o_req_ndn,
95                 op->o_tmpmemctx );
96         if( rs->sr_err != LDAP_SUCCESS ) {
97                 Debug( LDAP_DEBUG_ANY, "%s do_modify: invalid dn (%s)\n",
98                         op->o_log_prefix, dn.bv_val, 0 );
99                 send_ldap_error( op, rs, LDAP_INVALID_DN_SYNTAX, "invalid DN" );
100                 goto cleanup;
101         }
102
103         op->orm_no_opattrs = 0;
104
105 #ifdef LDAP_DEBUG
106         Debug( LDAP_DEBUG_ARGS, "%s modifications:\n",
107                         op->o_log_prefix, 0, 0 );
108
109         for ( tmp = op->orm_modlist; tmp != NULL; tmp = tmp->sml_next ) {
110                 Debug( LDAP_DEBUG_ARGS, "\t%s: %s\n",
111                         tmp->sml_op == LDAP_MOD_ADD ? "add" :
112                                 (tmp->sml_op == LDAP_MOD_INCREMENT ? "increment" :
113                                 (tmp->sml_op == LDAP_MOD_DELETE ? "delete" :
114                                         "replace")), tmp->sml_type.bv_val, 0 );
115
116                 if ( tmp->sml_values == NULL ) {
117                         Debug( LDAP_DEBUG_ARGS, "%s\n",
118                            "\t\tno values", NULL, NULL );
119                 } else if ( BER_BVISNULL( &tmp->sml_values[ 0 ] ) ) {
120                         Debug( LDAP_DEBUG_ARGS, "%s\n",
121                            "\t\tzero values", NULL, NULL );
122                 } else if ( BER_BVISNULL( &tmp->sml_values[ 1 ] ) ) {
123                         Debug( LDAP_DEBUG_ARGS, "%s, length %ld\n",
124                            "\t\tone value", (long) tmp->sml_values[0].bv_len, NULL );
125                 } else {
126                         Debug( LDAP_DEBUG_ARGS, "%s\n",
127                            "\t\tmultiple values", NULL, NULL );
128                 }
129         }
130
131         if ( StatslogTest( LDAP_DEBUG_STATS ) ) {
132                 char abuf[BUFSIZ/2], *ptr = abuf;
133                 int len = 0;
134
135                 Statslog( LDAP_DEBUG_STATS, "%s MOD dn=\"%s\"\n",
136                         op->o_log_prefix, op->o_req_dn.bv_val, 0, 0, 0 );
137
138                 for ( tmp = op->orm_modlist; tmp != NULL; tmp = tmp->sml_next ) {
139                         if (len + 1 + tmp->sml_type.bv_len > sizeof(abuf)) {
140                                 Statslog( LDAP_DEBUG_STATS, "%s MOD attr=%s\n",
141                                     op->o_log_prefix, abuf, 0, 0, 0 );
142
143                                 len = 0;
144                                 ptr = abuf;
145
146                                 if( 1 + tmp->sml_type.bv_len > sizeof(abuf)) {
147                                         Statslog( LDAP_DEBUG_STATS, "%s MOD attr=%s\n",
148                                                 op->o_log_prefix, tmp->sml_type.bv_val, 0, 0, 0 );
149                                         continue;
150                                 }
151                         }
152                         if (len) {
153                                 *ptr++ = ' ';
154                                 len++;
155                         }
156                         ptr = lutil_strcopy(ptr, tmp->sml_type.bv_val);
157                         len += tmp->sml_type.bv_len;
158                 }
159                 if (len) {
160                         Statslog( LDAP_DEBUG_STATS, "%s MOD attr=%s\n",
161                                 op->o_log_prefix, abuf, 0, 0, 0 );
162                 }
163         }
164 #endif  /* LDAP_DEBUG */
165
166         rs->sr_err = slap_mods_check( op, op->orm_modlist,
167                 &rs->sr_text, textbuf, textlen, NULL );
168
169         if ( rs->sr_err != LDAP_SUCCESS ) {
170                 send_ldap_result( op, rs );
171                 goto cleanup;
172         }
173
174         op->o_bd = frontendDB;
175         rs->sr_err = frontendDB->be_modify( op, rs );
176
177 #ifdef LDAP_X_TXN
178         if( rs->sr_err == LDAP_X_TXN_SPECIFY_OKAY ) {
179                 /* skip cleanup */
180                 return rs->sr_err;
181         }
182 #endif
183
184 cleanup:
185         op->o_tmpfree( op->o_req_dn.bv_val, op->o_tmpmemctx );
186         op->o_tmpfree( op->o_req_ndn.bv_val, op->o_tmpmemctx );
187         if ( op->orm_modlist != NULL ) slap_mods_free( op->orm_modlist, 1 );
188
189         return rs->sr_err;
190 }
191
192 int
193 fe_op_modify( Operation *op, SlapReply *rs )
194 {
195         BackendDB       *op_be, *bd = op->o_bd;
196         char            textbuf[ SLAP_TEXT_BUFLEN ];
197         size_t          textlen = sizeof( textbuf );
198         
199         if ( BER_BVISEMPTY( &op->o_req_ndn ) ) {
200                 Debug( LDAP_DEBUG_ANY, "%s do_modify: root dse!\n",
201                         op->o_log_prefix, 0, 0 );
202                 send_ldap_error( op, rs, LDAP_UNWILLING_TO_PERFORM,
203                         "modify upon the root DSE not supported" );
204                 goto cleanup;
205
206         } else if ( bvmatch( &op->o_req_ndn, &frontendDB->be_schemandn ) ) {
207                 Debug( LDAP_DEBUG_ANY, "%s do_modify: subschema subentry!\n",
208                         op->o_log_prefix, 0, 0 );
209                 send_ldap_error( op, rs, LDAP_UNWILLING_TO_PERFORM,
210                         "modification of subschema subentry not supported" );
211                 goto cleanup;
212         }
213
214         /*
215          * We could be serving multiple database backends.  Select the
216          * appropriate one, or send a referral to our "referral server"
217          * if we don't hold it.
218          */
219         op->o_bd = select_backend( &op->o_req_ndn, 1 );
220         if ( op->o_bd == NULL ) {
221                 op->o_bd = bd;
222                 rs->sr_ref = referral_rewrite( default_referral,
223                         NULL, &op->o_req_dn, LDAP_SCOPE_DEFAULT );
224                 if ( !rs->sr_ref ) {
225                         rs->sr_ref = default_referral;
226                 }
227
228                 if ( rs->sr_ref != NULL ) {
229                         rs->sr_err = LDAP_REFERRAL;
230                         send_ldap_result( op, rs );
231
232                         if ( rs->sr_ref != default_referral ) {
233                                 ber_bvarray_free( rs->sr_ref );
234                         }
235
236                 } else {
237                         send_ldap_error( op, rs, LDAP_UNWILLING_TO_PERFORM,
238                                 "no global superior knowledge" );
239                 }
240                 goto cleanup;
241         }
242
243         /* If we've got a glued backend, check the real backend */
244         op_be = op->o_bd;
245         if ( SLAP_GLUE_INSTANCE( op->o_bd )) {
246                 op->o_bd = select_backend( &op->o_req_ndn, 0 );
247         }
248
249         /* check restrictions */
250         if ( backend_check_restrictions( op, rs, NULL ) != LDAP_SUCCESS ) {
251                 send_ldap_result( op, rs );
252                 goto cleanup;
253         }
254
255         /* check for referrals */
256         if ( backend_check_referrals( op, rs ) != LDAP_SUCCESS ) {
257                 goto cleanup;
258         }
259
260         rs->sr_err = slap_mods_obsolete_check( op, op->orm_modlist,
261                 &rs->sr_text, textbuf, textlen );
262         if ( rs->sr_err != LDAP_SUCCESS ) {
263                 send_ldap_result( op, rs );
264                 goto cleanup;
265         }
266
267         /* check for modify/increment support */
268         if ( op->orm_increment && !SLAP_INCREMENT( op->o_bd ) ) {
269                 send_ldap_error( op, rs, LDAP_UNWILLING_TO_PERFORM,
270                         "modify/increment not supported in context" );
271         }
272
273         /*
274          * do the modify if 1 && (2 || 3)
275          * 1) there is a modify function implemented in this backend;
276          * 2) this backend is master for what it holds;
277          * 3) it's a replica and the dn supplied is the update_ndn.
278          */
279         if ( op->o_bd->be_modify ) {
280                 /* do the update here */
281                 int repl_user = be_isupdate( op );
282
283                 /*
284                  * Multimaster slapd does not have to check for replicator dn
285                  * because it accepts each modify request
286                  */
287                 if ( !SLAP_SINGLE_SHADOW(op->o_bd) || repl_user ) {
288                         int update = !BER_BVISEMPTY( &op->o_bd->be_update_ndn );
289
290                         op->o_bd = op_be;
291
292                         if ( !update ) {
293                                 rs->sr_err = slap_mods_no_user_mod_check( op, op->orm_modlist,
294                                         &rs->sr_text, textbuf, textlen );
295                                 if ( rs->sr_err != LDAP_SUCCESS ) {
296                                         send_ldap_result( op, rs );
297                                         goto cleanup;
298                                 }
299                         }
300                         op->o_bd->be_modify( op, rs );
301
302                 } else { /* send a referral */
303                         BerVarray defref = op->o_bd->be_update_refs
304                                 ? op->o_bd->be_update_refs : default_referral;
305                         if ( defref != NULL ) {
306                                 rs->sr_ref = referral_rewrite( defref,
307                                         NULL, &op->o_req_dn,
308                                         LDAP_SCOPE_DEFAULT );
309                                 if ( rs->sr_ref == NULL ) {
310                                         /* FIXME: must duplicate, because
311                                          * overlays may muck with it */
312                                         rs->sr_ref = defref;
313                                 }
314                                 rs->sr_err = LDAP_REFERRAL;
315                                 send_ldap_result( op, rs );
316                                 if ( rs->sr_ref != defref ) {
317                                         ber_bvarray_free( rs->sr_ref );
318                                 }
319
320                         } else {
321                                 send_ldap_error( op, rs, LDAP_UNWILLING_TO_PERFORM,
322                                         "shadow context; no update referral" );
323                         }
324                 }
325
326         } else {
327                 send_ldap_error( op, rs, LDAP_UNWILLING_TO_PERFORM,
328                     "operation not supported within namingContext" );
329         }
330
331 cleanup:;
332         op->o_bd = bd;
333         return rs->sr_err;
334 }
335
336 /*
337  * Obsolete constraint checking.
338  */
339 int
340 slap_mods_obsolete_check(
341         Operation *op,
342         Modifications *ml,
343         const char **text,
344         char *textbuf,
345         size_t textlen )
346 {
347         if( get_relax( op ) ) return LDAP_SUCCESS;
348
349         for ( ; ml != NULL; ml = ml->sml_next ) {
350                 if ( is_at_obsolete( ml->sml_desc->ad_type ) &&
351                         (( ml->sml_op != LDAP_MOD_REPLACE &&
352                                 ml->sml_op != LDAP_MOD_DELETE ) ||
353                                         ml->sml_values != NULL ))
354                 {
355                         /*
356                          * attribute is obsolete,
357                          * only allow replace/delete with no values
358                          */
359                         snprintf( textbuf, textlen,
360                                 "%s: attribute is obsolete",
361                                 ml->sml_type.bv_val );
362                         *text = textbuf;
363                         return LDAP_CONSTRAINT_VIOLATION;
364                 }
365         }
366
367         return LDAP_SUCCESS;
368 }
369
370 /*
371  * No-user-modification constraint checking.
372  */
373 int
374 slap_mods_no_user_mod_check(
375         Operation *op,
376         Modifications *ml,
377         const char **text,
378         char *textbuf,
379         size_t textlen )
380 {
381         for ( ; ml != NULL; ml = ml->sml_next ) {
382                 if ( !is_at_no_user_mod( ml->sml_desc->ad_type ) ) {
383                         continue;
384                 }
385
386                 if ( get_relax( op ) ) {
387                         if ( ml->sml_desc->ad_type->sat_flags & SLAP_AT_MANAGEABLE ) {
388                                 ml->sml_flags |= SLAP_MOD_MANAGING;
389                                 continue;
390                         }
391
392                         /* attribute not manageable */
393                         snprintf( textbuf, textlen,
394                                 "%s: no-user-modification attribute not manageable",
395                                 ml->sml_type.bv_val );
396
397                 } else {
398                         /* user modification disallowed */
399                         snprintf( textbuf, textlen,
400                                 "%s: no user modification allowed",
401                                 ml->sml_type.bv_val );
402                 }
403
404                 *text = textbuf;
405                 return LDAP_CONSTRAINT_VIOLATION;
406         }
407
408         return LDAP_SUCCESS;
409 }
410
411 int
412 slap_mods_no_repl_user_mod_check(
413         Operation *op,
414         Modifications *ml,
415         const char **text,
416         char *textbuf,
417         size_t textlen )
418 {
419         Modifications *mods;
420         Modifications *modp;
421
422         for ( mods = ml; mods != NULL; mods = mods->sml_next ) {
423                 assert( mods->sml_op == LDAP_MOD_ADD );
424
425                 /* check doesn't already appear */
426                 for ( modp = ml; modp != NULL; modp = modp->sml_next ) {
427                         if ( mods->sml_desc == modp->sml_desc && mods != modp ) {
428                                 snprintf( textbuf, textlen,
429                                         "attribute '%s' provided more than once",
430                                         mods->sml_desc->ad_cname.bv_val );
431                                 *text = textbuf;
432                                 return LDAP_TYPE_OR_VALUE_EXISTS;
433                         }
434                 }
435         }
436
437         return LDAP_SUCCESS;
438 }
439
440 /*
441  * Do basic attribute type checking and syntax validation.
442  */
443 int slap_mods_check(
444         Operation *op,
445         Modifications *ml,
446         const char **text,
447         char *textbuf,
448         size_t textlen,
449         void *ctx )
450 {
451         int rc;
452
453         for( ; ml != NULL; ml = ml->sml_next ) {
454                 AttributeDescription *ad = NULL;
455
456                 /* convert to attribute description */
457                 if ( ml->sml_desc == NULL ) {
458                         rc = slap_bv2ad( &ml->sml_type, &ml->sml_desc, text );
459                         if( rc != LDAP_SUCCESS ) {
460                                 if ( get_no_schema_check( op )) {
461                                         rc = slap_bv2undef_ad( &ml->sml_type, &ml->sml_desc,
462                                                 text, 0 );
463                                 }
464                         }
465                         if( rc != LDAP_SUCCESS ) {
466                                 snprintf( textbuf, textlen, "%s: %s",
467                                         ml->sml_type.bv_val, *text );
468                                 *text = textbuf;
469                                 return rc;
470                         }
471                 }
472
473                 ad = ml->sml_desc;
474
475                 if( slap_syntax_is_binary( ad->ad_type->sat_syntax )
476                         && !slap_ad_is_binary( ad ))
477                 {
478                         /* attribute requires binary transfer */
479                         snprintf( textbuf, textlen,
480                                 "%s: requires ;binary transfer",
481                                 ml->sml_type.bv_val );
482                         *text = textbuf;
483                         return LDAP_UNDEFINED_TYPE;
484                 }
485
486                 if( !slap_syntax_is_binary( ad->ad_type->sat_syntax )
487                         && slap_ad_is_binary( ad ))
488                 {
489                         /* attribute does not require binary transfer */
490                         snprintf( textbuf, textlen,
491                                 "%s: disallows ;binary transfer",
492                                 ml->sml_type.bv_val );
493                         *text = textbuf;
494                         return LDAP_UNDEFINED_TYPE;
495                 }
496
497                 if( slap_ad_is_tag_range( ad )) {
498                         /* attribute requires binary transfer */
499                         snprintf( textbuf, textlen,
500                                 "%s: inappropriate use of tag range option",
501                                 ml->sml_type.bv_val );
502                         *text = textbuf;
503                         return LDAP_UNDEFINED_TYPE;
504                 }
505
506 #if 0
507                 if ( is_at_obsolete( ad->ad_type ) &&
508                         (( ml->sml_op != LDAP_MOD_REPLACE &&
509                                 ml->sml_op != LDAP_MOD_DELETE ) ||
510                                         ml->sml_values != NULL ))
511                 {
512                         /*
513                          * attribute is obsolete,
514                          * only allow replace/delete with no values
515                          */
516                         snprintf( textbuf, textlen,
517                                 "%s: attribute is obsolete",
518                                 ml->sml_type.bv_val );
519                         *text = textbuf;
520                         return LDAP_CONSTRAINT_VIOLATION;
521                 }
522 #endif
523
524                 if ( ml->sml_op == LDAP_MOD_INCREMENT &&
525 #ifdef SLAPD_REAL_SYNTAX
526                         !is_at_syntax( ad->ad_type, SLAPD_REAL_SYNTAX ) &&
527 #endif
528                         !is_at_syntax( ad->ad_type, SLAPD_INTEGER_SYNTAX ) )
529                 {
530                         /*
531                          * attribute values must be INTEGER or REAL
532                          */
533                         snprintf( textbuf, textlen,
534                                 "%s: attribute syntax inappropriate for increment",
535                                 ml->sml_type.bv_val );
536                         *text = textbuf;
537                         return LDAP_CONSTRAINT_VIOLATION;
538                 }
539
540                 /*
541                  * check values
542                  */
543                 if( ml->sml_values != NULL ) {
544                         ber_len_t nvals;
545                         slap_syntax_validate_func *validate =
546                                 ad->ad_type->sat_syntax->ssyn_validate;
547                         slap_syntax_transform_func *pretty =
548                                 ad->ad_type->sat_syntax->ssyn_pretty;
549  
550                         if( !pretty && !validate ) {
551                                 *text = "no validator for syntax";
552                                 snprintf( textbuf, textlen,
553                                         "%s: no validator for syntax %s",
554                                         ml->sml_type.bv_val,
555                                         ad->ad_type->sat_syntax->ssyn_oid );
556                                 *text = textbuf;
557                                 return LDAP_INVALID_SYNTAX;
558                         }
559
560                         /*
561                          * check that each value is valid per syntax
562                          *      and pretty if appropriate
563                          */
564                         for ( nvals = 0; !BER_BVISNULL( &ml->sml_values[nvals] ); nvals++ ) {
565                                 struct berval pval;
566
567                                 if ( pretty ) {
568                                         rc = ordered_value_pretty( ad,
569                                                 &ml->sml_values[nvals], &pval, ctx );
570                                 } else {
571                                         rc = ordered_value_validate( ad,
572                                                 &ml->sml_values[nvals], ml->sml_op );
573                                 }
574
575                                 if( rc != 0 ) {
576                                         snprintf( textbuf, textlen,
577                                                 "%s: value #%ld invalid per syntax",
578                                                 ml->sml_type.bv_val, (long) nvals );
579                                         *text = textbuf;
580                                         return LDAP_INVALID_SYNTAX;
581                                 }
582
583                                 if( pretty ) {
584                                         ber_memfree_x( ml->sml_values[nvals].bv_val, ctx );
585                                         ml->sml_values[nvals] = pval;
586                                 }
587                         }
588                         ml->sml_numvals = nvals;
589
590                         /*
591                          * a rough single value check... an additional check is needed
592                          * to catch add of single value to existing single valued attribute
593                          */
594                         if ((ml->sml_op == LDAP_MOD_ADD || ml->sml_op == LDAP_MOD_REPLACE)
595                                 && nvals > 1 && is_at_single_value( ad->ad_type ))
596                         {
597                                 snprintf( textbuf, textlen,
598                                         "%s: multiple values provided",
599                                         ml->sml_type.bv_val );
600                                 *text = textbuf;
601                                 return LDAP_CONSTRAINT_VIOLATION;
602                         }
603
604                         /* if the type has a normalizer, generate the
605                          * normalized values. otherwise leave them NULL.
606                          *
607                          * this is different from the rule for attributes
608                          * in an entry - in an attribute list, the normalized
609                          * value is set equal to the non-normalized value
610                          * when there is no normalizer.
611                          */
612                         if( nvals && ad->ad_type->sat_equality &&
613                                 ad->ad_type->sat_equality->smr_normalize )
614                         {
615                                 ml->sml_nvalues = ber_memalloc_x(
616                                         (nvals+1)*sizeof(struct berval), ctx );
617
618                                 for ( nvals = 0; !BER_BVISNULL( &ml->sml_values[nvals] ); nvals++ ) {
619                                         rc = ordered_value_normalize(
620                                                 SLAP_MR_VALUE_OF_ATTRIBUTE_SYNTAX,
621                                                 ad,
622                                                 ad->ad_type->sat_equality,
623                                                 &ml->sml_values[nvals], &ml->sml_nvalues[nvals], ctx );
624                                         if ( rc ) {
625                                                 Debug( LDAP_DEBUG_ANY,
626                                                         "<= str2entry NULL (ssyn_normalize %d)\n",
627                                                         rc, 0, 0 );
628                                                 snprintf( textbuf, textlen,
629                                                         "%s: value #%ld normalization failed",
630                                                         ml->sml_type.bv_val, (long) nvals );
631                                                 *text = textbuf;
632                                                 BER_BVZERO( &ml->sml_nvalues[nvals] );
633                                                 return rc;
634                                         }
635                                 }
636
637                                 BER_BVZERO( &ml->sml_nvalues[nvals] );
638                         }
639
640                         /* check for duplicates, but ignore Deletes.
641                          */
642                         if( nvals > 1 && ml->sml_op != LDAP_MOD_DELETE ) {
643                                 int i;
644                                 rc = slap_sort_vals( ml, text, &i, ctx );
645                                 if ( rc == LDAP_TYPE_OR_VALUE_EXISTS ) {
646                                         /* value exists already */
647                                         snprintf( textbuf, textlen,
648                                                 "%s: value #%d provided more than once",
649                                                 ml->sml_desc->ad_cname.bv_val, i );
650                                         *text = textbuf;
651                                 }
652                                 if ( rc )
653                                         return rc;
654                         }
655                 } else {
656                         ml->sml_numvals = 0;
657                 }
658         }
659
660         return LDAP_SUCCESS;
661 }
662
663 /* Sort a set of values. An (Attribute *) may be used interchangeably here
664  * instead of a (Modifications *) structure.
665  *
666  * Uses Quicksort + Insertion sort for small arrays
667  */
668
669 int
670 slap_sort_vals(
671         Modifications *ml,
672         const char **text,
673         int *dup,
674         void *ctx )
675 {
676         AttributeDescription *ad;
677         MatchingRule *mr;
678         int istack[sizeof(int)*16];
679         int i, j, k, l, ir, jstack, match, *ix, itmp, nvals, rc;
680         int is_norm;
681         struct berval a, *cv;
682
683 #define SMALL   8
684 #define SWAP(a,b,tmp)   tmp=(a);(a)=(b);(b)=tmp
685 #define COMP(a,b)       match=0; rc = ordered_value_match( &match, \
686                                                 ad, mr, SLAP_MR_EQUALITY \
687                                                                 | SLAP_MR_VALUE_OF_ATTRIBUTE_SYNTAX \
688                                                                 | SLAP_MR_ASSERTED_VALUE_NORMALIZED_MATCH \
689                                                                 | SLAP_MR_ATTRIBUTE_VALUE_NORMALIZED_MATCH, \
690                                                                 &(a), &(b), text );
691
692 #define IX(x)   ix[x]
693 #define EXCH(x,y)       SWAP(ix[x],ix[y],itmp)
694 #define SETA(x) itmp = ix[x]; a = cv[itmp]
695 #define GETA(x) ix[x] = itmp;
696 #define SET(x,y)        ix[x] = ix[y]
697
698         ad = ml->sml_desc;
699         nvals = ml->sml_numvals;
700
701         /* For Modifications, sml_nvalues is NULL if normalization wasn't needed.
702          * For Attributes, sml_nvalues == sml_values when normalization isn't needed.
703          */
704         if ( ml->sml_nvalues && ml->sml_nvalues != ml->sml_values ) {
705                 cv = ml->sml_nvalues;
706                 is_norm = 1;
707         } else {
708                 cv = ml->sml_values;
709                 is_norm = 0;
710         }
711
712         if ( ad == slap_schema.si_ad_objectClass )
713                 mr = NULL;      /* shortcut matching */
714         else
715                 mr = ad->ad_type->sat_equality;
716
717         /* record indices to preserve input ordering */
718         ix = slap_sl_malloc( nvals * sizeof(int), ctx );
719         for (i=0; i<nvals; i++) ix[i] = i;
720
721         ir = nvals-1;
722         l = 0;
723         jstack = 0;
724
725         for(;;) {
726                 if (ir - l < SMALL) {   /* Insertion sort */
727                         match=1;
728                         for (j=l+1;j<=ir;j++) {
729                                 SETA(j);
730                                 for (i=j-1;i>=0;i--) {
731                                         COMP(cv[IX(i)], a);
732                                         if ( match <= 0 )
733                                                 break;
734                                         SET(i+1,i);
735                                 }
736                                 GETA(i+1);
737                                 if ( match == 0 ) goto done;
738                         }
739                         if ( jstack == 0 ) break;
740                         if ( match == 0 ) break;
741                         ir = istack[jstack--];
742                         l = istack[jstack--];
743                 } else {
744                         k = (l + ir) >> 1;      /* Choose median of left, center, right */
745                         EXCH(k, l+1);
746                         COMP( cv[IX(l)], cv[IX(ir)] );
747                         if ( match > 0 ) {
748                                 EXCH(l, ir);
749                         } else if ( match == 0 ) {
750                                 i = ir;
751                                 break;
752                         }
753                         COMP( cv[IX(l+1)], cv[IX(ir)] );
754                         if ( match > 0 ) {
755                                 EXCH(l+1, ir);
756                         } else if ( match == 0 ) {
757                                 i = ir;
758                                 break;
759                         }
760                         COMP( cv[IX(l)], cv[IX(l+1)] );
761                         if ( match > 0 ) {
762                                 EXCH(l, l+1);
763                         } else if ( match == 0 ) {
764                                 i = l;
765                                 break;
766                         }
767                         i = l+1;
768                         j = ir;
769                         a = cv[IX(i)];
770                         for(;;) {
771                                 do {
772                                         i++;
773                                         COMP( cv[IX(i)], a );
774                                 } while( match < 0 );
775                                 while( match > 0 ) {
776                                         j--;
777                                         COMP( cv[IX(j)], a );
778                                 }
779                                 if (j < i) {
780                                         match = 1;
781                                         break;
782                                 }
783                                 if ( match == 0 ) {
784                                         i = l+1;
785                                         break;
786                                 }
787                                 EXCH(i,j);
788                         }
789                         if ( match == 0 )
790                                 break;
791                         EXCH(l+1,j);
792                         jstack += 2;
793                         if (ir-i+1 >= j) {
794                                 istack[jstack] = ir;
795                                 istack[jstack-1] = i;
796                                 ir = j;
797                         } else {
798                                 istack[jstack] = j;
799                                 istack[jstack-1] = l;
800                                 l = i;
801                         }
802                 }
803         }
804         done:
805         if ( i >= 0 )
806                 *dup = ix[i];
807
808         /* For sorted attributes, put the values in index order */
809         if ( rc == LDAP_SUCCESS && match &&
810                 ( ad->ad_type->sat_flags & SLAP_AT_SORTED_VAL )) {
811                 BerVarray tmpv = slap_sl_malloc( sizeof( struct berval ) * nvals, ctx );
812                 for ( i = 0; i<nvals; i++ )
813                         tmpv[i] = cv[ix[i]];
814                 for ( i = 0; i<nvals; i++ )
815                         cv[i] = tmpv[i];
816                 /* Check if the non-normalized array needs to move too */
817                 if ( is_norm ) {
818                         cv = ml->sml_values;
819                         for ( i = 0; i<nvals; i++ )
820                                 tmpv[i] = cv[ix[i]];
821                         for ( i = 0; i<nvals; i++ )
822                                 cv[i] = tmpv[i];
823                 }
824                 slap_sl_free( tmpv, ctx );
825         }
826
827         slap_sl_free( ix, ctx );
828
829         if ( rc != LDAP_SUCCESS ) {
830                 return rc;
831         } else if ( match == 0 ) {
832                 /* value exists already */
833                 assert( i >= 0 );
834                 assert( i < nvals );
835                 return LDAP_TYPE_OR_VALUE_EXISTS;
836         }
837         return LDAP_SUCCESS;
838 }
839
840 /* Enter with bv->bv_len = sizeof buffer, returns with
841  * actual length of string
842  */
843 void slap_timestamp( time_t *tm, struct berval *bv )
844 {
845         struct tm *ltm;
846 #ifdef HAVE_GMTIME_R
847         struct tm ltm_buf;
848
849         ltm = gmtime_r( tm, &ltm_buf );
850 #else
851         ldap_pvt_thread_mutex_lock( &gmtime_mutex );
852         ltm = gmtime( tm );
853 #endif
854
855         bv->bv_len = lutil_gentime( bv->bv_val, bv->bv_len, ltm );
856
857 #ifndef HAVE_GMTIME_R
858         ldap_pvt_thread_mutex_unlock( &gmtime_mutex );
859 #endif
860 }
861
862 /* Called for all modify and modrdn ops. If the current op was replicated
863  * from elsewhere, all of the attrs should already be present.
864  */
865 void slap_mods_opattrs(
866         Operation *op,
867         Modifications **modsp,
868         int manage_ctxcsn )
869 {
870         struct berval name, timestamp, csn = BER_BVNULL;
871         struct berval nname;
872         char timebuf[ LDAP_LUTIL_GENTIME_BUFSIZE ];
873         char csnbuf[ LDAP_LUTIL_CSNSTR_BUFSIZE ];
874         Modifications *mod, **modtail, *modlast;
875         int gotcsn = 0, gotmname = 0, gotmtime = 0;
876
877         if ( SLAP_LASTMOD( op->o_bd ) && !op->orm_no_opattrs ) {
878                 char *ptr;
879                 timestamp.bv_val = timebuf;
880                 for ( modtail = modsp; *modtail; modtail = &(*modtail)->sml_next ) {
881                         if ( (*modtail)->sml_op != LDAP_MOD_ADD &&
882                                 (*modtail)->sml_op != SLAP_MOD_SOFTADD &&
883                                 (*modtail)->sml_op != LDAP_MOD_REPLACE )
884                         {
885                                 continue;
886                         }
887
888                         if ( (*modtail)->sml_desc == slap_schema.si_ad_entryCSN )
889                         {
890                                 csn = (*modtail)->sml_values[0];
891                                 gotcsn = 1;
892
893                         } else if ( (*modtail)->sml_desc == slap_schema.si_ad_modifiersName )
894                         {
895                                 gotmname = 1;
896
897                         } else if ( (*modtail)->sml_desc == slap_schema.si_ad_modifyTimestamp )
898                         {
899                                 gotmtime = 1;
900                         }
901                 }
902
903                 if ( BER_BVISEMPTY( &op->o_csn )) {
904                         if ( !gotcsn ) {
905                                 csn.bv_val = csnbuf;
906                                 csn.bv_len = sizeof( csnbuf );
907                                 slap_get_csn( op, &csn, manage_ctxcsn );
908
909                         } else {
910                                 if ( manage_ctxcsn ) {
911                                         slap_queue_csn( op, &csn );
912                                 }
913                         }
914
915                 } else {
916                         csn = op->o_csn;
917                 }
918
919                 ptr = ber_bvchr( &csn, '#' );
920                 if ( ptr ) {
921                         timestamp.bv_len = STRLENOF("YYYYMMDDHHMMSSZ");
922                         AC_MEMCPY( timebuf, csn.bv_val, timestamp.bv_len );
923                         timebuf[timestamp.bv_len-1] = 'Z';
924                         timebuf[timestamp.bv_len] = '\0';
925
926                 } else {
927                         time_t now = slap_get_time();
928
929                         timestamp.bv_len = sizeof(timebuf);
930
931                         slap_timestamp( &now, &timestamp );
932                 }
933
934                 if ( BER_BVISEMPTY( &op->o_dn ) ) {
935                         BER_BVSTR( &name, SLAPD_ANONYMOUS );
936                         nname = name;
937
938                 } else {
939                         name = op->o_dn;
940                         nname = op->o_ndn;
941                 }
942
943                 if ( !gotcsn ) {
944                         mod = (Modifications *) ch_malloc( sizeof( Modifications ) );
945                         mod->sml_op = LDAP_MOD_REPLACE;
946                         mod->sml_flags = SLAP_MOD_INTERNAL;
947                         mod->sml_next = NULL;
948                         BER_BVZERO( &mod->sml_type );
949                         mod->sml_desc = slap_schema.si_ad_entryCSN;
950                         mod->sml_numvals = 1;
951                         mod->sml_values = (BerVarray) ch_malloc( 2 * sizeof( struct berval ) );
952                         ber_dupbv( &mod->sml_values[0], &csn );
953                         BER_BVZERO( &mod->sml_values[1] );
954                         assert( !BER_BVISNULL( &mod->sml_values[0] ) );
955                         mod->sml_nvalues = NULL;
956                         *modtail = mod;
957                         modlast = mod;
958                         modtail = &mod->sml_next;
959                 }
960
961                 if ( !gotmname ) {
962                         mod = (Modifications *) ch_malloc( sizeof( Modifications ) );
963                         mod->sml_op = LDAP_MOD_REPLACE;
964                         mod->sml_flags = SLAP_MOD_INTERNAL;
965                         mod->sml_next = NULL;
966                         BER_BVZERO( &mod->sml_type );
967                         mod->sml_desc = slap_schema.si_ad_modifiersName;
968                         mod->sml_numvals = 1;
969                         mod->sml_values = (BerVarray) ch_malloc( 2 * sizeof( struct berval ) );
970                         ber_dupbv( &mod->sml_values[0], &name );
971                         BER_BVZERO( &mod->sml_values[1] );
972                         assert( !BER_BVISNULL( &mod->sml_values[0] ) );
973                         mod->sml_nvalues =
974                                 (BerVarray) ch_malloc( 2 * sizeof( struct berval ) );
975                         ber_dupbv( &mod->sml_nvalues[0], &nname );
976                         BER_BVZERO( &mod->sml_nvalues[1] );
977                         assert( !BER_BVISNULL( &mod->sml_nvalues[0] ) );
978                         *modtail = mod;
979                         modtail = &mod->sml_next;
980                 }
981
982                 if ( !gotmtime ) {
983                         mod = (Modifications *) ch_malloc( sizeof( Modifications ) );
984                         mod->sml_op = LDAP_MOD_REPLACE;
985                         mod->sml_flags = SLAP_MOD_INTERNAL;
986                         mod->sml_next = NULL;
987                         BER_BVZERO( &mod->sml_type );
988                         mod->sml_desc = slap_schema.si_ad_modifyTimestamp;
989                         mod->sml_numvals = 1;
990                         mod->sml_values = (BerVarray) ch_malloc( 2 * sizeof( struct berval ) );
991                         ber_dupbv( &mod->sml_values[0], &timestamp );
992                         BER_BVZERO( &mod->sml_values[1] );
993                         assert( !BER_BVISNULL( &mod->sml_values[0] ) );
994                         mod->sml_nvalues = NULL;
995                         *modtail = mod;
996                         modtail = &mod->sml_next;
997                 }
998         }
999 }
1000
1001 int
1002 slap_parse_modlist(
1003         Operation *op,
1004         SlapReply *rs,
1005         BerElement *ber,
1006         req_modify_s *ms )
1007 {
1008         ber_tag_t       tag;
1009         ber_len_t       len;
1010         char            *last;
1011         Modifications   **modtail = &ms->rs_mods.rs_modlist;
1012
1013         ms->rs_mods.rs_modlist = NULL;
1014         ms->rs_increment = 0;
1015
1016         rs->sr_err = LDAP_SUCCESS;
1017
1018         /* collect modifications & save for later */
1019         for ( tag = ber_first_element( ber, &len, &last );
1020                 tag != LBER_DEFAULT;
1021                 tag = ber_next_element( ber, &len, last ) )
1022         {
1023                 ber_int_t mop;
1024                 Modifications tmp, *mod;
1025
1026                 tmp.sml_nvalues = NULL;
1027
1028                 if ( ber_scanf( ber, "{e{m[W]}}", &mop,
1029                     &tmp.sml_type, &tmp.sml_values ) == LBER_ERROR )
1030                 {
1031                         rs->sr_text = "decoding modlist error";
1032                         rs->sr_err = LDAP_PROTOCOL_ERROR;
1033                         goto done;
1034                 }
1035
1036                 mod = (Modifications *) ch_malloc( sizeof(Modifications) );
1037                 mod->sml_op = mop;
1038                 mod->sml_flags = 0;
1039                 mod->sml_type = tmp.sml_type;
1040                 mod->sml_values = tmp.sml_values;
1041                 mod->sml_nvalues = NULL;
1042                 mod->sml_desc = NULL;
1043                 mod->sml_next = NULL;
1044                 *modtail = mod;
1045
1046                 switch( mop ) {
1047                 case LDAP_MOD_ADD:
1048                         if ( mod->sml_values == NULL ) {
1049                                 rs->sr_text = "modify/add operation requires values";
1050                                 rs->sr_err = LDAP_PROTOCOL_ERROR;
1051                                 goto done;
1052                         }
1053
1054                         /* fall through */
1055
1056                 case LDAP_MOD_DELETE:
1057                 case LDAP_MOD_REPLACE:
1058                         break;
1059
1060                 case LDAP_MOD_INCREMENT:
1061                         if( op->o_protocol >= LDAP_VERSION3 ) {
1062                                 ms->rs_increment++;
1063                                 if ( mod->sml_values == NULL ) {
1064                                         rs->sr_text = "modify/increment operation requires value";
1065                                         rs->sr_err = LDAP_PROTOCOL_ERROR;
1066                                         goto done;
1067                                 }
1068
1069                                 if ( !BER_BVISNULL( &mod->sml_values[ 1 ] ) ) {
1070                                         rs->sr_text = "modify/increment operation requires single value";
1071                                         rs->sr_err = LDAP_PROTOCOL_ERROR;
1072                                         goto done;
1073                                 }
1074
1075                                 break;
1076                         }
1077                         /* fall thru */
1078
1079                 default:
1080                         rs->sr_text = "unrecognized modify operation";
1081                         rs->sr_err = LDAP_PROTOCOL_ERROR;
1082                         goto done;
1083                 }
1084
1085                 modtail = &mod->sml_next;
1086         }
1087         *modtail = NULL;
1088
1089 done:
1090         if ( rs->sr_err != LDAP_SUCCESS ) {
1091                 slap_mods_free( ms->rs_mods.rs_modlist, 1 );
1092                 ms->rs_mods.rs_modlist = NULL;
1093                 ms->rs_increment = 0;
1094         }
1095
1096         return rs->sr_err;
1097 }
1098