UNet2/UNetExchange.h

#ifndef UNetExchange_H_
#define UNetExchange_H_
// -----------------------------------------------------------------------------
#include <ostream>
#include <string>
#include <queue>
#include <cc++/socket.h>
#include "UniSetObject_LT.h"
#include "Trigger.h"
#include "Mutex.h"
#include "SMInterface.h"
#include "SharedMemory.h"
#include "ThreadCreator.h"
#include "UNetReceiver.h"
#include "UNetSender.h"
// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
class UNetExchange:
    public UniSetObject_LT
{
    public:
        UNetExchange( UniSetTypes::ObjectId objId, UniSetTypes::ObjectId shmID, SharedMemory* ic=0 );
        virtual ~UNetExchange();
    
        static UNetExchange* init_unetexchange( int argc, const char* argv[],
                                            UniSetTypes::ObjectId shmID, SharedMemory* ic=0 );

        static void help_print( int argc, const char* argv[] );

        bool checkExistUNetHost( const std::string host, ost::tpport_t port );

    protected:

        xmlNode* cnode;
        std::string s_field;
        std::string s_fvalue;

        SMInterface* shm;
        void step();

        virtual void processingMessage( UniSetTypes::VoidMessage *msg );
        void sysCommand( UniSetTypes::SystemMessage *msg );
        void sensorInfo( UniSetTypes::SensorMessage*sm );
        void timerInfo( UniSetTypes::TimerMessage *tm );
        void askSensors( UniversalIO::UIOCommand cmd );
        void waitSMReady();
        void receiverEvent( UNetReceiver* r, UNetReceiver::Event ev );

        virtual bool activateObject();
        
        // действия при завершении работы
        virtual void sigterm( int signo );

        void initIterators();
        void startReceivers();
        

        enum Timer
        {
            tmStep
        };

    private:
        UNetExchange();
        bool initPause;
        UniSetTypes::uniset_mutex mutex_start;

        PassiveTimer ptHeartBeat;
        UniSetTypes::ObjectId sidHeartBeat;
        int maxHeartBeat;
        IOController::AIOStateList::iterator aitHeartBeat;
        UniSetTypes::ObjectId test_id;

        int steptime;   
        bool activated;
        int activateTimeout;

        struct ReceiverInfo
        {
            ReceiverInfo():r1(0),r2(0){}
            ReceiverInfo(UNetReceiver* _r1, UNetReceiver* _r2 ):r1(_r1),r2(_r2){}
            
            UNetReceiver* r1;   
            UNetReceiver* r2;   
        };
        
        typedef std::list<ReceiverInfo> ReceiverList;
        ReceiverList recvlist;

        bool no_sender;  
        UNetSender* sender;
        UNetSender* sender2;
};
// -----------------------------------------------------------------------------
#endif // UNetExchange_H_
// -----------------------------------------------------------------------------