(Modbus): продолжаю работу над выносом общего кода в MBTCPMaster и RTUExchange

extensions/MBTCPMaster/MBTCPMaster.h

@@ -196,152 +196,9 @@ class MBTCPMaster:
 
 		void execute();
 	
-		enum Timer
-		{
-			tmExchange
-		};
-
-		// -----------------------------------------------------
-		struct RTUDevice;
-		struct RegInfo;
-
-		struct RSProperty:
-			public IOBase
-		{
-			// only for RTU
-			short nbit;				/*!< bit number) */
-			VTypes::VType vType;	/*!< type of value */
-			short rnum;				/*!< count of registers */
-			short nbyte;			/*!< byte number (1-2) */
-			
-			RSProperty():
-				nbit(-1),vType(VTypes::vtUnknown),
-				rnum(VTypes::wsize(VTypes::vtUnknown)),
-				nbyte(0),reg(0)
-			{}
-
-			RegInfo* reg;
-		};
-
-		friend std::ostream& operator<<( std::ostream& os, const RSProperty& p );
-
-		typedef std::list<RSProperty> PList;
-		static std::ostream& print_plist( std::ostream& os, PList& p );
-
-		typedef unsigned long RegID;
-
-		typedef std::map<RegID,RegInfo*> RegMap;
-		struct RegInfo
-		{
-			RegInfo():
-				mbval(0),mbreg(0),mbfunc(ModbusRTU::fnUnknown),
-				id(0),dev(0),mtrType(MTR::mtUnknown),
-				q_num(0),q_count(1),mb_initOK(true),sm_initOK(true)
-			{}
-
-			ModbusRTU::ModbusData mbval;
-			ModbusRTU::ModbusData mbreg;			/*!< регистр */
-			ModbusRTU::SlaveFunctionCode mbfunc;	/*!< функция для чтения/записи */
-			PList slst;
-			RegID id;
-
-			RTUDevice* dev;
-
-			// only for MTR
-			MTR::MTRType mtrType;	/*!< тип регистра (согласно спецификации на MTR) */
-			
-			// optimization
-			int q_num;		/*!< number in query */
-			int q_count;	/*!< count registers for query */
-			
-			RegMap::iterator rit;
-
-			// начальная инициалиазция для "записываемых" регистров
-			// Механизм:
-			// Если tcp_preinit="1", то сперва будет сделано чтение значения из устройства.
-			// при этом флаг mb_init=false пока не пройдёт успешной инициализации
-			// Если tcp_preinit="0", то флаг mb_init сразу выставляется в true.
-			bool mb_initOK;	/*!< инициализировалось ли значение из устройства */
-
-			// Флаг sm_init означает, что писать в устройство нельзя, т.к. значение в "карте регистров"
-			// ещё не инициализировано из SM
-			bool sm_initOK;	/*!< инициализировалось ли значение из SM */
-		};
-
-		friend std::ostream& operator<<( std::ostream& os, RegInfo& r );
-
-		struct RTUDevice
-		{
-			RTUDevice():
-			respnond(false),
-			mbaddr(0),
-			dtype(dtUnknown),
-			resp_id(UniSetTypes::DefaultObjectId),
-			resp_state(false),
-			resp_invert(false),
-			resp_real(false),
-			resp_init(false),
-			ask_every_reg(false)
-			{
-				resp_trTimeout.change(false);
-			}
-			
-			bool respnond;
-			ModbusRTU::ModbusAddr mbaddr;	/*!< адрес устройства */
-			RegMap regmap;
-
-			DeviceType dtype;	/*!< тип устройства */
-
-			UniSetTypes::ObjectId resp_id;
-			IOController::DIOStateList::iterator resp_dit;
-			PassiveTimer resp_ptTimeout;
-			Trigger resp_trTimeout;
-			bool resp_state;
-			bool resp_invert;
-			bool resp_real;
-			bool resp_init;
-			bool ask_every_reg;
-
-			// return TRUE if state changed
-			bool checkRespond();
-
-		};
-
-		friend std::ostream& operator<<( std::ostream& os, RTUDevice& d );
-		
-		typedef std::map<ModbusRTU::ModbusAddr,RTUDevice*> RTUDeviceMap;
-
-		friend std::ostream& operator<<( std::ostream& os, RTUDeviceMap& d );
-		void printMap(RTUDeviceMap& d);
-// ----------------------------------
-		static RegID genRegID( const ModbusRTU::ModbusData r, const int fn );
-		
 	protected:
-		struct InitRegInfo
-		{
-			InitRegInfo():
-			dev(0),mbreg(0),
-			mbfunc(ModbusRTU::fnUnknown),
-			initOK(false),ri(0)
-			{}
-			RSProperty p;
-			RTUDevice* dev;
-			ModbusRTU::ModbusData mbreg;
-			ModbusRTU::SlaveFunctionCode mbfunc;
-			bool initOK;
-			RegInfo* ri;
-		};
-		typedef std::list<InitRegInfo> InitList;
+		virtual void sysCommand( UniSetTypes::SystemMessage *sm );
 
-		void firstInitRegisters();
-		bool preInitRead( InitList::iterator& p );
-		bool initSMValue( ModbusRTU::ModbusData* data, int count, RSProperty* p );
-		bool allInitOK;
-	  
-		RTUDeviceMap rmap;
-		InitList initRegList;	/*!< список регистров для инициализации */
-		
-		ModbusTCPMaster* mb;
 		UniSetTypes::uniset_mutex mbMutex;
 		std::string iaddr;
 //		ost::InetAddress* ia;
@@ -349,62 +206,23 @@ class MBTCPMaster:
 		int recv_timeout;
 
 		virtual void step();
-		void poll_thread();
-		void poll();
-		bool pollRTU( RTUDevice* dev, RegMap::iterator& it );
+		virtual ModbusClient* initMB( bool reopen=false );
 		
-		void updateSM();
-		void updateRTU(RegMap::iterator& it);
-		void updateMTR(RegMap::iterator& it);
-		void updateRSProperty( RSProperty* p, bool write_only=false );
+		void poll_thread();
 		void updateRespondSensors();
 
-		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 initOutput();
-		void initMB( bool reopen=false );
-
-		virtual bool activateObject();
 		virtual void sigterm( int signo );
-		virtual void initIterators();
-		virtual bool initItem( UniXML_iterator& it );
-		void initDeviceList();
-		void initOffsetList();
-
-		RTUDevice* addDev( RTUDeviceMap& dmap, ModbusRTU::ModbusAddr a, UniXML_iterator& it );
-		RegInfo* addReg( RegMap& rmap, RegID id, ModbusRTU::ModbusData r, UniXML_iterator& it,
-							RTUDevice* dev, RegInfo* rcopy=0 );
-		RSProperty* addProp( PList& plist, RSProperty& p );
-
-		bool initMTRitem( UniXML_iterator& it, RegInfo* p );
-		bool initRSProperty( RSProperty& p, UniXML_iterator& it );
-		bool initRegInfo( RegInfo* r, UniXML_iterator& it, RTUDevice* dev  );
-		bool initRTUDevice( RTUDevice* d, UniXML_iterator& it );
-		bool initDeviceInfo( RTUDeviceMap& m, ModbusRTU::ModbusAddr a, UniXML_iterator& it );
 		
-		void rtuQueryOptimization( RTUDeviceMap& m );
-
-		bool no_extimer;
 		bool force_disconnect;
 
-		timeout_t stat_time; 		/*!< время сбора статистики обмена */
-		int poll_count;
-		PassiveTimer ptStatistic;   /*!< таймер для сбора статистики обмена */
-
 	 private:
 		MBTCPMaster();
 
+		ModbusTCPMaster* mbtcp;
+
 		// т.к. TCP может "зависнуть" на подключении к недоступному узлу
 		// делаем опрос в отдельном потоке
 		ThreadCreator<MBTCPMaster>* pollThread; /*!< поток опроса */
-		bool pollActivated;
-		UniSetTypes::uniset_mutex pollMutex;
-
-		// определение timeout для соединения
-		PassiveTimer ptTimeout;
 		UniSetTypes::uniset_mutex tcpMutex;
 };
 // -----------------------------------------------------------------------------

extensions/MBTCPMaster/start_fg.sh

 #!/bin/sh
 
-./uniset-start.sh -f ./uniset-mbtcpmaster \
+./uniset-start.sh -g ./uniset-mbtcpmaster \
 --confile test.xml \
 --mbtcp-name MBMaster1 \
 --smemory-id SharedMemory \

extensions/RTUExchange/RTUExchange.h

@@ -97,8 +97,6 @@ class RTUExchange:
 
 		friend std::ostream& operator<<( std::ostream& os, RegInfo& r );
 
-
-
 		struct RTUDevice
 		{
 			RTUDevice():

extensions/include/MBExchange.h

@@ -17,6 +17,7 @@
 #include "IOBase.h"
 #include "VTypes.h"
 #include "MTR.h"
+#include "modbus/ModbusClient.h"
 // -----------------------------------------------------------------------------
 // -----------------------------------------------------------------------------
 /*!
@@ -56,14 +57,179 @@ class MBExchange:
 
 		static DeviceType getDeviceType( const std::string dtype );
 		friend std::ostream& operator<<( std::ostream& os, const DeviceType& dt );
-	
-	protected:
+
+		struct RTUDevice;
+		struct RegInfo;
+
+		struct RSProperty:
+			public IOBase
+		{
+			// only for RTU
+			short nbit;				/*!< bit number) */
+			VTypes::VType vType;	/*!< type of value */
+			short rnum;				/*!< count of registers */
+			short nbyte;			/*!< byte number (1-2) */
+			
+			RSProperty():
+				nbit(-1),vType(VTypes::vtUnknown),
+				rnum(VTypes::wsize(VTypes::vtUnknown)),
+				nbyte(0),reg(0)
+			{}
+
+			RegInfo* reg;
+		};
+
+		friend std::ostream& operator<<( std::ostream& os, const RSProperty& p );
+
+		typedef std::list<RSProperty> PList;
+		static std::ostream& print_plist( std::ostream& os, PList& p );
+
+		typedef unsigned long RegID;
+
+		typedef std::map<RegID,RegInfo*> RegMap;
+		struct RegInfo
+		{
+			RegInfo():
+				mbval(0),mbreg(0),mbfunc(ModbusRTU::fnUnknown),
+				id(0),dev(0),
+//				rtuJack(RTUStorage::nUnknown),rtuChan(0),
+				mtrType(MTR::mtUnknown),
+				q_num(0),q_count(1),mb_initOK(true),sm_initOK(true)
+			{}
+
+			ModbusRTU::ModbusData mbval;
+			ModbusRTU::ModbusData mbreg;			/*!< регистр */
+			ModbusRTU::SlaveFunctionCode mbfunc;	/*!< функция для чтения/записи */
+			PList slst;
+			RegID id;
+
+			RTUDevice* dev;
+
+			// only for RTU188
+//			RTUStorage::RTUJack rtuJack;
+//			int rtuChan;
+
+			// only for MTR
+			MTR::MTRType mtrType;	/*!< тип регистра (согласно спецификации на MTR) */
+			
+			// optimization
+			int q_num;		/*!< number in query */
+			int q_count;	/*!< count registers for query */
+			
+			RegMap::iterator rit;
+
+			// начальная инициалиазция для "записываемых" регистров
+			// Механизм:
+			// Если tcp_preinit="1", то сперва будет сделано чтение значения из устройства.
+			// при этом флаг mb_init=false пока не пройдёт успешной инициализации
+			// Если tcp_preinit="0", то флаг mb_init сразу выставляется в true.
+			bool mb_initOK;	/*!< инициализировалось ли значение из устройства */
+
+			// Флаг sm_init означает, что писать в устройство нельзя, т.к. значение в "карте регистров"
+			// ещё не инициализировано из SM
+			bool sm_initOK;	/*!< инициализировалось ли значение из SM */
+		};
+
+		friend std::ostream& operator<<( std::ostream& os, RegInfo& r );
+
+		struct RTUDevice
+		{
+			RTUDevice():
+			respnond(false),
+			mbaddr(0),
+			dtype(dtUnknown),
+			resp_id(UniSetTypes::DefaultObjectId),
+			resp_state(false),
+			resp_invert(false),
+			resp_real(false),
+			resp_init(false),
+			ask_every_reg(false)
+			{
+				resp_trTimeout.change(false);
+			}
+			
+			bool respnond;
+			ModbusRTU::ModbusAddr mbaddr;	/*!< адрес устройства */
+			RegMap regmap;
+
+			DeviceType dtype;	/*!< тип устройства */
+
+			UniSetTypes::ObjectId resp_id;
+			IOController::DIOStateList::iterator resp_dit;
+			PassiveTimer resp_ptTimeout;
+			Trigger resp_trTimeout;
+			bool resp_state;
+			bool resp_invert;
+			bool resp_real;
+			bool resp_init;
+			bool ask_every_reg;
+
+			// return TRUE if state changed
+			bool checkRespond();
+
+		};
+
+		friend std::ostream& operator<<( std::ostream& os, RTUDevice& d );
 		
+		typedef std::map<ModbusRTU::ModbusAddr,RTUDevice*> RTUDeviceMap;
+
+		friend std::ostream& operator<<( std::ostream& os, RTUDeviceMap& d );
+		void printMap(RTUDeviceMap& d);
+		
+		// ----------------------------------
+		static RegID genRegID( const ModbusRTU::ModbusData r, const int fn );	
+
+		enum Timer
+		{
+			tmExchange
+		};
+
+	protected:
 		virtual void step();
-		virtual void sensorInfo( UniSetTypes::SensorMessage* sm );
+		virtual void processingMessage( UniSetTypes::VoidMessage *msg );
+		virtual void sysCommand( UniSetTypes::SystemMessage *msg );
+		virtual void sensorInfo( UniSetTypes::SensorMessage*sm );
+		virtual void timerInfo( UniSetTypes::TimerMessage *tm );
+		virtual void askSensors( UniversalIO::UIOCommand cmd );	
+		virtual void initOutput();
 		virtual void sigterm( int signo );
-		virtual bool initItem( UniXML_iterator& it ){ return false; }
+		virtual bool activateObject();
 		virtual void initIterators();
+
+		struct InitRegInfo
+		{
+			InitRegInfo():
+			dev(0),mbreg(0),
+			mbfunc(ModbusRTU::fnUnknown),
+			initOK(false),ri(0)
+			{}
+			RSProperty p;
+			RTUDevice* dev;
+			ModbusRTU::ModbusData mbreg;
+			ModbusRTU::SlaveFunctionCode mbfunc;
+			bool initOK;
+			RegInfo* ri;
+		};
+		typedef std::list<InitRegInfo> InitList;
+
+		void firstInitRegisters();
+		bool preInitRead( InitList::iterator& p );
+		bool initSMValue( ModbusRTU::ModbusData* data, int count, RSProperty* p );
+		bool allInitOK;
+	  
+		RTUDeviceMap rmap;
+		InitList initRegList;	/*!< список регистров для инициализации */
+		UniSetTypes::uniset_mutex pollMutex;
+
+		virtual ModbusClient* initMB( bool reopen=false )=0;
+		
+		void poll();
+		bool pollRTU( RTUDevice* dev, RegMap::iterator& it );
+		
+		void updateSM();
+		void updateRTU(RegMap::iterator& it);
+		void updateMTR(RegMap::iterator& it);
+		void updateRSProperty( RSProperty* p, bool write_only=false );
 		
 		bool checkUpdateSM( bool wrFunc );
 		bool checkPoll( bool wrFunc );
@@ -74,6 +240,22 @@ class MBExchange:
 
 		void readConfiguration();
 		bool readItem( UniXML& xml, UniXML_iterator& it, xmlNode* sec );
+		bool initItem( UniXML_iterator& it );
+		void initDeviceList();
+		void initOffsetList();
+
+		RTUDevice* addDev( RTUDeviceMap& dmap, ModbusRTU::ModbusAddr a, UniXML_iterator& it );
+		RegInfo* addReg( RegMap& rmap, RegID id, ModbusRTU::ModbusData r, UniXML_iterator& it,
+							RTUDevice* dev, RegInfo* rcopy=0 );
+		RSProperty* addProp( PList& plist, RSProperty& p );
+
+		bool initMTRitem( UniXML_iterator& it, RegInfo* p );
+		bool initRSProperty( RSProperty& p, UniXML_iterator& it );
+		bool initRegInfo( RegInfo* r, UniXML_iterator& it, RTUDevice* dev  );
+		bool initRTUDevice( RTUDevice* d, UniXML_iterator& it );
+		bool initDeviceInfo( RTUDeviceMap& m, ModbusRTU::ModbusAddr a, UniXML_iterator& it );
+
+		void rtuQueryOptimization( RTUDeviceMap& m );
 
 		xmlNode* cnode;
 		std::string s_field;
@@ -103,8 +285,8 @@ class MBExchange:
 		UniSetTypes::uniset_mutex actMutex;
 		bool activated;
 		int activateTimeout;
-
 		bool noQueryOptimization;
+		bool no_extimer;
 		
 		std::string prefix;
 		
@@ -112,6 +294,14 @@ class MBExchange:
 		int poll_count;
 		PassiveTimer ptStatistic;   /*!< таймер для сбора статистики обмена */
 
+		std::string prop_prefix;  /*!< префикс для считывания параметров обмена */
+		
+		ModbusClient* mb;
+
+		// определение timeout для соединения
+		PassiveTimer ptTimeout;
+		bool pollActivated;
+
 	 private:
 		MBExchange();