diff options
author | Tor Egge <Tor.Egge@online.no> | 2021-11-18 11:31:10 +0100 |
---|---|---|
committer | Tor Egge <Tor.Egge@online.no> | 2021-11-18 11:31:10 +0100 |
commit | 259c0e6af4bea57cbfcb3ca27526566ee6b40c23 (patch) | |
tree | 43ae5602bb970937c5b55fba68107a46807f2086 /searchcore | |
parent | f302ccc48241cc631f2bf361e969335bdb70be7d (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.cpp | 2 | ||||
-rw-r--r-- | searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp | 3 |
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(), |