CubeDataThread.h

Go to the documentation of this file.

#ifndef CubeDataThread_h
#define CubeDataThread_h
 
/* SPDX-License-Identifier: CC0-1.0 */
 
#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