| line |
true |
false |
branch |
|
166
|
0 |
0 |
if $params{'no_slots_initialization'} |
|
177
|
0 |
0 |
if $self->{'no_slots_initialization'} |
|
178
|
0 |
0 |
unless ($self->{'_nodes'} and @{$self->{'_nodes'};}) |
|
186
|
0 |
0 |
unless $redis |
|
189
|
0 |
0 |
if ref $nodes =~ /^RedisDB::Error/ |
|
196
|
0 |
0 |
if ref $slots =~ /^RedisDB::Error/ |
|
208
|
0 |
0 |
unless ($new_nodes and @$new_nodes) |
|
215
|
0 |
0 |
unless $new_nodes{$_} |
|
247
|
0 |
0 |
unless $key_pos{$command} |
|
249
|
0 |
0 |
unless length $key |
|
251
|
0 |
0 |
if ($self->{'_refresh_slots'}) |
|
263
|
0 |
0 |
unless ($redis) |
|
275
|
0 |
0 |
if ($redis) { } |
|
276
|
0 |
0 |
if $asking |
|
285
|
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') { } |
|
286
|
0 |
0 |
if ($res->{'slot'} ne $slot) |
|
290
|
0 |
0 |
if $DEBUG |
|
296
|
0 |
0 |
if $DEBUG |
|
302
|
0 |
0 |
if $DEBUG |
|
305
|
0 |
0 |
if ($last_connection and $last_connection eq $node_key) { } |
|
308
|
0 |
0 |
if $DEBUG |
|
312
|
0 |
0 |
if $self->{'_slots'}[$slot] eq $node_key |
|
313
|
0 |
0 |
if $DEBUG |
|
316
|
0 |
0 |
if $DEBUG |
|
343
|
0 |
0 |
unless ($connection) |
|
346
|
0 |
0 |
if $connection |
|
370
|
0 |
0 |
if ($self->{'_refresh_slots'}) |
|
374
|
0 |
0 |
unless my $node_key = $self->{'_slots'}[$slot] |
|
422
|
0 |
0 |
if not ref $_[1] and $_[1] eq 'OK' |
|
|
0 |
0 |
if ref $_[1] |
|
426
|
0 |
0 |
unless $ok |
|
428
|
0 |
0 |
if ($master_id) |
|
432
|
0 |
0 |
if $attempt++ >= 10 |
|
438
|
0 |
0 |
if ref $res =~ /^RedisDB::Error/ |
|
460
|
0 |
0 |
unless $src_key |
|
463
|
0 |
0 |
unless $dst = $self->_get_node_info($dst) |
|
466
|
0 |
0 |
if $DEBUG |
|
469
|
0 |
0 |
if $src_key eq $dst_key |
|
472
|
0 |
0 |
unless my $dst_redis = _connect_to_node($self, $dst) |
|
474
|
0 |
0 |
unless my $src_redis = _connect_to_node($self, $src) |
|
480
|
0 |
0 |
unless "$res" eq 'OK' |
|
483
|
0 |
0 |
unless "$res" eq 'OK' |
|
484
|
0 |
0 |
if $DEBUG |
|
490
|
0 |
0 |
if ref $keys =~ /^RedisDB::Error/ |
|
491
|
0 |
0 |
unless @$keys |
|
494
|
0 |
0 |
unless "$res" eq 'OK' |
|
498
|
0 |
0 |
if $DEBUG |
|
501
|
0 |
0 |
unless "$res" eq 'OK' |
|
503
|
0 |
0 |
unless "$res" eq 'OK' |
|
504
|
0 |
0 |
if $DEBUG |
|
523
|
0 |
0 |
if ($node->{'flags'}{'master'}) |
|
527
|
0 |
0 |
if ($_->{'flags'}{'slave'}) |
|
528
|
0 |
0 |
if $_->{'master_id'} eq $node->{'node_id'} |
|
531
|
0 |
0 |
if $_->{'node_id'} eq $node->{'node_id'} |
|
537
|
0 |
0 |
if $self->{'_slots'}[$i] eq $node_key |
|
540
|
0 |
0 |
if ($DEBUG) |
|
556
|
0 |
0 |
unless defined $slot |
|
560
|
0 |
0 |
unless my $slave = shift @slaves |
|
561
|
0 |
0 |
unless my $redis = $self->_connect_to_node($slave) |
|
563
|
0 |
0 |
if ref $res =~ /^RedisDB::Error/ |
|
574
|
0 |
0 |
if $_->{'node_id'} eq $node->{'node_id'} |
|
576
|
0 |
0 |
unless my $redis = $self->_connect_to_node($_) |
|
578
|
0 |
0 |
if $res =~ /^RedisDB::Error/ |
|
590
|
0 |
0 |
if $node->{'host'} eq $_->{'host'} and $node->{'port'} eq $_->{'port'} |
|
597
|
0 |
0 |
unless (ref $addr eq 'HASH') |
|
599
|
0 |
0 |
unless $host and $port |
|
611
|
0 |
0 |
unless ($self->{'_connections'}{$host_key}) |
|
617
|
0 |
0 |
$redis->{'_socket'} ? : |
|
670
|
1 |
6 |
if (utf8::is_utf8($buf)) |
|
691
|
2 |
2 |
if ($key =~ /\{([^}]+)\}/) |