include/MBTCPMultiMaster.h

#ifndef _MBTCPMultiMaster_H_
#define _MBTCPMultiMaster_H_
// -----------------------------------------------------------------------------
#include <ostream>
#include <string>
#include <map>
#include <vector>
#include "MBExchange.h"
#include "modbus/ModbusTCPMaster.h"
// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
class MBTCPMultiMaster:
    public MBExchange
{
    public:
        MBTCPMultiMaster( UniSetTypes::ObjectId objId, UniSetTypes::ObjectId shmID, SharedMemory* ic=0,
                        const std::string prefix="mbtcp" );
        virtual ~MBTCPMultiMaster();
    
        static MBTCPMultiMaster* init_mbmaster( int argc, const char* const* argv, 
                                            UniSetTypes::ObjectId shmID, SharedMemory* ic=0,
                                            const std::string prefix="mbtcp" );

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

    protected:
        virtual void sysCommand( UniSetTypes::SystemMessage *sm );
        virtual void initIterators();
        virtual ModbusClient* initMB( bool reopen=false );
        void poll_thread();
        void check_thread();

        UniSetTypes::uniset_mutex mbMutex;
        int recv_timeout;
        bool force_disconnect;
        int checktime;

     private:
        MBTCPMultiMaster();

        struct MBSlaveInfo
        {
            MBSlaveInfo():ip(""),port(0),mbtcp(0),priority(0),
                respond(false),respond_id(UniSetTypes::DefaultObjectId),respond_invert(false),
                recv_timeout(200),aftersend_pause(0),sleepPause_usec(100),
                force_disconnect(true),
                myname(""),initOK(false){}

            std::string ip;
            int port;
            ModbusTCPMaster* mbtcp;
            int priority;
            
            bool respond;
            UniSetTypes::ObjectId respond_id;
            IOController::DIOStateList::iterator respond_dit;
            bool respond_invert;

            inline bool operator < ( const MBSlaveInfo& mbs ) const
            {
                return priority < mbs.priority;
            }

            bool init();
            bool check();

            int recv_timeout;
            int aftersend_pause;
            int sleepPause_usec;
            bool force_disconnect;
            
            std::string myname;

            bool initOK;
        };

        typedef std::list<MBSlaveInfo> MBGateList;

        MBGateList mblist;
        MBGateList::reverse_iterator mbi;

        // т.к. TCP может "зависнуть" на подключении к недоступному узлу
        // делаем опрос в отдельном потоке
        ThreadCreator<MBTCPMultiMaster>* pollThread; 
        UniSetTypes::uniset_mutex tcpMutex;

        ThreadCreator<MBTCPMultiMaster>* checkThread; 
};
// -----------------------------------------------------------------------------
#endif // _MBTCPMultiMaster_H_
// -----------------------------------------------------------------------------