LATsweep.py

#!/usr/bin/env python
#
#                               Copyright 2002
#                                     by
#                        The Board of Trustees of the
#                     Leland Stanford Junior University.
#                            All rights reserved.
#

__facility__ = "Online"
__abstract__ = "Sweep handler class"
__author__   = "S. Tuvi <stuvi@SLAC.Stanford.edu> SLAC - GLAST LAT I&T/Online"
__date__     = ("$Date: 2005/03/04 21:32:00 $").split(' ')[1]
__version__  = "$Revision: 2.13 $"
__release__  = "$Name: R04-12-00 $"
__credits__  = "SLAC"

import LATTE.copyright_SLAC

import sys

from LATTE.database import gLAT
from LATTE.client   import gException

class LATsweep(object):
  """Saves the current values of the registers, sets the TEM to a
  valid and known state for reliable event data taking. Triggers the event and
  then restores the registers to their prior values. This is done to make sure
  the sweep events that are retrieved from the TEM are good events.

  \param lat        The LAT object hierarchy
  \param trigger    The trigger object
  \param sweepEvent Event() object passed to the trigger

  """

  def __init__(self, lat, trigger, shut):
    self.__lat = lat
    self.__trigger = trigger
    self.__shut    = shut

  def shut(self, sweepEvent, progress = None):
    # Disable the trigger since we are going to access registers
    self.__trigger.disable()

    # Use a temporary LAT hierarchy in case the current lat
    # doesn't define what we need to access.
    tempLAT = gLAT.GLAT(self.__lat.client())
    tkrTimeouts = {}
    tkrConfig = {}
    calConfig = {}
    for (temId, tem) in self.__lat.TEM.items():
      try:
        tem.configuration # Check to see if this TEM really exists
        tempTEM = tempLAT._GLAT__addTEM(temId)
      except gException.LATInterfaceException:
        if sys.exc_info()[1].errstr()[0] in ('LCB_RTOERR', 'LCBD_RTOERR') \
            and self.__lat.getDeclarations()['options']['ignorehardwaretimeouts']:
          continue
        else:
          raise gException.LATInterfaceException(sys.exc_info()[1].status)

      # Save the configuration register values of the CCCs and TCCCs
      # that are defined in the schema
      tkrConfig[temId] = {}
      tkrTimeouts[temId] = {}
      for cc in range(8):
        tempTCC = tempTEM._GTEM__addTCC(cc)
        timeouts = tempTCC.event_timeouts
        if timeouts != 0:
          tkrTimeouts[temId][cc] = timeouts
        tkrConfig[temId][cc] = tempTCC.configuration
      calConfig[temId] = {}
      for cc in range(4):
        tempCCC = tempTEM._GTEM__addCCC(cc)
        calConfig[temId][cc] = tempCCC.configuration
    # Broadcast to all TEMS
    if self.__lat.TEMcnt() > 0:
      tempTEMall = tempLAT._GLAT__addTEM(255)
      allTCC = tempTEMall._GTEM__addTCC(255)
      allTCC.event_timeouts = (1L << 14) - 1
      allTCC.configuration = (1L << 31)
      tempTEMall._GTEM__addCCC(255).configuration = (1L << 31)
      # Put back the timeouts that werent zero.
      for temId in tkrTimeouts.keys():
        for cc in tkrTimeouts[temId]:
          tempLAT.TEM[temId].TCC[cc].event_timeouts = tkrTimeouts[temId][cc]
      # Put back the configuration values that we saved ORing with (1<<31)
      for temId in tkrConfig.keys():
        tempTEM = tempLAT.TEM[temId]
        for cc in tkrConfig[temId]:
          tempTEM.TCC[cc].configuration = (tkrConfig[temId][cc] | (1L << 31))
        for cc in calConfig[temId]:
          tempTEM.CCC[cc].configuration = (calConfig[temId][cc] | (1L << 31))

    #self.__trigger._shut(sweepEvent, progress)
    swept = self.__shut(sweepEvent, progress)

    # Finally restore the configuration register values to their initial settings.
    for temId in tkrConfig.keys():
      tempTEM = tempLAT.TEM[temId]
      for cc in tkrConfig[temId].keys():
        tempTEM.TCC[cc].configuration = tkrConfig[temId][cc]
      for cc in calConfig[temId].keys():
        tempTEM.CCC[cc].configuration = calConfig[temId][cc]

    return swept

---