include/Dispatcher.h

Go to the documentation of this file.

#define DISPATCHER_H

#include <stdlib.h>
#include <stdio.h>
#include <vector>
#include <map>
#include <string>
#include <queue>

#ifndef BOOST_SHARED_PTR_HPP_INCLUDED
#include <boost/shared_ptr.hpp>
#endif

//Forward declarations:
class StateControl;
class MessageController;

using namespace boost;
using namespace std;

class Dispatcher{

        public:
        Dispatcher();
        ~Dispatcher();
        bool proccessMessageFromMC(shared_ptr< vector< shared_ptr< string > > > msg);
        bool dispatchMessage();
        bool setSpdInSim(int id, double speed, double ts, double te);
        bool order(int Ris, int Rid, double ts, double tf);
        bool communicationMode(int cMode, string filename);
        bool communicationMode(int cMode, string thisName, string thatName);
        bool setTimeFlow(double flowFactor);
        double getTime();
        double getTimeFlow();

        private:
        StateControl* world; 
        MessageController* mc;
//      map<string, void*> stateFunc; 
        shared_ptr< queue< shared_ptr< vector< shared_ptr< string > > > > > parseQ; //A queue with messages.
        pthread_mutex_t* mutex_ptr;
        pthread_cond_t* cond_ptr;

        /*
         * Functions for parsing messages and calling functions in StateControl. 
         * If there is need for a new message a parse function should be added here.
   */   
        bool drvparse(shared_ptr< vector< shared_ptr< string > > >);
        bool loadparse(shared_ptr< vector< shared_ptr< string > > >);
        bool unloadparse(shared_ptr< vector< shared_ptr< string > > >);
        bool setspdparse(shared_ptr< vector< shared_ptr< string > > >);
        bool locationparse(shared_ptr< vector< shared_ptr< string > > >);
        bool trnewparse(shared_ptr< vector< shared_ptr< string > > >);
        bool trdelparse(shared_ptr< vector< shared_ptr< string > > >);
        bool newcargparse(shared_ptr< vector< shared_ptr< string > > >);
        bool rmcargparse(shared_ptr< vector< shared_ptr< string > > >);
        bool arcparse(shared_ptr< vector< shared_ptr< string > > >);
};

---