Commit 13763cc8 authored by guj's avatar guj
Browse files

support BeginStep/Get(Sync)/EndStep

parent 8333e4b4

source/adios2/engine/hdf5/HDF5ReaderP.cpp

+4 −1
Original line number Diff line number Diff line
@@ -255,14 +255,17 @@ void HDF5ReaderP::UseHDFRead(Variable<T> &variable, T *data, hid_t h5Type) 


StepStatus HDF5ReaderP::BeginStep(StepMode mode, const float timeoutSeconds)

{

    // printf(".... in begin step: \n");

    m_InStreamMode = true;

    int ts = m_H5File.GetNumAdiosSteps();



    if (m_StreamAt >= ts)

    {

        return StepStatus::EndOfStream;

    }



    m_IO.RemoveAllVariables();

    m_H5File.ReadVariables(m_StreamAt, m_IO);



    return StepStatus::OK;

}

source/adios2/engine/hdf5/HDF5ReaderP.tcc

+5 −0
Original line number Diff line number Diff line
@@ -31,6 +31,11 @@ void HDF5ReaderP::GetSyncCommon(Variable<T> &variable, T *data) 
    */

    hid_t h5Type = m_H5File.GetHDF5Type<T>();

    //    UseHDFRead(variable.m_Name, data, h5Type);

    if (m_InStreamMode)

    {

        variable.m_StepsStart = m_StreamAt;

        variable.m_StepsCount = 1;

    }

    UseHDFRead(variable, data, h5Type);

}