IterativeReader.h

Go to the documentation of this file.

//                                                         //
// Copyright (c) 2003-2017 by The University of Queensland //
// Centre for Geoscience Computing                         //
// http://earth.uq.edu.au/centre-geoscience-computing      //
//                                                         //
// Primary Business: Brisbane, Queensland, Australia       //
// Licensed under the Open Software License version 3.0    //
// http://www.apache.org/licenses/LICENSE-2.0              //
//                                                         //
 
 
#ifndef ESYS_LSMITERATIVEREADER_H
#define ESYS_LSMITERATIVEREADER_H
 
#include <sstream>
#include <memory>
 
namespace esys
{
  namespace lsm
  {
    template <class TmplData>
    class IStreamIterator
    {
    public:
      typedef TmplData value_type;
      
      IStreamIterator(std::istream &iStream, int numElements);
 
      virtual ~IStreamIterator();
 
      bool hasNext() const;
 
      const TmplData &next();
 
      int getNumRemaining() const;
 
    protected:
      IStreamIterator(const IStreamIterator &it);
      IStreamIterator &operator=(const IStreamIterator &it);
 
      virtual void readDataFromStream();
      
      std::istream *m_pIStream;
      TmplData     m_data;
      int          m_numRemaining;
    };
 
    template <class TmplIterator>
    class IterativeReader
    {
    public:
      typedef TmplIterator Iterator;
      
      IterativeReader(std::istream &iStream);
 
      virtual ~IterativeReader();
 
      virtual void initialise();
 
      int getNumElements() const;
 
      bool isInitialised() const;
 
      Iterator &getIterator();
 
      protected:
        typedef std::auto_ptr<Iterator> IteratorAutoPtr;
 
        void setNumElements(int numElements);
 
        std::istream &getIStream();
 
        const std::istream &getIStream() const;
 
        virtual Iterator *createNewIterator();
 
      private:
        
        int             m_numElements;
        std::istream    *m_pIStream;
        IteratorAutoPtr m_iteratorPtr;
    };
  }
}
 
#include "Parallel/IterativeReader.hpp"
 
#endif