excalibur: prepare for exc block to wrap grk BlockExec

Author: Grok Compression

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

@@ -175,8 +175,8 @@ bool DecompressSchedulerExcalibur::scheduleT1(ITileProcessor* tileProcessor)
             block->R_b = prec_ + gain_b[band->orientation_];
             block->finalLayer_ = finalLayer;
 
-            tf::Task t = placeholder();
-            auto blockFunc = [this, activePool, tileProcessor, block, tccp, cbw, cbh, cacheAll] {
+            std::function<void()> op = [this, activePool, tileProcessor, block, tccp, cbw, cbh,
+                                        cacheAll] {
               if(success_)
               {
                 t1::ICoder* coder = nullptr;
@@ -203,7 +203,9 @@ bool DecompressSchedulerExcalibur::scheduleT1(ITileProcessor* tileProcessor)
                 }
               }
             };
-            t.work(blockFunc);
+            block->setOpen(op);
+            tf::Task t = placeholder();
+            t.work([block] { block->open(); });
           }
         }
       }

src/lib/core/t1/BlockExec.h

@@ -27,8 +27,15 @@
 namespace grk::t1
 {
 
-struct BlockExec
+struct IOpenable
 {
+  virtual void open() = 0;
+};
+
+struct BlockExec : public IOpenable
+{
+  using IOpenable::open;
+
   BlockExec() = default;
   virtual ~BlockExec() = default;
   virtual bool open(ICoder* coder) = 0;
@@ -64,6 +71,15 @@ struct DecompressBlockExec : public BlockExec
   {
     delete cachedCoder_;
   }
+  void setOpen(std::function<void()>& open)
+  {
+    open_ = open;
+  }
+  void open(void) override
+  {
+    if(open_)
+      open_();
+  }
   bool open(ICoder* coder) override
   {
     auto activeCoder = cachedCoder_ ? cachedCoder_ : coder;
@@ -99,14 +115,22 @@ struct DecompressBlockExec : public BlockExec
   bool shouldCacheCoder_ = false;
   bool finalLayer_ = false;
 
+private:
+  std::function<void()> open_;
+
   // Delete copy constructor and assignment operator
   DecompressBlockExec(const DecompressBlockExec&) = delete;
   DecompressBlockExec& operator=(const DecompressBlockExec&) = delete;
 };
 struct CompressBlockExec : public BlockExec
 {
+  using IOpenable::open;
+
   CompressBlockExec() = default;
   ~CompressBlockExec() = default;
+
+  void open(void) override {}
+
   bool open(ICoder* coder)
   {
     return coder->compress(this);