]> git.sur5r.net Git - openldap/blob - servers/slapd/slapcommon.c
dc8ff261b3adc162bae7068e400c1e643ac43149
[openldap] / servers / slapd / slapcommon.c
1 /* slapcommon.c - common routine for the slap tools */
2 /* $OpenLDAP$ */
3 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
4  *
5  * Copyright 1998-2005 The OpenLDAP Foundation.
6  * Portions Copyright 1998-2003 Kurt D. Zeilenga.
7  * Portions Copyright 2003 IBM Corporation.
8  * All rights reserved.
9  *
10  * Redistribution and use in source and binary forms, with or without
11  * modification, are permitted only as authorized by the OpenLDAP
12  * Public License.
13  *
14  * A copy of this license is available in file LICENSE in the
15  * top-level directory of the distribution or, alternatively, at
16  * <http://www.OpenLDAP.org/license.html>.
17  */
18 /* ACKNOWLEDGEMENTS:
19  * This work was initially developed by Kurt Zeilenga for inclusion
20  * in OpenLDAP Software.  Additional signficant contributors include
21  *    Jong Hyuk Choi
22  *    Hallvard B. Furuseth
23  *    Howard Chu
24  *    Pierangelo Masarati
25  */
26
27 #include "portable.h"
28
29 #include <stdio.h>
30
31 #include <ac/stdlib.h>
32 #include <ac/ctype.h>
33 #include <ac/string.h>
34 #include <ac/socket.h>
35 #include <ac/unistd.h>
36
37 #include "slapcommon.h"
38 #include "lutil.h"
39 #include "ldif.h"
40
41 tool_vars tool_globals;
42
43 #ifdef CSRIMALLOC
44 static char *leakfilename;
45 static FILE *leakfile;
46 #endif
47
48 static LDIFFP dummy;
49
50 static void
51 usage( int tool, const char *progname )
52 {
53         char *options = NULL;
54         fprintf( stderr,
55                 "usage: %s [-v] [-d debuglevel] [-f configfile] [-F configdir]",
56                 progname );
57
58         switch( tool ) {
59         case SLAPACL:
60                 options = "\n\t[-U authcID | -D authcDN] [-X authzID | -o authzDN=<DN>]"
61                         "\n\t-b DN -o <var>[=<val>] [-u] [attr[/access][:value]] [...]\n";
62                 break;
63
64         case SLAPADD:
65                 options = " [-c]\n\t[-g] [-n databasenumber | -b suffix]\n"
66                         "\t[-l ldiffile] [-q] [-u] [-w]\n";
67                 break;
68
69         case SLAPAUTH:
70                 options = "\n\t[-U authcID] [-X authzID] [-R realm] [-M mech] ID [...]\n";
71                 break;
72
73         case SLAPCAT:
74                 options = " [-c]\n\t[-g] [-n databasenumber | -b suffix]"
75                         " [-l ldiffile] [-a filter]\n";
76                 break;
77
78         case SLAPDN:
79                 options = "\n\t[-N | -P] DN [...]\n";
80                 break;
81
82         case SLAPINDEX:
83                 options = " [-c]\n\t[-g] [-n databasenumber | -b suffix] [-q]\n";
84                 break;
85
86         case SLAPTEST:
87                 options = " [-u]\n";
88                 break;
89         }
90
91         if ( options != NULL ) {
92                 fputs( options, stderr );
93         }
94         exit( EXIT_FAILURE );
95 }
96
97 static int
98 parse_slapacl( void )
99 {
100         size_t  len;
101         char    *p;
102
103         p = strchr( optarg, '=' );
104         if ( p == NULL ) {
105                 return -1;
106         }
107
108         len = p - optarg;
109         p++;
110
111         if ( strncasecmp( optarg, "sockurl", len ) == 0 ) {
112                 if ( !BER_BVISNULL( &listener_url ) ) {
113                         ber_memfree( listener_url.bv_val );
114                 }
115                 ber_str2bv( p, 0, 1, &listener_url );
116
117         } else if ( strncasecmp( optarg, "domain", len ) == 0 ) {
118                 if ( !BER_BVISNULL( &peer_domain ) ) {
119                         ber_memfree( peer_domain.bv_val );
120                 }
121                 ber_str2bv( p, 0, 1, &peer_domain );
122
123         } else if ( strncasecmp( optarg, "peername", len ) == 0 ) {
124                 if ( !BER_BVISNULL( &peer_name ) ) {
125                         ber_memfree( peer_name.bv_val );
126                 }
127                 ber_str2bv( p, 0, 1, &peer_name );
128
129         } else if ( strncasecmp( optarg, "sockname", len ) == 0 ) {
130                 if ( !BER_BVISNULL( &sock_name ) ) {
131                         ber_memfree( sock_name.bv_val );
132                 }
133                 ber_str2bv( p, 0, 1, &sock_name );
134
135         } else if ( strncasecmp( optarg, "ssf", len ) == 0 ) {
136                 if ( lutil_atou( &ssf, p ) ) {
137                         Debug( LDAP_DEBUG_ANY, "unable to parse ssf=\"%s\".\n", p, 0, 0 );
138                         return -1;
139                 }
140
141         } else if ( strncasecmp( optarg, "transport_ssf", len ) == 0 ) {
142                 if ( lutil_atou( &transport_ssf, p ) ) {
143                         Debug( LDAP_DEBUG_ANY, "unable to parse transport_ssf=\"%s\".\n", p, 0, 0 );
144                         return -1;
145                 }
146
147         } else if ( strncasecmp( optarg, "tls_ssf", len ) == 0 ) {
148                 if ( lutil_atou( &tls_ssf, p ) ) {
149                         Debug( LDAP_DEBUG_ANY, "unable to parse tls_ssf=\"%s\".\n", p, 0, 0 );
150                         return -1;
151                 }
152
153         } else if ( strncasecmp( optarg, "sasl_ssf", len ) == 0 ) {
154                 if ( lutil_atou( &sasl_ssf, p ) ) {
155                         Debug( LDAP_DEBUG_ANY, "unable to parse sasl_ssf=\"%s\".\n", p, 0, 0 );
156                         return -1;
157                 }
158
159         } else if ( strncasecmp( optarg, "authzDN", len ) == 0 ) {
160                 ber_str2bv( p, 0, 1, &authzDN );
161
162         } else {
163                 return -1;
164         }
165
166         return 0;
167 }
168
169 /*
170  * slap_tool_init - initialize slap utility, handle program options.
171  * arguments:
172  *      name            program name
173  *      tool            tool code
174  *      argc, argv      command line arguments
175  */
176
177 void
178 slap_tool_init(
179         const char* progname,
180         int tool,
181         int argc, char **argv )
182 {
183         char *options;
184         char *conffile = NULL;
185         char *confdir = NULL;
186         struct berval base = BER_BVNULL;
187         char *filterstr = NULL;
188         char *subtree = NULL;
189         char *ldiffile  = NULL;
190         int rc, i, dbnum;
191         int mode = SLAP_TOOL_MODE;
192         int truncatemode = 0;
193         int use_glue = 1;
194
195 #ifdef LDAP_DEBUG
196         /* tools default to "none", so that at least LDAP_DEBUG_ANY 
197          * messages show up; use -d 0 to reset */
198         slap_debug = LDAP_DEBUG_NONE;
199 #endif
200
201 #ifdef CSRIMALLOC
202         leakfilename = malloc( strlen( progname ) + STRLENOF( ".leak" ) + 1 );
203         sprintf( leakfilename, "%s.leak", progname );
204         if( ( leakfile = fopen( leakfilename, "w" )) == NULL ) {
205                 leakfile = stderr;
206         }
207         free( leakfilename );
208 #endif
209
210         switch( tool ) {
211         case SLAPADD:
212                 options = "b:cd:f:F:gl:n:qtuvw";
213                 break;
214
215         case SLAPCAT:
216                 options = "a:b:cd:f:F:gl:n:s:v";
217                 mode |= SLAP_TOOL_READMAIN | SLAP_TOOL_READONLY;
218                 break;
219
220         case SLAPDN:
221                 options = "d:f:F:NPv";
222                 mode |= SLAP_TOOL_READMAIN | SLAP_TOOL_READONLY;
223                 break;
224
225         case SLAPTEST:
226                 options = "d:f:F:uv";
227                 mode |= SLAP_TOOL_READMAIN | SLAP_TOOL_READONLY;
228                 break;
229
230         case SLAPAUTH:
231                 options = "d:f:F:M:R:U:vX:";
232                 mode |= SLAP_TOOL_READMAIN | SLAP_TOOL_READONLY;
233                 break;
234
235         case SLAPINDEX:
236                 options = "b:cd:f:F:gn:qv";
237                 mode |= SLAP_TOOL_READMAIN;
238                 break;
239
240         case SLAPACL:
241                 options = "b:D:d:f:F:o:uU:vX:";
242                 mode |= SLAP_TOOL_READMAIN | SLAP_TOOL_READONLY;
243                 break;
244
245         default:
246                 fprintf( stderr, "%s: unknown tool mode (%d)\n", progname, tool );
247                 exit( EXIT_FAILURE );
248         }
249
250         dbnum = -1;
251         while ( (i = getopt( argc, argv, options )) != EOF ) {
252                 switch ( i ) {
253                 case 'a':
254                         filterstr = strdup( optarg );
255                         break;
256
257                 case 'b':
258                         ber_str2bv( optarg, 0, 1, &base );
259                         break;
260
261                 case 'c':       /* enable continue mode */
262                         continuemode++;
263                         break;
264
265                 case 'd':       /* turn on debugging */
266 #ifdef LDAP_DEBUG
267                         if ( optarg != NULL && optarg[ 0 ] != '-' && !isdigit( optarg[ 0 ] ) )
268                         {
269                                 int     level, i, goterr = 0;
270                                 char    **levels;
271
272                                 levels = ldap_str2charray( optarg, "," );
273
274                                 for ( i = 0; levels[ i ] != NULL; i++ ) {
275                                         if ( str2loglevel( levels[ i ], &level ) ) {
276                                                 fprintf( stderr,
277                                                         "unrecognized log level "
278                                                         "\"%s\"\n", levels[ i ] );
279                                                 goterr = 1;
280
281                                         } else {
282                                                 if ( level ) {
283                                                         slap_debug |= level;
284                                                 } else {
285                                                         /* allow to reset log level */
286                                                         slap_debug = 0;
287                                                 }
288                                         }
289                                 }
290
291                                 ldap_charray_free( levels );
292
293                                 if ( goterr ) {
294                                         usage( tool, progname );
295                                 }
296
297                         } else {
298                                 int     level;
299
300                                 if ( lutil_atoix( &level, optarg, 0 ) != 0 ) {
301                                         fprintf( stderr,
302                                                 "unrecognized log level "
303                                                 "\"%s\"\n", optarg );
304                                         usage( tool, progname );
305                                 }
306
307                                 if ( level ) {
308                                         slap_debug |= level;
309                                 } else {
310                                         /* allow to reset log level */
311                                         slap_debug = 0;
312                                 }
313                         }
314 #else
315                         if ( lutil_atoi( &level, optarg ) != 0 || level != 0 )
316                                 fputs( "must compile with LDAP_DEBUG for debugging\n",
317                                        stderr );
318 #endif
319                         break;
320
321                 case 'D':
322                         ber_str2bv( optarg, 0, 1, &authcDN );
323                         break;
324
325                 case 'f':       /* specify a conf file */
326                         conffile = strdup( optarg );
327                         break;
328
329                 case 'F':       /* specify a conf dir */
330                         confdir = strdup( optarg );
331                         break;
332
333                 case 'g':       /* disable subordinate glue */
334                         use_glue = 0;
335                         break;
336
337                 case 'l':       /* LDIF file */
338                         ldiffile = strdup( optarg );
339                         break;
340
341                 case 'M':
342                         ber_str2bv( optarg, 0, 0, &mech );
343                         break;
344
345                 case 'N':
346                         if ( dn_mode && dn_mode != SLAP_TOOL_LDAPDN_NORMAL ) {
347                                 usage( tool, progname );
348                         }
349                         dn_mode = SLAP_TOOL_LDAPDN_NORMAL;
350                         break;
351
352                 case 'n':       /* which config file db to index */
353                         if ( lutil_atoi( &dbnum, optarg ) ) {
354                                 usage( tool, progname );
355                         }
356                         break;
357
358                 case 'o':
359                         if ( parse_slapacl() ) {
360                                 usage( tool, progname );
361                         }
362                         break;
363
364                 case 'P':
365                         if ( dn_mode && dn_mode != SLAP_TOOL_LDAPDN_PRETTY ) {
366                                 usage( tool, progname );
367                         }
368                         dn_mode = SLAP_TOOL_LDAPDN_PRETTY;
369                         break;
370
371                 case 'q':       /* turn on quick */
372                         mode |= SLAP_TOOL_QUICK;
373                         break;
374
375                 case 'R':
376                         realm = optarg;
377                         break;
378
379                 case 's':       /* dump subtree */
380                         subtree = strdup( optarg );
381                         break;
382
383                 case 't':       /* turn on truncate */
384                         truncatemode++;
385                         mode |= SLAP_TRUNCATE_MODE;
386                         break;
387
388                 case 'U':
389                         ber_str2bv( optarg, 0, 0, &authcID );
390                         break;
391
392                 case 'u':       /* dry run */
393                         dryrun++;
394                         break;
395
396                 case 'v':       /* turn on verbose */
397                         verbose++;
398                         break;
399
400                 case 'w':       /* write context csn at the end */
401                         update_ctxcsn++;
402                         break;
403
404                 case 'X':
405                         ber_str2bv( optarg, 0, 0, &authzID );
406                         break;
407
408                 default:
409                         usage( tool, progname );
410                         break;
411                 }
412         }
413
414         switch ( tool ) {
415         case SLAPADD:
416         case SLAPCAT:
417         case SLAPINDEX:
418                 if ( ( argc != optind ) || (dbnum >= 0 && base.bv_val != NULL ) ) {
419                         usage( tool, progname );
420                 }
421
422                 break;
423
424         case SLAPDN:
425                 if ( argc == optind ) {
426                         usage( tool, progname );
427                 }
428                 break;
429
430         case SLAPAUTH:
431                 if ( argc == optind && BER_BVISNULL( &authcID ) ) {
432                         usage( tool, progname );
433                 }
434                 break;
435
436         case SLAPTEST:
437                 if ( argc != optind ) {
438                         usage( tool, progname );
439                 }
440                 break;
441
442         case SLAPACL:
443                 if ( !BER_BVISNULL( &authcDN ) && !BER_BVISNULL( &authcID ) ) {
444                         usage( tool, progname );
445                 }
446                 if ( BER_BVISNULL( &base ) ) {
447                         usage( tool, progname );
448                 }
449                 ber_dupbv( &baseDN, &base );
450                 break;
451
452         default:
453                 break;
454         }
455
456         ldap_syslog = 0;
457
458         if ( ldiffile == NULL ) {
459                 dummy.fp = tool == SLAPCAT ? stdout : stdin;
460                 ldiffp = &dummy;
461
462         } else if ((ldiffp = ldif_open( ldiffile, tool == SLAPCAT ? "w" : "r" ))
463                 == NULL )
464         {
465                 perror( ldiffile );
466                 exit( EXIT_FAILURE );
467         }
468
469         /*
470          * initialize stuff and figure out which backend we're dealing with
471          */
472
473         rc = slap_init( mode, progname );
474         if ( rc != 0 ) {
475                 fprintf( stderr, "%s: slap_init failed!\n", progname );
476                 exit( EXIT_FAILURE );
477         }
478
479         rc = read_config( conffile, confdir );
480
481         if ( rc != 0 ) {
482                 fprintf( stderr, "%s: bad configuration %s!\n",
483                         progname, confdir ? "directory" : "file" );
484                 exit( EXIT_FAILURE );
485         }
486
487         at_oc_cache = 1;
488
489         switch ( tool ) {
490         case SLAPADD:
491         case SLAPCAT:
492         case SLAPINDEX:
493                 if ( !nbackends ) {
494                         fprintf( stderr, "No databases found "
495                                         "in config file\n" );
496                         exit( EXIT_FAILURE );
497                 }
498                 break;
499
500         default:
501                 break;
502         }
503
504         if ( use_glue ) {
505                 rc = glue_sub_attach();
506
507                 if ( rc != 0 ) {
508                         fprintf( stderr,
509                                 "%s: subordinate configuration error\n", progname );
510                         exit( EXIT_FAILURE );
511                 }
512         }
513
514         rc = slap_schema_check();
515
516         if ( rc != 0 ) {
517                 fprintf( stderr, "%s: slap_schema_prep failed!\n", progname );
518                 exit( EXIT_FAILURE );
519         }
520
521         switch ( tool ) {
522         case SLAPDN:
523         case SLAPTEST:
524         case SLAPAUTH:
525                 be = NULL;
526                 goto startup;
527
528         default:
529                 break;
530         }
531
532         if( filterstr ) {
533                 filter = str2filter( filterstr );
534
535                 if( filter == NULL ) {
536                         fprintf( stderr, "Invalid filter '%s'\n", filterstr );
537                         exit( EXIT_FAILURE );
538                 }
539         }
540
541         if( subtree ) {
542                 struct berval val;
543                 ber_str2bv( subtree, 0, 0, &val );
544                 rc = dnNormalize( 0, NULL, NULL, &val, &sub_ndn, NULL );
545                 if( rc != LDAP_SUCCESS ) {
546                         fprintf( stderr, "Invalid subtree DN '%s'\n", subtree );
547                         exit( EXIT_FAILURE );
548                 }
549
550                 if ( BER_BVISNULL( &base ) && dbnum == -1 ) {
551                         base = val;
552                 } else {
553                         free( subtree );
554                 }
555         }
556
557         if( base.bv_val != NULL ) {
558                 struct berval nbase;
559
560                 rc = dnNormalize( 0, NULL, NULL, &base, &nbase, NULL );
561                 if( rc != LDAP_SUCCESS ) {
562                         fprintf( stderr, "%s: slap_init invalid suffix (\"%s\")\n",
563                                 progname, base.bv_val );
564                         exit( EXIT_FAILURE );
565                 }
566
567                 be = select_backend( &nbase, 0, 0 );
568                 ber_memfree( nbase.bv_val );
569
570                 switch ( tool ) {
571                 case SLAPACL:
572                         goto startup;
573
574                 default:
575                         break;
576                 }
577
578                 if( be == NULL ) {
579                         fprintf( stderr, "%s: slap_init no backend for \"%s\"\n",
580                                 progname, base.bv_val );
581                         exit( EXIT_FAILURE );
582                 }
583                 /* If the named base is a glue master, operate on the
584                  * entire context
585                  */
586                 if ( SLAP_GLUE_INSTANCE( be ) ) {
587                         nosubordinates = 1;
588                 }
589
590         } else if ( dbnum == -1 ) {
591                 /* no suffix and no dbnum specified, just default to
592                  * the first available database
593                  */
594                 if ( nbackends <= 0 ) {
595                         fprintf( stderr, "No available databases\n" );
596                         exit( EXIT_FAILURE );
597                 }
598                 LDAP_STAILQ_FOREACH( be, &backendDB, be_next ) {
599                         dbnum++;
600
601                         /* db #0 is cn=config, don't select it as a default */
602                         if ( dbnum < 1 ) continue;
603                 
604                         if ( SLAP_MONITOR(be))
605                                 continue;
606
607                 /* If just doing the first by default and it is a
608                  * glue subordinate, find the master.
609                  */
610                         if ( SLAP_GLUE_SUBORDINATE(be) ) {
611                                 nosubordinates = 1;
612                                 continue;
613                         }
614                         break;
615                 }
616
617                 if ( !be ) {
618                         fprintf( stderr, "Available database(s) "
619                                         "do not allow %s\n", progname );
620                         exit( EXIT_FAILURE );
621                 }
622                 
623                 if ( nosubordinates == 0 && dbnum > 1 ) {
624                         Debug( LDAP_DEBUG_ANY,
625                                 "The first database does not allow %s;"
626                                 " using the first available one (%d)\n",
627                                 progname, dbnum, 0 );
628                 }
629
630         } else if ( dbnum < 0 || dbnum > (nbackends-1) ) {
631                 fprintf( stderr,
632                         "Database number selected via -n is out of range\n"
633                         "Must be in the range 0 to %d"
634                         " (number of configured databases)\n",
635                         nbackends-1 );
636                 exit( EXIT_FAILURE );
637
638         } else {
639                 LDAP_STAILQ_FOREACH( be, &backendDB, be_next ) {
640                         if ( dbnum == 0 ) break;
641                         dbnum--;
642                 }
643         }
644
645 startup:;
646
647 #ifdef CSRIMALLOC
648         mal_leaktrace(1);
649 #endif
650
651         if ( conffile != NULL ) {
652                 ch_free( conffile );
653         }
654
655         if ( ldiffile != NULL ) {
656                 ch_free( ldiffile );
657         }
658
659         /* slapdn doesn't specify a backend to startup */
660         if ( !dryrun && tool != SLAPDN && slap_startup( be ) ) {
661                 switch ( tool ) {
662                 case SLAPTEST:
663                         fprintf( stderr, "slap_startup failed "
664                                         "(test would succeed using "
665                                         "the -u switch)\n" );
666                         break;
667
668                 default:
669                         fprintf( stderr, "slap_startup failed\n" );
670                         break;
671                 }
672                 
673                 exit( EXIT_FAILURE );
674         }
675 }
676
677 void slap_tool_destroy( void )
678 {
679         if ( !dryrun ) {
680                 slap_shutdown( be );
681                 slap_destroy();
682         }
683 #ifdef SLAPD_MODULES
684         if ( slapMode == SLAP_SERVER_MODE ) {
685         /* always false. just pulls in necessary symbol references. */
686                 lutil_uuidstr(NULL, 0);
687         }
688         module_kill();
689 #endif
690         schema_destroy();
691 #ifdef HAVE_TLS
692         ldap_pvt_tls_destroy();
693 #endif
694         config_destroy();
695
696 #ifdef CSRIMALLOC
697         mal_dumpleaktrace( leakfile );
698 #endif
699
700         if ( !BER_BVISNULL( &authcDN ) ) {
701                 ch_free( authcDN.bv_val );
702         }
703 }