File Coverage

blib/lib/Spread/Messaging/Content.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 Spread::Messaging::Content;

use 5.008;
use strict;
use warnings;

require Exporter;

use Spread::Messaging::Transport;
use Spread::Messaging::Exception;

our @ISA = qw(Exporter Spread::Messaging::Transport);

our @EXPORT = qw(
 UNRELIABLE_MESS
 RELIABLE_MESS
 FIFO_MESS
 CAUSAL_MESS
 AGREED_MESS
 SAFE_MESS
);

our $VERSION = '0.01';

# ------------------------------------------------------------------------
# Public methods
# ------------------------------------------------------------------------

sub new {
    my $class = shift;
    my $self = $class->SUPER::new(@_);

    $self->{message_type} = undef;
    $self->{sender} = undef;
    $self->{group} = undef;
    $self->{type} = 0;
    $self->{endian} = undef;
    $self->{message} = undef;

    return($self);

}

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

    return($self->message_type & UNRELIABLE_MESS);

}

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

    return($self->message_type & RELIABLE_MESS);

}

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

    return($self->message_type & FIFO_MESS);

}

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

    return($self->message_type & CAUSAL_MESS);

}

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

    return($self->message_type & AGREED_MESS);

}

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

    return($self->message_type & REGULAR_MESS);

}

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

    return ((index(@{$self->group}[0], '#') == 0) &&
            (index(@{$self->group}[0], '#', 1)));

}

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

    return($self->message_type & SELF_DISCARD);

}

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

    return($self->message_type & REG_MEMB_MESS);

}

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

    return($self->message_type & TRANSITION_MESS);

}

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

    return($self->message_type & SAFE_MESS);

}

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

    return($self->message_type & CAUSED_BY_JOIN);

}

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

    return($self->message_type & CAUSED_BY_LEAVE);

}

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

    return($self->message_type & CAUSED_BY_DISCONNECT);

}

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

    return($self->message_type & CAUSED_BY_NETWORK);

}

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

    return($self->message_type & MEMBERSHIP_MESS);

}

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

    return(($self->message_type & CAUSED_BY_LEAVE) &&
           !($self->message_type & (REG_MEMB_MESS | TRANSITION_MESS)));

}

sub group {
    my ($self, $p) = @_;

    $self->{group} = $p if defined $p;
    return($self->{group});

}

sub type {
    my ($self, $p) = @_;

    $self->{type} = $p if defined $p;
    return($self->{type});

}

sub message {
    my ($self, $p) = @_;

    $self->{message} = $p if defined $p;
    return($self->{message});

}

sub message_type {
    my ($self, $p) = @_;

    $self->{message_type} = $p if defined $p;
    return($self->{message_type});

}

sub endian {
    my ($self, $p) = @_;

    $self->{endian} = $p if defined $p;
    return($self->{endian});

}

sub sender {
    my ($self, $p) = @_;

    $self->{sender} = $p if defined $p;
    return($self->{sender});

}

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

    $self->SUPER::send($self->group, $self->message, $self->type);

}

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

    my ($message_type, $sender, $group,
        $type, $endian, $message) = $self->SUPER::recv($self);

    $self->message_type($message_type);
    $self->sender($sender);
    $self->group($group);
    $self->type($type);
    $self->endian($endian);
    $self->message($message);

}

1;

__END__