This commit was manufactured by cvs2svn to create tag

[bacula/bacula] / bacula / src / filed / filed.c

diff --git a/bacula/src/filed/filed.c b/bacula/src/filed/filed.c
index bbd95ba5c8938ca6277c26df09ad7caf890bbfc7..aa8dbe07bef51fda265f104efa9936502e179e22 100644 (file)
--- a/bacula/src/filed/filed.c
+++ b/bacula/src/filed/filed.c
@@ -30,12 +30,15 @@
 #include "filed.h"
 
 /* Imported Functions */
-extern void handle_client_request(void *dir_sock);
+extern void *handle_client_request(void *dir_sock);
 
 /* Forward referenced functions */
 void terminate_filed(int sig);
 
 /* Exported variables */
+CLIENT *me;                          /* my resource */
+char OK_msg[]   = "2000 OK\n";
+char TERM_msg[] = "2999 Terminate\n";
 
 
 #ifdef HAVE_CYGWIN
@@ -49,20 +52,24 @@ int win32_client = 0;
 
 static char *configfile = NULL;
 static int foreground = 0;
+static int inetd_request = 0;
 static workq_t dir_workq;            /* queue of work from Director */
 
-CLIENT *me;                          /* my resource */
 
 static void usage()
 {
    fprintf(stderr, _(
-"\nVersion: " VERSION " (" DATE ")\n\n"
-"Usage: filed [-f -s] [-c config_file] [-d debug_level] [config_file]\n"  
+"\nVersion: " VERSION " (" BDATE ")\n\n"
+"Usage: bacula-fd [-f -s] [-c config_file] [-d debug_level]\n"  
 "        -c <file>   use <file> as configuration file\n"
 "        -dnn        set debug level to nn\n"
 "        -f          run in foreground (for debugging)\n"
+"        -g          groupid\n"
+"        -i          inetd request\n"
 "        -s          no signals (for debugging)\n"
 "        -t          test configuration file and exit\n"
+"        -u          userid\n"
+"        -v          verbose user messages\n"
 "        -?          print this message.\n"
 "\n"));         
    exit(1);
@@ -83,45 +90,61 @@ int main (int argc, char *argv[])
    int no_signals = FALSE;
    int test_config = FALSE;
    DIRRES *director;
+   char *uid = NULL;
+   char *gid = NULL;
 
    init_stack_dump();
-   my_name_is(argc, argv, "filed");
+   my_name_is(argc, argv, "bacula-fd");
+   textdomain("bacula-fd");
    init_msg(NULL, NULL);
    daemon_start_time = time(NULL);
 
-   memset(&last_job, 0, sizeof(last_job));
-
-   while ((ch = getopt(argc, argv, "c:d:fst?")) != -1) {
+   while ((ch = getopt(argc, argv, "c:d:fg:istu:v?")) != -1) {
       switch (ch) {
-         case 'c':                    /* configuration file */
-           if (configfile != NULL) {
-              free(configfile);
-           }
-           configfile = bstrdup(optarg);
-           break;
-
-         case 'd':                    /* debug level */
-           debug_level = atoi(optarg);
-           if (debug_level <= 0) {
-              debug_level = 1; 
-           }
-           break;
-
-         case 'f':                    /* run in foreground */
-           foreground = TRUE;
-           break;
-
-         case 's':
-           no_signals = TRUE;
-           break;
-
-         case 't':
-           test_config = TRUE;
-           break;
-
-         case '?':
-        default:
-           usage();
+      case 'c':                    /* configuration file */
+        if (configfile != NULL) {
+           free(configfile);
+        }
+        configfile = bstrdup(optarg);
+        break;
+
+      case 'd':                    /* debug level */
+        debug_level = atoi(optarg);
+        if (debug_level <= 0) {
+           debug_level = 1; 
+        }
+        break;
+
+      case 'f':                    /* run in foreground */
+        foreground = TRUE;
+        break;
+
+      case 'g':                    /* set group */
+        gid = optarg;
+        break;
+
+      case 'i':
+        inetd_request = TRUE;
+        break;
+      case 's':
+        no_signals = TRUE;
+        break;
+
+      case 't':
+        test_config = TRUE;
+        break;
+
+      case 'u':                    /* set userid */
+        uid = optarg;
+        break;
+
+      case 'v':                    /* verbose */
+        verbose++;
+        break;
+
+      case '?':
+      default:
+        usage();
 
       }  
    }
@@ -176,29 +199,43 @@ Without that I don't know who I am :-(\n"), configfile);
       close_msg(NULL);               /* close temp message handler */
       init_msg(NULL, me->messages);   /* open user specified message handler */
    }
-   working_directory = me->working_directory;
+
+   set_working_directory(me->working_directory);
 
    if (test_config) {
       terminate_filed(0);
    }
 
-   if (!foreground) {
+   if (!foreground &&!inetd_request) {
       daemon_start();
       init_stack_dump();             /* set new pid */
    }
 
+   drop(uid, gid);
+
+   /* Maximum 1 daemon at a time */
    create_pid_file(me->pid_directory, "bacula-fd", me->FDport);
 
 #ifdef BOMB
    me += 1000000;
 #endif
 
+   set_thread_concurrency(10);
+
    start_watchdog();                 /* start watchdog thread */
 
-   /* Become server, and handle requests */
-   Dmsg1(10, "filed: listening on port %d\n", me->FDport);
-   bnet_thread_server(me->FDport, 10, &dir_workq, handle_client_request);
+   if (inetd_request) {
+      /* Socket is on fd 0 */         
+      BSOCK *bs = init_bsock(NULL, 0, "client", "unknown client", me->FDport);
+      handle_client_request((void *)bs);
+   } else {
+      /* Become server, and handle requests */
+      Dmsg1(10, "filed: listening on port %d\n", me->FDport);
+      bnet_thread_server(me->FDaddr, me->FDport, me->MaxConcurrentJobs, 
+                     &dir_workq, handle_client_request);
+   }
 
+   term_msg();
    exit(0);                          /* should never get here */
 }