File Coverage

blib/lib/Log/Dispatch/Spread.pm

Criterion	Covered	Total	%
statement	19	21	90.4
branch			n/a
condition			n/a
subroutine	7	7	100.0
pod			n/a
total	26	28	92.8

package Log::Dispatch::Spread;

use strict;

use Log::Dispatch::Output;
use base qw( Log::Dispatch::Output );

use 5.008000;
use warnings;
no warnings 'uninitialized';
use Spread qw( :SP :ERROR :MESS );
use Carp;
use Params::Validate qw( :all );
use Sys::Hostname qw( hostname );

our $VERSION     = '0.9';

use constant SPREAD_PRIV  => 'jc-' . hostname();
use constant LOG_MSG_TYPE => 11;

1;

sub new {
  my $proto = shift;
  my $class = ref $proto || $proto;
  my $self = bless {}, $class;

  my %p = @_;

  validate( @_, {
            name      => { type => SCALAR },
            min_level => { type => SCALAR, default => 'DEBUG' },
            max_level => { type => SCALAR, default => 'FATAL' },
            channels  => { type => ARRAYREF },
            server    => { type => SCALAR },
          } );

  $self->_basic_init(%p);

  ($self->{'mbox'}, $self->{'private_group'} ) = Spread::connect( {
                          spread_name => $p{'server'},
                          private_name => SPREAD_PRIV,
                          group_membership => 0,
                        } );


  if ( $sperrno ) {
    croak "Could not join spread cluster. Error was: " . $sperrno;
  }

  $self->{'joined'} = ();
  ( $self->{'joined'} ) = grep Spread::join($self->{'mbox'}, $_), $p{'channels'};

  # What you need to do here is see if two arrays aer equal
  unless ( $self->{'joined'} ) {
    croak "Could not join spread cluster. Error was: " . $sperrno;
  }

  return $self;

}

sub log_message {
  my $self = shift;
  my %p = @_;
  Spread::multicast( $self->{'mbox'},
                     SAFE_MESS,
                     @{$self->{'joined'}},
                     LOG_MSG_TYPE,
                     $p{message},
                   );

  if ( $sperrno ) {
    carp "Could not send a log message! Error was: " . $sperrno;
    return undef;
  }

  return $self;
}

__END__