File Coverage

blib/lib/Log/Log4perl/Appender/Spread.pm

Criterion	Covered	Total	%
statement	10	12	83.3
branch			n/a
condition			n/a
subroutine	4	4	100.0
pod			n/a
total	14	16	87.5

package Log::Log4perl::Appender::Spread;

use warnings;
use strict;

use vars qw($VERSION);
$VERSION = 0.03;

use Spread 3.17;

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

    my $self = {
        @options
    };

    # set parameters
    $self->{SpreadGroup} = $self->{SpreadGroup} || 'LOG';
    if ( !defined( $self->{SpreadMailbox} ) ) {
      # not called with an existing spread mailbox, so we need to join spread
      $self->{SpreadName} = $self->{SpreadName} || '4803';
      $self->{SpreadPrivateName} = $self->{SpreadPrivateName} || 'log';
    }

    bless $self, $class;

    $self->spread_join();

    return $self;
}

sub spread_join {
    my($self) = @_;

    if ( !defined( $self->{SpreadMailbox} ) ) {
      # join spread, or die.
      ($self->{mailbox}, $self->{private_group}) =
	Spread::connect( {
			  spread_name => $self->{SpreadName},
			  private_name => $self->{SpreadPrivateName}
			 } );
      die("$sperrno") if ($sperrno);
    }
    else {
      $self->{mailbox} = $self->{SpreadMailbox};
    }
    # now that connecting is done, join the logging group.
    die("Unable to join the spread group, $self->{SpreadGroup}")
      unless grep( Spread::join($self->{mailbox}, $_), $self->{SpreadGroup} );
}

sub spread_leave {
    my($self) = @_;

    if ( !$sperrno && defined($self->{mailbox}) ) {
        # the mailbox could be dead allready - so ignore errors, they dont make much sense anymore anyway
        Spread::leave($self->{mailbox}, $self->{SpreadGroup});

        if ( !defined($self->{SpreadMailbox}) ) {
            # dont disconnect unless you connected.
            Spread::disconnect($self->{mailbox});
        }
    }
}


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

    # Send the message to the group joined.
    return Spread::multicast($self->{mailbox}, SAFE_MESS, $self->{SpreadGroup}, $params{level}, $params{message});
}

sub DESTROY {
    my($self) = @_;

    $self->spread_leave();
}

1;

__END__