fix startup of smbd, nmbd, winbindd
[samba.git] / source3 / nmbd / nmbd.c
1 /*
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)
7    
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.
12    
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.
17    
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/>.
20    
21 */
22
23 #include "includes.h"
24
25 int ClientNMB       = -1;
26 int ClientDGRAM     = -1;
27 int global_nmb_port = -1;
28
29 extern bool rescan_listen_set;
30 extern bool global_in_nmbd;
31
32 extern bool override_logfile;
33
34 /* have we found LanMan clients yet? */
35 bool found_lm_clients = False;
36
37 /* what server type are we currently */
38
39 time_t StartupTime = 0;
40
41 struct event_context *nmbd_event_context(void)
42 {
43         static struct event_context *ctx;
44
45         if (!ctx && !(ctx = event_context_init(NULL))) {
46                 smb_panic("Could not init nmbd event context");
47         }
48         return ctx;
49 }
50
51 struct messaging_context *nmbd_messaging_context(void)
52 {
53         static struct messaging_context *ctx;
54
55         if (!ctx && !(ctx = messaging_init(NULL, server_id_self(),
56                                            nmbd_event_context()))) {
57                 smb_panic("Could not init nmbd messaging context");
58         }
59         return ctx;
60 }
61
62 /**************************************************************************** **
63  Handle a SIGTERM in band.
64  **************************************************************************** */
65
66 static void terminate(void)
67 {
68         DEBUG(0,("Got SIGTERM: going down...\n"));
69   
70         /* Write out wins.dat file if samba is a WINS server */
71         wins_write_database(0,False);
72   
73         /* Remove all SELF registered names from WINS */
74         release_wins_names();
75   
76         /* Announce all server entries as 0 time-to-live, 0 type. */
77         announce_my_servers_removed();
78
79         /* If there was an async dns child - kill it. */
80         kill_async_dns_child();
81
82         exit(0);
83 }
84
85 /**************************************************************************** **
86  Handle a SHUTDOWN message from smbcontrol.
87  **************************************************************************** */
88
89 static void nmbd_terminate(struct messaging_context *msg,
90                            void *private_data,
91                            uint32_t msg_type,
92                            struct server_id server_id,
93                            DATA_BLOB *data)
94 {
95         terminate();
96 }
97
98 /**************************************************************************** **
99  Catch a SIGTERM signal.
100  **************************************************************************** */
101
102 static SIG_ATOMIC_T got_sig_term;
103
104 static void sig_term(int sig)
105 {
106         got_sig_term = 1;
107         sys_select_signal(SIGTERM);
108 }
109
110 /**************************************************************************** **
111  Catch a SIGHUP signal.
112  **************************************************************************** */
113
114 static SIG_ATOMIC_T reload_after_sighup;
115
116 static void sig_hup(int sig)
117 {
118         reload_after_sighup = 1;
119         sys_select_signal(SIGHUP);
120 }
121
122 /**************************************************************************** **
123  Possibly continue after a fault.
124  **************************************************************************** */
125
126 static void fault_continue(void)
127 {
128         dump_core();
129 }
130
131 /**************************************************************************** **
132  Expire old names from the namelist and server list.
133  **************************************************************************** */
134
135 static void expire_names_and_servers(time_t t)
136 {
137         static time_t lastrun = 0;
138   
139         if ( !lastrun )
140                 lastrun = t;
141         if ( t < (lastrun + 5) )
142                 return;
143         lastrun = t;
144
145         /*
146          * Expire any timed out names on all the broadcast
147          * subnets and those registered with the WINS server.
148          * (nmbd_namelistdb.c)
149          */
150
151         expire_names(t);
152
153         /*
154          * Go through all the broadcast subnets and for each
155          * workgroup known on that subnet remove any expired
156          * server names. If a workgroup has an empty serverlist
157          * and has itself timed out then remove the workgroup.
158          * (nmbd_workgroupdb.c)
159          */
160
161         expire_workgroups_and_servers(t);
162 }
163
164 /************************************************************************** **
165  Reload the list of network interfaces.
166  ************************************************************************** */
167
168 static bool reload_interfaces(time_t t)
169 {
170         static time_t lastt;
171         int n;
172         struct subnet_record *subrec;
173
174         if (t && ((t - lastt) < NMBD_INTERFACES_RELOAD)) return False;
175         lastt = t;
176
177         if (!interfaces_changed()) return False;
178
179         /* the list of probed interfaces has changed, we may need to add/remove
180            some subnets */
181         load_interfaces();
182
183         /* find any interfaces that need adding */
184         for (n=iface_count() - 1; n >= 0; n--) {
185                 char str[INET6_ADDRSTRLEN];
186                 const struct interface *iface = get_interface(n);
187                 struct in_addr ip, nmask;
188
189                 if (!iface) {
190                         DEBUG(2,("reload_interfaces: failed to get interface %d\n", n));
191                         continue;
192                 }
193
194                 /* Ensure we're only dealing with IPv4 here. */
195                 if (iface->ip.ss_family != AF_INET) {
196                         DEBUG(2,("reload_interfaces: "
197                                 "ignoring non IPv4 interface.\n"));
198                         continue;
199                 }
200
201                 ip = ((struct sockaddr_in *)&iface->ip)->sin_addr;
202                 nmask = ((struct sockaddr_in *)&iface->netmask)->sin_addr;
203
204                 /*
205                  * We don't want to add a loopback interface, in case
206                  * someone has added 127.0.0.1 for smbd, nmbd needs to
207                  * ignore it here. JRA.
208                  */
209
210                 if (is_loopback_addr(&iface->ip)) {
211                         DEBUG(2,("reload_interfaces: Ignoring loopback "
212                                 "interface %s\n",
213                                 print_sockaddr(str, sizeof(str),
214                                         &iface->ip, sizeof(iface->ip)) ));
215                         continue;
216                 }
217
218                 for (subrec=subnetlist; subrec; subrec=subrec->next) {
219                         if (ip_equal(ip, subrec->myip) &&
220                             ip_equal(nmask, subrec->mask_ip)) break;
221                 }
222
223                 if (!subrec) {
224                         /* it wasn't found! add it */
225                         DEBUG(2,("Found new interface %s\n", 
226                                  print_sockaddr(str, sizeof(str),
227                                          &iface->ip, sizeof(iface->ip)) ));
228                         subrec = make_normal_subnet(iface);
229                         if (subrec)
230                                 register_my_workgroup_one_subnet(subrec);
231                 }
232         }
233
234         /* find any interfaces that need deleting */
235         for (subrec=subnetlist; subrec; subrec=subrec->next) {
236                 for (n=iface_count() - 1; n >= 0; n--) {
237                         struct interface *iface = get_interface(n);
238                         struct in_addr ip, nmask;
239                         if (!iface) {
240                                 continue;
241                         }
242                         /* Ensure we're only dealing with IPv4 here. */
243                         if (iface->ip.ss_family != AF_INET) {
244                                 DEBUG(2,("reload_interfaces: "
245                                         "ignoring non IPv4 interface.\n"));
246                                 continue;
247                         }
248                         ip = ((struct sockaddr_in *)&iface->ip)->sin_addr;
249                         nmask = ((struct sockaddr_in *)&iface->netmask)->sin_addr;
250                         if (ip_equal(ip, subrec->myip) &&
251                             ip_equal(nmask, subrec->mask_ip)) break;
252                 }
253                 if (n == -1) {
254                         /* oops, an interface has disapeared. This is
255                          tricky, we don't dare actually free the
256                          interface as it could be being used, so
257                          instead we just wear the memory leak and
258                          remove it from the list of interfaces without
259                          freeing it */
260                         DEBUG(2,("Deleting dead interface %s\n", 
261                                  inet_ntoa(subrec->myip)));
262                         close_subnet(subrec);
263                 }
264         }
265         
266         rescan_listen_set = True;
267
268         /* We need to shutdown if there are no subnets... */
269         if (FIRST_SUBNET == NULL) {
270                 DEBUG(0,("reload_interfaces: No subnets to listen to. Shutting down...\n"));
271                 return True;
272         }
273         return False;
274 }
275
276 /**************************************************************************** **
277  Reload the services file.
278  **************************************************************************** */
279
280 static bool reload_nmbd_services(bool test)
281 {
282         bool ret;
283
284         set_remote_machine_name("nmbd", False);
285
286         if ( lp_loaded() ) {
287                 pstring fname;
288                 pstrcpy( fname,lp_configfile());
289                 if (file_exist(fname,NULL) && !strcsequal(fname,dyn_CONFIGFILE)) {
290                         pstrcpy(dyn_CONFIGFILE,fname);
291                         test = False;
292                 }
293         }
294
295         if ( test && !lp_file_list_changed() )
296                 return(True);
297
298         ret = lp_load( dyn_CONFIGFILE, True , False, False, True);
299
300         /* perhaps the config filename is now set */
301         if ( !test ) {
302                 DEBUG( 3, ( "services not loaded\n" ) );
303                 reload_nmbd_services( True );
304         }
305
306         return(ret);
307 }
308
309 /**************************************************************************** **
310  * React on 'smbcontrol nmbd reload-config' in the same way as to SIGHUP
311  * We use buf here to return bool result to process() when reload_interfaces()
312  * detects that there are no subnets.
313  **************************************************************************** */
314
315 static void msg_reload_nmbd_services(struct messaging_context *msg,
316                                      void *private_data,
317                                      uint32_t msg_type,
318                                      struct server_id server_id,
319                                      DATA_BLOB *data)
320 {
321         write_browse_list( 0, True );
322         dump_all_namelists();
323         reload_nmbd_services( True );
324         reopen_logs();
325         
326         if (data->data) {
327                 /* We were called from process() */
328                 /* If reload_interfaces() returned True */
329                 /* we need to shutdown if there are no subnets... */
330                 /* pass this info back to process() */
331                 *((bool *)data->data) = reload_interfaces(0);  
332         }
333 }
334
335 static void msg_nmbd_send_packet(struct messaging_context *msg,
336                                  void *private_data,
337                                  uint32_t msg_type,
338                                  struct server_id src,
339                                  DATA_BLOB *data)
340 {
341         struct packet_struct *p = (struct packet_struct *)data->data;
342         struct subnet_record *subrec;
343         struct sockaddr_storage ss;
344         const struct sockaddr_storage *pss;
345         const struct in_addr *local_ip;
346
347         DEBUG(10, ("Received send_packet from %d\n", procid_to_pid(&src)));
348
349         if (data->length != sizeof(struct packet_struct)) {
350                 DEBUG(2, ("Discarding invalid packet length from %d\n",
351                           procid_to_pid(&src)));
352                 return;
353         }
354
355         if ((p->packet_type != NMB_PACKET) &&
356             (p->packet_type != DGRAM_PACKET)) {
357                 DEBUG(2, ("Discarding invalid packet type from %d: %d\n",
358                           procid_to_pid(&src), p->packet_type));
359                 return;
360         }
361
362         in_addr_to_sockaddr_storage(&ss, p->ip);
363         pss = iface_ip(&ss);
364
365         if (pss == NULL) {
366                 DEBUG(2, ("Could not find ip for packet from %d\n",
367                           procid_to_pid(&src)));
368                 return;
369         }
370
371         local_ip = &((const struct sockaddr_in *)pss)->sin_addr;
372         subrec = FIRST_SUBNET;
373
374         p->fd = (p->packet_type == NMB_PACKET) ?
375                 subrec->nmb_sock : subrec->dgram_sock;
376
377         for (subrec = FIRST_SUBNET; subrec != NULL;
378              subrec = NEXT_SUBNET_EXCLUDING_UNICAST(subrec)) {
379                 if (ip_equal(*local_ip, subrec->myip)) {
380                         p->fd = (p->packet_type == NMB_PACKET) ?
381                                 subrec->nmb_sock : subrec->dgram_sock;
382                         break;
383                 }
384         }
385
386         if (p->packet_type == DGRAM_PACKET) {
387                 p->port = 138;
388                 p->packet.dgram.header.source_ip.s_addr = local_ip->s_addr;
389                 p->packet.dgram.header.source_port = 138;
390         }
391
392         send_packet(p);
393 }
394
395 /**************************************************************************** **
396  The main select loop.
397  **************************************************************************** */
398
399 static void process(void)
400 {
401         bool run_election;
402         bool no_subnets;
403
404         while( True ) {
405                 time_t t = time(NULL);
406                 TALLOC_CTX *frame = talloc_stackframe();
407
408                 /* Check for internal messages */
409
410                 message_dispatch(nmbd_messaging_context());
411
412                 /*
413                  * Check all broadcast subnets to see if
414                  * we need to run an election on any of them.
415                  * (nmbd_elections.c)
416                  */
417
418                 run_election = check_elections();
419
420                 /*
421                  * Read incoming UDP packets.
422                  * (nmbd_packets.c)
423                  */
424
425                 if(listen_for_packets(run_election)) {
426                         TALLOC_FREE(frame);
427                         return;
428                 }
429
430                 /*
431                  * Handle termination inband.
432                  */
433
434                 if (got_sig_term) {
435                         got_sig_term = 0;
436                         terminate();
437                 }
438
439                 /*
440                  * Process all incoming packets
441                  * read above. This calls the success and
442                  * failure functions registered when response
443                  * packets arrrive, and also deals with request
444                  * packets from other sources.
445                  * (nmbd_packets.c)
446                  */
447
448                 run_packet_queue();
449
450                 /*
451                  * Run any elections - initiate becoming
452                  * a local master browser if we have won.
453                  * (nmbd_elections.c)
454                  */
455
456                 run_elections(t);
457
458                 /*
459                  * Send out any broadcast announcements
460                  * of our server names. This also announces
461                  * the workgroup name if we are a local
462                  * master browser.
463                  * (nmbd_sendannounce.c)
464                  */
465
466                 announce_my_server_names(t);
467
468                 /*
469                  * Send out any LanMan broadcast announcements
470                  * of our server names.
471                  * (nmbd_sendannounce.c)
472                  */
473
474                 announce_my_lm_server_names(t);
475
476                 /*
477                  * If we are a local master browser, periodically
478                  * announce ourselves to the domain master browser.
479                  * This also deals with syncronising the domain master
480                  * browser server lists with ourselves as a local
481                  * master browser.
482                  * (nmbd_sendannounce.c)
483                  */
484
485                 announce_myself_to_domain_master_browser(t);
486
487                 /*
488                  * Fullfill any remote announce requests.
489                  * (nmbd_sendannounce.c)
490                  */
491
492                 announce_remote(t);
493
494                 /*
495                  * Fullfill any remote browse sync announce requests.
496                  * (nmbd_sendannounce.c)
497                  */
498
499                 browse_sync_remote(t);
500
501                 /*
502                  * Scan the broadcast subnets, and WINS client
503                  * namelists and refresh any that need refreshing.
504                  * (nmbd_mynames.c)
505                  */
506
507                 refresh_my_names(t);
508
509                 /*
510                  * Scan the subnet namelists and server lists and
511                  * expire thos that have timed out.
512                  * (nmbd.c)
513                  */
514
515                 expire_names_and_servers(t);
516
517                 /*
518                  * Write out a snapshot of our current browse list into
519                  * the browse.dat file. This is used by smbd to service
520                  * incoming NetServerEnum calls - used to synchronise
521                  * browse lists over subnets.
522                  * (nmbd_serverlistdb.c)
523                  */
524
525                 write_browse_list(t, False);
526
527                 /*
528                  * If we are a domain master browser, we have a list of
529                  * local master browsers we should synchronise browse
530                  * lists with (these are added by an incoming local
531                  * master browser announcement packet). Expire any of
532                  * these that are no longer current, and pull the server
533                  * lists from each of these known local master browsers.
534                  * (nmbd_browsesync.c)
535                  */
536
537                 dmb_expire_and_sync_browser_lists(t);
538
539                 /*
540                  * Check that there is a local master browser for our
541                  * workgroup for all our broadcast subnets. If one
542                  * is not found, start an election (which we ourselves
543                  * may or may not participate in, depending on the
544                  * setting of the 'local master' parameter.
545                  * (nmbd_elections.c)
546                  */
547
548                 check_master_browser_exists(t);
549
550                 /*
551                  * If we are configured as a logon server, attempt to
552                  * register the special NetBIOS names to become such
553                  * (WORKGROUP<1c> name) on all broadcast subnets and
554                  * with the WINS server (if used). If we are configured
555                  * to become a domain master browser, attempt to register
556                  * the special NetBIOS name (WORKGROUP<1b> name) to
557                  * become such.
558                  * (nmbd_become_dmb.c)
559                  */
560
561                 add_domain_names(t);
562
563                 /*
564                  * If we are a WINS server, do any timer dependent
565                  * processing required.
566                  * (nmbd_winsserver.c)
567                  */
568
569                 initiate_wins_processing(t);
570
571                 /*
572                  * If we are a domain master browser, attempt to contact the
573                  * WINS server to get a list of all known WORKGROUPS/DOMAINS.
574                  * This will only work to a Samba WINS server.
575                  * (nmbd_browsesync.c)
576                  */
577
578                 if (lp_enhanced_browsing())
579                         collect_all_workgroup_names_from_wins_server(t);
580
581                 /*
582                  * Go through the response record queue and time out or re-transmit
583                  * and expired entries.
584                  * (nmbd_packets.c)
585                  */
586
587                 retransmit_or_expire_response_records(t);
588
589                 /*
590                  * check to see if any remote browse sync child processes have completed
591                  */
592
593                 sync_check_completion();
594
595                 /*
596                  * regularly sync with any other DMBs we know about 
597                  */
598
599                 if (lp_enhanced_browsing())
600                         sync_all_dmbs(t);
601
602                 /*
603                  * clear the unexpected packet queue 
604                  */
605
606                 clear_unexpected(t);
607
608                 /*
609                  * Reload the services file if we got a sighup.
610                  */
611
612                 if(reload_after_sighup) {
613                         DATA_BLOB blob = data_blob_const(&no_subnets,
614                                                          sizeof(no_subnets));
615                         DEBUG( 0, ( "Got SIGHUP dumping debug info.\n" ) );
616                         msg_reload_nmbd_services(nmbd_messaging_context(),
617                                                  NULL, MSG_SMB_CONF_UPDATED,
618                                                  procid_self(), &blob);
619
620                         if(no_subnets) {
621                                 TALLOC_FREE(frame);
622                                 return;
623                         }
624                         reload_after_sighup = 0;
625                 }
626
627                 /* check for new network interfaces */
628
629                 if(reload_interfaces(t)) {
630                         TALLOC_FREE(frame);
631                         return;
632                 }
633
634                 /* free up temp memory */
635                 TALLOC_FREE(frame);
636         }
637 }
638
639 /**************************************************************************** **
640  Open the socket communication.
641  **************************************************************************** */
642
643 static bool open_sockets(bool isdaemon, int port)
644 {
645         /*
646          * The sockets opened here will be used to receive broadcast
647          * packets *only*. Interface specific sockets are opened in
648          * make_subnet() in namedbsubnet.c. Thus we bind to the
649          * address "0.0.0.0". The parameter 'socket address' is
650          * now deprecated.
651          */
652
653         if ( isdaemon )
654                 ClientNMB = open_socket_in(SOCK_DGRAM, port,
655                                            0, interpret_addr(lp_socket_address()),
656                                            True);
657         else
658                 ClientNMB = 0;
659   
660         ClientDGRAM = open_socket_in(SOCK_DGRAM, DGRAM_PORT,
661                                            3, interpret_addr(lp_socket_address()),
662                                            True);
663
664         if ( ClientNMB == -1 )
665                 return( False );
666
667         /* we are never interested in SIGPIPE */
668         BlockSignals(True,SIGPIPE);
669
670         set_socket_options( ClientNMB,   "SO_BROADCAST" );
671         set_socket_options( ClientDGRAM, "SO_BROADCAST" );
672
673         /* Ensure we're non-blocking. */
674         set_blocking( ClientNMB, False);
675         set_blocking( ClientDGRAM, False);
676
677         DEBUG( 3, ( "open_sockets: Broadcast sockets opened.\n" ) );
678         return( True );
679 }
680
681 /**************************************************************************** **
682  main program
683  **************************************************************************** */
684  int main(int argc, const char *argv[])
685 {
686         static int is_daemon;
687         static int Fork = True;
688         static int log_stdout;
689         pstring logfile;
690         static int opt_interactive;
691         poptContext pc;
692         static char *p_lmhosts = dyn_LMHOSTSFILE;
693         static int no_process_group = False;
694         int opt;
695         struct poptOption long_options[] = {
696         POPT_AUTOHELP
697         {"daemon", 'D', POPT_ARG_VAL, &is_daemon, True, "Become a daemon(default)" },
698         {"interactive", 'i', POPT_ARG_VAL, &opt_interactive, True, "Run interactive (not a daemon)" },
699         {"foreground", 'F', POPT_ARG_VAL, &Fork, False, "Run daemon in foreground (for daemontools & etc)" },
700         {"no-process-group", 0, POPT_ARG_VAL, &no_process_group, True, "Don't create a new process group" },
701         {"log-stdout", 'S', POPT_ARG_VAL, &log_stdout, True, "Log to stdout" },
702         {"hosts", 'H', POPT_ARG_STRING, &p_lmhosts, 'H', "Load a netbios hosts file"},
703         {"port", 'p', POPT_ARG_INT, &global_nmb_port, NMB_PORT, "Listen on the specified port" },
704         POPT_COMMON_SAMBA
705         { NULL }
706         };
707
708         load_case_tables();
709
710         global_nmb_port = NMB_PORT;
711
712         pc = poptGetContext("nmbd", argc, argv, long_options, 0);
713         while ((opt = poptGetNextOpt(pc)) != -1) {
714                 switch (opt) {
715                 default:
716                         d_fprintf(stderr, "\nInvalid option %s: %s\n\n",
717                                   poptBadOption(pc, 0), poptStrerror(opt));
718                         poptPrintUsage(pc, stderr, 0);
719                         exit(1);
720                 }
721         };
722         poptFreeContext(pc);
723
724         global_in_nmbd = True;
725         
726         StartupTime = time(NULL);
727         
728         sys_srandom(time(NULL) ^ sys_getpid());
729         
730         if (!override_logfile) {
731                 slprintf(logfile, sizeof(logfile)-1, "%s/log.nmbd", dyn_LOGFILEBASE);
732                 lp_set_logfile(logfile);
733         }
734         
735         fault_setup((void (*)(void *))fault_continue );
736         dump_core_setup("nmbd");
737         
738         /* POSIX demands that signals are inherited. If the invoking process has
739          * these signals masked, we will have problems, as we won't receive them. */
740         BlockSignals(False, SIGHUP);
741         BlockSignals(False, SIGUSR1);
742         BlockSignals(False, SIGTERM);
743         
744         CatchSignal( SIGHUP,  SIGNAL_CAST sig_hup );
745         CatchSignal( SIGTERM, SIGNAL_CAST sig_term );
746         
747 #if defined(SIGFPE)
748         /* we are never interested in SIGFPE */
749         BlockSignals(True,SIGFPE);
750 #endif
751
752         /* We no longer use USR2... */
753 #if defined(SIGUSR2)
754         BlockSignals(True, SIGUSR2);
755 #endif
756
757         if ( opt_interactive ) {
758                 Fork = False;
759                 log_stdout = True;
760         }
761
762         if ( log_stdout && Fork ) {
763                 DEBUG(0,("ERROR: Can't log to stdout (-S) unless daemon is in foreground (-F) or interactive (-i)\n"));
764                 exit(1);
765         }
766
767         setup_logging( argv[0], log_stdout );
768
769         reopen_logs();
770
771         DEBUG( 0, ( "Netbios nameserver version %s started.\n", SAMBA_VERSION_STRING) );
772         DEBUGADD( 0, ( "%s\n", COPYRIGHT_STARTUP_MESSAGE ) );
773
774         if ( !reload_nmbd_services(False) )
775                 return(-1);
776
777         if(!init_names())
778                 return -1;
779
780         reload_nmbd_services( True );
781
782         if (strequal(lp_workgroup(),"*")) {
783                 DEBUG(0,("ERROR: a workgroup name of * is no longer supported\n"));
784                 exit(1);
785         }
786
787         set_samba_nb_type();
788
789         if (!is_daemon && !is_a_socket(0)) {
790                 DEBUG(0,("standard input is not a socket, assuming -D option\n"));
791                 is_daemon = True;
792         }
793   
794         if (is_daemon && !opt_interactive) {
795                 DEBUG( 2, ( "Becoming a daemon.\n" ) );
796                 become_daemon(Fork, no_process_group);
797         }
798
799 #if HAVE_SETPGID
800         /*
801          * If we're interactive we want to set our own process group for 
802          * signal management.
803          */
804         if (opt_interactive && !no_process_group)
805                 setpgid( (pid_t)0, (pid_t)0 );
806 #endif
807
808         if (nmbd_messaging_context() == NULL) {
809                 return 1;
810         }
811
812 #ifndef SYNC_DNS
813         /* Setup the async dns. We do it here so it doesn't have all the other
814                 stuff initialised and thus chewing memory and sockets */
815         if(lp_we_are_a_wins_server() && lp_dns_proxy()) {
816                 start_async_dns();
817         }
818 #endif
819
820         if (!directory_exist(lp_lockdir(), NULL)) {
821                 mkdir(lp_lockdir(), 0755);
822         }
823
824         pidfile_create("nmbd");
825         messaging_register(nmbd_messaging_context(), NULL,
826                            MSG_FORCE_ELECTION, nmbd_message_election);
827 #if 0
828         /* Until winsrepl is done. */
829         messaging_register(nmbd_messaging_context(), NULL,
830                            MSG_WINS_NEW_ENTRY, nmbd_wins_new_entry);
831 #endif
832         messaging_register(nmbd_messaging_context(), NULL,
833                            MSG_SHUTDOWN, nmbd_terminate);
834         messaging_register(nmbd_messaging_context(), NULL,
835                            MSG_SMB_CONF_UPDATED, msg_reload_nmbd_services);
836         messaging_register(nmbd_messaging_context(), NULL,
837                            MSG_SEND_PACKET, msg_nmbd_send_packet);
838
839         TimeInit();
840
841         DEBUG( 3, ( "Opening sockets %d\n", global_nmb_port ) );
842
843         if ( !open_sockets( is_daemon, global_nmb_port ) ) {
844                 kill_async_dns_child();
845                 return 1;
846         }
847
848         /* Determine all the IP addresses we have. */
849         load_interfaces();
850
851         /* Create an nmbd subnet record for each of the above. */
852         if( False == create_subnets() ) {
853                 DEBUG(0,("ERROR: Failed when creating subnet lists. Exiting.\n"));
854                 kill_async_dns_child();
855                 exit(1);
856         }
857
858         /* Load in any static local names. */ 
859         load_lmhosts_file(p_lmhosts);
860         DEBUG(3,("Loaded hosts file %s\n", p_lmhosts));
861
862         /* If we are acting as a WINS server, initialise data structures. */
863         if( !initialise_wins() ) {
864                 DEBUG( 0, ( "nmbd: Failed when initialising WINS server.\n" ) );
865                 kill_async_dns_child();
866                 exit(1);
867         }
868
869         /* 
870          * Register nmbd primary workgroup and nmbd names on all
871          * the broadcast subnets, and on the WINS server (if specified).
872          * Also initiate the startup of our primary workgroup (start
873          * elections if we are setup as being able to be a local
874          * master browser.
875          */
876
877         if( False == register_my_workgroup_and_names() ) {
878                 DEBUG(0,("ERROR: Failed when creating my my workgroup. Exiting.\n"));
879                 kill_async_dns_child();
880                 exit(1);
881         }
882
883         /* We can only take signals in the select. */
884         BlockSignals( True, SIGTERM );
885
886         process();
887
888         if (dbf)
889                 x_fclose(dbf);
890         kill_async_dns_child();
891         return(0);
892 }