Remove unused method declaration and allign code.
@@ -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);
@@ -58,7 +50,6 @@ public:
private:
PersistenceUtil _env;
uint32_t _warnOnSlowOperations;
-
spi::PersistenceProvider& _spi;
ProcessAllHandler _processAllHandler;
MergeHandler _mergeHandler;
@@ -67,7 +58,6 @@ private:
framework::Thread::UP _thread;
spi::Context _context;
std::unique_ptr<BucketOwnershipNotifier> _bucketOwnershipNotifier;
-
vespalib::Monitor _flushMonitor;
bool _closed;
