temLrsTest.py

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

__facility__ = "Online"
__abstract__ = "Application to test the TEM's LRS counters"
__author__   = "R. Claus <Claus@SLAC.Stanford.edu> SLAC - GLAST LAT I&T/Online"
__date__     = ("$Date: 2005/03/21 17:58:11 $").split(' ')[1]
__version__  = "$Revision: 1.2 $"
__release__  = "$Name: R04-12-00 $"
__credits__  = "SLAC"

import LATTE.copyright_SLAC

import            threading
import logging as log
import            time

from   LATTE.runcontrol.rcTransitions  import rcTransitions
from   LATTE.runcontrol.ArgumentImpl   import ArgumentImpl
#from   rcHouseKeeping import rcHouseKeeping

from support.SimpleGasuExample   import *
from support.MiniGLTExample      import *


#  Example application implementation.
#  Note that the name of the class must be userApplication.
#  Look at rcTransitions for names of other transition methods that can be used.
class userApplication(rcTransitions):
  "Implmentation class for a user application"
  def __init__(self, rc, userId, debug):
    rcTransitions.__init__(self, rc, userId, debug)
    log.debug("userApplication.__init__()")

  def getName(self):
    return __name__

  def setup(self):
    log.debug("userApplication.setup()")

    # Get a TEM instance
    if self.lat.TEMcnt() == 1:
      tem = self.lat.TEM[self.lat.TEM.keys()[0]]
    elif self.lat.TEMcnt() > 1:
      #tem = self.lat.TEM.all()
      log.fatal("More than one TEM found in the schema")
      return -1
    else:
      log.fatal("No TEM found in the schema")
      return -1

    # clear TEM stats reg
    tem.COMMAND_RESPONSE = 0

    # clear TEM status reg
    tem.STATUS = 0

    # enable output in our GCCCs
    # broadcast load of GCCC_REG_CONFIGURATION

    bcast_ccc = tem.allCCC()
    bcast_ccc.CONFIGURATION = 0x80000000L

    #  disable all GCRCs in all GCCCs via broadcast # GCCC_REG_LAYER_MASK_0, GCCC_REG_LAYER_MASK_1
    bcast_ccc.LAYER_MASK_0 = 0xFFFFFFFFL
    bcast_ccc.LAYER_MASK_1 = 0xFFFFFFFFL
    ccc0 = tem.downCCC(0) # O$GCCC_00
    ccc0.LAYER_MASK_0 = 0xFFFF0000L
    ccc0.LAYER_MASK_1 = 0xFFFF000FL
    ccc2 = tem.downCCC(2) # O$GCCC_02
    ccc2.LAYER_MASK_0 = 0xFFFF0000L
    ccc2.LAYER_MASK_1 = 0xFFFF0000L

    # config GCFE for calibration -- range 0 first
    bcast_cfe = tem.allCCC().allCRC().allCFE()
    bcast_cfe.CONFIG_0    = 0x00
    bcast_cfe.CONFIG_1    = 0x36
    bcast_cfe.FLE_DAC     = 0x55
    bcast_cfe.FHE_DAC     = 0x55
    bcast_cfe.LOG_ACPT    = 0x10
    bcast_cfe.RNG_ULD_DAC = 0x7F
    bcast_cfe.REF_DAC     = 0x7f

    # config GCRC for calibration
    bcast_crc = tem.allCCC().allCRC()
    bcast_crc.DELAY_1 = 0xFF
    bcast_crc.DELAY_2 = 0xFF
    bcast_crc.DELAY_3 = 0xFF
    bcast_crc.DAC = 0x42FE
    bcast_crc.DAC = 0x42FE

    # large timeouts for all GCCCs
    # broadcast load of GCCC_REG_EVENT_TIMEOUTS
    bcast_ccc.EVENT_TIMEOUTS = 0x0
    #status = gGCCCread( __GT, temId, 1, GCCC_REG_EVENT_TIMEOUTS, &payload);
    #printf("gccc register event timeouts = 0x%08x\n", payload);

    # Register environment variables for housekeeping
    #hsk = self.getHSK()
    #regs = [tem.regs['data_masks'], ccc2.regs['layer_mask_1']]
    #hsk.addEnvRegs(regs)
    #hsk.setUpdateInterval(1)

    # Two choices for the trigger, GEM and MiniGLT
    if self.lat.existsGEM():
      self.trigger( SimpleGasuExample() )
    else:
      self.trigger( MiniGLTExample() )

    # Override the default event handler
    self.selectEventHandler(rcTransitions.EVENT_HANDLER_LEAN_AND_MEAN)

    # A state transition can be rejected by not returning None
    return None

  def startRun(self):
    log.debug("userApplication.startRun()")

    # Spawn a thread to synchronize commands with events
    self.__cmdSynchQuit = False

    # A state transition can be rejected by not returning None
    return None

  def stopRun(self):
    log.debug("userApplication.stopRun()")

    if self.getBadEvents() == 0 and self.getErrorEvents() == 0:
      self.setCompletionStatus(self.COMPL_STATUS_PASSED)
    else:
      self.setCompletionStatus(self.COMPL_STATUS_FAILED)

    self.__cmdSynchQuit = True

    # The STOP_RUN transition can not be rejected

  def resume(self):
    log.debug("userApplication.resume()")

    # Issue self trigger to make up for the one that was lost during PAUSE
    self.trigger().solicit()

    return None

  def stop(self):
    log.debug("userApplication.stop()")

    return self.stopRun()

  def teardown(self):
    log.debug("userApplication.teardown()")

  def process(self, (status, latDatagram)):
    "Method called back for each data event taken"
    #log.debug("userApplication.process()")

    pass


  def commandSynch(self):
    "Method called by the command synchronization task"
    import time
    trigger  = self.trigger()

    # Wait for START_RUN to enable triggers
    trigger.waitForMaskEnable()

    # Get a TEM instance
    if self.lat.TEMcnt() == 1:
      tem = self.lat.TEM[self.lat.TEM.keys()[0]]
    elif self.lat.TEMcnt() > 1:
    #  tem = self.lat.TEM.all()
      log.fatal("More than one TEM found in the schema")
      return -1
    else:
      log.fatal("No TEM found in the schema")
      return -1

    lrsId = tem.TIC.regs ['sat_deadtime_lrs_ctr'].id()
    print "Deadtime LRS saturation counter ID =", lrsId
    tem.TIC.satCtrDisable(lrsId)
    print "Deadtime LRS saturation counters disabled"

    tem.TIC.sat_deadtime_lrs_ctr = 0
    print "Deadtime LRS saturation counters cleared"

    tem.TIC.satCtrEnable(lrsId)
    print "Deadtime LRS saturation counters enabled"

    t = 0
    while not self.__cmdSynchQuit and t < 30:
      print "Deadtime LRS saturation counter = ", tem.TIC.sat_deadtime_lrs_ctr
      time.sleep(1.0)
      t += 1

    # execute the GUI functions for stopRun, just in case
    if not self.__cmdSynchQuit and not self.isRunFromSuite():
      if self.rc is not None:
        self.rc.doStop()

  def wait(self):
    #self.__cmdSynchSem.acquire()
    pass

  def sync(self):
    if __name__ == "__main__" or self.isRunFromSuite():
      self.__cmdSynchSem.release()
      pass


# Standalone mode:
if __name__ == "__main__":
  import os
  log.basicConfig()
  log.getLogger("").setLevel(log.DEBUG)
  ua = userApplication(None, 321, 0)
  prefs = {'datasave': 1, 'datadir':os.path.join(os.environ['ONLINE_ROOT'],'temp')}
  ua.setPrefs(prefs)
  ua.rcSetup(os.path.join(os.environ['ONLINE_ROOT'], 'repos/simpleTemSchema.xml'))
  ua.rcStartRun()
  ua.wait()
  ua.rcStopRun()
  ua.rcTeardown()

# History:
#     $Log: temLrsTest.py,v $
#     Revision 1.2  2005/03/21 17:58:11  claus
#     Modified to use the first TEM found in the schema, if only one is there, or
#     broadcast to all TEMs if there are multiple.
#
#     Revision 1.1  2005/02/15 01:38:36  claus
#     Initial stab at a tester for the TEM LRS counters.  It currently checks
#     only whether the deadtime counter functions throw an exception or not.
#
#     Revision 1.2  2004/10/18 01:00:19  claus
#     Provided switch between 2 examples of adding custom LATcontributions.
#
#     Revision 1.4  2004/08/31 03:13:38  stuvi
#     Integrated the parameter verifier with Run Control
#
#     Revision 1.3  2004/08/18 18:00:15  stuvi
#     Updated for LATTE 4.
#     All hippo functions go through the Qt GUI bridge now.
#
#     Revision 1.2  2004/08/13 04:46:22  claus
#     Got rid of obsolete TRUE and FALSE declarations.
#
#     Revision 1.1  2004/07/28 21:24:00  stuvi
#     Added testAppCal and its supporting classes.
#
#     Revision 1.28  2004/07/09 23:14:17  stuvi
#     Added "operatorobj" preference that contains the rcUser object and left the "operator" preference to contain the user name.
#
#     Revision 1.27  2004/05/03 22:49:36  stuvi
#     Added commented out code example that demonstrates how to access the CAL and TKR diagnostics contributions.
#
#     Revision 1.26  2004/05/03 21:19:47  stuvi
#     Moved non-Runcontrol scripts to the support directory and modified imports accordingly.
#
#     Revision 1.25  2004/04/21 21:05:29  stuvi
#     Added an example of how to pass the preferences using the setPrefs method when running in standalone mode.
#
#     Revision 1.24  2004/04/17 02:23:48  stuvi
#     Added teardown() to delete the C++ object for the userArgument
#     Fixed LogData parsing based on the evtCli changes
#
#     Revision 1.23  2004/03/31 01:01:19  stuvi
#     Added commented code on how to parse the error contribution.
#
#     Revision 1.22  2004/03/10 22:24:51  panetta
#     Upgraded trigger interface.
#     Removed dependencies on self.glt.
#
#     Revision 1.21  2004/03/04 23:08:47  stuvi
#     Removed glt.destination assignment
#
#     Revision 1.20  2004/02/20 03:20:23  stuvi
#     Added handling of the sweep events and error checking to the process() method,
#
#     Revision 1.19  2004/02/13 03:13:25  stuvi
#     Sweep events are also sent to user script's process event now, so added code to handle the case.
#
#     Revision 1.18  2004/02/02 23:14:00  stuvi
#     Changes required to make the scripts work with the new FSM engine.
#
#     Revision 1.17  2004/01/30 04:33:44  claus
#     Updated for transitions not running in the GUI thread.
#     New commandSynch handling.
#
#     Revision 1.16  2003/12/19 02:05:26  stuvi
#     Added support for creating and updating GUIs from a suite
#
#     Revision 1.15  2003/12/11 02:22:35  stuvi
#     Suite and standalone mode modifications
#
#     Revision 1.14  2003/12/11 01:53:16  stuvi
#     Modified code to support suites.
#
#     Revision 1.13  2003/11/25 02:16:12  stuvi
#     Modified according to the current test setup to generate some results
#
#     Revision 1.12  2003/11/04 04:25:11  stuvi
#     Changed the commandSynch logic so that the enableMask() call would not pose a threat to snapshot taking.
#
#     Revision 1.11  2003/10/31 01:09:37  panetta
#     1)  Moved register writes from startRun to setup
#     2)  Added GLT enabling logic to __commandSynch
#     3)  Gave example of getting the start/stop time from the hardware/event stream
#
#     Revision 1.10  2003/10/28 03:17:34  stuvi
#     Added support for calculating the event rate correctly using the new GLT behaviour.
#
#     Revision 1.9  2003/08/21 21:13:38  stuvi
#     no message
#
#     Revision 1.8  2003/07/17 00:01:35  stuvi
#     no message
#
#     Revision 1.7  2003/06/13 23:26:24  stuvi
#     Added TEM reset
#
#     Revision 1.6  2003/04/12 02:38:34  stuvi
#     Added Cancel button handler to argument class
#
#     Revision 1.5  2003/04/09 00:45:15  stuvi
#     Commented out references to DATA_MASKS register which should not be touched during script execution.
#
#     Revision 1.4  2003/04/01 21:04:59  stuvi
#     Fixed event count discrepancy when the run is stopped in the middle.
#
#     Revision 1.3  2003/03/31 19:23:44  stuvi
#     Fixed name
#
#     Revision 1.2  2003/03/26 21:59:36  stuvi
#     Fixed standalone mode
#
#     Revision 1.1  2003/03/11 21:20:55  stuvi
#     Moved from RunControl directory
#
#     Revision 1.8  2003/02/06 05:19:38  claus
#     Added resume; StopRun bug fix
#
#     Revision 1.7  2003/02/06 04:14:35  claus
#     Fixed StopRun bug
#
#     Revision 1.6  2002/12/11 21:18:07  stuvi
#     Changed glt register assignments to bit field assignments
#
#     Revision 1.5  2002/12/10 01:09:58  claus
#     Added path and changed schema/config file for stand-alone mode
#
#     Revision 1.4  2002/12/04 01:59:23  claus
#     Added message logging
#
#     Revision 1.3  2002/12/02 17:17:09  claus
#     Added provision to allow application to run stand-alone
#
#     Revision 1.2  2002/11/28 02:02:04  claus
#     Shuffled constructor arguments
#
#     Revision 1.1  2002/11/27 05:02:48  claus
#     Initial version of Run Control
#

---