include/MessageController.h

Go to the documentation of this file.

#define MESSAGECONTROLLER_H 1

#ifndef _GLIBCXX_LIST
#include <list>
#endif

#ifndef _GLIBCXX_VECTOR
#include <vector>
#endif

#ifndef _GLIBCXX_STRING
#include <string>
#endif

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

#include <pthread.h>

using namespace boost;
using namespace std;

//forward declarations:
class Dispatcher;
class Comm;

class MessageController{
        private:
        Comm *comm;
        Dispatcher* disp;

        int cmode;                                      //      Communication mode.

        shared_ptr< list< shared_ptr< vector< shared_ptr< string > > > > > msgqueue;    //      Queue with messages.
        pthread_mutex_t mutex;
        pthread_cond_t cond;

        double currenttime;                     //      The current time of the visualisation.
        double timeflowfactor;          //      The speed of the the visualisation.

        pthread_t msgcontrollerthread;
        bool msgcontrollerthread_run;

        public:
        MessageController(Dispatcher *dp);
        ~MessageController();

        inline double getVisualisationTime(){ return currenttime / 1000; }
        bool processMessageFromComm(shared_ptr< vector< shared_ptr< string > > > messagebody);
        bool sendMessageToComm(shared_ptr< vector< shared_ptr< string > > > messagebody);
        bool communicationMode(int cMode, string filename);
        bool communicationMode(int cMode, string thisname, string thatname);
        bool setTimeFlow(double ntimeflowfactor);
        inline double getTimeFlow(){ return timeflowfactor; }
        friend void* msgcontrollerThread( void * args );
};

---