]> git.sur5r.net Git - openldap/blobdiff - servers/slapd/main.c
declare overlays_init()
[openldap] / servers / slapd / main.c
index 40a036ce8928174ac48e5ae7c1836c922dd9d8b4..d656dec7d1dd45a601a27d59b36ed4357272a815 100644 (file)
@@ -1,10 +1,29 @@
 /* $OpenLDAP$ */
-/*
- * Copyright 1998-2002 The OpenLDAP Foundation, All Rights Reserved.
- * COPYING RESTRICTIONS APPLY, see COPYRIGHT file
+/* This work is part of OpenLDAP Software <http://www.openldap.org/>.
+ *
+ * Copyright 1998-2003 The OpenLDAP Foundation.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted only as authorized by the OpenLDAP
+ * Public License.
+ *
+ * A copy of this license is available in the file LICENSE in the
+ * top-level directory of the distribution or, alternatively, at
+ * <http://www.OpenLDAP.org/license.html>.
+ */
+/* Portions Copyright (c) 1995 Regents of the University of Michigan.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms are permitted
+ * provided that this notice is preserved and that due credit is given
+ * to the University of Michigan at Ann Arbor. The name of the University
+ * may not be used to endorse or promote products derived from this
+ * software without specific prior written permission. This software
+ * is provided ``as is'' without express or implied warranty.
  */
+
 #include "portable.h"
-#include "slapi_common.h"
 
 #include <stdio.h>
 
 
 #include "ldap_pvt.h"
 
-
 #include "slap.h"
-#include "slapi.h"
 #include "lutil.h"
 #include "ldif.h"
 
+#ifdef LDAP_SLAPI
+#include "slapi.h"
+#endif
+
 #ifdef LDAP_SIGCHLD
 static RETSIGTYPE wait4child( int sig );
 #endif
@@ -31,15 +52,10 @@ static RETSIGTYPE wait4child( int sig );
 #define MAIN_RETURN(x) return
 static struct sockaddr_in      bind_addr;
 
-void CommenceStartupProcessing( LPCTSTR serverName,
-                                                          void(*stopper)(int));
-void ReportSlapdShutdownComplete( void );
-void *getRegParam( char *svc, char *value );
-
 #define SERVICE_EXIT( e, n )   do { \
        if ( is_NT_Service ) { \
-               SLAPDServiceStatus.dwWin32ExitCode                              = (e); \
-               SLAPDServiceStatus.dwServiceSpecificExitCode    = (n); \
+               lutil_ServiceStatus.dwWin32ExitCode                             = (e); \
+               lutil_ServiceStatus.dwServiceSpecificExitCode   = (n); \
        } \
 } while ( 0 )
 
@@ -48,11 +64,6 @@ void *getRegParam( char *svc, char *value );
 #define MAIN_RETURN(x) return(x)
 #endif
 
-#ifdef HAVE_NT_EVENT_LOG
-void LogSlapdStartedEvent( char *svc, int slap_debug, char *configfile, char *urls );
-void LogSlapdStoppedEvent( char *svc );
-#endif
-
 /*
  * when more than one slapd is running on one machine, each one might have
  * it's own LOCAL for syslogging and must have its own pid/args files
@@ -84,7 +95,7 @@ static STRDISP        syslog_types[] = {
        { "LOCAL5", sizeof("LOCAL5"), LOG_LOCAL5 },
        { "LOCAL6", sizeof("LOCAL6"), LOG_LOCAL6 },
        { "LOCAL7", sizeof("LOCAL7"), LOG_LOCAL7 },
-       { NULL }
+       { NULL, 0, 0 }
 };
 
 static int   cnvt_str2int( char *, STRDISP_P, int );
@@ -92,6 +103,7 @@ static int   cnvt_str2int( char *, STRDISP_P, int );
 #endif /* LOG_LOCAL4 */
 
 static int check_config = 0;
+static int version = 0;
 
 static void
 usage( char *name )
@@ -101,6 +113,7 @@ usage( char *name )
        fprintf( stderr,
                "\t-4\t\tIPv4 only\n"
                "\t-6\t\tIPv6 only\n"
+               "\t-c cookie\tSync cookie of consumer\n"
                "\t-d level\tDebug level" "\n"
                "\t-f filename\tConfiguration file\n"
 #if defined(HAVE_SETUID) && defined(HAVE_SETGID)
@@ -118,6 +131,7 @@ usage( char *name )
                "\t-t\t\tCheck configuration file and exit\n"
 #if defined(HAVE_SETUID) && defined(HAVE_SETGID)
                "\t-u user\t\tUser (id or name) to run as\n"
+               "\t-V\t\tprint version info (-VV only)\n"
 #endif
     );
 }
@@ -153,6 +167,10 @@ int main( int argc, char **argv )
        char        *serverName = NULL;
        int         serverMode = SLAP_SERVER_MODE;
 
+       struct berval cookie = { 0, NULL };
+       struct sync_cookie *scp = NULL;
+       struct sync_cookie *scp_entry = NULL;
+
 #ifdef CSRIMALLOC
        FILE *leakfile;
        if( ( leakfile = fopen( "slapd.leak", "w" )) == NULL ) {
@@ -160,6 +178,7 @@ int main( int argc, char **argv )
        }
 #endif
 
+       sl_mem_init();
 
 #ifdef HAVE_NT_SERVICE_MANAGER
        {
@@ -170,12 +189,12 @@ int main( int argc, char **argv )
 
                if ( is_NT_Service ) {
                        serverName = argv[0];
-                       CommenceStartupProcessing( serverName, slap_sig_shutdown );
+                       lutil_CommenceStartupProcessing( serverName, slap_sig_shutdown );
                        if ( strcmp(serverName, SERVICE_NAME) )
                            regService = serverName;
                }
 
-               i = (int*)getRegParam( regService, "DebugLevel" );
+               i = (int*)lutil_getRegParam( regService, "DebugLevel" );
                if ( i != NULL ) 
                {
                        slap_debug = *i;
@@ -189,7 +208,7 @@ int main( int argc, char **argv )
 #endif
                }
 
-               newUrls = (char *) getRegParam(regService, "Urls");
+               newUrls = (char *) lutil_getRegParam(regService, "Urls");
                if (newUrls)
                {
                    if (urls)
@@ -206,7 +225,7 @@ int main( int argc, char **argv )
 
                }
 
-               newConfigFile = (char*)getRegParam( regService, "ConfigFile" );
+               newConfigFile = (char*)lutil_getRegParam( regService, "ConfigFile" );
                if ( newConfigFile != NULL ) 
                {
                        configfile = newConfigFile;
@@ -222,7 +241,7 @@ int main( int argc, char **argv )
 #endif
 
        while ( (i = getopt( argc, argv,
-                            "d:f:h:s:n:t"
+                            "c:d:f:h:s:n:t:V"
 #if LDAP_PF_INET6
                                "46"
 #endif
@@ -249,7 +268,32 @@ int main( int argc, char **argv )
                case 'h':       /* listen URLs */
                        if ( urls != NULL ) free( urls );
                        urls = ch_strdup( optarg );
-           break;
+                       break;
+
+               case 'c':       /* provide sync cookie, override if exist in replica */
+                       scp = (struct sync_cookie *) ch_calloc( 1,
+                                                                               sizeof( struct sync_cookie ));
+                       ber_str2bv( optarg, strlen( optarg ), 1, &cookie );
+                       ber_bvarray_add( &scp->octet_str, &cookie );
+                       slap_parse_sync_cookie( scp );
+
+                       LDAP_STAILQ_FOREACH( scp_entry, &slap_sync_cookie, sc_next ) {
+                               if ( scp->rid == scp_entry->rid ) {
+#ifdef NEW_LOGGING
+                                       LDAP_LOG( OPERATION, CRIT,
+                                                       "main: duplicated replica id in cookies\n",
+                                                       0, 0, 0 );
+#else
+                                       Debug( LDAP_DEBUG_ANY,
+                                                   "main: duplicated replica id in cookies\n",
+                                                       0, 0, 0 );
+#endif
+                                       slap_sync_cookie_free( scp, 1 );
+                                       goto destroy;
+                               }
+                       }
+                       LDAP_STAILQ_INSERT_TAIL( &slap_sync_cookie, scp, sc_next );
+                       break;
 
                case 'd':       /* set debug level and 'do not detach' flag */
                        no_detach = 1;
@@ -304,6 +348,9 @@ int main( int argc, char **argv )
                case 't':
                        check_config++;
                        break;
+               case 'V':
+                       version++;
+                       break;
 
                default:
                        usage( argv[0] );
@@ -322,12 +369,10 @@ int main( int argc, char **argv )
        ldif_debug = slap_debug;
 #endif
 
-#ifdef NEW_LOGGING
-       LDAP_LOG( SLAPD, INFO, "%s", Versionstr, 0, 0 );
-#else
-       Debug( LDAP_DEBUG_TRACE, "%s", Versionstr, 0, 0 );
-#endif
-
+       if ( version ) {
+               fprintf( stderr, "%s\n", Versionstr );
+               if ( version > 1 ) goto stop;
+       }
 
        if( serverName == NULL ) {
                if ( (serverName = strrchr( argv[0], *LDAP_DIRSEP )) == NULL ) {
@@ -343,6 +388,12 @@ int main( int argc, char **argv )
        openlog( serverName, OPENLOG_OPTIONS );
 #endif
 
+#ifdef NEW_LOGGING
+       LDAP_LOG( SLAPD, INFO, "%s", Versionstr, 0, 0 );
+#else
+       Debug( LDAP_DEBUG_ANY, "%s", Versionstr, 0, 0 );
+#endif
+
        if( !check_config && slapd_daemon_init( urls ) != 0 ) {
                rc = 1;
                SERVICE_EXIT( ERROR_SERVICE_SPECIFIC_ERROR, 16 );
@@ -371,6 +422,8 @@ int main( int argc, char **argv )
 #endif
 
        extops_init();
+       lutil_passwd_init();
+       slap_op_init();
 
 #ifdef SLAPD_MODULES
        if ( module_init() != 0 ) {
@@ -380,18 +433,30 @@ int main( int argc, char **argv )
        }
 #endif
 
+       if ( slap_schema_init( ) != 0 ) {
+#ifdef NEW_LOGGING
+               LDAP_LOG( OPERATION, CRIT, "main: schema initialization error\n", 0, 0, 0 );
+#else
+               Debug( LDAP_DEBUG_ANY,
+                   "schema initialization error\n",
+                   0, 0, 0 );
+#endif
+
+               goto destroy;
+       }
+
        if ( slap_init( serverMode, serverName ) != 0 ) {
                rc = 1;
                SERVICE_EXIT( ERROR_SERVICE_SPECIFIC_ERROR, 18 );
                goto destroy;
        }
 
-       if ( slap_schema_init( ) != 0 ) {
+       if ( slap_controls_init( ) != 0 ) {
 #ifdef NEW_LOGGING
-               LDAP_LOG( OPERATION, CRIT, "main: schema initialization error\n", 0, 0, 0 );
+               LDAP_LOG( OPERATION, CRIT, "main: controls initialization error\n", 0, 0, 0 );
 #else
                Debug( LDAP_DEBUG_ANY,
-                   "schema initialization error\n",
+                   "controls initialization error\n",
                    0, 0, 0 );
 #endif
 
@@ -422,6 +487,10 @@ int main( int argc, char **argv )
        }
 #endif /* LDAP_SLAPI */
 
+       if ( overlay_init() ) {
+               goto destroy;
+       }
+
        if ( read_config( configfile, 0 ) != 0 ) {
                rc = 1;
                SERVICE_EXIT( ERROR_SERVICE_SPECIFIC_ERROR, 19 );
@@ -519,43 +588,56 @@ int main( int argc, char **argv )
        mal_leaktrace(1);
 #endif
 
+       /*
+        * FIXME: moved here from slapd_daemon_task()
+        * because back-monitor db_open() needs it
+        */
+       time( &starttime );
+
        if ( slap_startup( NULL )  != 0 ) {
                rc = 1;
                SERVICE_EXIT( ERROR_SERVICE_SPECIFIC_ERROR, 21 );
                goto shutdown;
        }
 
-       {
-               FILE *fp;
-
 #ifdef NEW_LOGGING
-               LDAP_LOG( SLAPD, INFO, "main: slapd starting.\n", 0, 0, 0 );
+       LDAP_LOG( SLAPD, INFO, "main: slapd starting.\n", 0, 0, 0 );
 #else
-               Debug( LDAP_DEBUG_ANY, "slapd starting\n", 0, 0, 0 );
+       Debug( LDAP_DEBUG_ANY, "slapd starting\n", 0, 0, 0 );
 #endif
 
 
-               if (( slapd_pid_file != NULL ) &&
-                       (( fp = fopen( slapd_pid_file, "w" )) != NULL ))
-               {
+       if ( slapd_pid_file != NULL ) {
+               FILE *fp = fopen( slapd_pid_file, "w" );
+
+               if( fp != NULL ) {
                        fprintf( fp, "%d\n", (int) getpid() );
                        fclose( fp );
+
+               } else {
+                       free(slapd_pid_file);
+                       slapd_pid_file = NULL;
                }
+       }
 
-               if (( slapd_args_file != NULL ) &&
-                       (( fp = fopen( slapd_args_file, "w" )) != NULL ))
-               {
+       if ( slapd_args_file != NULL ) {
+               FILE *fp = fopen( slapd_args_file, "w" );
+
+               if( fp != NULL ) {
                        for ( i = 0; i < g_argc; i++ ) {
                                fprintf( fp, "%s ", g_argv[i] );
                        }
                        fprintf( fp, "\n" );
                        fclose( fp );
+               } else {
+                       free(slapd_args_file);
+                       slapd_args_file = NULL;
                }
        }
 
 #ifdef HAVE_NT_EVENT_LOG
        if (is_NT_Service)
-       LogSlapdStartedEvent( serverName, slap_debug, configfile, urls );
+       lutil_LogStartedEvent( serverName, slap_debug, configfile, urls );
 #endif
 
        rc = slapd_daemon();
@@ -574,16 +656,24 @@ destroy:
        /* remember an error during destroy */
        rc |= slap_destroy();
 
+       while ( !LDAP_STAILQ_EMPTY( &slap_sync_cookie )) {
+               scp = LDAP_STAILQ_FIRST( &slap_sync_cookie );
+               LDAP_STAILQ_REMOVE_HEAD( &slap_sync_cookie, sc_next );
+               ch_free( scp );
+       }
+
 #ifdef SLAPD_MODULES
        module_kill();
 #endif
 
+       slap_op_destroy();
+
        extops_kill();
 
 stop:
 #ifdef HAVE_NT_EVENT_LOG
        if (is_NT_Service)
-       LogSlapdStoppedEvent( serverName );
+       lutil_LogStoppedEvent( serverName );
 #endif
 
 #ifdef NEW_LOGGING
@@ -594,7 +684,7 @@ stop:
 
 
 #ifdef HAVE_NT_SERVICE_MANAGER
-       ReportSlapdShutdownComplete();
+       lutil_ReportShutdownComplete();
 #endif
 
 #ifdef LOG_DEBUG
@@ -602,12 +692,23 @@ stop:
 #endif
        slapd_daemon_destroy();
 
+       controls_destroy();
+
        schema_destroy();
 
+       lutil_passwd_destroy();
+
 #ifdef HAVE_TLS
        ldap_pvt_tls_destroy();
 #endif
 
+       if ( slapd_pid_file != NULL ) {
+               unlink( slapd_pid_file );
+       }
+       if ( slapd_args_file != NULL ) {
+               unlink( slapd_args_file );
+       }
+
        config_destroy();
 
 #ifdef CSRIMALLOC