Fixed up atomic update code.
[tprouty/samba.git] / source / smbd / server.c
index 5bcb47393a63a1cc4f3ec7d240f648ab2128ceb2..08bcf22dd293392498bceb3a6cbba99b0d098214 100644 (file)
@@ -21,8 +21,6 @@
 
 #include "includes.h"
 
-pstring servicesf = CONFIGFILE;
-extern pstring debugf;
 extern fstring global_myworkgroup;
 extern pstring global_myname;
 
@@ -34,8 +32,6 @@ int last_message = -1;
 /* a useful macro to debug the last message processed */
 #define LAST_MESSAGE() smb_fn_name(last_message)
 
-extern int DEBUGLEVEL;
-
 extern pstring user_socket_options;
 
 #ifdef WITH_DFS
@@ -80,6 +76,31 @@ static void  killkids(void)
        if(am_parent) kill(0,SIGTERM);
 }
 
+/****************************************************************************
+  process a sam sync message - not sure whether to do this here or
+  somewhere else
+****************************************************************************/
+static void msg_sam_sync(int msg_type, pid_t pid, void *buf, size_t len)
+{
+        DEBUG(10, ("** sam sync message received, ignoring\n"));
+}
+
+/****************************************************************************
+  process a sam sync replicate message - not sure whether to do this here or
+  somewhere else
+****************************************************************************/
+static void msg_sam_repl(int msg_type, pid_t pid, void *buf, size_t len)
+{
+        uint32 low_serial;
+
+        if (len != sizeof(uint32))
+                return;
+
+        low_serial = *((uint32 *)buf);
+
+        DEBUG(3, ("received sam replication message, serial = 0x%04x\n",
+                  low_serial));
+}
 
 /****************************************************************************
   open the socket communication
@@ -196,6 +217,11 @@ max can be %d\n",
                FD_SET(s,&listen_set);
        } 
 
+        /* Listen to messages */
+
+        message_register(MSG_SMB_SAM_SYNC, msg_sam_sync);
+        message_register(MSG_SMB_SAM_REPL, msg_sam_repl);
+
        /* now accept incoming connections - forking a new process
           for each incoming connection */
        DEBUG(2,("waiting for a connection\n"));
@@ -219,7 +245,7 @@ max can be %d\n",
 
                        /* check for sighup processing */
                        if (reload_after_sighup) {
-                               unbecome_user();
+                               change_to_root_user();
                                DEBUG(1,("Reloading services after SIGHUP\n"));
                                reload_services(False);
                                reload_after_sighup = False;
@@ -279,6 +305,9 @@ max can be %d\n",
                                   done correctly in the process.  */
                                reset_globals_after_fork();
 
+                               /* tdb needs special fork handling */
+                               tdb_reopen_all();
+
                                return True; 
                        }
                        /* The parent doesn't need this socket */
@@ -326,8 +355,8 @@ BOOL reload_services(BOOL test)
        if (lp_loaded()) {
                pstring fname;
                pstrcpy(fname,lp_configfile());
-               if (file_exist(fname,NULL) && !strcsequal(fname,servicesf)) {
-                       pstrcpy(servicesf,fname);
+               if (file_exist(fname,NULL) && !strcsequal(fname,dyn_CONFIGFILE)) {
+                       pstrcpy(dyn_CONFIGFILE,fname);
                        test = False;
                }
        }
@@ -339,7 +368,7 @@ BOOL reload_services(BOOL test)
 
        lp_killunused(conn_snum_used);
        
-       ret = lp_load(servicesf,False,False,True);
+       ret = lp_load(dyn_CONFIGFILE,False,False,True);
 
        load_printers();
 
@@ -362,7 +391,7 @@ BOOL reload_services(BOOL test)
        reset_stat_cache();
 
        /* this forces service parameters to be flushed */
-       become_service(NULL,True);
+       set_current_service(NULL,True);
 
        return(ret);
 }
@@ -395,7 +424,7 @@ static BOOL dump_core(void)
 {
        char *p;
        pstring dname;
-       pstrcpy(dname,debugf);
+       pstrcpy(dname,lp_logfile());
        if ((p=strrchr_m(dname,'/'))) *p=0;
        pstrcat(dname,"/corefiles");
        mkdir(dname,0700);
@@ -431,11 +460,11 @@ update the current smbd process count
 
 static void decrement_smbd_process_count(void)
 {
-       int total_smbds;
+       int32 total_smbds;
 
        if (lp_max_smbd_processes()) {
                total_smbds = 0;
-               tdb_change_int_atomic(conn_tdb_ctx(), "INFO/total_smbds", &total_smbds, -1);
+               tdb_change_int32_atomic(conn_tdb_ctx(), "INFO/total_smbds", &total_smbds, -1);
        }
 }
 
@@ -446,14 +475,19 @@ void exit_server(char *reason)
 {
        static int firsttime=1;
        extern char *last_inbuf;
+       extern struct auth_context *negprot_global_auth_context;
 
-
-       if (!firsttime) exit(0);
+       if (!firsttime)
+               exit(0);
        firsttime = 0;
 
-       unbecome_user();
+       change_to_root_user();
        DEBUG(2,("Closing connections\n"));
 
+       if (negprot_global_auth_context) {
+               negprot_global_auth_context->free(&negprot_global_auth_context);
+       }
+
        conn_close_all();
 
        invalidate_all_vuids();
@@ -527,36 +561,39 @@ usage on the program
 static void usage(char *pname)
 {
 
-       printf("Usage: %s [-DaoPh?V] [-d debuglevel] [-l log basename] [-p port]\n", pname);
-       printf("       [-O socket options] [-s services file]\n");
-       printf("\t-D                    Become a daemon\n");
-       printf("\t-a                    Append to log file (default)\n");
-       printf("\t-o                    Overwrite log file, don't append\n");
-       printf("\t-h                    Print usage\n");
-       printf("\t-?                    Print usage\n");
-       printf("\t-V                    Print version\n");
-       printf("\t-d debuglevel         Set the debuglevel\n");
-       printf("\t-l log basename.      Basename for log/debug files\n");
-       printf("\t-p port               Listen on the specified port\n");
-       printf("\t-O socket options     Socket options\n");
-       printf("\t-s services file.     Filename of services file\n");
-       printf("\n");
+       d_printf("Usage: %s [-DaioPh?Vb] [-d debuglevel] [-l log basename] [-p port]\n", pname);
+       d_printf("       [-O socket options] [-s services file]\n");
+       d_printf("\t-D                    Become a daemon (default)\n");
+       d_printf("\t-a                    Append to log file (default)\n");
+       d_printf("\t-i                    Run interactive (not a daemon)\n" );
+       d_printf("\t-o                    Overwrite log file, don't append\n");
+       d_printf("\t-h                    Print usage\n");
+       d_printf("\t-?                    Print usage\n");
+       d_printf("\t-V                    Print version\n");
+       d_printf("\t-b                    Print build options\n");
+       d_printf("\t-d debuglevel         Set the debuglevel\n");
+       d_printf("\t-l log basename.      Basename for log/debug files\n");
+       d_printf("\t-p port               Listen on the specified port\n");
+       d_printf("\t-O socket options     Socket options\n");
+       d_printf("\t-s services file.     Filename of services file\n");
+       d_printf("\n");
 }
 
-
 /****************************************************************************
   main program
 ****************************************************************************/
  int main(int argc,char *argv[])
 {
        extern BOOL append_log;
+       extern char *optarg;
        /* shall I run as a daemon */
        BOOL is_daemon = False;
+       BOOL interactive = False;
        BOOL specified_logfile = False;
        int port = SMB_PORT;
        int opt;
-       extern char *optarg;
-       
+       pstring logfile;
+
 #ifdef HAVE_SET_AUTH_PARAMETERS
        set_auth_parameters(argc,argv);
 #endif
@@ -567,25 +604,30 @@ static void usage(char *pname)
                argc--;
        }
 
-       while ( EOF != (opt = getopt(argc, argv, "O:l:s:d:Dp:h?Vaof:")) )
+       while ( EOF != (opt = getopt(argc, argv, "O:l:s:d:Dp:h?bVaiof:")) )
                switch (opt)  {
                case 'O':
                        pstrcpy(user_socket_options,optarg);
                        break;
 
                case 's':
-                       pstrcpy(servicesf,optarg);
+                       pstrcpy(dyn_CONFIGFILE,optarg);
                        break;
 
                case 'l':
                        specified_logfile = True;
-                       slprintf(debugf, sizeof(debugf)-1, "%s/log.smbd", optarg);
+                       slprintf(logfile, sizeof(logfile)-1, "%s/log.smbd", optarg);
+                       lp_set_logfile(logfile);
                        break;
 
                case 'a':
                        append_log = True;
                        break;
 
+               case 'i':
+                       interactive = True;
+                       break;
+
                case 'o':
                        append_log = False;
                        break;
@@ -612,7 +654,11 @@ static void usage(char *pname)
                        break;
 
                case 'V':
-                       printf("Version %s\n",VERSION);
+                       d_printf("Version %s\n",VERSION);
+                       exit(0);
+                       break;
+               case 'b':
+                       build_options(True); /* Display output to screen as well as debug */ 
                        exit(0);
                        break;
                default:
@@ -628,17 +674,19 @@ static void usage(char *pname)
 
        sec_init();
 
-       append_log = True;
+       load_case_tables();
 
-       TimeInit();
+       append_log = True;
 
        if(!specified_logfile) {
-               slprintf(debugf, sizeof(debugf)-1, "%s/log.smbd", LOGFILEBASE);
+               slprintf(logfile, sizeof(logfile)-1, "%s/log.smbd",
+                        dyn_LOGFILEBASE);
+               lp_set_logfile(logfile);
        }
 
        pstrcpy(remote_machine, "smbd");
 
-       setup_logging(argv[0],False);
+       setup_logging(argv[0],interactive);
 
        /* we want to re-seed early to prevent time delays causing
            client problems at a later date. (tridge) */
@@ -680,11 +728,14 @@ static void usage(char *pname)
        reopen_logs();
 
        DEBUG(1,( "smbd version %s started.\n", VERSION));
-       DEBUGADD(1,( "Copyright Andrew Tridgell 1992-1998\n"));
+       DEBUGADD(1,( "Copyright Andrew Tridgell 1992-2002\n"));
 
        DEBUG(2,("uid=%d gid=%d euid=%d egid=%d\n",
                 (int)getuid(),(int)getgid(),(int)geteuid(),(int)getegid()));
 
+       /* Output the build options to the debug log */ 
+       build_options(False);
+
        if (sizeof(uint16) < 2 || sizeof(uint32) < 4) {
                DEBUG(0,("ERROR: Samba is not configured correctly for the word size on your machine\n"));
                exit(1);
@@ -731,11 +782,20 @@ static void usage(char *pname)
                is_daemon = True;
        }
 
-       if (is_daemon) {
+       if (is_daemon && !interactive) {
                DEBUG( 3, ( "Becoming a daemon.\n" ) );
                become_daemon();
        }
 
+#if HAVE_SETPGID
+       /*
+        * If we're interactive we want to set our own process group for
+        * signal management.
+        */
+       if (interactive)
+               setpgid( (pid_t)0, (pid_t)0);
+#endif
+
        if (!directory_exist(lp_lockdir(), NULL)) {
                mkdir(lp_lockdir(), 0755);
        }
@@ -747,14 +807,17 @@ static void usage(char *pname)
        if (!message_init()) {
                exit(1);
        }
+       register_msg_pool_usage();
 
        /* Setup the main smbd so that we can get messages. */
        claim_connection(NULL,"",MAXSTATUS,True);
 
-       /* Attempt to migrate from an old 2.0.x machine account file. */
-       if (!migrate_from_old_password_file(global_myworkgroup)) {
-               DEBUG(0,("Failed to migrate from old MAC file.\n"));
-       }
+       /* 
+          DO NOT ENABLE THIS TILL YOU COPE WITH KILLING THESE TASKS AND INETD
+          THIS *killed* LOTS OF BUILD FARM MACHINES. IT CREATED HUNDREDS OF 
+          smbd PROCESSES THAT NEVER DIE
+          start_background_queue(); 
+       */
 
        if (!open_sockets(is_daemon,port))
                exit(1);
@@ -782,13 +845,18 @@ static void usage(char *pname)
        /* possibly reload the services file. */
        reload_services(True);
 
-       if (init_group_mapping()==False) {
-               printf("Could not open tdb mapping file.\n");
+       if(!pdb_generate_sam_sid()) {
+               DEBUG(0,("ERROR: Samba cannot create a SAM SID.\n"));
+               exit(1);
+       }
+
+       if (!init_group_mapping()) {
+               DEBUG(0,("Could not open tdb mapping file.\n"));
                return 0;
        }
 
-       if(!pdb_generate_sam_sid()) {
-               DEBUG(0,("ERROR: Samba cannot create a SAM SID.\n"));
+       if (!init_account_policy()) {
+               DEBUG(0,("Could not open account policy tdb.\n"));
                exit(1);
        }
 
@@ -801,6 +869,11 @@ static void usage(char *pname)
        if (!init_oplocks()) {
                exit(1);
        }
+       
+       /* Setup mangle */
+       if (!init_mangle_tdb()) {
+               exit(1);
+       }
 
        /* Setup change notify */
        if (!init_change_notify()) {