Fix Del command case.

This commit is contained in:
Vladimir Mihailenco 2016-07-08 09:24:02 +00:00
parent 4d018d831e
commit 261cf7ae70
3 changed files with 4 additions and 2 deletions

View File

@ -235,6 +235,7 @@ func (c *ClusterClient) slotClosestNode(slot int) (*clusterNode, error) {
func (c *ClusterClient) cmdSlotAndNode(cmd Cmder) (int, *clusterNode, error) { func (c *ClusterClient) cmdSlotAndNode(cmd Cmder) (int, *clusterNode, error) {
cmdInfo := c.cmdInfo(cmd.arg(0)) cmdInfo := c.cmdInfo(cmd.arg(0))
if cmdInfo == nil { if cmdInfo == nil {
internal.Logf("info for cmd=%s not found", cmd.arg(0))
node, err := c.randomNode() node, err := c.randomNode()
return 0, node, err return 0, node, err
} }

View File

@ -82,7 +82,7 @@ func (c *statefulCmdable) Select(index int) *StatusCmd {
func (c *cmdable) Del(keys ...string) *IntCmd { func (c *cmdable) Del(keys ...string) *IntCmd {
args := make([]interface{}, 1+len(keys)) args := make([]interface{}, 1+len(keys))
args[0] = "DEL" args[0] = "del"
for i, key := range keys { for i, key := range keys {
args[1+i] = key args[1+i] = key
} }
@ -550,7 +550,7 @@ func (c *cmdable) Set(key string, value interface{}, expiration time.Duration) *
func (c *cmdable) SetBit(key string, offset int64, value int) *IntCmd { func (c *cmdable) SetBit(key string, offset int64, value int) *IntCmd {
cmd := NewIntCmd( cmd := NewIntCmd(
"SETBIT", "setbit",
key, key,
offset, offset,
value, value,

View File

@ -169,6 +169,7 @@ func (c *Ring) cmdInfo(name string) *CommandInfo {
func (c *Ring) cmdFirstKey(cmd Cmder) string { func (c *Ring) cmdFirstKey(cmd Cmder) string {
cmdInfo := c.cmdInfo(cmd.arg(0)) cmdInfo := c.cmdInfo(cmd.arg(0))
if cmdInfo == nil { if cmdInfo == nil {
internal.Logf("info for cmd=%s not found", cmd.arg(0))
return "" return ""
} }
return cmd.arg(int(cmdInfo.FirstKeyPos)) return cmd.arg(int(cmdInfo.FirstKeyPos))