HDF5DataAdaptor.h

#ifndef HDF5_DataAdaptor_h
#define HDF5_DataAdaptor_h

#include "InTransitDataAdaptor.h"

#include <hdf5.h>
#include <map>
#include <mpi.h>
#include <string>
#include <svtkSmartPointer.h>

#include "HDF5Schema.h"

namespace sensei
{

//
// read from HDF and construct SVTK object
//
class SENSEI_EXPORT HDF5DataAdaptor : public InTransitDataAdaptor
{
public:
  static HDF5DataAdaptor *New();
  senseiTypeMacro(HDF5DataAdaptor, DataAdaptor);

  // int Open( const std::string& filename); // replaced to OpenStream()

  void SetStreamName(const std::string &name);
  void SetStreaming(bool s) { m_Streaming = s; }
  void SetCollective(bool s) { m_Collective = s; }

  // int Advance(); now is AdvanceStream()

  // int Close(); now is CloseStream()

  /// SENSEI DataAdaptor API
  int GetNumberOfMeshes(unsigned int &numMeshes) override;

  int GetMeshMetadata(unsigned int id, MeshMetadataPtr &metadata) override;

  int GetMesh(const std::string &meshName, bool structure_only,
              svtkDataObject *&mesh) override;

  int AddGhostNodesArray(svtkDataObject *mesh,
                         const std::string &meshName) override;
  int AddGhostCellsArray(svtkDataObject *mesh,
                         const std::string &meshName) override;

  int AddArray(svtkDataObject *mesh, const std::string &meshName,
               int association, const std::string &arrayName) override;

  int ReleaseData() override;

  // intransit:
  int OpenStream() override;
  int CloseStream() override;
  int AdvanceStream() override;
  int StreamGood() override;
  int Initialize(pugi::xml_node &parent) override;
  int Finalize() override;
  int GetSenderMeshMetadata(unsigned int id,
                            MeshMetadataPtr &metadata) override;

protected:
  HDF5DataAdaptor();
  ~HDF5DataAdaptor();

  // reads the current time step and time values from the stream
  // stores them in the base class information object
  int UpdateTimeStep();

private:
  // struct InternalsType;
  // InternalsType *Internals;
  senseiHDF5::ReadStream *m_HDF5Reader;

  bool m_Streaming = false;
  bool m_Collective = false;

  std::string m_StreamName;

  HDF5DataAdaptor(const HDF5DataAdaptor &) = delete;
  void operator=(const HDF5DataAdaptor &) = delete;
};

} // namespace sensei

#endif