station.h

Go to the documentation of this file.

#include "./../includes.h"
#ifndef STATION_H
#define STATION_H

class station
{
    long mxN; 
    std::vector<int> server_status; 
    std::vector<int> current_customer; 
    std::queue<int> current_queue; 
    std::vector<float> td; 
    int c; 
    int n; 
    int Na; 
    std::vector< std::tuple<int,float,int,int,float,float> > counter_variable; 
    using C_type = std::function<int(float t)>; 
    using event_type = std::function<float(float t)>; 
    C_type C; 
    event_type DepartureTimes; 
public:
    station(long init_mxN, C_type C_para, event_type dept_para, float t = 0, int init_n = 0)
        : C(C_para), DepartureTimes(dept_para)
    {
        mxN = init_mxN;

        server_status.assign(mxN, -1);
        current_customer.assign(mxN, -1);
        td.assign(mxN, INF);
        n = init_n;
        c = 0;
        this->server_updates((t - int(t)) + int(t) % 1440);
        Na = n;
        // Initialising n customers
        for (int j = 0; j < std::min(n, c); j++)
        {
            server_status[j] = 1;
            td[j] = DepartureTimes(0);
            current_customer[j] = j;
        }
        for (int i = std::min(n, c); i < n; i++)
        {
            current_queue.push(i);
        }
    }

    station(long init_mxN, C_type C_para, float init_dept, float t = 0, int init_n = 0)
        : C(C_para),
          DepartureTimes([init_dept](float t) -> float { return init_dept; })
    {
        mxN = init_mxN;

        server_status.assign(mxN, -1);
        current_customer.assign(mxN, -1);
        td.assign(mxN, INF);
        n = init_n;
        c = 0;
        this->server_updates((t - int(t)) + int(t) % 1440);
        Na = n;
        // Initialising n customers
        for (int j = 0; j < std::min(n, c); j++)
        {
            server_status[j] = 1;
            td[j] = DepartureTimes(0);
            current_customer[j] = j;
        }
        for (int i = std::min(n, c); i < n; i++)
        {
            current_queue.push(i);
        }
    }

    station(long init_mxN, int init_C, float init_dept, float t = 0, int init_n = 0)
        : C([init_C](float t) -> int { return init_C; }),
          DepartureTimes([init_dept](float t) -> float { return init_dept; })
    {
        mxN = init_mxN;

        server_status.assign(mxN, -1);
        current_customer.assign(mxN, -1);
        td.assign(mxN, INF);
        n = init_n;
        c = 0;
        this->server_updates((t - int(t)) + int(t) % 1440);
        Na = n;
        // Initialising n customers
        for (int j = 0; j < std::min(n, c); j++)
        {
            server_status[j] = 1;
            td[j] = DepartureTimes(0);
            current_customer[j] = j;
        }
        for (int i = std::min(n, c); i < n; i++)
        {
            current_queue.push(i);
        }
    }

    station(long init_mxN, int init_C, event_type init_dept, float t = 0, int init_n = 0)
        : C([init_C](float t) -> int { return init_C; }),
          DepartureTimes(init_dept)
    {
        mxN = init_mxN;

        server_status.assign(mxN, -1);
        current_customer.assign(mxN, -1);
        td.assign(mxN, INF);
        n = init_n;
        c = 0;
        this->server_updates((t - int(t)) + int(t) % 1440);
        Na = n;
        // Initialising n customers
        for (int j = 0; j < std::min(n, c); j++)
        {
            server_status[j] = 1;
            td[j] = DepartureTimes(0);
            current_customer[j] = j;
        }
        for (int i = std::min(n, c); i < n; i++)
        {
            current_queue.push(i);
        }
    }
    
    void print_station_status(float t);
    int find_min_k();
    float find_min_td();
    void server_updates(float t);
    int departure_updates(float t);
    void add_customer_to_station(float t,int customer_id);
    void write_to_csv(std::string file_name);
    std::vector<std::tuple<int, float, int, int, float, float>> get_counter_variable();
    int find_queue_len();
    void logger(int station_id, float t);
    void logger(std::string station_id, float t);
    void reset_queue(float t);
    float minimum_residual_time(float t);
    std::tuple<int,int,int> access_system_state(float t); 
    void initialize_CSV(std::string file_name);
    void dump_counter_variable_memory(std::string file_name);
    void dump_counter_variable_memory();
};


std::vector<float> read_csv(std::string filename,int index);
#endif