Data handler that evaluates alarm conditions and writes status outputs. More...

#include <QwAlarmHandler.h>

Inheritance diagram for QwAlarmHandler:

Collaboration diagram for QwAlarmHandler:

Data Structures
struct	alarmObject

Public Types
typedef std::vector< VQwHardwareChannel * >::iterator	Iterator_HdwChan

typedef std::vector< VQwHardwareChannel * >::const_iterator	ConstIterator_HdwChan

Public Types inherited from VQwDataHandler
enum	EQwHandleType { kHandleTypeUnknown =0 , kHandleTypeMps , kHandleTypeAsym , kHandleTypeDiff , kHandleTypeYield }

typedef std::vector< VQwHardwareChannel * >::iterator	Iterator_HdwChan

typedef std::vector< VQwHardwareChannel * >::const_iterator	ConstIterator_HdwChan

Public Member Functions
	QwAlarmHandler (const TString &name)
	Constructor with name.

	QwAlarmHandler (const QwAlarmHandler &source)
	Copy constructor.

	~QwAlarmHandler () override
	Virtual destructor.

Int_t	LoadChannelMap (const std::string &mapfile) override
	Load the channels and sensitivities.

Int_t	ConnectChannels (QwSubsystemArrayParity &yield, QwSubsystemArrayParity &asym, QwSubsystemArrayParity &diff) override
	Connect to Channels (event only)

void	ProcessData () override
	Process a single event: update alarm states and outputs.

void	CheckAlarms ()

void	UpdateAlarmFile ()

void	ParseConfigFile (QwParameterFile &) override

Public Member Functions inherited from VQwDataHandler
	VQwDataHandler (const TString &name)

	VQwDataHandler (const VQwDataHandler &source)

void	SetPointer (QwHelicityPattern *ptr)

void	SetPointer (QwSubsystemArrayParity *ptr)

virtual Int_t	ConnectChannels (QwSubsystemArrayParity &)

Int_t	ConnectChannels (QwHelicityPattern &helicitypattern)

virtual void	UpdateBurstCounter (Short_t burstcounter)

virtual void	FinishDataHandler ()

	~VQwDataHandler () override

TString	GetName ()

virtual void	ClearEventData ()

void	InitRunningSum ()

void	AccumulateRunningSum ()

virtual void	AccumulateRunningSum (VQwDataHandler &value, Int_t count=0, Int_t ErrorMask=0xFFFFFFF)

void	CalculateRunningAverage ()

void	PrintValue () const

void	WritePromptSummary (QwPromptSummary *ps, TString type)

virtual void	ConstructTreeBranches (QwRootFile *treerootfile, const std::string &treeprefix="", const std::string &branchprefix="")

virtual void	FillTreeBranches (QwRootFile *treerootfile)

virtual void	ConstructNTupleFields (QwRootFile *treerootfile, const std::string &treeprefix="", const std::string &branchprefix="")
	RNTuple methods.

virtual void	FillNTupleFields (QwRootFile *treerootfile)

virtual void	ConstructHistograms (TDirectory *, TString &)
	Construct the histograms in a folder with a prefix.

virtual void	FillHistograms ()
	Fill the histograms.

void	FillTreeVector (QwRootTreeBranchVector &values) const

void	ConstructBranchAndVector (TTree *tree, TString &prefix, QwRootTreeBranchVector &values)

void	SetRunLabel (TString x)

Int_t	LoadChannelMap ()

Bool_t	PublishInternalValues () const override
	Publish all variables of the subsystem.

Bool_t	PublishByRequest (TString device_name) override
	Try to publish an internal variable matching the submitted name.

Public Member Functions inherited from MQwPublishable_child< QwDataHandlerArray, VQwDataHandler >
	MQwPublishable_child ()
	Default constructor Initializes the child object and sets up self-reference for publishing.

	MQwPublishable_child (const MQwPublishable_child &source)
	Copy constructor.

virtual	~MQwPublishable_child ()
	Virtual destructor.

void	SetParent (QwDataHandlerArray *parent)
	Set the parent container for this child object.

QwDataHandlerArray *	GetParent () const
	Get the parent container for this child object.

Public Member Functions inherited from MQwCloneable< VQwDataHandler, QwAlarmHandler >
	~MQwCloneable () override
	Virtual destructor.

VQwDataHandler *	Clone () const override
	Concrete clone method.

const VQwFactory< VQwDataHandler > *	Factory () const override
	Factory getter.

Public Member Functions inherited from VQwCloneable< VQwDataHandler >
virtual	~VQwCloneable ()
	Virtual destructor.

std::string	GetClassName () const
	Get demangled name of this class.

Protected Member Functions
	QwAlarmHandler ()
	Default constructor (Protected for child class access)

std::pair< std::string, std::string >	ParseAlarmMapVariable (const string &, char)

Protected Member Functions inherited from VQwDataHandler
	VQwDataHandler ()

virtual Int_t	ConnectChannels (QwSubsystemArrayParity &asym, QwSubsystemArrayParity &diff)

void	SetEventcutErrorFlagPointer (const UInt_t *errorflagptr)

UInt_t	GetEventcutErrorFlag () const

std::pair< EQwHandleType, std::string >	ParseHandledVariable (const std::string &variable)

void	CalcOneOutput (const VQwHardwareChannel dv, VQwHardwareChannel output, std::vector< const VQwHardwareChannel * > &ivs, std::vector< Double_t > &sens)

Protected Member Functions inherited from MQwPublishable_child< QwDataHandlerArray, VQwDataHandler >
Bool_t	RequestExternalValue (const TString &name, VQwHardwareChannel *value) const
	Retrieve the variable name from other subsystem arrays Get the value corresponding to some variable name from a different data array.

const VQwHardwareChannel *	RequestExternalPointer (const TString &name) const
	Retrieve a pointer to an external variable by name Requests a direct pointer to a variable from sibling subsystems via the parent container.

Bool_t	PublishInternalValue (const TString name, const TString desc, const VQwHardwareChannel *element) const
	Publish a variable from this child into the parent container.

Protected Attributes
std::string	fAlarmOutputFile = "adaqfs/home/apar/bin/onlineAlarms.csv"

UInt_t	fCounter = 0

int	fAlarmNupdate = 350

int	fAlarmActive = 0

std::vector< alarmObject >	fAlarmObjectList

Protected Attributes inherited from VQwDataHandler
Int_t	fPriority

Short_t	fBurstCounter
	When a datahandler array is processed, handlers with lower priority will be processed before handlers with higher priority.

TString	fName

std::string	fMapFile

std::string	fTreeName

std::string	fTreeComment

std::string	fPrefix

TString	run_label

const UInt_t *	fErrorFlagPtr
	Error flag pointer.

QwSubsystemArrayParity *	fSubsystemArray
	Single event pointer.

QwHelicityPattern *	fHelicityPattern
	Helicity pattern pointer.

std::vector< std::string >	fDependentFull

std::vector< EQwHandleType >	fDependentType

std::vector< std::string >	fDependentName

std::vector< const VQwHardwareChannel * >	fDependentVar

std::vector< Double_t >	fDependentValues

std::vector< VQwHardwareChannel * >	fOutputVar

std::vector< Double_t >	fOutputValues

std::vector< std::vector< TString > >	fPublishList

std::string	ParseSeparator

Bool_t	fKeepRunningSum

Bool_t	fRunningsumFillsTree

VQwDataHandler *	fRunningsum

Additional Inherited Members
Static Public Member Functions inherited from MQwCloneable< VQwDataHandler, QwAlarmHandler >
static VQwDataHandler *	Create (const std::string &name)
	Object creation.

static QwAlarmHandler *	Cast (QwAlarmHandler *type)
	Object dynamic cast.

Detailed Description

Data handler that evaluates alarm conditions and writes status outputs.

Connects to configured variables and checks them against user-defined alarm thresholds or patterns. Can periodically write a CSV status file for online monitoring and provides simple state tracking to avoid flapping.

Definition at line 22 of file QwAlarmHandler.h.

Member Typedef Documentation

◆ ConstIterator_HdwChan

typedef std::vector<VQwHardwareChannel*>::const_iterator QwAlarmHandler::ConstIterator_HdwChan

Definition at line 26 of file QwAlarmHandler.h.

◆ Iterator_HdwChan

typedef std::vector<VQwHardwareChannel*>::iterator QwAlarmHandler::Iterator_HdwChan

Definition at line 25 of file QwAlarmHandler.h.

Constructor & Destructor Documentation

◆ QwAlarmHandler() [1/3]

QwAlarmHandler::QwAlarmHandler ( const TString & name )

Constructor with name.

Definition at line 21 of file QwAlarmHandler.cc.

                                                 :VQwDataHandler(name)
{
  ParseSeparator = "_";
  //fKeepRunningSum = kTRUE;
}

References VQwDataHandler::ParseSeparator, and VQwDataHandler::VQwDataHandler().

Referenced by QwAlarmHandler().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ QwAlarmHandler() [2/3]

QwAlarmHandler::QwAlarmHandler ( const QwAlarmHandler & source )

Copy constructor.

Definition at line 27 of file QwAlarmHandler.cc.

                                                          :VQwDataHandler(source)
{
}

References QwAlarmHandler(), and VQwDataHandler::VQwDataHandler().

Here is the call graph for this function:

◆ ~QwAlarmHandler()

QwAlarmHandler::~QwAlarmHandler ( )

inlineoverride

Virtual destructor.

Definition at line 35 of file QwAlarmHandler.h.

35{};

◆ QwAlarmHandler() [3/3]

QwAlarmHandler::QwAlarmHandler ( )

inlineprotected

Default constructor (Protected for child class access)

Definition at line 76 of file QwAlarmHandler.h.

76{ };

Member Function Documentation

◆ CheckAlarms()

void QwAlarmHandler::CheckAlarms ( )

Definition at line 323 of file QwAlarmHandler.cc.

                                 {
  // If user-name-of-variable exists then grab it, grab its value from memory, and then compare to the upper and lower limits defined by user (if they were defined) 
  std::string tmpAlarmStat = "OK";
  for ( size_t numAna = 0; numAna < fAlarmObjectList.size() ; numAna++ ) {
    if (fAlarmObjectList.at(numAna).value != NULL){
      //QwWarning << "fAlarmObjectList.at("<<numAna<<").value == " << fAlarmObjectList.at(numAna).value  <<QwLog::endl;
      //QwWarning << "fAlarmObjectList.at("<<numAna<<").value->GetValue() == " << fAlarmObjectList.at(numAna).value->GetValue()  <<QwLog::endl;
      if ( fAlarmObjectList.at(numAna).alarmParameterMapStr.count("Error-Code") != 0 
          && ((TString)fAlarmObjectList.at(numAna).alarmParameterMapStr.at("Error-Code")).IsHex() && ((std::stoul(fAlarmObjectList.at(numAna).alarmParameterMapStr.at("Error-Code"),nullptr,16)) & *fAlarmObjectList.at(numAna).eventcutErrorFlag) != 0 ) { 
        fAlarmObjectList.at(numAna).Nviolated++;
        fAlarmObjectList.at(numAna).NsinceLastViolation = 0;
        tmpAlarmStat = "Error-Code";
      }
      else if (fAlarmObjectList.at(numAna).alarmParameterMap.count("Exactly") != 0 
          && fAlarmObjectList.at(numAna).value->GetValue() != fAlarmObjectList.at(numAna).alarmParameterMap.at("Exactly"))  {
        fAlarmObjectList.at(numAna).Nviolated++;
        fAlarmObjectList.at(numAna).NsinceLastViolation = 0;
        tmpAlarmStat = "Not-Exactly";
      }
      else if ( fAlarmObjectList.at(numAna).alarmParameterMap.count("HighHigh") != 0 
          && fAlarmObjectList.at(numAna).value->GetValue() >= fAlarmObjectList.at(numAna).alarmParameterMap.at("HighHigh") ) { 
        fAlarmObjectList.at(numAna).Nviolated++;
        fAlarmObjectList.at(numAna).NsinceLastViolation = 0;
        tmpAlarmStat = "HighHigh";
      }
      else if ( fAlarmObjectList.at(numAna).alarmParameterMap.count("High") != 0 
          && fAlarmObjectList.at(numAna).value->GetValue() >= fAlarmObjectList.at(numAna).alarmParameterMap.at("High") ) {
        fAlarmObjectList.at(numAna).Nviolated++;
        fAlarmObjectList.at(numAna).NsinceLastViolation = 0;
        tmpAlarmStat = "High";
      }
      else if ( fAlarmObjectList.at(numAna).alarmParameterMap.count("LowLow") != 0 
          && fAlarmObjectList.at(numAna).value->GetValue() <= fAlarmObjectList.at(numAna).alarmParameterMap.at("LowLow") ) {
        fAlarmObjectList.at(numAna).Nviolated++;
        fAlarmObjectList.at(numAna).NsinceLastViolation = 0;
        tmpAlarmStat = "LowLow";
      }
      else if ( fAlarmObjectList.at(numAna).alarmParameterMap.count("Low") != 0 
          &&  fAlarmObjectList.at(numAna).value->GetValue() <= fAlarmObjectList.at(numAna).alarmParameterMap.at("Low") ) {
        fAlarmObjectList.at(numAna).Nviolated++;
        fAlarmObjectList.at(numAna).NsinceLastViolation = 0;
        tmpAlarmStat = "Low";
      }
      else {
        fAlarmObjectList.at(numAna).NsinceLastViolation++;
      }
      if ( fAlarmObjectList.at(numAna).Nviolated > 0 && fAlarmObjectList.at(numAna).NsinceLastViolation > fAlarmObjectList.at(numAna).alarmParameterMap.at("Ring-Length") ) { 
        fAlarmObjectList.at(numAna).Nviolated--;
      }
      if ( fAlarmObjectList.at(numAna).Nviolated > fAlarmObjectList.at(numAna).alarmParameterMap.at("Tolerance") ) {
        fAlarmObjectList.at(numAna).alarmStatus = tmpAlarmStat;
      }
      else {
        fAlarmObjectList.at(numAna).alarmStatus = "OK";
      }
    }
    else {
      QwError << "Null: fAlarmObjectList.at("<<numAna<<").value == NULL" <<QwLog::endl;
    }
  }
}

References QwLog::endl(), fAlarmObjectList, and QwError.

Referenced by ProcessData().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ConnectChannels()

Int_t QwAlarmHandler::ConnectChannels	(	QwSubsystemArrayParity &	yield,
		QwSubsystemArrayParity &	asym,
		QwSubsystemArrayParity &	diff )

overridevirtual

Connect to Channels (event only)

Connect to channels across subsystem arrays

Establish pointers to input variables (yield/asym/diff) and prepare output channels for alarm evaluation.

Parameters

yield	Subsystem array containing per-MPS yields
asym	Subsystem array containing asymmetries
diff	Subsystem array containing differences

Returns: 0 on success, non-zero on failure

Fill vector of pointers to the relevant data elements

Reimplemented from VQwDataHandler.

Definition at line 157 of file QwAlarmHandler.cc.

{
  /// Fill vector of pointers to the relevant data elements
  for (size_t anaInd = 0; anaInd < fAlarmObjectList.size(); anaInd++) {
    // Get the dependent variables
    if (fAlarmObjectList.at(anaInd).analysisType==kHandleTypeMps || fAlarmObjectList.at(anaInd).alarmParameterMapStr.count("Channel-Name") == 0){
      //  Quietly ignore the MPS type when we're connecting the asym & diff
      continue;
    }
    const VQwHardwareChannel* ana_ptr = NULL;
    const UInt_t* eventcut = NULL;
    switch (fAlarmObjectList.at(anaInd).analysisType) {
      case kHandleTypeYield:
        SetEventcutErrorFlagPointer(yield.GetEventcutErrorFlagPointer());
        ana_ptr = yield.ReturnInternalValue(fAlarmObjectList.at(anaInd).alarmParameterMapStr.at("Channel-Name"));
        eventcut = yield.GetEventcutErrorFlagPointer();
        break;
      case kHandleTypeAsym:
        SetEventcutErrorFlagPointer(asym.GetEventcutErrorFlagPointer());
        ana_ptr = asym.ReturnInternalValue(fAlarmObjectList.at(anaInd).alarmParameterMapStr.at("Channel-Name"));
        eventcut = asym.GetEventcutErrorFlagPointer();
        break;
      case kHandleTypeDiff:
        SetEventcutErrorFlagPointer(diff.GetEventcutErrorFlagPointer());
        ana_ptr = diff.ReturnInternalValue(fAlarmObjectList.at(anaInd).alarmParameterMapStr.at("Channel-Name"));
        eventcut = diff.GetEventcutErrorFlagPointer();
        break;
      default:
        QwWarning << "Independent variable for AlarmHandler has unknown type."
          << QwLog::endl;
        break;
    }
    if (ana_ptr != NULL) {
      fAlarmObjectList.at(anaInd).value = ana_ptr;
      //QwError << "ana_ptr = " << ana_ptr <<QwLog::endl;
      //QwError << "fAlarmObjectList.at(" << anaInd << ").value = " <<  fAlarmObjectList.at(anaInd).value <<QwLog::endl;
      fAlarmObjectList.at(anaInd).eventcutErrorFlag = eventcut;
    } else {
      fAlarmObjectList.at(anaInd).value = NULL;
      //QwWarning << "Independent variable " << fAlarmObjectList.at(anaInd).alarmParameterMapStr.at("Channel-Name") << " missing in alarm map "
      //  << QwLog::endl;
    }
  }
  return 0;
}

References QwLog::endl(), fAlarmObjectList, QwSubsystemArrayParity::GetEventcutErrorFlagPointer(), VQwDataHandler::kHandleTypeAsym, VQwDataHandler::kHandleTypeDiff, VQwDataHandler::kHandleTypeMps, VQwDataHandler::kHandleTypeYield, QwWarning, MQwPublishable< U, T >::ReturnInternalValue(), and VQwDataHandler::SetEventcutErrorFlagPointer().

Here is the call graph for this function:

◆ LoadChannelMap()

Int_t QwAlarmHandler::LoadChannelMap ( const std::string & mapfile )

overridevirtual

Load the channels and sensitivities.

Load the channel map

Parameters

mapfile Filename of map file

Returns: Zero when success

Reimplemented from VQwDataHandler.

Definition at line 70 of file QwAlarmHandler.cc.

{
  // Open the file
  QwParameterFile map(mapfile);
 
  // Read the sections of dependent variables
  std::pair<EQwHandleType,std::string> type_name;
  std::pair<std::string,std::string> tmpPair;
 
  // Add independent variables and sensitivities
  while (map.ReadNextLine()) {
    // Throw away comments, whitespace, empty lines
    map.TrimComment();
    map.TrimWhitespace();
    if (map.LineIsEmpty()) continue;
    // Get first token: label (dv or iv), second token is the name like "asym_blah"
//  Type, Channel, Ana, tree, channel, highhigh, high, low, lowlow, ringLength, pat-tolerance
//  Kind=Main-Det Chan=usr Tree=mul Channel=asym_usr HighHigh=1000 High=100 Low=-100 LowLow=-1000 Ring-Length=200 Tolerance=2
    alarmObject tmpAlarmObject;
    // Do while tmpVal = map.GetNextToken parse
    // Do map[tmpVal.type] = tmpVal.value
    std::string tmpToken = map.GetNextToken(" ");
    while ( tmpToken != "" ) {
      tmpPair = ParseAlarmMapVariable(tmpToken,'='); // This refers to the object under scrutiny, finds type of object - asym, yield, diff, etc. Check on yields FIXME
      if (tmpPair.first=="Channel") {
        type_name = ParseHandledVariable(tmpPair.second);
        tmpAlarmObject.alarmParameterMapStr["Analysis"] = tmpPair.second;
        tmpAlarmObject.analysisType = type_name.first;
        tmpAlarmObject.alarmParameterMapStr["Channel-Name"] = type_name.second;
        tmpAlarmObject.alarmParameterMapStr["Type-Name"] = tmpPair.second;
      }
      else if (tmpPair.first == "Kind") {
        tmpAlarmObject.alarmParameterMapStr[tmpPair.first] = tmpPair.second;
      }
      else if (tmpPair.first == "Chan") {
        tmpAlarmObject.alarmParameterMapStr[tmpPair.first] = tmpPair.second;
      }
      else if (tmpPair.first == "Error-Code") {
        tmpAlarmObject.alarmParameterMapStr[tmpPair.first] = tmpPair.second;
      }
      else {
        tmpAlarmObject.alarmParameterMap[tmpPair.first] = std::stod(tmpPair.second);
      }
      tmpToken = map.GetNextToken(" ");
    }
    if (!tmpAlarmObject.alarmParameterMap.count("Ring-Length")) {
      tmpAlarmObject.alarmParameterMap["Ring-Length"] = 1e9;
    }
    if (!tmpAlarmObject.alarmParameterMap.count("Tolerance")) {
      tmpAlarmObject.alarmParameterMap["Tolerance"] = 0;
    }
 
    /* tmpAlarmObject.type         = map.GetNextToken(" ");
    tmpAlarmObject.channel      = map.GetNextToken(" ");
    tmpAlarmObject.ana          = map.GetNextToken(" ");
    tmpAlarmObject.tree         = map.GetNextToken(" ");
    std::string localAna_token = map.GetNextToken(" ");
    // Parse current token into independent variable type and name
    type_name = ParseHandledVariable(localAna_token); // This refers to the object under scrutiny, finds type of object - asym, yield, diff, etc. Check on yields FIXME
    tmpAlarmObject.analysisType = type_name.first;
    tmpAlarmObject.analysisName = type_name.second;
    tmpAlarmObject.highHigh     = map.GetNextToken(" ");
    tmpAlarmObject.high         = map.GetNextToken(" ");
    tmpAlarmObject.low          = map.GetNextToken(" ");
    tmpAlarmObject.lowLow       = map.GetNextToken(" ");
    tmpAlarmObject.ringLength   = map.GetNextToken(" "); 
    tmpAlarmObject.tolerance    = map.GetNextToken(" "); // This is all hardcoded.... how to do with keywords? FIXME
    */
    // Default Initializations
    tmpAlarmObject.alarmStatus  = "OK";
    tmpAlarmObject.Nviolated    = 0;
    tmpAlarmObject.NsinceLastViolation = 1e9;
    tmpAlarmObject.value = NULL;
    tmpAlarmObject.eventcutErrorFlag = NULL;
    fAlarmObjectList.push_back(tmpAlarmObject);
 
    /*else if (primary_token == "treetype") {
      QwMessage << "Tree Type read, ignoring." << QwLog::endl;
    }
    else {
      QwError << "Function LoadChannelMap in QwCorrelator.cc read in invalid primary_token." << QwLog::endl;
    }*/
  }
  return 0;
}

Here is the call graph for this function:

◆ ParseAlarmMapVariable()

std::pair< std::string, std::string > QwAlarmHandler::ParseAlarmMapVariable	(	const string &	variable,
		char	delim )

protected

Definition at line 46 of file QwAlarmHandler.cc.

                                                                                                        {
  std::pair<std::string,std::string> type_name;
  size_t len = variable.length();
  size_t pos1 = variable.find_first_of(delim);
  size_t pos2 = variable.find_first_not_of(delim,pos1);
  if (pos1 == string::npos) {
    type_name.first  = "NULL";
    type_name.second = "NULL";
  } else {
    string type = variable.substr(0,pos1);
    string name = variable.substr(pos2,len-pos2);
    type_name.first = type;
    type_name.second = name;
  }
  return type_name;
}

Referenced by LoadChannelMap().

Here is the caller graph for this function:

◆ ParseConfigFile()

void QwAlarmHandler::ParseConfigFile ( QwParameterFile & file )

overridevirtual

Parse configuration file for map file, priority, tree settings.

Reimplemented from VQwDataHandler.

Definition at line 33 of file QwAlarmHandler.cc.

{
  VQwDataHandler::ParseConfigFile(file);
  //name        = MyAlarmHandler
  //priority    = 20
  //map         = prex_alarm_handler.map
  file.PopValue("alarm-output-file",fAlarmOutputFile);
  file.PopValue("alarm-loop-N-update",fAlarmNupdate);
  file.PopValue("alarm-active",fAlarmActive);
  // Check for and process key-value pairs
  //file.PopValue("new-key-word",fsomething); // These need = signs in map files
}

References fAlarmActive, fAlarmNupdate, fAlarmOutputFile, VQwDataHandler::ParseConfigFile(), and QwParameterFile::PopValue().

Here is the call graph for this function:

◆ ProcessData()

void QwAlarmHandler::ProcessData ( )

overridevirtual

Process a single event: update alarm states and outputs.

Checks all configured alarm conditions against current inputs and updates any associated status channels. May periodically write an overview CSV if enabled by configuration.

Reimplemented from VQwDataHandler.

Definition at line 262 of file QwAlarmHandler.cc.

                                 {
 // for (size_t i = 0; i < fDependentVar.size(); ++i) {
 //   *(fOutputVar.at(i)) = *(fDependentVar[i]);
 // }
 // for (size_t i = 0; i < fDependentValues.size(); ++i) {
 //   fValue.at(i) = fDependentValues[i];
 // }
  fCounter++;
  if (fAlarmActive) {
    CheckAlarms();
    if (fCounter % fAlarmNupdate == 0) {
      UpdateAlarmFile();
    }
  }
}  // FIXME do I even need a process data method? Probably not

References CheckAlarms(), fAlarmActive, fAlarmNupdate, fCounter, and UpdateAlarmFile().

Here is the call graph for this function:

◆ UpdateAlarmFile()

void QwAlarmHandler::UpdateAlarmFile ( )

Definition at line 385 of file QwAlarmHandler.cc.

                                    {
  std::ofstream file_out;
  // Format of alarmObject struct contents
  // std::map <std::string,std::string> alarmParameterMap;
  // VQwDataHandler::EQwHandleType analysisType;
  // const VQwHardwareChannel* value;
  // UInt_t eventcutErrorFlag;
  // std::string alarmStatus;
  // int Nviolated; // Vector of 0's for history tracking
  // int NsinceLastViolation; // Vector of 0's for history tracking
 
  file_out.open(fAlarmOutputFile,std::ofstream::trunc);
  for (size_t ite = 0 ; ite<fAlarmObjectList.size(); ite++){
    if (fAlarmObjectList.at(ite).value != NULL && fAlarmObjectList.at(ite).alarmParameterMapStr.count("Kind") && fAlarmObjectList.at(ite).alarmParameterMapStr.count("Chan") && fAlarmObjectList.at(ite).alarmParameterMapStr.count("Analysis")) {
      if (fAlarmObjectList.at(ite).value != 0) { // Check if non-trivial value object...
        file_out<<fAlarmObjectList.at(ite).alarmParameterMapStr.at("Kind")<<","<<fAlarmObjectList.at(ite).alarmParameterMapStr.at("Chan")<<","<<fAlarmObjectList.at(ite).alarmParameterMapStr.at("Analysis")<<","<<"Value"<<","<<fAlarmObjectList.at(ite).value->GetValue()<<std::endl;
      }
      else continue;
      if (fAlarmObjectList.at(ite).alarmStatus != "") { // Check if non-trivial value object...
        file_out<<fAlarmObjectList.at(ite).alarmParameterMapStr.at("Kind")<<","<<fAlarmObjectList.at(ite).alarmParameterMapStr.at("Chan")<<","<<fAlarmObjectList.at(ite).alarmParameterMapStr.at("Analysis")<<","<<"Alarm Status"<<","<<fAlarmObjectList.at(ite).alarmStatus<<std::endl;
      }
      else continue;
      if (fAlarmObjectList.at(ite).alarmParameterMapStr.count("Error-Code")) { // Check if non-trivial value object...
        file_out<<fAlarmObjectList.at(ite).alarmParameterMapStr.at("Kind")<<","<<fAlarmObjectList.at(ite).alarmParameterMapStr.at("Chan")<<","<<fAlarmObjectList.at(ite).alarmParameterMapStr.at("Analysis")<<","<<"Error-Code"<<","<<fAlarmObjectList.at(ite).alarmParameterMapStr.at("Error-Code")<<std::endl;
      }
    }
    else continue;
    for (auto jte : fAlarmObjectList.at(ite).alarmParameterMap){ // Loop through parameter list
      file_out<<fAlarmObjectList.at(ite).alarmParameterMapStr.at("Kind")<<","<<fAlarmObjectList.at(ite).alarmParameterMapStr.at("Chan")<<","<<fAlarmObjectList.at(ite).alarmParameterMapStr.at("Analysis")<<","<<jte.first<<","<<jte.second<<std::endl;
    }
  }
  file_out.close();
}

References fAlarmObjectList, and fAlarmOutputFile.

Referenced by ProcessData().

Here is the caller graph for this function:

Field Documentation

◆ fAlarmActive

int QwAlarmHandler::fAlarmActive = 0

protected

Definition at line 81 of file QwAlarmHandler.h.

Referenced by ParseConfigFile(), and ProcessData().

◆ fAlarmNupdate

int QwAlarmHandler::fAlarmNupdate = 350

protected

Definition at line 80 of file QwAlarmHandler.h.

Referenced by ParseConfigFile(), and ProcessData().

◆ fAlarmObjectList

std::vector<alarmObject> QwAlarmHandler::fAlarmObjectList

protected

Definition at line 112 of file QwAlarmHandler.h.

Referenced by CheckAlarms(), ConnectChannels(), LoadChannelMap(), and UpdateAlarmFile().

◆ fAlarmOutputFile

std::string QwAlarmHandler::fAlarmOutputFile = "adaqfs/home/apar/bin/onlineAlarms.csv"

protected

Definition at line 78 of file QwAlarmHandler.h.

Referenced by ParseConfigFile(), and UpdateAlarmFile().

◆ fCounter

UInt_t QwAlarmHandler::fCounter = 0

protected

Definition at line 79 of file QwAlarmHandler.h.

Referenced by ProcessData().

The documentation for this class was generated from the following files:

Data Structures

Public Types

Public Member Functions

Protected Member Functions

Protected Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ ConstIterator_HdwChan

◆ Iterator_HdwChan

Constructor & Destructor Documentation

◆ QwAlarmHandler() [1/3]

◆ QwAlarmHandler() [2/3]

◆ ~QwAlarmHandler()

◆ QwAlarmHandler() [3/3]

Member Function Documentation

◆ CheckAlarms()

◆ ConnectChannels()

◆ LoadChannelMap()

◆ ParseAlarmMapVariable()

◆ ParseConfigFile()

◆ ProcessData()

◆ UpdateAlarmFile()

Field Documentation

◆ fAlarmActive

◆ fAlarmNupdate

◆ fAlarmObjectList

◆ fAlarmOutputFile

◆ fCounter