diff options
| author | Dan Goodliffe <dan@randomdan.homeip.net> | 2026-04-10 20:22:35 +0100 |
|---|---|---|
| committer | Dan Goodliffe <dan@randomdan.homeip.net> | 2026-04-10 20:22:35 +0100 |
| commit | 72bfa9dd305258789b0d2e80f8af13962e5aac42 (patch) | |
| tree | 4f4dd17921154452289107fae6b6358047f35bce /src/ingestor.hpp | |
| parent | 1e551e618a63c869fde6a4b327566b38696a5f45 (diff) | |
| download | webstat-72bfa9dd305258789b0d2e80f8af13962e5aac42.tar.bz2 webstat-72bfa9dd305258789b0d2e80f8af13962e5aac42.tar.xz webstat-72bfa9dd305258789b0d2e80f8af13962e5aac42.zip | |
Return path of parked lines log file from parkQueuedLogLines
Or the last errno on failure.
Diffstat (limited to 'src/ingestor.hpp')
| -rw-r--r-- | src/ingestor.hpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/ingestor.hpp b/src/ingestor.hpp index fcddc92..b2e0fed 100644 --- a/src/ingestor.hpp +++ b/src/ingestor.hpp @@ -7,6 +7,7 @@ #include <connectionPool.h> #include <connection_fwd.h> #include <cstdio> +#include <expected> #include <flat_set> #include <future> #include <scn/scan.h> @@ -54,7 +55,7 @@ namespace WebStat { void ingestLog(std::FILE *); void tryIngestQueuedLogLines(); void ingestLogLines(DB::Connection *, const LineBatch & lines); - void parkQueuedLogLines(); + std::expected<std::filesystem::path, int> parkQueuedLogLines(); void runJobsAsNeeded(); unsigned int jobIngestParkedLines(); |