xdasd_trigger.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_trigger.h"
#include "xdasd_exec.h"
#include "xdasd_parse.h"
#include "xdasd_mqueue.h"
#include "xdasd_list.h"
#include "xdasd_log.h"

#include <stdio.h>
#include <stdlib.h>
#include <string.h>

/* module statics */
static XDList s_list_trigger;    
static MsgQueue s_mq_trigger;    
static int tr_put(void * msg)
{
   Parsed * parsed = (Parsed *)msg;
   Parsed * cpy;
   int i;

   /* allocate a copy for the queue */
   if ((cpy = (Parsed *)malloc(parsed->structsz)) == 0)
      return -1;

   /* copy all fields up to parsed - triggers list becomes ours */
   memcpy(cpy, parsed, offsetof(Parsed, parsed));
   memset(&parsed->triggers, 0, sizeof(parsed->triggers));

   /* copy message data */
   memcpy(cpy->msg, parsed->msg, parsed->parsed[XDAS_FIELD_COUNT] - parsed->msg);

   /* setup message field pointers */
   for (i = 0; i < XDAS_FIELD_COUNT + 1; i++)
      cpy->parsed[i] = cpy->msg + (parsed->parsed[i] - parsed->msg);

   xdasd_list_link_tail(&s_list_trigger, &cpy->elem);

   return 0;
}

static void * tr_get(void)
{
   return s_list_trigger.count != 0? 
         xdasd_list_unlink(&s_list_trigger, s_list_trigger.tail): 
         0;
}

static void tr_process(void * msg)
{
   Parsed * parsed = (Parsed *)msg;
   Trigger * t = (Trigger *)parsed->triggers.head;
   while (t)
   {
      if (xdasd_exec(t->script, parsed->parsed) != 0)
         xdasd_log(0, "trigger: Error processing script for message:\n[ %s ]\n", 
               parsed->msg);
      t = (Trigger *)t->elem.next;
   }
   xdasd_parse_free(parsed);
}

/*--------------------------------------------------------------------------*/

int xdasd_trigger_append(Parsed * parsed)
{
   return xdasd_mqueue_append(s_mq_trigger, parsed);
}

int xdasd_trigger_init(void)
{
   memset(&s_list_trigger, 0, sizeof(s_list_trigger));
   if ((s_mq_trigger = xdasd_mqueue_create(tr_put, tr_get, tr_process)) == 0)
   {
      xdasd_log(0, "trigger: Unable to create trigger queue.\n");
      return -1;
   }
   return 0;
}

void xdasd_trigger_exit(void)
{
   xdasd_mqueue_destroy(s_mq_trigger);
}