| 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 |