aboutsummaryrefslogtreecommitdiffstats
path: root/searchcore
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@online.no>2021-11-18 11:31:10 +0100
committerTor Egge <Tor.Egge@online.no>2021-11-18 11:31:10 +0100
commit259c0e6af4bea57cbfcb3ca27526566ee6b40c23 (patch)
tree43ae5602bb970937c5b55fba68107a46807f2086 /searchcore
parentf302ccc48241cc631f2bf361e969335bdb70be7d (diff)
Commit document meta store as part of feed view force commit
Diffstat (limited to 'searchcore')
-rw-r--r--searchcore/src/tests/proton/docsummary/docsummary.cpp2
-rw-r--r--searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp3
2 files changed, 4 insertions, 1 deletions
diff --git a/searchcore/src/tests/proton/docsummary/docsummary.cpp b/searchcore/src/tests/proton/docsummary/docsummary.cpp
index d190d39ff80..5c3fe94a8d7 100644
--- a/searchcore/src/tests/proton/docsummary/docsummary.cpp
+++ b/searchcore/src/tests/proton/docsummary/docsummary.cpp
@@ -251,8 +251,8 @@ public:
PutRes putRes(dms.put(docId.getGlobalId(), BucketFactory::getBucketId(docId),
Timestamp(0u), docSize, lid, 0u));
LOG_ASSERT(putRes.ok());
- dms.commit(CommitParam(0u));
uint64_t serialNum = _ddb->getFeedHandler().inc_serial_num();
+ dms.commit(CommitParam(serialNum));
_aw->put(serialNum, doc, lid, std::shared_ptr<IDestructorCallback>());
{
vespalib::Gate gate;
diff --git a/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp b/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp
index c9a0892d3c3..01b6212308e 100644
--- a/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp
+++ b/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp
@@ -175,6 +175,9 @@ StoreOnlyFeedView::Context::~Context() = default;
void
StoreOnlyFeedView::forceCommit(const CommitParam & param, DoneCallback onDone)
{
+ if (useDocumentMetaStore(param.lastSerialNum())) {
+ _metaStore.commit(param);
+ }
internalForceCommit(param, std::make_shared<ForceCommitContext>(_writeService.master(), _metaStore,
_pendingLidsForCommit->produceSnapshot(),
_gidToLidChangeHandler.grab_pending_changes(),