aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-10-13 13:18:10 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2017-10-13 13:18:10 +0200
commit37080afcba0c5f059631092e4cb345c6a144cc4f (patch)
tree60733321edeb6457c698e5d132804c7c506383e9
parent5eaf803e6bbf278976f18a44db60ce0cba5edc75 (diff)
Remove unused method declaration and allign code.
-rw-r--r--storage/src/vespa/storage/persistence/persistencethread.h34
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);