diff --git a/source/adios2/engine/bp3/BP3Reader.cpp b/source/adios2/engine/bp3/BP3Reader.cpp index e0ff9077d7..ef56c5d6f4 100644 --- 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 index 681da602de..eef53f7774 100644 --- 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 index b4e78c8f49..7bd94e3bde 100644 --- 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();