]> git.sur5r.net Git - openldap/blob - servers/slapd/controls.c
c5eacd2029e87107062a57ef52f8edbc03016007
[openldap] / servers / slapd / controls.c
1 /* $OpenLDAP$ */
2 /* 
3  * Copyright 1999-2003 The OpenLDAP Foundation.
4  * All rights reserved.
5  *
6  * Redistribution and use in source and binary forms are permitted only
7  * as authorized by the OpenLDAP Public License.  A copy of this
8  * license is available at http://www.OpenLDAP.org/license.html or
9  * in file LICENSE in the top-level directory of the distribution.
10  */
11 #include "portable.h"
12
13 #include <stdio.h>
14
15 #include <ac/string.h>
16 #include <ac/socket.h>
17
18 #include "slap.h"
19
20 #include "../../libraries/liblber/lber-int.h"
21
22 static SLAP_CTRL_PARSE_FN parseProxyAuthz;
23 static SLAP_CTRL_PARSE_FN parseManageDSAit;
24 static SLAP_CTRL_PARSE_FN parseNoOp;
25 static SLAP_CTRL_PARSE_FN parsePagedResults;
26 static SLAP_CTRL_PARSE_FN parseValuesReturnFilter;
27 static SLAP_CTRL_PARSE_FN parsePermissiveModify;
28 static SLAP_CTRL_PARSE_FN parseDomainScope;
29
30 #ifdef LDAP_CONTROL_SUBENTRIES
31 static SLAP_CTRL_PARSE_FN parseSubentries;
32 #endif
33 #ifdef LDAP_CLIENT_UPDATE
34 static SLAP_CTRL_PARSE_FN parseClientUpdate;
35 #endif
36 #ifdef LDAP_SYNC
37 static SLAP_CTRL_PARSE_FN parseLdupSync;
38 #endif
39
40 #undef sc_mask /* avoid conflict with Irix 6.5 <sys/signal.h> */
41
42 static char *proxy_authz_extops[] = {
43         LDAP_EXOP_MODIFY_PASSWD,
44         LDAP_EXOP_X_WHO_AM_I,
45         NULL
46 };
47
48 struct slap_control {
49         /*
50          * Control OID
51          */
52         char *sc_oid;
53
54         /*
55          * Operations supported by control
56          */
57         slap_mask_t sc_mask;
58
59         /*
60          * Extended operations supported by control
61          */
62         char **sc_extendedops;
63
64         /*
65          * Control parsing callback
66          */
67         SLAP_CTRL_PARSE_FN *sc_parse;
68
69         LDAP_SLIST_ENTRY(slap_control) sc_next;
70 };
71
72 static LDAP_SLIST_HEAD(ControlsList, slap_control) controls_list
73         = LDAP_SLIST_HEAD_INITIALIZER(&controls_list);
74
75 /*
76  * all known request control OIDs should be added to this list
77  */
78 char **slap_known_controls = NULL;
79
80 static struct slap_control control_defs[] = {
81         { LDAP_CONTROL_VALUESRETURNFILTER,
82                 SLAP_CTRL_SEARCH, NULL,
83                 parseValuesReturnFilter, LDAP_SLIST_ENTRY_INITIALIZER(next) },
84 #ifdef LDAP_CONTROL_PAGEDRESULTS
85         { LDAP_CONTROL_PAGEDRESULTS,
86                 SLAP_CTRL_SEARCH, NULL,
87                 parsePagedResults, LDAP_SLIST_ENTRY_INITIALIZER(next) },
88 #endif
89 #ifdef LDAP_CONTROL_X_DOMAIN_SCOPE
90         { LDAP_CONTROL_X_DOMAIN_SCOPE,
91                 SLAP_CTRL_FRONTEND|SLAP_CTRL_SEARCH, NULL,
92                 parseDomainScope, LDAP_SLIST_ENTRY_INITIALIZER(next) },
93 #endif
94 #ifdef LDAP_CONTROL_X_PERMISSIVE_MODIFY
95         { LDAP_CONTROL_X_PERMISSIVE_MODIFY,
96                 SLAP_CTRL_MODIFY, NULL,
97                 parsePermissiveModify, LDAP_SLIST_ENTRY_INITIALIZER(next) },
98 #endif
99 #ifdef LDAP_CONTROL_SUBENTRIES
100         { LDAP_CONTROL_SUBENTRIES,
101                 SLAP_CTRL_SEARCH, NULL,
102                 parseSubentries, LDAP_SLIST_ENTRY_INITIALIZER(next) },
103 #endif
104         { LDAP_CONTROL_NOOP,
105                 SLAP_CTRL_ACCESS, NULL,
106                 parseNoOp, LDAP_SLIST_ENTRY_INITIALIZER(next) },
107 #ifdef LDAP_CLIENT_UPDATE
108         { LDAP_CONTROL_CLIENT_UPDATE,
109                 SLAP_CTRL_HIDE|SLAP_CTRL_SEARCH, NULL,
110                 parseClientUpdate, LDAP_SLIST_ENTRY_INITIALIZER(next) },
111 #endif
112 #ifdef LDAP_SYNC
113         { LDAP_CONTROL_SYNC,
114                 SLAP_CTRL_HIDE|SLAP_CTRL_SEARCH, NULL,
115                 parseLdupSync, LDAP_SLIST_ENTRY_INITIALIZER(next) },
116 #endif
117         { LDAP_CONTROL_MANAGEDSAIT,
118                 SLAP_CTRL_ACCESS, NULL,
119                 parseManageDSAit, LDAP_SLIST_ENTRY_INITIALIZER(next) },
120         { LDAP_CONTROL_PROXY_AUTHZ,
121                 SLAP_CTRL_FRONTEND|SLAP_CTRL_ACCESS, proxy_authz_extops,
122                 parseProxyAuthz, LDAP_SLIST_ENTRY_INITIALIZER(next) },
123         { NULL, 0, NULL, 0, LDAP_SLIST_ENTRY_INITIALIZER(next) }
124 };
125
126 /*
127  * Register a supported control.
128  *
129  * This can be called by an OpenLDAP plugin or, indirectly, by a
130  * SLAPI plugin calling slapi_register_supported_control().
131  */
132 int
133 register_supported_control(const char *controloid,
134         slap_mask_t controlmask,
135         char **controlexops,
136         SLAP_CTRL_PARSE_FN *controlparsefn)
137 {
138         struct slap_control *sc;
139         int i;
140
141         if ( controloid == NULL ) {
142                 return LDAP_PARAM_ERROR;
143         }
144
145         sc = (struct slap_control *)SLAP_MALLOC( sizeof( *sc ) );
146         if ( sc == NULL ) {
147                 return LDAP_NO_MEMORY;
148         }
149         sc->sc_oid = ch_strdup( controloid );
150         sc->sc_mask = controlmask;
151         if ( controlexops != NULL ) {
152                 sc->sc_extendedops = ldap_charray_dup( controlexops );
153                 if ( sc->sc_extendedops == NULL ) {
154                         ch_free( sc );
155                         return LDAP_NO_MEMORY;
156                 }
157         } else {
158                 sc->sc_extendedops = NULL;
159         }
160         sc->sc_parse = controlparsefn;
161
162         /* Update slap_known_controls, too. */
163         if ( slap_known_controls == NULL ) {
164                 slap_known_controls = (char **)SLAP_MALLOC( 2 * sizeof(char *) );
165                 if ( slap_known_controls == NULL ) {
166                         if ( sc->sc_extendedops != NULL ) ldap_charray_free( sc->sc_extendedops );
167                         ch_free( sc );
168                         return LDAP_NO_MEMORY;
169                 }
170                 slap_known_controls[0] = ch_strdup( sc->sc_oid );
171                 slap_known_controls[1] = NULL;
172         } else {
173                 for ( i = 0; slap_known_controls[i] != NULL; i++ )
174                         ;
175                 slap_known_controls = (char **)SLAP_REALLOC( slap_known_controls, (i + 2) * sizeof(char *) );
176                 if ( slap_known_controls == NULL ) {
177                         if ( sc->sc_extendedops != NULL ) ldap_charray_free( sc->sc_extendedops );
178                         ch_free( sc );
179                         return LDAP_NO_MEMORY;
180                 }
181                 slap_known_controls[i++] = ch_strdup( sc->sc_oid );
182                 slap_known_controls[i] = NULL;
183         }
184
185         LDAP_SLIST_NEXT( sc, sc_next ) = NULL;
186         LDAP_SLIST_INSERT_HEAD( &controls_list, sc, sc_next );
187
188         return LDAP_SUCCESS;
189 }
190
191 /*
192  * One-time initialization of internal controls.
193  */
194 int
195 slap_controls_init( void )
196 {
197         int i, rc;
198         struct slap_control *sc;
199
200         rc = LDAP_SUCCESS;
201
202         for ( i = 0; control_defs[i].sc_oid != NULL; i++ ) {
203                 rc = register_supported_control( control_defs[i].sc_oid,
204                         control_defs[i].sc_mask, control_defs[i].sc_extendedops,
205                         control_defs[i].sc_parse );
206                 if ( rc != LDAP_SUCCESS )
207                         break;
208         }
209
210         return rc;
211 }
212
213 /*
214  * Free memory associated with list of supported controls.
215  */
216 void
217 controls_destroy( void )
218 {
219         struct slap_control *sc;
220
221         while ( !LDAP_SLIST_EMPTY(&controls_list) ) {
222                 sc = LDAP_SLIST_FIRST(&controls_list);
223                 LDAP_SLIST_REMOVE_HEAD(&controls_list, sc_next);
224
225                 ch_free( sc->sc_oid );
226                 if ( sc->sc_extendedops != NULL ) {
227                         ldap_charray_free( sc->sc_extendedops );
228                 }
229                 ch_free( sc );
230         }
231         ldap_charray_free( slap_known_controls );
232 }
233
234 /*
235  * Format the supportedControl attribute of the root DSE,
236  * detailing which controls are supported by the directory
237  * server.
238  */
239 int
240 controls_root_dse_info( Entry *e )
241 {
242         AttributeDescription *ad_supportedControl
243                 = slap_schema.si_ad_supportedControl;
244         struct berval vals[2];
245         struct slap_control *sc;
246
247         vals[1].bv_val = NULL;
248         vals[1].bv_len = 0;
249
250         LDAP_SLIST_FOREACH( sc, &controls_list, sc_next ) {
251                 if( sc->sc_mask & SLAP_CTRL_HIDE ) continue;
252
253                 vals[0].bv_val = sc->sc_oid;
254                 vals[0].bv_len = strlen( sc->sc_oid );
255
256                 if ( attr_merge( e, ad_supportedControl, vals, NULL ) ) {
257                         return -1;
258                 }
259         }
260
261         return 0;
262 }
263
264 /*
265  * Return a list of OIDs and operation masks for supported
266  * controls. Used by SLAPI.
267  */
268 int
269 get_supported_controls(char ***ctrloidsp,
270         slap_mask_t **ctrlmasks)
271 {
272         int i, n;
273         char **oids;
274         slap_mask_t *masks;
275         int rc;
276         struct slap_control *sc;
277
278         n = 0;
279
280         LDAP_SLIST_FOREACH( sc, &controls_list, sc_next ) {
281                 n++;
282         }
283
284         if ( n == 0 ) {
285                 *ctrloidsp = NULL;
286                 *ctrlmasks = NULL;
287                 return LDAP_SUCCESS;
288         }
289
290         oids = (char **)SLAP_MALLOC( (n + 1) * sizeof(char *) );
291         if ( oids == NULL ) {
292                 return LDAP_NO_MEMORY;
293         }
294         masks = (slap_mask_t *)SLAP_MALLOC( (n + 1) * sizeof(slap_mask_t) );
295         if  ( masks == NULL ) {
296                 ch_free( oids );
297                 return LDAP_NO_MEMORY;
298         }
299
300         n = 0;
301
302         LDAP_SLIST_FOREACH( sc, &controls_list, sc_next ) {
303                 oids[n] = ch_strdup( sc->sc_oid );
304                 masks[n] = sc->sc_mask;
305                 n++;
306         }
307         oids[n] = NULL;
308         masks[n] = 0;
309
310         *ctrloidsp = oids;
311         *ctrlmasks = masks;
312
313         return LDAP_SUCCESS;
314 }
315
316 /*
317  * Find a control given its OID.
318  */
319 static struct slap_control *
320 find_ctrl( const char *oid )
321 {
322         struct slap_control *sc;
323
324         LDAP_SLIST_FOREACH( sc, &controls_list, sc_next ) {
325                 if ( strcmp( oid, sc->sc_oid ) == 0 ) {
326                         return sc;
327                 }
328         }
329
330         return NULL;
331 }
332
333 void slap_free_ctrls(
334         Operation *op,
335         LDAPControl **ctrls
336 )
337 {
338         int i;
339
340         for (i=0; ctrls[i]; i++) {
341                 op->o_tmpfree(ctrls[i], op->o_tmpmemctx );
342         }
343         op->o_tmpfree( ctrls, op->o_tmpmemctx );
344 }
345
346 int get_ctrls(
347         Operation *op,
348         SlapReply *rs,
349         int sendres )
350 {
351         int nctrls = 0;
352         ber_tag_t tag;
353         ber_len_t len;
354         char *opaque;
355         BerElement *ber = op->o_ber;
356         struct slap_control *sc;
357         struct berval bv;
358
359         len = ber_pvt_ber_remaining(ber);
360
361         if( len == 0) {
362                 /* no controls */
363                 rs->sr_err = LDAP_SUCCESS;
364                 return rs->sr_err;
365         }
366
367         if(( tag = ber_peek_tag( ber, &len )) != LDAP_TAG_CONTROLS ) {
368                 if( tag == LBER_ERROR ) {
369                         rs->sr_err = SLAPD_DISCONNECT;
370                         rs->sr_text = "unexpected data in PDU";
371                 }
372
373                 goto return_results;
374         }
375
376 #ifdef NEW_LOGGING
377         LDAP_LOG( OPERATION, ENTRY,
378                 "get_ctrls: conn %lu\n", op->o_connid, 0, 0 );
379 #else
380         Debug( LDAP_DEBUG_TRACE,
381                 "=> get_ctrls\n", 0, 0, 0 );
382 #endif
383
384         if( op->o_protocol < LDAP_VERSION3 ) {
385                 rs->sr_err = SLAPD_DISCONNECT;
386                 rs->sr_text = "controls require LDAPv3";
387                 goto return_results;
388         }
389
390         /* one for first control, one for termination */
391         op->o_ctrls = op->o_tmpalloc( 2 * sizeof(LDAPControl *), op->o_tmpmemctx );
392
393 #if 0
394         if( op->ctrls == NULL ) {
395                 rs->sr_err = LDAP_NO_MEMORY;
396                 rs->sr_text = "no memory";
397                 goto return_results;
398         }
399 #endif
400
401         op->o_ctrls[nctrls] = NULL;
402
403         /* step through each element */
404         for( tag = ber_first_element( ber, &len, &opaque );
405                 tag != LBER_ERROR;
406                 tag = ber_next_element( ber, &len, opaque ) )
407         {
408                 LDAPControl *c;
409                 LDAPControl **tctrls;
410
411                 c = op->o_tmpalloc( sizeof(LDAPControl), op->o_tmpmemctx );
412                 memset(c, 0, sizeof(LDAPControl));
413
414                 /* allocate pointer space for current controls (nctrls)
415                  * + this control + extra NULL
416                  */
417                 tctrls = op->o_tmprealloc( op->o_ctrls,
418                         (nctrls+2) * sizeof(LDAPControl *), op->o_tmpmemctx );
419
420 #if 0
421                 if( tctrls == NULL ) {
422                         ch_free( c );
423                         ldap_controls_free(op->o_ctrls);
424                         op->o_ctrls = NULL;
425
426                         rs->sr_err = LDAP_NO_MEMORY;
427                         rs->sr_text = "no memory";
428                         goto return_results;
429                 }
430 #endif
431                 op->o_ctrls = tctrls;
432
433                 op->o_ctrls[nctrls++] = c;
434                 op->o_ctrls[nctrls] = NULL;
435
436                 tag = ber_scanf( ber, "{m" /*}*/, &bv );
437                 c->ldctl_oid = bv.bv_val;
438
439                 if( tag == LBER_ERROR ) {
440 #ifdef NEW_LOGGING
441                         LDAP_LOG( OPERATION, INFO, "get_ctrls: conn %lu get OID failed.\n",
442                                 op->o_connid, 0, 0 );
443 #else
444                         Debug( LDAP_DEBUG_TRACE, "=> get_ctrls: get oid failed.\n",
445                                 0, 0, 0 );
446 #endif
447
448                         slap_free_ctrls( op, op->o_ctrls );
449                         op->o_ctrls = NULL;
450                         rs->sr_err = SLAPD_DISCONNECT;
451                         rs->sr_text = "decoding controls error";
452                         goto return_results;
453
454                 } else if( c->ldctl_oid == NULL ) {
455 #ifdef NEW_LOGGING
456                         LDAP_LOG( OPERATION, INFO,
457                                 "get_ctrls: conn %lu got emtpy OID.\n",
458                                 op->o_connid, 0, 0 );
459 #else
460                         Debug( LDAP_DEBUG_TRACE,
461                                 "get_ctrls: conn %lu got emtpy OID.\n",
462                                 op->o_connid, 0, 0 );
463 #endif
464
465                         slap_free_ctrls( op, op->o_ctrls );
466                         op->o_ctrls = NULL;
467                         rs->sr_err = LDAP_PROTOCOL_ERROR;
468                         rs->sr_text = "OID field is empty";
469                         goto return_results;
470                 }
471
472                 tag = ber_peek_tag( ber, &len );
473
474                 if( tag == LBER_BOOLEAN ) {
475                         ber_int_t crit;
476                         tag = ber_scanf( ber, "b", &crit );
477
478                         if( tag == LBER_ERROR ) {
479 #ifdef NEW_LOGGING
480                                 LDAP_LOG( OPERATION, INFO, 
481                                         "get_ctrls: conn %lu get crit failed.\n", 
482                                         op->o_connid, 0, 0 );
483 #else
484                                 Debug( LDAP_DEBUG_TRACE, "=> get_ctrls: get crit failed.\n",
485                                         0, 0, 0 );
486 #endif
487                                 slap_free_ctrls( op, op->o_ctrls );
488                                 op->o_ctrls = NULL;
489                                 rs->sr_err = SLAPD_DISCONNECT;
490                                 rs->sr_text = "decoding controls error";
491                                 goto return_results;
492                         }
493
494                         c->ldctl_iscritical = (crit != 0);
495                         tag = ber_peek_tag( ber, &len );
496                 }
497
498                 if( tag == LBER_OCTETSTRING ) {
499                         tag = ber_scanf( ber, "m", &c->ldctl_value );
500
501                         if( tag == LBER_ERROR ) {
502 #ifdef NEW_LOGGING
503                                 LDAP_LOG( OPERATION, INFO, "get_ctrls: conn %lu: "
504                                         "%s (%scritical): get value failed.\n",
505                                         op->o_connid, c->ldctl_oid,
506                                         c->ldctl_iscritical ? "" : "non" );
507 #else
508                                 Debug( LDAP_DEBUG_TRACE, "=> get_ctrls: conn %lu: "
509                                         "%s (%scritical): get value failed.\n",
510                                         op->o_connid, c->ldctl_oid,
511                                         c->ldctl_iscritical ? "" : "non" );
512 #endif
513                                 slap_free_ctrls( op, op->o_ctrls );
514                                 op->o_ctrls = NULL;
515                                 rs->sr_err = SLAPD_DISCONNECT;
516                                 rs->sr_text = "decoding controls error";
517                                 goto return_results;
518                         }
519                 }
520
521 #ifdef NEW_LOGGING
522                 LDAP_LOG( OPERATION, INFO, 
523                         "get_ctrls: conn %lu oid=\"%s\" (%scritical)\n",
524                         op->o_connid, c->ldctl_oid, c->ldctl_iscritical ? "" : "non" );
525 #else
526                 Debug( LDAP_DEBUG_TRACE,
527                         "=> get_ctrls: oid=\"%s\" (%scritical)\n",
528                         c->ldctl_oid, c->ldctl_iscritical ? "" : "non", 0 );
529 #endif
530
531                 sc = find_ctrl( c->ldctl_oid );
532                 if( sc != NULL ) {
533                         /* recognized control */
534                         slap_mask_t tagmask;
535                         switch( op->o_tag ) {
536                         case LDAP_REQ_ADD:
537                                 tagmask = SLAP_CTRL_ADD;
538                                 break;
539                         case LDAP_REQ_BIND:
540                                 tagmask = SLAP_CTRL_BIND;
541                                 break;
542                         case LDAP_REQ_COMPARE:
543                                 tagmask = SLAP_CTRL_COMPARE;
544                                 break;
545                         case LDAP_REQ_DELETE:
546                                 tagmask = SLAP_CTRL_DELETE;
547                                 break;
548                         case LDAP_REQ_MODIFY:
549                                 tagmask = SLAP_CTRL_MODIFY;
550                                 break;
551                         case LDAP_REQ_RENAME:
552                                 tagmask = SLAP_CTRL_RENAME;
553                                 break;
554                         case LDAP_REQ_SEARCH:
555                                 tagmask = SLAP_CTRL_SEARCH;
556                                 break;
557                         case LDAP_REQ_UNBIND:
558                                 tagmask = SLAP_CTRL_UNBIND;
559                                 break;
560                         case LDAP_REQ_ABANDON:
561                                 tagmask = SLAP_CTRL_ABANDON;
562                                 break;
563                         case LDAP_REQ_EXTENDED:
564                                 tagmask=~0L;
565                                 assert( op->ore_reqoid.bv_val != NULL );
566                                 if( sc->sc_extendedops != NULL ) {
567                                         int i;
568                                         for( i=0; sc->sc_extendedops[i] != NULL; i++ ) {
569                                                 if( strcmp( op->ore_reqoid.bv_val, sc->sc_extendedops[i] )
570                                                         == 0 )
571                                                 {
572                                                         tagmask=0L;
573                                                         break;
574                                                 }
575                                         }
576                                 }
577                                 break;
578                         default:
579                                 rs->sr_err = LDAP_OTHER;
580                                 rs->sr_text = "controls internal error";
581                                 goto return_results;
582                         }
583
584                         if (( sc->sc_mask & tagmask ) == tagmask ) {
585                                 /* available extension */
586
587                                 if( !sc->sc_parse ) {
588                                         rs->sr_err = LDAP_OTHER;
589                                         rs->sr_text = "not yet implemented";
590                                         goto return_results;
591                                 }
592
593                                 rs->sr_err = sc->sc_parse( op, rs, c );
594
595                                 if( rs->sr_err != LDAP_SUCCESS ) goto return_results;
596
597                                 if ( sc->sc_mask & SLAP_CTRL_FRONTEND ) {
598                                         /* kludge to disable backend_control() check */
599                                         c->ldctl_iscritical = 0;
600
601                                 } else if ( tagmask == SLAP_CTRL_SEARCH &&
602                                         sc->sc_mask & SLAP_CTRL_FRONTEND_SEARCH )
603                                 {
604                                         /* kludge to disable backend_control() check */
605                                         c->ldctl_iscritical = 0;
606                                 }
607
608                         } else if( c->ldctl_iscritical ) {
609                                 /* unavailable CRITICAL control */
610                                 rs->sr_err = LDAP_UNAVAILABLE_CRITICAL_EXTENSION;
611                                 rs->sr_text = "critical extension is unavailable";
612                                 goto return_results;
613                         }
614
615                 } else if( c->ldctl_iscritical ) {
616                         /* unrecognized CRITICAL control */
617                         rs->sr_err = LDAP_UNAVAILABLE_CRITICAL_EXTENSION;
618                         rs->sr_text = "critical extension is not recognized";
619                         goto return_results;
620                 }
621         }
622
623 return_results:
624 #ifdef NEW_LOGGING
625         LDAP_LOG( OPERATION, RESULTS, 
626                 "get_ctrls: n=%d rc=%d err=\"%s\"\n",
627                 nctrls, rs->sr_err, rs->sr_text ? rs->sr_text : "" );
628 #else
629         Debug( LDAP_DEBUG_TRACE,
630                 "<= get_ctrls: n=%d rc=%d err=\"%s\"\n",
631                 nctrls, rs->sr_err, rs->sr_text ? rs->sr_text : "");
632 #endif
633
634         if( sendres && rs->sr_err != LDAP_SUCCESS ) {
635                 if( rs->sr_err == SLAPD_DISCONNECT ) {
636                         rs->sr_err = LDAP_PROTOCOL_ERROR;
637                         send_ldap_disconnect( op, rs );
638                         rs->sr_err = SLAPD_DISCONNECT;
639                 } else {
640                         send_ldap_result( op, rs );
641                 }
642         }
643
644         return rs->sr_err;
645 }
646
647 static int parseManageDSAit (
648         Operation *op,
649         SlapReply *rs,
650         LDAPControl *ctrl )
651 {
652         if ( op->o_managedsait != SLAP_NO_CONTROL ) {
653                 rs->sr_text = "manageDSAit control specified multiple times";
654                 return LDAP_PROTOCOL_ERROR;
655         }
656
657         if ( ctrl->ldctl_value.bv_len ) {
658                 rs->sr_text = "manageDSAit control value not empty";
659                 return LDAP_PROTOCOL_ERROR;
660         }
661
662         op->o_managedsait = ctrl->ldctl_iscritical
663                 ? SLAP_CRITICAL_CONTROL
664                 : SLAP_NONCRITICAL_CONTROL;
665
666         return LDAP_SUCCESS;
667 }
668
669 static int parseProxyAuthz (
670         Operation *op,
671         SlapReply *rs,
672         LDAPControl *ctrl )
673 {
674         int rc;
675         struct berval dn = { 0, NULL };
676
677         if ( op->o_proxy_authz != SLAP_NO_CONTROL ) {
678                 rs->sr_text = "proxy authorization control specified multiple times";
679                 return LDAP_PROTOCOL_ERROR;
680         }
681
682         op->o_proxy_authz = ctrl->ldctl_iscritical
683                 ? SLAP_CRITICAL_CONTROL
684                 : SLAP_NONCRITICAL_CONTROL;
685
686 #ifdef NEW_LOGGING
687         LDAP_LOG( OPERATION, ARGS, 
688                 "parseProxyAuthz: conn %lu authzid=\"%s\"\n", 
689                 op->o_connid,
690                 ctrl->ldctl_value.bv_len ?  ctrl->ldctl_value.bv_val : "anonymous",
691                 0 );
692 #else
693         Debug( LDAP_DEBUG_ARGS,
694                 "parseProxyAuthz: conn %lu authzid=\"%s\"\n", 
695                 op->o_connid,
696                 ctrl->ldctl_value.bv_len ?  ctrl->ldctl_value.bv_val : "anonymous",
697                 0 );
698 #endif
699
700         if( ctrl->ldctl_value.bv_len == 0 ) {
701 #ifdef NEW_LOGGING
702                 LDAP_LOG( OPERATION, RESULTS, 
703                         "parseProxyAuthz: conn=%lu anonymous\n", 
704                         op->o_connid, 0, 0 );
705 #else
706                 Debug( LDAP_DEBUG_TRACE,
707                         "parseProxyAuthz: conn=%lu anonymous\n", 
708                         op->o_connid, 0, 0 );
709 #endif
710
711                 /* anonymous */
712                 free( op->o_dn.bv_val );
713                 op->o_dn.bv_len = 0;
714                 op->o_dn.bv_val = ch_strdup( "" );
715
716                 free( op->o_ndn.bv_val );
717                 op->o_ndn.bv_len = 0;
718                 op->o_ndn.bv_val = ch_strdup( "" );
719
720                 return LDAP_SUCCESS;
721         }
722
723         rc = slap_sasl_getdn( op->o_conn, op,
724                 ctrl->ldctl_value.bv_val, ctrl->ldctl_value.bv_len,
725                 NULL, &dn, SLAP_GETDN_AUTHZID );
726
727         if( rc != LDAP_SUCCESS || !dn.bv_len ) {
728                 if ( dn.bv_val ) {
729                         ch_free( dn.bv_val );
730                 }
731                 rs->sr_text = "authzId mapping failed";
732                 return LDAP_PROXY_AUTHZ_FAILURE;
733         }
734
735 #ifdef NEW_LOGGING
736         LDAP_LOG( OPERATION, RESULTS, 
737                 "parseProxyAuthz: conn=%lu \"%s\"\n", 
738                 op->o_connid,
739                 dn.bv_len ? dn.bv_val : "(NULL)", 0 );
740 #else
741         Debug( LDAP_DEBUG_TRACE,
742                 "parseProxyAuthz: conn=%lu \"%s\"\n", 
743                 op->o_connid,
744                 dn.bv_len ? dn.bv_val : "(NULL)", 0 );
745 #endif
746
747         rc = slap_sasl_authorized( op, &op->o_ndn, &dn );
748
749         if( rc ) {
750                 ch_free( dn.bv_val );
751                 rs->sr_text = "not authorized to assume identity";
752                 return LDAP_PROXY_AUTHZ_FAILURE;
753         }
754
755         ch_free( op->o_dn.bv_val );
756         ch_free( op->o_ndn.bv_val );
757
758         op->o_dn.bv_val = NULL;
759         op->o_ndn = dn;
760
761         /*
762          * NOTE: since slap_sasl_getdn() returns a normalized dn,
763          * from now on op->o_dn is normalized
764          */
765         ber_dupbv( &op->o_dn, &dn );
766
767         return LDAP_SUCCESS;
768 }
769
770 static int parseNoOp (
771         Operation *op,
772         SlapReply *rs,
773         LDAPControl *ctrl )
774 {
775         if ( op->o_noop != SLAP_NO_CONTROL ) {
776                 rs->sr_text = "noop control specified multiple times";
777                 return LDAP_PROTOCOL_ERROR;
778         }
779
780         if ( ctrl->ldctl_value.bv_len ) {
781                 rs->sr_text = "noop control value not empty";
782                 return LDAP_PROTOCOL_ERROR;
783         }
784
785         op->o_noop = ctrl->ldctl_iscritical
786                 ? SLAP_CRITICAL_CONTROL
787                 : SLAP_NONCRITICAL_CONTROL;
788
789         return LDAP_SUCCESS;
790 }
791
792 #ifdef LDAP_CONTROL_PAGEDRESULTS
793 static int parsePagedResults (
794         Operation *op,
795         SlapReply *rs,
796         LDAPControl *ctrl )
797 {
798         ber_tag_t tag;
799         ber_int_t size;
800         BerElement *ber;
801         struct berval cookie = { 0, NULL };
802
803         if ( op->o_pagedresults != SLAP_NO_CONTROL ) {
804                 rs->sr_text = "paged results control specified multiple times";
805                 return LDAP_PROTOCOL_ERROR;
806         }
807
808         if ( ctrl->ldctl_value.bv_len == 0 ) {
809                 rs->sr_text = "paged results control value is empty (or absent)";
810                 return LDAP_PROTOCOL_ERROR;
811         }
812
813         /* Parse the control value
814          *      realSearchControlValue ::= SEQUENCE {
815          *              size    INTEGER (0..maxInt),
816          *                              -- requested page size from client
817          *                              -- result set size estimate from server
818          *              cookie  OCTET STRING
819          * }
820          */
821         ber = ber_init( &ctrl->ldctl_value );
822         if( ber == NULL ) {
823                 rs->sr_text = "internal error";
824                 return LDAP_OTHER;
825         }
826
827         tag = ber_scanf( ber, "{im}", &size, &cookie );
828         (void) ber_free( ber, 1 );
829
830         if( tag == LBER_ERROR ) {
831                 rs->sr_text = "paged results control could not be decoded";
832                 return LDAP_PROTOCOL_ERROR;
833         }
834
835         if( size < 0 ) {
836                 rs->sr_text = "paged results control size invalid";
837                 return LDAP_PROTOCOL_ERROR;
838         }
839
840         if( cookie.bv_len ) {
841                 PagedResultsCookie reqcookie;
842                 if( cookie.bv_len != sizeof( reqcookie ) ) {
843                         /* bad cookie */
844                         rs->sr_text = "paged results cookie is invalid";
845                         return LDAP_PROTOCOL_ERROR;
846                 }
847
848                 AC_MEMCPY( &reqcookie, cookie.bv_val, sizeof( reqcookie ));
849
850                 if( reqcookie > op->o_pagedresults_state.ps_cookie ) {
851                         /* bad cookie */
852                         rs->sr_text = "paged results cookie is invalid";
853                         return LDAP_PROTOCOL_ERROR;
854
855                 } else if( reqcookie < op->o_pagedresults_state.ps_cookie ) {
856                         rs->sr_text = "paged results cookie is invalid or old";
857                         return LDAP_UNWILLING_TO_PERFORM;
858                 }
859         } else {
860                 /* Initial request.  Initialize state. */
861                 op->o_pagedresults_state.ps_cookie = 0;
862                 op->o_pagedresults_state.ps_id = NOID;
863         }
864
865         op->o_pagedresults_size = size;
866
867         op->o_pagedresults = ctrl->ldctl_iscritical
868                 ? SLAP_CRITICAL_CONTROL
869                 : SLAP_NONCRITICAL_CONTROL;
870
871         return LDAP_SUCCESS;
872 }
873 #endif
874
875 int parseValuesReturnFilter (
876         Operation *op,
877         SlapReply *rs,
878         LDAPControl *ctrl )
879 {
880         BerElement      *ber;
881         struct berval   fstr = { 0, NULL };
882         const char *err_msg = "";
883
884         if ( op->o_valuesreturnfilter != SLAP_NO_CONTROL ) {
885                 rs->sr_text = "valuesReturnFilter control specified multiple times";
886                 return LDAP_PROTOCOL_ERROR;
887         }
888
889         if ( ctrl->ldctl_value.bv_len == 0 ) {
890                 rs->sr_text = "valuesReturnFilter control value is empty (or absent)";
891                 return LDAP_PROTOCOL_ERROR;
892         }
893
894         ber = ber_init( &(ctrl->ldctl_value) );
895         if (ber == NULL) {
896                 rs->sr_text = "internal error";
897                 return LDAP_OTHER;
898         }
899         
900         rs->sr_err = get_vrFilter( op, ber, &(op->vrFilter), &rs->sr_text);
901
902         if( rs->sr_err != LDAP_SUCCESS ) {
903                 if( rs->sr_err == SLAPD_DISCONNECT ) {
904                         rs->sr_err = LDAP_PROTOCOL_ERROR;
905                         send_ldap_disconnect( op, rs );
906                         rs->sr_err = SLAPD_DISCONNECT;
907                 } else {
908                         send_ldap_result( op, rs );
909                 }
910                 if( op->vrFilter != NULL) vrFilter_free( op, op->vrFilter ); 
911
912         }
913 #ifdef LDAP_DEBUG
914         else {
915                 vrFilter2bv( op, op->vrFilter, &fstr );
916         }
917
918 #ifdef NEW_LOGGING
919         LDAP_LOG( OPERATION, ARGS, 
920                 "parseValuesReturnFilter: conn %d       vrFilter: %s\n", 
921                 op->o_connid, fstr.bv_len ? fstr.bv_val : "empty" , 0 );
922 #else
923         Debug( LDAP_DEBUG_ARGS, "       vrFilter: %s\n",
924                 fstr.bv_len ? fstr.bv_val : "empty", 0, 0 );
925 #endif
926         op->o_tmpfree( fstr.bv_val, op->o_tmpmemctx );
927 #endif
928
929         op->o_valuesreturnfilter = ctrl->ldctl_iscritical
930                 ? SLAP_CRITICAL_CONTROL
931                 : SLAP_NONCRITICAL_CONTROL;
932
933         rs->sr_err = LDAP_SUCCESS;
934         return LDAP_SUCCESS;
935 }
936
937 #ifdef LDAP_CONTROL_SUBENTRIES
938 static int parseSubentries (
939         Operation *op,
940         SlapReply *rs,
941         LDAPControl *ctrl )
942 {
943         if ( op->o_subentries != SLAP_NO_CONTROL ) {
944                 rs->sr_text = "subentries control specified multiple times";
945                 return LDAP_PROTOCOL_ERROR;
946         }
947
948         /* FIXME: should use BER library */
949         if( ( ctrl->ldctl_value.bv_len != 3 )
950                 && ( ctrl->ldctl_value.bv_val[0] != 0x01 )
951                 && ( ctrl->ldctl_value.bv_val[1] != 0x01 ))
952         {
953                 rs->sr_text = "subentries control value encoding is bogus";
954                 return LDAP_PROTOCOL_ERROR;
955         }
956
957         op->o_subentries = ctrl->ldctl_iscritical
958                 ? SLAP_CRITICAL_CONTROL
959                 : SLAP_NONCRITICAL_CONTROL;
960
961         op->o_subentries_visibility = (ctrl->ldctl_value.bv_val[2] != 0x00);
962
963         return LDAP_SUCCESS;
964 }
965 #endif
966
967 #ifdef LDAP_CONTROL_X_PERMISSIVE_MODIFY
968 static int parsePermissiveModify (
969         Operation *op,
970         SlapReply *rs,
971         LDAPControl *ctrl )
972 {
973         if ( op->o_permissive_modify != SLAP_NO_CONTROL ) {
974                 rs->sr_text = "permissiveModify control specified multiple times";
975                 return LDAP_PROTOCOL_ERROR;
976         }
977
978         if ( ctrl->ldctl_value.bv_len ) {
979                 rs->sr_text = "permissiveModify control value not empty";
980                 return LDAP_PROTOCOL_ERROR;
981         }
982
983         op->o_permissive_modify = ctrl->ldctl_iscritical
984                 ? SLAP_CRITICAL_CONTROL
985                 : SLAP_NONCRITICAL_CONTROL;
986
987         return LDAP_SUCCESS;
988 }
989 #endif
990
991 #ifdef LDAP_CONTROL_X_DOMAIN_SCOPE
992 static int parseDomainScope (
993         Operation *op,
994         SlapReply *rs,
995         LDAPControl *ctrl )
996 {
997         if ( op->o_domain_scope != SLAP_NO_CONTROL ) {
998                 rs->sr_text = "domainScope control specified multiple times";
999                 return LDAP_PROTOCOL_ERROR;
1000         }
1001
1002         if ( ctrl->ldctl_value.bv_len ) {
1003                 rs->sr_text = "domainScope control value not empty";
1004                 return LDAP_PROTOCOL_ERROR;
1005         }
1006
1007         op->o_domain_scope = ctrl->ldctl_iscritical
1008                 ? SLAP_CRITICAL_CONTROL
1009                 : SLAP_NONCRITICAL_CONTROL;
1010
1011         return LDAP_SUCCESS;
1012 }
1013 #endif
1014
1015 #ifdef LDAP_CLIENT_UPDATE
1016 static int parseClientUpdate (
1017         Operation *op,
1018         SlapReply *rs,
1019         LDAPControl *ctrl )
1020 {
1021         ber_tag_t tag;
1022         BerElement *ber;
1023         ber_int_t type;
1024         ber_int_t interval;
1025         ber_len_t len;
1026         struct berval scheme = { 0, NULL };
1027         struct berval cookie = { 0, NULL };
1028
1029         if ( op->o_clientupdate != SLAP_NO_CONTROL ) {
1030                 rs->sr_text = "LCUP client update control specified multiple times";
1031                 return LDAP_PROTOCOL_ERROR;
1032         }
1033
1034 #ifdef LDAP_SYNC
1035         if ( op->o_sync != SLAP_NO_CONTROL ) {
1036                 rs->sr_text = "LDAP Client Update and Sync controls used together";
1037                 return LDAP_PROTOCOL_ERROR;
1038         }
1039 #endif
1040
1041         if ( ctrl->ldctl_value.bv_len == 0 ) {
1042                 rs->sr_text = "LCUP client update control value is empty (or absent)";
1043                 return LDAP_PROTOCOL_ERROR;
1044         }
1045
1046         /* Parse the control value
1047          *      ClientUpdateControlValue ::= SEQUENCE {
1048          *              updateType      ENUMERATED {
1049          *                                      synchronizeOnly {0},
1050          *                                      synchronizeAndPersist {1},
1051          *                                      persistOnly {2} },
1052          *              sendCookieInterval INTEGER OPTIONAL,
1053          *              cookie          LCUPCookie OPTIONAL
1054          *      }
1055          */
1056
1057         ber = ber_init( &ctrl->ldctl_value );
1058         if( ber == NULL ) {
1059                 rs->sr_text = "internal error";
1060                 return LDAP_OTHER;
1061         }
1062
1063         if ( (tag = ber_scanf( ber, "{i" /*}*/, &type )) == LBER_ERROR ) {
1064                 rs->sr_text = "LCUP client update control : decoding error";
1065                 return LDAP_PROTOCOL_ERROR;
1066         }
1067
1068         switch( type ) {
1069         case LDAP_CUP_SYNC_ONLY:
1070                 type = SLAP_LCUP_SYNC;
1071                 break;
1072         case LDAP_CUP_SYNC_AND_PERSIST:
1073                 type = SLAP_LCUP_SYNC_AND_PERSIST;
1074                 break;
1075         case LDAP_CUP_PERSIST_ONLY:
1076                 type = SLAP_LCUP_PERSIST;
1077                 break;
1078         default:
1079                 rs->sr_text = "LCUP client update control : unknown update type";
1080                 return LDAP_PROTOCOL_ERROR;
1081         }
1082
1083         if ( (tag = ber_peek_tag( ber, &len )) == LBER_DEFAULT ) {
1084                 rs->sr_text = "LCUP client update control : decoding error";
1085                 return LDAP_PROTOCOL_ERROR;
1086         }
1087
1088         if ( tag == LDAP_CUP_TAG_INTERVAL ) {
1089                 if ( (tag = ber_scanf( ber, "i", &interval )) == LBER_ERROR ) {
1090                         rs->sr_text = "LCUP client update control : decoding error";
1091                         return LDAP_PROTOCOL_ERROR;
1092                 }
1093                 
1094                 if ( interval <= 0 ) {
1095                         /* server chooses interval */
1096                         interval = LDAP_CUP_DEFAULT_SEND_COOKIE_INTERVAL;
1097                 }
1098
1099         } else {
1100                 /* server chooses interval */
1101                 interval = LDAP_CUP_DEFAULT_SEND_COOKIE_INTERVAL;
1102         }
1103
1104         if ( (tag = ber_peek_tag( ber, &len )) == LBER_DEFAULT ) {
1105                 rs->sr_text = "LCUP client update control : decoding error";
1106                 return LDAP_PROTOCOL_ERROR;
1107         }
1108
1109         if ( tag == LDAP_CUP_TAG_COOKIE ) {
1110                 if ( (tag = ber_scanf( ber, /*{*/ "{mm}}",
1111                         &scheme, &cookie )) == LBER_ERROR )
1112                 {
1113                         rs->sr_text = "LCUP client update control : decoding error";
1114                         return LDAP_PROTOCOL_ERROR;
1115                 }
1116         }
1117
1118         /* TODO : Cookie Scheme Validation */
1119 #if 0
1120         if ( lcup_cookie_scheme_validate(scheme) != LDAP_SUCCESS ) {
1121                 rs->sr_text = "Unsupported LCUP cookie scheme";
1122                 return LCUP_UNSUPPORTED_SCHEME;
1123         }
1124
1125         if ( lcup_cookie_validate(scheme, cookie) != LDAP_SUCCESS ) {
1126                 rs->sr_text = "Invalid LCUP cookie";
1127                 return LCUP_INVALID_COOKIE;
1128         }
1129 #endif
1130
1131         ber_dupbv( &op->o_clientupdate_state, &cookie );
1132
1133         (void) ber_free( ber, 1 );
1134
1135         op->o_clientupdate_type = (char) type;
1136         op->o_clientupdate_interval = interval;
1137
1138         op->o_clientupdate = ctrl->ldctl_iscritical
1139                 ? SLAP_CRITICAL_CONTROL
1140                 : SLAP_NONCRITICAL_CONTROL;
1141
1142         return LDAP_SUCCESS;
1143 }
1144 #endif
1145
1146 #ifdef LDAP_SYNC
1147 static int parseLdupSync (
1148         Operation *op,
1149         SlapReply *rs,
1150         LDAPControl *ctrl )
1151 {
1152         ber_tag_t tag;
1153         BerElement *ber;
1154         ber_int_t mode;
1155         ber_len_t len;
1156         struct berval cookie = { 0, NULL };
1157
1158         if ( op->o_sync != SLAP_NO_CONTROL ) {
1159                 rs->sr_text = "LDAP Sync control specified multiple times";
1160                 return LDAP_PROTOCOL_ERROR;
1161         }
1162
1163 #ifdef LDAP_CLIENT_UPDATE
1164         if ( op->o_clientupdate != SLAP_NO_CONTROL ) {
1165                 rs->sr_text = "LDAP Sync and LDAP Client Update controls used together";
1166                 return LDAP_PROTOCOL_ERROR;
1167         }
1168 #endif
1169
1170         if ( ctrl->ldctl_value.bv_len == 0 ) {
1171                 rs->sr_text = "LDAP Sync control value is empty (or absent)";
1172                 return LDAP_PROTOCOL_ERROR;
1173         }
1174
1175         /* Parse the control value
1176          *      syncRequestValue ::= SEQUENCE {
1177          *              mode   ENUMERATED {
1178          *                      -- 0 unused
1179          *                      refreshOnly             (1),
1180          *                      -- 2 reserved
1181          *                      refreshAndPersist       (3)
1182          *              },
1183          *              cookie  syncCookie OPTIONAL
1184          *      }
1185          */
1186
1187         ber = ber_init( &ctrl->ldctl_value );
1188         if( ber == NULL ) {
1189                 rs->sr_text = "internal error";
1190                 return LDAP_OTHER;
1191         }
1192
1193         if ( (tag = ber_scanf( ber, "{i" /*}*/, &mode )) == LBER_ERROR ) {
1194                 rs->sr_text = "LDAP Sync control : mode decoding error";
1195                 return LDAP_PROTOCOL_ERROR;
1196         }
1197
1198         switch( mode ) {
1199         case LDAP_SYNC_REFRESH_ONLY:
1200                 mode = SLAP_SYNC_REFRESH;
1201                 break;
1202         case LDAP_SYNC_REFRESH_AND_PERSIST:
1203                 mode = SLAP_SYNC_REFRESH_AND_PERSIST;
1204                 break;
1205         default:
1206                 rs->sr_text = "LDAP Sync control : unknown update mode";
1207                 return LDAP_PROTOCOL_ERROR;
1208         }
1209
1210         tag = ber_peek_tag( ber, &len );
1211
1212         if ( tag == LDAP_SYNC_TAG_COOKIE ) {
1213                 if (( ber_scanf( ber, /*{*/ "m}",
1214                                         &cookie )) == LBER_ERROR ) {
1215                         rs->sr_text = "LDAP Sync control : cookie decoding error";
1216                         return LDAP_PROTOCOL_ERROR;
1217                 }
1218         } else {
1219                 if (( ber_scanf( ber, /*{*/ "}")) == LBER_ERROR ) {
1220                         rs->sr_text = "LDAP Sync control : decoding error";
1221                         return LDAP_PROTOCOL_ERROR;
1222                 }
1223                 cookie.bv_len = 0;
1224                 cookie.bv_val = NULL;
1225         }
1226
1227         /* TODO : Cookie Scheme Validation */
1228 #if 0
1229         if ( lcup_cookie_scheme_validate(scheme) != LDAP_SUCCESS ) {
1230                 rs->sr_text = "Unsupported LCUP cookie scheme";
1231                 return LCUP_UNSUPPORTED_SCHEME;
1232         }
1233
1234         if ( lcup_cookie_validate(scheme, cookie) != LDAP_SUCCESS ) {
1235                 rs->sr_text = "Invalid LCUP cookie";
1236                 return LCUP_INVALID_COOKIE;
1237         }
1238 #endif
1239
1240         ber_dupbv( &op->o_sync_state, &cookie );
1241
1242         (void) ber_free( ber, 1 );
1243
1244         op->o_sync_mode = (char) mode;
1245
1246         op->o_sync = ctrl->ldctl_iscritical
1247                 ? SLAP_CRITICAL_CONTROL
1248                 : SLAP_NONCRITICAL_CONTROL;
1249
1250         return LDAP_SUCCESS;
1251 }
1252 #endif