| line |
true |
false |
branch |
|
69
|
0 |
0 |
@_ ? : |
|
85
|
0 |
0 |
if (defined $c and &refaddr($c) == &refaddr($channel)) |
|
102
|
0 |
0 |
if ($_loaded_spec and $_loaded_spec ne $spec) { } |
|
|
0 |
0 |
elsif (not $_loaded_spec) { } |
|
115
|
0 |
0 |
if ($self->{'_state'} != 0) |
|
125
|
0 |
0 |
unless $args{$_} |
|
128
|
0 |
0 |
if ($self->{'verbose'}) |
|
140
|
0 |
0 |
unless my $self = $weak_self |
|
144
|
0 |
0 |
unless ($fh) |
|
157
|
0 |
0 |
unless my $self = $weak_self |
|
159
|
0 |
0 |
if ($self->is_open) { } |
|
168
|
0 |
0 |
unless my $self = $weak_self |
|
171
|
0 |
0 |
if exists $self->{'drain_condvar'} |
|
176
|
0 |
0 |
$args{'tls'} ? : |
|
|
0 |
0 |
$args{'tls_ctx'} ? : |
|
|
0 |
0 |
$args{'nodelay'} ? : |
|
196
|
0 |
0 |
unless defined $self->{'_handle'} |
|
200
|
0 |
0 |
unless my $self = $weak_self |
|
204
|
0 |
0 |
if (length $data <= 7) |
|
211
|
0 |
0 |
unless (defined $type_id and defined $channel and defined $length) |
|
218
|
0 |
0 |
unless my $self = $weak_self |
|
222
|
0 |
0 |
if $self->{'_heartbeat_timer'} |
|
224
|
0 |
0 |
if ($self->{'verbose'}) |
|
230
|
0 |
0 |
if (0 == $id) { } |
|
231
|
0 |
0 |
if ($frame->type_id == 8) { } |
|
235
|
0 |
0 |
unless $self->_check_close_and_clean($frame, $close_cb) |
|
240
|
0 |
0 |
if (defined $channel) { } |
|
259
|
0 |
0 |
$frame->isa('Net::AMQP::Frame::Method') ? : |
|
261
|
0 |
0 |
if ($self->{'_state'} == 0) |
|
265
|
0 |
0 |
if ($method_frame and $method_frame->isa('Net::AMQP::Protocol::Connection::Close')) |
|
281
|
0 |
0 |
ref $why ? : |
|
295
|
0 |
0 |
if ($self->{'verbose'}) |
|
308
|
0 |
0 |
if &none(sub {
$_ eq 'AMQPLAIN';
}
, @mechanisms) |
|
312
|
0 |
0 |
if &none(sub {
$_ eq 'en_US';
}
, @locales) |
|
327
|
0 |
0 |
unless $args{'client_properties'} |
|
354
|
0 |
0 |
unless my $self = $weak_self |
|
364
|
0 |
0 |
$server > $client ? : |
|
|
0 |
0 |
$client > $server ? : |
|
|
0 |
0 |
$server == 0 || $client == 0 ? : |
|
369
|
0 |
0 |
if ($self->{'_frame_max'} = $tune{'frame_max'}) |
|
380
|
0 |
0 |
if ($tune{'heartbeat'} > 0) |
|
401
|
0 |
0 |
unless my $self = $weak_self |
|
402
|
0 |
0 |
if ($self->{'_heartbeat_recv'} != $last_recv) { } |
|
|
0 |
0 |
elsif (++$idle_cycles > 1) { } |
|
448
|
0 |
0 |
if &in_global_destruction() |
|
452
|
0 |
0 |
if ($self->{'_state'} == 0) |
|
456
|
0 |
0 |
if ($self->{'_state'} != 2) |
|
457
|
0 |
0 |
$self->{'_state'} == 1 ? : |
|
472
|
0 |
0 |
if ($channel->is_open) |
|
490
|
0 |
0 |
if defined $_ |
|
|
0 |
0 |
if (my(@ch) = map({$_->id;} grep({$_->is_open if defined $_;} values %{$$self{'_channels'};}))) |
|
518
|
0 |
0 |
unless $self->_check_open($args{'on_failure'}) |
|
523
|
0 |
0 |
if ($id and $self->{'_channels'}{$id}) |
|
528
|
0 |
0 |
unless ($id) |
|
531
|
0 |
0 |
if ++$try_id > $self->{'_channel_max'} |
|
532
|
0 |
0 |
unless (defined $self->{'_channels'}{$try_id}) |
|
537
|
0 |
0 |
unless ($id) |
|
583
|
0 |
0 |
ref $exp eq 'ARRAY' ? : |
|
586
|
0 |
0 |
if (not $id) { } |
|
|
0 |
0 |
elsif (defined $self->{'_channels'}{$id}) { } |
|
594
|
0 |
0 |
unless $queue |
|
598
|
0 |
0 |
unless $frame->isa('Net::AMQP::Frame::Method') |
|
603
|
0 |
0 |
if $method_frame->isa('Net::AMQP::Protocol::' . $exp_elem) |
|
607
|
0 |
0 |
$method_frame->isa('Net::AMQP::Protocol::Channel::Close') ? : |
|
619
|
0 |
0 |
if ($output->isa('Net::AMQP::Protocol::Base')) |
|
624
|
0 |
0 |
if ($self->{'verbose'}) |
|
629
|
0 |
0 |
if $self->{'_handle'} |
|
638
|
0 |
0 |
unless &in_global_destruction() |
|
647
|
0 |
0 |
if $self->is_open |
|
656
|
0 |
0 |
if ($timeout) |
|
667
|
0 |
0 |
unless &in_global_destruction() |