CubeDataThread.h

#ifndef CubeDataThread_h
#define CubeDataThread_h

#include <QThread>

template<typename T> class QList;

template<typename A, typename B> struct QPair;
template<typename A, typename B> class QMap;

class QReadWriteLock;
class QMutex;

namespace Isis {
  class Cube;
  class FileName;
  class Brick;
  class UniversalGroundMap;

  class CubeDataThread : public QThread {
      Q_OBJECT

    public:
      CubeDataThread();
      virtual ~CubeDataThread();

      int AddCube(const FileName &fileName,
                  bool mustOpenReadWrite = false);
      int AddCube(Cube *cube);

      void RemoveCube(int cubeId);

      void AddChangeListener();
      void RemoveChangeListener();

      int BricksInMemory();

      UniversalGroundMap *GetUniversalGroundMap(int cubeId) const;

      const Cube *GetCube(int cubeId) const;
      int FindCubeId(const Cube *) const;

    public slots:
      void ReadCube(int cubeId, int startSample, int startLine,
                    int endSample, int endLine, int band, void *caller);
      void ReadWriteCube(int cubeId, int startSample, int startLine,
                         int endSample, int endLine, int band, void *caller);

      void DoneWithData(int, const Isis::Brick *);

    signals:

      void ReadReady(void *requester, int cubeId, const Isis::Brick *data);

      void ReadWriteReady(void *requester, int cubeId, Isis::Brick *data);

      void BrickChanged(int cubeId, const Isis::Brick *data);

    private:
      CubeDataThread(const CubeDataThread &cdt);

      const CubeDataThread &operator=(CubeDataThread rhs);

      int OverlapIndex(const Brick *initial, int cubeId,
                       int instanceNum, bool &exact);

      void GetCubeData(int cubeId, int ss, int sl, int es, int el, int band,
                       void *caller, bool sharedLock);

      void AcquireLock(QReadWriteLock *lockObject, bool readLock);

      bool FreeBrick(int brickIndex);

      QMap< int, QPair< bool, Cube * > > * p_managedCubes;

      QMutex *p_threadSafeMutex;

      QList< QPair<QReadWriteLock *, Brick *> > * p_managedData;

      QList< int > * p_managedDataSources;

      int p_numChangeListeners;

      unsigned int p_currentId;

      bool p_stopping;

      unsigned int p_currentLocksWaiting;
  };

};


#endif