IOpenable: add close method to interface

Author: Grok Compression

src/lib/core/scheduling/excalibur/DecompressSchedulerExcalibur.cpp

@@ -148,7 +148,7 @@ bool DecompressSchedulerExcalibur::scheduleT1(ITileProcessor* tileProcessor)
               continue;
 
             auto cblk = precinct->getDecompressBlock(cblkno);
-            auto block = new t1::DecompressBlockExec(cacheAll);
+            auto block = std::make_shared<t1::DecompressBlockExec>(cacheAll);
             block->x = cblk->x0();
             block->y = cblk->y0();
             // block->postProcessor_ =

src/lib/core/scheduling/excalibur/IOpenable.h

@@ -24,6 +24,7 @@ struct IOpenable
 {
   virtual ~IOpenable() = default;
   virtual void open() = 0;
+  virtual void close() = 0;
 };
 
 } // namespace exc

src/lib/core/t1/BlockExec.h

@@ -76,6 +76,13 @@ struct DecompressBlockExec : public BlockExec
     if(open_)
       open_();
   }
+  void close(void) override
+  {
+    delete cachedCoder_;
+    cachedCoder_ = nullptr;
+    if(cblk)
+      cblk->release();
+  }
   bool open(ICoder* coder) override
   {
     auto activeCoder = cachedCoder_ ? cachedCoder_ : coder;
@@ -120,18 +127,17 @@ struct DecompressBlockExec : public BlockExec
 };
 struct CompressBlockExec : public BlockExec
 {
-  using IOpenable::open;
-
   CompressBlockExec() = default;
   ~CompressBlockExec() override = default;
 
   void open(void) override {}
+  void close(void) override {}
 
   bool open(ICoder* coder) override
   {
     return coder->compress(this);
   }
-  void close(void) {}
+
   CodeblockCompress* cblk = nullptr;
   uint32_t tile_width = 0;
   bool doRateControl = false;