From f7500b9960915553fbc3a4f11c4f2de68156dfb8 Mon Sep 17 00:00:00 2001
From: zhengchao <zhengchao@iie.ac.cn>
Date: Thu, 18 Oct 2018 19:43:54 +0800
Subject: [PATCH] =?UTF-8?q?=E8=BF=9B=E4=B8=80=E6=AD=A5=E5=AE=8C=E5=96=84re?=
 =?UTF-8?q?dis=E4=B8=8D=E5=8F=AF=E7=94=A8=E6=97=B6=E7=9A=84=E9=94=99?=
 =?UTF-8?q?=E8=AF=AF=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/entry/Maat_command.cpp | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/src/entry/Maat_command.cpp b/src/entry/Maat_command.cpp
index ed1719f..e0eb038 100644
--- a/src/entry/Maat_command.cpp
+++ b/src/entry/Maat_command.cpp
@@ -376,6 +376,10 @@ int get_inc_key_list(long long instance_version, long long target_version, redis
 	nearest_rule_version=read_redis_integer(tmp_reply);
 	freeReplyObject(tmp_reply);
 	tmp_reply=NULL;
+	if(nearest_rule_version<0)
+	{
+		return -1;
+	}
 	if(nearest_rule_version!=instance_version+1)
 	{
 		MESA_handle_runtime_log(logger, RLOG_LV_INFO, maat_redis_monitor,
@@ -516,6 +520,15 @@ int get_rm_key_list(redisContext *c, long long instance_version, long long desir
 		return -1;
 	}
 	redis_version=read_redis_integer(reply);
+	if(redis_version<0)
+	{
+		if(reply->type==REDIS_REPLY_ERROR)
+		{
+			MESA_handle_runtime_log(logger, RLOG_LV_FATAL, maat_redis_monitor,
+			"Redis Communication error: %s.",reply->str);
+		}
+		return -1;
+	}
 	freeReplyObject(reply);
 	if(redis_version==instance_version)
 	{