diff options
| author | Dan Goodliffe <dan.goodliffe@octal.co.uk> | 2026-05-01 16:58:01 +0100 |
|---|---|---|
| committer | Dan Goodliffe <dan.goodliffe@octal.co.uk> | 2026-05-01 17:01:56 +0100 |
| commit | 0e768a00fab74818533458b5b40c84556b2137e0 (patch) | |
| tree | 3a405ae5ecbd71727b77e4a7892ad0b2815dddc4 /src/ingestor.hpp | |
| parent | ed3598ac6f77f62b0c4fe32d4dab05784e5fa51d (diff) | |
| download | webstat-0e768a00fab74818533458b5b40c84556b2137e0.tar.bz2 webstat-0e768a00fab74818533458b5b40c84556b2137e0.tar.xz webstat-0e768a00fab74818533458b5b40c84556b2137e0.zip | |
Append unparked lines to queue in finalise function
Fixes issue where queuedLines would be accessed from background thread.
Diffstat (limited to 'src/ingestor.hpp')
| -rw-r--r-- | src/ingestor.hpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/ingestor.hpp b/src/ingestor.hpp index 4882b7d..4373f40 100644 --- a/src/ingestor.hpp +++ b/src/ingestor.hpp @@ -114,8 +114,8 @@ namespace WebStat { void finalizeJob(Job &, minutes freq, Job::LastRunTime::clock::time_point now); void finishAllJobs(); - void jobIngestParkedLines(const std::filesystem::path &); - size_t jobIngestParkedLines(FILE *, size_t count); + LineBatch jobIngestParkedLines(const std::filesystem::path &); + LineBatch jobIngestParkedLines(FILE *, size_t count); static void sigtermHandler(int); void terminate(int); |