File Coverage

blib/lib/Armadito/Agent/Logger/File.pm

Criterion	Covered	Total	%
statement	18	44	40.9
branch	0	14	0.0
condition	0	9	0.0
subroutine	6	8	75.0
pod	2	2	100.0
total	26	77	33.7

package Armadito::Agent::Logger::File;

use strict;
use warnings;
use base 'Armadito::Agent::Logger::Backend';

use English qw(-no_match_vars);
use Fcntl qw(:flock);
use File::stat;

sub new {
	my ( $class, %params ) = @_;

	my $self = {
		logfile         => $params{config}->{logfile},
		logfile_maxsize => $params{config}->{'logfile-maxsize'}
		? $params{config}->{'logfile-maxsize'} * 1024 * 1024
		: 0
	};
	bless $self, $class;

	return $self;
}

sub addMessage {
	my ( $self, %params ) = @_;

	my $level   = $params{level};
	my $message = $params{message};

	my $handle;
	if ( $self->{logfile_maxsize} ) {
		my $stat = stat( $self->{logfile} );
		if ( $stat && $stat->size() > $self->{logfile_maxsize} ) {
			if ( !open $handle, '>', $self->{logfile} ) {
				warn "Can't open $self->{logfile}: $ERRNO";
				return;
			}
		}
	}

	if ( !$handle && !open $handle, '>>', $self->{logfile} ) {
		warn "can't open $self->{logfile}: $ERRNO";
		return;
	}

	my $locked;
	my $retryTill = time + 60;

	while ( $retryTill > time && !$locked ) {
		## no critic (ProhibitBitwise)
		# get an exclusive lock on log file
		$locked = 1 if flock( $handle, LOCK_EX | LOCK_NB );
	}

	if ( !$locked ) {
		die "can't get an exclusive lock on $self->{logfile}: $ERRNO";
	}

	print {$handle} "[" . localtime() . "]" . "[$level]" . " $message\n";

	# closing handle release the lock automatically
	close $handle;

}

1;
__END__

=head1 NAME

Armadito::Agent::Logger::File - A file backend for the logger

=head1 DESCRIPTION

This is a file-based backend for the logger. It supports automatic filesize
limitation.