diff options
author | Tor Egge <Tor.Egge@online.no> | 2021-11-23 11:23:52 +0100 |
---|---|---|
committer | Tor Egge <Tor.Egge@online.no> | 2021-11-23 11:23:52 +0100 |
commit | 3b677d749ac574645dc8af558c755d6eedb5978e (patch) | |
tree | 3150159696e3d752b77e6eac5334eedfe612e5e1 /searchcore | |
parent | eddbd9d4264e126fb862c0b33e952cec299e8a7c (diff) |
Reduce document meta store commit rate.
Diffstat (limited to 'searchcore')
-rw-r--r-- | searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp | 6 |
1 files changed, 0 insertions, 6 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp b/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp index 5a7afcc584d..527eaff07cc 100644 --- a/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp +++ b/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp @@ -417,7 +417,6 @@ StoreOnlyFeedView::internalUpdate(FeedToken token, const UpdateOperation &updOp) bool updateOk = _metaStore.updateMetaData(updOp.getLid(), updOp.getBucketId(), updOp.getTimestamp()); assert(updateOk); (void) updateOk; - _metaStore.commit(CommitParam(serialNum)); } auto onWriteDone = createUpdateDoneContext(std::move(token), get_pending_lid_token(updOp), updOp.getUpdate()); @@ -605,7 +604,6 @@ StoreOnlyFeedView::adjustMetaStore(const DocumentOperation &op, const GlobalId & gate.await(); removeMetaData(_metaStore, gid, docId, op, _params._subDbType == SubDbType::REMOVED); } - _metaStore.commit(CommitParam(serialNum)); } } @@ -621,9 +619,6 @@ StoreOnlyFeedView::removeDocuments(const RemoveDocumentsOperation &op, bool remo const SerialNum serialNum = op.getSerialNum(); const LidVectorContext::SP &ctx = op.getLidsToRemove(_params._subDbId); if (!ctx) { - if (useDocumentMetaStore(serialNum)) { - _metaStore.commit(CommitParam(serialNum)); - } return 0; } const LidVector &lidsToRemove(ctx->getLidVector()); @@ -634,7 +629,6 @@ StoreOnlyFeedView::removeDocuments(const RemoveDocumentsOperation &op, bool remo _gidToLidChangeHandler.notifyRemoves(std::make_shared<vespalib::GateCallback>(gate), gidsToRemove, serialNum); gate.await(); _metaStore.removeBatch(lidsToRemove, ctx->getDocIdLimit()); - _metaStore.commit(CommitParam(serialNum)); _lidReuseDelayer.delayReuse(lidsToRemove); } std::shared_ptr<vespalib::IDestructorCallback> onWriteDone; |