diff --git a/medredis.c b/medredis.c index 544f901..9f78027 100644 --- a/medredis.c +++ b/medredis.c @@ -40,9 +40,16 @@ typedef struct { unsigned int append_counter; } medredis_con_t; +typedef struct { + const char *name; +} medredis_table_t; + static medredis_con_t *con = NULL; static char medredis_srem_key_lua[41]; // sha-1 hex string +static medredis_table_t medredis_table_trash = { .name = "trash" }; +static medredis_table_t medredis_table_backup = { .name = "backup" }; + /**********************************************************************/ static void medredis_free_reply(redisReply **reply) { if (reply && *reply) { @@ -802,10 +809,10 @@ err: } /**********************************************************************/ -static int medredis_cleanup_entries(GQueue *records, const char *table) { +static int medredis_cleanup_entries(GQueue *records, medredis_table_t *table) { char buffer[512]; - if (medmysql_insert_records(records, table) != 0) { + if (medmysql_insert_records(records, table->name) != 0) { L_CRITICAL("Failed to cleanup redis records\n"); goto err; } @@ -854,10 +861,10 @@ err: /**********************************************************************/ int medredis_trash_entries(GQueue *records) { - return medredis_cleanup_entries(records, "trash"); + return medredis_cleanup_entries(records, &medredis_table_trash); } /**********************************************************************/ int medredis_backup_entries(GQueue *records) { - return medredis_cleanup_entries(records, "backup"); + return medredis_cleanup_entries(records, &medredis_table_backup); }