]> git.sur5r.net Git - bacula/bacula/blobdiff - bacula/src/dird/dird.c
07Jan06
[bacula/bacula] / bacula / src / dird / dird.c
index fd0584ee69be5d2e5e7f05ebfc4cc1e170b152e1..63a3b1ea8ac873ed4a9df9274d4d8953174dfeab 100644 (file)
@@ -7,22 +7,17 @@
  *   Version $Id$
  */
 /*
-   Copyright (C) 2000-2005 Kern Sibbald
+   Copyright (C) 2000-2006 Kern Sibbald
 
    This program is free software; you can redistribute it and/or
-   modify it under the terms of the GNU General Public License as
-   published by the Free Software Foundation; either version 2 of
-   the License, or (at your option) any later version.
+   modify it under the terms of the GNU General Public License
+   version 2 as amended with additional clauses defined in the
+   file LICENSE in the main source directory.
 
    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
-   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
-   General Public License for more details.
-
-   You should have received a copy of the GNU General Public
-   License along with this program; if not, write to the Free
-   Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
-   MA 02111-1307, USA.
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 
+   the file LICENSE for additional details.
 
  */
 
@@ -50,7 +45,6 @@ void store_level(LEX *lc, RES_ITEM *item, int index, int pass);
 void store_replace(LEX *lc, RES_ITEM *item, int index, int pass);
 void init_device_resources();
 
-static char *configfile = NULL;
 static char *runjob = NULL;
 static int background = 1;
 static void init_reload(void);
@@ -59,6 +53,7 @@ static void init_reload(void);
 DIRRES *director;                     /* Director resource */
 int FDConnectTimeout;
 int SDConnectTimeout;
+char *configfile = NULL;
 
 /* Globals Imported */
 extern int r_first, r_last;           /* first and last resources */
@@ -74,7 +69,7 @@ static void usage()
 {
    fprintf(stderr, _(
 "Copyright (C) 2000-2005 Kern Sibbald.\n"
-"\nVersion: " VERSION " (" BDATE ")\n\n"
+"\nVersion: %s (%s)\n\n"
 "Usage: dird [-f -s] [-c config_file] [-d debug_level] [config_file]\n"
 "       -c <file>   set configuration file to file\n"
 "       -dnn        set debug level to nn\n"
@@ -86,7 +81,7 @@ static void usage()
 "       -u          userid\n"
 "       -v          verbose user messages\n"
 "       -?          print this message.\n"
-"\n"));
+"\n"), VERSION, BDATE);
 
    exit(1);
 }
@@ -106,9 +101,12 @@ int main (int argc, char *argv[])
    char *uid = NULL;
    char *gid = NULL;
 
+   setlocale(LC_ALL, "");
+   bindtextdomain("bacula", LOCALEDIR);
+   textdomain("bacula");
+
    init_stack_dump();
    my_name_is(argc, argv, "bacula-dir");
-   textdomain("bacula");
    init_msg(NULL, NULL);              /* initialize message handler */
    init_reload();
    daemon_start_time = time(NULL);
@@ -194,8 +192,8 @@ int main (int argc, char *argv[])
 
    parse_config(configfile);
 
-   if (init_tls() != 0) {
-      Jmsg((JCR *)NULL, M_ERROR_TERM, 0, _("TLS library initialization failed.\n"));
+   if (init_crypto() != 0) {
+      Jmsg((JCR *)NULL, M_ERROR_TERM, 0, _("Cryptography library initialization failed.\n"));
    }
 
    if (!check_resources()) {
@@ -241,11 +239,9 @@ int main (int argc, char *argv[])
 
    init_job_server(director->MaxConcurrentJobs);
 
-// init_device_resources();
-
    Dmsg0(200, "wait for next job\n");
    /* Main loop -- call scheduler to get next job to run */
-   while ((jcr = wait_for_next_job(runjob))) {
+   while ( (jcr = wait_for_next_job(runjob)) ) {
       run_job(jcr);                   /* run job */
       free_jcr(jcr);                  /* release jcr */
       if (runjob) {                   /* command line, run a single job? */
@@ -284,7 +280,7 @@ static void terminate_dird(int sig)
    term_ua_server();
    term_msg();                        /* terminate message handler */
    stop_watchdog();
-   cleanup_tls();
+   cleanup_crypto();
    close_memory_pool();               /* release free memory in pool */
    sm_dump(false);
    exit(sig);
@@ -334,13 +330,13 @@ static void reload_job_end_cb(JCR *jcr, void *ctx)
    int reload_id = (int)((long int)ctx);
    Dmsg3(100, "reload job_end JobId=%d table=%d cnt=%d\n", jcr->JobId,
       reload_id, reload_table[reload_id].job_count);
-   lock_jcr_chain();
+   lock_jobs();
    LockRes();
    if (--reload_table[reload_id].job_count <= 0) {
       free_saved_resources(reload_id);
    }
    UnlockRes();
-   unlock_jcr_chain();
+   unlock_jobs();
 }
 
 static int find_free_reload_table_entry()
@@ -392,9 +388,7 @@ void reload_config(int sig)
    sigaddset(&set, SIGHUP);
    sigprocmask(SIG_BLOCK, &set, NULL);
 
-// Jmsg(NULL, M_INFO, 0, "Entering experimental reload config code. Bug reports will not be accepted.\n");
-
-   lock_jcr_chain();
+   lock_jobs();
    LockRes();
 
    table = find_free_reload_table_entry();
@@ -437,8 +431,8 @@ void reload_config(int sig)
             job_end_push(jcr, reload_job_end_cb, (void *)((long int)table));
             njobs++;
          }
-         free_locked_jcr(jcr);
       }
+      endeach_jcr(jcr);
    }
 
    /* Reset globals */
@@ -447,8 +441,6 @@ void reload_config(int sig)
    SDConnectTimeout = director->SDConnectTimeout;
    Dmsg0(0, "Director's configuration file reread.\n");
 
-// init_device_resources();           /* Update Device resources */
-
    /* Now release saved resources, if no jobs using the resources */
    if (njobs == 0) {
       free_saved_resources(table);
@@ -456,7 +448,7 @@ void reload_config(int sig)
 
 bail_out:
    UnlockRes();
-   unlock_jcr_chain();
+   unlock_jobs();
    sigprocmask(SIG_UNBLOCK, &set, NULL);
    signal(SIGHUP, reload_config);
    already_here = false;
@@ -496,10 +488,14 @@ static int check_resources()
             configfile);
          OK = false;
       }
-#ifdef HAVE_TLS
       /* tls_require implies tls_enable */
       if (director->tls_require) {
-         director->tls_enable = true;
+         if (have_tls) {
+            director->tls_enable = true;
+         } else {
+            Jmsg(NULL, M_FATAL, 0, _("TLS required but not configured in Bacula.\n"));
+            OK = false;
+         }
       }
 
       if (!director->tls_certfile && director->tls_enable) {
@@ -539,7 +535,6 @@ static int check_resources()
             OK = false;
          }
       }
-#endif /* HAVE_TLS */
    }
 
    if (!job) {
@@ -587,7 +582,7 @@ static int check_resources()
                        job->hdr.name, job_items[i].name, *def_svalue, i, offset);
                   svalue = (char **)((char *)job + offset);
                   if (*svalue) {
-                     Pmsg1(000, "Hey something is wrong. p=0x%lu\n", *svalue);
+                     Pmsg1(000, _("Hey something is wrong. p=0x%lu\n"), *svalue);
                   }
                   *svalue = bstrdup(*def_svalue);
                   set_bit(i, job->hdr.item_present);
@@ -600,7 +595,7 @@ static int check_resources()
                        job->hdr.name, job_items[i].name, i, offset);
                   svalue = (char **)((char *)job + offset);
                   if (*svalue) {
-                     Pmsg1(000, "Hey something is wrong. p=0x%lu\n", *svalue);
+                     Pmsg1(000, _("Hey something is wrong. p=0x%lu\n"), *svalue);
                   }
                   *svalue = *def_svalue;
                   set_bit(i, job->hdr.item_present);
@@ -649,14 +644,14 @@ static int check_resources()
       for (i=0; job_items[i].name; i++) {
          if (job_items[i].flags & ITEM_REQUIRED) {
                if (!bit_is_set(i, job->hdr.item_present)) {
-                  Jmsg(NULL, M_FATAL, 0, "\"%s\" directive in Job \"%s\" resource is required, but not found.\n",
+                  Jmsg(NULL, M_FATAL, 0, _("\"%s\" directive in Job \"%s\" resource is required, but not found.\n"),
                     job_items[i].name, job->hdr.name);
                   OK = false;
                 }
          }
          /* If this triggers, take a look at lib/parse_conf.h */
          if (i >= MAX_RES_ITEMS) {
-            Emsg0(M_ERROR_TERM, 0, "Too many items in Job resource\n");
+            Emsg0(M_ERROR_TERM, 0, _("Too many items in Job resource\n"));
          }
       }
    } /* End loop over Job res */
@@ -708,10 +703,14 @@ static int check_resources()
             db_update_storage_record(NULL, db, &sr);
          }
 
-#ifdef HAVE_TLS
          /* tls_require implies tls_enable */
          if (store->tls_require) {
-            store->tls_enable = true;
+            if (have_tls) {
+               store->tls_enable = true;
+            } else {
+               Jmsg(NULL, M_FATAL, 0, _("TLS required but not configured in Bacula.\n"));
+               OK = false;
+            }
          } 
 
          if ((!store->tls_ca_certfile && !store->tls_ca_certdir) && store->tls_enable) {
@@ -736,7 +735,6 @@ static int check_resources()
                OK = false;
             }
          }
-#endif /* HAVE_TLS */
       }
 
       /* Loop over all counters, defining them in each database */
@@ -768,13 +766,18 @@ static int check_resources()
       db_close_database(NULL, db);
    }
 
-#ifdef HAVE_TLS
    /* Loop over Consoles */
    CONRES *cons;
    foreach_res(cons, R_CONSOLE) {
       /* tls_require implies tls_enable */
       if (cons->tls_require) {
-         cons->tls_enable = true;
+         if (have_tls) {
+            cons->tls_enable = true;
+         } else {
+            Jmsg(NULL, M_FATAL, 0, _("TLS required but not configured in Bacula.\n"));
+            OK = false;
+            continue;
+         }
       }
 
       if (!cons->tls_certfile && cons->tls_enable) {
@@ -814,15 +817,19 @@ static int check_resources()
       }
 
    }
-#endif /* HAVE_TLS */
 
-#ifdef HAVE_TLS
    /* Loop over Clients */
    CLIENT *client;
    foreach_res(client, R_CLIENT) {
       /* tls_require implies tls_enable */
       if (client->tls_require) {
-         client->tls_enable = true;
+         if (have_tls) {
+            client->tls_enable = true;
+         } else {
+            Jmsg(NULL, M_FATAL, 0, _("TLS required but not configured in Bacula.\n"));
+            OK = false;
+            continue;
+         }
       }
 
       if ((!client->tls_ca_certfile && !client->tls_ca_certdir) && client->tls_enable) {
@@ -849,7 +856,6 @@ static int check_resources()
          }
       }
    }
-#endif /* HAVE_TLS */
 
    UnlockRes();
    if (OK) {