diff --git a/src/entry/Maat_command.cpp b/src/entry/Maat_command.cpp index 6887ab0..c5a8227 100644 --- a/src/entry/Maat_command.cpp +++ b/src/entry/Maat_command.cpp @@ -1255,7 +1255,7 @@ int exec_serial_rule(redisContext* ctx,struct serial_rule_t* s_rule, unsigned in unsigned int max_multi_cmd_num=MAX_REDIS_OP_PER_SRULE*serial_rule_num+2;// 2 for operation in _exec_serial_rule_end() struct expected_reply *expected_reply=(struct expected_reply*)calloc(sizeof(struct expected_reply), max_multi_cmd_num); - long long new_version=0; + long long new_version=0, transaction_finished_version=0; int renew_num=0,ret=0; for(i=0;i0) + { + transaction_finished_version=read_redis_integer(transaction_reply->element[multi_cmd_cnt-1]); + MESA_handle_runtime_log(logger, RLOG_LV_INFO, maat_command, + "Redis transaction version: %lld, transaction finished version: %lld, status: %s", + new_version, + transaction_finished_version, + transaction_finished_version==new_version?"OK":"Weird"); + } + freeReplyObject(transaction_reply); error_out: diff --git a/src/entry/Maat_rule.cpp b/src/entry/Maat_rule.cpp index b778e7b..9017822 100644 --- a/src/entry/Maat_rule.cpp +++ b/src/entry/Maat_rule.cpp @@ -32,7 +32,7 @@ #include "stream_fuzzy_hash.h" #include "gram_index_engine.h" -int MAAT_FRAME_VERSION_2_6_20190127=1; +int MAAT_FRAME_VERSION_2_6_20190220=1; const char* CHARSET_STRING[]={"NONE","gbk","big5","unicode","utf8","bin", "unicode_ascii_esc","unicode_ascii_aligned","unicode_ncr_dec","unicode_ncr_hex","url_encode_gb2312","url_encode_utf8",""};