| line |
true |
false |
branch |
|
82
|
0 |
0 |
if ($self->{'_state'} != 0) |
|
109
|
0 |
0 |
unless my $connection = $self->{'connection'} |
|
116
|
0 |
0 |
unless my $self = $wself |
|
117
|
0 |
0 |
if $self->{'_state'} == 1 |
|
123
|
0 |
0 |
if ($self->{'_state'} == 0) |
|
160
|
0 |
0 |
if $self->{'_state'} == 0 |
|
177
|
0 |
0 |
if $@ |
|
199
|
0 |
0 |
if (my $connection = $self->{'connection'}) |
|
209
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
236
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
258
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
280
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
303
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
329
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
351
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
372
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
394
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
419
|
0 |
0 |
unless ($self->{'_is_active'}) |
|
420
|
0 |
0 |
if (defined $args{'on_inactive'}) |
|
433
|
0 |
0 |
unless defined $header_args |
|
434
|
0 |
0 |
unless defined $body |
|
435
|
0 |
0 |
if (defined $ack_cb or defined $nack_cb or defined $return_cb) |
|
437
|
0 |
0 |
unless $self->{'_is_confirm'} |
|
441
|
0 |
0 |
if ($self->{'_is_confirm'}) |
|
444
|
0 |
0 |
if ($return_cb) |
|
487
|
0 |
0 |
if not ref $v |
|
488
|
0 |
0 |
if (@prot) |
|
543
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
579
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
581
|
0 |
0 |
unless (defined $args{'consumer_tag'}) |
|
587
|
0 |
0 |
unless ($cons_cbs) |
|
608
|
0 |
0 |
unless my $cons_cbs = delete $self->{'_consumer_cbs'}{$tag} |
|
624
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
636
|
0 |
0 |
if $frame->method_frame->isa('Net::AMQP::Protocol::Basic::GetEmpty') |
|
651
|
0 |
0 |
unless $self->_check_open(sub {
}
) |
|
662
|
0 |
0 |
defined $args{'delivery_tag'} && $args{'delivery_tag'} != 0 ? : |
|
671
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
694
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
695
|
0 |
0 |
unless $self->_check_version(0, 9, $failure_cb) |
|
707
|
0 |
0 |
unless my $me = $wself |
|
722
|
0 |
0 |
unless $self->_check_open(sub {
}
) |
|
732
|
0 |
0 |
if (not $args{'nowait'} and $self->_check_version(0, 9)) { } |
|
751
|
0 |
0 |
unless $self->_check_open(sub {
}
) |
|
769
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
785
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
801
|
0 |
0 |
unless $self->_check_open($failure_cb) |
|
820
|
0 |
0 |
if ($frame->isa('Net::AMQP::Frame::Method')) { } |
|
822
|
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')) { } |
|
831
|
0 |
0 |
if ($method_frame->isa('Net::AMQP::Protocol::Channel::OpenOk') or $method_frame->isa('Net::AMQP::Protocol::Channel::CloseOk')) |
|
845
|
0 |
0 |
if (not $self->_canceled($method_frame->consumer_tag, $frame) and $method_frame->isa('Net::AMQP::Protocol::Basic::CancelOk')) |
|
854
|
0 |
0 |
unless my $me = $wself |
|
857
|
0 |
0 |
if (defined(my $tag = $headers->{'_ar_return'})) |
|
859
|
0 |
0 |
if $cbs |
|
870
|
0 |
0 |
if (not $self->{'_is_confirm'}) { } |
|
875
|
0 |
0 |
if ($method_frame->{'multiple'}) { } |
|
883
|
0 |
0 |
$resp eq 'Ack' ? : |
|
886
|
0 |
0 |
if (not $cbs = delete $self->{'_publish_cbs'}{$tag}) { } |
|
|
0 |
0 |
elsif ($cbs->[$cbi]) { } |
|
903
|
0 |
0 |
$self->{'_is_active'} ? : |
|
928
|
0 |
0 |
unless $frame->isa('Net::AMQP::Frame::Body') |
|
933
|
0 |
0 |
if (length $body_payload < $body_size) { } |
|
935
|
0 |
0 |
unless my $contq = $wcontq |
|
950
|
0 |
0 |
unless $frame->isa('Net::AMQP::Frame::Header') |
|
954
|
0 |
0 |
unless $header_frame->isa('Net::AMQP::Protocol::Basic::ContentHeader') |
|
962
|
0 |
0 |
if ($body_size) { } |
|
963
|
0 |
0 |
unless my $contq = $wcontq |
|
988
|
0 |
0 |
if $self->is_open |
|
1001
|
0 |
0 |
if $amaj >= $major or $amaj == $major and $amin >= $minor |
|
1003
|
0 |
0 |
if $failure_cb |
|
1009
|
0 |
0 |
if not &in_global_destruction() and $self->is_open |