aboutsummaryrefslogtreecommitdiffstats
path: root/searchcore
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@online.no>2021-11-23 11:23:52 +0100
committerTor Egge <Tor.Egge@online.no>2021-11-23 11:23:52 +0100
commit3b677d749ac574645dc8af558c755d6eedb5978e (patch)
tree3150159696e3d752b77e6eac5334eedfe612e5e1 /searchcore
parenteddbd9d4264e126fb862c0b33e952cec299e8a7c (diff)
Reduce document meta store commit rate.
Diffstat (limited to 'searchcore')
-rw-r--r--searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp6
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;