From ece4d082c84602371df9d13de32ee3c55ac32787 Mon Sep 17 00:00:00 2001
From: wenbo <wenbobuaa@foxmail.com>
Date: Thu, 17 Oct 2019 11:44:01 +0800
Subject: [PATCH] fix redisproxy del

---
 lib/acid/chash_redis.lua | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/lib/acid/chash_redis.lua b/lib/acid/chash_redis.lua
index e55caaa..23b64c5 100644
--- a/lib/acid/chash_redis.lua
+++ b/lib/acid/chash_redis.lua
@@ -178,20 +178,23 @@ local function run_xdel_cmd(self, cmd, cmd_args, n)
     end
 
     local nok = 0
+    local err_code, err_msg
+    local n_failed = 0
+
     for _, addr in ipairs(addrs) do
         local ipport = str_split(addr, ':')
 
-        local _, err_code, err_msg =
+        _, err_code, err_msg =
             run_cmd_on_redis(ipport[1], ipport[2], cmd, cmd_args)
 
         if err_code ~= nil then
-            return nok, err_code, err_msg
+            n_failed = n_failed + 1
+        else
+            nok = nok + 1
         end
-
-        nok = nok + 1
     end
 
-    return nok, nil, nil
+    return nok, err_code, err_msg
 end
 
 function _M.del(self, args, n)