Cleanup VolumeDataRequestProcessor

src/VDS/VolumeDataRequestProcessor.cpp

@@ -39,6 +39,14 @@ VolumeDataRequestProcessor::VolumeDataRequestProcessor(VolumeDataAccessManagerIm
   , m_threadPool(std::thread::hardware_concurrency())
 {}
 
+VolumeDataRequestProcessor::~VolumeDataRequestProcessor()
+{
+  for (auto &pair : m_pageAccessors)
+  {
+    m_manager.DestroyVolumeDataPageAccessor(pair.second);
+  }
+}
+
 static int64_t GenJobId()
 {
   static std::atomic< std::int64_t > id(0);

src/VDS/VolumeDataRequestProcessor.h

@@ -75,6 +75,7 @@ class VolumeDataRequestProcessor
 {
 public:
   VolumeDataRequestProcessor(VolumeDataAccessManagerImpl &manager);
+  ~VolumeDataRequestProcessor();
 
   int64_t AddJob(const std::vector<VolumeDataChunk> &chunks, std::function<bool(VolumeDataPageImpl *page, const VolumeDataChunk &volumeDataChunk, Error &error)> processor);
   bool  IsCompleted(int64_t requestID);