include/MBTCPMaster.h

#ifndef _MBTCPMaster_H_
#define _MBTCPMaster_H_
// -----------------------------------------------------------------------------
#include <ostream>
#include <string>
#include <map>
#include <vector>
#include "MBExchange.h"
#include "modbus/ModbusTCPMaster.h"
// -----------------------------------------------------------------------------
// -----------------------------------------------------------------------------
class MBTCPMaster:
    public MBExchange
{
    public:
        MBTCPMaster( UniSetTypes::ObjectId objId, UniSetTypes::ObjectId shmID, SharedMemory* ic=0,
                        const std::string prefix="mbtcp" );
        virtual ~MBTCPMaster();
    
        static MBTCPMaster* 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 );

        UniSetTypes::uniset_mutex mbMutex;
        std::string iaddr;
//      ost::InetAddress* ia;
        int port;
        int recv_timeout;

//      virtual void step();
        virtual ModbusClient* initMB( bool reopen=false );
        
        void poll_thread();
        bool force_disconnect;

     private:
        MBTCPMaster();

        ModbusTCPMaster* mbtcp;

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