diff --git a/inc/Maat_command.h b/inc/Maat_command.h index 1ccefe8..e457646 100644 --- a/inc/Maat_command.h +++ b/inc/Maat_command.h @@ -120,7 +120,7 @@ struct Maat_line_t { const char* table_name; const char* table_line; - int rule_id; // for MAAT_OP_DEL, only rule_id is necessary. + int rule_id; // for MAAT_OP_DEL, only rule_id and table_name are necessary. int label_id; int expire_after; //expired after $timeout$ seconds, set to 0 for never timeout. }; diff --git a/src/entry/Maat_command.cpp b/src/entry/Maat_command.cpp index 7ce9ce3..9b056cd 100644 --- a/src/entry/Maat_command.cpp +++ b/src/entry/Maat_command.cpp @@ -1220,6 +1220,14 @@ int Maat_cmd_set_lines(Maat_feather_t feather,const struct Maat_line_t** line_ru int ret=0, table_id=0,retry=0,success_cnt=0; struct serial_rule_t *s_rule=NULL; long long server_time=0,absolute_expire_time=0; + if(_feather->redis_write_ctx==NULL) + { + ret=connect_redis_for_write(_feather); + if(ret!=0) + { + return -1; + } + } server_time=redis_server_time(_feather->redis_write_ctx); s_rule=(struct serial_rule_t *)calloc(sizeof(struct serial_rule_t),line_num); for(i=0;i