diff options
| author | Dan Goodliffe <dan@randomdan.homeip.net> | 2025-09-12 00:13:56 +0100 |
|---|---|---|
| committer | Dan Goodliffe <dan@randomdan.homeip.net> | 2025-09-13 13:23:36 +0100 |
| commit | 55439681e7a45489e5a77c2d6169f4b722525c96 (patch) | |
| tree | a922a5d60344c6638f34f8fb273d82b97c29b238 /src/ingestor.hpp | |
| parent | c8f0fb73e49f6b6b6ac1690c585c25ab7dbd2b88 (diff) | |
| download | webstat-55439681e7a45489e5a77c2d6169f4b722525c96.tar.bz2 webstat-55439681e7a45489e5a77c2d6169f4b722525c96.tar.xz webstat-55439681e7a45489e5a77c2d6169f4b722525c96.zip | |
Perform background curl operations when not processing log input
Diffstat (limited to 'src/ingestor.hpp')
| -rw-r--r-- | src/ingestor.hpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/ingestor.hpp b/src/ingestor.hpp index f181ea3..b55886e 100644 --- a/src/ingestor.hpp +++ b/src/ingestor.hpp @@ -43,10 +43,13 @@ namespace WebStat { void storeEntities(DB::Connection *, std::span<const std::optional<Entity>>) const; using NewEntities = std::array<std::optional<Entity>, MAX_NEW_ENTITIES>; template<typename... T> NewEntities newEntities(const std::tuple<T...> &) const; + void handleCurlOperations(); + using CurlOperations = std::map<CURL *, std::unique_ptr<CurlOperation>>; mutable std::flat_set<Crc32Value> existingEntities; uint32_t hostnameId; DB::ConnectionPoolPtr dbpool; CurlMultiPtr curl; + mutable CurlOperations curlOperations; }; } |