LoadBalancer.h

Go to the documentation of this file.

 
#ifndef LOADBALANCER_H
#define LOADBALANCER_H
 
#include <string>
#include <thread>
#include <mutex>
#include <vector>
#include "Request.h"
#include "Queue.h"
#include "WebServer.h"
 
class LoadBalancer {
public:
    LoadBalancer(int numberServers);
 
    ~LoadBalancer();
 
    void start();
 
    void stop();
 
    void sendRequest(const Request& req); 
 
    void evaluate();
 
    void work();
 
private:
    size_t originalRequestSize_;                     
    int lastEvaluationQueueSize_;                     
    int numberServers_;                               
    int requestsProcessed_;                           
    int serversAdded_;                                
    int serversSubtracted_;                           
    std::vector<std::unique_ptr<WebServer>> webServers_; 
    Queue requestQueue_;                              
    std::mutex coutMutex_;                           
    std::mutex webServersMutex_;                      
    std::mutex requestQueueMutex_;                   
    std::thread loadBalancerThread_;                  
    bool shouldStop_;                                 
};
 
#endif // LOADBALANCER_H