# Initialize the event handler.
my $events = Guardian::Events->Init(%mainsettings);
-# Shared hash between the main process and all threads. It will store all
+# Hash to store the currently monitored files and their configured
+# parsers.
+my %monitored_files = ();
+
+# Shared hash between the main process and all threads. It will store the
# monitored files and their current file position.
-my %monitored_files :shared = ();
+my %file_positions :shared = ();
# Create the main queue. It is used to store and process all events which are
# reported and enqueued by the worker threads.
sub Worker ($) {
my $file = $_[0];
+ # Obtain the parser name which should be used to parser any
+ # messages of this file.
+ my $parser = $monitored_files{$file};
+
# Signal handler to kill worker.
$SIG{'KILL'} = sub { threads->exit(); };
my @message = ();
# Obtain fileposition from hash.
- my $fileposition = $monitored_files{$file};
+ my $fileposition = $file_positions{$file};
# Open the file.
open (FILE, $file) or die "Could not open $file. $!";
{
# Lock shared hash.
- lock(%monitored_files);
+ lock(%file_positions);
# Update fileposition.
- $monitored_files{$file} = tell(FILE);
+ $file_positions{$file} = tell(FILE);
}
# Close file.
# Send filename and message to the parser,
# which will return if an action has to be performed.
- my @action = &Guardian::Parser::Parser("$file", @message);
+ my @action = &Guardian::Parser::Parser("$parser", @message);
# Send the action to the main process and put it into
# the queue.
## be added to the array of running workers.
#
sub StartWorkers () {
+ # Init/Update hash which contains the cursor position of EOF.
+ %file_positions = &Guardian::Base::FilePositions(\%monitored_files, \%file_positions);
+
# Loop through the hash which contains the monitored files and start
# a worker thread for each single one.
foreach my $file (keys %monitored_files) {