diff options
| author | Dan Goodliffe <dan.goodliffe@octal.co.uk> | 2026-05-13 15:01:30 +0100 |
|---|---|---|
| committer | Dan Goodliffe <dan.goodliffe@octal.co.uk> | 2026-05-13 15:01:30 +0100 |
| commit | 868446ad4d8ba33053b048dd4d82b6d4f5328f07 (patch) | |
| tree | ba8a8ecdb32c42f0d9c938965590f220cab7ee20 /src/ingestor.cpp | |
| parent | 4739bb6a1565e69492eb0349298d86d4d0daad38 (diff) | |
| download | webstat-868446ad4d8ba33053b048dd4d82b6d4f5328f07.tar.bz2 webstat-868446ad4d8ba33053b048dd4d82b6d4f5328f07.tar.xz webstat-868446ad4d8ba33053b048dd4d82b6d4f5328f07.zip | |
Remove maxBatches
It's not required; DB insertion occurs only in a background thread now.
Diffstat (limited to 'src/ingestor.cpp')
| -rw-r--r-- | src/ingestor.cpp | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/ingestor.cpp b/src/ingestor.cpp index 88bea9f..2c59866 100644 --- a/src/ingestor.cpp +++ b/src/ingestor.cpp @@ -316,8 +316,7 @@ namespace WebStat { { auto storedEnd = processingLines.begin(); try { - for (auto batch : processingLines | std::views::chunk(settings.maxBatchSize) - | std::views::take(settings.maxBatches)) { + for (auto batch : processingLines | std::views::chunk(settings.maxBatchSize)) { ingestLogLines(dbpool->get().get(), batch); storedEnd = batch.end(); } |