diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-07-31 14:43:39 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-07-31 14:43:39 +0200 |
commit | 8e8a75183b89d67763f16bb074b9887bcf993fa8 (patch) | |
tree | 24d0dbe4f3fc770cd911ebbb927dd3adcaf145d2 /searchcore | |
parent | 0dae3d558b5f31c3458bfb9f93b6fea47a331517 (diff) |
More style changes in header file.
Diffstat (limited to 'searchcore')
-rw-r--r-- | searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp | 12 | ||||
-rw-r--r-- | searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.h | 153 |
2 files changed, 40 insertions, 125 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp b/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp index e264fbcf0dd..4c4a2f698b0 100644 --- a/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp +++ b/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp @@ -345,8 +345,7 @@ StoreOnlyFeedView::internalUpdate(FeedToken::UP token, const UpdateOperation &up considerEarlyAck(token, updOp.getType()); bool immediateCommit = _commitTimeTracker.needCommit(); - auto onWriteDone = createUpdateDoneContext(token, updOp.getType(), - _params._metrics, updOp.getUpdate()); + auto onWriteDone = createUpdateDoneContext(token, updOp.getType(), _params._metrics, updOp.getUpdate()); updateAttributes(serialNum, lid, upd, immediateCommit, onWriteDone); UpdateScope updateScope(getUpdateScope(upd)); /* @@ -366,8 +365,7 @@ StoreOnlyFeedView::internalUpdate(FeedToken::UP token, const UpdateOperation &up onWriteDone); } if (!updateScope._indexedFields && onWriteDone) { - if (onWriteDone->shouldTrace(1)) - { + if (onWriteDone->shouldTrace(1)) { token->trace(1, "Partial update applied."); } } @@ -396,11 +394,9 @@ StoreOnlyFeedView::updateIndexAndDocumentStore(bool indexedFieldsInScope, return; } if (upd.getId() == prevDoc->getId()) { - if (shouldTrace(onWriteDone, 1)) - { + if (shouldTrace(onWriteDone, 1)) { FeedToken *token = onWriteDone->getToken(); - token->trace(1, "The update looks like : " + - upd.toString(token->shouldTrace(2))); + token->trace(1, "The update looks like : " + upd.toString(token->shouldTrace(2))); } vespalib::nbostream os; prevDoc->serialize(os); diff --git a/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.h b/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.h index 17b94d1c6a6..8eef750ec42 100644 --- a/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.h +++ b/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.h @@ -133,9 +133,7 @@ protected: documentmetastore::ILidReuseDelayer &_lidReuseDelayer; CommitTimeTracker &_commitTimeTracker; - bool - useDocumentStore(SerialNum replaySerialNum) const - { + bool useDocumentStore(SerialNum replaySerialNum) const { return replaySerialNum > _params._flushedDocumentStoreSerialNum; } @@ -146,45 +144,20 @@ private: return replaySerialNum > _params._flushedDocumentMetaStoreSerialNum; } - void - adjustMetaStore(const DocumentOperation &op, - const document::DocumentId &docId); - - void - internalPut(FeedTokenUP token, - const PutOperation &putOp); - - void - internalUpdate(FeedTokenUP token, - const UpdateOperation &updOp); + void adjustMetaStore(const DocumentOperation &op, const document::DocumentId &docId); + void internalPut(FeedTokenUP token, const PutOperation &putOp); + void internalUpdate(FeedTokenUP token, const UpdateOperation &updOp); - void - updateIndexAndDocumentStore(bool indexedFieldsInScope, - SerialNum serialNum, - search::DocumentIdT lid, - const document::DocumentUpdate &upd, - bool immediateCommit, - OnOperationDoneType onWriteDone); - - bool - lookupDocId(const document::DocumentId &gid, - search::DocumentIdT & lid) const; - - void - internalRemove(FeedTokenUP token, - const RemoveOperation &rmOp); + bool lookupDocId(const document::DocumentId &gid, search::DocumentIdT & lid) const; + void internalRemove(FeedTokenUP token, const RemoveOperation &rmOp); // Removes documents from meta store and document store. // returns the number of documents removed. - size_t removeDocuments(const RemoveDocumentsOperation &op, - bool remove_index_and_attribute_fields, + size_t removeDocuments(const RemoveDocumentsOperation &op, bool remove_index_and_attribute_fields, bool immediateCommit); - void internalRemove(FeedTokenUP token, - SerialNum serialNum, - search::DocumentIdT lid, - FeedOperation::Type opType, - std::shared_ptr<search::IDestructorCallback> moveDoneCtx); + void internalRemove(FeedTokenUP token, SerialNum serialNum, search::DocumentIdT lid, + FeedOperation::Type opType, std::shared_ptr<search::IDestructorCallback> moveDoneCtx); // Ack token early if visibility delay is nonzero void considerEarlyAck(FeedTokenUP &token, FeedOperation::Type opType); @@ -202,106 +175,52 @@ protected: heartBeatAttributes(SerialNum serialNum); private: - virtual void - putAttributes(SerialNum serialNum, - search::DocumentIdT lid, - const document::Document &doc, - bool immediateCommit, - OnPutDoneType onWriteDone); + virtual void putAttributes(SerialNum serialNum, search::DocumentIdT lid, const document::Document &doc, + bool immediateCommit, OnPutDoneType onWriteDone); - virtual void - putIndexedFields(SerialNum serialNum, - search::DocumentIdT lid, - const document::Document::SP &newDoc, - bool immediateCommit, - OnOperationDoneType onWriteDone); + virtual void putIndexedFields(SerialNum serialNum, search::DocumentIdT lid, const document::Document::SP &newDoc, + bool immediateCommit, OnOperationDoneType onWriteDone); - virtual UpdateScope - getUpdateScope(const document::DocumentUpdate &upd); + virtual UpdateScope getUpdateScope(const document::DocumentUpdate &upd); - virtual void - updateAttributes(SerialNum serialNum, - search::DocumentIdT lid, - const document::DocumentUpdate &upd, - bool immediateCommit, - OnOperationDoneType onWriteDone); + virtual void updateAttributes(SerialNum serialNum, search::DocumentIdT lid, const document::DocumentUpdate &upd, + bool immediateCommit, OnOperationDoneType onWriteDone); - virtual void - updateIndexedFields(SerialNum serialNum, - search::DocumentIdT lid, - const document::Document::SP &newDoc, - bool immediateCommit, - OnOperationDoneType onWriteDone); + virtual void updateIndexedFields(SerialNum serialNum, search::DocumentIdT lid, const document::Document::SP &newDoc, + bool immediateCommit, OnOperationDoneType onWriteDone); - virtual void - removeAttributes(SerialNum serialNum, - search::DocumentIdT lid, - bool immediateCommit, - OnRemoveDoneType onWriteDone); + virtual void removeAttributes(SerialNum serialNum, search::DocumentIdT lid, + bool immediateCommit, OnRemoveDoneType onWriteDone); - virtual void - removeIndexedFields(SerialNum serialNum, - search::DocumentIdT lid, - bool immediateCommit, - OnRemoveDoneType onWriteDone); + virtual void removeIndexedFields(SerialNum serialNum, search::DocumentIdT lid, + bool immediateCommit, OnRemoveDoneType onWriteDone); protected: - virtual void - removeAttributes(SerialNum serialNum, - const LidVector &lidsToRemove, - bool immediateCommit, - OnWriteDoneType onWriteDone); + virtual void removeAttributes(SerialNum serialNum, const LidVector &lidsToRemove, + bool immediateCommit, OnWriteDoneType onWriteDone); - virtual void - removeIndexedFields(SerialNum serialNum, - const LidVector &lidsToRemove, - bool immediateCommit, - OnWriteDoneType onWriteDone); + virtual void removeIndexedFields(SerialNum serialNum, const LidVector &lidsToRemove, + bool immediateCommit, OnWriteDoneType onWriteDone); public: - StoreOnlyFeedView(const Context &ctx, - const PersistentParams ¶ms); + StoreOnlyFeedView(const Context &ctx, const PersistentParams ¶ms); virtual ~StoreOnlyFeedView() {} - const ISummaryAdapter::SP & - getSummaryAdapter() const { return _summaryAdapter; } - - const search::index::Schema::SP & - getSchema() const { return _schema; } - - const PersistentParams & - getPersistentParams() const { return _params; } - - const search::IDocumentStore & - getDocumentStore() const { return _summaryAdapter->getDocumentStore(); } - - const IDocumentMetaStoreContext::SP & - getDocumentMetaStore() const { return _documentMetaStoreContext; } - - searchcorespi::index::IThreadingService &getWriteService() { - return _writeService; - } - - documentmetastore::ILidReuseDelayer & - getLidReuseDelayer() - { - return _lidReuseDelayer; - } - + const ISummaryAdapter::SP &getSummaryAdapter() const { return _summaryAdapter; } + const search::index::Schema::SP &getSchema() const { return _schema; } + const PersistentParams &getPersistentParams() const { return _params; } + const search::IDocumentStore &getDocumentStore() const { return _summaryAdapter->getDocumentStore(); } + const IDocumentMetaStoreContext::SP &getDocumentMetaStore() const { return _documentMetaStoreContext; } + searchcorespi::index::IThreadingService &getWriteService() { return _writeService; } + documentmetastore::ILidReuseDelayer &getLidReuseDelayer() { return _lidReuseDelayer; } CommitTimeTracker &getCommitTimeTracker() { return _commitTimeTracker; } /** * Implements IFeedView. */ - virtual const document::DocumentTypeRepo::SP & - getDocumentTypeRepo() const override { return _repo; } - - /** - * Implements IFeedView. - */ - virtual const ISimpleDocumentMetaStore * - getDocumentMetaStorePtr() const override; + virtual const document::DocumentTypeRepo::SP &getDocumentTypeRepo() const override { return _repo; } + virtual const ISimpleDocumentMetaStore *getDocumentMetaStorePtr() const override; /** * Similar to IPersistenceHandler functions. |