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/>.
27 int global_nmb_port
= -1;
29 extern bool rescan_listen_set
;
30 extern bool global_in_nmbd
;
32 extern bool override_logfile
;
34 /* have we found LanMan clients yet? */
35 bool found_lm_clients
= False
;
37 /* what server type are we currently */
39 time_t StartupTime
= 0;
41 struct event_context
*nmbd_event_context(void)
43 static struct event_context
*ctx
;
45 if (!ctx
&& !(ctx
= event_context_init(NULL
))) {
46 smb_panic("Could not init nmbd event context");
51 struct messaging_context
*nmbd_messaging_context(void)
53 static struct messaging_context
*ctx
;
56 ctx
= messaging_init(NULL
, server_id_self(),
57 nmbd_event_context());
60 DEBUG(0, ("Could not init nmbd messaging context.\n"));
65 /**************************************************************************** **
66 Handle a SIGTERM in band.
67 **************************************************************************** */
69 static void terminate(void)
71 DEBUG(0,("Got SIGTERM: going down...\n"));
73 /* Write out wins.dat file if samba is a WINS server */
74 wins_write_database(0,False
);
76 /* Remove all SELF registered names from WINS */
79 /* Announce all server entries as 0 time-to-live, 0 type. */
80 announce_my_servers_removed();
82 /* If there was an async dns child - kill it. */
83 kill_async_dns_child();
92 static void nmbd_sig_term_handler(struct tevent_context
*ev
,
93 struct tevent_signal
*se
,
102 static bool nmbd_setup_sig_term_handler(void)
104 struct tevent_signal
*se
;
106 se
= tevent_add_signal(nmbd_event_context(),
107 nmbd_event_context(),
109 nmbd_sig_term_handler
,
112 DEBUG(0,("failed to setup SIGTERM handler"));
119 static void msg_reload_nmbd_services(struct messaging_context
*msg
,
122 struct server_id server_id
,
125 static void nmbd_sig_hup_handler(struct tevent_context
*ev
,
126 struct tevent_signal
*se
,
132 DEBUG(0,("Got SIGHUP dumping debug info.\n"));
133 msg_reload_nmbd_services(nmbd_messaging_context(),
134 NULL
, MSG_SMB_CONF_UPDATED
,
135 procid_self(), NULL
);
138 static bool nmbd_setup_sig_hup_handler(void)
140 struct tevent_signal
*se
;
142 se
= tevent_add_signal(nmbd_event_context(),
143 nmbd_event_context(),
145 nmbd_sig_hup_handler
,
148 DEBUG(0,("failed to setup SIGHUP handler"));
155 /**************************************************************************** **
156 Handle a SHUTDOWN message from smbcontrol.
157 **************************************************************************** */
159 static void nmbd_terminate(struct messaging_context
*msg
,
162 struct server_id server_id
,
168 /**************************************************************************** **
169 Possibly continue after a fault.
170 **************************************************************************** */
172 static void fault_continue(void)
177 /**************************************************************************** **
178 Expire old names from the namelist and server list.
179 **************************************************************************** */
181 static void expire_names_and_servers(time_t t
)
183 static time_t lastrun
= 0;
187 if ( t
< (lastrun
+ 5) )
192 * Expire any timed out names on all the broadcast
193 * subnets and those registered with the WINS server.
194 * (nmbd_namelistdb.c)
200 * Go through all the broadcast subnets and for each
201 * workgroup known on that subnet remove any expired
202 * server names. If a workgroup has an empty serverlist
203 * and has itself timed out then remove the workgroup.
204 * (nmbd_workgroupdb.c)
207 expire_workgroups_and_servers(t
);
210 /************************************************************************** **
211 Reload the list of network interfaces.
212 Doesn't return until a network interface is up.
213 ************************************************************************** */
215 static void reload_interfaces(time_t t
)
219 bool print_waiting_msg
= true;
220 struct subnet_record
*subrec
;
222 if (t
&& ((t
- lastt
) < NMBD_INTERFACES_RELOAD
)) {
228 if (!interfaces_changed()) {
234 /* the list of probed interfaces has changed, we may need to add/remove
238 /* find any interfaces that need adding */
239 for (n
=iface_count() - 1; n
>= 0; n
--) {
240 char str
[INET6_ADDRSTRLEN
];
241 const struct interface
*iface
= get_interface(n
);
242 struct in_addr ip
, nmask
;
245 DEBUG(2,("reload_interfaces: failed to get interface %d\n", n
));
249 /* Ensure we're only dealing with IPv4 here. */
250 if (iface
->ip
.ss_family
!= AF_INET
) {
251 DEBUG(2,("reload_interfaces: "
252 "ignoring non IPv4 interface.\n"));
256 ip
= ((struct sockaddr_in
*)&iface
->ip
)->sin_addr
;
257 nmask
= ((struct sockaddr_in
*)&iface
->netmask
)->sin_addr
;
260 * We don't want to add a loopback interface, in case
261 * someone has added 127.0.0.1 for smbd, nmbd needs to
262 * ignore it here. JRA.
265 if (is_loopback_addr((struct sockaddr
*)&iface
->ip
)) {
266 DEBUG(2,("reload_interfaces: Ignoring loopback "
268 print_sockaddr(str
, sizeof(str
), &iface
->ip
) ));
272 for (subrec
=subnetlist
; subrec
; subrec
=subrec
->next
) {
273 if (ip_equal_v4(ip
, subrec
->myip
) &&
274 ip_equal_v4(nmask
, subrec
->mask_ip
)) {
280 /* it wasn't found! add it */
281 DEBUG(2,("Found new interface %s\n",
283 sizeof(str
), &iface
->ip
) ));
284 subrec
= make_normal_subnet(iface
);
286 register_my_workgroup_one_subnet(subrec
);
290 /* find any interfaces that need deleting */
291 for (subrec
=subnetlist
; subrec
; subrec
=subrec
->next
) {
292 for (n
=iface_count() - 1; n
>= 0; n
--) {
293 struct interface
*iface
= get_interface(n
);
294 struct in_addr ip
, nmask
;
298 /* Ensure we're only dealing with IPv4 here. */
299 if (iface
->ip
.ss_family
!= AF_INET
) {
300 DEBUG(2,("reload_interfaces: "
301 "ignoring non IPv4 interface.\n"));
304 ip
= ((struct sockaddr_in
*)&iface
->ip
)->sin_addr
;
305 nmask
= ((struct sockaddr_in
*)&iface
->netmask
)->sin_addr
;
306 if (ip_equal_v4(ip
, subrec
->myip
) &&
307 ip_equal_v4(nmask
, subrec
->mask_ip
)) {
312 /* oops, an interface has disapeared. This is
313 tricky, we don't dare actually free the
314 interface as it could be being used, so
315 instead we just wear the memory leak and
316 remove it from the list of interfaces without
318 DEBUG(2,("Deleting dead interface %s\n",
319 inet_ntoa(subrec
->myip
)));
320 close_subnet(subrec
);
324 rescan_listen_set
= True
;
326 /* We need to wait if there are no subnets... */
327 if (FIRST_SUBNET
== NULL
) {
328 void (*saved_handler
)(int);
330 if (print_waiting_msg
) {
331 DEBUG(0,("reload_interfaces: "
332 "No subnets to listen to. Waiting..\n"));
333 print_waiting_msg
= false;
337 * Whilst we're waiting for an interface, allow SIGTERM to
340 saved_handler
= CatchSignal( SIGTERM
, SIGNAL_CAST SIG_DFL
);
342 /* We only count IPv4, non-loopback interfaces here. */
343 while (iface_count_v4_nl() == 0) {
348 CatchSignal( SIGTERM
, SIGNAL_CAST saved_handler
);
351 * We got an interface, go back to blocking term.
358 /**************************************************************************** **
359 Reload the services file.
360 **************************************************************************** */
362 static bool reload_nmbd_services(bool test
)
366 set_remote_machine_name("nmbd", False
);
369 char *fname
= lp_configfile();
370 if (file_exist(fname
) && !strcsequal(fname
,get_dyn_CONFIGFILE())) {
371 set_dyn_CONFIGFILE(fname
);
377 if ( test
&& !lp_file_list_changed() )
380 ret
= lp_load(get_dyn_CONFIGFILE(), True
, False
, False
, True
);
382 /* perhaps the config filename is now set */
384 DEBUG( 3, ( "services not loaded\n" ) );
385 reload_nmbd_services( True
);
391 /**************************************************************************** **
392 * React on 'smbcontrol nmbd reload-config' in the same way as to SIGHUP
393 **************************************************************************** */
395 static void msg_reload_nmbd_services(struct messaging_context
*msg
,
398 struct server_id server_id
,
401 write_browse_list( 0, True
);
402 dump_all_namelists();
403 reload_nmbd_services( True
);
405 reload_interfaces(0);
408 static void msg_nmbd_send_packet(struct messaging_context
*msg
,
411 struct server_id src
,
414 struct packet_struct
*p
= (struct packet_struct
*)data
->data
;
415 struct subnet_record
*subrec
;
416 struct sockaddr_storage ss
;
417 const struct sockaddr_storage
*pss
;
418 const struct in_addr
*local_ip
;
420 DEBUG(10, ("Received send_packet from %u\n", (unsigned int)procid_to_pid(&src
)));
422 if (data
->length
!= sizeof(struct packet_struct
)) {
423 DEBUG(2, ("Discarding invalid packet length from %u\n",
424 (unsigned int)procid_to_pid(&src
)));
428 if ((p
->packet_type
!= NMB_PACKET
) &&
429 (p
->packet_type
!= DGRAM_PACKET
)) {
430 DEBUG(2, ("Discarding invalid packet type from %u: %d\n",
431 (unsigned int)procid_to_pid(&src
), p
->packet_type
));
435 in_addr_to_sockaddr_storage(&ss
, p
->ip
);
436 pss
= iface_ip((struct sockaddr
*)&ss
);
439 DEBUG(2, ("Could not find ip for packet from %u\n",
440 (unsigned int)procid_to_pid(&src
)));
444 local_ip
= &((const struct sockaddr_in
*)pss
)->sin_addr
;
445 subrec
= FIRST_SUBNET
;
448 p
->send_fd
= (p
->packet_type
== NMB_PACKET
) ?
449 subrec
->nmb_sock
: subrec
->dgram_sock
;
451 for (subrec
= FIRST_SUBNET
; subrec
!= NULL
;
452 subrec
= NEXT_SUBNET_EXCLUDING_UNICAST(subrec
)) {
453 if (ip_equal_v4(*local_ip
, subrec
->myip
)) {
454 p
->send_fd
= (p
->packet_type
== NMB_PACKET
) ?
455 subrec
->nmb_sock
: subrec
->dgram_sock
;
460 if (p
->packet_type
== DGRAM_PACKET
) {
462 p
->packet
.dgram
.header
.source_ip
.s_addr
= local_ip
->s_addr
;
463 p
->packet
.dgram
.header
.source_port
= 138;
469 /**************************************************************************** **
470 The main select loop.
471 **************************************************************************** */
473 static void process(void)
478 time_t t
= time(NULL
);
479 TALLOC_CTX
*frame
= talloc_stackframe();
482 * Check all broadcast subnets to see if
483 * we need to run an election on any of them.
487 run_election
= check_elections();
490 * Read incoming UDP packets.
494 if(listen_for_packets(run_election
)) {
500 * Process all incoming packets
501 * read above. This calls the success and
502 * failure functions registered when response
503 * packets arrrive, and also deals with request
504 * packets from other sources.
511 * Run any elections - initiate becoming
512 * a local master browser if we have won.
519 * Send out any broadcast announcements
520 * of our server names. This also announces
521 * the workgroup name if we are a local
523 * (nmbd_sendannounce.c)
526 announce_my_server_names(t
);
529 * Send out any LanMan broadcast announcements
530 * of our server names.
531 * (nmbd_sendannounce.c)
534 announce_my_lm_server_names(t
);
537 * If we are a local master browser, periodically
538 * announce ourselves to the domain master browser.
539 * This also deals with syncronising the domain master
540 * browser server lists with ourselves as a local
542 * (nmbd_sendannounce.c)
545 announce_myself_to_domain_master_browser(t
);
548 * Fullfill any remote announce requests.
549 * (nmbd_sendannounce.c)
555 * Fullfill any remote browse sync announce requests.
556 * (nmbd_sendannounce.c)
559 browse_sync_remote(t
);
562 * Scan the broadcast subnets, and WINS client
563 * namelists and refresh any that need refreshing.
570 * Scan the subnet namelists and server lists and
571 * expire thos that have timed out.
575 expire_names_and_servers(t
);
578 * Write out a snapshot of our current browse list into
579 * the browse.dat file. This is used by smbd to service
580 * incoming NetServerEnum calls - used to synchronise
581 * browse lists over subnets.
582 * (nmbd_serverlistdb.c)
585 write_browse_list(t
, False
);
588 * If we are a domain master browser, we have a list of
589 * local master browsers we should synchronise browse
590 * lists with (these are added by an incoming local
591 * master browser announcement packet). Expire any of
592 * these that are no longer current, and pull the server
593 * lists from each of these known local master browsers.
594 * (nmbd_browsesync.c)
597 dmb_expire_and_sync_browser_lists(t
);
600 * Check that there is a local master browser for our
601 * workgroup for all our broadcast subnets. If one
602 * is not found, start an election (which we ourselves
603 * may or may not participate in, depending on the
604 * setting of the 'local master' parameter.
608 check_master_browser_exists(t
);
611 * If we are configured as a logon server, attempt to
612 * register the special NetBIOS names to become such
613 * (WORKGROUP<1c> name) on all broadcast subnets and
614 * with the WINS server (if used). If we are configured
615 * to become a domain master browser, attempt to register
616 * the special NetBIOS name (WORKGROUP<1b> name) to
618 * (nmbd_become_dmb.c)
624 * If we are a WINS server, do any timer dependent
625 * processing required.
626 * (nmbd_winsserver.c)
629 initiate_wins_processing(t
);
632 * If we are a domain master browser, attempt to contact the
633 * WINS server to get a list of all known WORKGROUPS/DOMAINS.
634 * This will only work to a Samba WINS server.
635 * (nmbd_browsesync.c)
638 if (lp_enhanced_browsing())
639 collect_all_workgroup_names_from_wins_server(t
);
642 * Go through the response record queue and time out or re-transmit
643 * and expired entries.
647 retransmit_or_expire_response_records(t
);
650 * check to see if any remote browse sync child processes have completed
653 sync_check_completion();
656 * regularly sync with any other DMBs we know about
659 if (lp_enhanced_browsing())
663 * clear the unexpected packet queue
668 /* check for new network interfaces */
670 reload_interfaces(t
);
672 /* free up temp memory */
677 /**************************************************************************** **
678 Open the socket communication.
679 **************************************************************************** */
681 static bool open_sockets(bool isdaemon
, int port
)
683 struct sockaddr_storage ss
;
684 const char *sock_addr
= lp_socket_address();
687 * The sockets opened here will be used to receive broadcast
688 * packets *only*. Interface specific sockets are opened in
689 * make_subnet() in namedbsubnet.c. Thus we bind to the
690 * address "0.0.0.0". The parameter 'socket address' is
694 if (!interpret_string_addr(&ss
, sock_addr
,
695 AI_NUMERICHOST
|AI_PASSIVE
)) {
696 DEBUG(0,("open_sockets: unable to get socket address "
697 "from string %s", sock_addr
));
700 if (ss
.ss_family
!= AF_INET
) {
701 DEBUG(0,("open_sockets: unable to use IPv6 socket"
708 ClientNMB
= open_socket_in(SOCK_DGRAM
, port
,
715 if (ClientNMB
== -1) {
719 ClientDGRAM
= open_socket_in(SOCK_DGRAM
, DGRAM_PORT
,
723 if (ClientDGRAM
== -1) {
724 if (ClientNMB
!= 0) {
730 /* we are never interested in SIGPIPE */
731 BlockSignals(True
,SIGPIPE
);
733 set_socket_options( ClientNMB
, "SO_BROADCAST" );
734 set_socket_options( ClientDGRAM
, "SO_BROADCAST" );
736 /* Ensure we're non-blocking. */
737 set_blocking( ClientNMB
, False
);
738 set_blocking( ClientDGRAM
, False
);
740 DEBUG( 3, ( "open_sockets: Broadcast sockets opened.\n" ) );
744 /**************************************************************************** **
746 **************************************************************************** */
748 int main(int argc
, const char *argv
[])
750 static bool is_daemon
;
751 static bool opt_interactive
;
752 static bool Fork
= true;
753 static bool no_process_group
;
754 static bool log_stdout
;
756 char *p_lmhosts
= NULL
;
762 OPT_NO_PROCESS_GROUP
,
765 struct poptOption long_options
[] = {
767 {"daemon", 'D', POPT_ARG_NONE
, NULL
, OPT_DAEMON
, "Become a daemon(default)" },
768 {"interactive", 'i', POPT_ARG_NONE
, NULL
, OPT_INTERACTIVE
, "Run interactive (not a daemon)" },
769 {"foreground", 'F', POPT_ARG_NONE
, NULL
, OPT_FORK
, "Run daemon in foreground (for daemontools & etc)" },
770 {"no-process-group", 0, POPT_ARG_NONE
, NULL
, OPT_NO_PROCESS_GROUP
, "Don't create a new process group" },
771 {"log-stdout", 'S', POPT_ARG_NONE
, NULL
, OPT_LOG_STDOUT
, "Log to stdout" },
772 {"hosts", 'H', POPT_ARG_STRING
, &p_lmhosts
, 0, "Load a netbios hosts file"},
773 {"port", 'p', POPT_ARG_INT
, &global_nmb_port
, 0, "Listen on the specified port" },
777 TALLOC_CTX
*frame
= talloc_stackframe(); /* Setup tos. */
781 global_nmb_port
= NMB_PORT
;
783 pc
= poptGetContext("nmbd", argc
, argv
, long_options
, 0);
784 while ((opt
= poptGetNextOpt(pc
)) != -1) {
789 case OPT_INTERACTIVE
:
790 opt_interactive
= true;
795 case OPT_NO_PROCESS_GROUP
:
796 no_process_group
= true;
802 d_fprintf(stderr
, "\nInvalid option %s: %s\n\n",
803 poptBadOption(pc
, 0), poptStrerror(opt
));
804 poptPrintUsage(pc
, stderr
, 0);
810 global_in_nmbd
= true;
812 StartupTime
= time(NULL
);
814 sys_srandom(time(NULL
) ^ sys_getpid());
816 if (!override_logfile
) {
818 if (asprintf(&lfile
, "%s/log.nmbd", get_dyn_LOGFILEBASE()) < 0) {
821 lp_set_logfile(lfile
);
825 fault_setup((void (*)(void *))fault_continue
);
826 dump_core_setup("nmbd");
828 /* POSIX demands that signals are inherited. If the invoking process has
829 * these signals masked, we will have problems, as we won't receive them. */
830 BlockSignals(False
, SIGHUP
);
831 BlockSignals(False
, SIGUSR1
);
832 BlockSignals(False
, SIGTERM
);
835 /* we are never interested in SIGFPE */
836 BlockSignals(True
,SIGFPE
);
839 /* We no longer use USR2... */
841 BlockSignals(True
, SIGUSR2
);
844 if ( opt_interactive
) {
849 if ( log_stdout
&& Fork
) {
850 DEBUG(0,("ERROR: Can't log to stdout (-S) unless daemon is in foreground (-F) or interactive (-i)\n"));
854 setup_logging( argv
[0], log_stdout
);
858 DEBUG(0,("nmbd version %s started.\n", samba_version_string()));
859 DEBUGADD(0,("%s\n", COPYRIGHT_STARTUP_MESSAGE
));
861 if (!lp_load_initial_only(get_dyn_CONFIGFILE())) {
862 DEBUG(0, ("error opening config file\n"));
866 if (nmbd_messaging_context() == NULL
) {
870 if ( !reload_nmbd_services(False
) )
876 reload_nmbd_services( True
);
878 if (strequal(lp_workgroup(),"*")) {
879 DEBUG(0,("ERROR: a workgroup name of * is no longer supported\n"));
885 if (!is_daemon
&& !is_a_socket(0)) {
886 DEBUG(0,("standard input is not a socket, assuming -D option\n"));
890 if (is_daemon
&& !opt_interactive
) {
891 DEBUG( 2, ( "Becoming a daemon.\n" ) );
892 become_daemon(Fork
, no_process_group
);
897 * If we're interactive we want to set our own process group for
900 if (opt_interactive
&& !no_process_group
)
901 setpgid( (pid_t
)0, (pid_t
)0 );
904 if (nmbd_messaging_context() == NULL
) {
909 /* Setup the async dns. We do it here so it doesn't have all the other
910 stuff initialised and thus chewing memory and sockets */
911 if(lp_we_are_a_wins_server() && lp_dns_proxy()) {
916 if (!directory_exist(lp_lockdir())) {
917 mkdir(lp_lockdir(), 0755);
920 pidfile_create("nmbd");
922 if (!NT_STATUS_IS_OK(reinit_after_fork(nmbd_messaging_context(),
923 nmbd_event_context(), false))) {
924 DEBUG(0,("reinit_after_fork() failed\n"));
928 if (!nmbd_setup_sig_term_handler())
930 if (!nmbd_setup_sig_hup_handler())
933 /* get broadcast messages */
934 claim_connection(NULL
,"",FLAG_MSG_GENERAL
|FLAG_MSG_DBWRAP
);
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();
1008 kill_async_dns_child();