diff --git a/StatsCrosslet-DS/StatsCrosslet.py b/StatsCrosslet-DS/StatsCrosslet.py
new file mode 100644
index 0000000000000000000000000000000000000000..2e0bb6ebe0b8b811971c50d1acc04d17ab172564
--- /dev/null
+++ b/StatsCrosslet-DS/StatsCrosslet.py
@@ -0,0 +1,318 @@
+# -*- coding: utf-8 -*-
+#
+# This file is part of the StatsCrosslet project
+#
+#
+#
+# Distributed under the terms of the APACHE license.
+# See LICENSE.txt for more info.
+
+""" OPC-UA client for LOFAR stations crosslet stats
+
+"""
+
+# PyTango imports
+import tango
+from tango import DebugIt
+from tango.server import run
+from tango.server import Device
+from tango.server import attribute, command, pipe
+from tango.server import device_property
+from tango import AttrQuality, DispLevel, DevState
+from tango import AttrWriteType, PipeWriteType
+# Additional import
+# PROTECTED REGION ID(StatsCrosslet.additionnal_import) ENABLED START #
+import opcua
+import numpy
+import traceback
+import threading
+import time
+# PROTECTED REGION END # // StatsCrosslet.additionnal_import
+
+__all__ = ["StatsCrosslet", "main"]
+
+
+class StatsCrosslet(Device):
+ """
+
+ **Properties:**
+
+ - Device Property
+ OPC_Server_Name
+ - Type:'DevString'
+ OPC_Server_Port
+ - Type:'DevULong'
+ OPC_time_out
+ - Type:'DevULong'
+ """
+ # PROTECTED REGION ID(StatsCrosslet.class_variable) ENABLED START #
+ client = 0
+ ns = 0
+ obj = 0
+ record_cross = 0
+ data = []
+ data_lock = threading.Lock()
+ stop_data_read_loop = threading.Event()
+ data_acquisition_is_active = threading.Event()
+ data_read_loop = threading.Thread()
+
+ def read_data(self):
+ # This is the the thread that continuously reads the crosslet
+ # statistics from the station and feeds it into the Tango
+ # property system.
+ while self.stop_data_read_loop.is_set() is False:
+ time.sleep(self._pause_time)
+ if self.data_acquisition_is_active.is_set() is True:
+ data = []
+ try:
+ timestamp, visibilities, rcu_modes = self.obj.call_method(self.record_cross, self._subband, self._integration_time)
+ self.data_lock.acquire()
+ self._time_stamp = timestamp
+ self._raw_visibilities = visibilities
+ self._visibilities = numpy.array(visibilities)[0] + 1j * numpy.array(visibilities[1])
+ self._rcu_modes = rcu_modes
+ self.data_lock.release()
+
+ except Exception as e:
+ print("Cannot call the method %s in the OPC-UA server %s. Trace: %s" % (self.record_cross, self.OPC_Server_Name, traceback.format_exc
+()))
+ # PROTECTED REGION END # // StatsCrosslet.class_variable
+
+ # -----------------
+ # Device Properties
+ # -----------------
+
+ OPC_Server_Name = device_property(
+ dtype='DevString',
+ default_value="okeanos"
+ )
+
+ OPC_Server_Port = device_property(
+ dtype='DevULong',
+ default_value=55556
+ )
+
+ OPC_time_out = device_property(
+ dtype='DevULong',
+ default_value=1000
+ )
+
+ # ----------
+ # Attributes
+ # ----------
+
+ subband = attribute(
+ dtype='DevUShort',
+ access=AttrWriteType.READ_WRITE,
+ )
+
+ integration_time = attribute(
+ dtype='DevDouble',
+ )
+
+ time_stamp = attribute(
+ dtype='DevDouble',
+ )
+
+ pause_time = attribute(
+ dtype='DevDouble',
+ access=AttrWriteType.READ_WRITE,
+ )
+
+ visibilities = attribute(
+ dtype=('DevDouble',),
+ max_dim_x=96,
+ )
+
+ rcu_modes = attribute(
+ dtype=('DevString',),
+ max_dim_x=96,
+ )
+
+ raw_visibilities = attribute(
+ dtype=(('DevDouble',),),
+ max_dim_x=96, max_dim_y=96,
+ )
+
+ # -----
+ # Pipes
+ # -----
+
+ pipe_visibilities = pipe(
+ )
+ pipe_raw_visibilities = pipe(
+ )
+
+ # ---------------
+ # General methods
+ # ---------------
+
+ def init_device(self):
+ """Initialises the attributes and properties of the StatsCrosslet."""
+ Device.init_device(self)
+ # PROTECTED REGION ID(StatsCrosslet.init_device) ENABLED START #
+ self._visibilities = (0.0,)
+ try:
+ self.client = opcua.Client("opc.tcp://{}:{}/".format(self.OPC_Server_Name, self.OPC_Server_Port), self.OPC_time_out)
+ self.client.connect()
+ ns = self.client.get_namespace_index("http://lofar.eu")
+ self.obj = self.client.get_root_node().get_child(["0:Objects", "{}:StationMetrics".format(ns), "{}:RCU".format(ns)])
+ self.record_cross = "{}:record_cross".format(ns)
+ self.data_read_loop = threading.Thread(target = self.read_data)
+ self.data_acquisition_is_active.set()
+ self.stop_data_read_loop.clear()
+ self.data_read_loop.start()
+ except Exception as e:
+ print("Cannot connect to the OPC-UA server %s. Trace: %s" % (self.OPC_Server_Name, traceback.format_exc()))
+ # PROTECTED REGION END # // StatsCrosslet.init_device
+
+ def always_executed_hook(self):
+ """Method always executed before any TANGO command is executed."""
+ # PROTECTED REGION ID(StatsCrosslet.always_executed_hook) ENABLED START #
+ # PROTECTED REGION END # // StatsCrosslet.always_executed_hook
+
+ def delete_device(self):
+ """Hook to delete resources allocated in init_device.
+
+ This method allows for any memory or other resources allocated in the
+ init_device method to be released. This method is called by the device
+ destructor and by the device Init command.
+ """
+ # PROTECTED REGION ID(StatsCrosslet.delete_device) ENABLED START #
+ self.data_acquisition_is_active.clear()
+ self.stop_data_read_loop.set()
+ self.data_read_loop.join()
+ if self.client is not Null:
+ self.client.close_session()
+ self.client_secure_channel()
+ # PROTECTED REGION END # // StatsCrosslet.delete_device
+ # ------------------
+ # Attributes methods
+ # ------------------
+
+ def read_subband(self):
+ # PROTECTED REGION ID(StatsCrosslet.subband_read) ENABLED START #
+ """Return the subband attribute."""
+ return self._subband
+ # PROTECTED REGION END # // StatsCrosslet.subband_read
+
+ def write_subband(self, value):
+ # PROTECTED REGION ID(StatsCrosslet.subband_write) ENABLED START #
+ """Set the subband attribute."""
+ self._subband = value
+ # PROTECTED REGION END # // StatsCrosslet.subband_write
+
+ def read_integration_time(self):
+ # PROTECTED REGION ID(StatsCrosslet.integration_time_read) ENABLED START #
+ """Return the integration_time attribute."""
+ return self._integration_time
+ # PROTECTED REGION END # // StatsCrosslet.integration_time_read
+
+ def read_time_stamp(self):
+ # PROTECTED REGION ID(StatsCrosslet.time_stamp_read) ENABLED START #
+ """Return the time_stamp attribute."""
+ self.data_lock.acquire()
+ time_stamp = self._time_stamp
+ self.data_lock.release()
+ return time_stamp
+ # PROTECTED REGION END # // StatsCrosslet.time_stamp_read
+
+ def read_pause_time(self):
+ # PROTECTED REGION ID(StatsCrosslet.pause_time_read) ENABLED START #
+ """Return the pause_time attribute."""
+ return self._pause_time
+ # PROTECTED REGION END # // StatsCrosslet.pause_time_read
+
+ def write_pause_time(self, value):
+ # PROTECTED REGION ID(StatsCrosslet.pause_time_write) ENABLED START #
+ """Set the pause_time attribute."""
+ self._pause_time = value
+ # PROTECTED REGION END # // StatsCrosslet.pause_time_write
+
+ def read_visibilities(self):
+ # PROTECTED REGION ID(StatsCrosslet.visibilities_read) ENABLED START #
+ """Return the visibilities attribute."""
+ self.data_lock.acquire()
+ visibilities = self._visibilities
+ self.data_lock.release()
+ return visibilities
+ # PROTECTED REGION END # // StatsCrosslet.visibilities_read
+
+ def read_rcu_modes(self):
+ # PROTECTED REGION ID(StatsCrosslet.rcu_modes_read) ENABLED START #
+ """Return the rcu_modes attribute."""
+ self.data_lock.acquire()
+ rcu_modes = self._rcu_modes
+ self.data_lock.release()
+ return rcu_modes
+ # PROTECTED REGION END # // StatsCrosslet.rcu_modes_read
+
+ def read_raw_visibilities(self):
+ # PROTECTED REGION ID(StatsCrosslet.raw_visibilities_read) ENABLED START #
+ """Return the raw_visibilities attribute."""
+ self.data_lock.acquire()
+ raw_visibilities = self._raw_visibilities
+ self.data_lock.release()
+ return raw_visibilities
+ # PROTECTED REGION END # // StatsCrosslet.raw_visibilities_read
+
+ # -------------
+ # Pipes methods
+ # -------------
+
+ def read_pipe_visibilities(self):
+ # PROTECTED REGION ID(StatsCrosslet.pipe_visibilities_read) ENABLED START #
+ return dict(x=0, y=0)
+ # PROTECTED REGION END # // StatsCrosslet.pipe_visibilities_read
+
+ def read_pipe_raw_visibilities(self):
+ # PROTECTED REGION ID(StatsCrosslet.pipe_raw_visibilities_read) ENABLED START #
+ return dict(x=0, y=0)
+ # PROTECTED REGION END # // StatsCrosslet.pipe_raw_visibilities_read
+
+ # --------
+ # Commands
+ # --------
+
+ @command(
+ )
+ @DebugIt()
+ def start_acquisition(self):
+ # PROTECTED REGION ID(StatsCrosslet.start_acquisition) ENABLED START #
+ """
+ Start the data acquisition of the station`s crosslet stats.
+
+ :param argin: 'DevULong'
+
+ :return:None
+ """
+ self.data_acquisition_is_active.set()
+ # PROTECTED REGION END # // StatsCrosslet.start_acquisition
+
+ @command(
+ )
+ @DebugIt()
+ def stop_acquisition(self):
+ # PROTECTED REGION ID(StatsCrosslet.stop_acquisition) ENABLED START #
+ """
+ Stop the data acquisition.
+
+ :return:None
+ """
+ self.data_acquisition_is_active.clear()
+ # PROTECTED REGION END # // StatsCrosslet.stop_acquisition
+
+# ----------
+# Run server
+# ----------
+
+
+def main(args=None, **kwargs):
+ """Main function of the StatsCrosslet module."""
+ # PROTECTED REGION ID(StatsCrosslet.main) ENABLED START #
+ return run((StatsCrosslet,), args=args, **kwargs)
+ # PROTECTED REGION END # // StatsCrosslet.main
+
+
+if __name__ == '__main__':
+ main()
diff --git a/StatsCrosslet-DS/StatsCrosslet.xmi b/StatsCrosslet-DS/StatsCrosslet.xmi
new file mode 100644
index 0000000000000000000000000000000000000000..884ebb33d7a932c094ea3b0dde400bb1f1742cc3
--- /dev/null
+++ b/StatsCrosslet-DS/StatsCrosslet.xmi
@@ -0,0 +1,119 @@
+<?xml version="1.0" encoding="ASCII"?>
+<pogoDsl:PogoSystem xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:pogoDsl="http://www.esrf.fr/tango/pogo/PogoDsl">
+ <classes name="StatsCrosslet" pogoRevision="9.6">
+ <description description="" title="OPC-UA client for LOFAR stations crosslet stats" sourcePath="/opt/tango/StatsCrosslet-DS" language="PythonHL" filestogenerate="XMI file,Code files,Protected Regions" license="APACHE" copyright="" hasMandatoryProperty="false" hasConcreteProperty="true" hasAbstractCommand="false" hasAbstractAttribute="false">
+ <inheritances classname="Device_Impl" sourcePath=""/>
+ <identification contact="at astron.nl - jurges" author="jurges" emailDomain="astron.nl" classFamily="Acquisition" siteSpecific="" platform="Unix Like" bus="Ethernet" manufacturer="" reference=""/>
+ </description>
+ <deviceProperties name="OPC_Server_Name" description="">
+ <type xsi:type="pogoDsl:StringType"/>
+ <status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
+ <DefaultPropValue>okeanos</DefaultPropValue>
+ </deviceProperties>
+ <deviceProperties name="OPC_Server_Port" description="">
+ <type xsi:type="pogoDsl:UIntType"/>
+ <status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
+ <DefaultPropValue>55556</DefaultPropValue>
+ </deviceProperties>
+ <deviceProperties name="OPC_time_out" description="">
+ <type xsi:type="pogoDsl:UIntType"/>
+ <status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
+ <DefaultPropValue>1000</DefaultPropValue>
+ </deviceProperties>
+ <commands name="State" description="This command gets the device state (stored in its device_state data member) and returns it to the caller." execMethod="dev_state" displayLevel="OPERATOR" polledPeriod="0">
+ <argin description="none">
+ <type xsi:type="pogoDsl:VoidType"/>
+ </argin>
+ <argout description="Device state">
+ <type xsi:type="pogoDsl:StateType"/>
+ </argout>
+ <status abstract="true" inherited="true" concrete="true"/>
+ </commands>
+ <commands name="Status" description="This command gets the device status (stored in its device_status data member) and returns it to the caller." execMethod="dev_status" displayLevel="OPERATOR" polledPeriod="0">
+ <argin description="none">
+ <type xsi:type="pogoDsl:VoidType"/>
+ </argin>
+ <argout description="Device status">
+ <type xsi:type="pogoDsl:ConstStringType"/>
+ </argout>
+ <status abstract="true" inherited="true" concrete="true"/>
+ </commands>
+ <commands name="start_acquisition" description="Start the data acquisition of the station`s crosslet stats." execMethod="start_acquisition" displayLevel="OPERATOR" polledPeriod="0" isDynamic="false">
+ <argin description="">
+ <type xsi:type="pogoDsl:VoidType"/>
+ </argin>
+ <argout description="">
+ <type xsi:type="pogoDsl:VoidType"/>
+ </argout>
+ <status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
+ </commands>
+ <commands name="stop_acquisition" description="Stop the data acquisition." execMethod="stop_acquisition" displayLevel="OPERATOR" polledPeriod="0" isDynamic="false">
+ <argin description="">
+ <type xsi:type="pogoDsl:VoidType"/>
+ </argin>
+ <argout description="">
+ <type xsi:type="pogoDsl:VoidType"/>
+ </argout>
+ <status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
+ </commands>
+ <attributes name="subband" attType="Scalar" rwType="READ_WRITE" displayLevel="OPERATOR" polledPeriod="0" maxX="" maxY="" allocReadMember="true" isDynamic="false">
+ <dataType xsi:type="pogoDsl:UShortType"/>
+ <changeEvent fire="false" libCheckCriteria="false"/>
+ <archiveEvent fire="false" libCheckCriteria="false"/>
+ <dataReadyEvent fire="false" libCheckCriteria="true"/>
+ <status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
+ <properties description="" label="" unit="" standardUnit="" displayUnit="" format="" maxValue="" minValue="" maxAlarm="" minAlarm="" maxWarning="" minWarning="" deltaTime="" deltaValue=""/>
+ </attributes>
+ <attributes name="integration_time" attType="Scalar" rwType="READ" displayLevel="OPERATOR" polledPeriod="0" maxX="" maxY="" allocReadMember="true" isDynamic="false">
+ <dataType xsi:type="pogoDsl:DoubleType"/>
+ <changeEvent fire="false" libCheckCriteria="false"/>
+ <archiveEvent fire="false" libCheckCriteria="false"/>
+ <dataReadyEvent fire="false" libCheckCriteria="true"/>
+ <status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
+ <properties description="" label="" unit="" standardUnit="" displayUnit="" format="" maxValue="" minValue="" maxAlarm="" minAlarm="" maxWarning="" minWarning="" deltaTime="" deltaValue=""/>
+ </attributes>
+ <attributes name="time_stamp" attType="Scalar" rwType="READ" displayLevel="OPERATOR" polledPeriod="0" maxX="" maxY="" allocReadMember="true" isDynamic="false">
+ <dataType xsi:type="pogoDsl:DoubleType"/>
+ <changeEvent fire="false" libCheckCriteria="false"/>
+ <archiveEvent fire="false" libCheckCriteria="false"/>
+ <dataReadyEvent fire="false" libCheckCriteria="true"/>
+ <status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
+ <properties description="" label="" unit="" standardUnit="" displayUnit="" format="" maxValue="" minValue="" maxAlarm="" minAlarm="" maxWarning="" minWarning="" deltaTime="" deltaValue=""/>
+ </attributes>
+ <attributes name="pause_time" attType="Scalar" rwType="READ_WRITE" displayLevel="OPERATOR" polledPeriod="0" maxX="" maxY="" allocReadMember="true" isDynamic="false">
+ <dataType xsi:type="pogoDsl:DoubleType"/>
+ <changeEvent fire="false" libCheckCriteria="false"/>
+ <archiveEvent fire="false" libCheckCriteria="false"/>
+ <dataReadyEvent fire="false" libCheckCriteria="true"/>
+ <status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
+ <properties description="" label="" unit="" standardUnit="" displayUnit="" format="" maxValue="" minValue="" maxAlarm="" minAlarm="" maxWarning="" minWarning="" deltaTime="" deltaValue=""/>
+ </attributes>
+ <attributes name="visibilities" attType="Spectrum" rwType="READ" displayLevel="OPERATOR" polledPeriod="0" maxX="96" maxY="" allocReadMember="true" isDynamic="false">
+ <dataType xsi:type="pogoDsl:DoubleType"/>
+ <changeEvent fire="false" libCheckCriteria="false"/>
+ <archiveEvent fire="false" libCheckCriteria="false"/>
+ <dataReadyEvent fire="false" libCheckCriteria="true"/>
+ <status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
+ <properties description="" label="" unit="" standardUnit="" displayUnit="" format="" maxValue="" minValue="" maxAlarm="" minAlarm="" maxWarning="" minWarning="" deltaTime="" deltaValue=""/>
+ </attributes>
+ <attributes name="rcu_modes" attType="Spectrum" rwType="READ" displayLevel="OPERATOR" polledPeriod="0" maxX="96" maxY="" allocReadMember="true" isDynamic="false">
+ <dataType xsi:type="pogoDsl:StringType"/>
+ <changeEvent fire="false" libCheckCriteria="false"/>
+ <archiveEvent fire="false" libCheckCriteria="false"/>
+ <dataReadyEvent fire="false" libCheckCriteria="true"/>
+ <status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
+ <properties description="" label="" unit="" standardUnit="" displayUnit="" format="" maxValue="" minValue="" maxAlarm="" minAlarm="" maxWarning="" minWarning="" deltaTime="" deltaValue=""/>
+ </attributes>
+ <attributes name="raw_visibilities" attType="Image" rwType="READ" displayLevel="OPERATOR" polledPeriod="0" maxX="96" maxY="96" allocReadMember="true" isDynamic="false">
+ <dataType xsi:type="pogoDsl:DoubleType"/>
+ <changeEvent fire="false" libCheckCriteria="false"/>
+ <archiveEvent fire="false" libCheckCriteria="false"/>
+ <dataReadyEvent fire="false" libCheckCriteria="true"/>
+ <status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
+ <properties description="" label="" unit="" standardUnit="" displayUnit="" format="" maxValue="" minValue="" maxAlarm="" minAlarm="" maxWarning="" minWarning="" deltaTime="" deltaValue=""/>
+ </attributes>
+ <pipes name="pipe_visibilities" description="" label="" rwType="READ" displayLevel="OPERATOR"/>
+ <pipes name="pipe_raw_visibilities" description="" label="" rwType="READ" displayLevel="OPERATOR"/>
+ <preferences docHome="./doc_html" makefileHome="/usr/local/share/pogo/preferences"/>
+ </classes>
+</pogoDsl:PogoSystem>
diff --git a/StatsCrosslet-DS/requirements.txt b/StatsCrosslet-DS/requirements.txt
new file mode 100644
index 0000000000000000000000000000000000000000..3b3b3b08bb560cfbe4fed2e7c7a0241f02f0af24
--- /dev/null
+++ b/StatsCrosslet-DS/requirements.txt
@@ -0,0 +1 @@
+opcua >= 0.98.9