thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-19 12:52:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Preallocate log queue buffer after flush

Browse Source
This commit is contained in:
Alexander Gololobov 2024-12-10 16:58:09 +01:00
parent d65dd866c6
commit 61d5c75343
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/Common/SystemLogBase.cpp
View File

@ -208,13 +208,19 @@ typename SystemLogQueue<LogElement>::PopResult SystemLogQueue<LogElement>::pop()
if (is_shutdown)
return PopResult{.is_shutdown = true};
queue_front_index += queue.size();
const auto queue_size = queue.size();
queue_front_index += queue_size;
prev_ignored_logs = ignored_logs;
ignored_logs = 0;
result.last_log_index = queue_front_index;
result.logs.swap(queue);
if (!queue.empty())
result.logs.swap(queue);
result.create_table_force = requested_prepare_tables > prepared_tables;
/// Preallocate same amount of memory for the next batch to minimize reallocations.
if (queue_size > queue.capacity())
queue.reserve(std::max(settings.reserved_size_rows, queue_size));
}
if (prev_ignored_logs)