| line |
true |
false |
branch |
|
70
|
0 |
0 |
@_ ? : |
|
86
|
0 |
0 |
if (defined $c and &refaddr($c) == &refaddr($channel)) |
|
103
|
0 |
0 |
if ($_loaded_spec and $_loaded_spec ne $spec) { } |
|
|
0 |
0 |
elsif (not $_loaded_spec) { } |
|
116
|
0 |
0 |
if ($self->{'_state'} != 0) |
|
126
|
0 |
0 |
unless $args{$_} |
|
129
|
0 |
0 |
if ($self->{'verbose'}) |
|
141
|
0 |
0 |
unless my $self = $weak_self |
|
145
|
0 |
0 |
unless ($fh) |
|
158
|
0 |
0 |
unless my $self = $weak_self |
|
160
|
0 |
0 |
if ($self->is_open) { } |
|
169
|
0 |
0 |
unless my $self = $weak_self |
|
172
|
0 |
0 |
if exists $self->{'drain_condvar'} |
|
177
|
0 |
0 |
$args{'tls'} ? : |
|
|
0 |
0 |
$args{'tls_ctx'} ? : |
|
|
0 |
0 |
$args{'nodelay'} ? : |
|
197
|
0 |
0 |
unless defined $self->{'_handle'} |
|
201
|
0 |
0 |
unless my $self = $weak_self |
|
205
|
0 |
0 |
if (length $data <= 7) |
|
212
|
0 |
0 |
unless (defined $type_id and defined $channel and defined $length) |
|
219
|
0 |
0 |
unless my $self = $weak_self |
|
223
|
0 |
0 |
if $self->{'_heartbeat_timer'} |
|
225
|
0 |
0 |
if ($self->{'verbose'}) |
|
231
|
0 |
0 |
if (0 == $id) { } |
|
232
|
0 |
0 |
if ($frame->type_id == 8) { } |
|
236
|
0 |
0 |
unless $self->_check_close_and_clean($frame, $close_cb) |
|
241
|
0 |
0 |
if (defined $channel) { } |
|
260
|
0 |
0 |
$frame->isa('Net::AMQP::Frame::Method') ? : |
|
262
|
0 |
0 |
if ($self->{'_state'} == 0) |
|
266
|
0 |
0 |
if ($method_frame and $method_frame->isa('Net::AMQP::Protocol::Connection::Close')) |
|
282
|
0 |
0 |
ref $why ? : |
|
296
|
0 |
0 |
if ($self->{'verbose'}) |
|
309
|
0 |
0 |
if &none(sub {
$_ eq 'AMQPLAIN';
}
, @mechanisms) |
|
313
|
0 |
0 |
if &none(sub {
$_ eq 'en_US';
}
, @locales) |
|
328
|
0 |
0 |
unless $args{'client_properties'} |
|
355
|
0 |
0 |
unless my $self = $weak_self |
|
365
|
0 |
0 |
$server > $client ? : |
|
|
0 |
0 |
$client > $server ? : |
|
|
0 |
0 |
$server == 0 || $client == 0 ? : |
|
370
|
0 |
0 |
if ($self->{'_frame_max'} = $tune{'frame_max'}) |
|
381
|
0 |
0 |
if ($tune{'heartbeat'} > 0) |
|
402
|
0 |
0 |
unless my $self = $weak_self |
|
403
|
0 |
0 |
if ($self->{'_heartbeat_recv'} != $last_recv) { } |
|
|
0 |
0 |
elsif (++$idle_cycles > 1) { } |
|
449
|
0 |
0 |
if &in_global_destruction() |
|
453
|
0 |
0 |
if ($self->{'_state'} == 0) |
|
457
|
0 |
0 |
if ($self->{'_state'} != 2) |
|
458
|
0 |
0 |
$self->{'_state'} == 1 ? : |
|
473
|
0 |
0 |
if ($channel->is_open) |
|
491
|
0 |
0 |
if defined $_ |
|
|
0 |
0 |
if (my(@ch) = map({$_->id;} grep({$_->is_open if defined $_;} values %{$$self{'_channels'};}))) |
|
519
|
0 |
0 |
unless $self->_check_open($args{'on_failure'}) |
|
524
|
0 |
0 |
if ($id and $self->{'_channels'}{$id}) |
|
529
|
0 |
0 |
unless ($id) |
|
532
|
0 |
0 |
if ++$try_id > $self->{'_channel_max'} |
|
533
|
0 |
0 |
unless (defined $self->{'_channels'}{$try_id}) |
|
538
|
0 |
0 |
unless ($id) |
|
584
|
0 |
0 |
ref $exp eq 'ARRAY' ? : |
|
587
|
0 |
0 |
if (not $id) { } |
|
|
0 |
0 |
elsif (defined $self->{'_channels'}{$id}) { } |
|
595
|
0 |
0 |
unless $queue |
|
599
|
0 |
0 |
unless $frame->isa('Net::AMQP::Frame::Method') |
|
604
|
0 |
0 |
if $method_frame->isa('Net::AMQP::Protocol::' . $exp_elem) |
|
608
|
0 |
0 |
$method_frame->isa('Net::AMQP::Protocol::Channel::Close') ? : |
|
620
|
0 |
0 |
if ($output->isa('Net::AMQP::Protocol::Base')) |
|
625
|
0 |
0 |
if ($self->{'verbose'}) |
|
630
|
0 |
0 |
if $self->{'_handle'} |
|
639
|
0 |
0 |
unless &in_global_destruction() |
|
648
|
0 |
0 |
if $self->is_open |
|
657
|
0 |
0 |
if ($timeout) |
|
668
|
0 |
0 |
unless &in_global_destruction() |