| line |
!l |
l&&!r |
l&&r |
condition |
|
312
|
0 |
0 |
0 |
$result and $result eq "OK" |
|
321
|
0 |
0 |
0 |
$self->{'database'} and $self->{'database'} != 0 |
|
328
|
0 |
0 |
0 |
$result and $result eq "OK" |
|
361
|
0 |
0 |
0 |
$self->{'_current_read_future'} and not $self->{'_current_read_future'}->is_ready |
|
369
|
0 |
0 |
0 |
$entry->{'future'} and not $entry->{'future'}->is_ready |
|
383
|
0 |
0 |
0 |
$was_connected and $self->{'on_disconnect'} |
|
388
|
0 |
0 |
0 |
$was_connected and $self->{'_telemetry'} |
|
400
|
70 |
0 |
0 |
$self->{'socket'} and fileno $self->{'socket'} |
|
418
|
0 |
0 |
0 |
$entry->{'future'} and not $entry->{'future'}->is_ready |
|
438
|
0 |
0 |
0 |
$self->{'_pid'} and $self->{'_pid'} != $$ |
|
506
|
0 |
0 |
0 |
$entry->{'future'} and not $entry->{'future'}->is_ready |
|
522
|
0 |
0 |
0 |
@{$self->{'inflight'};} and $self->{'connected'} |
|
769
|
0 |
0 |
0 |
defined $self->{'prefix'} and $self->{'prefix'} ne "" |
|
781
|
0 |
0 |
0 |
not $self->{'connected'} and $self->{'reconnect'} |
|
943
|
0 |
0 |
0 |
$self->{'_current_read_future'} and not $self->{'_current_read_future'}->is_ready |
|
951
|
0 |
0 |
0 |
$entry->{'future'} and not $entry->{'future'}->is_ready |
|
966
|
0 |
0 |
0 |
$was_connected and $self->{'on_disconnect'} |
|
1134
|
0 |
0 |
0 |
defined $name and length $name |
|
1467
|
0 |
0 |
0 |
@{$self->{'inflight'};} and &Time::HiRes::time() < $deadline |
| line |
l |
!l |
condition |
|
163
|
70 |
0 |
$args{'host'} // "localhost" |
|
|
70 |
0 |
$args{'port'} // 6379 |
|
|
70 |
0 |
$args{'connect_timeout'} // 10 |
|
|
0 |
70 |
$args{'request_timeout'} // 5 |
|
|
0 |
70 |
$args{'blocking_timeout_buffer'} // 2 |
|
|
0 |
70 |
$args{'reconnect'} // 0 |
|
|
0 |
70 |
$args{'reconnect_delay'} // "0.1" |
|
|
0 |
70 |
$args{'reconnect_delay_max'} // 60 |
|
|
0 |
70 |
$args{'reconnect_jitter'} // "0.25" |
|
|
0 |
70 |
$args{'database'} // 0 |
|
|
0 |
70 |
$args{'pipeline_depth'} // 10000 |
|
|
0 |
70 |
$args{'auto_pipeline'} // 0 |
|
|
0 |
70 |
$args{'otel_include_args'} // 1 |
|
|
0 |
70 |
$args{'otel_redact'} // 1 |
|
176
|
0 |
0 |
$self->{'database'} // 0 |
|
355
|
0 |
0 |
$reason //= "client_disconnect" |
|
468
|
0 |
0 |
$arg //= "" |
|
598
|
0 |
0 |
$cmd // "" |
|
603
|
0 |
0 |
$args[-1] // 0 |
|
611
|
0 |
0 |
$args[$i + 1] // 0 |
|
760
|
0 |
0 |
$cmd // "" |
|
937
|
0 |
0 |
$reason //= "timeout" |
|
1148
|
0 |
0 |
$def->{'keys'} // "dynamic" |
|
1352
|
0 |
0 |
+(shift())->{'inflight'} // [] |
|
1361
|
0 |
0 |
$self->{'inflight'} // [] |
|
1461
|
0 |
0 |
$timeout //= 30 |
| line |
l |
!l&&r |
!l&&!r |
condition |
|
167
|
0 |
0 |
70 |
$self->{'debug'} or $self->{'otel_tracer'} |
|
|
0 |
0 |
70 |
$self->{'debug'} or $self->{'otel_tracer'} or $self->{'otel_meter'} |
|
582
|
0 |
0 |
0 |
not defined $buf or length $buf == 0 |
|
919
|
0 |
0 |
0 |
not defined $buf or length $buf == 0 |
|
1498
|
0 |
0 |
0 |
$self->{'_subscription'} //= "Async::Redis::Subscription"->new("redis", $self) |
|
1526
|
0 |
0 |
0 |
$self->{'_subscription'} //= "Async::Redis::Subscription"->new("redis", $self) |
|
1551
|
0 |
0 |
0 |
$self->{'_subscription'} //= "Async::Redis::Subscription"->new("redis", $self) |
|
1601
|
0 |
0 |
0 |
$opts{'max_depth'} // $self->{'pipeline_depth'} |