diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-05-12 18:13:42 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-05-12 18:13:42 +0000 |
commit | 59e9c48c4b5e800f9439d06541df22a62d85f2e2 (patch) | |
tree | 1375d499f40d21a8f6e371867104938e282d0917 /searchcore | |
parent | 5a71e52a3938bc2c56285e73983fdcaa65354ef9 (diff) |
Various cleanup when reading code.
Diffstat (limited to 'searchcore')
4 files changed, 24 insertions, 43 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/server/removedonecontext.h b/searchcore/src/vespa/searchcore/proton/server/removedonecontext.h index 485b82dd141..5eea6f7faaf 100644 --- a/searchcore/src/vespa/searchcore/proton/server/removedonecontext.h +++ b/searchcore/src/vespa/searchcore/proton/server/removedonecontext.h @@ -14,7 +14,7 @@ struct IDocumentMetaStore; /** - * Context class for document removes that acks remove andschedules a + * Context class for document removes that acks remove and schedules a * task when instance is destroyed. Typically a shared pointer to an * instance is passed around to multiple worker threads that performs * portions of a larger task before dropping the shared pointer, diff --git a/searchcore/src/vespa/searchcore/proton/server/removedonetask.cpp b/searchcore/src/vespa/searchcore/proton/server/removedonetask.cpp index c66a5d949e6..49a7490b263 100644 --- a/searchcore/src/vespa/searchcore/proton/server/removedonetask.cpp +++ b/searchcore/src/vespa/searchcore/proton/server/removedonetask.cpp @@ -5,17 +5,14 @@ namespace proton { -RemoveDoneTask::RemoveDoneTask(IDocumentMetaStore &documentMetaStore, - uint32_t lid) +RemoveDoneTask::RemoveDoneTask(IDocumentMetaStore &documentMetaStore, uint32_t lid) : vespalib::Executor::Task(), _documentMetaStore(documentMetaStore), _lid(lid) { } -RemoveDoneTask::~RemoveDoneTask() -{ -} +RemoveDoneTask::~RemoveDoneTask() = default; void RemoveDoneTask::run() diff --git a/searchcore/src/vespa/searchcore/proton/server/removedonetask.h b/searchcore/src/vespa/searchcore/proton/server/removedonetask.h index d9059e6ad6a..1aa59c6d37f 100644 --- a/searchcore/src/vespa/searchcore/proton/server/removedonetask.h +++ b/searchcore/src/vespa/searchcore/proton/server/removedonetask.h @@ -29,12 +29,10 @@ class RemoveDoneTask : public vespalib::Executor::Task public: - RemoveDoneTask(IDocumentMetaStore &documentMetaStore, - uint32_t lid); + RemoveDoneTask(IDocumentMetaStore &documentMetaStore, uint32_t lid); + ~RemoveDoneTask() override; - virtual ~RemoveDoneTask(); - - virtual void run() override; + void run() override; }; diff --git a/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp b/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp index 6066fef68d8..df9ff54e29e 100644 --- a/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp +++ b/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp @@ -49,9 +49,7 @@ private: public: PutDoneContextForMove(FeedToken token, IPendingLidTracker::Token uncommitted, - std::shared_ptr<const Document> doc, - uint32_t lid, - IDestructorCallback::SP moveDoneCtx) + std::shared_ptr<const Document> doc, uint32_t lid, IDestructorCallback::SP moveDoneCtx) : PutDoneContext(std::move(token), std::move(uncommitted),std::move(doc), lid), _moveDoneCtx(std::move(moveDoneCtx)) {} @@ -60,25 +58,21 @@ public: std::shared_ptr<PutDoneContext> createPutDoneContext(FeedToken token, IPendingLidTracker::Token uncommitted, - std::shared_ptr<const Document> doc, - uint32_t lid, - IDestructorCallback::SP moveDoneCtx) + std::shared_ptr<const Document> doc, uint32_t lid, IDestructorCallback::SP moveDoneCtx) { std::shared_ptr<PutDoneContext> result; if (moveDoneCtx) { result = std::make_shared<PutDoneContextForMove>(std::move(token), std::move(uncommitted), std::move(doc), lid, std::move(moveDoneCtx)); } else { - result = std::make_shared<PutDoneContext>(std::move(token), std::move(uncommitted), - std::move(doc), lid); + result = std::make_shared<PutDoneContext>(std::move(token), std::move(uncommitted), std::move(doc), lid); } return result; } std::shared_ptr<PutDoneContext> createPutDoneContext(FeedToken token, IPendingLidTracker::Token uncommitted, - std::shared_ptr<const Document> doc, - uint32_t lid) + std::shared_ptr<const Document> doc, uint32_t lid) { return createPutDoneContext(std::move(token), std::move(uncommitted), std::move(doc), lid, IDestructorCallback::SP()); @@ -106,10 +100,8 @@ private: public: RemoveDoneContextForMove(FeedToken token, IPendingLidTracker::Token uncommitted, vespalib::Executor &executor, - IDocumentMetaStore &documentMetaStore, - uint32_t lid, IDestructorCallback::SP moveDoneCtx) - : RemoveDoneContext(std::move(token), std::move(uncommitted), executor, - documentMetaStore, lid), + IDocumentMetaStore &documentMetaStore, uint32_t lid, IDestructorCallback::SP moveDoneCtx) + : RemoveDoneContext(std::move(token), std::move(uncommitted), executor, documentMetaStore, lid), _moveDoneCtx(std::move(moveDoneCtx)) {} ~RemoveDoneContextForMove() override = default; @@ -117,13 +109,11 @@ public: std::shared_ptr<RemoveDoneContext> createRemoveDoneContext(FeedToken token, IPendingLidTracker::Token uncommitted, vespalib::Executor &executor, - IDocumentMetaStore &documentMetaStore, - uint32_t lid, IDestructorCallback::SP moveDoneCtx) + IDocumentMetaStore &documentMetaStore, uint32_t lid, IDestructorCallback::SP moveDoneCtx) { if (moveDoneCtx) { return std::make_shared<RemoveDoneContextForMove> - (std::move(token), std::move(uncommitted), executor, documentMetaStore, - lid, std::move(moveDoneCtx)); + (std::move(token), std::move(uncommitted), executor, documentMetaStore, lid, std::move(moveDoneCtx)); } else { return std::make_shared<RemoveDoneContext> (std::move(token), std::move(uncommitted), executor, documentMetaStore, lid); @@ -163,8 +153,8 @@ void putMetaData(documentmetastore::IStore &meta_store, const DocumentId & doc_i const DocumentOperation &op, bool is_removed_doc) { documentmetastore::IStore::Result putRes( - meta_store.put(doc_id.getGlobalId(), - op.getBucketId(), op.getTimestamp(), op.getSerializedDocSize(), op.getLid(), op.get_prepare_serial_num())); + meta_store.put(doc_id.getGlobalId(), op.getBucketId(), op.getTimestamp(), + op.getSerializedDocSize(), op.getLid(), op.get_prepare_serial_num())); if (!putRes.ok()) { throw IllegalStateException( make_string("Could not put <lid, gid> pair for %sdocument with id '%s' and gid '%s'", @@ -312,14 +302,13 @@ StoreOnlyFeedView::internalPut(FeedToken token, const PutOperation &putOp) if (putOp.changedDbdId() && useDocumentMetaStore(serialNum)) { _gidToLidChangeHandler.notifyPut(token, docId.getGlobalId(), putOp.getLid(), serialNum); } - std::shared_ptr<PutDoneContext> onWriteDone = - createPutDoneContext(std::move(token), std::move(uncommitted), - doc, putOp.getLid()); + auto onWriteDone = createPutDoneContext(std::move(token), std::move(uncommitted), doc, putOp.getLid()); putSummary(serialNum, putOp.getLid(), doc, onWriteDone); putAttributes(serialNum, putOp.getLid(), *doc, onWriteDone); putIndexedFields(serialNum, putOp.getLid(), doc, onWriteDone); } if (docAlreadyExists && putOp.changedDbdId()) { + //TODO, better to have an else than an assert ? assert(!putOp.getValidDbdId(_params._subDbId)); internalRemove(std::move(token), _pendingLidsForCommit->produce(putOp.getPrevLid()), serialNum, putOp.getPrevLid(), IDestructorCallback::SP()); @@ -602,6 +591,7 @@ StoreOnlyFeedView::internalRemove(FeedToken token, const RemoveOperationWithDocI } if (rmOp.getValidPrevDbdId(_params._subDbId)) { if (rmOp.changedDbdId()) { + //TODO Prefer else over assert ? assert(!rmOp.getValidDbdId(_params._subDbId)); internalRemove(std::move(token), _pendingLidsForCommit->produce(rmOp.getPrevLid()), serialNum, rmOp.getPrevLid(), IDestructorCallback::SP()); @@ -630,14 +620,11 @@ StoreOnlyFeedView::internalRemove(FeedToken token, const RemoveOperationWithGid void StoreOnlyFeedView::internalRemove(FeedToken token, IPendingLidTracker::Token uncommitted, SerialNum serialNum, - Lid lid, - IDestructorCallback::SP moveDoneCtx) + Lid lid, IDestructorCallback::SP moveDoneCtx) { bool explicitReuseLid = _lidReuseDelayer.delayReuse(lid); - std::shared_ptr<RemoveDoneContext> onWriteDone; - onWriteDone = createRemoveDoneContext(std::move(token), std::move(uncommitted),_writeService.master(), _metaStore, - (explicitReuseLid ? lid : 0u), - std::move(moveDoneCtx)); + auto onWriteDone = createRemoveDoneContext(std::move(token), std::move(uncommitted), _writeService.master(), _metaStore, + (explicitReuseLid ? lid : 0u), std::move(moveDoneCtx)); removeSummary(serialNum, lid, onWriteDone); removeAttributes(serialNum, lid, onWriteDone); removeIndexedFields(serialNum, lid, onWriteDone); @@ -786,9 +773,8 @@ StoreOnlyFeedView::handleMove(const MoveOperation &moveOp, IDestructorCallback:: if (moveOp.changedDbdId() && useDocumentMetaStore(serialNum)) { _gidToLidChangeHandler.notifyPut(FeedToken(), docId.getGlobalId(), moveOp.getLid(), serialNum); } - std::shared_ptr<PutDoneContext> onWriteDone = - createPutDoneContext(FeedToken(), _pendingLidsForCommit->produce(moveOp.getLid()), - doc, moveOp.getLid(), doneCtx); + auto onWriteDone = createPutDoneContext(FeedToken(), _pendingLidsForCommit->produce(moveOp.getLid()), + doc, moveOp.getLid(), doneCtx); putSummary(serialNum, moveOp.getLid(), doc, onWriteDone); putAttributes(serialNum, moveOp.getLid(), *doc, onWriteDone); putIndexedFields(serialNum, moveOp.getLid(), doc, onWriteDone); |