Branch Coverage

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


line true false branch
80 0 0 if ($self->{'_state'} != 0)
107 0 0 unless my $connection = $self->{'connection'}
114 0 0 unless my $self = $wself
115 0 0 if $self->{'_state'} == 1
121 0 0 if ($self->{'_state'} == 0)
158 0 0 if $self->{'_state'} == 0
175 0 0 if $@
197 0 0 if (my $connection = $self->{'connection'})
207 0 0 unless $self->_check_open($failure_cb)
234 0 0 unless $self->_check_open($failure_cb)
256 0 0 unless $self->_check_open($failure_cb)
278 0 0 unless $self->_check_open($failure_cb)
301 0 0 unless $self->_check_open($failure_cb)
327 0 0 unless $self->_check_open($failure_cb)
349 0 0 unless $self->_check_open($failure_cb)
370 0 0 unless $self->_check_open($failure_cb)
392 0 0 unless $self->_check_open($failure_cb)
417 0 0 unless ($self->{'_is_active'})
418 0 0 if (defined $args{'on_inactive'})
431 0 0 unless defined $header_args
432 0 0 unless defined $body
433 0 0 if (defined $ack_cb or defined $nack_cb or defined $return_cb)
435 0 0 unless $self->{'_is_confirm'}
439 0 0 if ($self->{'_is_confirm'})
442 0 0 if ($return_cb)
485 0 0 if not ref $v
486 0 0 if (@prot)
541 0 0 unless $self->_check_open($failure_cb)
577 0 0 unless $self->_check_open($failure_cb)
579 0 0 unless (defined $args{'consumer_tag'})
585 0 0 unless ($cons_cbs)
606 0 0 unless my $cons_cbs = delete $self->{'_consumer_cbs'}{$tag}
622 0 0 unless $self->_check_open($failure_cb)
634 0 0 if $frame->method_frame->isa('Net::AMQP::Protocol::Basic::GetEmpty')
649 0 0 unless $self->_check_open(sub { } )
660 0 0 defined $args{'delivery_tag'} && $args{'delivery_tag'} != 0 ? :
669 0 0 unless $self->_check_open($failure_cb)
692 0 0 unless $self->_check_open($failure_cb)
693 0 0 unless $self->_check_version(0, 9, $failure_cb)
705 0 0 unless my $me = $wself
720 0 0 unless $self->_check_open(sub { } )
730 0 0 if (not $args{'nowait'} and $self->_check_version(0, 9)) { }
749 0 0 unless $self->_check_open(sub { } )
767 0 0 unless $self->_check_open($failure_cb)
783 0 0 unless $self->_check_open($failure_cb)
799 0 0 unless $self->_check_open($failure_cb)
818 0 0 if ($frame->isa('Net::AMQP::Frame::Method')) { }
820 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')) { }
829 0 0 if ($method_frame->isa('Net::AMQP::Protocol::Channel::OpenOk') or $method_frame->isa('Net::AMQP::Protocol::Channel::CloseOk'))
843 0 0 if (not $self->_canceled($method_frame->consumer_tag, $frame) and $method_frame->isa('Net::AMQP::Protocol::Basic::CancelOk'))
852 0 0 unless my $me = $wself
855 0 0 if (defined(my $tag = $headers->{'_ar_return'}))
857 0 0 if $cbs
868 0 0 if (not $self->{'_is_confirm'}) { }
873 0 0 if ($method_frame->{'multiple'}) { }
881 0 0 $resp eq 'Ack' ? :
884 0 0 if (not $cbs = delete $self->{'_publish_cbs'}{$tag}) { }
0 0 elsif ($cbs->[$cbi]) { }
901 0 0 $self->{'_is_active'} ? :
926 0 0 unless $frame->isa('Net::AMQP::Frame::Body')
931 0 0 if (length $body_payload < $body_size) { }
933 0 0 unless my $contq = $wcontq
948 0 0 unless $frame->isa('Net::AMQP::Frame::Header')
952 0 0 unless $header_frame->isa('Net::AMQP::Protocol::Basic::ContentHeader')
960 0 0 if ($body_size) { }
961 0 0 unless my $contq = $wcontq
986 0 0 if $self->is_open
999 0 0 if $amaj >= $major or $amaj == $major and $amin >= $minor
1001 0 0 if $failure_cb
1007 0 0 if not &in_global_destruction() and $self->is_open