summaryrefslogtreecommitdiffstats
path: root/searchlib/src/tests/docstore/logdatastore/logdatastore_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'searchlib/src/tests/docstore/logdatastore/logdatastore_test.cpp')
-rw-r--r--searchlib/src/tests/docstore/logdatastore/logdatastore_test.cpp60
1 files changed, 32 insertions, 28 deletions
diff --git a/searchlib/src/tests/docstore/logdatastore/logdatastore_test.cpp b/searchlib/src/tests/docstore/logdatastore/logdatastore_test.cpp
index d58d7cc5cf8..3f42464ffe5 100644
--- a/searchlib/src/tests/docstore/logdatastore/logdatastore_test.cpp
+++ b/searchlib/src/tests/docstore/logdatastore/logdatastore_test.cpp
@@ -435,21 +435,8 @@ makeDoc(const DocumentTypeRepo &repo, uint32_t i, bool extra_field)
class VisitCacheStore {
public:
- VisitCacheStore() :
- _myDir("visitcache"),
- _repo(makeDocTypeRepoConfig()),
- _config(DocumentStore::Config(CompressionConfig::LZ4, 1000000, 0).allowVisitCaching(true),
- LogDataStore::Config(50000, 0.2, 3.0, 0.2, 1, true,CompressionConfig::LZ4,
- WriteableFileChunk::Config(CompressionConfig(), 16384))),
- _fileHeaderContext(),
- _executor(_config.getLogConfig().getNumThreads(), 128*1024),
- _tlSyncer(),
- _datastore(_executor, _myDir.getDir(), _config,
- GrowStrategy(), TuneFileSummary(),
- _fileHeaderContext, _tlSyncer, NULL),
- _inserted(),
- _serial(1)
- { }
+ VisitCacheStore();
+ ~VisitCacheStore();
IDocumentStore & getStore() { return _datastore; }
void write(uint32_t id) {
write(id, makeDoc(_repo, id, true));
@@ -481,19 +468,8 @@ public:
private:
class VerifyVisitor : public IDocumentVisitor {
public:
- VerifyVisitor(VisitCacheStore & vcs, std::vector<uint32_t> lids, bool allowCaching) :
- _vcs(vcs),
- _expected(),
- _actual(),
- _allowVisitCaching(allowCaching)
- {
- for (uint32_t lid : lids) {
- _expected.insert(lid);
- }
- }
- ~VerifyVisitor() {
- EXPECT_EQUAL(_expected.size(), _actual.size());
- }
+ VerifyVisitor(VisitCacheStore & vcs, std::vector<uint32_t> lids, bool allowCaching);
+ ~VerifyVisitor();
void visit(uint32_t lid, Document::UP doc) override {
EXPECT_TRUE(_expected.find(lid) != _expected.end());
EXPECT_TRUE(_actual.find(lid) == _actual.end());
@@ -518,6 +494,34 @@ private:
SerialNum _serial;
};
+VisitCacheStore::VerifyVisitor::VerifyVisitor(VisitCacheStore & vcs, std::vector<uint32_t> lids, bool allowCaching)
+ : _vcs(vcs), _expected(), _actual(), _allowVisitCaching(allowCaching)
+{
+ for (uint32_t lid : lids) {
+ _expected.insert(lid);
+ }
+}
+VisitCacheStore::VerifyVisitor::~VerifyVisitor() {
+ EXPECT_EQUAL(_expected.size(), _actual.size());
+}
+
+VisitCacheStore::VisitCacheStore() :
+ _myDir("visitcache"),
+ _repo(makeDocTypeRepoConfig()),
+ _config(DocumentStore::Config(CompressionConfig::LZ4, 1000000, 0).allowVisitCaching(true),
+ LogDataStore::Config(50000, 0.2, 3.0, 0.2, 1, true,CompressionConfig::LZ4,
+ WriteableFileChunk::Config(CompressionConfig(), 16384))),
+ _fileHeaderContext(),
+ _executor(_config.getLogConfig().getNumThreads(), 128*1024),
+ _tlSyncer(),
+ _datastore(_executor, _myDir.getDir(), _config,
+ GrowStrategy(), TuneFileSummary(),
+ _fileHeaderContext, _tlSyncer, NULL),
+ _inserted(),
+ _serial(1)
+{ }
+VisitCacheStore::~VisitCacheStore() {}
+
void
verifyCacheStats(CacheStats cs, size_t hits, size_t misses, size_t elements, size_t memory_used) {
EXPECT_EQUAL(hits, cs.hits);