Switch.cpp

Go to the documentation of this file.

 
#include "Switch.h"
 
#include <stdexcept>
 
Switch::Switch(std::unique_ptr<LoadBalancer> processing, std::unique_ptr<LoadBalancer> streaming)
    : processing_(std::move(processing)), streaming_(std::move(streaming)) {
    if (!processing_ || !streaming_) {
        throw std::invalid_argument("Switch needs two load balancers");
    }
}
 
bool Switch::route(const Request& request, unsigned long cycle) {
    if (request.jobType == JobType::Streaming) {
        ++routedStreaming_;
        return streaming_->admit(request, cycle);
    }
    ++routedProcessing_;
    return processing_->admit(request, cycle);
}
 
void Switch::start() {
    processing_->start();
    streaming_->start();
}
 
void Switch::processCycle(unsigned long cycle, const std::vector<Request>& arrivals) {
    std::vector<Request> processingArrivals;
    std::vector<Request> streamingArrivals;
    for (const Request& request : arrivals) {
        if (request.jobType == JobType::Streaming) {
            ++routedStreaming_;
            streamingArrivals.push_back(request);
        } else {
            ++routedProcessing_;
            processingArrivals.push_back(request);
        }
    }
    processing_->processCycle(cycle, processingArrivals);
    streaming_->processCycle(cycle, streamingArrivals);
}
 
LoadBalancer& Switch::processing() { return *processing_; }
 
LoadBalancer& Switch::streaming() { return *streaming_; }
 
unsigned long Switch::routedProcessing() const { return routedProcessing_; }
 
unsigned long Switch::routedStreaming() const { return routedStreaming_; }