logfilehandler.h

Go to the documentation of this file.

/*
** Copyright (C) 2004 Russell Leighton
**
** 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.
**
** 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.
*/




#ifndef __AWHANDLER_LOGFILE__
#define __AWHANDLER_LOGFILE__

#include "hash.h"
#include "regexmatch.h"
#include "monitor.h"
#include "wire.h"

/*\@{*/



/* 

Changes:

02/11/04 Russell Leighton
Port to handler

*/

typedef struct aw_logfilehandler_digest_s {

  /* list */
  struct aw_logfilehandler_digest_s *next;
 
  /* line from log file we are dedupping */
  byte_t
   *line;

  /* associated event */
  aw_event_sig_t
   *eventsig;

  aw_timestamp_t
   createtime;

  u_int32_t
   count;

} aw_logfilehandler_digest_t;

typedef struct {

  aw_event_sig_t
   match,               /* regex matched */
   nomatch;             /* regex did not match */

} aw_logfilehandler_events_t;

typedef struct {

  int32_t
   fd;               /* open fd to text file */

  ino_t
   inode;            /* inode of file */

  off_t
   offset;           /* where in file */

  aw_hashString_t
   *line2digest;     /* lookup for digest */

  aw_logfilehandler_digest_t
   *active_digests;  /* list of active digests */

} aw_logfilehandler_state_t;


typedef struct {

  aw_logfilehandler_events_t
    events;

  /* regex string */
  const byte_t
   *regex;

  /* holds substitution string, may be NULL */
  const byte_t
   *subst;

} aw_logfilehandler_regex_t;

typedef struct {

  aw_logfilehandler_events_t
    events;

  /* holds compiled regular expression  */
  regex_t
   pattern;

  /* holds substitution string, may be NULL */
  byte_t
   *subst;

} aw_logfilehandler_watcher_t;

typedef struct {

  aw_handler_t 
    handler_header;

  /* max size of text line */
  int32_t
   max_line_len;

  /* filename to watch (or name of Unix domain socket) */
  const char
   *filename;

  u_int32_t
   nwatchers;

  aw_logfilehandler_watcher_t
   *watchers;

  /* holds time interval for digest, if > 0 */
  aw_timestamp_t
   digest_interval;

  aw_logfilehandler_state_t
   state;

} aw_logfilehandler_t ;


aw_logfilehandler_t *aw_create_logfilehandler(const byte_t *filename,
                                              const u_int32_t nregexs,
                                              const aw_logfilehandler_regex_t *regexs,  
                                              const aw_timestamp_t digest_interval,
                                              int32_t (*regevent)(aw_handler_t *h, aw_address_t *eventid, u_int32_t index),
                                              int32_t (*regmaskevent)(aw_handler_t *h, aw_address_t *eventid, u_int32_t index),
                                              const aw_alarm_sched_t *sched,
                                              aw_logger_t *logger
                                          );

void aw_free_logfilehandler(aw_logfilehandler_t *p);

aw_handler_t *aw_wire_logfilehandler(aw_wire_mkhandler_args_t *args);

/*\@}*/

#endif

Aware 0.11.1 Copyright (C) 1998-2005 Russell Leighton (russ@elegant-software.com)