RoundRobinDistributor.h

#ifndef ROUND_ROBIN_DISTRIBUTOR_H_
#define ROUND_ROBIN_DISTRIBUTOR_H_

#include <iostream>
#include <atomic>
#include <memory>
#include <limits>
#include <thread>
#include <mutex>
#include <chrono>
#include <condition_variable>
#include <queue>

#include "AbstractDistributor.h"


class RoundRobinDistributor: public AbstractDistributor {
public:
    RoundRobinDistributor(std::vector<struct Host*> *hosts);
    ~RoundRobinDistributor();

    virtual void sendToMaster(struct HttpRequest *request, int sock);
    virtual void distribute(struct HttpRequest *request, int sock);

    void execute();
private:
    std::atomic<unsigned int> read_counter;
    const unsigned int m_boundary = std::numeric_limits<unsigned int>::max() / 2;
    std::vector<std::thread> thread_pool;
    std::mutex m_queue_mtx;
    std::condition_variable m_queue_cv;

    struct RequestTuple {
        struct HttpRequest *request;
        int host;
        int socket;
        bool is_write;
    };
    std::queue<struct RequestTuple*> m_parsedRequests;
};

#endif