diff --git a/src/entry/Maat_api.cpp b/src/entry/Maat_api.cpp
index 2648ecf..0572763 100644
--- a/src/entry/Maat_api.cpp
+++ b/src/entry/Maat_api.cpp
@@ -638,11 +638,16 @@ void maat_read_full_config(_Maat_feather_t* _feather)
 							,_feather->redis_port
 							,_feather->redis_index);
 		_feather->redis_read_ctx=redisConnectWithTimeout(_feather->redis_ip,_feather->redis_port,_feather->connect_timeout);
-		if(_feather->redis_read_ctx==NULL)
+		if(_feather->redis_read_ctx==NULL||_feather->redis_read_ctx->err)
 		{
 			MESA_handle_runtime_log(_feather->logger,RLOG_LV_FATAL,maat_module 
-								,"Redis connect %s:%d failed."
-								,_feather->redis_ip,_feather->redis_port);
+								,"Redis connect %s:%d failed : %s."
+								,_feather->redis_ip,_feather->redis_port,_feather->redis_read_ctx==NULL?"Unkonwn":_feather->redis_read_ctx->errstr);
+			if(_feather->redis_read_ctx!=NULL)
+			{
+				redisFree(_feather->redis_write_ctx);
+				_feather->redis_write_ctx=NULL;
+			}
 		}
 		else
 		{
diff --git a/src/entry/Maat_command.cpp b/src/entry/Maat_command.cpp
index 4d9e8eb..f87b680 100644
--- a/src/entry/Maat_command.cpp
+++ b/src/entry/Maat_command.cpp
@@ -61,11 +61,16 @@ int connect_redis_for_write(_Maat_feather_t * feather)
 	redisReply* reply=NULL;
 	assert(feather->redis_write_ctx==NULL);
 	feather->redis_write_ctx=redisConnectWithTimeout(feather->redis_ip, feather->redis_port,feather->connect_timeout);
-	if(feather->redis_write_ctx==NULL)
+	if(feather->redis_write_ctx==NULL||feather->redis_write_ctx->err)
 	{
 		MESA_handle_runtime_log(feather->logger,RLOG_LV_FATAL,maat_module 
-				,"Redis connect %s:%d for write failed."
-				,feather->redis_ip,feather->redis_port);
+				,"Redis connect %s:%d for write failed: %s."
+				,feather->redis_ip,feather->redis_port,feather->redis_write_ctx==NULL?"Unkown":feather->redis_write_ctx->errstr);
+		if(feather->redis_write_ctx!=NULL)
+		{
+			redisFree(feather->redis_write_ctx);
+			feather->redis_write_ctx=NULL;
+		}
 		ret=-1;
 	}
 	else
@@ -1110,12 +1115,16 @@ void redis_monitor_traverse(long        long version,redisContext *c,
 	long long new_version=0;
 	enum MAAT_TABLE_TYPE table_type;
 	void* logger=feather->logger;
-	if(feather->redis_write_ctx!=NULL)//authorized to write
+	if(feather->redis_write_ctx!=NULL&&feather->redis_write_ctx->err==0)//authorized to write
 	{
 		//For thread safe, deliberately use redis_read_ctx but not redis_write_ctx.
 		check_maat_expiration(feather->redis_read_ctx, logger);
 		cleanup_update_status(feather->redis_read_ctx, logger);
 	}
+	if(c==NULL||c->err)
+	{
+		return;
+	}
 	rule_num=get_rm_key_list(version, c, &rule_list, logger,&new_version, &update_type,feather->cumulative_update_off);
 	if(rule_num<0||(rule_num==0&&update_type==CM_UPDATE_TYPE_INC))//error or nothing changed
 	{
diff --git a/tools/maat_redis_tool.cpp b/tools/maat_redis_tool.cpp
index cff62d2..9fae08f 100644
--- a/tools/maat_redis_tool.cpp
+++ b/tools/maat_redis_tool.cpp
@@ -46,9 +46,9 @@ static redisContext * connect_redis(const char*redis_ip, int redis_port, int red
 
 	redisContext * ctx;
 	ctx=redisConnectWithTimeout(redis_ip, redis_port,connect_timeout);
-	if(ctx==NULL)
+	if(ctx==NULL||ctx->err)
 	{
-		printf("Unable to connect %s:%d db%d\n",redis_ip,redis_port,redis_db);
+		printf("Unable to connect %s:%d db%d : %s\n",redis_ip,redis_port,redis_db, ctx==NULL?"Unknown":ctx->errstr);
 		return NULL;
 	}
 	reply=_wrap_redisCommand(ctx, "select %d",redis_db);