xdasd_main.c

Go to the documentation of this file.

/*----------------------------------------------------------------------------
 * Copyright (c) 2006, Novell, Inc.
 * All rights reserved.
 * 
 * Redistribution and use in source and binary forms, with or without 
 * modification, are permitted provided that the following conditions are 
 * met:
 * 
 *     * Redistributions of source code must retain the above copyright 
 *       notice, this list of conditions and the following disclaimer.
 *     * Redistributions in binary form must reproduce the above copyright 
 *       notice, this list of conditions and the following disclaimer in the 
 *       documentation and/or other materials provided with the distribution.
 *     * Neither the name of the Novell nor the names of its contributors 
 *       may be used to endorse or promote products derived from this 
 *       software without specific prior written permission.
 * 
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 
 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR 
 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 
 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 
 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR 
 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF 
 * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING 
 * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 
 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *--------------------------------------------------------------------------*/

#include "xdasd_main.h"
#include "xdasd_log.h"
#include "xdasd_net.h"
#include "xdasd_conf.h"
#include "xdasd_cmdline.h"
#include "xdasd_filter.h"
#include "xdasd_trigger.h"
#include "xdasd_logger.h"

#include <errno.h>
#include <stdio.h>

#ifdef _WIN32
# define snprintf _snprintf
#endif

static unsigned s_xdasd_sigmask = 0;

static void xdasd_clear_signal(unsigned sigbit)
{
   s_xdasd_sigmask &= ~sigbit;
}

static int xdasd_is_signaled(unsigned sigbit)
{
   return (s_xdasd_sigmask & sigbit)? 1: 0;
}

static void xdasd_handle_sigterm(void)
{
   xdasd_log(0, "----------------------------------\n");
   xdasd_log(0, "xdasd terminating.\n");

   xdasd_net_exit();

   xdasd_log(0, "----------------------------------\n");
   xdasd_log(0, "xdasd terminated.\n");

   xdasd_clear_signal(XDASD_SIGTERM);
}

void xdasd_handle_sighup(void)
{
   xdasd_log(0, "----------------------------------\n");
   xdasd_log(0, "xdasd reset by SIGHUP.\n");

   xdasd_conf_init(0);

   xdasd_log(0, "----------------------------------\n");
   xdasd_log(0, "xdasd reset finished.\n");

   xdasd_clear_signal(XDASD_SIGHUP);
}

void xdasd_set_signal(unsigned sigbit)
{
   s_xdasd_sigmask |= sigbit;
}

int xdasd_main_init(XDASDCmdLine * cmdline)
{
   int err;
   char ipcfile[FILENAME_MAX];

   snprintf(ipcfile, sizeof(ipcfile), "%s/" XDASD_IPCFNAME, cmdline->runpath);
   remove(ipcfile);

   if ((err = xdasd_log_open(cmdline->logfile, 1, cmdline->loglevel)) != 0)
      return err;

   xdasd_log(0, "----------------------------------\n");
   xdasd_log(0, "Starting xdasd version %s...\n", cmdline->verstr);
   xdasd_log(0, "Using configuration file %s.\n", cmdline->confile);
   xdasd_log(0, "Using filter specification file %s.\n", cmdline->fltfile);
   xdasd_log(0, "Using message queue directory %s.\n", cmdline->msgfdir);
   xdasd_log(0, "Using unique ipc path/string %s.\n", ipcfile);

   xdasd_conf_init(cmdline->confile);

   if ((err = xdasd_filter_init(cmdline->fltfile)) != 0)
   {
      xdasd_log(0, "Filter initialization failed.\n");
      goto e2;
   }
   if ((err = xdasd_logger_init(cmdline->msgfdir)) != 0)
   {
      xdasd_log(0, "Logger initialization failed.\n");
      goto e3;
   }
   if ((err = xdasd_trigger_init()) != 0)
   {
      xdasd_log(0, "Trigger initialization failed.\n");
      goto e4;
   }
   if ((err = xdasd_net_init(ipcfile)) != 0)
   {
      xdasd_log(0, "Network initialization failed (%d).\n", errno);
      goto e5;
   }
   xdasd_log(0, "main: Successfully initialized.\n");
   return 0;

   /* error paths */
e5:xdasd_trigger_exit();
e4:xdasd_logger_exit();
e3:xdasd_filter_exit();
e2:xdasd_conf_exit();
   xdasd_log_close();
   return err;
}

void xdasd_main_run(void)
{
   xdasd_log(0, "Entering main run loop...\n");

   while (!xdasd_is_signaled(XDASD_SIGTERM))
   {
      fd_set readfds, writefds;
      int fdcount, highfd = 0;
      struct timeval tmout = {2,0}; /* 2 seconds */

      if (xdasd_is_signaled(XDASD_SIGHUP))
         xdasd_handle_sighup();

      FD_ZERO(&readfds);
      FD_ZERO(&writefds);
      xdasd_net_load_fdsets(&highfd, &readfds, &writefds);
      if ((fdcount = select(highfd + 1, &readfds, &writefds, 0, &tmout)) > 0)
         xdasd_net_event_handler(fdcount, &readfds, &writefds);
   }
   xdasd_handle_sigterm();
   xdasd_trigger_exit();
   xdasd_logger_exit();
   xdasd_filter_exit();
   xdasd_conf_exit();
   xdasd_log_close();
}