lwes-perl-journal-listener

   1 #!/usr/bin/env perl
   2
   3 use strict;
   4 use warnings;
   5
   6 use Getopt::Long;
   7 use Pod::Usage;
   8 use LWES::EventParser;
   9 use LWES::Listener;
  10 use POSIX qw(strftime);
  11
  12 my $help_opt         = 0;
  13 my $man_opt          = 0;
  14 my $verbose_opt      = 0;
  15 my $stats_opt        = 0;
  16
  17 GetOptions
  18   (
  19     'help'           => \$help_opt,
  20     'man'            => \$man_opt,
  21     'stats'          => \$stats_opt,
  22     'verbose'        => \$verbose_opt,
  23   ) or pod2usage (2);
  24
  25 pod2usage (-exitval => -1, -verbose => 0) if $help_opt;
  26 pod2usage (-exitval => -2, -verbose => 2) if $man_opt;
  27
  28 my $listener_or_code;
  29
  30 # if the first argument is a file, we'll assume it s a journal file, and
  31 # use the PrintingListener
  32 if (-f $ARGV[0])
  33   {
  34     $listener_or_code = "LWES::Listeners::EventPrintingListener";
  35   }
  36 else
  37   {
  38     $listener_or_code = shift @ARGV;
  39   }
  40
  41 # determine the callback which will process each event
  42 my $processEventFunc = getProcessEventFunc ($listener_or_code, @ARGV);
  43
  44 foreach my $journal (@ARGV)
  45   {
  46     my $start      = time();
  47     my $log_date   = strftime ("%a %b %e %H:%M:%S %Y", localtime ($start));
  48     my $num_events = 0;
  49
  50     if ($stats_opt)
  51       {
  52         print "$log_date : $journal ";
  53       }
  54
  55     if (-f $journal)
  56       {
  57         open FH, "zcat $journal |";
  58
  59         # read and parse header
  60         my $header_bytes;
  61         while ( read (FH, $header_bytes, 22) == 22)
  62           {
  63             my $header = bytesToHeader ($header_bytes);
  64
  65             # read and parse bytes
  66             my $event_bytes;
  67             my $n = read (FH, $event_bytes, $header->{'PayloadLength'});
  68             if (defined ($n) && $n == $header->{'PayloadLength'})
  69               {
  70                 my $event = bytesToEvent ($event_bytes);
  71
  72                 # merge header into event
  73                 foreach my $h (keys %{$header})
  74                   {
  75                     unless (exists ($event->{$h}))
  76                       {
  77                         $event->{$h} = $header->{$h};
  78                       }
  79                   }
  80
  81                 # call handler
  82                 $processEventFunc->($event);
  83                 $num_events++;
  84               }
  85             else
  86               {
  87                 die "malformed or truncated journal";
  88               }
  89           }
  90
  91         close FH;
  92       }
  93
  94     if ($stats_opt)
  95       {
  96         my $end = time()-$start;
  97         print "had $num_events events processed in $end seconds\n";
  98       }
  99   }
 100
 101 0;