gfwleak/tango-maat
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复操作redis错误处理的笔误。

Browse Source
This commit is contained in:
zhengchao
2018-12-08 16:43:07 +06:00
parent baa9f1f1ec
commit da52d77bd9
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/entry/Maat_command.cpp
View File

@@ -1224,7 +1224,7 @@ int exec_serial_rule(redisContext* ctx,struct serial_rule_t* s_rule, unsigned in
unsigned int max_redis_batch=1*1024, batch_cnt=0; unsigned int max_redis_batch=1*1024, batch_cnt=0;
int renew_allowed=0,last_failed=-1; int renew_allowed=0,last_failed=-1;
redisReply*transaction_reply=NULL,*p=NULL; redisReply*transaction_reply=NULL,*p=NULL;
unsigned int i=0; unsigned int i=0, rule_seq=0;
unsigned int multi_cmd_cnt=0, success_cnt=0; unsigned int multi_cmd_cnt=0, success_cnt=0;
const int MAX_REDIS_OP_PER_SRULE=8; const int MAX_REDIS_OP_PER_SRULE=8;
@@ -1268,12 +1268,13 @@ int exec_serial_rule(redisContext* ctx,struct serial_rule_t* s_rule, unsigned in
{ {
continue; continue;
} }
rule_seq=expected_reply[i].srule_seq;
MESA_handle_runtime_log(logger,RLOG_LV_FATAL,maat_command MESA_handle_runtime_log(logger,RLOG_LV_FATAL,maat_command
,"%s %s %d failed, rule id maybe conflict or not exist." ,"%s %s %d failed, rule id maybe conflict or not exist."
,rm_op_str[s_rule[i].op] ,rm_op_str[s_rule[rule_seq].op]
,s_rule[i].table_name,s_rule[i].rule_id); ,s_rule[rule_seq].table_name,s_rule[rule_seq].rule_id);
success_cnt--; success_cnt--;
last_failed=expected_reply[i].srule_seq; last_failed=rule_seq;
} }
} }
else else