| 1229 | } |
| 1230 | |
| 1231 | void IdoMysqlConnection::CleanUpExecuteQuery(const String& table, const String& time_column, double max_age) |
| 1232 | { |
| 1233 | if (IsPaused()) |
| 1234 | return; |
| 1235 | |
| 1236 | #ifdef I2_DEBUG /* I2_DEBUG */ |
| 1237 | Log(LogDebug, "IdoMysqlConnection") |
| 1238 | << "Rescheduling cleanup query for table '" << table << "' and column '" |
| 1239 | << time_column << "'. max_age is set to '" << max_age << "'."; |
| 1240 | #endif /* I2_DEBUG */ |
| 1241 | |
| 1242 | IncreasePendingQueries(1); |
| 1243 | m_QueryQueue.Enqueue([this, table, time_column, max_age]() { InternalCleanUpExecuteQuery(table, time_column, max_age); }, PriorityLow, true); |
| 1244 | } |
| 1245 | |
| 1246 | void IdoMysqlConnection::InternalCleanUpExecuteQuery(const String& table, const String& time_column, double max_age) |
| 1247 | { |