fault: get fault.c ready for use by s4
[samba.git] / source3 / smbd / server.c
index aa0f7e85abe40be38644dc8311ff0165c7d0426d..37c97049b813a15253991f5554b3a7b0b063c616 100644 (file)
 #include "smbd/globals.h"
 #include "librpc/gen_ndr/messaging.h"
 #include "registry.h"
+#include "registry/reg_init_full.h"
 #include "libcli/auth/schannel.h"
 #include "secrets.h"
 #include "memcache.h"
+#include "ctdbd_conn.h"
+#include "printing/printer_list.h"
+#include "rpc_server/rpc_ep_setup.h"
+#include "printing/pcap.h"
+#include "printing.h"
+#include "serverid.h"
 
-#include "../librpc/gen_ndr/srv_dfs.h"
-#include "../librpc/gen_ndr/srv_dssetup.h"
-#include "../librpc/gen_ndr/srv_echo.h"
-#include "../librpc/gen_ndr/srv_eventlog.h"
-#include "../librpc/gen_ndr/srv_initshutdown.h"
-#include "../librpc/gen_ndr/srv_lsa.h"
-#include "../librpc/gen_ndr/srv_netlogon.h"
-#include "../librpc/gen_ndr/srv_ntsvcs.h"
-#include "../librpc/gen_ndr/srv_samr.h"
-#include "../librpc/gen_ndr/srv_spoolss.h"
-#include "../librpc/gen_ndr/srv_srvsvc.h"
-#include "../librpc/gen_ndr/srv_svcctl.h"
-#include "../librpc/gen_ndr/srv_winreg.h"
-#include "../librpc/gen_ndr/srv_wkssvc.h"
-
-#include "printing/nt_printing_migrate.h"
-
-static_decl_rpc;
+extern void start_epmd(struct tevent_context *ev_ctx,
+                      struct messaging_context *msg_ctx);
 
 #ifdef WITH_DFS
 extern int dcelogin_atmost_once;
@@ -97,12 +88,36 @@ static void smb_conf_updated(struct messaging_context *msg,
                             struct server_id server_id,
                             DATA_BLOB *data)
 {
+       struct tevent_context *ev_ctx =
+               talloc_get_type_abort(private_data, struct tevent_context);
+
        DEBUG(10,("smb_conf_updated: Got message saying smb.conf was "
                  "updated. Reloading.\n"));
        change_to_root_user();
        reload_services(msg, smbd_server_conn->sock, False);
+       if (am_parent) {
+               pcap_cache_reload(ev_ctx, msg,
+                                 &reload_pcap_change_notify);
+       }
 }
 
+/*******************************************************************
+ What to do when printcap is updated.
+ ********************************************************************/
+
+static void smb_pcap_updated(struct messaging_context *msg,
+                            void *private_data,
+                            uint32_t msg_type,
+                            struct server_id server_id,
+                            DATA_BLOB *data)
+{
+       struct tevent_context *ev_ctx =
+               talloc_get_type_abort(private_data, struct tevent_context);
+
+       DEBUG(10,("Got message saying pcap was updated. Reloading.\n"));
+       change_to_root_user();
+       reload_printers(ev_ctx, msg);
+}
 
 /*******************************************************************
  Delete a statcache entry.
@@ -291,7 +306,8 @@ static void remove_child_pid(pid_t pid, bool unclean_shutdown)
                }
        }
 
-       DEBUG(0, ("Could not find child %d -- ignoring\n", (int)pid));
+       /* not all forked child processes are added to the children list */
+       DEBUG(1, ("Could not find child %d -- ignoring\n", (int)pid));
 }
 
 /****************************************************************************
@@ -578,11 +594,32 @@ static bool smbd_open_one_socket(struct smbd_parent_context *parent,
        return true;
 }
 
+static bool smbd_parent_housekeeping(const struct timeval *now, void *private_data)
+{
+       time_t printcap_cache_time = (time_t)lp_printcap_cache_time();
+       time_t t = time_mono(NULL);
+
+       DEBUG(5, ("parent housekeeping\n"));
+
+       /* if periodic printcap rescan is enabled, see if it's time to reload */
+       if ((printcap_cache_time != 0)
+        && (t >= (last_printer_reload_time + printcap_cache_time))) {
+               DEBUG( 3,( "Printcap cache time expired.\n"));
+               pcap_cache_reload(server_event_context(),
+                                 smbd_messaging_context(),
+                                 &reload_pcap_change_notify);
+               last_printer_reload_time = t;
+       }
+
+       return true;
+}
+
 /****************************************************************************
  Open the socket communication.
 ****************************************************************************/
 
 static bool open_sockets_smbd(struct smbd_parent_context *parent,
+                             struct messaging_context *msg_ctx,
                              const char *smb_ports)
 {
        int num_interfaces = iface_count();
@@ -711,35 +748,43 @@ static bool open_sockets_smbd(struct smbd_parent_context *parent,
                return false;
        }
 
+       if (!(event_add_idle(smbd_event_context(), NULL,
+                            timeval_set(SMBD_HOUSEKEEPING_INTERVAL, 0),
+                            "parent_housekeeping", smbd_parent_housekeeping,
+                            NULL))) {
+               DEBUG(0, ("Could not add parent_housekeeping event\n"));
+               return false;
+       }
+
         /* Listen to messages */
 
-       messaging_register(smbd_messaging_context(), NULL,
-                          MSG_SMB_SAM_SYNC, msg_sam_sync);
-       messaging_register(smbd_messaging_context(), NULL,
-                          MSG_SHUTDOWN, msg_exit_server);
-       messaging_register(smbd_messaging_context(), NULL,
-                          MSG_SMB_FILE_RENAME, msg_file_was_renamed);
-       messaging_register(smbd_messaging_context(), NULL,
-                          MSG_SMB_CONF_UPDATED, smb_conf_updated);
-       messaging_register(smbd_messaging_context(), NULL,
-                          MSG_SMB_STAT_CACHE_DELETE, smb_stat_cache_delete);
-       messaging_register(smbd_messaging_context(), NULL,
-                          MSG_DEBUG, smbd_msg_debug);
-       brl_register_msgs(smbd_messaging_context());
+       messaging_register(msg_ctx, NULL, MSG_SMB_SAM_SYNC, msg_sam_sync);
+       messaging_register(msg_ctx, NULL, MSG_SHUTDOWN, msg_exit_server);
+       messaging_register(msg_ctx, NULL, MSG_SMB_FILE_RENAME,
+                          msg_file_was_renamed);
+       messaging_register(msg_ctx, server_event_context(), MSG_SMB_CONF_UPDATED,
+                          smb_conf_updated);
+       messaging_register(msg_ctx, NULL, MSG_SMB_STAT_CACHE_DELETE,
+                          smb_stat_cache_delete);
+       messaging_register(msg_ctx, NULL, MSG_DEBUG, smbd_msg_debug);
+       messaging_register(msg_ctx, server_event_context(), MSG_PRINTER_PCAP,
+                          smb_pcap_updated);
+       brl_register_msgs(msg_ctx);
+
+       msg_idmap_register_msgs(msg_ctx);
 
 #ifdef CLUSTER_SUPPORT
        if (lp_clustering()) {
-               ctdbd_register_reconfigure(
-                       messaging_ctdbd_connection(procid_self()));
+               ctdbd_register_reconfigure(messaging_ctdbd_connection());
        }
 #endif
 
 #ifdef DEVELOPER
-       messaging_register(smbd_messaging_context(), NULL,
-                          MSG_SMB_INJECT_FAULT, msg_inject_fault);
+       messaging_register(msg_ctx, NULL, MSG_SMB_INJECT_FAULT,
+                          msg_inject_fault);
 #endif
 
-       if (dns_port != 0) {
+       if (lp_multicast_dns_register() && (dns_port != 0)) {
 #ifdef WITH_DNSSD_SUPPORT
                smbd_setup_mdns_registration(smbd_event_context(),
                                             parent, dns_port);
@@ -793,21 +838,12 @@ static bool init_structs(void )
        if (!init_names())
                return False;
 
-       file_init();
-
        if (!secrets_init())
                return False;
 
        return True;
 }
 
-static bool spoolss_init_cb(void *ptr)
-{
-       struct messaging_context *msg_ctx = talloc_get_type_abort(
-               ptr, struct messaging_context);
-       return nt_printing_tdb_migrate(msg_ctx);
-}
-
 /****************************************************************************
  main program.
 ****************************************************************************/
@@ -853,10 +889,17 @@ extern void build_options(bool screen);
        POPT_TABLEEND
        };
        struct smbd_parent_context *parent = NULL;
-       TALLOC_CTX *frame = talloc_stackframe(); /* Setup tos. */
+       TALLOC_CTX *frame;
        NTSTATUS status;
        uint64_t unique_id;
-       struct rpc_srv_callbacks spoolss_cb;
+
+       /*
+        * Do this before any other talloc operation
+        */
+       talloc_enable_null_tracking();
+       frame = talloc_stackframe();
+
+       load_case_tables();
 
        /* Initialize the event context, it will panic on error */
        smbd_event_context();
@@ -904,15 +947,17 @@ extern void build_options(bool screen);
                log_stdout = True;
        }
 
-       setup_logging(argv[0],log_stdout);
+       if (log_stdout) {
+               setup_logging(argv[0], DEBUG_STDOUT);
+       } else {
+               setup_logging(argv[0], DEBUG_FILE);
+       }
 
        if (print_build_options) {
                build_options(True); /* Display output to screen as well as debug */
                exit(0);
        }
 
-       load_case_tables();
-
 #ifdef HAVE_SETLUID
        /* needed for SecureWare on SCO */
        setluid(0);
@@ -941,8 +986,8 @@ extern void build_options(bool screen);
        gain_root_privilege();
        gain_root_group_privilege();
 
-       fault_setup((void (*)(void *))exit_server_fault);
-       dump_core_setup("smbd");
+       fault_setup();
+       dump_core_setup("smbd", lp_logfile());
 
        /* we are never interested in SIGPIPE */
        BlockSignals(True,SIGPIPE);
@@ -1118,15 +1163,19 @@ extern void build_options(bool screen);
        if (!locking_init())
                exit(1);
 
-       if (!messaging_tdb_parent_init()) {
+       if (!messaging_tdb_parent_init(smbd_event_context())) {
+               exit(1);
+       }
+
+       if (!notify_internal_parent_init(smbd_event_context())) {
                exit(1);
        }
 
-       if (!notify_internal_parent_init()) {
+       if (!serverid_parent_init(smbd_event_context())) {
                exit(1);
        }
 
-       if (!serverid_parent_init()) {
+       if (!printer_list_parent_init()) {
                exit(1);
        }
 
@@ -1136,11 +1185,6 @@ extern void build_options(bool screen);
        if (!print_backend_init(smbd_messaging_context()))
                exit(1);
 
-#if 0
-       if (!init_svcctl_db())
-                exit(1);
-#endif
-
        /* Open the share_info.tdb here, so we don't have to open
           after the fork on every single connection.  This is a small
           performance improvment and reduces the total number of system
@@ -1150,8 +1194,10 @@ extern void build_options(bool screen);
                exit(1);
        }
 
-       if (!init_system_info()) {
-               DEBUG(0,("ERROR: failed to setup system user info.\n"));
+       status = init_system_info();
+       if (!NT_STATUS_IS_OK(status)) {
+               DEBUG(1, ("ERROR: failed to setup system user info: %s.\n",
+                         nt_errstr(status)));
                return -1;
        }
 
@@ -1160,28 +1206,30 @@ extern void build_options(bool screen);
                return -1;
        }
 
-       /*
-        * Initialize spoolss with an init function to convert printers first.
-        * static_init_rpc will try to initialize the spoolss server too but you
-        * can't register it twice.
-        */
-       spoolss_cb.init = spoolss_init_cb;
-       spoolss_cb.shutdown = NULL;
-       spoolss_cb.private_data = smbd_server_conn->msg_ctx;
+       if (!file_init(smbd_server_conn)) {
+               DEBUG(0, ("ERROR: file_init failed\n"));
+               return -1;
+       }
 
-       /* Spoolss depends on a winreg pipe, so start it first. */
-       if (!NT_STATUS_IS_OK(rpc_winreg_init(NULL))) {
-               exit(1);
+       if (is_daemon && !interactive) {
+               const char *rpcsrv_type;
+
+               rpcsrv_type = lp_parm_const_string(GLOBAL_SECTION_SNUM,
+                                                  "rpc_server", "epmapper",
+                                                  "none");
+               if (StrCaseCmp(rpcsrv_type, "daemon") == 0) {
+                       start_epmd(smbd_event_context(),
+                                  smbd_server_conn->msg_ctx);
+               }
        }
 
-       if (!NT_STATUS_IS_OK(rpc_spoolss_init(&spoolss_cb))) {
+       if (!dcesrv_ep_setup(smbd_event_context(), smbd_server_conn->msg_ctx)) {
                exit(1);
        }
 
-       static_init_rpc;
-
        /* Publish nt printers, this requires a working winreg pipe */
-       reload_printers(smbd_messaging_context());
+       pcap_cache_reload(server_event_context(), smbd_messaging_context(),
+                         &reload_printers);
 
        /* only start the background queue daemon if we are 
           running as a daemon -- bad things will happen if
@@ -1225,7 +1273,7 @@ extern void build_options(bool screen);
        }
        parent->interactive = interactive;
 
-       if (!open_sockets_smbd(parent, ports))
+       if (!open_sockets_smbd(parent, smbd_messaging_context(), ports))
                exit_server("open_sockets_smbd() failed");
 
        TALLOC_FREE(frame);