diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-10-13 13:18:10 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-10-13 13:18:10 +0200 |
commit | 37080afcba0c5f059631092e4cb345c6a144cc4f (patch) | |
tree | 60733321edeb6457c698e5d132804c7c506383e9 | |
parent | 5eaf803e6bbf278976f18a44db60ce0cba5edc75 (diff) |
Remove unused method declaration and allign code.
-rw-r--r-- | storage/src/vespa/storage/persistence/persistencethread.h | 34 |
1 files changed, 12 insertions, 22 deletions
diff --git a/storage/src/vespa/storage/persistence/persistencethread.h b/storage/src/vespa/storage/persistence/persistencethread.h index e9ab36bd7ed..4d714dc878a 100644 --- a/storage/src/vespa/storage/persistence/persistencethread.h +++ b/storage/src/vespa/storage/persistence/persistencethread.h @@ -19,27 +19,19 @@ class TestAndSetHelper; class PersistenceThread final : public DiskThread, public Types { public: - PersistenceThread(ServiceLayerComponentRegister&, - const config::ConfigUri & configUri, - spi::PersistenceProvider& provider, - FileStorHandler& filestorHandler, - FileStorThreadMetrics& metrics, - uint16_t deviceIndex, - uint8_t lowestPriority); + PersistenceThread(ServiceLayerComponentRegister&, const config::ConfigUri & configUri, + spi::PersistenceProvider& provider, FileStorHandler& filestorHandler, + FileStorThreadMetrics& metrics, uint16_t deviceIndex, uint8_t lowestPriority); ~PersistenceThread(); /** Waits for current operation to be finished. */ void flush() override; - - bool isMerging(const BucketId& bucket) const; - framework::Thread& getThread() override { return *_thread; } MessageTracker::UP handlePut(api::PutCommand& cmd); MessageTracker::UP handleRemove(api::RemoveCommand& cmd); MessageTracker::UP handleUpdate(api::UpdateCommand& cmd); MessageTracker::UP handleGet(api::GetCommand& cmd); - MessageTracker::UP handleMultiOperation(api::MultiOperationCommand& cmd); MessageTracker::UP handleRevert(api::RevertCommand& cmd); MessageTracker::UP handleCreateBucket(api::CreateBucketCommand& cmd); @@ -56,20 +48,18 @@ public: MessageTracker::UP handleRecheckBucketInfo(RecheckBucketInfoCommand& cmd); private: - PersistenceUtil _env; - uint32_t _warnOnSlowOperations; - + PersistenceUtil _env; + uint32_t _warnOnSlowOperations; spi::PersistenceProvider& _spi; - ProcessAllHandler _processAllHandler; - MergeHandler _mergeHandler; - DiskMoveOperationHandler _diskMoveHandler; + ProcessAllHandler _processAllHandler; + MergeHandler _mergeHandler; + DiskMoveOperationHandler _diskMoveHandler; ServiceLayerComponent::UP _component; - framework::Thread::UP _thread; - spi::Context _context; + framework::Thread::UP _thread; + spi::Context _context; std::unique_ptr<BucketOwnershipNotifier> _bucketOwnershipNotifier; - - vespalib::Monitor _flushMonitor; - bool _closed; + vespalib::Monitor _flushMonitor; + bool _closed; void setBucketInfo(MessageTracker& tracker, const document::BucketId& bucketId); |