2 Unix SMB/CIFS implementation.
3 NBT netbios routines and daemon - version 2
4 Copyright (C) Andrew Tridgell 1994-1998
5 Copyright (C) Jeremy Allison 1997-2002
6 Copyright (C) Jelmer Vernooij 2002,2003 (Conversion to popt)
8 This program is free software; you can redistribute it and/or modify
9 it under the terms of the GNU General Public License as published by
10 the Free Software Foundation; either version 3 of the License, or
11 (at your option) any later version.
13 This program is distributed in the hope that it will be useful,
14 but WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 GNU General Public License for more details.
18 You should have received a copy of the GNU General Public License
19 along with this program. If not, see <http://www.gnu.org/licenses/>.
23 #include "popt_common.h"
24 #include "librpc/gen_ndr/messaging.h"
25 #include "nmbd/nmbd.h"
30 int global_nmb_port = -1;
32 extern bool rescan_listen_set;
33 extern bool global_in_nmbd;
35 extern bool override_logfile;
37 /* have we found LanMan clients yet? */
38 bool found_lm_clients = False;
40 /* what server type are we currently */
42 time_t StartupTime = 0;
44 struct event_context *nmbd_event_context(void)
46 return server_event_context();
49 struct messaging_context *nmbd_messaging_context(void)
51 struct messaging_context *msg_ctx = server_messaging_context();
52 if (likely(msg_ctx != NULL)) {
55 smb_panic("Could not init nmbd's messaging context.\n");
59 /**************************************************************************** **
60 Handle a SIGTERM in band.
61 **************************************************************************** */
63 static void terminate(void)
65 DEBUG(0,("Got SIGTERM: going down...\n"));
67 /* Write out wins.dat file if samba is a WINS server */
68 wins_write_database(0,False);
70 /* Remove all SELF registered names from WINS */
73 /* Announce all server entries as 0 time-to-live, 0 type. */
74 announce_my_servers_removed();
76 /* If there was an async dns child - kill it. */
77 kill_async_dns_child();
80 serverid_deregister(procid_self());
87 static void nmbd_sig_term_handler(struct tevent_context *ev,
88 struct tevent_signal *se,
97 static bool nmbd_setup_sig_term_handler(void)
99 struct tevent_signal *se;
101 se = tevent_add_signal(nmbd_event_context(),
102 nmbd_event_context(),
104 nmbd_sig_term_handler,
107 DEBUG(0,("failed to setup SIGTERM handler"));
114 static void msg_reload_nmbd_services(struct messaging_context *msg,
117 struct server_id server_id,
120 static void nmbd_sig_hup_handler(struct tevent_context *ev,
121 struct tevent_signal *se,
127 DEBUG(0,("Got SIGHUP dumping debug info.\n"));
128 msg_reload_nmbd_services(nmbd_messaging_context(),
129 NULL, MSG_SMB_CONF_UPDATED,
130 procid_self(), NULL);
133 static bool nmbd_setup_sig_hup_handler(void)
135 struct tevent_signal *se;
137 se = tevent_add_signal(nmbd_event_context(),
138 nmbd_event_context(),
140 nmbd_sig_hup_handler,
143 DEBUG(0,("failed to setup SIGHUP handler"));
150 /**************************************************************************** **
151 Handle a SHUTDOWN message from smbcontrol.
152 **************************************************************************** */
154 static void nmbd_terminate(struct messaging_context *msg,
157 struct server_id server_id,
163 /**************************************************************************** **
164 Expire old names from the namelist and server list.
165 **************************************************************************** */
167 static void expire_names_and_servers(time_t t)
169 static time_t lastrun = 0;
173 if ( t < (lastrun + 5) )
178 * Expire any timed out names on all the broadcast
179 * subnets and those registered with the WINS server.
180 * (nmbd_namelistdb.c)
186 * Go through all the broadcast subnets and for each
187 * workgroup known on that subnet remove any expired
188 * server names. If a workgroup has an empty serverlist
189 * and has itself timed out then remove the workgroup.
190 * (nmbd_workgroupdb.c)
193 expire_workgroups_and_servers(t);
196 /************************************************************************** **
197 Reload the list of network interfaces.
198 Doesn't return until a network interface is up.
199 ************************************************************************** */
201 static void reload_interfaces(time_t t)
205 bool print_waiting_msg = true;
206 struct subnet_record *subrec;
208 if (t && ((t - lastt) < NMBD_INTERFACES_RELOAD)) {
214 if (!interfaces_changed()) {
220 /* the list of probed interfaces has changed, we may need to add/remove
224 /* find any interfaces that need adding */
225 for (n=iface_count() - 1; n >= 0; n--) {
226 char str[INET6_ADDRSTRLEN];
227 const struct interface *iface = get_interface(n);
228 struct in_addr ip, nmask;
231 DEBUG(2,("reload_interfaces: failed to get interface %d\n", n));
235 /* Ensure we're only dealing with IPv4 here. */
236 if (iface->ip.ss_family != AF_INET) {
237 DEBUG(2,("reload_interfaces: "
238 "ignoring non IPv4 interface.\n"));
242 ip = ((struct sockaddr_in *)(void *)&iface->ip)->sin_addr;
243 nmask = ((struct sockaddr_in *)(void *)
244 &iface->netmask)->sin_addr;
247 * We don't want to add a loopback interface, in case
248 * someone has added 127.0.0.1 for smbd, nmbd needs to
249 * ignore it here. JRA.
252 if (is_loopback_addr((struct sockaddr *)(void *)&iface->ip)) {
253 DEBUG(2,("reload_interfaces: Ignoring loopback "
255 print_sockaddr(str, sizeof(str), &iface->ip) ));
259 for (subrec=subnetlist; subrec; subrec=subrec->next) {
260 if (ip_equal_v4(ip, subrec->myip) &&
261 ip_equal_v4(nmask, subrec->mask_ip)) {
267 /* it wasn't found! add it */
268 DEBUG(2,("Found new interface %s\n",
270 sizeof(str), &iface->ip) ));
271 subrec = make_normal_subnet(iface);
273 register_my_workgroup_one_subnet(subrec);
277 /* find any interfaces that need deleting */
278 for (subrec=subnetlist; subrec; subrec=subrec->next) {
279 for (n=iface_count() - 1; n >= 0; n--) {
280 struct interface *iface = get_interface(n);
281 struct in_addr ip, nmask;
285 /* Ensure we're only dealing with IPv4 here. */
286 if (iface->ip.ss_family != AF_INET) {
287 DEBUG(2,("reload_interfaces: "
288 "ignoring non IPv4 interface.\n"));
291 ip = ((struct sockaddr_in *)(void *)
292 &iface->ip)->sin_addr;
293 nmask = ((struct sockaddr_in *)(void *)
294 &iface->netmask)->sin_addr;
295 if (ip_equal_v4(ip, subrec->myip) &&
296 ip_equal_v4(nmask, subrec->mask_ip)) {
301 /* oops, an interface has disapeared. This is
302 tricky, we don't dare actually free the
303 interface as it could be being used, so
304 instead we just wear the memory leak and
305 remove it from the list of interfaces without
307 DEBUG(2,("Deleting dead interface %s\n",
308 inet_ntoa(subrec->myip)));
309 close_subnet(subrec);
313 rescan_listen_set = True;
315 /* We need to wait if there are no subnets... */
316 if (FIRST_SUBNET == NULL) {
317 void (*saved_handler)(int);
319 if (print_waiting_msg) {
320 DEBUG(0,("reload_interfaces: "
321 "No subnets to listen to. Waiting..\n"));
322 print_waiting_msg = false;
326 * Whilst we're waiting for an interface, allow SIGTERM to
329 saved_handler = CatchSignal(SIGTERM, SIG_DFL);
331 /* We only count IPv4, non-loopback interfaces here. */
332 while (iface_count_v4_nl() == 0) {
337 CatchSignal(SIGTERM, saved_handler);
340 * We got an interface, go back to blocking term.
347 /**************************************************************************** **
348 Reload the services file.
349 **************************************************************************** */
351 static bool reload_nmbd_services(bool test)
355 set_remote_machine_name("nmbd", False);
358 const char *fname = lp_configfile();
359 if (file_exist(fname) && !strcsequal(fname,get_dyn_CONFIGFILE())) {
360 set_dyn_CONFIGFILE(fname);
365 if ( test && !lp_file_list_changed() )
368 ret = lp_load(get_dyn_CONFIGFILE(), True , False, False, True);
370 /* perhaps the config filename is now set */
372 DEBUG( 3, ( "services not loaded\n" ) );
373 reload_nmbd_services( True );
379 /**************************************************************************** **
380 * React on 'smbcontrol nmbd reload-config' in the same way as to SIGHUP
381 **************************************************************************** */
383 static void msg_reload_nmbd_services(struct messaging_context *msg,
386 struct server_id server_id,
389 write_browse_list( 0, True );
390 dump_all_namelists();
391 reload_nmbd_services( True );
393 reload_interfaces(0);
396 static void msg_nmbd_send_packet(struct messaging_context *msg,
399 struct server_id src,
402 struct packet_struct *p = (struct packet_struct *)data->data;
403 struct subnet_record *subrec;
404 struct sockaddr_storage ss;
405 const struct sockaddr_storage *pss;
406 const struct in_addr *local_ip;
408 DEBUG(10, ("Received send_packet from %u\n", (unsigned int)procid_to_pid(&src)));
410 if (data->length != sizeof(struct packet_struct)) {
411 DEBUG(2, ("Discarding invalid packet length from %u\n",
412 (unsigned int)procid_to_pid(&src)));
416 if ((p->packet_type != NMB_PACKET) &&
417 (p->packet_type != DGRAM_PACKET)) {
418 DEBUG(2, ("Discarding invalid packet type from %u: %d\n",
419 (unsigned int)procid_to_pid(&src), p->packet_type));
423 in_addr_to_sockaddr_storage(&ss, p->ip);
424 pss = iface_ip((struct sockaddr *)(void *)&ss);
427 DEBUG(2, ("Could not find ip for packet from %u\n",
428 (unsigned int)procid_to_pid(&src)));
432 local_ip = &((const struct sockaddr_in *)pss)->sin_addr;
433 subrec = FIRST_SUBNET;
436 p->send_fd = (p->packet_type == NMB_PACKET) ?
437 subrec->nmb_sock : subrec->dgram_sock;
439 for (subrec = FIRST_SUBNET; subrec != NULL;
440 subrec = NEXT_SUBNET_EXCLUDING_UNICAST(subrec)) {
441 if (ip_equal_v4(*local_ip, subrec->myip)) {
442 p->send_fd = (p->packet_type == NMB_PACKET) ?
443 subrec->nmb_sock : subrec->dgram_sock;
448 if (p->packet_type == DGRAM_PACKET) {
450 p->packet.dgram.header.source_ip.s_addr = local_ip->s_addr;
451 p->packet.dgram.header.source_port = 138;
457 /**************************************************************************** **
458 The main select loop.
459 **************************************************************************** */
461 static void process(void)
466 time_t t = time(NULL);
467 TALLOC_CTX *frame = talloc_stackframe();
470 * Check all broadcast subnets to see if
471 * we need to run an election on any of them.
475 run_election = check_elections();
478 * Read incoming UDP packets.
482 if(listen_for_packets(run_election)) {
488 * Process all incoming packets
489 * read above. This calls the success and
490 * failure functions registered when response
491 * packets arrrive, and also deals with request
492 * packets from other sources.
499 * Run any elections - initiate becoming
500 * a local master browser if we have won.
507 * Send out any broadcast announcements
508 * of our server names. This also announces
509 * the workgroup name if we are a local
511 * (nmbd_sendannounce.c)
514 announce_my_server_names(t);
517 * Send out any LanMan broadcast announcements
518 * of our server names.
519 * (nmbd_sendannounce.c)
522 announce_my_lm_server_names(t);
525 * If we are a local master browser, periodically
526 * announce ourselves to the domain master browser.
527 * This also deals with syncronising the domain master
528 * browser server lists with ourselves as a local
530 * (nmbd_sendannounce.c)
533 announce_myself_to_domain_master_browser(t);
536 * Fullfill any remote announce requests.
537 * (nmbd_sendannounce.c)
543 * Fullfill any remote browse sync announce requests.
544 * (nmbd_sendannounce.c)
547 browse_sync_remote(t);
550 * Scan the broadcast subnets, and WINS client
551 * namelists and refresh any that need refreshing.
558 * Scan the subnet namelists and server lists and
559 * expire thos that have timed out.
563 expire_names_and_servers(t);
566 * Write out a snapshot of our current browse list into
567 * the browse.dat file. This is used by smbd to service
568 * incoming NetServerEnum calls - used to synchronise
569 * browse lists over subnets.
570 * (nmbd_serverlistdb.c)
573 write_browse_list(t, False);
576 * If we are a domain master browser, we have a list of
577 * local master browsers we should synchronise browse
578 * lists with (these are added by an incoming local
579 * master browser announcement packet). Expire any of
580 * these that are no longer current, and pull the server
581 * lists from each of these known local master browsers.
582 * (nmbd_browsesync.c)
585 dmb_expire_and_sync_browser_lists(t);
588 * Check that there is a local master browser for our
589 * workgroup for all our broadcast subnets. If one
590 * is not found, start an election (which we ourselves
591 * may or may not participate in, depending on the
592 * setting of the 'local master' parameter.
596 check_master_browser_exists(t);
599 * If we are configured as a logon server, attempt to
600 * register the special NetBIOS names to become such
601 * (WORKGROUP<1c> name) on all broadcast subnets and
602 * with the WINS server (if used). If we are configured
603 * to become a domain master browser, attempt to register
604 * the special NetBIOS name (WORKGROUP<1b> name) to
606 * (nmbd_become_dmb.c)
612 * If we are a WINS server, do any timer dependent
613 * processing required.
614 * (nmbd_winsserver.c)
617 initiate_wins_processing(t);
620 * If we are a domain master browser, attempt to contact the
621 * WINS server to get a list of all known WORKGROUPS/DOMAINS.
622 * This will only work to a Samba WINS server.
623 * (nmbd_browsesync.c)
626 if (lp_enhanced_browsing())
627 collect_all_workgroup_names_from_wins_server(t);
630 * Go through the response record queue and time out or re-transmit
631 * and expired entries.
635 retransmit_or_expire_response_records(t);
638 * check to see if any remote browse sync child processes have completed
641 sync_check_completion();
644 * regularly sync with any other DMBs we know about
647 if (lp_enhanced_browsing())
650 /* check for new network interfaces */
652 reload_interfaces(t);
654 /* free up temp memory */
659 /**************************************************************************** **
660 Open the socket communication.
661 **************************************************************************** */
663 static bool open_sockets(bool isdaemon, int port)
665 struct sockaddr_storage ss;
666 const char *sock_addr = lp_socket_address();
669 * The sockets opened here will be used to receive broadcast
670 * packets *only*. Interface specific sockets are opened in
671 * make_subnet() in namedbsubnet.c. Thus we bind to the
672 * address "0.0.0.0". The parameter 'socket address' is
676 if (!interpret_string_addr(&ss, sock_addr,
677 AI_NUMERICHOST|AI_PASSIVE)) {
678 DEBUG(0,("open_sockets: unable to get socket address "
679 "from string %s", sock_addr));
682 if (ss.ss_family != AF_INET) {
683 DEBUG(0,("open_sockets: unable to use IPv6 socket"
690 ClientNMB = open_socket_in(SOCK_DGRAM, port,
697 if (ClientNMB == -1) {
701 ClientDGRAM = open_socket_in(SOCK_DGRAM, DGRAM_PORT,
705 if (ClientDGRAM == -1) {
706 if (ClientNMB != 0) {
712 /* we are never interested in SIGPIPE */
713 BlockSignals(True,SIGPIPE);
715 set_socket_options( ClientNMB, "SO_BROADCAST" );
716 set_socket_options( ClientDGRAM, "SO_BROADCAST" );
718 /* Ensure we're non-blocking. */
719 set_blocking( ClientNMB, False);
720 set_blocking( ClientDGRAM, False);
722 DEBUG( 3, ( "open_sockets: Broadcast sockets opened.\n" ) );
726 /**************************************************************************** **
728 **************************************************************************** */
730 int main(int argc, const char *argv[])
732 static bool is_daemon;
733 static bool opt_interactive;
734 static bool Fork = true;
735 static bool no_process_group;
736 static bool log_stdout;
738 char *p_lmhosts = NULL;
744 OPT_NO_PROCESS_GROUP,
747 struct poptOption long_options[] = {
749 {"daemon", 'D', POPT_ARG_NONE, NULL, OPT_DAEMON, "Become a daemon(default)" },
750 {"interactive", 'i', POPT_ARG_NONE, NULL, OPT_INTERACTIVE, "Run interactive (not a daemon)" },
751 {"foreground", 'F', POPT_ARG_NONE, NULL, OPT_FORK, "Run daemon in foreground (for daemontools & etc)" },
752 {"no-process-group", 0, POPT_ARG_NONE, NULL, OPT_NO_PROCESS_GROUP, "Don't create a new process group" },
753 {"log-stdout", 'S', POPT_ARG_NONE, NULL, OPT_LOG_STDOUT, "Log to stdout" },
754 {"hosts", 'H', POPT_ARG_STRING, &p_lmhosts, 0, "Load a netbios hosts file"},
755 {"port", 'p', POPT_ARG_INT, &global_nmb_port, 0, "Listen on the specified port" },
763 * Do this before any other talloc operation
765 talloc_enable_null_tracking();
766 frame = talloc_stackframe();
770 global_nmb_port = NMB_PORT;
772 pc = poptGetContext("nmbd", argc, argv, long_options, 0);
773 while ((opt = poptGetNextOpt(pc)) != -1) {
778 case OPT_INTERACTIVE:
779 opt_interactive = true;
784 case OPT_NO_PROCESS_GROUP:
785 no_process_group = true;
791 d_fprintf(stderr, "\nInvalid option %s: %s\n\n",
792 poptBadOption(pc, 0), poptStrerror(opt));
793 poptPrintUsage(pc, stderr, 0);
799 global_in_nmbd = true;
801 StartupTime = time(NULL);
803 sys_srandom(time(NULL) ^ sys_getpid());
805 if (!override_logfile) {
807 if (asprintf(&lfile, "%s/log.nmbd", get_dyn_LOGFILEBASE()) < 0) {
810 lp_set_logfile(lfile);
815 dump_core_setup("nmbd", lp_logfile());
817 /* POSIX demands that signals are inherited. If the invoking process has
818 * these signals masked, we will have problems, as we won't receive them. */
819 BlockSignals(False, SIGHUP);
820 BlockSignals(False, SIGUSR1);
821 BlockSignals(False, SIGTERM);
824 /* we are never interested in SIGFPE */
825 BlockSignals(True,SIGFPE);
828 /* We no longer use USR2... */
830 BlockSignals(True, SIGUSR2);
833 if ( opt_interactive ) {
838 if ( log_stdout && Fork ) {
839 DEBUG(0,("ERROR: Can't log to stdout (-S) unless daemon is in foreground (-F) or interactive (-i)\n"));
843 setup_logging( argv[0], DEBUG_STDOUT);
845 setup_logging( argv[0], DEBUG_FILE);
850 DEBUG(0,("nmbd version %s started.\n", samba_version_string()));
851 DEBUGADD(0,("%s\n", COPYRIGHT_STARTUP_MESSAGE));
853 if (!lp_load_initial_only(get_dyn_CONFIGFILE())) {
854 DEBUG(0, ("error opening config file '%s'\n", get_dyn_CONFIGFILE()));
858 if (nmbd_messaging_context() == NULL) {
862 if ( !reload_nmbd_services(False) )
868 reload_nmbd_services( True );
870 if (strequal(lp_workgroup(),"*")) {
871 DEBUG(0,("ERROR: a workgroup name of * is no longer supported\n"));
877 if (!is_daemon && !is_a_socket(0)) {
878 DEBUG(0,("standard input is not a socket, assuming -D option\n"));
882 if (is_daemon && !opt_interactive) {
883 DEBUG( 2, ( "Becoming a daemon.\n" ) );
884 become_daemon(Fork, no_process_group, log_stdout);
889 * If we're interactive we want to set our own process group for
892 if (opt_interactive && !no_process_group)
893 setpgid( (pid_t)0, (pid_t)0 );
896 if (nmbd_messaging_context() == NULL) {
901 /* Setup the async dns. We do it here so it doesn't have all the other
902 stuff initialised and thus chewing memory and sockets */
903 if(lp_we_are_a_wins_server() && lp_dns_proxy()) {
908 if (!directory_exist(lp_lockdir())) {
909 mkdir(lp_lockdir(), 0755);
912 pidfile_create("nmbd");
914 status = reinit_after_fork(nmbd_messaging_context(),
915 nmbd_event_context(),
916 procid_self(), false);
918 if (!NT_STATUS_IS_OK(status)) {
919 DEBUG(0,("reinit_after_fork() failed\n"));
923 if (!nmbd_setup_sig_term_handler())
925 if (!nmbd_setup_sig_hup_handler())
928 /* get broadcast messages */
930 if (!serverid_register(procid_self(),
931 FLAG_MSG_GENERAL|FLAG_MSG_DBWRAP)) {
932 DEBUG(1, ("Could not register myself in serverid.tdb\n"));
936 messaging_register(nmbd_messaging_context(), NULL,
937 MSG_FORCE_ELECTION, nmbd_message_election);
939 /* Until winsrepl is done. */
940 messaging_register(nmbd_messaging_context(), NULL,
941 MSG_WINS_NEW_ENTRY, nmbd_wins_new_entry);
943 messaging_register(nmbd_messaging_context(), NULL,
944 MSG_SHUTDOWN, nmbd_terminate);
945 messaging_register(nmbd_messaging_context(), NULL,
946 MSG_SMB_CONF_UPDATED, msg_reload_nmbd_services);
947 messaging_register(nmbd_messaging_context(), NULL,
948 MSG_SEND_PACKET, msg_nmbd_send_packet);
952 DEBUG( 3, ( "Opening sockets %d\n", global_nmb_port ) );
954 if ( !open_sockets( is_daemon, global_nmb_port ) ) {
955 kill_async_dns_child();
959 /* Determine all the IP addresses we have. */
962 /* Create an nmbd subnet record for each of the above. */
963 if( False == create_subnets() ) {
964 DEBUG(0,("ERROR: Failed when creating subnet lists. Exiting.\n"));
965 kill_async_dns_child();
969 /* Load in any static local names. */
971 set_dyn_LMHOSTSFILE(p_lmhosts);
973 load_lmhosts_file(get_dyn_LMHOSTSFILE());
974 DEBUG(3,("Loaded hosts file %s\n", get_dyn_LMHOSTSFILE()));
976 /* If we are acting as a WINS server, initialise data structures. */
977 if( !initialise_wins() ) {
978 DEBUG( 0, ( "nmbd: Failed when initialising WINS server.\n" ) );
979 kill_async_dns_child();
984 * Register nmbd primary workgroup and nmbd names on all
985 * the broadcast subnets, and on the WINS server (if specified).
986 * Also initiate the startup of our primary workgroup (start
987 * elections if we are setup as being able to be a local
991 if( False == register_my_workgroup_and_names() ) {
992 DEBUG(0,("ERROR: Failed when creating my my workgroup. Exiting.\n"));
993 kill_async_dns_child();
997 if (!initialize_nmbd_proxy_logon()) {
998 DEBUG(0,("ERROR: Failed setup nmbd_proxy_logon.\n"));
999 kill_async_dns_child();
1003 if (!nmbd_init_packet_server()) {
1004 kill_async_dns_child();
1011 kill_async_dns_child();