| 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" |
|
377
|
0 |
0 |
0 |
$self->{'_current_read_future'} and not $self->{'_current_read_future'}->is_ready |
|
385
|
0 |
0 |
0 |
$entry->{'future'} and not $entry->{'future'}->is_ready |
|
399
|
0 |
0 |
0 |
$was_connected and $self->{'on_disconnect'} |
|
404
|
0 |
0 |
0 |
$was_connected and $self->{'_telemetry'} |
|
416
|
81 |
0 |
0 |
$self->{'socket'} and fileno $self->{'socket'} |
|
434
|
0 |
0 |
0 |
$entry->{'future'} and not $entry->{'future'}->is_ready |
|
454
|
0 |
0 |
0 |
$self->{'_pid'} and $self->{'_pid'} != $$ |
|
522
|
0 |
0 |
0 |
$entry->{'future'} and not $entry->{'future'}->is_ready |
|
538
|
0 |
0 |
0 |
@{$self->{'inflight'};} and $self->{'connected'} |
|
821
|
0 |
0 |
0 |
defined $self->{'prefix'} and $self->{'prefix'} ne "" |
|
833
|
0 |
0 |
0 |
not $self->{'connected'} and $self->{'reconnect'} |
|
995
|
1 |
0 |
0 |
$self->{'_current_read_future'} and not $self->{'_current_read_future'}->is_ready |
|
1003
|
0 |
0 |
0 |
$entry->{'future'} and not $entry->{'future'}->is_ready |
|
1019
|
0 |
1 |
0 |
$was_connected and $self->{'on_disconnect'} |
|
1187
|
0 |
0 |
0 |
defined $name and length $name |
|
1520
|
0 |
0 |
0 |
@{$self->{'inflight'};} and &Time::HiRes::time() < $deadline |
| line |
l |
!l |
condition |
|
165
|
77 |
0 |
$args{'host'} // "localhost" |
|
|
73 |
4 |
$args{'port'} // 6379 |
|
|
75 |
6 |
$args{'connect_timeout'} // 10 |
|
|
0 |
81 |
$args{'request_timeout'} // 5 |
|
|
0 |
81 |
$args{'blocking_timeout_buffer'} // 2 |
|
|
0 |
81 |
$args{'reconnect'} // 0 |
|
|
0 |
81 |
$args{'reconnect_delay'} // "0.1" |
|
|
0 |
81 |
$args{'reconnect_delay_max'} // 60 |
|
|
0 |
81 |
$args{'reconnect_jitter'} // "0.25" |
|
|
1 |
80 |
$args{'database'} // 0 |
|
|
0 |
81 |
$args{'pipeline_depth'} // 10000 |
|
|
0 |
81 |
$args{'auto_pipeline'} // 0 |
|
|
0 |
81 |
$args{'otel_include_args'} // 1 |
|
|
0 |
81 |
$args{'otel_redact'} // 1 |
|
178
|
0 |
0 |
$self->{'database'} // 0 |
|
256
|
74 |
1 |
$self->{'port'} // 0 |
|
371
|
0 |
0 |
$reason //= "client_disconnect" |
|
484
|
0 |
0 |
$arg //= "" |
|
614
|
0 |
0 |
$cmd // "" |
|
619
|
0 |
0 |
$args[-1] // 0 |
|
627
|
0 |
0 |
$args[$i + 1] // 0 |
|
812
|
0 |
0 |
$cmd // "" |
|
989
|
1 |
0 |
$reason //= "timeout" |
|
1201
|
0 |
0 |
$def->{'keys'} // "dynamic" |
|
1405
|
0 |
0 |
+(shift())->{'inflight'} // [] |
|
1414
|
0 |
0 |
$self->{'inflight'} // [] |
|
1514
|
0 |
0 |
$timeout //= 30 |
| line |
l |
!l&&r |
!l&&!r |
condition |
|
169
|
0 |
0 |
81 |
$self->{'debug'} or $self->{'otel_tracer'} |
|
|
0 |
0 |
81 |
$self->{'debug'} or $self->{'otel_tracer'} or $self->{'otel_meter'} |
|
256
|
1 |
74 |
0 |
$self->{'path'} // $self->{'host'} |
|
301
|
0 |
0 |
0 |
$self->{'path'} // "$self->{'host'}:$self->{'port'}" |
|
598
|
0 |
0 |
0 |
not defined $buf or length $buf == 0 |
|
971
|
0 |
0 |
0 |
not defined $buf or length $buf == 0 |
|
1551
|
0 |
0 |
0 |
$self->{'_subscription'} //= "Async::Redis::Subscription"->new("redis", $self) |
|
1579
|
0 |
0 |
0 |
$self->{'_subscription'} //= "Async::Redis::Subscription"->new("redis", $self) |
|
1604
|
0 |
0 |
0 |
$self->{'_subscription'} //= "Async::Redis::Subscription"->new("redis", $self) |
|
1658
|
0 |
0 |
0 |
$opts{'max_depth'} // $self->{'pipeline_depth'} |