|
@@ -953,6 +953,14 @@ int redisc_exec(str *srv, str *res, str *cmd, ...)
|
|
|
goto error_exec;
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+ LM_DBG("rpl->rplRedis->type:%d\n", rpl->rplRedis->type);
|
|
|
+ if(rpl->rplRedis->type == REDIS_REPLY_ERROR) {
|
|
|
+ LM_ERR("Redis error:%.*s\n",
|
|
|
+ (int)rpl->rplRedis->len, rpl->rplRedis->str);
|
|
|
+ goto error_exec;
|
|
|
+ }
|
|
|
+
|
|
|
if (check_cluster_reply(rpl->rplRedis, &rsrv)) {
|
|
|
LM_DBG("rsrv->ctxRedis = %p\n", rsrv->ctxRedis);
|
|
|
if(rsrv->ctxRedis==NULL)
|
|
@@ -987,6 +995,13 @@ int redisc_exec(str *srv, str *res, str *cmd, ...)
|
|
|
goto error_exec;
|
|
|
}
|
|
|
}
|
|
|
+
|
|
|
+ LM_DBG("rpl->rplRedis->type:%d\n", rpl->rplRedis->type);
|
|
|
+ if(rpl->rplRedis->type == REDIS_REPLY_ERROR) {
|
|
|
+ LM_ERR("Redis error:%.*s\n",
|
|
|
+ (int)rpl->rplRedis->len, rpl->rplRedis->str);
|
|
|
+ goto error_exec;
|
|
|
+ }
|
|
|
}
|
|
|
cmd->s[cmd->len] = c;
|
|
|
rsrv->disable.consecutive_errors = 0;
|