IterativeReader.h

Go to the documentation of this file.

//                                                         //
// Copyright (c) 2003-2014 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.opensource.org/licenses/osl-3.0.php          //
//                                                         //


#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