Happy new year
[pazpar2-moved-to-github.git] / src / pazpar2.c
index 3352fa0..0db4a4f 100644 (file)
@@ -1,5 +1,5 @@
 /* This file is part of Pazpar2.
-   Copyright (C) 2006-2009 Index Data
+   Copyright (C) Index Data
 
 Pazpar2 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
@@ -22,52 +22,62 @@ Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
 #endif
 #ifdef WIN32
 #include <winsock.h>
+#include <direct.h>
+#endif
+#if HAVE_UNISTD_H
+#include <unistd.h>
 #endif
 
 #include <signal.h>
 #include <assert.h>
 
-#include "pazpar2.h"
-#include "database.h"
-#include "settings.h"
+#include "parameters.h"
+#include "session.h"
+#include "ppmutex.h"
 #include <yaz/daemon.h>
-
+#include <yaz/log.h>
+#include <yaz/options.h>
 #include <yaz/sc.h>
+#include <yaz/backtrace.h>
 
-void child_handler(void *data)
-{
-    start_proxy();
-    init_settings();
+// #define MTRACE
+#ifdef MTRACE
+#include <mcheck.h>
+#endif
 
-    if (*global_parameters.settings_path_override)
-        settings_read(global_parameters.settings_path_override);
-    else if (global_parameters.server->settings)
-        settings_read(global_parameters.server->settings);
-    else
-        yaz_log(YLOG_WARN, "No settings-directory specified");
-    global_parameters.odr_in = odr_createmem(ODR_DECODE);
-    global_parameters.odr_out = odr_createmem(ODR_ENCODE);
+static struct conf_config *sc_stop_config = 0;
 
+void child_handler(void *data)
+{
+    struct conf_config *config = (struct conf_config *) data;
 
-    pazpar2_event_loop();
+    config_process_events(config);
 
+    config_destroy(config);
 }
 
 static void show_version(void)
 {
-    char yaz_version_str[80];
-    printf("Pazpar2 " PACKAGE_VERSION "\n");
+    char yaz_version_str[20];
+    printf("Pazpar2 " PACKAGE_VERSION
+#ifdef PAZPAR2_VERSION_SHA1
+           " "
+           PAZPAR2_VERSION_SHA1
+#endif
+"\n");
 
     yaz_version(yaz_version_str, 0);
 
     printf("Configuration:");
 #if YAZ_HAVE_ICU
-    printf(" icu:?");
+    printf(" icu:enabled");
+#else
+    printf(" icu:disabled");
 #endif
     printf(" yaz:%s", yaz_version_str);
     printf("\n");
     exit(0);
-}            
+}
 
 #ifdef WIN32
 static int tcpip_init (void)
@@ -84,7 +94,7 @@ static int tcpip_init (void)
 
 
 static int sc_main(
-    yaz_sc_t s, 
+    yaz_sc_t s,
     int argc, char **argv)
 {
     int daemon = 0;
@@ -93,6 +103,14 @@ static int sc_main(
     char *arg;
     const char *pidfile = 0;
     const char *uid = 0;
+    const char *listener_override = 0;
+    const char *config_fname = 0;
+    const char *record_fname = 0;
+    struct conf_config *config = 0;
+    int test_mode = 0;
+
+    xmlInitParser();
+    LIBXML_TEST_VERSION
 
 #ifndef WIN32
     if (signal(SIGPIPE, SIG_IGN) == SIG_ERR)
@@ -102,96 +120,156 @@ static int sc_main(
 #endif
 
     yaz_log_init_prefix("pazpar2");
+    yaz_log_init_level(yaz_log_mask_str("post"));
     yaz_log_xml_errors(0, YLOG_WARN);
 
-    while ((ret = options("dDf:h:l:p:t:u:VX", argv, argc, &arg)) != -2)
+    yaz_enable_panic_backtrace(argv[0]);
+
+    while ((ret = options("dDf:h:l:m:p:R:tu:v:Vw:X", argv, argc, &arg)) != -2)
     {
        switch (ret)
         {
         case 'd':
-            global_parameters.dump_records = 1;
+            global_parameters.dump_records++;
             break;
         case 'D':
             daemon = 1;
             break;
         case 'f':
-            if (!read_config(arg))
-                exit(1);
+            config_fname = arg;
             break;
         case 'h':
-            strcpy(global_parameters.listener_override, arg);
+            listener_override = arg;
             break;
         case 'l':
             yaz_log_init_file(arg);
             log_file_in_use = 1;
             break;
+        case 'm':
+            yaz_log_time_format(arg);
+            break;
         case 'p':
             pidfile = arg;
             break;
+        case 'R':
+            if (strcmp(arg, "-"))
+                record_fname = arg;
+            global_parameters.predictable_sessions = 1;
+            break;
         case 't':
-            strcpy(global_parameters.settings_path_override, arg);
+            test_mode = 1;
             break;
         case 'u':
             uid = arg;
             break;
+        case 'v':
+            yaz_log_init_level(yaz_log_mask_str(arg));
+            break;
         case 'V':
             show_version();
+            break;
+        case 'w':
+            if (
+#ifdef WIN32
+              _chdir
+#else
+              chdir
+#endif
+                (arg))
+            {
+                yaz_log(YLOG_FATAL|YLOG_ERRNO, "chdir %s", arg);
+                return 1;
+            }
+            break;
         case 'X':
-            global_parameters.debug_mode = 1;
+            global_parameters.debug_mode++;
+            global_parameters.predictable_sessions = 1;
             break;
         default:
             fprintf(stderr, "Usage: pazpar2\n"
-                    "    -d                      (show internal records)\n"
+                    "    -d                      Show internal records\n"
                     "    -D                      Daemon mode (background)\n"
-                    "    -f configfile\n"
-                    "    -h [host:]port          (REST protocol listener)\n"
-                    "    -l file                 log to file\n"
+                    "    -f configfile           Configuration\n"
+                    "    -h [host:]port          Listener port\n"
+                    "    -l file                 Log to file\n"
+                    "    -m logformat            log time format (strftime)\n"
                     "    -p pidfile              PID file\n"
-                    "    -t settings\n"
-                    "    -u uid\n"
-                    "    -V                      show version\n"
-                    "    -X                      debug mode\n"
+                    "    -R recfile              HTTP recording file\n"
+                    "    -t                      Test configuration\n"
+                    "    -u uid                  Change user to uid\n"
+                    "    -V                      Show version\n"
+                    "    -v level                Set log level\n"
+                    "    -w dir                  Working directory\n"
+                    "    -X                      Debug mode\n"
 #ifdef WIN32
-                    "    -install                install windows service\n"
-                    "    -remove                 remove windows service\n"
+                    "    -install                Install windows service\n"
+                    "    -remove                 Remove windows service\n"
 #endif
                 );
             return 1;
        }
     }
-
-    yaz_log(YLOG_LOG, "Pazpar2 %s started", VERSION);
-    if (daemon && !log_file_in_use)
+    if (!config_fname)
     {
-        yaz_log(YLOG_FATAL, "Logfile must be given (option -l) for daemon "
-                "mode");
+        yaz_log(YLOG_FATAL, "Configuration must be given with option -f");
         return 1;
     }
-    if (!config)
+    pazpar2_mutex_init();
+
     {
-        yaz_log(YLOG_FATAL, "Load config with -f");
-        return 1;
+        char yaz_version_str[20];
+        char yaz_sha1_str[41];
+        yaz_log(YLOG_LOG, "Pazpar2 %s " VERSION " "
+#ifdef PAZPAR2_VERSION_SHA1
+                PAZPAR2_VERSION_SHA1
+#else
+                "-"
+#endif
+                , test_mode ? "test" : "start");
+        yaz_version(yaz_version_str, yaz_sha1_str);
+        yaz_log(YLOG_LOG, "YAZ %s %s", yaz_version_str, yaz_sha1_str);
     }
-    global_parameters.server = config->servers;
-
-    ret = start_http_listener();
-    if (ret)
-        return ret; /* error starting http listener */
 
-    yaz_sc_running(s);
-
-    yaz_daemon("pazpar2",
-               (global_parameters.debug_mode ? YAZ_DAEMON_DEBUG : 0) +
-               (daemon ? YAZ_DAEMON_FORK : 0) + YAZ_DAEMON_KEEPALIVE,
-               child_handler, 0 /* child_data */,
-               pidfile, uid);
-    return 0;
+    config = config_create(config_fname);
+    if (!config)
+        return 1;
+    sc_stop_config = config;
+    ret = 0;
+    if (test_mode)
+    {
+        yaz_log(YLOG_LOG, "Configuration OK");
+        config_destroy(config);
+    }
+    else
+    {
+        if (daemon && !log_file_in_use)
+        {
+            yaz_log(YLOG_FATAL, "Logfile must be given (option -l) for daemon "
+                    "mode");
+            ret = 1;
+        }
+        if (!ret)
+            ret = config_start_listeners(config, listener_override,
+                                         record_fname);
+        if (!ret)
+        {
+            yaz_sc_running(s);
+            yaz_daemon("pazpar2",
+                       (global_parameters.debug_mode ? YAZ_DAEMON_DEBUG : 0) +
+                       (daemon ? YAZ_DAEMON_FORK : 0) + YAZ_DAEMON_KEEPALIVE,
+                       child_handler, config /* child_data */,
+                       pidfile, uid);
+        }
+        yaz_log(YLOG_LOG, "Pazpar2 stop");
+    }
+    config_destroy(config);
+    return ret;
 }
 
 
 static void sc_stop(yaz_sc_t s)
 {
-    http_close_server();
+    config_stop_listeners(sc_stop_config);
 }
 
 int main(int argc, char **argv)
@@ -199,9 +277,19 @@ int main(int argc, char **argv)
     int ret;
     yaz_sc_t s = yaz_sc_create("pazpar2", "Pazpar2");
 
+#ifdef MTRACE
+    mtrace();
+#endif
+
     ret = yaz_sc_program(s, argc, argv, sc_main, sc_stop);
 
     yaz_sc_destroy(&s);
+
+#ifdef MTRACE
+    muntrace();
+#endif
+
+
     exit(ret);
 }