| 1034 | } |
| 1035 | |
| 1036 | void IdoPgsqlConnection::CleanUpExecuteQuery(const String& table, const String& time_column, double max_age) |
| 1037 | { |
| 1038 | if (IsPaused()) |
| 1039 | return; |
| 1040 | |
| 1041 | IncreasePendingQueries(1); |
| 1042 | m_QueryQueue.Enqueue([this, table, time_column, max_age]() { InternalCleanUpExecuteQuery(table, time_column, max_age); }, PriorityLow, true); |
| 1043 | } |
| 1044 | |
| 1045 | void IdoPgsqlConnection::InternalCleanUpExecuteQuery(const String& table, const String& time_column, double max_age) |
| 1046 | { |