src/event_table.h

 /*
  * event_table.h
  *
- * $Author: graziano $
- *
- * $Revision: 1.2 $
- *
- * $Log: event_table.h,v $
- *
- *
  * copyleft: Sincrotrone Trieste S.C.p.A. di interesse nazionale
  *           Strada Statale 14 - km 163,5 in AREA Science Park
  *           34012 Basovizza, Trieste ITALY
@@ -20,7 +13,7 @@
 #include <string>
 #include <map>
 #include <atomic>
-#include <tango.h>
+#include <tango/tango.h>
 
 
 using namespace std;
@@ -65,7 +58,7 @@ class event {
 		string	attname;
 		value_t value;				/* event value */
 		string value_string;	//added for DevString attributes
-		int quality;
+		int quality{Tango::ATTR_INVALID};
 		string ex_reason;
 		string ex_desc;
 		string ex_origin;
@@ -73,7 +66,8 @@ class event {
 		int type,							/* attribute data type */
 				read_size,                                      /* attribute size of read part */
 				counter,					/* molteplicita' */
-				err_counter;					/* molteplicita' errore */				
+				err_counter;					/* molteplicita' errore */		
+		long dim_x, dim_y;		
 		alarm_list m_alarm;
 		bool valid;	//TODO: old
 		bool 	first;//TODO: new
@@ -123,6 +117,8 @@ typedef struct basic_event_info_s {
 	string ex_origin;
 	int type;
 	int read_size;
+	long dim_x;
+	long dim_y;
 	Tango::TimeVal ts;
 	string msg;
 } bei_t;
@@ -161,8 +157,8 @@ class event_table : public Tango::TangoMonitor, public Tango::LogAdapter {
 #if 0
 		void init_proxy(void)  throw(vector<string> &);
 		void free_proxy(void);
-		void subscribe(EventCallBack& ecb) throw(vector<string> &);//throw(string&);
-		void unsubscribe(void) throw(string&);
+		void subscribe(EventCallBack& ecb);
+		void unsubscribe(void);
 #endif
 		/**
 		 * Add a new signal.
@@ -209,7 +205,7 @@ class EventCallBack : public Tango::CallBack, public Tango::LogAdapter
 		~EventCallBack(void);
 		void push_event(Tango::EventData* ev);
 		//void init(event_list* e);
-		void extract_values(Tango::DeviceAttribute *attr_value, vector<double> &val, string &val_string, int &type, int &read_size);
+		void extract_values(Tango::DeviceAttribute *attr_value, vector<double> &val, string &val_string, int &type, int &read_size, long &dim_x, long &dim_y);
 	private:
 		//event_list* e_ptr;
 		Tango::DeviceImpl *mydev;

src/formula_grammar.h

 /*
  * formula_grammar.h
  *
- * $Author: graziano $
- *
- * $Revision: 1.5 $ 
- *
- * $Log: formula_grammar.h,v $
- *
- *
  * copyleft: Sincrotrone Trieste S.C.p.A. di interesse nazionale
  *           Strada Statale 14 - km 163,5 in AREA Science Park
  *           34012 Basovizza, Trieste ITALY
@@ -132,6 +125,8 @@ struct formula_grammar : public grammar<formula_grammar>
     static const int val_qualityID = 23;
     static const int val_alarm_enum_stID = 24;
     static const int propertyID = 25;
+	static const int index_rangeID = 26; 
+	static const int index_listID = 27; 
 
     
     symbols<unsigned int> tango_states;
@@ -198,7 +193,7 @@ struct formula_grammar : public grammar<formula_grammar>
             	=	(alnum_p | '.' | '_' | '-' | '+')				//any alpha numeric char plus '.', '_', '-'
             	;
             symbol_attr
-            	=	(alnum_p | '_' | '.')								//any alpha numeric char plus '_', '.' for attribute names
+            	=	(alnum_p | '_' | '.') - str_p(".normal") - str_p(".alarm") - str_p(".quality")		//any alpha numeric char plus '_', '.' for attribute names
             	;
             //------------------------------ALARM NAME--------------------------------------	
             name
@@ -214,9 +209,18 @@ struct formula_grammar : public grammar<formula_grammar>
             			]
             		]
 //            	=	repeat_p(3)[(+symbol) >> ch_p('/')] >> (+symbol) 
-            	; 
+            	;
+            index_range
+            	= 	
+					( uint_p >> !(discard_node_d[ch_p('-')] >> uint_p))	// n or n-m
+            	;
+            index_list
+            	= 	(index_range >> *(discard_node_d[ch_p(',')] >> index_range)) // n-m,k,s-t,..
+            	;
             index
-            	= 	inner_node_d[ch_p('[') >> uint_p >> ch_p(']')]
+				=  discard_node_d[ch_p('[')] >> 
+				(str_p("-1") | index_list) >> 
+				discard_node_d[ch_p(']')]
             	;
             property
             	= 	str_p(".quality")
@@ -270,8 +274,8 @@ struct formula_grammar : public grammar<formula_grammar>
 
 			event_
 				=	name
-					>> !( (index)
-						| (property)
+					>> ( *(index)//0 or more indexex
+						>> !(property) //followed by 0 or 1 property
 						)
 				;				
 
@@ -406,6 +410,8 @@ struct formula_grammar : public grammar<formula_grammar>
         rule<ScannerT, parser_context<>, parser_tag<expr_atomID> > expr_atom;
         rule<ScannerT, parser_context<>, parser_tag<funcID> > function;
 		rule<ScannerT, parser_context<>, parser_tag<nameID> > name;
+		rule<ScannerT, parser_context<>, parser_tag<index_rangeID> > index_range;
+		rule<ScannerT, parser_context<>, parser_tag<index_listID> > index_list;
 		rule<ScannerT, parser_context<>, parser_tag<indexID> > index;
 		rule<ScannerT, parser_context<>, parser_tag<val_stringID> > val_string;
 		rule<ScannerT, parser_context<>, parser_tag<func_dualID> > function_dual;

src/main.cpp

@@ -31,7 +31,7 @@
 //                This file is generated by POGO
 //        (Program Obviously used to Generate tango Object)
 //=============================================================================
-#include <tango.h>
+#include <tango/tango.h>
 
 // Check if crash reporting is used.
 #if defined(ENABLE_CRASH_REPORT)
@@ -43,8 +43,15 @@
 
 DECLARE_CRASH_HANDLER;
 
+#ifndef TANGO_LOG
+#define TANGO_LOG cout
+#endif
+
+
 int main(int argc,char *argv[])
 {
+    using std::endl;
+    using std::bad_alloc;
 	INSTALL_CRASH_HANDLER
 	try
 	{
@@ -59,20 +66,20 @@ int main(int argc,char *argv[])
 
 		// Run the endless loop
 		//----------------------------------------
-		cout << "Ready to accept request" << endl;
+		TANGO_LOG << "Ready to accept request" << endl;
 		tg->server_run();
 	}
 	catch (bad_alloc &)
 	{
-		cout << "Can't allocate memory to store device object !!!" << endl;
-		cout << "Exiting" << endl;
+		TANGO_LOG << "Can't allocate memory to store device object !!!" << endl;
+		TANGO_LOG << "Exiting" << endl;
 	}
 	catch (CORBA::Exception &e)
 	{
 		Tango::Except::print_exception(e);
 		
-		cout << "Received a CORBA_Exception" << endl;
-		cout << "Exiting" << endl;
+		TANGO_LOG << "Received a CORBA_Exception" << endl;
+		TANGO_LOG << "Exiting" << endl;
 	}
 	Tango::Util::instance()->server_cleanup();
 	return(0);

src/update-thread.cpp

 /*
  * update-thread.cpp
- *
- * $Author: claudio $
- *
- * $Revision: 1.2 $
- *
- * $Log: update-thread.cpp,v $
- * Revision 1.2  2013-03-06 10:38:43  claudio
- * commented out debug print statements
- *
- * Revision 1.1  2008-11-10 10:54:09  graziano
- * thread for update of alarms with time threshold > 0
- *
- *
- *
- *
- * copyleft: Sincrotrone Trieste S.C.p.A. di interesse nazionale
- *           Strada Statale 14 - km 163,5 in AREA Science Park
- *           34012 Basovizza, Trieste ITALY
  */
 
 #include "update-thread.h"
@@ -28,7 +10,7 @@ static const char __FILE__rev[] = __FILE__ " $Revision: 1.2 $";
  */
 update_thread::update_thread(AlarmHandler_ns::AlarmHandler *p) : p_Alarm(p),Tango::LogAdapter(p)
 {
-	//cout << __FILE__rev << endl;
+	//TANGO_LOG << __FILE__rev << endl;
 }
 
 /*

src/update-thread.h

 /*
- * alarm-thread.h
- *
- * $Author: graziano $
- *
- * $Revision: 1.1 $
- *
- * $Log: update-thread.h,v $
- * Revision 1.1  2008-11-10 10:54:09  graziano
- * thread for update of alarms with time threshold > 0
- *
- *
- *
- *
- * copyleft: Sincrotrone Trieste S.C.p.A. di interesse nazionale
- *           Strada Statale 14 - km 163,5 in AREA Science Park
- *           34012 Basovizza, Trieste ITALY
+ * update-thread.h
  */
 
 #ifndef UPDATE_THREAD_H
 #define UPDATE_THREAD_H
 
 #include <omnithread.h>
-#include <tango.h>
+#include <tango/tango.h>
 #include <AlarmHandler.h>
 
 class update_thread : public omni_thread, public Tango::TangoMonitor, public Tango::LogAdapter {

test/CMakeLists.txt

+cmake_minimum_required(VERSION 3.2)
+
+project(test NONE)
+include(ExternalProject)
+
+ExternalProject_Add(testdevice
+		SOURCE_DIR ${CMAKE_SOURCE_DIR}/test/testdevice
+#		PREFIX ${CMAKE_BINARY_DIR}
+		CMAKE_ARGS "-DCMAKE_INSTALL_PREFIX=${CMAKE_BINARY_DIR}"
+#		INSTALL_DIR ${CMAKE_BINARY_DIR}
+#		BINARY_DIR ${CMAKE_BINARY_DIR}
+#		STEP_TARGETS build
+#		EXCLUDE_FROM_ALL TRUE
+		)
+
+ExternalProject_Get_property(testdevice SOURCE_DIR)
+message("Source dir of testdevice = ${SOURCE_DIR}")
+
+ExternalProject_Get_property(testdevice INSTALL_DIR)
+message("Install dir of testdevice = ${INSTALL_DIR}")
+
+ExternalProject_Get_property(testdevice BINARY_DIR)
+message("Binary dir of testdevice = ${BINARY_DIR}")
+
+ExternalProject_Get_property(testdevice CMAKE_ARGS)
+message("CMqke args for testdevice = ${CMAKE_ARGS}")
+
+#ExternalProject_Get_property(testdevice PREFIX)
+#message("Prefix dir of testdevice = ${PREFIX}")

test/ah_config.json

+{
+    "_version": 1,
+    "_source": "ConfigInjectorDiag.xls",
+    "_title": "hdbpp mysql innodb test",
+    "_date": "2020-07-07 14:45:04",
+
+    "servers": {
+        "alarm-handler-srv/01": {
+            "AlarmHandler": {
+                "alarm/handler/01": {
+                    "properties": {
+                    },
+                    "attribute_properties": {
+                    }
+                }
+            }
+        },
+        "testdevice-srv/01": {
+            "TestDevice": {
+                "alarm/test/01": {
+                    "properties": {
+                        "Attr_config": [
+                            "condition:bool:0:0.0"
+                        ]
+                    },
+                    "attribute_properties": {
+                    }
+                }
+            }
+        }
+    },
+    "classes": {
+        "AlarmHandler": {
+            "properties": {
+                "GroupNames": ["gr_none","gr_test"],
+                "StatisticsTimeWindow": ["60"],
+                "SubscribeRetryPeriod": ["30"]
+            }
+        },
+        "TestDevice": {
+            "properties": {
+            }
+        }
+    }
+}

test/check-alarm-conf.py

+#!/usr/bin/python
+#
+
+import sys,re
+#import PyTango
+from PyTango import *
+import time
+import string
+	
+if __name__ == "__main__":
+
+	Device = False
+	Conf = False
+	File = False
+	conflist = []
+	#PrepareState = False
+	for arg in sys.argv:
+		word = '([a-z0-9._\-\*]*)'
+		wordpath = '([a-z0-9._\-\*/]*)'
+		m = re.compile("--device=" + word + "/{0,1}" + word + "/{0,1}" + word).match(arg.lower())
+		if m is not None:
+			#print m.groups()
+			domain = m.groups()[0]
+			family = m.groups()[1]
+			member = m.groups()[2]
+			if domain == '':
+				domain = '*'
+			if family == '':
+				family = '*'
+			if member == '':
+				member = '*'
+			Device = True
+		#formula = '([a-z0-9._,\*,\-,\|,\/,\",\s,\t]*)'
+		formula = '(.*)'
+		m = re.compile("--conf=" + formula).match(arg)
+		if m is not None:
+			#print m.groups()	
+			alarm_rule = m.groups()[0]
+			Conf = True
+		#m = re.compile("--prepare_state").match(arg.lower())
+		#if m is not None:
+		#	PrepareState = True			
+		m = re.compile("--file=" + wordpath).match(arg)
+		if m is not None:
+			#print m.groups()
+			file_name = m.groups()[0]
+			File = True
+	        
+		tagchars = '([a-zA-Z0-9._-]*)'
+		tag=''
+		if Device:
+			if Conf or File:
+				dev_name = domain + '/' + family + '/' + member
+				try:
+					dev = DeviceProxy(dev_name)
+				except (DevFailed,ConnectionFailed,EventSystemFailed) as e:
+					print ('ERROR connecting proxy(',dev_name,'): ',e[0].desc)
+					sys.exit(-1)				
+			if Conf:									
+				m = re.compile("tag=" + tagchars + ";(.*)").match(alarm_rule)
+				if m is not None:
+					try:
+						tag = m.groups()[0]
+						conflist = dev.command_inout('SearchAlarm',tag)
+					except (DevFailed,ConnectionFailed,EventSystemFailed) as e:
+						print ('     ---> ERROR: ', e[0].desc)
+						sys.exit(1)
+					for co in conflist:
+						if co == alarm_rule:
+							print ('Found matching alarm: ', co)
+							sys.exit(0)
+				print ('Not found conf for alarm ', tag)			
+				sys.exit(1)
+			elif File:
+				for line in open(file_name):
+					line = line[0:-1]
+					m = re.compile("tag=" + tagchars + ";(.*)").match(line)
+					conf_found = False
+					if m is not None:
+						try:
+							tag = m.groups()[0]
+							conflist = dev.command_inout('SearchAlarm',tag)
+						except (DevFailed,ConnectionFailed,EventSystemFailed) as e:
+							print ('     ---> ERROR: ', e[0].desc)
+							sys.exit(1)
+						for co in conflist:
+							if co == alarm_rule:
+								conf_found = True
+						if not conf_found:
+							print ('Not found conf for alarm ', tag)				
+							sys.exit(1)
+
+				sys.exit(0)
+
+	if len(sys.argv) < 3:
+		print ('Usage:', sys.argv[0], ' --device=alarm_device --conf=alarm_rule | --file=filename')
+		print ()
+		print ('Examples:')
+		print ('\tcheck one alarm_rule in alarm/handler/01:', sys.argv[0], '--device=alarm/handler/01 --conf=\"tag=test0;formula=(alarm/test/01/condition == 1);on_delay=0;off_delay=0;priority=high;shlvd_time=0;group=gr_test;message=Test alarm;url=;on_command=;off_command=;enabled=1\"')
+		print ('\tcheck alarm rules from filename in alarm/handler/01:', sys.argv[0], '--device=alarm/handler/01 --file=alarms.txt')
+		sys.exit(-1)
+
+# EOF

test/load-alarm-conf.py

+#!/usr/bin/python
+#
+
+import sys,re
+#import PyTango
+from PyTango import *
+import time
+import string
+	
+if __name__ == "__main__":
+
+	Device = False
+	Conf = False
+	File = False
+	#PrepareState = False
+	for arg in sys.argv:
+		word = '([a-z0-9._\-\*]*)'
+		wordpath = '([a-z0-9._\-\*/]*)'
+		m = re.compile("--device=" + word + "/{0,1}" + word + "/{0,1}" + word).match(arg.lower())
+		if m is not None:
+			domain = m.groups()[0]
+			family = m.groups()[1]
+			member = m.groups()[2]
+			if domain == '':
+				domain = '*'
+			if family == '':
+				family = '*'
+			if member == '':
+				member = '*'
+			Device = True
+		#formula = '([a-z0-9._,\*,\-,\|,\/,\",\s,\t]*)'
+		formula = '(.*)'
+		m = re.compile("--conf=" + formula).match(arg)
+		if m is not None:	
+			alarm_rule = m.groups()[0]
+			Conf = True
+		#m = re.compile("--prepare_state").match(arg.lower())
+		#if m is not None:
+		#	PrepareState = True			
+		m = re.compile("--file=" + wordpath).match(arg)
+		if m is not None:
+			file_name = m.groups()[0]
+			File = True
+	        	
+		if Device:
+			if Conf or File:
+				dev_name = domain + '/' + family + '/' + member
+				try:
+					dev = DeviceProxy(dev_name)
+				except (DevFailed,ConnectionFailed,EventSystemFailed) as e:
+					print ('ERROR connecting proxy(',dev_name,'): ',e[0].desc)
+					sys.exit(-1)				
+			if Conf:					
+				print ('Loading: ', alarm_rule)				
+				try:
+					dev.command_inout('Load',alarm_rule)
+					print ('.............OK!')
+				except (DevFailed,ConnectionFailed,EventSystemFailed) as e:
+					print ('...........ERROR!')
+					print ('     ---> ERROR: ', e[0].desc)
+					continue						
+				sys.exit(0)	
+			elif File:
+				for line in open(file_name):
+					line = line[0:-1]
+					try:					
+						dev.command_inout('Load',line)
+						time.sleep(0.1)						
+					except (DevFailed,ConnectionFailed,EventSystemFailed) as e:
+						print ('     ---> ERROR: ', e[0].desc)
+						time.sleep(2)						
+						sys.exit(1)					
+				sys.exit(0)	
+	#dev = DeviceProxy("alarm/alarm/1")
+	#dev.command_inout('Load', sys.argv[1])
+
+	if len(sys.argv) < 3:
+		print ('Usage:', sys.argv[0], ' --device=alarm_device --conf=alarm_rule | --file=filename')
+		print ()
+		print ('Examples:')
+		print ('\tload one alarm_rule in alarm/handler/01:', sys.argv[0], '--device=alarm/handler/01 --conf=\"tag=test0;formula=(alarm/test/01/condition == 1);on_delay=0;off_delay=0;priority=high;shlvd_time=0;group=gr_test;message=Test alarm;url=;on_command=;off_command=;enabled=1\"')
+		print ('\tload alarm rules from filename in alarm/handler/01:', sys.argv[0], '--device=alarm/handler/01 --file=alarms.txt')
+		sys.exit(-1)
+
+# EOF

test/testdevice/Makefile

+NAME_SRV = testdevice-srv
+
+CXXFLAGS =
+LDFLAGS = 
+
+include ./Make-9.3.4.in

test/testdevice/README.md

+# Project Name
+
+testdevice
+
+## Description
+
+Tango device server for storing and distributing a number of variables as device attributes.
+
+## Installation
+
+See your institue guidelines for deploying and configuring a Tango device server.
+
+## Usage
+
+The server is dynamically configured by means of dedicated Methods. The configuration and values are stored in the Tango Database and restored at server restart.
+A typical usage is to store and distribute the results of measurments or simulations to a number of differet clients.
+
+## History
+
+
+## Credits
+
+
+Elettra-Sincrotrone Trieste S.C.p.A. di interesse nazionale
+Strada Statale 14 - km 163,5 in AREA Science Park
+34149 Basovizza, Trieste ITALY
+
+## License
+
+GPL 3

test/testdevice/src/CMakeLists.txt

+cmake_minimum_required(VERSION 3.2)
+
+# source files
+set(SRC_FILES ${SRC_FILES}
+    ${CMAKE_CURRENT_SOURCE_DIR}/TestDevice.cpp
+    ${CMAKE_CURRENT_SOURCE_DIR}/TestDeviceClass.cpp
+    ${CMAKE_CURRENT_SOURCE_DIR}/TestDeviceStateMachine.cpp
+    ${CMAKE_CURRENT_SOURCE_DIR}/ClassFactory.cpp
+    ${CMAKE_CURRENT_SOURCE_DIR}/main.cpp
+    PARENT_SCOPE)