Pārlūkot izejas kodu

Merge pull request #2960 from apogrebennyk/apogrebennyk/db_redis_update

db_redis: don't leave unconsumed redis replies in case of error
Andreas Granig 3 gadi atpakaļ
vecāks
revīzija
e97ae3e621
1 mainītis faili ar 2 papildinājumiem un 0 dzēšanām
  1. 2 0
      src/modules/db_redis/redis_dbase.c

+ 2 - 0
src/modules/db_redis/redis_dbase.c

@@ -2249,6 +2249,7 @@ static int db_redis_perform_update(const db1_con_t* _h, km_redis_con_t *con, con
 
 
     db_redis_key_free(&all_type_keys);
     db_redis_key_free(&all_type_keys);
     db_redis_key_free(&new_type_keys);
     db_redis_key_free(&new_type_keys);
+    db_redis_consume_replies(con);
     return 0;
     return 0;
 
 
 error:
 error:
@@ -2260,6 +2261,7 @@ error:
     db_redis_key_free(&type_keys);
     db_redis_key_free(&type_keys);
     db_redis_key_free(&set_keys);
     db_redis_key_free(&set_keys);
     db_redis_key_free(&new_type_keys);
     db_redis_key_free(&new_type_keys);
+    db_redis_consume_replies(con);
     return -1;
     return -1;
 }
 }