QwDataHandlerArray Class Reference

Virtual base class for the parity handlers. More...

#include <QwDataHandlerArray.h>

Inheritance diagram for QwDataHandlerArray:

Collaboration diagram for QwDataHandlerArray:

Public Member Functions
	QwDataHandlerArray (QwOptions &options, QwHelicityPattern &helicitypattern, const TString &run)
	Constructor from helicity pattern with options.
	QwDataHandlerArray (QwOptions &options, QwSubsystemArrayParity &detectors, const TString &run)
	Constructor from subsystem array with options.
	QwDataHandlerArray (const QwDataHandlerArray &source)
	Copy constructor by reference.
	~QwDataHandlerArray () override
	Default destructor.
void	ProcessOptions (QwOptions &options)
	Process configuration options for the datahandler array itself.
template<class T>
void	LoadDataHandlersFromParameterFile (QwParameterFile &mapfile, T &detectors, const TString &run)
	Load data handlers from a parameter file.
void	push_back (VQwDataHandler *handler)
	Add the datahandler to this array.
void	push_back (std::shared_ptr< VQwDataHandler > handler)
VQwDataHandler *	GetDataHandlerByName (const TString &name)
	Get the handler with the specified name.
std::vector< VQwDataHandler * >	GetDataHandlerByType (const std::string &type)
void	ConstructTreeBranches (QwRootFile *treerootfile, const std::string &treeprefix="", const std::string &branchprefix="")
void	ConstructBranchAndVector (TTree *tree, TString &prefix, QwRootTreeBranchVector &values)
	Construct a branch and vector for this handler with a prefix.
void	FillTreeBranches (QwRootFile *treerootfile)
void	FillTreeVector (QwRootTreeBranchVector &values) const
	Fill the vector for this handler.
void	ConstructNTupleFields (QwRootFile *treerootfile, const std::string &treeprefix="", const std::string &branchprefix="")
	RNTuple methods.
void	FillNTupleFields (QwRootFile *treerootfile)
void	ConstructHistograms ()
	Construct the histograms for this subsystem.
void	ConstructHistograms (TDirectory *folder)
	Construct the histograms for this subsystem in a folder.
void	ConstructHistograms (TDirectory *folder, TString &prefix)
	Construct the histograms in a folder with a prefix.
void	FillHistograms ()
	Fill the histograms.
void	FillDB (QwParityDB *db, TString type)
	Fill the database.
void	ClearEventData ()
void	ProcessEvent ()
void	UpdateBurstCounter (Short_t burstcounter)
QwDataHandlerArray &	operator= (const QwDataHandlerArray &value)
	Assignment operator.
void	AccumulateRunningSum ()
	Update the running sums for devices accumulated for the global error non-zero events/patterns.
void	AccumulateRunningSum (const QwDataHandlerArray &value, Int_t count=0, Int_t ErrorMask=0xFFFFFFF)
	Update the running sums for devices accumulated for the global error non-zero events/patterns.
void	AccumulateAllRunningSum (const QwDataHandlerArray &value, Int_t count=0, Int_t ErrorMask=0xFFFFFFF)
	Update the running sums for devices check only the error flags at the channel level. Only used for stability checks.
void	CalculateRunningAverage ()
	Calculate the average for all good events.
void	PrintErrorCounters () const
	Report the number of events failed due to HW and event cut failures.
void	PrintValue () const
	Print value of all channels.
void	WritePromptSummary (QwPromptSummary *ps, TString type)
void	ProcessDataHandlerEntry ()
void	FinishDataHandler ()
Public Member Functions inherited from MQwPublishable< QwDataHandlerArray, VQwDataHandler >
	MQwPublishable ()
	Default constructor Initializes empty variable publishing maps.
	MQwPublishable (const MQwPublishable &source)
	Copy constructor Creates a new container with cleared publishing maps (variables are not copied).
virtual	~MQwPublishable ()
	Virtual destructor.
Bool_t	RequestExternalValue (const TString &name, VQwHardwareChannel *value) const
	Retrieve a variable value from external sources by copying Searches for the named variable in external subsystem arrays and copies its value into the provided data element.
const VQwHardwareChannel *	RequestExternalPointer (const TString &name) const
	Retrieve a direct pointer to an external variable Searches for the named variable in external subsystem arrays and returns a direct pointer to the data element.
virtual const VQwHardwareChannel *	ReturnInternalValue (const TString &name) const
	Retrieve an internal variable by name (pointer version) Searches for the named variable among published internal variables and returns a direct pointer to the data element.
Bool_t	ReturnInternalValue (const TString &name, VQwHardwareChannel *value) const
	Retrieve an internal variable by name (copy version) Searches for the named variable among published internal variables and copies its value into the provided data element.
void	ListPublishedValues () const
	List all published variables with descriptions Prints a summary of all currently published variables and their descriptions to the logging output for debugging and inspection purposes.
Bool_t	PublishInternalValue (const TString name, const TString desc, const VQwDataHandler *subsys, const VQwHardwareChannel *element)
	Publish an internal variable from a subsystem Registers a variable from one of the contained subsystems in the publishing framework, making it available for external access by name.

Static Public Member Functions
static void	DefineOptions (QwOptions &options)
	Define configuration options for global array.

Protected Types
enum	EDataHandlerArrayScope { kUnknownScope =-1 , kEventScope , kPatternScope }

Protected Member Functions
void	SetPointer (QwHelicityPattern &helicitypattern)
void	SetPointer (QwSubsystemArrayParity &detectors)
Bool_t	ScopeMismatch (TString name)

Static Protected Member Functions
static Bool_t	CanContain (VQwDataHandler *handler)
	Test whether this handler array can contain a particular handler.

Protected Attributes
QwHelicityPattern *	fHelicityPattern
	Pointer for the original data source.
QwSubsystemArrayParity *	fSubsystemArray
std::string	fDataHandlersMapFile
	Filename of the global detector map.
EDataHandlerArrayScope	fArrayScope
std::vector< std::string >	fDataHandlersDisabledByName
	List of disabled types.
std::vector< std::string >	fDataHandlersDisabledByType
	List of disabled names.
Bool_t	fPrintRunningSum

Private Types
typedef std::vector< std::shared_ptr< VQwDataHandler > >	HandlerPtrs

Private Member Functions
	QwDataHandlerArray ()
	Private default constructor.

Additional Inherited Members
Data Fields inherited from MQwPublishable< QwDataHandlerArray, VQwDataHandler >
std::vector< std::vector< TString > >	fPublishList

Detailed Description

Virtual base class for the parity handlers.

Virtual base class for the classes containing the event-based information from each parity handler. This will define the interfaces used in communicating with the CODA routines.

Definition at line 45 of file QwDataHandlerArray.h.

Member Typedef Documentation

HandlerPtrs

typedef std::vector<std::shared_ptr<VQwDataHandler> > QwDataHandlerArray::HandlerPtrs

private

Definition at line 50 of file QwDataHandlerArray.h.

Member Enumeration Documentation

EDataHandlerArrayScope

enum QwDataHandlerArray::EDataHandlerArrayScope

protected

Enumerator
kUnknownScope
kEventScope
kPatternScope

Definition at line 214 of file QwDataHandlerArray.h.

{kUnknownScope=-1, kEventScope, kPatternScope};

Constructor & Destructor Documentation

QwDataHandlerArray() [1/4]

QwDataHandlerArray::QwDataHandlerArray ( )

private

Private default constructor.

References QwDataHandlerArray().

Referenced by AccumulateAllRunningSum(), AccumulateRunningSum(), AccumulateRunningSum(), operator=(), QwDataHandlerArray(), and QwDataHandlerArray().

Here is the call graph for this function:

Here is the caller graph for this function:

QwDataHandlerArray() [2/4]

QwDataHandlerArray::QwDataHandlerArray	(	QwOptions &	options,
		QwHelicityPattern &	helicitypattern,
		const TString &	run )

Constructor from helicity pattern with options.

Create a handler array based on the configuration option 'detectors'

Definition at line 20 of file QwDataHandlerArray.cc.

  : fHelicityPattern(0),fSubsystemArray(0),fDataHandlersMapFile(""),fArrayScope(kPatternScope)
{
  ProcessOptions(options);
  if (fDataHandlersMapFile != ""){
    QwParameterFile mapfile(fDataHandlersMapFile.c_str());
    QwMessage << "Loading handlers from " << fDataHandlersMapFile << "." << QwLog::endl;
    LoadDataHandlersFromParameterFile(mapfile, helicitypattern, run);
  }
}

References QwLog::endl(), fArrayScope, fDataHandlersMapFile, fHelicityPattern, fSubsystemArray, kPatternScope, LoadDataHandlersFromParameterFile(), ProcessOptions(), and QwMessage.

Here is the call graph for this function:

QwDataHandlerArray() [3/4]

QwDataHandlerArray::QwDataHandlerArray	(	QwOptions &	options,
		QwSubsystemArrayParity &	detectors,
		const TString &	run )

Constructor from subsystem array with options.

Create a handler array based on the configuration option 'detectors'

Definition at line 34 of file QwDataHandlerArray.cc.

  : fHelicityPattern(0),fSubsystemArray(0),fDataHandlersMapFile(""),fArrayScope(kEventScope)
{
  ProcessOptions(options);
  if (fDataHandlersMapFile != ""){
    QwParameterFile mapfile(fDataHandlersMapFile.c_str());
    QwMessage << "Loading handlers from " << fDataHandlersMapFile << "." << QwLog::endl;
    LoadDataHandlersFromParameterFile(mapfile, detectors, run);
  }
}

References QwLog::endl(), fArrayScope, fDataHandlersMapFile, fHelicityPattern, fSubsystemArray, kEventScope, LoadDataHandlersFromParameterFile(), ProcessOptions(), and QwMessage.

Here is the call graph for this function:

QwDataHandlerArray() [4/4]

QwDataHandlerArray::QwDataHandlerArray

(

const QwDataHandlerArray &

source

)

Copy constructor by reference.

Copy constructor by reference

Parameters

source

Source handler array

Definition at line 49 of file QwDataHandlerArray.cc.

: std::vector<std::shared_ptr<VQwDataHandler>>(),
  fHelicityPattern(source.fHelicityPattern),
  fSubsystemArray(source.fSubsystemArray),
  fDataHandlersMapFile(source.fDataHandlersMapFile),
  fDataHandlersDisabledByName(source.fDataHandlersDisabledByName),
  fDataHandlersDisabledByType(source.fDataHandlersDisabledByType)
{
  // Make copies of all handlers rather than copying just the pointers
  for (const_iterator handler = source.begin(); handler != source.end(); ++handler) {
    this->push_back(handler->get()->Clone());
    /*
    // Instruct the handler to publish variables
    if (this->back()->PublishInternalValues() == kFALSE) {
      QwError << "Not all variables for " << this->back()->GetName()
             << " could be published!" << QwLog::endl;
    */
  }
}

References fDataHandlersDisabledByName, fDataHandlersDisabledByType, fDataHandlersMapFile, fHelicityPattern, fSubsystemArray, and QwDataHandlerArray().

Here is the call graph for this function:

~QwDataHandlerArray()

QwDataHandlerArray::~QwDataHandlerArray ( )

override

Default destructor.

Destructor.

Definition at line 74 of file QwDataHandlerArray.cc.

{
  // nothing
}

Member Function Documentation

AccumulateAllRunningSum()

void QwDataHandlerArray::AccumulateAllRunningSum	(	const QwDataHandlerArray &	value,
		Int_t	count = 0,
		Int_t	ErrorMask = 0xFFFFFFF )

Update the running sums for devices check only the error flags at the channel level. Only used for stability checks.

Definition at line 576 of file QwDataHandlerArray.cc.

{
  if (!value.empty()) {
    if (this->size() == value.size()) {
    for (size_t i = 0; i < value.size(); i++) {
      if (value.at(i)==NULL || this->at(i)==NULL) {
        //  Either the value or the destination handler
        //  are null
      } else {
        VQwDataHandler *ptr1 =
          dynamic_cast<VQwDataHandler*>(this->at(i).get());
            VQwDataHandler *ptr2 = value.at(i).get();
        if (typeid(*ptr1) == typeid(*ptr2)) {
          ptr1->AccumulateRunningSum(*ptr2, count, ErrorMask);
        } else {
          QwError << "QwDataHandlerArray::AccumulateRunningSum here where types don't match" << QwLog::endl;
          QwError << " typeid(ptr1)=" << typeid(ptr1).name()
              << " but typeid(value.at(i)))=" << typeid(value.at(i)).name()
              << QwLog::endl;
          //  DataHandlers don't match
        }
      }
    }
    } else {
      //  Array sizes don't match
 
    }
  } else {
    //  The value is empty
  }
}

References VQwDataHandler::AccumulateRunningSum(), QwLog::endl(), QwDataHandlerArray(), and QwError.

Here is the call graph for this function:

AccumulateRunningSum() [1/2]

void QwDataHandlerArray::AccumulateRunningSum

(

)

Update the running sums for devices accumulated for the global error non-zero events/patterns.

References QwDataHandlerArray().

Here is the call graph for this function:

AccumulateRunningSum() [2/2]

void QwDataHandlerArray::AccumulateRunningSum	(	const QwDataHandlerArray &	value,
		Int_t	count = 0,
		Int_t	ErrorMask = 0xFFFFFFF )

Update the running sums for devices accumulated for the global error non-zero events/patterns.

Definition at line 543 of file QwDataHandlerArray.cc.

{
  if (!value.empty()) {
    if (this->size() == value.size()) {
    for (size_t i = 0; i < value.size(); i++) {
      if (value.at(i)==NULL || this->at(i)==NULL) {
        //  Either the value or the destination handler
        //  are null
      } else {
        VQwDataHandler *ptr1 =
          dynamic_cast<VQwDataHandler*>(this->at(i).get());
            VQwDataHandler *ptr2 = value.at(i).get();
        if (typeid(*ptr1) == typeid(*ptr2)) {
          ptr1->AccumulateRunningSum(*ptr2, count, ErrorMask);
        } else {
          QwError << "QwDataHandlerArray::AccumulateRunningSum here where types don't match" << QwLog::endl;
          QwError << " typeid(ptr1)=" << typeid(ptr1).name()
              << " but typeid(value.at(i)))=" << typeid(value.at(i)).name()
              << QwLog::endl;
          //  DataHandlers don't match
        }
      }
    }
 
    } else {
      //  Array sizes don't match
 
    }
  } else {
    //  The value is empty
  }
}

References VQwDataHandler::AccumulateRunningSum(), QwLog::endl(), QwDataHandlerArray(), and QwError.

Here is the call graph for this function:

CalculateRunningAverage()

void QwDataHandlerArray::CalculateRunningAverage

(

)

Calculate the average for all good events.

Definition at line 532 of file QwDataHandlerArray.cc.

{
  if (!empty()) {
    for (iterator handler = begin(); handler != end(); ++handler) {
      VQwDataHandler* handler_parity = dynamic_cast<VQwDataHandler*>(handler->get());
      handler_parity->CalculateRunningAverage();
    }
  }
}

References VQwDataHandler::CalculateRunningAverage().

Here is the call graph for this function:

CanContain()

static Bool_t QwDataHandlerArray::CanContain ( VQwDataHandler * handler )

inlinestaticprotected

Test whether this handler array can contain a particular handler.

Definition at line 223 of file QwDataHandlerArray.h.

                                                      {
      return (dynamic_cast<VQwDataHandler*>(handler) != 0);
    };

Referenced by LoadDataHandlersFromParameterFile(), push_back(), and push_back().

Here is the caller graph for this function:

ClearEventData()

void QwDataHandlerArray::ClearEventData

(

)

Definition at line 328 of file QwDataHandlerArray.cc.

{
  if (!empty()) {
    std::for_each(begin(), end(),
          std::mem_fn(&VQwDataHandler::ClearEventData));
  }
}

References VQwDataHandler::ClearEventData().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

ConstructBranchAndVector()

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

Construct a branch and vector for this handler with a prefix.

Definition at line 391 of file QwDataHandlerArray.cc.

{
  if (!empty()){
    for (iterator handler = begin(); handler != end(); ++handler) {
      VQwDataHandler* handler_parity = dynamic_cast<VQwDataHandler*>(handler->get());
      handler_parity->ConstructBranchAndVector(tree,prefix,values);
    }
  }
}

References VQwDataHandler::ConstructBranchAndVector().

Here is the call graph for this function:

ConstructHistograms() [1/3]

void QwDataHandlerArray::ConstructHistograms ( )

inline

Construct the histograms for this subsystem.

Definition at line 122 of file QwDataHandlerArray.h.

                                {
      ConstructHistograms((TDirectory*) NULL);
    };

References ConstructHistograms().

Referenced by ConstructHistograms(), and ConstructHistograms().

Here is the call graph for this function:

Here is the caller graph for this function:

ConstructHistograms() [2/3]

void QwDataHandlerArray::ConstructHistograms ( TDirectory * folder )

inline

Construct the histograms for this subsystem in a folder.

Definition at line 126 of file QwDataHandlerArray.h.

                                                  {
      TString prefix = "";
      ConstructHistograms(folder, prefix);
    };

References ConstructHistograms().

Here is the call graph for this function:

ConstructHistograms() [3/3]

void QwDataHandlerArray::ConstructHistograms	(	TDirectory *	folder,
		TString &	prefix )

Construct the histograms in a folder with a prefix.

Definition at line 413 of file QwDataHandlerArray.cc.

{
  if (!empty()) {
    for (iterator subsys = begin(); subsys != end(); ++subsys){
      (*subsys)->ConstructHistograms(folder,prefix);
    }
  }
}

ConstructNTupleFields()

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

RNTuple methods.

Definition at line 366 of file QwDataHandlerArray.cc.

{
  if (!empty()){
    for (iterator handler = begin(); handler != end(); ++handler) {
      handler->get()->ConstructNTupleFields(treerootfile, treeprefix, branchprefix);
    }
  }
}

Referenced by main().

Here is the caller graph for this function:

ConstructTreeBranches()

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

Definition at line 345 of file QwDataHandlerArray.cc.

{
  if (!empty()){
    for (iterator handler = begin(); handler != end(); ++handler) {
      handler->get()->ConstructTreeBranches(treerootfile, treeprefix, branchprefix);
    }
  }
}

Referenced by main().

Here is the caller graph for this function:

DefineOptions()

void QwDataHandlerArray::DefineOptions ( QwOptions & options )

static

Define configuration options for global array.

Define configuration options for global array

Parameters

options

Options

Definition at line 231 of file QwDataHandlerArray.cc.

{
  options.AddOptions()("datahandlers",
                       po::value<std::string>(),
                       "map file with datahandlers to include");
 
  // Versions of boost::program_options below 1.39.0 have a bug in multitoken processing
#if BOOST_VERSION < 103900
  options.AddOptions()("DataHandler.disable-by-type",
                       po::value<std::vector <std::string> >(),
                       "handler types to disable");
  options.AddOptions()("DataHandler.disable-by-name",
                       po::value<std::vector <std::string> >(),
                       "handler names to disable");
#else // BOOST_VERSION >= 103900
  options.AddOptions()("DataHandler.disable-by-type",
                       po::value<std::vector <std::string> >()->multitoken(),
                       "handler types to disable");
  options.AddOptions()("DataHandler.disable-by-name",
                       po::value<std::vector <std::string> >()->multitoken(),
                       "handler names to disable");
#endif // BOOST_VERSION
}

References QwOptions::AddOptions().

Referenced by DefineOptionsParity().

Here is the call graph for this function:

Here is the caller graph for this function:

FillDB()

void QwDataHandlerArray::FillDB	(	QwParityDB *	db,
		TString	type )

Fill the database.

FillHistograms()

void QwDataHandlerArray::FillHistograms

(

)

Fill the histograms.

Definition at line 422 of file QwDataHandlerArray.cc.

{
  if (!empty())
    std::for_each(begin(), end(), std::mem_fn(&VQwDataHandler::FillHistograms));
}

References VQwDataHandler::FillHistograms().

Here is the call graph for this function:

FillNTupleFields()

void QwDataHandlerArray::FillNTupleFields

(

QwRootFile *

treerootfile

)

Definition at line 378 of file QwDataHandlerArray.cc.

{
  if (!empty()){
    for (iterator handler = begin(); handler != end(); ++handler) {
      handler->get()->FillNTupleFields(treerootfile);
    }
  }
}

Referenced by main().

Here is the caller graph for this function:

FillTreeBranches()

void QwDataHandlerArray::FillTreeBranches

(

QwRootFile *

treerootfile

)

Definition at line 357 of file QwDataHandlerArray.cc.

{
  if (!empty()){
    for (iterator handler = begin(); handler != end(); ++handler) {
      handler->get()->FillTreeBranches(treerootfile);
    }
  }
}

Referenced by main().

Here is the caller graph for this function:

FillTreeVector()

void QwDataHandlerArray::FillTreeVector

(

QwRootTreeBranchVector &

values

)

const

Fill the vector for this handler.

Definition at line 401 of file QwDataHandlerArray.cc.

{
  if (!empty()){
    for (const_iterator handler = begin(); handler != end(); ++handler) {
      VQwDataHandler* handler_parity = dynamic_cast<VQwDataHandler*>(handler->get());
      handler_parity->FillTreeVector(values);
    }
  }
}

References VQwDataHandler::FillTreeVector().

Here is the call graph for this function:

FinishDataHandler()

void QwDataHandlerArray::FinishDataHandler

(

)

Definition at line 715 of file QwDataHandlerArray.cc.

{
  if (!empty()) {
    for(iterator handler = begin(); handler != end(); ++handler){
      (*handler)->FinishDataHandler();
    }
  }
}

Referenced by main().

Here is the caller graph for this function:

GetDataHandlerByName()

VQwDataHandler * QwDataHandlerArray::GetDataHandlerByName

(

const TString &

name

)

Get the handler with the specified name.

Get the handler in this array with the specified name

Parameters

name	Name of the handler

Returns

Pointer to the handler

Definition at line 280 of file QwDataHandlerArray.cc.

{
  VQwDataHandler* tmp = NULL;
  if (!empty()) {
    // Loop over the handlers
    for (const_iterator handler = begin(); handler != end(); ++handler) {
      // Check the name of this handler
      // std::cout<<"QwDataHandlerArray::GetDataHandlerByName available name=="<<(*handler)->GetName()<<"== to be compared to =="<<name<<"==\n";
      if ((*handler)->GetName() == name) {
        tmp = (*handler).get();
        //std::cout<<"QwDataHandlerArray::GetDataHandlerByName found a matching name \n";
      } else {
        // nothing
      }
    }
  }
  return tmp;
}

Referenced by push_back(), and push_back().

Here is the caller graph for this function:

GetDataHandlerByType()

std::vector< VQwDataHandler * > QwDataHandlerArray::GetDataHandlerByType

(

const std::string &

type

)

Get the list of handlers in this array of the specified type

Parameters

type	Type of the handler

Returns

Vector of handlers

Definition at line 305 of file QwDataHandlerArray.cc.

{
  // Vector of handler pointers
  std::vector<VQwDataHandler*> handler_list;
 
  // If this array is not empty
  if (!empty()) {
 
    // Loop over the handlers
    for (const_iterator handler = begin(); handler != end(); ++handler) {
 
      // Test to see if the handler inherits from the required type
      if (VQwDataHandlerFactory::InheritsFrom((*handler).get(),type)) {
        handler_list.push_back((*handler).get());
      }
 
    } // end of loop over handlers
 
  } // end of if !empty()
 
  return handler_list;
}

LoadDataHandlersFromParameterFile()

template<class T>

void QwDataHandlerArray::LoadDataHandlersFromParameterFile	(	QwParameterFile &	mapfile,
		T &	detectors,
		const TString &	run )

Load data handlers from a parameter file.

Parses the map file and constructs/initializes handlers, connecting them to the provided source container.

Template Parameters

T	Source type (QwHelicityPattern or QwSubsystemArrayParity).

Parameters

mapfile	Parameter file describing handlers and settings.
detectors	Source object to connect handlers to.
run	Run label used for per-run configuration.

Definition at line 86 of file QwDataHandlerArray.cc.

{
  // Set pointer to this object
  SetPointer(detectors);
 
  // This is how this should work
  std::unique_ptr<QwParameterFile> preamble;
  preamble = mapfile.ReadSectionPreamble();
  // Process preamble
  QwVerbose << "Preamble:" << QwLog::endl;
  QwVerbose << *preamble << QwLog::endl;
  if (preamble) preamble.reset();
 
  std::unique_ptr<QwParameterFile> section;
  std::string section_name;
  while ((section = mapfile.ReadNextSection(section_name))) {
 
    // Debugging output of configuration section
    QwVerbose << "[" << section_name << "]" << QwLog::endl;
    QwVerbose << *section << QwLog::endl;
 
    // Determine type and name of handler
    std::string handler_type = section_name;
    std::string handler_name;
    std::string handler_scope;
    if (! section->FileHasVariablePair("=","name",handler_name)) {
      QwError << "No name defined in section for handler " << handler_type << "." << QwLog::endl;
      continue;
    }
    if (section->FileHasVariablePair("=","scope",handler_scope)) {
      if (ScopeMismatch(handler_scope)) continue;
    } else {
      //  Assume the scope of a handler without a scope specifier is
      //  "pattern".
      if (fArrayScope != kPatternScope) continue;
    }
 
    // If handler type is explicitly disabled
    bool disabled_by_type = false;
    for (size_t i = 0; i < fDataHandlersDisabledByType.size(); i++)
      if (handler_type == fDataHandlersDisabledByType.at(i))
        disabled_by_type = true;
    if (disabled_by_type) {
      QwWarning << "DataHandler of type " << handler_type << " disabled." << QwLog::endl;
      continue;
    }
 
    // If handler name is explicitly disabled
    bool disabled_by_name = false;
    for (size_t i = 0; i < fDataHandlersDisabledByName.size(); i++)
      if (handler_name == fDataHandlersDisabledByName.at(i))
        disabled_by_name = true;
    if (disabled_by_name) {
      QwWarning << "DataHandler with name " << handler_name << " disabled." << QwLog::endl;
      continue;
    }
 
    // Create handler
    QwMessage << "Creating handler of type " << handler_type << " "
              << "with name " << handler_name << "." << QwLog::endl;
    VQwDataHandler* handler = 0;
 
    try {
      handler =
        VQwDataHandlerFactory::Create(handler_type, handler_name);
    } catch (QwException_TypeUnknown&) {
      QwError << "No support for handlers of type " << handler_type << "." << QwLog::endl;
      // Fall-through to next error for more the psychological effect of many warnings
    }
    if (! handler) {
      QwError << "Could not create handler " << handler_type << "." << QwLog::endl;
      continue;
    }
 
    // If this handler cannot be stored in this array
    if (! CanContain(handler)) {
      QwMessage << "DataHandler " << handler_name << " cannot be stored in this "
                << "handler array." << QwLog::endl;
      QwMessage << "Deleting handler " << handler_name << " again" << QwLog::endl;
      delete handler; handler = 0;
      continue;
    }
 
    // Pass detector maps
    handler->SetParent(this);
    handler->SetRunLabel(run);
    handler->SetPointer(&detectors);
    handler->ParseConfigFile(*section);
    handler->LoadChannelMap();
    handler->ConnectChannels(detectors);
    handler->InitRunningSum();
 
    // Add to array
    this->push_back(handler);
    /*
    // Instruct the handler to publish variables
    if (handler->PublishInternalValues() == kFALSE) {
      QwError << "Not all variables for " << handler->GetName()
              << " could be published!" << QwLog::endl;
    }
    */
  }
}

References CanContain(), VQwDataHandler::ConnectChannels(), QwLog::endl(), fArrayScope, fDataHandlersDisabledByName, fDataHandlersDisabledByType, VQwDataHandler::InitRunningSum(), kPatternScope, VQwDataHandler::LoadChannelMap(), VQwDataHandler::ParseConfigFile(), push_back(), QwError, QwMessage, QwVerbose, QwWarning, QwParameterFile::ReadNextSection(), QwParameterFile::ReadSectionPreamble(), ScopeMismatch(), MQwPublishable_child< U, T >::SetParent(), SetPointer(), VQwDataHandler::SetPointer(), and VQwDataHandler::SetRunLabel().

Referenced by QwDataHandlerArray(), and QwDataHandlerArray().

Here is the call graph for this function:

Here is the caller graph for this function:

operator=()

QwDataHandlerArray & QwDataHandlerArray::operator=

(

const QwDataHandlerArray &

source

)

Assignment operator.

Assignment operator

Parameters

source

DataHandler array to assign to this array

Returns

This handler array after assignment

Definition at line 469 of file QwDataHandlerArray.cc.

{
  Bool_t localdebug=kFALSE;
  if(localdebug)  std::cout<<"QwDataHandlerArray::operator= \n";
  if (!source.empty()){
    if (this->size() == source.size()){
      for(size_t i=0;i<source.size();i++){
    if (source.at(i)==NULL || this->at(i)==NULL){
      //  Either the source or the destination handler
      //  are null
    } else {
      VQwDataHandler *ptr1 =
        dynamic_cast<VQwDataHandler*>(this->at(i).get());
          VQwDataHandler *ptr2 = source.at(i).get();
      if (typeid(*ptr1)==typeid(*ptr2)){
        if(localdebug) std::cout<<" here in QwDataHandlerArray::operator= types mach \n";
        *(ptr1) = *(source.at(i).get());
      } else {
        //  DataHandlers don't match
          QwError << " QwDataHandlerArray::operator= types do not mach" << QwLog::endl;
          QwError << " typeid(*ptr1)=" << typeid(*ptr1).name()
                      << " but typeid(*ptr2)=" << typeid(*ptr2).name()
                      << QwLog::endl;
      }
    }
      }
    } else {
      //  Array sizes don't match
    }
  } else {
    //  The source is empty
  }
  return *this;
}

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

Here is the call graph for this function:

PrintErrorCounters()

void QwDataHandlerArray::PrintErrorCounters

(

)

const

Report the number of events failed due to HW and event cut failures.

PrintValue()

void QwDataHandlerArray::PrintValue

(

)

const

Print value of all channels.

Definition at line 517 of file QwDataHandlerArray.cc.

{
  if (!empty()) {
    for (const_iterator handler = begin(); handler != end(); ++handler) {
      VQwDataHandler* handler_parity = dynamic_cast<VQwDataHandler*>(handler->get());
      handler_parity->PrintValue();
    }
  }
}

References VQwDataHandler::PrintValue().

Here is the call graph for this function:

ProcessDataHandlerEntry()

void QwDataHandlerArray::ProcessDataHandlerEntry

(

)

Definition at line 705 of file QwDataHandlerArray.cc.

{
  if (!empty()) {
    for(iterator handler = begin(); handler != end(); ++handler){
      (*handler)->ProcessData();
      (*handler)->AccumulateRunningSum();
    }
  }
}

Referenced by main().

Here is the caller graph for this function:

ProcessEvent()

void QwDataHandlerArray::ProcessEvent

(

)

Definition at line 338 of file QwDataHandlerArray.cc.

{
  if (!empty()){
    std::for_each(begin(), end(), std::mem_fn(&VQwDataHandler::ProcessData));
  }
}

References VQwDataHandler::ProcessData().

Here is the call graph for this function:

ProcessOptions()

void QwDataHandlerArray::ProcessOptions

(

QwOptions &

options

)

Process configuration options for the datahandler array itself.

Handle configuration options for the handler array itself

Parameters

options

Options

Definition at line 260 of file QwDataHandlerArray.cc.

{
  // Filename to use for handler creation (single filename could be expanded
  // to a list)
  if (options.HasValue("datahandlers")){
    fDataHandlersMapFile = options.GetValue<std::string>("datahandlers");
  }
  // DataHandlers to disable
  fDataHandlersDisabledByName = options.GetValueVector<std::string>("DataHandler.disable-by-name");
  fDataHandlersDisabledByType = options.GetValueVector<std::string>("DataHandler.disable-by-type");
 
  //  Get the globally defined print running sum flag
  fPrintRunningSum = options.GetValue<bool>("print-runningsum");
}

References fDataHandlersDisabledByName, fDataHandlersDisabledByType, fDataHandlersMapFile, fPrintRunningSum, QwOptions::GetValue(), QwOptions::GetValueVector(), and QwOptions::HasValue().

Referenced by QwDataHandlerArray(), and QwDataHandlerArray().

Here is the call graph for this function:

Here is the caller graph for this function:

push_back() [1/2]

void QwDataHandlerArray::push_back

(

std::shared_ptr< VQwDataHandler >

handler

)

Add the handler to this array. Do nothing if the handler is null or if there is already a handler with that name in the array.

Parameters

handler

DataHandler to add to the array

Definition at line 627 of file QwDataHandlerArray.cc.

{
 
 if (handler.get() == NULL) {
   QwError << "QwDataHandlerArray::push_back(): NULL handler"
           << QwLog::endl;
   //  This is an empty handler...
   //  Do nothing for now.
 
 } else if (!this->empty() && GetDataHandlerByName(handler->GetName())){
   //  There is already a handler with this name!
   QwError << "QwDataHandlerArray::push_back(): handler " << handler->GetName()
           << " already exists" << QwLog::endl;
 
 } else if (!CanContain(handler.get())) {
   //  There is no support for this type of handler
   QwError << "QwDataHandlerArray::push_back(): handler " << handler->GetName()
           << " is not supported by this handler array" << QwLog::endl;
 
 } else {
   std::shared_ptr<VQwDataHandler> handler_tmp(handler);
   HandlerPtrs::push_back(handler_tmp);
 
/*
   // Set the parent of the handler to this array
   handler_tmp->SetParent(this);
 
 
   // Instruct the handler to publish variables
   if (handler_tmp->PublishInternalValues() == kFALSE) {
     QwError << "Not all variables for " << handler_tmp->GetName()
             << " could be published!" << QwLog::endl;
   }
*/
 }
}

References CanContain(), QwLog::endl(), GetDataHandlerByName(), and QwError.

Here is the call graph for this function:

push_back() [2/2]

void QwDataHandlerArray::push_back

(

VQwDataHandler *

handler

)

Add the datahandler to this array.

Add the handler to this array. Do nothing if the handler is null or if there is already a handler with that name in the array.

Parameters

handler

DataHandler to add to the array

Definition at line 199 of file QwDataHandlerArray.cc.

{
  if (handler == NULL) {
    QwError << "QwDataHandlerArray::push_back(): NULL handler"
            << QwLog::endl;
    //  This is an empty handler...
    //  Do nothing for now.
 
  } else if (!this->empty() && GetDataHandlerByName(handler->GetName())){
    //  There is already a handler with this name!
    QwError << "QwDataHandlerArray::push_back(): handler " << handler->GetName()
            << " already exists" << QwLog::endl;
 
  } else if (!CanContain(handler)) {
    //  There is no support for this type of handler
    QwError << "QwDataHandlerArray::push_back(): handler " << handler->GetName()
            << " is not supported by this handler array" << QwLog::endl;
 
  } else {
    std::shared_ptr<VQwDataHandler> handler_tmp(handler);
    HandlerPtrs::push_back(handler_tmp);
 
    // Set the parent of the handler to this array
    //    handler_tmp->SetParent(this);
 
  }
}

References CanContain(), QwLog::endl(), GetDataHandlerByName(), VQwDataHandler::GetName(), and QwError.

Referenced by LoadDataHandlersFromParameterFile().

Here is the call graph for this function:

Here is the caller graph for this function:

ScopeMismatch()

Bool_t QwDataHandlerArray::ScopeMismatch ( TString name )

inlineprotected

Definition at line 207 of file QwDataHandlerArray.h.

                                      {
      name.ToLower();
      EDataHandlerArrayScope tmpscope = kUnknownScope;
      if (name=="event") tmpscope = kEventScope;
      if (name=="pattern") tmpscope = kPatternScope;
      return (fArrayScope != tmpscope);
    }

References fArrayScope, kEventScope, kPatternScope, and kUnknownScope.

Referenced by LoadDataHandlersFromParameterFile().

Here is the caller graph for this function:

SetPointer() [1/2]

void QwDataHandlerArray::SetPointer ( QwHelicityPattern & helicitypattern )

inlineprotected

Definition at line 193 of file QwDataHandlerArray.h.

                                                        {
      fHelicityPattern = &helicitypattern;
    }

References fHelicityPattern.

Referenced by LoadDataHandlersFromParameterFile().

Here is the caller graph for this function:

SetPointer() [2/2]

void QwDataHandlerArray::SetPointer ( QwSubsystemArrayParity & detectors )

inlineprotected

Definition at line 196 of file QwDataHandlerArray.h.

                                                       {
      fSubsystemArray = &detectors;
    }

References fSubsystemArray.

UpdateBurstCounter()

void QwDataHandlerArray::UpdateBurstCounter ( Short_t burstcounter )

inline

Definition at line 142 of file QwDataHandlerArray.h.

    {
      if (!empty()) {
    for(iterator handler = begin(); handler != end(); ++handler){
      (*handler)->UpdateBurstCounter(burstcounter);
    }
      }
    }

Referenced by main().

Here is the caller graph for this function:

WritePromptSummary()

void QwDataHandlerArray::WritePromptSummary	(	QwPromptSummary *	ps,
		TString	type )

Definition at line 451 of file QwDataHandlerArray.cc.

{
  if (!empty()){
    for (const_iterator handler = begin(); handler != end(); ++handler) {
      VQwDataHandler* handler_parity = dynamic_cast<VQwDataHandler*>(handler->get());
      handler_parity->WritePromptSummary(ps, type);
    }
  }
}

References VQwDataHandler::WritePromptSummary().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

Field Documentation

fArrayScope

EDataHandlerArrayScope QwDataHandlerArray::fArrayScope

protected

Definition at line 215 of file QwDataHandlerArray.h.

Referenced by LoadDataHandlersFromParameterFile(), QwDataHandlerArray(), QwDataHandlerArray(), and ScopeMismatch().

fDataHandlersDisabledByName

std::vector<std::string> QwDataHandlerArray::fDataHandlersDisabledByName

protected

List of disabled types.

Definition at line 217 of file QwDataHandlerArray.h.

Referenced by LoadDataHandlersFromParameterFile(), ProcessOptions(), and QwDataHandlerArray().

fDataHandlersDisabledByType

std::vector<std::string> QwDataHandlerArray::fDataHandlersDisabledByType

protected

List of disabled names.

Definition at line 218 of file QwDataHandlerArray.h.

Referenced by LoadDataHandlersFromParameterFile(), ProcessOptions(), and QwDataHandlerArray().

fDataHandlersMapFile

std::string QwDataHandlerArray::fDataHandlersMapFile

protected

Filename of the global detector map.

Definition at line 205 of file QwDataHandlerArray.h.

Referenced by ProcessOptions(), QwDataHandlerArray(), QwDataHandlerArray(), and QwDataHandlerArray().

fHelicityPattern

QwHelicityPattern* QwDataHandlerArray::fHelicityPattern

protected

Pointer for the original data source.

Definition at line 201 of file QwDataHandlerArray.h.

Referenced by QwDataHandlerArray(), QwDataHandlerArray(), QwDataHandlerArray(), and SetPointer().

fPrintRunningSum

Bool_t QwDataHandlerArray::fPrintRunningSum

protected

Definition at line 220 of file QwDataHandlerArray.h.

Referenced by ProcessOptions().

fSubsystemArray

QwSubsystemArrayParity* QwDataHandlerArray::fSubsystemArray

protected

Definition at line 202 of file QwDataHandlerArray.h.

Referenced by QwDataHandlerArray(), QwDataHandlerArray(), QwDataHandlerArray(), and SetPointer().

---

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

• QwDataHandlerArray.h
• QwDataHandlerArray.cc