159201

as3_example.cpp

#include <iostream>
#include <fstream>
#include <locale>
#include <sstream>
#include <string>
using namespace std;

/* implement your Queue class here */
////////////////////////////////////////////////////////////////////////
#define TIMEDELAY 3 //DO NOT CHANGE THIS VALUE!!!
#define N 128       //DO NOT CHANGE THIS VALUE!!!
int OutQueues_current[N];
int Congestion_Size[N]; //for output queues

/*include your array of queues declarations somewhere here, for example: */

//Queue InputQueues[N];
//Queue OutputQueues[N];


void init_simulation()
{
    for(int a=0; a<N; a++)
    {
        OutQueues_current[a]    = 0;
        Congestion_Size[a]      = 0;
    }
}

int sum_elements_array(int array[])
{
    int sum=0;
    for(int a=0;a<N;a++)
    {
        sum=sum+array[a];
    }
    return sum;
}

int number_of_ports=0;

int main( int argc, char** argv )//get arguments from command line, the name of the simulation text file
{
    /**
     * @brief part I read into input queues
     */
    //! read the file, print the input ports contents
    int portnumber=0;
    int destination=0;
    //char oper;
    string expression;
    ifstream input_file;
    if(argc!=2)
    {
        cout<< "Type a file name. " << endl << argv[1] << endl;
        exit(0);
    }

    input_file.open(argv[1]);
    if(input_file.is_open()==false)
    {
        cout << "Could not read file: " << endl << argv[1] << endl;
        exit(0);
    }

    string token;
    while(!input_file.eof())
    {
        getline(input_file, expression);
        stringstream line(expression);
        if(input_file.eof())
            break;

        if(expression[0] =='#')
            continue;//jump line

        if(expression[0] =='P')
        {
            getline(line, token,' ');
            getline(line, token,' ');
            number_of_ports=atoi(token.c_str());
            //cout << "Found the number of ports to be " << number_of_ports << endl;
            continue;//got the number of ports
        }

        portnumber++;//get data for the next port
        cout << "Port " << portnumber << ": " << endl;//DEBUG, comment for final version

        while(getline(line, token,' ')) //one packet per iteration
        {
            if(token[0] == char(13)) continue;

            int destination = std::stoi(token);
            if (destination < 0 || destination > number_of_ports || number_of_ports<portnumber)
            {
                cout << "ERROR in the format of the text file" << endl;
                exit(0);
            }
            //
            // include the input queue code here:
            //  enqueue depending on the destination
            //
            cout << "destination " << destination << endl;//DEBUG, comment for final version
        }
        int sumofinputpackets=0;
        /*sumofinputpackets=sumofinputpackets+ ???*/
        cout    << "Input packets at input queue for port "
                << portnumber << " = " << sumofinputpackets << endl;
                //DEBUG, comment for final version
        cout    << "still zero,did not implement the queues yet..." << endl;
        //DEBUG, comment for final version
    }

    /**
     * @brief part II simulation
     */
    cout << endl << "Start of the simulation, press a key"
         << endl << endl;//DEBUG, comment for final version
    string geninput;
    getline(cin, geninput);// pause //DEBUG, comment for final version

    init_simulation();
    unsigned long int clock=0;
    unsigned long int currentsum=99999999;//sum_elements_array(OutQueues_current);
    portnumber=0;
    while(currentsum>0)
    {
        cout << "Input portnumber " << portnumber+1 << endl;//DEBUG
        /*if(QUEUE[portnumber])
         * {
                decide what to do with the queues here
           }
         */

        portnumber++;
        if(portnumber > (number_of_ports-1)) portnumber=0;

        clock++;
        if(clock % (TIMEDELAY*number_of_ports) == 0 && clock!=0) //DO NOT MODIFY THIS LINE!
        {
            cout << "Packets can leave the output queues at "
                 << clock << " microsec " << endl;//DEBUG, comment for final version
            for(int a=0; a<number_of_ports; a++)
            {
                //Delete 1 packet from each queue and count number of packets again
            }
        }
        //
        // include the queue updates for the simulation
        //
        //
        //compute the current state of the output queues
        cout << "Current sum: " << currentsum << endl;//DEBUG, comment for final version
        if(currentsum > sum_elements_array(Congestion_Size))
        {
            for(int a=0;a<number_of_ports;a++)
            {
                Congestion_Size[a] = OutQueues_current[a];
            }
        }
    }

    //FINAL PRINTOUT
    for(int a=0; a<number_of_ports; a++)
    {
        cout << "output port " << a+1 << ": " << Congestion_Size[a] << " packets" << endl;
    }
}