Merge pull request #2805 from pnorbert/fix-streamreader-flag

fix: IO object has a flag m_ReadStreaming set to false initially but …
ornladios · Jul 30, 2021 · 7adcf1c · 7adcf1c
2 parents 696fabf + 2bfb07f
commit 7adcf1c
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 0 deletions.
diff --git a/source/adios2/engine/bp3/BP3Reader.cpp b/source/adios2/engine/bp3/BP3Reader.cpp
@@ -126,6 +126,9 @@ void BP3Reader::Init()
             " " + m_EndMessage);
     }
 
+    // if IO was involved in reading before this flag may be true now
+    m_IO.m_ReadStreaming = false;
+
     InitTransports();
     InitBuffer();
 }

diff --git a/source/adios2/engine/bp4/BP4Reader.cpp b/source/adios2/engine/bp4/BP4Reader.cpp
@@ -148,6 +148,8 @@ void BP4Reader::Init()
                                     "supports OpenMode::Read from" +
                                     m_Name + " " + m_EndMessage);
     }
+    // if IO was involved in reading before this flag may be true now
+    m_IO.m_ReadStreaming = false;
 
     m_BP4Deserializer.Init(m_IO.m_Parameters, "in call to BP4::Open to write");
     InitTransports();

diff --git a/source/adios2/engine/bp5/BP5Reader.cpp b/source/adios2/engine/bp5/BP5Reader.cpp
@@ -180,6 +180,9 @@ void BP5Reader::Init()
                                     m_Name + " " + m_EndMessage);
     }
 
+    // if IO was involved in reading before this flag may be true now
+    m_IO.m_ReadStreaming = false;
+
     ParseParams(m_IO, m_Parameters);
     m_ReaderIsRowMajor = helper::IsRowMajor(m_IO.m_HostLanguage);
     InitTransports();