diff --git a/src/database/query-table.c b/src/database/query-table.c index 1c9b95f3..c57ad73c 100644 --- a/src/database/query-table.c +++ b/src/database/query-table.c @@ -607,7 +607,7 @@ bool delete_old_queries_from_db(const bool use_memdb, const double mintime) { // Get time stamp 24 hours (or what was configured) in the past bool okay = false; - const char *querystr = "DELETE FROM query_storage WHERE timestamp >= ?"; + const char *querystr = "DELETE FROM query_storage WHERE timestamp <= ?"; sqlite3 *db = NULL; if(use_memdb) @@ -639,7 +639,10 @@ bool delete_old_queries_from_db(const bool use_memdb, const double mintime) mintime, sqlite3_errstr(rc)); // Update number of queries in in-memory database - mem_db_num = get_number_of_queries_in_DB(memdb, "query_storage", false); + const int new_num = get_number_of_queries_in_DB(memdb, "query_storage", false); + log_debug(DEBUG_GC, "delete_old_queries_from_db(): Deleted %i (%u) queries, new number of queries in memory: %i", + sqlite3_changes(db), (mem_db_num - new_num), new_num); + mem_db_num = new_num; // Finalize statement sqlite3_finalize(stmt); diff --git a/src/log.c b/src/log.c index 8651f7c0..45ca71cb 100644 --- a/src/log.c +++ b/src/log.c @@ -783,7 +783,7 @@ bool flush_dnsmasq_log(void) unlock_shm(); // Flush last 24 hours of on-disk database - const double mintime = double_time() - 86400.0; + const double mintime = double_time(); if(!delete_old_queries_from_db(false, mintime)) { log_err("Could not flush on-disk database");