MessageQueue.h

Go to the documentation of this file.

#ifndef GlobeEngine_MessageQueue_h
#define GlobeEngine_MessageQueue_h

#include "OpenGL_Includes.h"
#include "Cache.h"
#include "Tile.h"
#include "Image.h"

#include <iostream>
#include <vector>
#include <sstream>
#include <string>
#include <QRunnable>
#include <QMutex>

namespace geSpatial {

    class MessageQueue
    {
        // set up a Cache with the tile Type
        typedef geSpatial::Cache< geSpatial::Tile > TileCache;
        
    public:
        MessageQueue();
        ~MessageQueue();
        
        void clear();
        void create();
        void create(unsigned int _capacity);
        //void requestTFSKey(std::shared_ptr<geSpatial::SpatialKey> _key, std::string _repositoryUR, std::string _fileExtensionL);
        
        //void requestKey(std::shared_ptr<geSpatial::SpatialKey> _key, int _fileType, std::string _repositoryURL, std::string _fileExtension);
//        void requestKey(std::shared_ptr<geSpatial::SpatialKey> _key, tileService::TileMapServiceInfo _tmsInfo);
        
        //void requestAsyncKey(std::shared_ptr<geSpatial::SpatialKey> _key, int _fileType, std::string _repositoryURL, std::string _fileExtension, std::shared_ptr<ge::Texture2Df> _tex);
        void waitForDone();
        //void setKeyToLoaded(std::shared_ptr<geSpatial::SpatialKey> _key);
        void startTileLoadingJob(int _fileType, std::string _repositoryURL, std::string _fileExtension);
        //void startAsyncTileLoadingJob(int _fileType, std::string _repositoryURL, std::string _fileExtension, std::shared_ptr<ge::Texture2Df> _tex);
        void startFeatureLoadingJob(std::string _repositoryURL)
        ;
        void clearCache();
        void setCacheCapacity(unsigned int _capacity);
        const std::vector< std::shared_ptr<geSpatial::Tile> >& getAllLoadedTiles();
        int getLoadedTileCount();
        
    protected:
        std::shared_ptr<geSpatial::CullableSpatialKey> setNextKeyToOpenRequest();
        // dynamic key vectors
        std::vector< std::shared_ptr<geSpatial::CullableSpatialKey> > requestedKeys;
        std::vector< std::shared_ptr<geSpatial::CullableSpatialKey> > openRequestKeys;
        std::vector< std::shared_ptr<geSpatial::CullableSpatialKey> > loadedKeys;
        
        std::shared_ptr<TileCache> tileFetchcache;
        QMutex loadedKeysMutex;
    }; 
}
#endif