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 =~ /\{([^}]+)\}/) |