mirrors/valkey
1
0
Fork 0
mirror of http://github.com/valkey-io/valkey synced 2024-11-23 03:33:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Cluster: Tcl cluster client: handle MOVED/ASK.

Browse Source
This commit is contained in:
antirez 2014-05-02 15:35:08 +02:00
parent fcd2065f8e
commit 3bc119c155
1 changed files with 24 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
tests/support/cluster.tcl
View File

@ -166,12 +166,31 @@ proc ::redis_cluster::__dispatch__ {id method args} {
} }
# Execute the command in the node we think is the slot owner. # Execute the command in the node we think is the slot owner.
set node [dict get $::redis_cluster::nodes($id) $node_addr] set retry 10
set link [dict get $node link] while {[incr retry -1]} {
if {[catch {$link $method {*}$args} e]} { if {$retry < 5} {after 100}
# TODO: trap redirection error set node [dict get $::redis_cluster::nodes($id) $node_addr]
set link [dict get $node link]
if {[catch {$link $method {*}$args} e]} {
if {[string range $e 0 4] eq {MOVED}} {
# MOVED redirection.
::redis_cluster::__method__refresh_nodes_map $id
set node_addr [dict get $::redis_cluster::slots($id) $slot]
continue
} elseif {[string range $e 0 2] eq {ASK}} {
# ASK redirection.
set node_addr [lindex $e 2]
continue
} else {
# Non redirecting error.
error $e $::errorInfo $::errorCode
}
} else {
# OK query went fine
return $e
}
} }
return $e error "Too many redirections or failures contacting Redis Cluster."
} else { } else {
uplevel 1 [list ::redis_cluster::__method__$method $id] $args uplevel 1 [list ::redis_cluster::__method__$method $id] $args
} }