ConcurrentControlNetReader.h

Go to the documentation of this file.

#ifndef ConcurrentControlNetReader_h
#define ConcurrentControlNetReader_h

#include <QObject>
#include <QString>

#include "ControlNetFile.h"


template<typename A> class QAtomicPointer;
template<typename A> class QFutureWatcher;


namespace Isis {
  class ControlNet;
  class ControlPoint;
  class Distance;


  class ConcurrentControlNetReader : public QObject {
      Q_OBJECT

    public:
      ConcurrentControlNetReader();
      ~ConcurrentControlNetReader();
      void read(QString filename);


    signals:
      void progressRangeChanged(int, int);
      void progressValueChanged(int);
      void networkReadFinished(ControlNet *);


    private:
      void nullify();


    private slots:
      void startBuildingNetwork();
      void networkBuilt();


    private:
      QFutureWatcher<LatestControlNetFile *> * m_readWatcher;
      
      QFutureWatcher< QAtomicPointer<ControlNet> > * m_builderWatcher;
      
      LatestControlNetFile *m_versionerFile;

      int m_originalThreadCount;


    private:
      class ReadNetworkFunctor : public std::unary_function<
          void, LatestControlNetFile *> {

        public:
          ReadNetworkFunctor(QString);
          ~ReadNetworkFunctor();
          LatestControlNetFile *operator()() const;


        private:
          QString m_networkFileName;
      };


      class NetworkBuilder : public std::unary_function<
          const ControlPointFileEntryV0002 &, ControlPoint *> {

        public:
          NetworkBuilder(QString, QThread *);
          NetworkBuilder(NetworkBuilder const &);
          ~NetworkBuilder();
          ControlPoint * operator()(const ControlPointFileEntryV0002 &) const;
          NetworkBuilder & operator=(NetworkBuilder);

          static void addToNetwork(QAtomicPointer<ControlNet> &,
              ControlPoint * const &);


        private:
          void nullify();


        private:
          Distance *m_majorRad;

          Distance *m_minorRad;

          Distance *m_polarRad;

          QThread *m_targetThread;
      };
  };
}

#endif