| line |
!l |
l&&!r |
l&&r |
condition |
|
328
|
0 |
0 |
0 |
$result and $result eq "OK" |
|
337
|
0 |
0 |
0 |
$self->{'database'} and $self->{'database'} != 0 |
|
344
|
0 |
0 |
0 |
$result and $result eq "OK" |
|
378
|
0 |
0 |
0 |
$self->{'_subscription'} and not $self->{'_subscription'}->is_closed |
|
384
|
0 |
0 |
0 |
$self->{'_current_read_future'} and not $self->{'_current_read_future'}->is_ready |
|
392
|
0 |
0 |
0 |
$entry->{'future'} and not $entry->{'future'}->is_ready |
|
406
|
0 |
0 |
0 |
$was_connected and $self->{'on_disconnect'} |
|
411
|
0 |
0 |
0 |
$was_connected and $self->{'_telemetry'} |
|
423
|
84 |
0 |
0 |
$self->{'socket'} and fileno $self->{'socket'} |
|
441
|
0 |
0 |
0 |
$entry->{'future'} and not $entry->{'future'}->is_ready |
|
461
|
0 |
0 |
0 |
$self->{'_pid'} and $self->{'_pid'} != $$ |
|
529
|
0 |
0 |
0 |
$entry->{'future'} and not $entry->{'future'}->is_ready |
|
545
|
0 |
0 |
0 |
@{$self->{'inflight'};} and $self->{'connected'} |
|
828
|
0 |
0 |
0 |
defined $self->{'prefix'} and $self->{'prefix'} ne "" |
|
840
|
0 |
0 |
0 |
not $self->{'connected'} and $self->{'reconnect'} |
|
1002
|
1 |
0 |
0 |
$self->{'_current_read_future'} and not $self->{'_current_read_future'}->is_ready |
|
1010
|
0 |
0 |
0 |
$entry->{'future'} and not $entry->{'future'}->is_ready |
|
1026
|
0 |
1 |
0 |
$was_connected and $self->{'on_disconnect'} |
|
1194
|
0 |
0 |
0 |
defined $name and length $name |
|
1527
|
0 |
0 |
0 |
@{$self->{'inflight'};} and &Time::HiRes::time() < $deadline |
| line |
l |
!l |
condition |
|
165
|
80 |
0 |
$args{'host'} // "localhost" |
|
|
75 |
5 |
$args{'port'} // 6379 |
|
|
77 |
7 |
$args{'connect_timeout'} // 10 |
|
|
0 |
84 |
$args{'request_timeout'} // 5 |
|
|
0 |
84 |
$args{'blocking_timeout_buffer'} // 2 |
|
|
0 |
84 |
$args{'reconnect'} // 0 |
|
|
0 |
84 |
$args{'reconnect_delay'} // "0.1" |
|
|
0 |
84 |
$args{'reconnect_delay_max'} // 60 |
|
|
0 |
84 |
$args{'reconnect_jitter'} // "0.25" |
|
|
1 |
83 |
$args{'database'} // 0 |
|
|
0 |
84 |
$args{'pipeline_depth'} // 10000 |
|
|
0 |
84 |
$args{'auto_pipeline'} // 0 |
|
|
0 |
84 |
$args{'otel_include_args'} // 1 |
|
|
0 |
84 |
$args{'otel_redact'} // 1 |
|
178
|
0 |
0 |
$self->{'database'} // 0 |
|
256
|
76 |
1 |
$self->{'port'} // 0 |
|
371
|
0 |
0 |
$reason //= "client_disconnect" |
|
491
|
0 |
0 |
$arg //= "" |
|
621
|
0 |
0 |
$cmd // "" |
|
626
|
0 |
0 |
$args[-1] // 0 |
|
634
|
0 |
0 |
$args[$i + 1] // 0 |
|
819
|
0 |
0 |
$cmd // "" |
|
996
|
1 |
0 |
$reason //= "timeout" |
|
1208
|
0 |
0 |
$def->{'keys'} // "dynamic" |
|
1412
|
0 |
0 |
+(shift())->{'inflight'} // [] |
|
1421
|
0 |
0 |
$self->{'inflight'} // [] |
|
1521
|
0 |
0 |
$timeout //= 30 |
| line |
l |
!l&&r |
!l&&!r |
condition |
|
169
|
0 |
0 |
84 |
$self->{'debug'} or $self->{'otel_tracer'} |
|
|
0 |
0 |
84 |
$self->{'debug'} or $self->{'otel_tracer'} or $self->{'otel_meter'} |
|
256
|
1 |
76 |
0 |
$self->{'path'} // $self->{'host'} |
|
301
|
0 |
0 |
0 |
$self->{'path'} // "$self->{'host'}:$self->{'port'}" |
|
605
|
0 |
0 |
0 |
not defined $buf or length $buf == 0 |
|
978
|
0 |
0 |
0 |
not defined $buf or length $buf == 0 |
|
1558
|
0 |
0 |
0 |
$self->{'_subscription'} //= "Async::Redis::Subscription"->new("redis", $self) |
|
1586
|
0 |
0 |
0 |
$self->{'_subscription'} //= "Async::Redis::Subscription"->new("redis", $self) |
|
1611
|
0 |
0 |
0 |
$self->{'_subscription'} //= "Async::Redis::Subscription"->new("redis", $self) |
|
1665
|
0 |
0 |
0 |
$opts{'max_depth'} // $self->{'pipeline_depth'} |