diff options
| author | Dan Goodliffe <dan.goodliffe@octal.co.uk> | 2026-05-01 17:13:29 +0100 |
|---|---|---|
| committer | Dan Goodliffe <dan.goodliffe@octal.co.uk> | 2026-05-01 17:13:29 +0100 |
| commit | 5c0206f48dc7f90009629d0a74bdc1dd6b4f67ea (patch) | |
| tree | 4063eec8c51c26151129da558b214ac213d2f7c0 /src/ingestor.hpp | |
| parent | 0e768a00fab74818533458b5b40c84556b2137e0 (diff) | |
| download | webstat-5c0206f48dc7f90009629d0a74bdc1dd6b4f67ea.tar.bz2 webstat-5c0206f48dc7f90009629d0a74bdc1dd6b4f67ea.tar.xz webstat-5c0206f48dc7f90009629d0a74bdc1dd6b4f67ea.zip | |
Rename jobIngestParkedLines to jobReadParkedLines
Actual ingest is performed by the main process, jobReadParkedLines just
reads the park file and adds it to the queue.
Diffstat (limited to 'src/ingestor.hpp')
| -rw-r--r-- | src/ingestor.hpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/ingestor.hpp b/src/ingestor.hpp index 4373f40..d989ecd 100644 --- a/src/ingestor.hpp +++ b/src/ingestor.hpp @@ -72,7 +72,7 @@ namespace WebStat { std::optional<std::future<Result>> currentRun; }; - Job::Result jobIngestParkedLines(); + Job::Result jobReadParkedLines(); Job::Result jobPurgeOldLogs(); template<typename... T> void storeLogLine(DB::Connection *, const std::tuple<T...> &) const; @@ -114,8 +114,8 @@ namespace WebStat { void finalizeJob(Job &, minutes freq, Job::LastRunTime::clock::time_point now); void finishAllJobs(); - LineBatch jobIngestParkedLines(const std::filesystem::path &); - LineBatch jobIngestParkedLines(FILE *, size_t count); + LineBatch jobReadParkedLines(const std::filesystem::path &); + LineBatch jobReadParkedLines(FILE *, size_t count); static void sigtermHandler(int); void terminate(int); |