ARCHIVE/clio
1
0
Fork 0
mirror of https://github.com/XRPLF/clio.git synced 2025-11-27 07:05:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: Implement and use LedgerCacheInterface (#1955)

Browse Source 
For #1200
This commit is contained in:
Alex Kremer
2025-03-12 13:48:33 +00:00
committed by GitHub
parent 26842374de
commit 8ac1ff7699
68 changed files with 369 additions and 177 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
tests/unit/etl/CacheLoaderTests.cpp
View File

@@ -23,7 +23,7 @@
#include "etl/FakeDiffProvider.hpp"
#include "etl/impl/CacheLoader.hpp"
#include "util/MockBackendTestFixture.hpp"
#include "util/MockCache.hpp"
#include "util/MockLedgerCache.hpp"
#include "util/MockPrometheus.hpp"
#include "util/async/context/BasicExecutionContext.hpp"
#include "util/newconfig/ConfigDefinition.hpp"
@@ -75,7 +75,7 @@ constexpr auto kSEQ = 30;
struct CacheLoaderTest : util::prometheus::WithPrometheus, MockBackendTest {
DiffProvider diffProvider;
MockCache cache;
MockLedgerCache cache;
};
using Settings = etl::CacheLoaderSettings;
@@ -137,7 +137,7 @@ TEST_P(ParametrizedCacheLoaderTest, LoadCacheWithDifferentSettings)
async::CoroExecutionContext ctx{settings.numThreads};
etl::impl::CursorFromFixDiffNumProvider const provider{backend_, settings.numCacheDiffs};
etl::impl::CacheLoaderImpl<MockCache> loader{
etl::impl::CacheLoaderImpl<MockLedgerCache> loader{
ctx, backend_, cache, kSEQ, settings.numCacheMarkers, settings.cachePageFetchSize, provider.getCursors(kSEQ)
};
@@ -166,7 +166,7 @@ TEST_P(ParametrizedCacheLoaderTest, AutomaticallyCancelledAndAwaitedInDestructor
async::CoroExecutionContext ctx{settings.numThreads};
etl::impl::CursorFromFixDiffNumProvider const provider{backend_, settings.numCacheDiffs};
etl::impl::CacheLoaderImpl<MockCache> const loader{
etl::impl::CacheLoaderImpl<MockLedgerCache> const loader{
ctx, backend_, cache, kSEQ, settings.numCacheMarkers, settings.cachePageFetchSize, provider.getCursors(kSEQ)
};
@@ -195,7 +195,7 @@ TEST_P(ParametrizedCacheLoaderTest, CacheDisabledLeadsToCancellation)
async::CoroExecutionContext ctx{settings.numThreads};
etl::impl::CursorFromFixDiffNumProvider const provider{backend_, settings.numCacheDiffs};
etl::impl::CacheLoaderImpl<MockCache> loader{
etl::impl::CacheLoaderImpl<MockLedgerCache> loader{
ctx, backend_, cache, kSEQ, settings.numCacheMarkers, settings.cachePageFetchSize, provider.getCursors(kSEQ)
};
@@ -208,7 +208,7 @@ TEST_P(ParametrizedCacheLoaderTest, CacheDisabledLeadsToCancellation)
TEST_F(CacheLoaderTest, SyncCacheLoaderWaitsTillFullyLoaded)
{
auto const cfg = getParseCacheConfig(json::parse(R"({"cache": {"load": "sync"}})"));
CacheLoader loader{cfg, backend_, cache};
CacheLoader<> loader{cfg, backend_, cache};
auto const diffs = diffProvider.getLatestDiff();
auto const loops = diffs.size() + 1;