enable operator plugins to pass user parameters when reading

ornladios · Feb 23, 2022 · 2f089cb · 2f089cb
1 parent 8c43017
commit 2f089cb
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 2 deletions.
diff --git a/source/adios2/toolkit/format/bp/bp3/BP3Deserializer.tcc b/source/adios2/toolkit/format/bp/bp3/BP3Deserializer.tcc
@@ -528,7 +528,17 @@ void BP3Deserializer::PostDataRead(
         char *preOpData = m_ThreadBuffers[threadID][0].data();
         const char *postOpData = m_ThreadBuffers[threadID][1].data();
 
-        core::Decompress(postOpData, blockOperationInfo.PayloadSize, preOpData);
+        std::shared_ptr<core::Operator> op = nullptr;
+        for (auto &o : blockInfo.Operations)
+        {
+            if (o->m_Category == "compress" || o->m_Category == "plugin")
+            {
+                op = o;
+                break;
+            }
+        }
+        core::Decompress(postOpData, blockOperationInfo.PayloadSize, preOpData,
+                         op);
 
         // clip block to match selection
         helper::ClipVector(m_ThreadBuffers[threadID][0],

diff --git a/source/adios2/toolkit/format/bp/bp4/BP4Deserializer.tcc b/source/adios2/toolkit/format/bp/bp4/BP4Deserializer.tcc
@@ -535,7 +535,7 @@ void BP4Deserializer::PostDataRead(
         std::shared_ptr<core::Operator> op = nullptr;
         for (auto &o : blockInfo.Operations)
         {
-            if (o->m_Category == "compress")
+            if (o->m_Category == "compress" || o->m_Category == "plugin")
             {
                 op = o;
                 break;