| line |
true |
false |
branch |
|
176
|
0 |
0 |
if $params{'no_slots_initialization'} |
|
187
|
0 |
0 |
if $self->{'no_slots_initialization'} |
|
188
|
0 |
0 |
unless ($self->{'_nodes'} and @{$self->{'_nodes'};}) |
|
196
|
0 |
0 |
unless $redis |
|
199
|
0 |
0 |
if ref($nodes) =~ /^RedisDB::Error/ |
|
206
|
0 |
0 |
if ref $slots =~ /^RedisDB::Error/ |
|
218
|
0 |
0 |
unless ($new_nodes and @$new_nodes) |
|
225
|
0 |
0 |
unless $new_nodes{$_} |
|
257
|
0 |
0 |
unless $key_pos{$command} |
|
259
|
0 |
0 |
unless length $key |
|
261
|
0 |
0 |
if ($self->{'_refresh_slots'}) |
|
273
|
0 |
0 |
unless ($redis) |
|
285
|
0 |
0 |
if ($redis) { } |
|
286
|
0 |
0 |
if $asking |
|
295
|
0 |
0 |
if (ref $res eq 'RedisDB::Error::MOVED') { } |
|
|
0 |
0 |
elsif (ref $res eq 'RedisDB::Error::ASK') { } |
|
|
0 |
0 |
elsif (ref $res eq 'RedisDB::Error::DISCONNECTED') { } |
|
296
|
0 |
0 |
if ($res->{'slot'} ne $slot) |
|
300
|
0 |
0 |
if $DEBUG |
|
306
|
0 |
0 |
if $DEBUG |
|
312
|
0 |
0 |
if $DEBUG |
|
315
|
0 |
0 |
if ($last_connection and $last_connection eq $node_key) { } |
|
318
|
0 |
0 |
if $DEBUG |
|
322
|
0 |
0 |
if $self->{'_slots'}[$slot] eq $node_key |
|
323
|
0 |
0 |
if $DEBUG |
|
326
|
0 |
0 |
if $DEBUG |
|
353
|
0 |
0 |
unless ($connection) |
|
356
|
0 |
0 |
if $connection |
|
380
|
0 |
0 |
if ($self->{'_refresh_slots'}) |
|
383
|
0 |
0 |
unless my $node_key = $self->{'_slots'}[$slot] |
|
431
|
0 |
0 |
if not ref $_[1] and $_[1] eq 'OK' |
|
|
0 |
0 |
if ref $_[1] |
|
435
|
0 |
0 |
unless $ok |
|
437
|
0 |
0 |
if ($master_id) |
|
441
|
0 |
0 |
if $attempt++ >= 10 |
|
447
|
0 |
0 |
if ref $res =~ /^RedisDB::Error/ |
|
469
|
0 |
0 |
unless $src_key |
|
472
|
0 |
0 |
unless $dst = $self->_get_node_info($dst) |
|
475
|
0 |
0 |
if $DEBUG |
|
478
|
0 |
0 |
if $src_key eq $dst_key |
|
481
|
0 |
0 |
unless my $dst_redis = _connect_to_node($self, $dst) |
|
483
|
0 |
0 |
unless my $src_redis = _connect_to_node($self, $src) |
|
489
|
0 |
0 |
unless "$res" eq 'OK' |
|
492
|
0 |
0 |
unless "$res" eq 'OK' |
|
493
|
0 |
0 |
if $DEBUG |
|
499
|
0 |
0 |
if ref $keys =~ /^RedisDB::Error/ |
|
500
|
0 |
0 |
unless @$keys |
|
503
|
0 |
0 |
unless "$res" eq 'OK' |
|
507
|
0 |
0 |
if $DEBUG |
|
510
|
0 |
0 |
unless "$res" eq 'OK' |
|
512
|
0 |
0 |
unless "$res" eq 'OK' |
|
513
|
0 |
0 |
if $DEBUG |
|
532
|
0 |
0 |
if ($node->{'flags'}{'master'}) |
|
536
|
0 |
0 |
if ($_->{'flags'}{'slave'}) |
|
537
|
0 |
0 |
if $_->{'master_id'} eq $node->{'node_id'} |
|
540
|
0 |
0 |
if $_->{'node_id'} eq $node->{'node_id'} |
|
546
|
0 |
0 |
if $self->{'_slots'}[$i] eq $node_key |
|
549
|
0 |
0 |
if ($DEBUG) |
|
565
|
0 |
0 |
unless defined $slot |
|
569
|
0 |
0 |
unless my $slave = shift @slaves |
|
570
|
0 |
0 |
unless my $redis = $self->_connect_to_node($slave) |
|
572
|
0 |
0 |
if ref $res =~ /^RedisDB::Error/ |
|
583
|
0 |
0 |
if $_->{'node_id'} eq $node->{'node_id'} |
|
585
|
0 |
0 |
unless my $redis = $self->_connect_to_node($_) |
|
587
|
0 |
0 |
if $res =~ /^RedisDB::Error/ |
|
599
|
0 |
0 |
if $node->{'host'} eq $_->{'host'} and $node->{'port'} eq $_->{'port'} |
|
606
|
0 |
0 |
unless (ref $addr eq 'HASH') |
|
608
|
0 |
0 |
unless $host and $port |
|
620
|
0 |
0 |
unless ($self->{'_connections'}{$host_key}) |
|
627
|
0 |
0 |
$redis->{'_socket'} ? : |
|
680
|
1 |
6 |
if (utf8::is_utf8($buf)) |
|
701
|
2 |
2 |
if ($key =~ /\{([^}]+)\}/) |