Branch Coverage

blib/lib/AnyEvent/RabbitMQ/Channel.pm
Criterion Covered Total %
branch 0 152 0.0


line true false branch
83 0 0 if ($self->{'_state'} != 0)
110 0 0 unless my $connection = $self->{'connection'}
117 0 0 unless my $self = $wself
118 0 0 if $self->{'_state'} == 1
124 0 0 if ($self->{'_state'} == 0)
161 0 0 if $self->{'_state'} == 0
178 0 0 if $@
200 0 0 if (my $connection = $self->{'connection'})
210 0 0 unless $self->_check_open($failure_cb)
237 0 0 unless $self->_check_open($failure_cb)
259 0 0 unless $self->_check_open($failure_cb)
281 0 0 unless $self->_check_open($failure_cb)
304 0 0 unless $self->_check_open($failure_cb)
330 0 0 unless $self->_check_open($failure_cb)
352 0 0 unless $self->_check_open($failure_cb)
373 0 0 unless $self->_check_open($failure_cb)
395 0 0 unless $self->_check_open($failure_cb)
420 0 0 unless ($self->{'_is_active'})
421 0 0 if (defined $args{'on_inactive'})
434 0 0 unless defined $header_args
435 0 0 unless defined $body
436 0 0 if (defined $ack_cb or defined $nack_cb or defined $return_cb)
438 0 0 unless $self->{'_is_confirm'}
442 0 0 if ($self->{'_is_confirm'})
445 0 0 if ($return_cb)
488 0 0 if not ref $v
489 0 0 if (@prot)
544 0 0 unless $self->_check_open($failure_cb)
580 0 0 unless $self->_check_open($failure_cb)
582 0 0 unless (defined $args{'consumer_tag'})
588 0 0 unless ($cons_cbs)
609 0 0 unless my $cons_cbs = delete $self->{'_consumer_cbs'}{$tag}
625 0 0 unless $self->_check_open($failure_cb)
637 0 0 if $frame->method_frame->isa('Net::AMQP::Protocol::Basic::GetEmpty')
652 0 0 unless $self->_check_open(sub { } )
663 0 0 defined $args{'delivery_tag'} && $args{'delivery_tag'} != 0 ? :
672 0 0 unless $self->_check_open($failure_cb)
695 0 0 unless $self->_check_open($failure_cb)
696 0 0 unless $self->_check_version(0, 9, $failure_cb)
708 0 0 unless my $me = $wself
723 0 0 unless $self->_check_open(sub { } )
733 0 0 if (not $args{'nowait'} and $self->_check_version(0, 9)) { }
752 0 0 unless $self->_check_open(sub { } )
770 0 0 unless $self->_check_open($failure_cb)
786 0 0 unless $self->_check_open($failure_cb)
802 0 0 unless $self->_check_open($failure_cb)
821 0 0 if ($frame->isa('Net::AMQP::Frame::Method')) { }
823 0 0 if ($method_frame->isa('Net::AMQP::Protocol::Channel::Close')) { }
0 0 elsif ($self->{'_state'} != 2) { }
0 0 elsif ($method_frame->isa('Net::AMQP::Protocol::Basic::Deliver')) { }
0 0 elsif ($method_frame->isa('Net::AMQP::Protocol::Basic::CancelOk') or $method_frame->isa('Net::AMQP::Protocol::Basic::Cancel')) { }
0 0 elsif ($method_frame->isa('Net::AMQP::Protocol::Basic::Return')) { }
0 0 elsif ($method_frame->isa('Net::AMQP::Protocol::Basic::Ack') or $method_frame->isa('Net::AMQP::Protocol::Basic::Nack')) { }
0 0 elsif ($method_frame->isa('Net::AMQP::Protocol::Channel::Flow')) { }
832 0 0 if ($method_frame->isa('Net::AMQP::Protocol::Channel::OpenOk') or $method_frame->isa('Net::AMQP::Protocol::Channel::CloseOk'))
846 0 0 if (not $self->_canceled($method_frame->consumer_tag, $frame) and $method_frame->isa('Net::AMQP::Protocol::Basic::CancelOk'))
855 0 0 unless my $me = $wself
858 0 0 if (defined(my $tag = $headers->{'_ar_return'}))
860 0 0 if $cbs
871 0 0 if (not $self->{'_is_confirm'}) { }
876 0 0 if ($method_frame->{'multiple'}) { }
884 0 0 $resp eq 'Ack' ? :
887 0 0 if (not $cbs = delete $self->{'_publish_cbs'}{$tag}) { }
0 0 elsif ($cbs->[$cbi]) { }
904 0 0 $self->{'_is_active'} ? :
929 0 0 unless $frame->isa('Net::AMQP::Frame::Body')
934 0 0 if (length $body_payload < $body_size) { }
936 0 0 unless my $contq = $wcontq
951 0 0 unless $frame->isa('Net::AMQP::Frame::Header')
955 0 0 unless $header_frame->isa('Net::AMQP::Protocol::Basic::ContentHeader')
963 0 0 if ($body_size) { }
964 0 0 unless my $contq = $wcontq
989 0 0 if $self->is_open
1002 0 0 if $amaj >= $major or $amaj == $major and $amin >= $minor
1004 0 0 if $failure_cb
1010 0 0 if not &in_global_destruction() and $self->is_open