]> git.sur5r.net Git - openldap/blob - servers/slapd/controls.c
First cut at thread-local malloc. Only used by search() for now...
[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_SEARCH, NULL,
110                 parseClientUpdate, LDAP_SLIST_ENTRY_INITIALIZER(next) },
111 #endif
112 #ifdef LDAP_SYNC
113         { LDAP_CONTROL_SYNC,
114                 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                 vals[0].bv_val = sc->sc_oid;
252                 vals[0].bv_len = strlen( sc->sc_oid );
253                 if ( attr_merge( e, ad_supportedControl, vals, NULL ) )
254                         return -1;
255         }
256
257         return 0;
258 }
259
260 /*
261  * Return a list of OIDs and operation masks for supported
262  * controls. Used by SLAPI.
263  */
264 int
265 get_supported_controls(char ***ctrloidsp,
266         slap_mask_t **ctrlmasks)
267 {
268         int i, n;
269         char **oids;
270         slap_mask_t *masks;
271         int rc;
272         struct slap_control *sc;
273
274         n = 0;
275
276         LDAP_SLIST_FOREACH( sc, &controls_list, sc_next ) {
277                 n++;
278         }
279
280         if ( n == 0 ) {
281                 *ctrloidsp = NULL;
282                 *ctrlmasks = NULL;
283                 return LDAP_SUCCESS;
284         }
285
286         oids = (char **)SLAP_MALLOC( (n + 1) * sizeof(char *) );
287         if ( oids == NULL ) {
288                 return LDAP_NO_MEMORY;
289         }
290         masks = (slap_mask_t *)SLAP_MALLOC( (n + 1) * sizeof(slap_mask_t) );
291         if  ( masks == NULL ) {
292                 ch_free( oids );
293                 return LDAP_NO_MEMORY;
294         }
295
296         n = 0;
297
298         LDAP_SLIST_FOREACH( sc, &controls_list, sc_next ) {
299                 oids[n] = ch_strdup( sc->sc_oid );
300                 masks[n] = sc->sc_mask;
301                 n++;
302         }
303         oids[n] = NULL;
304         masks[n] = 0;
305
306         *ctrloidsp = oids;
307         *ctrlmasks = masks;
308
309         return LDAP_SUCCESS;
310 }
311
312 /*
313  * Find a control given its OID.
314  */
315 static struct slap_control *
316 find_ctrl( const char *oid )
317 {
318         struct slap_control *sc;
319
320         LDAP_SLIST_FOREACH( sc, &controls_list, sc_next ) {
321                 if ( strcmp( oid, sc->sc_oid ) == 0 ) {
322                         return sc;
323                 }
324         }
325
326         return NULL;
327 }
328
329 void slap_free_ctrls(
330         Operation *op,
331         LDAPControl **ctrls
332 )
333 {
334         int i;
335
336         for (i=0; ctrls[i]; i++) {
337                 op->o_tmpfree(ctrls[i], op->o_tmpmemctx );
338         }
339         op->o_tmpfree( ctrls, op->o_tmpmemctx );
340 }
341
342 int get_ctrls(
343         Operation *op,
344         SlapReply *rs,
345         int sendres )
346 {
347         int nctrls = 0;
348         ber_tag_t tag;
349         ber_len_t len;
350         char *opaque;
351         BerElement *ber = op->o_ber;
352         struct slap_control *sc;
353         struct berval bv;
354         BER_MEMREALLOC_FN *reallo;
355
356         reallo = op->o_tmpmemctx ? sl_realloc : (BER_MEMREALLOC_FN *)ch_realloc;
357
358         len = ber_pvt_ber_remaining(ber);
359
360         if( len == 0) {
361                 /* no controls */
362                 rs->sr_err = LDAP_SUCCESS;
363                 return rs->sr_err;
364         }
365
366         if(( tag = ber_peek_tag( ber, &len )) != LDAP_TAG_CONTROLS ) {
367                 if( tag == LBER_ERROR ) {
368                         rs->sr_err = SLAPD_DISCONNECT;
369                         rs->sr_text = "unexpected data in PDU";
370                 }
371
372                 goto return_results;
373         }
374
375 #ifdef NEW_LOGGING
376         LDAP_LOG( OPERATION, ENTRY,
377                 "get_ctrls: conn %lu\n", op->o_connid, 0, 0 );
378 #else
379         Debug( LDAP_DEBUG_TRACE,
380                 "=> get_ctrls\n", 0, 0, 0 );
381 #endif
382
383         if( op->o_protocol < LDAP_VERSION3 ) {
384                 rs->sr_err = SLAPD_DISCONNECT;
385                 rs->sr_text = "controls require LDAPv3";
386                 goto return_results;
387         }
388
389         /* one for first control, one for termination */
390         op->o_ctrls = op->o_tmpalloc( 2 * sizeof(LDAPControl *), op->o_tmpmemctx );
391
392 #if 0
393         if( op->ctrls == NULL ) {
394                 rs->sr_err = LDAP_NO_MEMORY;
395                 rs->sr_text = "no memory";
396                 goto return_results;
397         }
398 #endif
399
400         op->o_ctrls[nctrls] = NULL;
401
402         /* step through each element */
403         for( tag = ber_first_element( ber, &len, &opaque );
404                 tag != LBER_ERROR;
405                 tag = ber_next_element( ber, &len, opaque ) )
406         {
407                 LDAPControl *c;
408                 LDAPControl **tctrls;
409
410                 c = op->o_tmpalloc( sizeof(LDAPControl), op->o_tmpmemctx );
411                 memset(c, 0, sizeof(LDAPControl));
412
413                 /* allocate pointer space for current controls (nctrls)
414                  * + this control + extra NULL
415                  */
416                 tctrls = reallo( op->o_ctrls,
417                         (nctrls+2) * sizeof(LDAPControl *), op->o_tmpmemctx );
418
419 #if 0
420                 if( tctrls == NULL ) {
421                         ch_free( c );
422                         ldap_controls_free(op->o_ctrls);
423                         op->o_ctrls = NULL;
424
425                         rs->sr_err = LDAP_NO_MEMORY;
426                         rs->sr_text = "no memory";
427                         goto return_results;
428                 }
429 #endif
430                 op->o_ctrls = tctrls;
431
432                 op->o_ctrls[nctrls++] = c;
433                 op->o_ctrls[nctrls] = NULL;
434
435                 tag = ber_scanf( ber, "{m" /*}*/, &bv );
436                 c->ldctl_oid = bv.bv_val;
437
438                 if( tag == LBER_ERROR ) {
439 #ifdef NEW_LOGGING
440                         LDAP_LOG( OPERATION, INFO, "get_ctrls: conn %lu get OID failed.\n",
441                                 op->o_connid, 0, 0 );
442 #else
443                         Debug( LDAP_DEBUG_TRACE, "=> get_ctrls: get oid failed.\n",
444                                 0, 0, 0 );
445 #endif
446
447                         slap_free_ctrls( op, op->o_ctrls );
448                         op->o_ctrls = NULL;
449                         rs->sr_err = SLAPD_DISCONNECT;
450                         rs->sr_text = "decoding controls error";
451                         goto return_results;
452
453                 } else if( c->ldctl_oid == NULL ) {
454 #ifdef NEW_LOGGING
455                         LDAP_LOG( OPERATION, INFO,
456                                 "get_ctrls: conn %lu got emtpy OID.\n",
457                                 op->o_connid, 0, 0 );
458 #else
459                         Debug( LDAP_DEBUG_TRACE,
460                                 "get_ctrls: conn %lu got emtpy OID.\n",
461                                 op->o_connid, 0, 0 );
462 #endif
463
464                         slap_free_ctrls( op, op->o_ctrls );
465                         op->o_ctrls = NULL;
466                         rs->sr_err = LDAP_PROTOCOL_ERROR;
467                         rs->sr_text = "OID field is empty";
468                         goto return_results;
469                 }
470
471                 tag = ber_peek_tag( ber, &len );
472
473                 if( tag == LBER_BOOLEAN ) {
474                         ber_int_t crit;
475                         tag = ber_scanf( ber, "b", &crit );
476
477                         if( tag == LBER_ERROR ) {
478 #ifdef NEW_LOGGING
479                                 LDAP_LOG( OPERATION, INFO, 
480                                         "get_ctrls: conn %lu get crit failed.\n", 
481                                         op->o_connid, 0, 0 );
482 #else
483                                 Debug( LDAP_DEBUG_TRACE, "=> get_ctrls: get crit failed.\n",
484                                         0, 0, 0 );
485 #endif
486                                 slap_free_ctrls( op, op->o_ctrls );
487                                 op->o_ctrls = NULL;
488                                 rs->sr_err = SLAPD_DISCONNECT;
489                                 rs->sr_text = "decoding controls error";
490                                 goto return_results;
491                         }
492
493                         c->ldctl_iscritical = (crit != 0);
494                         tag = ber_peek_tag( ber, &len );
495                 }
496
497                 if( tag == LBER_OCTETSTRING ) {
498                         tag = ber_scanf( ber, "m", &c->ldctl_value );
499
500                         if( tag == LBER_ERROR ) {
501 #ifdef NEW_LOGGING
502                                 LDAP_LOG( OPERATION, INFO, "get_ctrls: conn %lu: "
503                                         "%s (%scritical): get value failed.\n",
504                                         op->o_connid, c->ldctl_oid,
505                                         c->ldctl_iscritical ? "" : "non" );
506 #else
507                                 Debug( LDAP_DEBUG_TRACE, "=> get_ctrls: conn %lu: "
508                                         "%s (%scritical): get value failed.\n",
509                                         op->o_connid, c->ldctl_oid,
510                                         c->ldctl_iscritical ? "" : "non" );
511 #endif
512                                 slap_free_ctrls( op, op->o_ctrls );
513                                 op->o_ctrls = NULL;
514                                 rs->sr_err = SLAPD_DISCONNECT;
515                                 rs->sr_text = "decoding controls error";
516                                 goto return_results;
517                         }
518                 }
519
520 #ifdef NEW_LOGGING
521                 LDAP_LOG( OPERATION, INFO, 
522                         "get_ctrls: conn %lu oid=\"%s\" (%scritical)\n",
523                         op->o_connid, c->ldctl_oid, c->ldctl_iscritical ? "" : "non" );
524 #else
525                 Debug( LDAP_DEBUG_TRACE,
526                         "=> get_ctrls: oid=\"%s\" (%scritical)\n",
527                         c->ldctl_oid, c->ldctl_iscritical ? "" : "non", 0 );
528 #endif
529
530                 sc = find_ctrl( c->ldctl_oid );
531                 if( sc != NULL ) {
532                         /* recognized control */
533                         slap_mask_t tagmask;
534                         switch( op->o_tag ) {
535                         case LDAP_REQ_ADD:
536                                 tagmask = SLAP_CTRL_ADD;
537                                 break;
538                         case LDAP_REQ_BIND:
539                                 tagmask = SLAP_CTRL_BIND;
540                                 break;
541                         case LDAP_REQ_COMPARE:
542                                 tagmask = SLAP_CTRL_COMPARE;
543                                 break;
544                         case LDAP_REQ_DELETE:
545                                 tagmask = SLAP_CTRL_DELETE;
546                                 break;
547                         case LDAP_REQ_MODIFY:
548                                 tagmask = SLAP_CTRL_MODIFY;
549                                 break;
550                         case LDAP_REQ_RENAME:
551                                 tagmask = SLAP_CTRL_RENAME;
552                                 break;
553                         case LDAP_REQ_SEARCH:
554                                 tagmask = SLAP_CTRL_SEARCH;
555                                 break;
556                         case LDAP_REQ_UNBIND:
557                                 tagmask = SLAP_CTRL_UNBIND;
558                                 break;
559                         case LDAP_REQ_ABANDON:
560                                 tagmask = SLAP_CTRL_ABANDON;
561                                 break;
562                         case LDAP_REQ_EXTENDED:
563                                 tagmask=~0L;
564                                 assert( op->ore_reqoid.bv_val != NULL );
565                                 if( sc->sc_extendedops != NULL ) {
566                                         int i;
567                                         for( i=0; sc->sc_extendedops[i] != NULL; i++ ) {
568                                                 if( strcmp( op->ore_reqoid.bv_val, sc->sc_extendedops[i] )
569                                                         == 0 )
570                                                 {
571                                                         tagmask=0L;
572                                                         break;
573                                                 }
574                                         }
575                                 }
576                                 break;
577                         default:
578                                 rs->sr_err = LDAP_OTHER;
579                                 rs->sr_text = "controls internal error";
580                                 goto return_results;
581                         }
582
583                         if (( sc->sc_mask & tagmask ) == tagmask ) {
584                                 /* available extension */
585
586                                 if( !sc->sc_parse ) {
587                                         rs->sr_err = LDAP_OTHER;
588                                         rs->sr_text = "not yet implemented";
589                                         goto return_results;
590                                 }
591
592                                 rs->sr_err = sc->sc_parse( op, rs, c );
593
594                                 if( rs->sr_err != LDAP_SUCCESS ) goto return_results;
595
596                                 if ( sc->sc_mask & SLAP_CTRL_FRONTEND ) {
597                                         /* kludge to disable backend_control() check */
598                                         c->ldctl_iscritical = 0;
599
600                                 } else if ( tagmask == SLAP_CTRL_SEARCH &&
601                                         sc->sc_mask & SLAP_CTRL_FRONTEND_SEARCH )
602                                 {
603                                         /* kludge to disable backend_control() check */
604                                         c->ldctl_iscritical = 0;
605                                 }
606
607                         } else if( c->ldctl_iscritical ) {
608                                 /* unavailable CRITICAL control */
609                                 rs->sr_err = LDAP_UNAVAILABLE_CRITICAL_EXTENSION;
610                                 rs->sr_text = "critical extension is unavailable";
611                                 goto return_results;
612                         }
613
614                 } else if( c->ldctl_iscritical ) {
615                         /* unrecognized CRITICAL control */
616                         rs->sr_err = LDAP_UNAVAILABLE_CRITICAL_EXTENSION;
617                         rs->sr_text = "critical extension is not recognized";
618                         goto return_results;
619                 }
620         }
621
622 return_results:
623 #ifdef NEW_LOGGING
624         LDAP_LOG( OPERATION, RESULTS, 
625                 "get_ctrls: n=%d rc=%d err=\"%s\"\n",
626                 nctrls, rs->sr_err, rs->sr_text ? rs->sr_text : "" );
627 #else
628         Debug( LDAP_DEBUG_TRACE,
629                 "<= get_ctrls: n=%d rc=%d err=\"%s\"\n",
630                 nctrls, rs->sr_err, rs->sr_text ? rs->sr_text : "");
631 #endif
632
633         if( sendres && rs->sr_err != LDAP_SUCCESS ) {
634                 if( rs->sr_err == SLAPD_DISCONNECT ) {
635                         rs->sr_err = LDAP_PROTOCOL_ERROR;
636                         send_ldap_disconnect( op, rs );
637                         rs->sr_err = SLAPD_DISCONNECT;
638                 } else {
639                         send_ldap_result( op, rs );
640                 }
641         }
642
643         return rs->sr_err;
644 }
645
646 static int parseManageDSAit (
647         Operation *op,
648         SlapReply *rs,
649         LDAPControl *ctrl )
650 {
651         if ( op->o_managedsait != SLAP_NO_CONTROL ) {
652                 rs->sr_text = "manageDSAit control specified multiple times";
653                 return LDAP_PROTOCOL_ERROR;
654         }
655
656         if ( ctrl->ldctl_value.bv_len ) {
657                 rs->sr_text = "manageDSAit control value not empty";
658                 return LDAP_PROTOCOL_ERROR;
659         }
660
661         op->o_managedsait = ctrl->ldctl_iscritical
662                 ? SLAP_CRITICAL_CONTROL
663                 : SLAP_NONCRITICAL_CONTROL;
664
665         return LDAP_SUCCESS;
666 }
667
668 static int parseProxyAuthz (
669         Operation *op,
670         SlapReply *rs,
671         LDAPControl *ctrl )
672 {
673         int rc;
674         struct berval dn = { 0, NULL };
675
676         if ( op->o_proxy_authz != SLAP_NO_CONTROL ) {
677                 rs->sr_text = "proxy authorization control specified multiple times";
678                 return LDAP_PROTOCOL_ERROR;
679         }
680
681         op->o_proxy_authz = ctrl->ldctl_iscritical
682                 ? SLAP_CRITICAL_CONTROL
683                 : SLAP_NONCRITICAL_CONTROL;
684
685 #ifdef NEW_LOGGING
686         LDAP_LOG( OPERATION, ARGS, 
687                 "parseProxyAuthz: conn %lu authzid=\"%s\"\n", 
688                 op->o_connid,
689                 ctrl->ldctl_value.bv_len ?  ctrl->ldctl_value.bv_val : "anonymous",
690                 0 );
691 #else
692         Debug( LDAP_DEBUG_ARGS,
693                 "parseProxyAuthz: conn %lu authzid=\"%s\"\n", 
694                 op->o_connid,
695                 ctrl->ldctl_value.bv_len ?  ctrl->ldctl_value.bv_val : "anonymous",
696                 0 );
697 #endif
698
699         if( ctrl->ldctl_value.bv_len == 0 ) {
700 #ifdef NEW_LOGGING
701                 LDAP_LOG( OPERATION, RESULTS, 
702                         "parseProxyAuthz: conn=%lu anonymous\n", 
703                         op->o_connid, 0, 0 );
704 #else
705                 Debug( LDAP_DEBUG_TRACE,
706                         "parseProxyAuthz: conn=%lu anonymous\n", 
707                         op->o_connid, 0, 0 );
708 #endif
709
710                 /* anonymous */
711                 free( op->o_dn.bv_val );
712                 op->o_dn.bv_len = 0;
713                 op->o_dn.bv_val = ch_strdup( "" );
714
715                 free( op->o_ndn.bv_val );
716                 op->o_ndn.bv_len = 0;
717                 op->o_ndn.bv_val = ch_strdup( "" );
718
719                 return LDAP_SUCCESS;
720         }
721
722         rc = slap_sasl_getdn( op->o_conn, op,
723                 ctrl->ldctl_value.bv_val, ctrl->ldctl_value.bv_len,
724                 NULL, &dn, SLAP_GETDN_AUTHZID );
725
726         if( rc != LDAP_SUCCESS || !dn.bv_len ) {
727                 if ( dn.bv_val ) {
728                         ch_free( dn.bv_val );
729                 }
730                 rs->sr_text = "authzId mapping failed";
731                 return LDAP_PROXY_AUTHZ_FAILURE;
732         }
733
734 #ifdef NEW_LOGGING
735         LDAP_LOG( OPERATION, RESULTS, 
736                 "parseProxyAuthz: conn=%lu \"%s\"\n", 
737                 op->o_connid,
738                 dn.bv_len ? dn.bv_val : "(NULL)", 0 );
739 #else
740         Debug( LDAP_DEBUG_TRACE,
741                 "parseProxyAuthz: conn=%lu \"%s\"\n", 
742                 op->o_connid,
743                 dn.bv_len ? dn.bv_val : "(NULL)", 0 );
744 #endif
745
746         rc = slap_sasl_authorized( op->o_conn, &op->o_ndn, &dn );
747
748         if( rc ) {
749                 ch_free( dn.bv_val );
750                 rs->sr_text = "not authorized to assume identity";
751                 return LDAP_PROXY_AUTHZ_FAILURE;
752         }
753
754         ch_free( op->o_dn.bv_val );
755         ch_free( op->o_ndn.bv_val );
756
757         op->o_dn.bv_val = NULL;
758         op->o_ndn = dn;
759
760         /*
761          * NOTE: since slap_sasl_getdn() returns a normalized dn,
762          * from now on op->o_dn is normalized
763          */
764         ber_dupbv( &op->o_dn, &dn );
765
766         return LDAP_SUCCESS;
767 }
768
769 static int parseNoOp (
770         Operation *op,
771         SlapReply *rs,
772         LDAPControl *ctrl )
773 {
774         if ( op->o_noop != SLAP_NO_CONTROL ) {
775                 rs->sr_text = "noop control specified multiple times";
776                 return LDAP_PROTOCOL_ERROR;
777         }
778
779         if ( ctrl->ldctl_value.bv_len ) {
780                 rs->sr_text = "noop control value not empty";
781                 return LDAP_PROTOCOL_ERROR;
782         }
783
784         op->o_noop = ctrl->ldctl_iscritical
785                 ? SLAP_CRITICAL_CONTROL
786                 : SLAP_NONCRITICAL_CONTROL;
787
788         return LDAP_SUCCESS;
789 }
790
791 #ifdef LDAP_CONTROL_PAGEDRESULTS
792 static int parsePagedResults (
793         Operation *op,
794         SlapReply *rs,
795         LDAPControl *ctrl )
796 {
797         ber_tag_t tag;
798         ber_int_t size;
799         BerElement *ber;
800         struct berval cookie = { 0, NULL };
801
802         if ( op->o_pagedresults != SLAP_NO_CONTROL ) {
803                 rs->sr_text = "paged results control specified multiple times";
804                 return LDAP_PROTOCOL_ERROR;
805         }
806
807         if ( ctrl->ldctl_value.bv_len == 0 ) {
808                 rs->sr_text = "paged results control value is empty (or absent)";
809                 return LDAP_PROTOCOL_ERROR;
810         }
811
812         /* Parse the control value
813          *      realSearchControlValue ::= SEQUENCE {
814          *              size    INTEGER (0..maxInt),
815          *                              -- requested page size from client
816          *                              -- result set size estimate from server
817          *              cookie  OCTET STRING
818          * }
819          */
820         ber = ber_init( &ctrl->ldctl_value );
821         if( ber == NULL ) {
822                 rs->sr_text = "internal error";
823                 return LDAP_OTHER;
824         }
825
826         tag = ber_scanf( ber, "{im}", &size, &cookie );
827         (void) ber_free( ber, 1 );
828
829         if( tag == LBER_ERROR ) {
830                 rs->sr_text = "paged results control could not be decoded";
831                 return LDAP_PROTOCOL_ERROR;
832         }
833
834         if( size < 0 ) {
835                 rs->sr_text = "paged results control size invalid";
836                 return LDAP_PROTOCOL_ERROR;
837         }
838
839         if( cookie.bv_len ) {
840                 PagedResultsCookie reqcookie;
841                 if( cookie.bv_len != sizeof( reqcookie ) ) {
842                         /* bad cookie */
843                         rs->sr_text = "paged results cookie is invalid";
844                         return LDAP_PROTOCOL_ERROR;
845                 }
846
847                 AC_MEMCPY( &reqcookie, cookie.bv_val, sizeof( reqcookie ));
848
849                 if( reqcookie > op->o_pagedresults_state.ps_cookie ) {
850                         /* bad cookie */
851                         rs->sr_text = "paged results cookie is invalid";
852                         return LDAP_PROTOCOL_ERROR;
853
854                 } else if( reqcookie < op->o_pagedresults_state.ps_cookie ) {
855                         rs->sr_text = "paged results cookie is invalid or old";
856                         return LDAP_UNWILLING_TO_PERFORM;
857                 }
858         } else {
859                 /* Initial request.  Initialize state. */
860                 op->o_pagedresults_state.ps_cookie = 0;
861                 op->o_pagedresults_state.ps_id = NOID;
862         }
863
864         op->o_pagedresults_size = size;
865
866         op->o_pagedresults = ctrl->ldctl_iscritical
867                 ? SLAP_CRITICAL_CONTROL
868                 : SLAP_NONCRITICAL_CONTROL;
869
870         return LDAP_SUCCESS;
871 }
872 #endif
873
874 int parseValuesReturnFilter (
875         Operation *op,
876         SlapReply *rs,
877         LDAPControl *ctrl )
878 {
879         BerElement      *ber;
880         struct berval   fstr = { 0, NULL };
881         const char *err_msg = "";
882
883         if ( op->o_valuesreturnfilter != SLAP_NO_CONTROL ) {
884                 rs->sr_text = "valuesReturnFilter control specified multiple times";
885                 return LDAP_PROTOCOL_ERROR;
886         }
887
888         if ( ctrl->ldctl_value.bv_len == 0 ) {
889                 rs->sr_text = "valuesReturnFilter control value is empty (or absent)";
890                 return LDAP_PROTOCOL_ERROR;
891         }
892
893         ber = ber_init( &(ctrl->ldctl_value) );
894         if (ber == NULL) {
895                 rs->sr_text = "internal error";
896                 return LDAP_OTHER;
897         }
898         
899         rs->sr_err = get_vrFilter( op, ber, &(op->vrFilter), &rs->sr_text);
900
901         if( rs->sr_err != LDAP_SUCCESS ) {
902                 if( rs->sr_err == SLAPD_DISCONNECT ) {
903                         rs->sr_err = LDAP_PROTOCOL_ERROR;
904                         send_ldap_disconnect( op, rs );
905                         rs->sr_err = SLAPD_DISCONNECT;
906                 } else {
907                         send_ldap_result( op, rs );
908                 }
909                 if( op->vrFilter != NULL) vrFilter_free( op, op->vrFilter ); 
910
911         }
912 #ifdef LDAP_DEBUG
913         else {
914                 vrFilter2bv( op, op->vrFilter, &fstr );
915         }
916
917 #ifdef NEW_LOGGING
918         LDAP_LOG( OPERATION, ARGS, 
919                 "parseValuesReturnFilter: conn %d       vrFilter: %s\n", 
920                 op->o_connid, fstr.bv_len ? fstr.bv_val : "empty" , 0 );
921 #else
922         Debug( LDAP_DEBUG_ARGS, "       vrFilter: %s\n",
923                 fstr.bv_len ? fstr.bv_val : "empty", 0, 0 );
924 #endif
925         op->o_tmpfree( fstr.bv_val, op->o_tmpmemctx );
926 #endif
927
928         op->o_valuesreturnfilter = ctrl->ldctl_iscritical
929                 ? SLAP_CRITICAL_CONTROL
930                 : SLAP_NONCRITICAL_CONTROL;
931
932         rs->sr_err = LDAP_SUCCESS;
933         return LDAP_SUCCESS;
934 }
935
936 #ifdef LDAP_CONTROL_SUBENTRIES
937 static int parseSubentries (
938         Operation *op,
939         SlapReply *rs,
940         LDAPControl *ctrl )
941 {
942         if ( op->o_subentries != SLAP_NO_CONTROL ) {
943                 rs->sr_text = "subentries control specified multiple times";
944                 return LDAP_PROTOCOL_ERROR;
945         }
946
947         /* FIXME: should use BER library */
948         if( ( ctrl->ldctl_value.bv_len != 3 )
949                 && ( ctrl->ldctl_value.bv_val[0] != 0x01 )
950                 && ( ctrl->ldctl_value.bv_val[1] != 0x01 ))
951         {
952                 rs->sr_text = "subentries control value encoding is bogus";
953                 return LDAP_PROTOCOL_ERROR;
954         }
955
956         op->o_subentries = ctrl->ldctl_iscritical
957                 ? SLAP_CRITICAL_CONTROL
958                 : SLAP_NONCRITICAL_CONTROL;
959
960         op->o_subentries_visibility = (ctrl->ldctl_value.bv_val[2] != 0x00);
961
962         return LDAP_SUCCESS;
963 }
964 #endif
965
966 #ifdef LDAP_CONTROL_X_PERMISSIVE_MODIFY
967 static int parsePermissiveModify (
968         Operation *op,
969         SlapReply *rs,
970         LDAPControl *ctrl )
971 {
972         if ( op->o_permissive_modify != SLAP_NO_CONTROL ) {
973                 rs->sr_text = "permissiveModify control specified multiple times";
974                 return LDAP_PROTOCOL_ERROR;
975         }
976
977         if ( ctrl->ldctl_value.bv_len ) {
978                 rs->sr_text = "permissiveModify control value not empty";
979                 return LDAP_PROTOCOL_ERROR;
980         }
981
982         op->o_permissive_modify = ctrl->ldctl_iscritical
983                 ? SLAP_CRITICAL_CONTROL
984                 : SLAP_NONCRITICAL_CONTROL;
985
986         return LDAP_SUCCESS;
987 }
988 #endif
989
990 #ifdef LDAP_CONTROL_X_DOMAIN_SCOPE
991 static int parseDomainScope (
992         Operation *op,
993         SlapReply *rs,
994         LDAPControl *ctrl )
995 {
996         if ( op->o_domain_scope != SLAP_NO_CONTROL ) {
997                 rs->sr_text = "domainScope control specified multiple times";
998                 return LDAP_PROTOCOL_ERROR;
999         }
1000
1001         if ( ctrl->ldctl_value.bv_len ) {
1002                 rs->sr_text = "domainScope control value not empty";
1003                 return LDAP_PROTOCOL_ERROR;
1004         }
1005
1006         op->o_domain_scope = ctrl->ldctl_iscritical
1007                 ? SLAP_CRITICAL_CONTROL
1008                 : SLAP_NONCRITICAL_CONTROL;
1009
1010         return LDAP_SUCCESS;
1011 }
1012 #endif
1013
1014 #ifdef LDAP_CLIENT_UPDATE
1015 static int parseClientUpdate (
1016         Operation *op,
1017         SlapReply *rs,
1018         LDAPControl *ctrl )
1019 {
1020         ber_tag_t tag;
1021         BerElement *ber;
1022         ber_int_t type;
1023         ber_int_t interval;
1024         ber_len_t len;
1025         struct berval scheme = { 0, NULL };
1026         struct berval cookie = { 0, NULL };
1027
1028         if ( op->o_clientupdate != SLAP_NO_CONTROL ) {
1029                 rs->sr_text = "LCUP client update control specified multiple times";
1030                 return LDAP_PROTOCOL_ERROR;
1031         }
1032
1033 #ifdef LDAP_SYNC
1034         if ( op->o_sync != SLAP_NO_CONTROL ) {
1035                 rs->sr_text = "LDAP Client Update and Sync controls used together";
1036                 return LDAP_PROTOCOL_ERROR;
1037         }
1038 #endif
1039
1040         if ( ctrl->ldctl_value.bv_len == 0 ) {
1041                 rs->sr_text = "LCUP client update control value is empty (or absent)";
1042                 return LDAP_PROTOCOL_ERROR;
1043         }
1044
1045         /* Parse the control value
1046          *      ClientUpdateControlValue ::= SEQUENCE {
1047          *              updateType      ENUMERATED {
1048          *                                      synchronizeOnly {0},
1049          *                                      synchronizeAndPersist {1},
1050          *                                      persistOnly {2} },
1051          *              sendCookieInterval INTEGER OPTIONAL,
1052          *              cookie          LCUPCookie OPTIONAL
1053          *      }
1054          */
1055
1056         ber = ber_init( &ctrl->ldctl_value );
1057         if( ber == NULL ) {
1058                 rs->sr_text = "internal error";
1059                 return LDAP_OTHER;
1060         }
1061
1062         if ( (tag = ber_scanf( ber, "{i" /*}*/, &type )) == LBER_ERROR ) {
1063                 rs->sr_text = "LCUP client update control : decoding error";
1064                 return LDAP_PROTOCOL_ERROR;
1065         }
1066
1067         switch( type ) {
1068         case LDAP_CUP_SYNC_ONLY:
1069                 type = SLAP_LCUP_SYNC;
1070                 break;
1071         case LDAP_CUP_SYNC_AND_PERSIST:
1072                 type = SLAP_LCUP_SYNC_AND_PERSIST;
1073                 break;
1074         case LDAP_CUP_PERSIST_ONLY:
1075                 type = SLAP_LCUP_PERSIST;
1076                 break;
1077         default:
1078                 rs->sr_text = "LCUP client update control : unknown update type";
1079                 return LDAP_PROTOCOL_ERROR;
1080         }
1081
1082         if ( (tag = ber_peek_tag( ber, &len )) == LBER_DEFAULT ) {
1083                 rs->sr_text = "LCUP client update control : decoding error";
1084                 return LDAP_PROTOCOL_ERROR;
1085         }
1086
1087         if ( tag == LDAP_CUP_TAG_INTERVAL ) {
1088                 if ( (tag = ber_scanf( ber, "i", &interval )) == LBER_ERROR ) {
1089                         rs->sr_text = "LCUP client update control : decoding error";
1090                         return LDAP_PROTOCOL_ERROR;
1091                 }
1092                 
1093                 if ( interval <= 0 ) {
1094                         /* server chooses interval */
1095                         interval = LDAP_CUP_DEFAULT_SEND_COOKIE_INTERVAL;
1096                 }
1097
1098         } else {
1099                 /* server chooses interval */
1100                 interval = LDAP_CUP_DEFAULT_SEND_COOKIE_INTERVAL;
1101         }
1102
1103         if ( (tag = ber_peek_tag( ber, &len )) == LBER_DEFAULT ) {
1104                 rs->sr_text = "LCUP client update control : decoding error";
1105                 return LDAP_PROTOCOL_ERROR;
1106         }
1107
1108         if ( tag == LDAP_CUP_TAG_COOKIE ) {
1109                 if ( (tag = ber_scanf( ber, /*{*/ "{mm}}",
1110                         &scheme, &cookie )) == LBER_ERROR )
1111                 {
1112                         rs->sr_text = "LCUP client update control : decoding error";
1113                         return LDAP_PROTOCOL_ERROR;
1114                 }
1115         }
1116
1117         /* TODO : Cookie Scheme Validation */
1118 #if 0
1119         if ( lcup_cookie_scheme_validate(scheme) != LDAP_SUCCESS ) {
1120                 rs->sr_text = "Unsupported LCUP cookie scheme";
1121                 return LCUP_UNSUPPORTED_SCHEME;
1122         }
1123
1124         if ( lcup_cookie_validate(scheme, cookie) != LDAP_SUCCESS ) {
1125                 rs->sr_text = "Invalid LCUP cookie";
1126                 return LCUP_INVALID_COOKIE;
1127         }
1128 #endif
1129
1130         ber_dupbv( &op->o_clientupdate_state, &cookie );
1131
1132         (void) ber_free( ber, 1 );
1133
1134         op->o_clientupdate_type = (char) type;
1135         op->o_clientupdate_interval = interval;
1136
1137         op->o_clientupdate = ctrl->ldctl_iscritical
1138                 ? SLAP_CRITICAL_CONTROL
1139                 : SLAP_NONCRITICAL_CONTROL;
1140
1141         return LDAP_SUCCESS;
1142 }
1143 #endif
1144
1145 #ifdef LDAP_SYNC
1146 static int parseLdupSync (
1147         Operation *op,
1148         SlapReply *rs,
1149         LDAPControl *ctrl )
1150 {
1151         ber_tag_t tag;
1152         BerElement *ber;
1153         ber_int_t mode;
1154         ber_len_t len;
1155         struct berval cookie = { 0, NULL };
1156
1157         if ( op->o_sync != SLAP_NO_CONTROL ) {
1158                 rs->sr_text = "LDAP Sync control specified multiple times";
1159                 return LDAP_PROTOCOL_ERROR;
1160         }
1161
1162 #ifdef LDAP_CLIENT_UPDATE
1163         if ( op->o_clientupdate != SLAP_NO_CONTROL ) {
1164                 rs->sr_text = "LDAP Sync and LDAP Client Update controls used together";
1165                 return LDAP_PROTOCOL_ERROR;
1166         }
1167 #endif
1168
1169         if ( ctrl->ldctl_value.bv_len == 0 ) {
1170                 rs->sr_text = "LDAP Sync control value is empty (or absent)";
1171                 return LDAP_PROTOCOL_ERROR;
1172         }
1173
1174         /* Parse the control value
1175          *      syncRequestValue ::= SEQUENCE {
1176          *              mode   ENUMERATED {
1177          *                      -- 0 unused
1178          *                      refreshOnly             (1),
1179          *                      -- 2 reserved
1180          *                      refreshAndPersist       (3)
1181          *              },
1182          *              cookie  syncCookie OPTIONAL
1183          *      }
1184          */
1185
1186         ber = ber_init( &ctrl->ldctl_value );
1187         if( ber == NULL ) {
1188                 rs->sr_text = "internal error";
1189                 return LDAP_OTHER;
1190         }
1191
1192         if ( (tag = ber_scanf( ber, "{i" /*}*/, &mode )) == LBER_ERROR ) {
1193                 rs->sr_text = "LDAP Sync control : mode decoding error";
1194                 return LDAP_PROTOCOL_ERROR;
1195         }
1196
1197         switch( mode ) {
1198         case LDAP_SYNC_REFRESH_ONLY:
1199                 mode = SLAP_SYNC_REFRESH;
1200                 break;
1201         case LDAP_SYNC_REFRESH_AND_PERSIST:
1202                 mode = SLAP_SYNC_REFRESH_AND_PERSIST;
1203                 break;
1204         default:
1205                 rs->sr_text = "LDAP Sync control : unknown update mode";
1206                 return LDAP_PROTOCOL_ERROR;
1207         }
1208
1209         tag = ber_peek_tag( ber, &len );
1210
1211         if ( tag == LDAP_SYNC_TAG_COOKIE ) {
1212                 if (( ber_scanf( ber, /*{*/ "m}",
1213                                         &cookie )) == LBER_ERROR ) {
1214                         rs->sr_text = "LDAP Sync control : cookie decoding error";
1215                         return LDAP_PROTOCOL_ERROR;
1216                 }
1217         } else {
1218                 if (( ber_scanf( ber, /*{*/ "}")) == LBER_ERROR ) {
1219                         rs->sr_text = "LDAP Sync control : decoding error";
1220                         return LDAP_PROTOCOL_ERROR;
1221                 }
1222                 cookie.bv_len = 0;
1223                 cookie.bv_val = NULL;
1224         }
1225
1226         /* TODO : Cookie Scheme Validation */
1227 #if 0
1228         if ( lcup_cookie_scheme_validate(scheme) != LDAP_SUCCESS ) {
1229                 rs->sr_text = "Unsupported LCUP cookie scheme";
1230                 return LCUP_UNSUPPORTED_SCHEME;
1231         }
1232
1233         if ( lcup_cookie_validate(scheme, cookie) != LDAP_SUCCESS ) {
1234                 rs->sr_text = "Invalid LCUP cookie";
1235                 return LCUP_INVALID_COOKIE;
1236         }
1237 #endif
1238
1239         ber_dupbv( &op->o_sync_state, &cookie );
1240
1241         (void) ber_free( ber, 1 );
1242
1243         op->o_sync_mode = (char) mode;
1244
1245         op->o_sync = ctrl->ldctl_iscritical
1246                 ? SLAP_CRITICAL_CONTROL
1247                 : SLAP_NONCRITICAL_CONTROL;
1248
1249         return LDAP_SUCCESS;
1250 }
1251 #endif