Commit fead4dfe authored by Marco Buttu's avatar Marco Buttu
Browse files

Added AntennaBoss simulator component

parent fbea980c

Common/Interfaces/ReceiversInterface/config/CDB/schemas/DewarPositionerMapping.xsd

+2 −0
Original line number Diff line number Diff line
@@ -17,6 +17,8 @@ 


    <xs:complexType name="DewarPositionerMappingType">

        <xs:attribute name="DerotatorName" type="xs:string" use="required" />

        <xs:attribute name="ObservatoryName" type="xs:string" use="required" />

        <xs:attribute name="CoordinateSourceName" type="xs:string" use="required" />

        <xs:attribute name="SetupPosition" type="xs:string" use="required" />

        <xs:attribute name="ParkPosition" type="xs:string" use="required" />

    </xs:complexType>

Common/Servers/DewarPositioner/src/DewarPositioner/DewarPositionerImpl.py

+3 −2
Original line number Diff line number Diff line
@@ -131,7 +131,8 @@ class DewarPositionerImpl(POA, cc, services, lcycle): 
            raise exc.getComponentErrorsEx()



        try:

            observatory = self.client.getComponent('ANTENNA/Observatory')

            observatoryName = self.cdbconf.getAttribute('ObservatoryName')

            observatory = self.client.getComponent(observatoryName)

            lat_obj = observatory._get_latitude()

            latitude_dec, compl = lat_obj.get_sync()

            latitude = radians(latitude_dec)
@@ -144,7 +145,7 @@ class DewarPositionerImpl(POA, cc, services, lcycle): 
            siteInfo = {'latitude': latitude}



        try:

            sourceName = 'ANTENNA/Boss'

            sourceName = self.cdbconf.getAttribute('CoordinateSourceName')

            source = self.client.getComponent(sourceName)

        except Exception:

            logger.logWarning('cannot get the %s component' %sourceName)

Common/Servers/DewarPositioner/src/DewarPositioner/cdbconf.py

+2 −0
Original line number Diff line number Diff line
@@ -20,6 +20,8 @@ class CDBConf(object): 


    mappingAttributes = (

            'DerotatorName', 

            'ObservatoryName', 

            'CoordinateSourceName', 

            'SetupPosition',

            'ParkPosition',

    )

Common/Servers/DewarPositioner/test/AntennaSimulator/AntennaSimulatorImpl.py

0 → 100644
+139 −0
Original line number Diff line number Diff line 
from __future__ import with_statement



import operator

import math

import time

from multiprocessing import Process, Value, Lock

from Antenna__POA import AntennaBoss

from Antenna import TCoordinateFrame, ANT_EQUATORIAL, ANT_HORIZONTAL

from Management__POA import CommandInterpreter as CI

from Management__POA import Subsystem

from Acspy.Servants.CharacteristicComponent import CharacteristicComponent as CC

from Acspy.Servants.ContainerServices import ContainerServices as Services

from Acspy.Servants.ComponentLifecycle import ComponentLifecycle as Lcycle

from Acspy.Common.TimeHelper import getTimeStamp

from Acspy.Util.BaciHelper import addProperty

from AntennaSimulator.devios import GenericDevIO





__copyright__ = "Marco Buttu <mbuttu@oa-cagliari.inaf.it>"





class AntennaSimulatorImpl(AntennaBoss, CI, Subsystem, CC, Services, Lcycle):

 

    def __init__(self):

        CC.__init__(self)

        Services.__init__(self)

        self._setDefault()



    def initialize(self):

        addProperty(self, 'target', devio_ref=GenericDevIO())

        addProperty(self, 'targetRightAscension', devio_ref=GenericDevIO())

        addProperty(self, 'targetDeclination', devio_ref=GenericDevIO())

        addProperty(self, 'targetVrad', devio_ref=GenericDevIO())

        addProperty(self, 'targetFlux', devio_ref=GenericDevIO())

        addProperty(self, 'vradReferenceFrame', devio_ref=GenericDevIO())

        addProperty(self, 'vradDefinition', devio_ref=GenericDevIO())

        addProperty(self, 'azimuthOffset', devio_ref=GenericDevIO())

        addProperty(self, 'elevationOffset', devio_ref=GenericDevIO())

        addProperty(self, 'rightAscensionOffset', devio_ref=GenericDevIO())

        addProperty(self, 'declinationOffset', devio_ref=GenericDevIO())

        addProperty(self, 'longitudeOffset', devio_ref=GenericDevIO())

        addProperty(self, 'latitudeOffset', devio_ref=GenericDevIO())

        addProperty(self, 'rawAzimuth', devio_ref=GenericDevIO())

        addProperty(self, 'rawElevation', devio_ref=GenericDevIO())

        addProperty(self, 'observedAzimuth', devio_ref=GenericDevIO())

        addProperty(self, 'observedElevation', devio_ref=GenericDevIO())

        addProperty(self, 'observedRightAscension', devio_ref=GenericDevIO())

        addProperty(self, 'observedDeclination', devio_ref=GenericDevIO())

        addProperty(self, 'observedGalLongitude', devio_ref=GenericDevIO())

        addProperty(self, 'observedGalLatitude', devio_ref=GenericDevIO())

        addProperty(self, 'enabled', devio_ref=GenericDevIO())

        addProperty(self, 'correctionEnabled', devio_ref=GenericDevIO())

        addProperty(self, 'generatorType', devio_ref=GenericDevIO())

        addProperty(self, 'FWHM', devio_ref=GenericDevIO())

        addProperty(self, 'waveLength', devio_ref=GenericDevIO())

        addProperty(self, 'pointingAzimuthCorrection', devio_ref=GenericDevIO())

        addProperty(self, 'pointingElevationCorrection', devio_ref=GenericDevIO())

        addProperty(self, 'refractionCorrection', devio_ref=GenericDevIO())



    def cleanUp(self):

        pass

        

    def getApparentCoordinates(self, t):

        """Return (az, el, ra, dec) + (jepoch, lon, lat)"""

        return self.history.get(t) + (0, 0, 0)



    def setOffsets(self, lon, lat, frame):

        """Set the (az, el) or (ra, dec) offset, depending of the frame"""

        az, el, ra, dec = self.coordinates

        if frame == ANT_HORIZONTAL:

            az, el = lon, lat

        elif frame == ANT_EQUATORIAL:

            ra, dec = lon, lat

        else:

            raise ValueError('Frame %s not supported' %frame)

        self.coordinates = az, el, ra, dec

        self.history.insert(self.coordinates)



    def _setDefault(self):

        self.coordinates = [math.pi/4] * 4 # az, el, ra, dec -> 45 degrees

        self.history = History(self.coordinates)





class History(object):

    lock = Lock()



    def __init__(self, position):

        self.history = []

        self.insert(position) 



    def insert(self, position):

        data = (getTimeStamp().value, position)

        with History.lock:

            self.history.append(data)

            self.history.sort(key=operator.itemgetter(0))

            self.history = self.history[-2**15:] # Last 2**15 positions

        print 'position %s inserted in the history' %position



    def clean(self, since=0):

        target_time = since if since else getTimeStamp().value

        with History.lock:

            idx = len(self.history)

            self.history.sort(key=operator.itemgetter(0))

            for idx, item in enumerate(self.history):

                timestamp = item[0]

                if timestamp > target_time:

                    break

            self.history = self.history[:idx] 



    def get(self, target_time=None):

        """Return the position @target_time"""

        if not target_time:

            target_time = getTimeStamp().value

        size = len(self.history)

        idx = -1

        with History.lock:

            while idx >= -size:

                data = self.history[idx]

                timestamp, position = data[0], data[1:]

                if timestamp <= target_time:

                    return data[-1]

                elif idx - 1 > -size:

                    prev_timestamp = self.history[idx - 1]

                    if prev_timestamp <= target_time:

                        return self.history[idx - 1][-1] # It's better to interpolate

                    else:

                        idx -= 1

                        continue

                else:

                    return self.history[-size][-1]

                    



class Status(object):

    def __init__(self):

        self.is_slewing = Value('i', 0)

        self.is_ready = Value('i', 0)

        self.is_tracking = Value('i', 0)

        self.is_updating = Value('i', 0)

Common/Servers/DewarPositioner/test/AntennaSimulator/__init__.py

0 → 100644
+0 −0

Empty file added.