1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "summaryadapter.h"
#include <vespa/searchcore/proton/docsummary/summarymanager.h>
#include <vespa/vespalib/objects/nbostream.h>
#include <cassert>
#include <cinttypes>
#include <vespa/log/log.h>
LOG_SETUP(".proton.server.summaryadapter");
using namespace document;
namespace proton {
SummaryAdapter::SummaryAdapter(SummaryManager::SP mgr)
: _mgr(std::move(mgr)),
_lastSerial(_mgr->getBackingStore().lastSyncToken())
{}
SummaryAdapter::~SummaryAdapter() = default;
bool SummaryAdapter::ignore(SerialNum serialNum) const
{
assert(serialNum != 0);
return serialNum <= _lastSerial;
}
ISummaryManager & SummaryAdapter::imgr() const { return *_mgr; }
void
SummaryAdapter::put(SerialNum serialNum, const DocumentIdT lid, const Document &doc)
{
if ( ! ignore(serialNum) ) {
LOG(spam, "SummaryAdapter::put(serialnum = '%" PRIu64 "', lid = %u, docId = '%s', document = '%s')",
serialNum, lid, doc.getId().toString().c_str(), doc.toString(true).c_str());
_mgr->putDocument(serialNum, lid, doc);
_lastSerial = serialNum;
}
}
void
SummaryAdapter::put(SerialNum serialNum, const DocumentIdT lid, const vespalib::nbostream &os)
{
if ( ! ignore(serialNum) ) {
LOG(spam, "SummaryAdapter::put(serialnum = '%" PRIu64 "', lid = %u, stream size = '%zd')",
serialNum, lid, os.size());
_mgr->putDocument(serialNum, lid, os);
_lastSerial = serialNum;
}
}
void
SummaryAdapter::remove(SerialNum serialNum, const DocumentIdT lid)
{
if ( ! ignore(serialNum + 1) ) {
LOG(spam, "SummaryAdapter::remove(serialnum = '%" PRIu64 "', lid = %u)", serialNum, lid);
_mgr->removeDocument(serialNum, lid);
_lastSerial = serialNum;
}
}
void
SummaryAdapter::heartBeat(SerialNum serialNum)
{
if (serialNum > _lastSerial) {
remove(serialNum, 0u); // XXX: Misused lid 0
}
}
const search::IDocumentStore &
SummaryAdapter::getDocumentStore() const {
return imgr().getBackingStore();
}
std::unique_ptr<Document>
SummaryAdapter::get(const DocumentIdT lid, const DocumentTypeRepo &repo)
{
auto result = imgr().getBackingStore().read(lid, repo);
LOG(spam, "SummaryAdapter::get(lid = %u, docId = '%s', document = '%s')",
lid, (result ? result->getId().toString().c_str() : "null"), (result ? result->toString(true).c_str() : "null"));
return result;
}
void
SummaryAdapter::compactLidSpace(uint32_t wantedDocIdLimit) {
_mgr->getBackingStore().compactLidSpace(wantedDocIdLimit);
}
} // namespace proton
|
