request_manager.hpp

Go to the documentation of this file.

#ifndef REQUEST_MANAGER_HPP
#define REQUEST_MANAGER_HPP


#include <chrono>
#include <boost/asio.hpp>
#include <boost/thread/thread.hpp>

#include "server/job.hpp"

#include "settings.hpp"

class Configuration;
class Cache;
class Renderer;
class Geodata;
class StylesheetManager;
class HttpRequest;
class TileIdentifier;
class RenderCanvasFactory;

class RequestManager : public boost::enable_shared_from_this<RequestManager>
{
public:
    RequestManager( const shared_ptr<Configuration>& config, const shared_ptr<Geodata>& data, const shared_ptr<Renderer>& renderer, const shared_ptr<Cache>& cache, const shared_ptr<StylesheetManager>& ssm);
    ~RequestManager();

    void stop();

    TESTABLE void enqueue(const shared_ptr<HttpRequest>& r);
    TESTABLE void enqueue(const shared_ptr<MetaIdentifier>& ti);
    TESTABLE shared_ptr<Geodata> getGeodata() const;
    TESTABLE shared_ptr<StylesheetManager> getStylesheetManager() const;
    TESTABLE shared_ptr<Cache> getCache() const;
    TESTABLE shared_ptr<Renderer> getRenderer() const;

private:
    void processNextRequest();
    bool nextUserRequest();
    bool nextPreRenderRequest();

private:
    shared_ptr<Geodata> data;
    shared_ptr<Renderer> renderer;
    shared_ptr<Cache> cache;
    shared_ptr<StylesheetManager> ssm;
    shared_ptr<Configuration> config;

    boost::asio::io_service jobPool;
    boost::asio::io_service::work preventStop;
    std::vector< shared_ptr<boost::thread> > workers;

    std::queue<shared_ptr<RenderCanvasFactory>> factories;
    boost::mutex factoriesMutex;

    boost::mutex userRJMutex;
    boost::mutex preRJMutex;
    std::queue< shared_ptr<HttpRequest> > userRequests;
    std::queue< shared_ptr<MetaIdentifier> > preRenderRequests;

    class RunningQueue;
    scoped_ptr<RunningQueue> running;

    unsigned int currentPrerenderingThreads;

    std::chrono::system_clock::time_point prerender_start, prerender_stop;
};


#endif