testAppAcd.py

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

__facility__ = "Online"
__abstract__ = "Example ACD test application"
__author__   = "R. Claus <Claus@SLAC.Stanford.edu> SLAC - GLAST LAT I&T/Online"
__date__     = "11/21/2002"
__version__  = "$Revision: 1.4 $"
__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 support.SimpleGasuExample   import *

#  This class puts up a GUI for inputting a value of some sort.  It is used by
#  the userApplication example to get the number of self triggers to take.
class userArgument(ArgumentImpl):
  "GUI for getting the user to input some sort of value"
  def __init__(self, parent = None, name = None, modal = 0, fl = 0):
    ArgumentImpl.__init__(self, parent, name, modal, fl)
    self.__value = 0
    self.setCaption("Hello world!")

  def OKButtonClicked(self):
    self.__value = int(self.ArgumentList.text().latin1())
    self.close()

  def CancelButtonClicked(self):
    self.__value = None
    self.close()

  def getValue(self, caption):
    self.setCaption(caption)
    self.show()
    self.exec_loop()
    return self.__value

class userArgText(object):
  "Text user interface for getting the user to input some sort of value"
  def __init__(self):
    pass

  def getValue(self, caption):
    return int(raw_input("%s: " % (caption)))


#  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__()")
    self.__eventSem    = threading.Semaphore(0)
    self.__cmdSynchSem = threading.Semaphore(0)

  def getName(self):
    return __name__

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

    if self.rc is None:
      self.__arg = userArgText()
    else:
      self.__arg = self.rc.createGUI(userArgument, self.rc, 'test1', 1)

    aem = self.lat.downAEM()

    arc0 = aem.downARC(11)
    arc0.cmd_reset = 1

    # configure the AEM
    aem.configuration = 0x007ff

    # The FREE-sim simulates 4 ADCs with fixed outputs of 1112, 1113, 1114, 1115 (decimal).
    # The FREE-sim simulates 4 ADCs with fixed outputs of 0x458, 0x459, 0x45a, 0x45b (hex).
    # adjust the PHA thresholds to turn these on/off.

    # config all PHAs on

    thresh_on  = 0x20
    thresh_off = 0xFFF

    arc0.PHA_THRESHOLD_0  = thresh_on
    arc0.PHA_THRESHOLD_1  = thresh_on
    arc0.PHA_THRESHOLD_2  = thresh_on
    arc0.PHA_THRESHOLD_3  = thresh_on
    arc0.PHA_THRESHOLD_4  = thresh_on
    arc0.PHA_THRESHOLD_5  = thresh_on
    arc0.PHA_THRESHOLD_6  = thresh_on
    arc0.PHA_THRESHOLD_7  = thresh_on
    arc0.PHA_THRESHOLD_8  = thresh_on
    arc0.PHA_THRESHOLD_9  = thresh_on
    arc0.PHA_THRESHOLD_10 = thresh_on
    arc0.PHA_THRESHOLD_11 = thresh_on
    arc0.PHA_THRESHOLD_12 = thresh_on
    arc0.PHA_THRESHOLD_13 = thresh_on
    arc0.PHA_THRESHOLD_14 = thresh_on
    arc0.PHA_THRESHOLD_15 = thresh_on
    arc0.PHA_THRESHOLD_16 = thresh_on
    arc0.PHA_THRESHOLD_17 = thresh_on
    arc0.veto_width      = 5

    # set MAX_PHA
    arc0.MAX_PHA = 18

    # set PHA ENABLE bits
    arc0.PHA_EN_0 = 0xffff
    arc0.PHA_EN_1 = 0x3

    # set VETO ENABLE bits
    arc0.VETO_EN_0 = 0xffff
    arc0.VETO_EN_1 = 0x3

    afeb = arc0.allAFE()
    afeb.CONFIGURATION = 0x0032
    afeb.VETO_DAC = 0x20
    afeb.HLD_DAC = 0x30
    afeb.TCI_DAC = 0x20
    afeb.bias_dac     = 3

    aem.TRGSEQ = 0x5f

    # Two choices for the trigger, GEM and MiniGLT
    if self.lat.existsGEM():
      self.trigger( SimpleGasuExample() )
    else:
      raise AssertionError, "ACD cannot take meaningful triggers without a GEM"

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

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

    caption = "Enter number of triggers to take"
    if self.rc is None:
      cnt = self.__arg.getValue(caption)
    else:
      cnt = self.rc.execGUImethod(self.__arg.getValue, caption)

    # The user pressed 'Cancel'
    if cnt is None:  return -1
    self.__cnt = cnt

    # 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()")

    self.__cmdSynchQuit = True
    self.__eventSem.release()

   # 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()")
    # Allow the C++ object to be deleted
    if self.gui is not None and self.__arg is not None:
      self.__arg.deleteLater()

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

    evtCli = self.evtCli

    if status != 0:
      if evtCli.isGGLTStatus():
        log.error("GGLT_STATUS=%d %s" % (evtCli.getGGLTStatus(), evtCli.getGGLTStatusStr()))
      elif not evtCli.checkOnlineStatus(status, self.evtCli.PLAYBACK_ERROR):
        log.error("EVENT ERROR= 0x%x %s" % (status, evtCli.getOnlineStatusStr()))
      self.__eventSem.release()
      return
    try:
      # In the future this event may contain additional data
      if evtCli.isSweepEvent(): return
    except:
      # Event summary word inaccessible, handle the bad event here
      log.exception("")
      return

    if evtCli.setCurrentContribution(evtCli.AEM) != -1:
      evtCli.evDumpEventAEM()
      print "AEM Veto Hit Vectors:"
      j = 0
      for hitVect in evtCli.evt.aem.vetoHitVectors:
        print "\tCable %2d Raw Data 0x%05x" % (j, hitVect)
        j+=1
      print "\nAEM Accept Hit Vectors:"
      j = 0
      for hitVect in evtCli.evt.aem.acceptHitVectors:
        print "\tCable %2d Raw Data 0x%05x" % (j, hitVect)
        j+=1
      print "\nAEM PHA Values:"
      j = 0
      for (cbl, phas) in evtCli.evt.aem.PHA.items():
        for pha in phas:
          print "\tCable: %02d - PHA Value: 0x%04x" % (cbl, pha.ui)

    # Get next event triggered
    self.__eventSem.release()

  #def __commandSynch(self, count):
  def commandSynch(self):
    "Method called by the command synchronization task"
    import time
    trigger  = self.trigger()
    eventSem = self.__eventSem
    # Drain the semaphore release count
    # Handles the case when the stop run release collided with a trigger release
    while eventSem.acquire(0):  pass

    t0  = time.time()

    # Compensate for the extra CMD_SELF_TRIGGER below
    cnt = 1
    count = self.__cnt

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

    trigger.solicit()                   # Issue an internal trigger
    eventSem.acquire()                  # Wait for the event to be processed

    t1 = trigger.getEnableTime()        # get the last trigger enable time from GLT

    while cnt < count and not self.__cmdSynchQuit:
      cnt += 1
      trigger.solicit()                 # Issue an internal trigger
      time.sleep(.0001)
      eventSem.acquire()                # Wait for the event to be processed
      #trigger.disable()                # Disable triggers
      # Do stuff
      #trigger.enable()                 # Enable triggers

    t2 = trigger.getTimeStamp()         # Get the last trigger timestamp

    if t1 is None:
      t1 = t0
    if t2 is None:
      t2 = time.time()
    dT = t2 - t1
    if dT == 0.0:  dT = 0.000001
    log.info("%s processed %d events in %.3f seconds = %.1f events/second" % \
             (self.getName(), self.evtCnt, dT, self.evtCnt/dT))

    # Get out of waiting when in suite or standalone mode
    self.sync()

    # 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()

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


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

# History:
#     $Log: testAppAcd.py,v $
#     Revision 1.4  2005/01/11 22:39:18  stuvi
#     no message
#
#     Revision 1.3  2004/10/22 20:32:48  stuvi
#     Fixed log.exception()
#
#     Revision 1.2  2004/08/18 18:00:15  stuvi
#     Updated for LATTE 4.
#     All hippo functions go through the Qt GUI bridge now.
#
#     Revision 1.1  2004/08/04 22:17:25  stuvi
#     no message
#
#     Revision 1.19  2004/05/13 18:55:09  stuvi
#     HLD_EN_0 and HLD_EN_1 no longer exist.
#
#     Revision 1.18  2004/05/03 21:19:47  stuvi
#     Moved non-Runcontrol scripts to the support directory and modified imports accordingly.
#
#     Revision 1.17  2004/04/20 22:09:34  stuvi
#     Changed ACD to AEM.
#
#     Revision 1.16  2004/04/17 02:22:54  stuvi
#     Added teardown() to delete the C++ object for the userArgument
#
#     Revision 1.15  2004/04/08 01:57:39  panetta
#     make testAppAcd work with GASU
#
#     Revision 1.14  2004/03/20 03:45:26  stuvi
#     Updated code to use the new PHA object.
#
#     Revision 1.13  2004/03/10 22:24:50  panetta
#     Upgraded trigger interface.
#     Removed dependencies on self.glt.
#
#     Revision 1.12  2004/02/20 03:20:23  stuvi
#     Added handling of the sweep events and error checking to the process() method,
#
#     Revision 1.11  2004/02/04 03:42:14  stuvi
#     Changes required to make the scripts work with the new FSM engine.
#
#     Revision 1.10  2003/12/11 19:54:45  stuvi
#     Suite and standalone mode modifications
#
#     Revision 1.9  2003/11/04 18:30:52  panetta
#     Changed the commandSynch logic so that the enableMask() call would not pose a threat to snapshot taking.
#
#     Revision 1.8  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.7  2003/08/14 02:36:03  stuvi
#     Fixed aem ui value access
#
#     Revision 1.6  2003/07/17 00:01:35  stuvi
#     no message
#
#     Revision 1.5  2003/04/01 21:04:59  stuvi
#     Fixed event count discrepancy when the run is stopped in the middle.
#
#     Revision 1.4  2003/03/31 19:28:53  stuvi
#     Fixed name
#
#     Revision 1.3  2003/03/26 21:59:36  stuvi
#     Fixed standalone mode
#
#     Revision 1.2  2003/03/25 04:53:52  stuvi
#     Made sure the semaphores are drained
#
#     Revision 1.1  2003/03/11 21:20:55  stuvi
#     Moved from RunControl directory
#
#     Revision 1.10  2003/02/21 04:08:03  stuvi
#     Updated for G2
#
#     Revision 1.9  2003/02/06 05:19:38  claus
#     Added resume; StopRun bug fix
#
#     Revision 1.8  2002/12/11 21:18:07  stuvi
#     Changed glt register assignments to bit field assignments
#
#     Revision 1.7  2002/12/10 01:09:58  claus
#     Added path and changed schema/config file for stand-alone mode
#
#     Revision 1.6  2002/12/04 01:59:23  claus
#     Added message logging
#
#     Revision 1.5  2002/12/02 17:17:09  claus
#     Added provision to allow application to run stand-alone
#
#     Revision 1.4  2002/11/28 02:02:03  claus
#     Shuffled constructor arguments
#
#     Revision 1.3  2002/11/27 23:49:27  claus
#     Initialize semaphore with zero count
#
#     Revision 1.2  2002/11/27 23:37:17  stuvi
#     Added semaphor release
#
#     Revision 1.1  2002/11/27 05:02:47  claus
#     Initial version of Run Control
#

---