UNetUDP/UNetExchange.h

#ifndef UNetExchange_H_
#define UNetExchange_H_
// -----------------------------------------------------------------------------
#include <ostream>
#include <string>
#include <queue>
#include <deque>
#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, const std::string& prefix="unet" );
        virtual ~UNetExchange();

        static UNetExchange* init_unetexchange( int argc, const char* argv[],
                                            UniSetTypes::ObjectId shmID, SharedMemory* ic=0, const std::string& prefix="unet" );

        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();

        void sysCommand( const UniSetTypes::SystemMessage *msg ) override;
        void sensorInfo( const UniSetTypes::SensorMessage*sm ) override;
        void timerInfo( const UniSetTypes::TimerMessage *tm ) override;
        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_rwmutex mutex_start;

        PassiveTimer ptHeartBeat;
        UniSetTypes::ObjectId sidHeartBeat;
        int maxHeartBeat;
        IOController::IOStateList::iterator itHeartBeat;
        UniSetTypes::ObjectId test_id;

        int steptime;    
        std::atomic_bool activated;
        int activateTimeout;

        struct ReceiverInfo
        {
            ReceiverInfo():r1(0),r2(0),
                sidRespond(UniSetTypes::DefaultObjectId),
                respondInvert(false),
                sidLostPackets(UniSetTypes::DefaultObjectId)
            {}

            ReceiverInfo(UNetReceiver* _r1, UNetReceiver* _r2 ):
                r1(_r1),r2(_r2),
                sidRespond(UniSetTypes::DefaultObjectId),
                respondInvert(false),
                sidLostPackets(UniSetTypes::DefaultObjectId)
            {}

            UNetReceiver* r1;      
            UNetReceiver* r2;    
            void step( SMInterface* shm, const std::string& myname );

            inline void setRespondID( UniSetTypes::ObjectId id, bool invert=false )
            { 
                sidRespond = id; 
                respondInvert = invert;
            }
            inline void setLostPacketsID( UniSetTypes::ObjectId id ){ sidLostPackets = id; }
            inline void initIterators( SMInterface* shm )
            {
                 shm->initIterator(itLostPackets);
                shm->initIterator(itRespond);
            }

            // Сводная информация по двум каналам
            // сумма потерянных пакетов и наличие связи
            // хотя бы по одному каналу
            // ( реализацию см. ReceiverInfo::step() )
            UniSetTypes::ObjectId sidRespond;
            IOController::IOStateList::iterator itRespond;
            bool respondInvert;
            UniSetTypes::ObjectId sidLostPackets;
            IOController::IOStateList::iterator itLostPackets;
        };

        typedef std::deque<ReceiverInfo> ReceiverList;
        ReceiverList recvlist;

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