Merge branch 'master' of git.eter:/projects/asu/uniset

TODO

@@ -13,9 +13,6 @@
 
 - Сделать ObjectIndex_ArrayXML. т.е. использовать vector, при этом считывая индексы из XML.
 
-- Везде где используется sstream и вызов str(), надо делать ss.rdbuf()->freeze(0);
-(http://www.intuit.ru/department/pl/cpp/17/2.html)
-
 - (IONotifyController): Разработать механизм заказа переодических уведомлений (msec), независимо от того, менялись ли датчики..
 - (IONotifyController): Разработать механизм заказа группы датчиков сразу (и ответ тоже группой)
 

Utilities/MBTester/Makefile.am

@@ -6,7 +6,8 @@ uniset_mbrtutest_SOURCES 	= mbrtutester.cc
 uniset_mbrtutest_LDADD 	= $(top_builddir)/lib/libUniSet.la
 
 uniset_mbtcptest_SOURCES 	= mbtcptester.cc
-uniset_mbtcptest_LDADD 	= $(top_builddir)/lib/libUniSet.la
+uniset_mbtcptest_LDADD 	= $(top_builddir)/lib/libUniSet.la $(COMCPP_LIBS)
+uniset_mbtcptest_CPPFLAGS = $(COMCPP_CFLAGS)
 
 uniset_mbrtuslave_echo_SOURCES 	= MBSlave.cc mbrtuslave.cc
 uniset_mbrtuslave_echo_LDADD 		= $(top_builddir)/lib/libUniSet.la $(SIGC_LIBS)

Utilities/NullController/main.cc

@@ -10,6 +10,7 @@ using namespace std;
 static void short_usage()
 {
 	cout << "Usage: uniset-nullController"
+	 	 << "--confile configure.xml. По умолчанию: configure.xml." << endl
 		 << " --name ObjectId [--confile configure.xml] [--askfile filename] \n"
 		 << " --s-filter-field name - поле для фильтрования списка датчиков\n"
 		 << " --s-filter-value value - значение для поля фильтрования списка датчиков \n"

Utilities/SImitator/main.cc

@@ -8,6 +8,7 @@ using namespace UniSetTypes;
 void help_print()
 {
 	cout << endl;
+	cout << "--confile configure.xml. По умолчанию: configure.xml." << endl;
 	cout << "--sid id1@Node1,id2,..,idXX@NodeXX  - Аналоговые датчики (AI,AO)" << endl;
 	cout << endl;
 	cout << "--min val       - Нижняя граница датчика. По умолчанию 0" << endl;

Utilities/SImitator/start_fg.sh

@@ -4,7 +4,7 @@ ulimit -Sc 1000000
 
 #for i in `seq 1 20`; 
 #do
-	uniset-start.sh -f ./uniset-simitator --confile test.xml --sid 10@localhost,9@3002
+	uniset-start.sh -f ./uniset-simitator --confile test.xml --sid 34
 #done
 
 #wait

Utilities/codegen/ctl-cpp-common.xsl

@@ -13,6 +13,15 @@
 	<xsl:when test="$iotype='AI'">long</xsl:when>
 </xsl:choose>
 </xsl:template>
+<xsl:template name="gettype">
+	<xsl:param name="iotype"/>
+<xsl:choose>
+	<xsl:when test="$iotype='DO'">UniversalIO::DigitalOutput</xsl:when>
+	<xsl:when test="$iotype='DI'">UniversalIO::DigitalInput</xsl:when>
+	<xsl:when test="$iotype='AO'">UniversalIO::AnalogOutput</xsl:when>
+	<xsl:when test="$iotype='AI'">UniversalIO::AnalogInput</xsl:when>
+</xsl:choose>
+</xsl:template>
 
 <xsl:template name="setprefix">
 <xsl:choose>
@@ -433,6 +442,7 @@ void <xsl:value-of select="$CLASSNAME"/>_SK::waitSM( int wait_msec, ObjectId _te
 <xsl:if test="normalize-space(@const)!=''">
 <xsl:if test="normalize-space(@type)='int'"><xsl:value-of select="normalize-space(@name)"/>(0),</xsl:if>
 <xsl:if test="normalize-space(@type)='float'"><xsl:value-of select="normalize-space(@name)"/>(0),</xsl:if>
+<xsl:if test="normalize-space(@type)='double'"><xsl:value-of select="normalize-space(@name)"/>(0),</xsl:if>
 <xsl:if test="normalize-space(@type)='bool'"><xsl:value-of select="normalize-space(@name)"/>(false),</xsl:if>
 <xsl:if test="normalize-space(@type)='str'"><xsl:value-of select="normalize-space(@name)"/>(""),</xsl:if>
 </xsl:if>
@@ -444,6 +454,9 @@ void <xsl:value-of select="$CLASSNAME"/>_SK::waitSM( int wait_msec, ObjectId _te
 <xsl:if test="normalize-space(@type)='float'">
 <xsl:value-of select="normalize-space(@name)"/>(atof( init3_str(conf->getArgParam("--<xsl:value-of select="../@arg_prefix"/><xsl:value-of select="@name"/>"),conf->getProp(cnode,"<xsl:value-of select="@name"/>"),"<xsl:value-of select="normalize-space(@default)"/>").c_str())),
 </xsl:if>
+<xsl:if test="normalize-space(@type)='double'">
+<xsl:value-of select="normalize-space(@name)"/>(atof( init3_str(conf->getArgParam("--<xsl:value-of select="../@arg_prefix"/><xsl:value-of select="@name"/>"),conf->getProp(cnode,"<xsl:value-of select="@name"/>"),"<xsl:value-of select="normalize-space(@default)"/>").c_str())),
+</xsl:if>
 <xsl:if test="normalize-space(@type)='bool'">
 <xsl:value-of select="normalize-space(@name)"/>(uni_atoi( init3_str(conf->getArgParam("--<xsl:value-of select="../@arg_prefix"/><xsl:value-of select="@name"/>"),conf->getProp(cnode,"<xsl:value-of select="@name"/>"),"<xsl:value-of select="normalize-space(@default)"/>"))),
 </xsl:if>
@@ -589,15 +602,27 @@ end_private(false)
 	<xsl:if test="normalize-space(@no_check_id)!='1'">
 	if( <xsl:value-of select="normalize-space(@name)"/> == UniSetTypes::DefaultObjectId )
 		throw Exception( myname + ": Not found ID for (<xsl:value-of select="@name"/>) " + conf->getProp(cnode,"<xsl:value-of select="@name"/>") );
+	
+	<xsl:if test="normalize-space(@no_check_iotype)!='1'">	
+	if( conf->getIOType( <xsl:value-of select="normalize-space(@name)"/> ) !=  <xsl:call-template name="gettype"><xsl:with-param name="iotype" select="@iotype"/></xsl:call-template> )
+	{
+		ostringstream err;
+		err &lt;&lt; myname &lt;&lt;  "(init): Invalid 'iotype' for '<xsl:value-of select="normalize-space(@name)"/>' set '<xsl:value-of select="normalize-space(@iotype)"/>' but " 
+			&lt;&lt; conf->getProp(cnode,"<xsl:value-of select="normalize-space(@name)"/>") &lt;&lt; "='" &lt;&lt; conf->getIOType( <xsl:value-of select="normalize-space(@name)"/> ) &lt;&lt; "'";
+		throw Exception( err.str() );
+	}
+	</xsl:if>
 	</xsl:if>
 	
 	if( node_<xsl:value-of select="normalize-space(@name)"/> == UniSetTypes::DefaultObjectId )
 	{
+		<xsl:if test="normalize-space(@no_check_id)!='1'">
 		if( !conf->getProp(cnode,"node_<xsl:value-of select="normalize-space(@name)"/>").empty() )
 			throw Exception( myname + ": Not found NodeID for (node='node_<xsl:value-of select="normalize-space(@name)"/>') " + conf->getProp(cnode,"node_<xsl:value-of select="normalize-space(@name)"/>") );
-		
+		</xsl:if>
 		node_<xsl:value-of select="normalize-space(@name)"/> = conf->getLocalNode();
 	}
+
 </xsl:for-each>
 
 <xsl:for-each select="//msgmap/item">

Utilities/codegen/ctl-cpp-h.xsl

@@ -86,6 +86,8 @@ class <xsl:value-of select="$CLASSNAME"/>_SK:
 		</xsl:if>
 		<xsl:if test="normalize-space(@type)='float'">float <xsl:value-of select="@name"/>; /*!&lt; <xsl:value-of select="@comment"/> */
 		</xsl:if>
+		<xsl:if test="normalize-space(@type)='double'">double <xsl:value-of select="@name"/>; /*!&lt; <xsl:value-of select="@comment"/> */
+		</xsl:if>
 		<xsl:if test="normalize-space(@type)='bool'">bool <xsl:value-of select="@name"/>; /*!&lt; <xsl:value-of select="@comment"/> */
 		</xsl:if>
 		<xsl:if test="normalize-space(@type)='str'">std::string <xsl:value-of select="@name"/>; /*!&lt; <xsl:value-of select="@comment"/> */
@@ -106,6 +108,8 @@ class <xsl:value-of select="$CLASSNAME"/>_SK:
 		</xsl:if>
 		<xsl:if test="normalize-space(@type)='float'">float <xsl:value-of select="@name"/>; /*!&lt; <xsl:value-of select="@comment"/> */
 		</xsl:if>
+		<xsl:if test="normalize-space(@type)='double'">double <xsl:value-of select="@name"/>; /*!&lt; <xsl:value-of select="@comment"/> */
+		</xsl:if>
 		<xsl:if test="normalize-space(@type)='bool'">bool <xsl:value-of select="@name"/>; /*!&lt; <xsl:value-of select="@comment"/> */
 		</xsl:if>
 		<xsl:if test="normalize-space(@type)='str'">std::string <xsl:value-of select="@name"/>; /*!&lt; <xsl:value-of select="@comment"/> */
@@ -127,6 +131,8 @@ class <xsl:value-of select="$CLASSNAME"/>_SK:
 		</xsl:if>
 		<xsl:if test="normalize-space(@type)='float'">float <xsl:value-of select="@name"/>; /*!&lt; <xsl:value-of select="@comment"/> */
 		</xsl:if>
+		<xsl:if test="normalize-space(@type)='double'">double <xsl:value-of select="@name"/>; /*!&lt; <xsl:value-of select="@comment"/> */
+		</xsl:if>
 		<xsl:if test="normalize-space(@type)='bool'">bool <xsl:value-of select="@name"/>; /*!&lt; <xsl:value-of select="@comment"/> */
 		</xsl:if>
 		<xsl:if test="normalize-space(@type)='str'">std::string <xsl:value-of select="@name"/>; /*!&lt; <xsl:value-of select="@comment"/> */

Utilities/codegen/tests/testgen.src.xml

@@ -31,6 +31,7 @@
 	  	<item name="test_int" type="int" min="0" comment="test int variable" const="1" public="1"/>
 		<item name="test_int2" type="int" max="100" default="110" no_range_exception="1"/>
 		<item name="test_float" type="float" max="100.0" default="50.0" />
+		<item name="test_double" type="double" max="100.340" default="52.044" />
 		<item name="test_bool" type="bool" private="1"/>
 		<item name="test_str" type="str" default="ddd"/>
   </variables>

conf/libuniset.spec

@@ -2,12 +2,12 @@
 %define oname uniset
 
 Name: libuniset
-Version: 1.3
-Release: alt18
+Version: 1.4
+Release: alt5
 Summary: UniSet - library for building distributed industrial control systems
 License: GPL
 Group: Development/C++
-Url: http://sourceforge.net/uniset
+Url: http://git.etersoft.ru/projects/?p=asu/uniset.git;a=summary
 
 Packager: Pavel Vainerman <pv@altlinux.ru>
 
@@ -183,7 +183,7 @@ rm -f %buildroot%_libdir/*.la
 %_libdir/libUniSetRT*.so.*
 %_libdir/libUniSetShared*.so.*
 %_libdir/libUniSetNetwork*.so.*
-%_libdir/libUniSetUNet2*.so.*
+%_libdir/libUniSetUNetUDP*.so.*
 #%_libdir/libUniSetSMDBServer*.so.*
 
 %files extensions-devel
@@ -195,7 +195,7 @@ rm -f %buildroot%_libdir/*.la
 %_libdir/libUniSetRT*.so
 %_libdir/libUniSetShared*.so
 %_libdir/libUniSetNetwork.so
-%_libdir/libUniSetUNet2.so
+%_libdir/libUniSetUNetUDP.so
 #%_libdir/libUniSetSMDBServer.so
 %_pkgconfigdir/*Extensions.pc
 %_pkgconfigdir/libUniSetIO*.pc
@@ -213,6 +213,26 @@ rm -f %buildroot%_libdir/*.la
 
 
 %changelog
+* Thu Jun 14 2012 Pavel Vainerman <pv@altlinux.ru> 1.4-alt5
+- (codegen): fixed bug in validation 'iotype'
+
+* Sun Jun 10 2012 Pavel Vainerman <pv@altlinux.ru> 1.4-alt4
+- (codegen): added validation 'iotype'
+
+* Sun Jun 10 2012 Pavel Vainerman <pv@altlinux.ru> 1.4-alt3
+- (DBServer_MySQL): buffer is added to query
+
+* Fri Jun 08 2012 Pavel Vainerman <pv@altlinux.ru> 1.4-alt2
+- added support type 'double' for uniset-codegen (<variables>)
+
+* Thu May 31 2012 Pavel Vainerman <pv@altlinux.ru> 1.4-alt1
+- rename unet2 -->unetudp
+- release version 1.4
+
+* Thu May 31 2012 Pavel Vainerman <pv@altlinux.ru> 1.3-alt19
+- DBServer: set log info level - LEVEL9
+- minor fixies for linker errors (new gcc)
+
 * Tue Apr 10 2012 Pavel Vainerman <pv@altlinux.ru> 1.3-alt18
 - fixed bug in ComPort485F (reinit function)
 

conf/test.xml

@@ -85,7 +85,7 @@
 	textname 	- текстовое имя датчика
 -->
 		<nodes port="2809" unet_broadcast_ip="192.168.1.255" unet_broadcast_ip2="192.168.122.255">
-			<item id="3000" infserver="InfoServer" ip="127.0.0.1" name="LocalhostNode" textname="Локальный узел" unet_ignore="0" unet_port="2048">
+			<item id="3000" dbserver="DBServer1" infserver="InfoServer" ip="127.0.0.1" name="LocalhostNode" textname="Локальный узел" unet_ignore="0" unet_port="2048">
 				<iocards>
 					<item card="1" name="DI32"/>
 					<item card="2" name="DO32"/>
@@ -159,7 +159,7 @@
 		<!-- ******************* Идентификаторы сервисов ***************** -->
 		<services name="Services">
 			<item id="5010" name="InfoServer"/>
-			<item id="5011" name="DBServer"/>
+			<item id="5011" name="DBServer1"/>
 			<item id="5012" name="PrintServer"/>
 			<item id="5013" name="TimeService"/>
 		</services>

configure.ac

@@ -3,7 +3,7 @@
 # See doc: http://www.gnu.org/software/hello/manual/autoconf/Generic-Programs.html
 
 # AC_PREREQ(2.59)
-AC_INIT([uniset], [1.3.0], pv@etersoft.ru)
+AC_INIT([uniset], [1.4.0], pv@etersoft.ru)
 AM_INIT_AUTOMAKE(AC_PACKAGE_NAME,AC_PACKAGE_VERSION)
 
 # AC_CONFIG_MACRO_DIR([m4])
@@ -30,7 +30,7 @@ AC_ENABLE_SHARED(yes)
 AC_ENABLE_STATIC(no)
 AM_PROG_LIBTOOL
 
-LIBVER=1:3:0
+LIBVER=1:4:0
 AC_SUBST(LIBVER)
 
 # Checks for libraries.
@@ -189,8 +189,8 @@ AC_CONFIG_FILES([Makefile
 				 extensions/SMViewer/Makefile
 				 extensions/UniNetwork/Makefile
 				 extensions/UniNetwork/libUniSetNetwork.pc
-				 extensions/UNet2/Makefile
-				 extensions/UNet2/libUniSetUNet2.pc
+				 extensions/UNetUDP/Makefile
+				 extensions/UNetUDP/libUniSetUNetUDP.pc
 				 extensions/SharedMemory/Makefile
 				 extensions/SharedMemory/libUniSetSharedMemory.pc
 				 extensions/SharedMemoryPlus/Makefile

extensions/DBServer-MySQL/DBServer_MySQL.h

@@ -25,6 +25,7 @@
 #define DBServer_MySQL_H_
 // --------------------------------------------------------------------------
 #include <map>
+#include <queue>
 #include "UniSetTypes.h"
 #include "DBInterface.h"
 #include "DBServer.h"
@@ -35,6 +36,7 @@
       - \ref sec_DBS_Comm
       - \ref sec_DBS_Conf
       - \ref sec_DBS_Tables
+      - \ref sec_DBS_Buffer
 
 
 	\section sec_DBS_Comm Общее описание работы DBServer_MySQL
@@ -50,8 +52,9 @@
 	
 	\par
 		Для повышения надежности DBServer переодически ( DBServer_MySQL::PingTimer ) проверяет наличие связи с сервером БД.
-	В случае если связь пропала (или не была установлена при старте) DBServer пытается вновь переодически ( DBServer::ReconnectTimer )
-	произвести соединение.	При этом все запросы которые поступают для запии в БД, пишутся в лог-файл.
+	В случае если связь пропала (или не была установлена при старте) DBServer пытается вновь каждые DBServer::ReconnectTimer
+	произвести соединение.	При этом все запросы которые поступают для запии в БД, но не мгут быть записаны складываются
+	в буфер (см. \ref sec_DBS_Buffer).
 	\warning При каждой попытке восстановить соединение DBServer заново читает конф. файл. Поэтому он может подхватить
 	новые настройки.
 
@@ -68,7 +71,17 @@
 	- \b pingTime - период проверки связи с сервером MySQL
 	- \b reconnectTime - время повторной попытки соединения с БД
 	
-	
+	\section sec_DBS_Buffer Защита от потери данных
+     Для того, чтобы на момент отсутствия связи с БД данные по возможности не потерялись,
+	сделан "кольцевой" буфер. Размер которго можно регулировать параметром "--dbserver-buffer-size"
+	или параметром \b bufferSize=".." в конфигурационном файле секции "<LocalDBSErver...>".
+
+	Механизм построен на том, что если связь с mysql сервером отсутствует или пропала,
+	то сообщения помещаются в колевой буфер, который "опустошается" как только она восстановится.
+    Если связь не восстановилась, а буфер достиг максимального заданного размера, то удаляются
+	более ранние сообщения. Эту логику можно сменить, если указать параметр "--dbserver-buffer-last-remove" 
+	или \b bufferLastRemove="1", то терятся будут сообщения добавляемые в конец.
+
 	\section sec_DBS_Tables Таблицы MySQL
 	  К основным таблицам относятся следующие:
 \code
@@ -138,6 +151,8 @@ class DBServer_MySQL:
 		DBServer_MySQL();
 		~DBServer_MySQL();
 
+		static const Debug::type DBLogInfoLevel = Debug::LEVEL9;
+
 	protected:
 		typedef std::map<int, std::string> DBTableMap;
 
@@ -166,8 +181,9 @@ class DBServer_MySQL:
 
 		enum Timers
 		{
-			PingTimer,  	/*!< таймер на переодическую проверку соединения  с сервером БД */
-			ReconnectTimer 	/*!< таймер на повторную попытку соединения с сервером БД (или восстановления связи) */
+			PingTimer,        /*!< таймер на переодическую проверку соединения  с сервером БД */
+			ReconnectTimer,   /*!< таймер на повторную попытку соединения с сервером БД (или восстановления связи) */
+			lastNumberOfTimer
 		};
 
 
@@ -178,6 +194,15 @@ class DBServer_MySQL:
 
 		bool activate;
 
+		typedef std::queue<std::string> QueryBuffer;
+
+		QueryBuffer qbuf;
+		unsigned int qbufSize; // размер буфера сообщений.
+		bool lastRemove;
+
+		void flushBuffer();
+		UniSetTypes::uniset_mutex mqbuf;
+
 	private:
 		DBTableMap tblMap;
 

extensions/DBServer-MySQL/start_fg.sh

@@ -2,4 +2,7 @@
 
 ulimit -Sc 1000000
 
-uniset-start.sh -f ./uniset-mysql-dbserver --confile test.xml --name DBServer --unideb-add-levels info,crit,warn,level9,system
+uniset-start.sh -f ./uniset-mysql-dbserver --confile test.xml --name DBServer1 \
+--unideb-add-levels info,crit,warn,level9,system \
+--dbserver-buffer-size 100
+

extensions/IOControl/Makefile.am

@@ -6,9 +6,9 @@ UIO_VER=@LIBVER@
 lib_LTLIBRARIES 	= libUniSetIOControl.la
 libUniSetIOControl_la_LDFLAGS  = -version-info $(UIO_VER) 
 libUniSetIOControl_la_LIBADD		= $(COMEDI_LIBS) $(SIGC_LIBS) \
-		$(top_builddir)/extensions/lib/libUniSetExtensions.la \
-		$(top_builddir)/lib/libUniSet.la \
-		$(top_builddir)/extensions/SharedMemory/libUniSetSharedMemory.la
+	$(top_builddir)/extensions/lib/libUniSetExtensions.la \
+	$(top_builddir)/lib/libUniSet.la \
+	$(top_builddir)/extensions/SharedMemory/libUniSetSharedMemory.la
 
 libUniSetIOControl_la_CXXFLAGS 	= $(COMEDI_CFLAGS) $(SIGC_CFLAGS) \
 	-I$(top_builddir)/extensions/include \
@@ -16,7 +16,9 @@ libUniSetIOControl_la_CXXFLAGS 	= $(COMEDI_CFLAGS) $(SIGC_CFLAGS) \
 
 libUniSetIOControl_la_SOURCES 	= ComediInterface.cc IOControl.cc
 
-@PACKAGE@_iocontrol_LDADD 	= libUniSetIOControl.la $(COMEDI_LIBS)
+@PACKAGE@_iocontrol_LDADD 	= libUniSetIOControl.la \
+	$(top_builddir)/lib/libUniSet.la \
+	$(top_builddir)/extensions/lib/libUniSetExtensions.la $(COMEDI_LIBS)
 @PACKAGE@_iocontrol_CXXFLAGS 	= $(COMEDI_CFLAGS) $(SIGC_CFLAGS) \
 	-I$(top_builddir)/extensions/include \
 	-I$(top_builddir)/extensions/SharedMemory

extensions/Makefile.am

@@ -4,7 +4,7 @@
 
 if HAVE_EXTENTIONS
 SUBDIRS = lib include SharedMemory IOControl LogicProcessor \
-	ModbusMaster ModbusSlave SMViewer UniNetwork UNet2 DBServer-MySQL tests
+	ModbusMaster ModbusSlave SMViewer UniNetwork UNetUDP DBServer-MySQL tests
 #SMDBServer
 #SharedMemoryPlus
 #UDPExchange

extensions/ModbusMaster/Makefile.am

@@ -11,7 +11,7 @@ lib_LTLIBRARIES 	= libUniSetMBTCPMaster.la libUniSetRTU.la
 
 # -------------------- Mobus TCP -------------------
 # не забывайте править версию в pc-файле
-UMBTCP_VER=1:3:1
+UMBTCP_VER=@LIBVER@
 
 
 libUniSetMBTCPMaster_la_LDFLAGS  = -version-info $(UMBTCP_VER)

extensions/ModbusSlave/Makefile.am

-bin_PROGRAMS 			= @PACKAGE@-mbslave
+bin_PROGRAMS = @PACKAGE@-mbslave
 
 # не забывайте править версию в pc-файле 
-UMBS_VER=1:1:1
+UMBS_VER=@LIBVER@
 
 lib_LTLIBRARIES 				= libUniSetMBSlave.la
 libUniSetMBSlave_la_LDFLAGS  = -version-info $(UMBS_VER) 

extensions/SharedMemory/Makefile.am

@@ -12,7 +12,8 @@ libUniSetSharedMemory_la_CPPFLAGS	= $(SIGC_CFLAGS) -I$(top_builddir)/extensions/
 libUniSetSharedMemory_la_SOURCES 	= SharedMemory.cc 
 
 
-@PACKAGE@_smemory_LDADD 	= libUniSetSharedMemory.la
+@PACKAGE@_smemory_LDADD 	= libUniSetSharedMemory.la $(top_builddir)/lib/libUniSet.la \
+	$(top_builddir)/extensions/lib/libUniSetExtensions.la
 @PACKAGE@_smemory_CPPFLAGS	= $(SIGC_CFLAGS) -I$(top_builddir)/extensions/include
 @PACKAGE@_smemory_SOURCES 	= smemory.cc
 

extensions/SharedMemory/SharedMemory.cc

@@ -132,10 +132,11 @@ SharedMemory::SharedMemory( ObjectId id, string datafile, std::string confname )
 		if( !t.empty() )
 		{
 			iotypePulsar = UniSetTypes::getIOType(t);
-			if( iotypePulsar == UniversalIO::UnknownIOType )
+			if( iotypePulsar == UniversalIO::UnknownIOType || 
+				iotypePulsar == UniversalIO::AnalogInput || iotypePulsar == UniversalIO::AnalogOutput )
 			{
 				ostringstream err;
-				err << myname << ": Unknown iotype '" << t << "' for pulsar. Must be 'DI' or 'DO'";
+				err << myname << ": Invalid iotype '" << t << "' for pulsar. Must be 'DI' or 'DO'";
 				dlog[Debug::CRIT] << myname << "(init): " << err.str() << endl;
 				throw SystemError(err.str());
 			}
@@ -527,59 +528,6 @@ bool SharedMemory::readItem( UniXML& xml, UniXML_iterator& it, xmlNode* sec )
 	return true;
 }
 // ------------------------------------------------------------------------------------------
-void SharedMemory::localSaveValue( AIOStateList::iterator& it, const IOController_i::SensorInfo& si,
-										CORBA::Long newvalue, UniSetTypes::ObjectId sup_id )
-{
-	if( hist.empty() )
-	{
-		IONotifyController_LT::localSaveValue( it, si, newvalue, sup_id );
-		return;
-	}
-
-	uniset_mutex_lock l(hbmutex);
-	IONotifyController_LT::localSaveValue( it, si, newvalue, sup_id );
-}
-// ------------------------------------------------------------------------------------------
-void SharedMemory::localSaveState( DIOStateList::iterator& it, const IOController_i::SensorInfo& si,
-										CORBA::Boolean newstate, UniSetTypes::ObjectId sup_id )
-{
-	if( hist.empty() )
-	{
-		IONotifyController_LT::localSaveState( it, si, newstate, sup_id );
-		return;
-	}
-
-	uniset_mutex_lock l(hbmutex);
-	IONotifyController_LT::localSaveState( it, si, newstate, sup_id );
-}
-// ------------------------------------------------------------------------------------------
-void SharedMemory::localSetState( DIOStateList::iterator& it, const IOController_i::SensorInfo& si,
-										CORBA::Boolean newstate, UniSetTypes::ObjectId sup_id )
-{
-	if( hist.empty() )
-	{
-		IONotifyController_LT::localSetState( it, si, newstate, sup_id );
-		return;
-	}
-
-	uniset_mutex_lock l(hbmutex);
-	IONotifyController_LT::localSetState( it, si, newstate, sup_id );
-}
-// ------------------------------------------------------------------------------------------
-void SharedMemory::localSetValue( AIOStateList::iterator& it, const IOController_i::SensorInfo& si,
-										CORBA::Long value, UniSetTypes::ObjectId sup_id )
-{
-	if( hist.empty() )
-	{
-		IONotifyController_LT::localSetValue( it, si, value, sup_id );
-		return;
-	}
-
-	uniset_mutex_lock l(hbmutex);
-	IONotifyController_LT::localSetValue( it, si, value, sup_id );
-}
-// ------------------------------------------------------------------------------------------
-
 SharedMemory* SharedMemory::init_smemory( int argc, const char* const* argv )
 {
 	string dfile = conf->getArgParam("--datfile", conf->getConfFileName());

extensions/SharedMemory/SharedMemory.h

@@ -351,16 +351,6 @@ class SharedMemory:
 		virtual void askSensors( UniversalIO::UIOCommand cmd );
 		virtual void sendEvent( UniSetTypes::SystemMessage& sm );
 
-		virtual void localSaveValue( AIOStateList::iterator& it, const IOController_i::SensorInfo& si,
-										CORBA::Long newvalue, UniSetTypes::ObjectId sup_id );
-		virtual void localSaveState( DIOStateList::iterator& it, const IOController_i::SensorInfo& si,
-										CORBA::Boolean newstate, UniSetTypes::ObjectId sup_id );
-	  	virtual void localSetState( DIOStateList::iterator& it, const IOController_i::SensorInfo& si,
-										CORBA::Boolean newstate, UniSetTypes::ObjectId sup_id );
-		virtual void localSetValue( AIOStateList::iterator& it, const IOController_i::SensorInfo& si,
-										CORBA::Long value, UniSetTypes::ObjectId sup_id );
-
-
 		// действия при завершении работы
 		virtual void sigterm( int signo );
 		bool activateObject();
@@ -413,7 +403,6 @@ class SharedMemory:
 
 		typedef std::list<HeartBeatInfo> HeartBeatList;
 		HeartBeatList hlist; // список датчиков "сердцебиения"
-		UniSetTypes::uniset_mutex hbmutex;
 		WDTInterface* wdt;
 		bool activated;
 		bool workready;

extensions/UNet2/Makefile.am

-bin_PROGRAMS 	= @PACKAGE@-unetexchange @PACKAGE@-unet2-tester
-
-# не забывайте править версию в pc-файле 
-UNET2_VER=@LIBVER@
-
-lib_LTLIBRARIES 			= libUniSetUNet2.la
-libUniSetUNet2_la_LDFLAGS  = -version-info $(UNET2_VER)
-libUniSetUNet2_la_LIBADD		= $(top_builddir)/lib/libUniSet.la \
-								$(top_builddir)/extensions/SharedMemory/libUniSetSharedMemory.la \
-								$(top_builddir)/extensions/lib/libUniSetExtensions.la \
-								$(SIGC_LIBS) $(COMCPP_LIBS)
-libUniSetUNet2_la_CXXFLAGS	= -I$(top_builddir)/extensions/include -I$(top_builddir)/extensions/SharedMemory $(SIGC_CFLAGS) $(COMCPP_CFLAGS)
-libUniSetUNet2_la_SOURCES 	= UDPPacket.cc UNetReceiver.cc UNetSender.cc UNetExchange.cc
-
-@PACKAGE@_unetexchange_SOURCES 		= unetexchange.cc
-@PACKAGE@_unetexchange_LDADD 		= libUniSetUNet2.la $(top_builddir)/lib/libUniSet.la \
-									$(top_builddir)/extensions/SharedMemory/libUniSetSharedMemory.la \
-									$(top_builddir)/extensions/lib/libUniSetExtensions.la \
-									$(SIGC_LIBS) $(COMCPP_LIBS)
-@PACKAGE@_unetexchange_CXXFLAGS	= -I$(top_builddir)/extensions/include -I$(top_builddir)/extensions/SharedMemory $(SIGC_CFLAGS) $(COMCPP_CFLAGS)
-
-
-@PACKAGE@_unet2_tester_SOURCES	= UDPPacket.cc unet2-tester.cc
-@PACKAGE@_unet2_tester_LDADD 	= $(COMCPP_LIBS)
-@PACKAGE@_unet2_tester_CXXFLAGS	= $(COMCPP_CFLAGS)
-
-# install
-devel_include_HEADERS = *.h
-devel_includedir = $(pkgincludedir)/extensions
-
-pkgconfigdir 	= $(libdir)/pkgconfig
-pkgconfig_DATA 	= libUniSetUNet2.pc
-
-all-local:
-	ln -sf ../UNet2/$(devel_include_HEADERS) ../include

extensions/UNet2/create_links.sh

-#!/bin/sh
-
-ln -s -f ../../Utilities/scripts/uniset-start.sh 
-ln -s -f ../../Utilities/scripts/uniset-stop.sh stop.sh
-ln -s -f ../../Utilities/scripts/uniset-functions.sh 
-ln -s -f ../../conf/test.xml test.xml
-

extensions/UNetUDP/Makefile.am

+bin_PROGRAMS = @PACKAGE@-unetexchange @PACKAGE@-unet-udp-tester
+
+# не забывайте править версию в pc-файле 
+UNETUDP_VER=@LIBVER@
+
+lib_LTLIBRARIES 			= libUniSetUNetUDP.la
+libUniSetUNetUDP_la_LDFLAGS  = -version-info $(UNETUDP_VER)
+libUniSetUNetUDP_la_LIBADD		= $(top_builddir)/lib/libUniSet.la \
+								$(top_builddir)/extensions/SharedMemory/libUniSetSharedMemory.la \
+								$(top_builddir)/extensions/lib/libUniSetExtensions.la \
+								$(SIGC_LIBS) $(COMCPP_LIBS)
+libUniSetUNetUDP_la_CXXFLAGS	= -I$(top_builddir)/extensions/include -I$(top_builddir)/extensions/SharedMemory $(SIGC_CFLAGS) $(COMCPP_CFLAGS)
+libUniSetUNetUDP_la_SOURCES 	= UDPPacket.cc UNetReceiver.cc UNetSender.cc UNetExchange.cc
+
+@PACKAGE@_unetexchange_SOURCES 		= unetexchange.cc
+@PACKAGE@_unetexchange_LDADD 		= libUniSetUNetUDP.la $(top_builddir)/lib/libUniSet.la \
+									$(top_builddir)/extensions/SharedMemory/libUniSetSharedMemory.la \
+									$(top_builddir)/extensions/lib/libUniSetExtensions.la \
+									$(SIGC_LIBS) $(COMCPP_LIBS)
+@PACKAGE@_unetexchange_CXXFLAGS	= -I$(top_builddir)/extensions/include -I$(top_builddir)/extensions/SharedMemory $(SIGC_CFLAGS) $(COMCPP_CFLAGS)
+
+
+@PACKAGE@_unet_udp_tester_SOURCES	= UDPPacket.cc unet-udp-tester.cc
+@PACKAGE@_unet_udp_tester_LDADD 	= $(COMCPP_LIBS)
+@PACKAGE@_unet_udp_tester_CXXFLAGS	= $(COMCPP_CFLAGS)
+
+# install
+devel_include_HEADERS = *.h
+devel_includedir = $(pkgincludedir)/extensions
+
+pkgconfigdir 	= $(libdir)/pkgconfig
+pkgconfig_DATA 	= libUniSetUNetUDP.pc
+
+all-local:
+	ln -sf ../UNetUDP/$(devel_include_HEADERS) ../include

extensions/UNet2/UNetExchange.h → extensions/UNetUDP/UNetExchange.h

@@ -15,13 +15,13 @@
 #include "UNetSender.h"
 // -----------------------------------------------------------------------------
 /*!
-	\page pageUNetExchange2 Сетевой обмен на основе UDP (UNet2)
+	\page pageUNetExchangeUDP Сетевой обмен на основе UDP (UNetUDP)
 		
-		- \ref pgUnet2_Common
-		- \ref pgUnet2_Conf
-		- \ref pgUnet2_Reserv
+		- \ref pgUNetUDP_Common
+		- \ref pgUNetUDP_Conf
+		- \ref pgUNetUDP_Reserv
 
-	\section pgUnet2_Common Общее описание
+	\section pgUNetUDP_Common Общее описание
 		Обмен построен  на основе протокола UDP. 
 		Основная идея заключается в том, что каждый узел на порту равном своему ID
 	посылает в сеть UDP-пакеты содержащие данные считанные из локальной SM. Формат данных - это набор
@@ -32,9 +32,9 @@
 		При своём старте процесс считывает из секции \<nodes> список узлов с которыми необходимо 
 	вести обмен, а также параметры своего узла. Открывает по потоку приёма на каждый узел и поток
 	передачи для своих данных. Помимо этого такие же потоки для резервных каналов, если они включены
-	(см. \ref pgUnet2_Reserv ).
+	(см. \ref pgUNetUDP_Reserv ).
 	
-	\section pgUnet2_Conf Пример конфигурирования
+	\section pgUNetUDP_Conf Пример конфигурирования
 		По умолчанию при считывании используется \b unet_broadcast_ip (указанный в секции \<nodes>)
 	и \b id узла - в качестве порта.
 	Но можно переопределять эти параметры, при помощи указания \b unet_port и/или \b unet_broadcast_ip,
@@ -51,7 +51,7 @@
 	</nodes>
 	\endcode
 
-	\section pgUnet2_Reserv Настройка резервного канала связи
+	\section pgUNetUDP_Reserv Настройка резервного канала связи
 		В текущей реализации поддерживается возможность обмена по двум подсетям (эзернет-каналам).
 	Она основана на том, что, для каждого узла помимо основного "читателя",
 	создаётся дополнительный "читатель"(поток) слушающий другой ip-адрес и порт. 

extensions/UNet2/libUniSetUNet2.pc.in → extensions/UNetUDP/libUniSetUNetUDP.pc.in

@@ -3,9 +3,9 @@ exec_prefix=@exec_prefix@
 libdir=@libdir@
 includedir=@includedir@
 
-Name: libUniSetUNet2
-Description: Support library for UniSetUNet2
+Name: libUniSetUNetUDP
+Description: Support library for UniSetUNetUDP
 Requires: libUniSetExtensions
 Version: @VERSION@
-Libs: -L${libdir} -lUniSetUNet2
+Libs: -L${libdir} -lUniSetUNetUDP
 Cflags: -I${includedir}/uniset

extensions/UNetUDP/stop.sh

+../../Utilities/scripts/uniset-stop.sh
\ No newline at end of file

extensions/UNetUDP/test.xml

+../../conf/test.xml
\ No newline at end of file

extensions/UNetUDP/uniset-functions.sh

+../../Utilities/scripts/uniset-functions.sh
\ No newline at end of file

extensions/UNetUDP/uniset-start.sh

+../../Utilities/scripts/uniset-start.sh
\ No newline at end of file

extensions/UniNetwork/Makefile.am

@@ -5,7 +5,7 @@ UNET_VER=@LIBVER@
 
 lib_LTLIBRARIES 	= libUniSetNetwork.la
 libUniSetNetwork_la_LDFLAGS  = -version-info $(UNET_VER) 
-libUniSetNetwork_la_LIBADD		= $(SIGC_LIBS) $(top_builddir)/lib/libUniSet.la \
+libUniSetNetwork_la_LIBADD = $(SIGC_LIBS) $(top_builddir)/lib/libUniSet.la \
 	$(top_builddir)/extensions/lib/libUniSetExtensions.la \
 	$(top_builddir)/extensions/SharedMemory/libUniSetSharedMemory.la
 libUniSetNetwork_la_CPPFLAGS	= $(SIGC_CFLAGS) \
@@ -13,7 +13,9 @@ libUniSetNetwork_la_CPPFLAGS	= $(SIGC_CFLAGS) \
 	-I$(top_builddir)/extensions/SharedMemory
 libUniSetNetwork_la_SOURCES 	= UniExchange.cc 
 
-@PACKAGE@_network_LDADD 	= libUniSetNetwork.la 
+@PACKAGE@_network_LDADD 	= libUniSetNetwork.la \
+	$(top_builddir)/lib/libUniSet.la \
+	$(top_builddir)/extensions/lib/libUniSetExtensions.la
 @PACKAGE@_network_CPPFLAGS	= $(SIGC_CFLAGS) -I$(top_builddir)/extensions/include
 @PACKAGE@_network_SOURCES 	= uninet.cc
 

extensions/UniNetwork/UniExchange.cc

@@ -482,7 +482,7 @@ bool UniExchange::initItem( UniXML_iterator& it )
 // ------------------------------------------------------------------------------------------
 void UniExchange::help_print( int argc, const char** argv )
 {
-	cout << "--unet-polltime msec     - Пауза между опросаом карт. По умолчанию 200 мсек." << endl;
+	cout << "--unet-polltime msec     - Пауза между опросами узлов. По умолчанию 200 мсек." << endl;
 //	cout << "--unet-heartbeat-id      - Данный процесс связан с указанным аналоговым heartbeat-дачиком." << endl;
 //	cout << "--unet-heartbeat-max     - Максимальное значение heartbeat-счётчика для данного процесса. По умолчанию 10." << endl;
 	cout << "--unet-sm-ready-timeout - время на ожидание старта SM" << endl;

include/UniXML.h

@@ -32,12 +32,13 @@
  
 #include <assert.h>
 #include <string>
+#include <cstddef>
 
 #include <libxml/parser.h>
 #include <libxml/tree.h>
-
-
-class UniXML_iterator : public std::iterator<std::bidirectional_iterator_tag, xmlNode, ptrdiff_t,                                            	xmlNode*, xmlNode&>
+// --------------------------------------------------------------------------
+class UniXML_iterator:
+	public std::iterator<std::bidirectional_iterator_tag, xmlNode, ptrdiff_t,xmlNode*, xmlNode&>
 {
 	public:
 		UniXML_iterator(xmlNode* node) :
@@ -121,12 +122,12 @@ class UniXML_iterator : public std::iterator<std::bidirectional_iterator_tag, xm
 	protected:
 		xmlNode* curNode;
 };
-
+// --------------------------------------------------------------------------
 class UniXML
 {
 public:
 	
-	typedef UniXML_iterator                 iterator;
+	typedef UniXML_iterator iterator;
 
 	inline xmlNode* getFirstNode()
 	{
@@ -212,5 +213,5 @@ protected:
 	static int recur;
 
 };
-
+// --------------------------------------------------------------------------
 #endif

libUniSet.include

@@ -23,7 +23,7 @@ eval $(head -n1 $PCFILE)
 
 test -d "$prefix" || exit 1
 
-export PKG_CONFIG_PATH=$EXPORTPATH:$EXPORTPATH/extensions:$EXPORTPATH/extensions/SharedMemory:$EXPORTPATH/extensions/UniNetwork:$PKG_CONFIG_PATH
+export PKG_CONFIG_PATH=$EXPORTPATH:$EXPORTPATH/extensions:$EXPORTPATH/extensions/SharedMemory:$EXPORTPATH/extensions/UniNetwork:$EXPORTPATH/extensions/LogicProcessor:$EXPORTPATH/extensions/UNetUDP:$EXPORTPATH/extensions/DBServer-MySQL:$PKG_CONFIG_PATH
 
 cflags()
 {
@@ -69,7 +69,7 @@ EXFILE="$EXPORTPATH/extensions/ModbusSlave libUniSetMBSlave.pc"
 export UNISET_EXT_MBS_CFLAGS="$( ext_cflags $EXFILE )"
 export UNISET_EXT_MBS_LIBS="$( ext_libs $EXFILE )"
 
-EXFILE="$EXPORTPATH/extensions/MBTCPMaster libUniSetMBTCPMaster.pc"
+EXFILE="$EXPORTPATH/extensions/ModbusMaster libUniSetMBTCPMaster.pc"
 export UNISET_EXT_MBM_CFLAGS="$( ext_cflags $EXFILE )"
 export UNISET_EXT_MBM_LIBS="$( ext_libs $EXFILE )"
 
@@ -77,8 +77,20 @@ EXFILE="$EXPORTPATH/extensions/UniNetwork libUniSetNetwork.pc"
 export UNISET_EXT_NET_CFLAGS="$( ext_cflags $EXFILE )"
 export UNISET_EXT_NET_LIBS="$( ext_libs $EXFILE )"
 
-EXFILE="$EXPORTPATH/extensions/RTUExchange libUniSetRTU.pc"
+EXFILE="$EXPORTPATH/extensions/UNetUDP libUniSetUNetUDP.pc"
+export UNISET_EXT_UNETUDP_CFLAGS="$( ext_cflags $EXFILE )"
+export UNISET_EXT_UNETUDP_LIBS="$( ext_libs $EXFILE )"
+
+EXFILE="$EXPORTPATH/extensions/ModbusMaster libUniSetRTU.pc"
 export UNISET_EXT_RTU_CFLAGS="$( ext_cflags $EXFILE )"
 export UNISET_EXT_RTU_LIBS="$( ext_libs $EXFILE )"
 
+EXFILE="$EXPORTPATH/extensions/DBServer-MySQL libUniSetMySQL.pc"
+export UNISET_EXT_MYSQL_CFLAGS="$( ext_cflags $EXFILE )"
+export UNISET_EXT_MYSQL_LIBS="$( ext_libs $EXFILE )"
+
+EXFILE="$EXPORTPATH/extensions/LogicProcessor libUniSetLogicProcessor.pc"
+export UNISET_EXT_LP_CFLAGS="$( ext_cflags $EXFILE )"
+export UNISET_EXT_LP_LIBS="$( ext_libs $EXFILE )"
+
 export UNISET_CODEGEN="sh $EXPORTPATH/Utilities/codegen/uniset-codegen --path $EXPORTPATH/Utilities/codegen"