source: proiecte/SIMEO/Simeo/src/SimeoEngine/Agent.cpp @ 167

#include <stdio.h>
#include "Agent.h"


Agent::Agent(vector<Sensor *> sensorList, vector<Actuator *> actuatorList, vector<CommChannel *> channelList)
{
        m_sensorList = sensorList;
        m_actuatorList = actuatorList;
        m_channelList = channelList;
}

Agent::~Agent()
{
        int i;

        for (i = 0; i < (int) m_sensorList.size(); i++) {
                delete m_sensorList[i];
        }

        for (i = 0; i < (int) m_actuatorList.size(); i++) {
                delete m_actuatorList[i];
        }

        for (i = 0; i < (int) m_channelList.size(); i++) {
                delete m_channelList[i];
        }
}

void Agent::run()
{
        int i;
        int rank, stop = 0;
        MPI_Status status;

        MPI_Comm_rank(MPI_COMM_WORLD, &rank);

        while (!stop) {
                MPI_Recv(&stop, 1, MPI_INT, MASTER_ID, SYNC_MSG, MPI_COMM_WORLD, &status);

                for (i = 0; i < (int) m_sensorList.size(); i++) {
                        Sensor *x = m_sensorList[i];
                        x->update();
                }

                step();

                for (i = 0; i < (int) m_actuatorList.size(); i++) {
                        Actuator *x = m_actuatorList[i];
                        x->update();
                }

                MPI_Send(&stop, 1, MPI_INT, MASTER_ID, SYNC_MSG, MPI_COMM_WORLD);
        }
}