| 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'} |
|
174
|
0 |
0 |
$args{'tls'} ? : |
|
|
0 |
0 |
$args{'tls_ctx'} ? : |
|
194
|
0 |
0 |
unless defined $self->{'_handle'} |
|
198
|
0 |
0 |
unless my $self = $weak_self |
|
202
|
0 |
0 |
if (length $data <= 7) |
|
209
|
0 |
0 |
unless (defined $type_id and defined $channel and defined $length) |
|
216
|
0 |
0 |
unless my $self = $weak_self |
|
220
|
0 |
0 |
if $self->{'_heartbeat_timer'} |
|
222
|
0 |
0 |
if ($self->{'verbose'}) |
|
228
|
0 |
0 |
if (0 == $id) { } |
|
229
|
0 |
0 |
if ($frame->type_id == 8) { } |
|
233
|
0 |
0 |
unless $self->_check_close_and_clean($frame, $close_cb) |
|
238
|
0 |
0 |
if (defined $channel) { } |
|
257
|
0 |
0 |
$frame->isa('Net::AMQP::Frame::Method') ? : |
|
259
|
0 |
0 |
if ($self->{'_state'} == 0) |
|
263
|
0 |
0 |
if ($method_frame and $method_frame->isa('Net::AMQP::Protocol::Connection::Close')) |
|
279
|
0 |
0 |
ref $why ? : |
|
293
|
0 |
0 |
if ($self->{'verbose'}) |
|
306
|
0 |
0 |
if &none(sub {
$_ eq 'AMQPLAIN';
}
, @mechanisms) |
|
310
|
0 |
0 |
if &none(sub {
$_ eq 'en_US';
}
, @locales) |
|
325
|
0 |
0 |
unless $args{'client_properties'} |
|
352
|
0 |
0 |
unless my $self = $weak_self |
|
362
|
0 |
0 |
$server > $client ? : |
|
|
0 |
0 |
$client > $server ? : |
|
|
0 |
0 |
$server == 0 || $client == 0 ? : |
|
367
|
0 |
0 |
if ($self->{'_frame_max'} = $tune{'frame_max'}) |
|
378
|
0 |
0 |
if ($tune{'heartbeat'} > 0) |
|
399
|
0 |
0 |
unless my $self = $weak_self |
|
400
|
0 |
0 |
if ($self->{'_heartbeat_recv'} != $last_recv) { } |
|
|
0 |
0 |
elsif (++$idle_cycles > 1) { } |
|
446
|
0 |
0 |
if &in_global_destruction() |
|
450
|
0 |
0 |
if ($self->{'_state'} == 0) |
|
454
|
0 |
0 |
if ($self->{'_state'} != 2) |
|
455
|
0 |
0 |
$self->{'_state'} == 1 ? : |
|
470
|
0 |
0 |
if ($channel->is_open) |
|
488
|
0 |
0 |
if defined $_ |
|
|
0 |
0 |
if (my(@ch) = map({$_->id;} grep({$_->is_open if defined $_;} values %{$$self{'_channels'};}))) |
|
516
|
0 |
0 |
unless $self->_check_open($args{'on_failure'}) |
|
521
|
0 |
0 |
if ($id and $self->{'_channels'}{$id}) |
|
526
|
0 |
0 |
unless ($id) |
|
529
|
0 |
0 |
if ++$try_id > $self->{'_channel_max'} |
|
530
|
0 |
0 |
unless (defined $self->{'_channels'}{$try_id}) |
|
535
|
0 |
0 |
unless ($id) |
|
581
|
0 |
0 |
ref $exp eq 'ARRAY' ? : |
|
584
|
0 |
0 |
if (not $id) { } |
|
|
0 |
0 |
elsif (defined $self->{'_channels'}{$id}) { } |
|
592
|
0 |
0 |
unless $queue |
|
596
|
0 |
0 |
unless $frame->isa('Net::AMQP::Frame::Method') |
|
601
|
0 |
0 |
if $method_frame->isa('Net::AMQP::Protocol::' . $exp_elem) |
|
605
|
0 |
0 |
$method_frame->isa('Net::AMQP::Protocol::Channel::Close') ? : |
|
617
|
0 |
0 |
if ($output->isa('Net::AMQP::Protocol::Base')) |
|
622
|
0 |
0 |
if ($self->{'verbose'}) |
|
627
|
0 |
0 |
if $self->{'_handle'} |
|
636
|
0 |
0 |
unless &in_global_destruction() |
|
645
|
0 |
0 |
if $self->is_open |
|
654
|
0 |
0 |
if ($timeout) |
|
665
|
0 |
0 |
unless &in_global_destruction() |