QwSubsystemArray Class Reference

Container for managing multiple subsystems with common operations. More...

#include <QwSubsystemArray.h>

Inheritance diagram for QwSubsystemArray:

Collaboration diagram for QwSubsystemArray:

Public Types
typedef Bool_t(*	CanContainFn) (VQwSubsystem *)

Public Member Functions
	QwSubsystemArray (QwOptions &options, CanContainFn myCanContain)
	Constructor with options.
	QwSubsystemArray (const QwSubsystemArray &source)
	Copy constructor by reference.
	~QwSubsystemArray () override
	Virtual destructor.
QwSubsystemArray &	operator= (const QwSubsystemArray &value)
	Assignment operator.
void	SetCodaRunNumber (UInt_t runnum)
	Set the internal record of the CODA run number.
void	SetCodaSegmentNumber (UInt_t segnum)
	Set the internal record of the CODA segment number.
void	SetCodaEventNumber (UInt_t evtnum)
	Set the internal record of the CODA event number.
void	SetCodaEventType (UInt_t evttype)
	Set the internal record of the CODA event type.
UInt_t	GetCodaRunNumber () const
	Get the internal record of the CODA run number.
UInt_t	GetCodaSegmentNumber () const
	Get the internal record of the CODA segment number.
UInt_t	GetCodaEventNumber () const
	Get the internal record of the CODA event number.
UInt_t	GetCodaEventType () const
	Get the internal record of the CODA event type.
void	SetEventTypeMask (const UInt_t mask)
	Set event type mask.
UInt_t	GetEventTypeMask () const
	Get event type mask.
UInt_t	UpdateEventTypeMask ()
	Update the event type mask from the subsystems.
void	SetDataLoaded (const Bool_t flag)
	Set data loaded flag.
Bool_t	HasDataLoaded () const
	Get data loaded flag.
void	ProcessOptionsToplevel (QwOptions &options)
	Process configuration options for the subsystem array itself.
void	ProcessOptionsSubsystems (QwOptions &options)
	Process configuration options for all subsystems in the array.
void	ProcessOptions (QwOptions &options)
	Process configuration options (default behavior)
void	LoadAllEventRanges (QwOptions &options)
void	push_back (VQwSubsystem *subsys)
	Add the subsystem to this array.
virtual VQwSubsystem *	GetSubsystemByName (const TString &name)
	Get the subsystem with the specified name.
virtual std::vector< VQwSubsystem * >	GetSubsystemByType (const std::string &type)
	Get the list of subsystems of the specified type.
void	ClearEventData ()
Int_t	ProcessConfigurationBuffer (const ROCID_t roc_id, const BankID_t bank_id, UInt_t *buffer, UInt_t num_words)
	Process the event buffer for configuration events.
Int_t	ProcessEvBuffer (const UInt_t event_type, const ROCID_t roc_id, const BankID_t bank_id, UInt_t *buffer, UInt_t num_words)
	Process the event buffer for events.
void	GetROCIDList (std::vector< ROCID_t > &list)
	Get the ROCID list.
void	ProcessEvent ()
	Process the decoded data in this event.
void	AtEndOfEventLoop ()
	Perform actions at the end of the event loop.
void	PrintParamFileList () const
	Print list of parameter files.
TList *	GetParamFileNameList (TString name) const
	Get list of parameter files.
Object construction and maintenance
void	ConstructObjects ()
	Construct the objects for this subsystem.
void	ConstructObjects (TDirectory *folder)
	Construct the objects for this subsystem in a folder.
void	ConstructObjects (TDirectory *folder, TString &prefix)
	Construct the objects for this subsystem in a folder with a prefix.
Histogram construction and maintenance
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 for this subsystem in a folder with a prefix.
void	FillHistograms ()
	Fill the histograms for this subsystem.
void	ShareHistograms (const QwSubsystemArray &source)
	Share the histograms with another subsystem.
Tree and vector construction and maintenance
void	ConstructBranchAndVector (TTree *tree, QwRootTreeBranchVector &values)
	Construct the tree and vector for this subsystem.
void	ConstructBranchAndVector (TTree *tree, TString &prefix, QwRootTreeBranchVector &values)
	Construct a branch and vector for this subsystem with a prefix.
void	ConstructBranch (TTree *tree, TString &prefix)
	Construct a branch for this subsystem with a prefix.
void	ConstructBranch (TTree *tree, TString &prefix, QwParameterFile &trim_file)
	Construct a branch for this subsystem with a prefix after tree leave trimming.
void	FillTreeVector (QwRootTreeBranchVector &values) const
	Fill the vector for this subsystem.
Public Member Functions inherited from MQwPublishable< QwSubsystemArray, VQwSubsystem >
	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 VQwSubsystem *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.

Private Types
typedef std::vector< std::shared_ptr< VQwSubsystem > >	SubsysPtrs

Private Member Functions
	QwSubsystemArray ()
	Private default constructor.

Tree construction and maintenance
These functions are not purely virtual, since not every subsystem is expected to implement them. They are intended for expert output to trees.
size_t	fTreeArrayIndex
UInt_t	fCodaRunNumber
	Index of this data element in root tree.
UInt_t	fCodaSegmentNumber
	CODA segment number as provided by QwEventBuffer.
UInt_t	fCodaEventNumber
	CODA event number as provided by QwEventBuffer.
UInt_t	fCodaEventType
	CODA event type as provided by QwEventBuffer.
UInt_t	fEventTypeMask
	Mask of event types.
Bool_t	fHasDataLoaded
	Has this array gotten data to be processed?
CanContainFn	fnCanContain
	Function to determine which subsystems we can accept.
std::vector< std::pair< UInt_t, UInt_t > >	fBadEventRange
std::vector< VQwSubsystem * >	fResolvedSelf
const QwSubsystemArray *	fResolvedPeer = nullptr
std::vector< VQwSubsystem * >	fResolvedPeerSlots
std::vector< Bool_t >	fResolvedPairCompatible
double	fWindowPeriod
std::string	fSubsystemsMapFile
	Filename of the global detector map.
std::vector< std::string >	fSubsystemsDisabledByName
	List of disabled types.
std::vector< std::string >	fSubsystemsDisabledByType
	List of disabled names.
void	ConstructTree ()
	Construct the tree for this subsystem.
void	ConstructTree (TDirectory *folder)
	Construct the tree for this subsystem in a folder.
void	ConstructTree (TDirectory *folder, TString &prefix)
	Construct the tree for this subsystem in a folder with a prefix.
void	FillTree ()
	Fill the tree for this subsystem.
void	DeleteTree ()
	Delete the tree for this subsystem.
void	PrintInfo () const
	Print some information about the subsystem.
void	push_back (std::shared_ptr< VQwSubsystem > subsys)
void	GetMarkerWordList (const ROCID_t roc_id, const BankID_t bank_id, std::vector< UInt_t > &marker) const
void	RandomizeEventData (int helicity=0, double time=0.0)
	Randomize the data in this event.
void	EncodeEventData (std::vector< UInt_t > &buffer)
	Encode the data in this event.
double	GetWindowPeriod ()
void	LoadSubsystemsFromParameterFile (QwParameterFile &detectors)
void	InvalidateResolvedDispatchCache ()
void	BuildResolvedSelf () const
void	ResolvePairing (const QwSubsystemArray &source, const char *context) const
static Bool_t	CanContain (VQwSubsystem *subsys)
	Test whether this subsystem array can contain a particular subsystem.

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

Detailed Description

Container for managing multiple subsystems with common operations.

Extends std::vector to provide subsystem-level operations such as event processing, accumulation, tree/histogram construction, and publishing. Uses container-delegation pattern to forward arithmetic operations to individual subsystems while maintaining type safety.

Definition at line 42 of file QwSubsystemArray.h.

Member Typedef Documentation

CanContainFn

typedef Bool_t(* QwSubsystemArray::CanContainFn) (VQwSubsystem *)

Definition at line 56 of file QwSubsystemArray.h.

SubsysPtrs

typedef std::vector<std::shared_ptr<VQwSubsystem> > QwSubsystemArray::SubsysPtrs

private

Definition at line 47 of file QwSubsystemArray.h.

Constructor & Destructor Documentation

QwSubsystemArray() [1/3]

QwSubsystemArray::QwSubsystemArray ( )

private

Private default constructor.

References QwSubsystemArray().

Referenced by operator=(), QwSubsystemArray(), QwSubsystemArray(), QwSubsystemArrayParity::QwSubsystemArrayParity(), QwSubsystemArrayParity::QwSubsystemArrayParity(), ResolvePairing(), and ShareHistograms().

Here is the call graph for this function:

Here is the caller graph for this function:

QwSubsystemArray() [2/3]

QwSubsystemArray::QwSubsystemArray	(	QwOptions &	options,
		CanContainFn	myCanContain )

Constructor with options.

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

Definition at line 22 of file QwSubsystemArray.cc.

: fEventTypeMask(0x0),fnCanContain(myCanContain)
{
  ProcessOptionsToplevel(options);
  QwParameterFile detectors(fSubsystemsMapFile.c_str());
  QwMessage << "Loading subsystems from " << fSubsystemsMapFile << "." << QwLog::endl;
  LoadSubsystemsFromParameterFile(detectors);
}

References QwLog::endl(), fEventTypeMask, fnCanContain, fSubsystemsMapFile, LoadSubsystemsFromParameterFile(), ProcessOptionsToplevel(), and QwMessage.

Here is the call graph for this function:

QwSubsystemArray() [3/3]

QwSubsystemArray::QwSubsystemArray

(

const QwSubsystemArray &

source

)

Copy constructor by reference.

Copy constructor by reference

Parameters

source

Source subsystem array

Definition at line 35 of file QwSubsystemArray.cc.

: std::vector<std::shared_ptr<VQwSubsystem>>(),
  MQwPublishable(source),
  fTreeArrayIndex(source.fTreeArrayIndex),
  fCodaRunNumber(source.fCodaRunNumber),
  fCodaSegmentNumber(source.fCodaSegmentNumber),
  fCodaEventNumber(source.fCodaEventNumber),
  fCodaEventType(source.fCodaEventType),
  fEventTypeMask(source.fEventTypeMask),
  fHasDataLoaded(source.fHasDataLoaded),
  fnCanContain(source.fnCanContain),
  fSubsystemsMapFile(source.fSubsystemsMapFile),
  fSubsystemsDisabledByName(source.fSubsystemsDisabledByName),
  fSubsystemsDisabledByType(source.fSubsystemsDisabledByType)
{
 
  // Make copies of all subsystems rather than copying just the pointers
  for (const_iterator subsys = source.begin(); subsys != source.end(); ++subsys) {
    this->push_back(subsys->get()->Clone());
    // Instruct the subsystem to publish variables
    if (this->back()->PublishInternalValues() == kFALSE) {
      QwError << "Not all variables for " << this->back()->GetName()
             << " could be published!" << QwLog::endl;
    }
  }
}

References fCodaEventNumber, fCodaEventType, fCodaRunNumber, fCodaSegmentNumber, fEventTypeMask, fHasDataLoaded, fnCanContain, fSubsystemsDisabledByName, fSubsystemsDisabledByType, fSubsystemsMapFile, fTreeArrayIndex, MQwPublishable< QwSubsystemArray, VQwSubsystem >::MQwPublishable(), and QwSubsystemArray().

Here is the call graph for this function:

~QwSubsystemArray()

QwSubsystemArray::~QwSubsystemArray ( )

inlineoverride

Virtual destructor.

Definition at line 70 of file QwSubsystemArray.h.

{ };

Member Function Documentation

AtEndOfEventLoop()

void QwSubsystemArray::AtEndOfEventLoop

(

)

Perform actions at the end of the event loop.

Definition at line 463 of file QwSubsystemArray.cc.

{
  QwDebug << "QwSubsystemArray at end of event loop" << QwLog::endl;
  if (!empty()) {
    std::for_each(begin(), end(), boost::mem_fn(&VQwSubsystem::AtEndOfEventLoop));
  }
}

References VQwSubsystem::AtEndOfEventLoop(), QwLog::endl(), and QwDebug.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

BuildResolvedSelf()

void QwSubsystemArray::BuildResolvedSelf ( ) const

protected

Definition at line 70 of file QwSubsystemArray.cc.

{
  if (fResolvedSelf.size() == this->size()) return;
  // Self layout changed: any peer cache built against the old layout is stale.
  fResolvedPeer = nullptr;
  fResolvedPeerSlots.clear();
  fResolvedPairCompatible.clear();
  fResolvedSelf.assign(this->size(), nullptr);
  for (size_t i = 0; i < this->size(); ++i) {
    if (this->at(i) != nullptr) {
      fResolvedSelf[i] = this->at(i).get();
    }
  }
}

References fResolvedPairCompatible, fResolvedPeer, fResolvedPeerSlots, and fResolvedSelf.

Referenced by ResolvePairing().

Here is the caller graph for this function:

CanContain()

static Bool_t QwSubsystemArray::CanContain ( VQwSubsystem * subsys )

inlinestaticprotected

Test whether this subsystem array can contain a particular subsystem.

Definition at line 281 of file QwSubsystemArray.h.

                                                 {
    if (subsys == 0) {
      QwError << "Zero pointer passed!" << QwLog::endl;
    }
    // should never occur
    return kFALSE;
  };

References QwLog::endl(), and QwError.

Here is the call graph for this function:

ClearEventData()

void QwSubsystemArray::ClearEventData

(

)

Definition at line 397 of file QwSubsystemArray.cc.

{
  if (!empty()) {
    SetDataLoaded(kFALSE);
    SetCodaEventNumber(0);
    SetCodaEventType(0);
    std::for_each(begin(), end(),
          std::mem_fn(&VQwSubsystem::ClearEventData));
  }
}

References VQwSubsystem::ClearEventData(), SetCodaEventNumber(), SetCodaEventType(), and SetDataLoaded().

Referenced by QwEventBuffer::FillSubsystemData(), main(), and main().

Here is the call graph for this function:

Here is the caller graph for this function:

ConstructBranch() [1/2]

void QwSubsystemArray::ConstructBranch	(	TTree *	tree,
		TString &	prefix )

Construct a branch for this subsystem with a prefix.

Construct the branch for the flat tree

Parameters

tree	Tree
prefix	Prefix

Definition at line 621 of file QwSubsystemArray.cc.

{
  // Only MPS tree should contain event number and type
  if (prefix == "" || prefix == "yield_") {
    tree->Branch("CodaEventNumber",&fCodaEventNumber,"CodaEventNumber/i");
    tree->Branch("CodaEventType",&fCodaEventType,"CodaEventType/i");
  }
 
  for (iterator subsys = begin(); subsys != end(); ++subsys) {
    VQwSubsystem* subsys_ptr = dynamic_cast<VQwSubsystem*>(subsys->get());
    subsys_ptr->ConstructBranch(tree, prefix);
  }
}

References VQwSubsystem::ConstructBranch(), fCodaEventNumber, and fCodaEventType.

Here is the call graph for this function:

ConstructBranch() [2/2]

void QwSubsystemArray::ConstructBranch	(	TTree *	tree,
		TString &	prefix,
		QwParameterFile &	trim_file )

Construct a branch for this subsystem with a prefix after tree leave trimming.

Construct the branch for the flat tree with tree trim files accepted

Parameters

tree	Tree
prefix	Prefix
trim_file	Trim file

Definition at line 642 of file QwSubsystemArray.cc.

{
  QwMessage << " QwSubsystemArray::ConstructBranch " << QwLog::endl;
 
  std::unique_ptr<QwParameterFile> preamble;
  std::unique_ptr<QwParameterFile> nextsection;
  preamble = trim_file.ReadSectionPreamble();
 
  // Process preamble
  QwVerbose << "QwSubsystemArrayTracking::ConstructBranch  Preamble:" << QwLog::endl;
  QwVerbose << *preamble << QwLog::endl;
 
  if (prefix == "" || prefix == "yield_") {
    tree->Branch("CodaEventNumber",&fCodaEventNumber,"CodaEventNumber/i");
    tree->Branch("CodaEventType",&fCodaEventType,"CodaEventType/i");
  }
 
  for (iterator subsys = begin(); subsys != end(); ++subsys) {
    VQwSubsystem* subsys_ptr = dynamic_cast<VQwSubsystem*>(subsys->get());
 
    TString subsysname = subsys_ptr->GetName();
    //QwMessage << "Tree leaves created for " << subsysname << QwLog::endl;
 
    if (trim_file.FileHasSectionHeader(subsysname)) {
      // This section contains modules and their channels to be included in the tree
      nextsection = trim_file.ReadUntilNextSection();
      subsys_ptr->ConstructBranch(tree, prefix, *nextsection);
      QwMessage << "Tree leaves created for " << subsysname << QwLog::endl;
    } else
      QwMessage << "No tree leaves created for " << subsysname << QwLog::endl;
  }
}

References VQwSubsystem::ConstructBranch(), QwLog::endl(), fCodaEventNumber, fCodaEventType, QwParameterFile::FileHasSectionHeader(), VQwSubsystem::GetName(), QwMessage, QwVerbose, QwParameterFile::ReadSectionPreamble(), and QwParameterFile::ReadUntilNextSection().

Here is the call graph for this function:

ConstructBranchAndVector() [1/2]

void QwSubsystemArray::ConstructBranchAndVector ( TTree * tree, QwRootTreeBranchVector & values )

inline

Construct the tree and vector for this subsystem.

Definition at line 202 of file QwSubsystemArray.h.

                                                                             {
    TString tmpstr("");
    ConstructBranchAndVector(tree,tmpstr,values);
  };

References ConstructBranchAndVector().

Referenced by ConstructBranchAndVector(), and QwSubsystemArrayParity::ConstructBranchAndVector().

Here is the call graph for this function:

Here is the caller graph for this function:

ConstructBranchAndVector() [2/2]

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

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

Construct the branch and tree vector

Parameters

tree	Tree
prefix	Prefix
values	Vector of values

Definition at line 592 of file QwSubsystemArray.cc.

{
  fTreeArrayIndex = values.size();
 
  // Each tree should only contain event number and type once, but will
  // still reserve space in the values vector, so we don't need to modify
  // FillTreeVector().
  values.push_back("CodaEventNumber", 'i');
  values.push_back("CodaEventType", 'i');
  if (prefix == "" || prefix.Index("yield_") == 0) {
    tree->Branch("CodaEventNumber",&(values[fTreeArrayIndex]),"CodaEventNumber/i");
    tree->Branch("CodaEventType",&(values[fTreeArrayIndex+1]),"CodaEventType/i");
  }
  for (iterator subsys = begin(); subsys != end(); ++subsys) {
    VQwSubsystem* subsys_ptr = dynamic_cast<VQwSubsystem*>(subsys->get());
    subsys_ptr->ConstructBranchAndVector(tree, prefix, values);
  }
 
}

References VQwSubsystem::ConstructBranchAndVector(), fTreeArrayIndex, QwRootTreeBranchVector::push_back(), and QwRootTreeBranchVector::size().

Here is the call graph for this function:

ConstructHistograms() [1/3]

void QwSubsystemArray::ConstructHistograms ( )

inline

Construct the histograms for this subsystem.

Definition at line 182 of file QwSubsystemArray.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 QwSubsystemArray::ConstructHistograms ( TDirectory * folder )

inline

Construct the histograms for this subsystem in a folder.

Definition at line 186 of file QwSubsystemArray.h.

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

References ConstructHistograms().

Here is the call graph for this function:

ConstructHistograms() [3/3]

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

Construct the histograms for this subsystem in a folder with a prefix.

Definition at line 514 of file QwSubsystemArray.cc.

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

ConstructObjects() [1/3]

void QwSubsystemArray::ConstructObjects ( )

inline

Construct the objects for this subsystem.

Definition at line 166 of file QwSubsystemArray.h.

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

References ConstructObjects().

Referenced by ConstructObjects(), and ConstructObjects().

Here is the call graph for this function:

Here is the caller graph for this function:

ConstructObjects() [2/3]

void QwSubsystemArray::ConstructObjects ( TDirectory * folder )

inline

Construct the objects for this subsystem in a folder.

Definition at line 170 of file QwSubsystemArray.h.

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

References ConstructObjects().

Here is the call graph for this function:

ConstructObjects() [3/3]

void QwSubsystemArray::ConstructObjects	(	TDirectory *	folder,
		TString &	prefix )

Construct the objects for this subsystem in a folder with a prefix.

Definition at line 504 of file QwSubsystemArray.cc.

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

ConstructTree() [1/3]

void QwSubsystemArray::ConstructTree ( )

inline

Construct the tree for this subsystem.

Definition at line 235 of file QwSubsystemArray.h.

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

References ConstructTree().

Referenced by ConstructTree(), and ConstructTree().

Here is the call graph for this function:

Here is the caller graph for this function:

ConstructTree() [2/3]

void QwSubsystemArray::ConstructTree ( TDirectory * folder )

inline

Construct the tree for this subsystem in a folder.

Definition at line 239 of file QwSubsystemArray.h.

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

References ConstructTree().

Here is the call graph for this function:

ConstructTree() [3/3]

void QwSubsystemArray::ConstructTree	(	TDirectory *	folder,
		TString &	prefix )

Construct the tree for this subsystem in a folder with a prefix.

Construct the tree for this subsystem

Parameters

folder	Directory where to construct the tree
prefix	Prefix for the name of the tree

Definition at line 546 of file QwSubsystemArray.cc.

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

DefineOptions()

void QwSubsystemArray::DefineOptions ( QwOptions & options )

static

Define configuration options for global array.

Define configuration options for global array

Parameters

options

Options

Definition at line 275 of file QwSubsystemArray.cc.

{
  options.AddOptions()("detectors",
                       po::value<std::string>()->default_value("detectors.map"),
                       "map file with detectors to include");
 
  options.AddOptions()("bad-event-list",
                       po::value<std::string>()->default_value(""),
                       "map file with bad event ranges");
 
  // Versions of boost::program_options below 1.39.0 have a bug in multitoken processing
  options.AddOptions()("disable-by-type",
                       po::value<std::vector <std::string> >()->multitoken(),
                       "subsystem types to disable");
  options.AddOptions()("disable-by-name",
                       po::value<std::vector <std::string> >()->multitoken(),
                       "subsystem names to disable");
}

References QwOptions::AddOptions().

Referenced by QwOptions::DefineOptions().

Here is the call graph for this function:

Here is the caller graph for this function:

DeleteTree()

void QwSubsystemArray::DeleteTree

(

)

Delete the tree for this subsystem.

Delete the tree for this subsystem

Definition at line 567 of file QwSubsystemArray.cc.

{
  if (!empty())
    std::for_each(begin(), end(), boost::mem_fn(&VQwSubsystem::DeleteTree));
}

References VQwSubsystem::DeleteTree().

Here is the call graph for this function:

EncodeEventData()

void QwSubsystemArray::EncodeEventData

(

std::vector< UInt_t > &

buffer

)

Encode the data in this event.

Definition at line 481 of file QwSubsystemArray.cc.

{
  if (!empty())
    for (iterator subsys = begin(); subsys != end(); ++subsys) {
      (*subsys)->EncodeEventData(buffer);
    }
}

Referenced by QwEventBuffer::EncodeSubsystemData().

Here is the caller graph for this function:

FillHistograms()

void QwSubsystemArray::FillHistograms

(

)

Fill the histograms for this subsystem.

Definition at line 523 of file QwSubsystemArray.cc.

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

References VQwSubsystem::FillHistograms().

Referenced by QwSubsystemArrayParity::FillHistograms().

Here is the call graph for this function:

Here is the caller graph for this function:

FillTree()

void QwSubsystemArray::FillTree

(

)

Fill the tree for this subsystem.

Fill the tree for this subsystem

Definition at line 558 of file QwSubsystemArray.cc.

{
  if (!empty())
    std::for_each(begin(), end(), boost::mem_fn(&VQwSubsystem::FillTree));
}

References VQwSubsystem::FillTree().

Here is the call graph for this function:

FillTreeVector()

void QwSubsystemArray::FillTreeVector

(

QwRootTreeBranchVector &

values

)

const

Fill the vector for this subsystem.

Fill the tree vector

Parameters

values

Vector of values

Definition at line 683 of file QwSubsystemArray.cc.

{
  // Fill the event number and event type
  size_t index = fTreeArrayIndex;
  values.SetValue(index++, this->GetCodaEventNumber());
  values.SetValue(index++, this->GetCodaEventType());
 
  // Fill the subsystem data
  for (const_iterator subsys = begin(); subsys != end(); ++subsys) {
    VQwSubsystem* subsys_ptr = dynamic_cast<VQwSubsystem*>(subsys->get());
    subsys_ptr->FillTreeVector(values);
  }
}

References VQwSubsystem::FillTreeVector(), fTreeArrayIndex, GetCodaEventNumber(), GetCodaEventType(), and QwRootTreeBranchVector::SetValue().

Referenced by QwSubsystemArrayParity::FillTreeVector().

Here is the call graph for this function:

Here is the caller graph for this function:

GetCodaEventNumber()

UInt_t QwSubsystemArray::GetCodaEventNumber ( ) const

inline

Get the internal record of the CODA event number.

Definition at line 88 of file QwSubsystemArray.h.

{ return fCodaEventNumber; };

References fCodaEventNumber.

Referenced by FillTreeVector().

Here is the caller graph for this function:

GetCodaEventType()

UInt_t QwSubsystemArray::GetCodaEventType ( ) const

inline

Get the internal record of the CODA event type.

Definition at line 90 of file QwSubsystemArray.h.

{ return fCodaEventType; };

References fCodaEventType.

Referenced by FillTreeVector().

Here is the caller graph for this function:

GetCodaRunNumber()

UInt_t QwSubsystemArray::GetCodaRunNumber ( ) const

inline

Get the internal record of the CODA run number.

Definition at line 84 of file QwSubsystemArray.h.

{ return fCodaRunNumber; };

References fCodaRunNumber.

GetCodaSegmentNumber()

UInt_t QwSubsystemArray::GetCodaSegmentNumber ( ) const

inline

Get the internal record of the CODA segment number.

Definition at line 86 of file QwSubsystemArray.h.

{ return fCodaSegmentNumber; };

References fCodaSegmentNumber.

GetEventTypeMask()

UInt_t QwSubsystemArray::GetEventTypeMask ( ) const

inline

Get event type mask.

Definition at line 95 of file QwSubsystemArray.h.

{ return fEventTypeMask; };

References fEventTypeMask.

Referenced by QwEventBuffer::FillSubsystemData().

Here is the caller graph for this function:

GetMarkerWordList()

void QwSubsystemArray::GetMarkerWordList	(	const ROCID_t	roc_id,
		const BankID_t	bank_id,
		std::vector< UInt_t > &	marker ) const

QwSubsystemArray::GetMarkerWordList should be called once by QwEventBuffer to build the marker word list as each roc_id and bank_id are reached in the decoding.

Definition at line 424 of file QwSubsystemArray.cc.

{
  if (!empty()){
    for (const_iterator subsys = begin(); subsys != end(); ++subsys) {
      (*subsys)->GetMarkerWordList(roc_id, bank_id, marker);
    }
  }
}

Referenced by QwEventBuffer::CheckForMarkerWords().

Here is the caller graph for this function:

GetParamFileNameList()

TList * QwSubsystemArray::GetParamFileNameList

(

TString

name

)

const

Get list of parameter files.

Definition at line 807 of file QwSubsystemArray.cc.

{
  if (not empty()) {
 
    TList* return_maps_TList = new TList;
    return_maps_TList->SetName(name);
 
    std::map<TString, TString> mapfiles_subsystem;
 
    for (const_iterator subsys = begin(); subsys != end(); ++subsys)
      {
    mapfiles_subsystem = (*subsys)->GetDetectorMaps();
    for( std::map<TString, TString>::iterator ii= mapfiles_subsystem.begin(); ii!= mapfiles_subsystem.end(); ++ii)
      {
        TList *test = new TList;
        test->SetName((*ii).first);
        test->AddLast(new TObjString((*ii).second));
        return_maps_TList -> AddLast(test);
      }
      }
 
    return return_maps_TList;
  }
  else {
    return NULL;
  }
};

GetROCIDList()

void QwSubsystemArray::GetROCIDList

(

std::vector< ROCID_t > &

list

)

Get the ROCID list.

Definition at line 489 of file QwSubsystemArray.cc.

{
  if (!empty()){
        std::vector<ROCID_t> tmp;
    for (iterator subsys = begin(); subsys != end(); ++subsys) {
            tmp = (*subsys)->GetROCIds();
            for(auto it = tmp.begin(); it!=tmp.end();it++){
                if(std::find(list.begin(), list.end(), *it) == list.end() )
                    list.push_back(*it);
            }
    }
    }
}

Referenced by QwEventBuffer::EncodeSubsystemData().

Here is the caller graph for this function:

GetSubsystemByName()

VQwSubsystem * QwSubsystemArray::GetSubsystemByName ( const TString & name )

virtual

Get the subsystem with the specified name.

Get the subsystem in this array with the specified name

Parameters

name	Name of the subsystem

Returns

Pointer to the subsystem

Reimplemented in QwSubsystemArrayParity.

Definition at line 348 of file QwSubsystemArray.cc.

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

Referenced by VQwSubsystem::GetSibling(), QwSubsystemArrayParity::GetSubsystemByName(), push_back(), and push_back().

Here is the caller graph for this function:

GetSubsystemByType()

std::vector< VQwSubsystem * > QwSubsystemArray::GetSubsystemByType ( const std::string & type )

virtual

Get the list of subsystems of the specified type.

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

Parameters

type	Type of the subsystem

Returns

Vector of subsystems

Definition at line 373 of file QwSubsystemArray.cc.

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

Referenced by main().

Here is the caller graph for this function:

GetWindowPeriod()

double QwSubsystemArray::GetWindowPeriod ( )

inline

Definition at line 316 of file QwSubsystemArray.h.

{return fWindowPeriod;};

References fWindowPeriod.

Referenced by main().

Here is the caller graph for this function:

HasDataLoaded()

Bool_t QwSubsystemArray::HasDataLoaded ( ) const

inline

Get data loaded flag.

Definition at line 109 of file QwSubsystemArray.h.

{ return fHasDataLoaded; };

References fHasDataLoaded.

Referenced by ProcessEvent().

Here is the caller graph for this function:

InvalidateResolvedDispatchCache()

void QwSubsystemArray::InvalidateResolvedDispatchCache ( )

protected

Definition at line 62 of file QwSubsystemArray.cc.

{
  fResolvedSelf.clear();
  fResolvedPeer = nullptr;
  fResolvedPeerSlots.clear();
  fResolvedPairCompatible.clear();
}

References fResolvedPairCompatible, fResolvedPeer, fResolvedPeerSlots, and fResolvedSelf.

Referenced by push_back(), and push_back().

Here is the caller graph for this function:

LoadAllEventRanges()

void QwSubsystemArray::LoadAllEventRanges

(

QwOptions &

options

)

Definition at line 324 of file QwSubsystemArray.cc.

                                                           {
 
  std::string fBadEventListFileName = options.GetValue<std::string>("bad-event-list");
  if (fBadEventListFileName.size() > 0) {
    QwParameterFile fBadEventListFile(fBadEventListFileName);
    // If there is an event list, open the next section
    std::string bad_event_range;
    while (fBadEventListFile.ReadNextLine(bad_event_range)){
      // Find next non-whitespace, non-comment, non-empty line, before EOF
      fBadEventListFile.TrimWhitespace();
      fBadEventListFile.TrimComment('#');
      if (fBadEventListFile.LineIsEmpty()) continue;
      std::pair<UInt_t,UInt_t> aBadEventRange = QwParameterFile::ParseIntRange(":",bad_event_range);
      fBadEventRange.push_back(aBadEventRange);
      QwMessage << "Next Bad event range is " << bad_event_range << QwLog::endl;
    } // end of loop of reading lines.
  }
}

References QwLog::endl(), fBadEventRange, QwOptions::GetValue(), QwParameterFile::LineIsEmpty(), QwParameterFile::ParseIntRange(), QwMessage, QwParameterFile::ReadNextLine(), QwParameterFile::TrimComment(), and QwParameterFile::TrimWhitespace().

Referenced by ProcessOptionsSubsystems().

Here is the call graph for this function:

Here is the caller graph for this function:

LoadSubsystemsFromParameterFile()

void QwSubsystemArray::LoadSubsystemsFromParameterFile ( QwParameterFile & detectors )

protected

Fill the subsystem array with the contents of a map file

Parameters

detectors

Map file

Definition at line 146 of file QwSubsystemArray.cc.

{
  // This is how this should work
  std::unique_ptr<QwParameterFile> preamble;
  preamble = detectors.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 = detectors.ReadNextSection(section_name))) {
 
    // Debugging output of configuration section
    QwVerbose << "[" << section_name << "]" << QwLog::endl;
    QwVerbose << *section << QwLog::endl;
 
    // Determine type and name of subsystem
    std::string subsys_type = section_name;
    std::string subsys_name;
    if (! section->FileHasVariablePair("=","name",subsys_name)) {
      QwError << "No name defined in section for subsystem " << subsys_type << "." << QwLog::endl;
      continue;
    }
 
    // If subsystem type is explicitly disabled
    bool disabled_by_type = false;
    for (size_t i = 0; i < fSubsystemsDisabledByType.size(); i++)
      if (subsys_type == fSubsystemsDisabledByType.at(i))
        disabled_by_type = true;
    if (disabled_by_type) {
      QwWarning << "Subsystem of type " << subsys_type << " disabled." << QwLog::endl;
      continue;
    }
 
    // If subsystem name is explicitly disabled
    bool disabled_by_name = false;
    for (size_t i = 0; i < fSubsystemsDisabledByName.size(); i++)
      if (subsys_name == fSubsystemsDisabledByName.at(i))
        disabled_by_name = true;
    if (disabled_by_name) {
      QwWarning << "Subsystem with name " << subsys_name << " disabled." << QwLog::endl;
      continue;
    }
 
    // Create subsystem
    QwMessage << "Creating subsystem of type " << subsys_type << " "
              << "with name " << subsys_name << "." << QwLog::endl;
    VQwSubsystem* subsys = 0;
    try {
      subsys =
        VQwSubsystemFactory::Create(subsys_type, subsys_name);
    } catch (QwException_TypeUnknown&) {
      QwError << "No support for subsystems of type " << subsys_type << "." << QwLog::endl;
      // Fall-through to next error for more the psychological effect of many warnings
    }
    if (! subsys) {
      QwError << "Could not create subsystem " << subsys_type << "." << QwLog::endl;
      continue;
    }
 
    // If this subsystem cannot be stored in this array
    if (! fnCanContain(subsys)) {
      QwMessage << "Subsystem " << subsys_name << " cannot be stored in this "
                << "subsystem array." << QwLog::endl;
      QwMessage << "Deleting subsystem " << subsys_name << " again" << QwLog::endl;
      delete subsys; subsys = 0;
      continue;
    }
 
    // Pass detector maps
    subsys->LoadDetectorMaps(*section);
    // Add to array
    this->push_back(subsys);
 
    // Instruct the subsystem to publish variables
    if (subsys->PublishInternalValues() == kFALSE) {
      QwError << "Not all variables for " << subsys->GetName()
              << " could be published!" << QwLog::endl;
    }
  }
}

References QwLog::endl(), fnCanContain, fSubsystemsDisabledByName, fSubsystemsDisabledByType, VQwSubsystem::GetName(), VQwSubsystem::LoadDetectorMaps(), VQwSubsystem::PublishInternalValues(), push_back(), QwError, QwMessage, QwVerbose, QwWarning, QwParameterFile::ReadNextSection(), and QwParameterFile::ReadSectionPreamble().

Referenced by QwSubsystemArray().

Here is the call graph for this function:

Here is the caller graph for this function:

operator=()

QwSubsystemArray & QwSubsystemArray::operator=

(

const QwSubsystemArray &

source

)

Assignment operator.

Assignment operator

Parameters

source

Subsystem array to assign to this array

Returns

This subsystem array after assignment

Definition at line 122 of file QwSubsystemArray.cc.

{
  this->fCodaEventNumber = source.fCodaEventNumber;
  this->fCodaEventType   = source.fCodaEventType;
  if (!source.empty()){
    if (this->size() == source.size()){
      ResolvePairing(source, "QwSubsystemArray::operator=");
      for(size_t i=0;i<source.size();i++){
        if (!fResolvedPairCompatible[i]) continue;
        *(fResolvedSelf[i]) = fResolvedPeerSlots[i];
      }
    } else {
      //  Array sizes don't match
    }
  } else {
    //  The source is empty
  }
  return *this;
}

References fCodaEventNumber, fCodaEventType, fResolvedPairCompatible, fResolvedPeerSlots, fResolvedSelf, QwSubsystemArray(), and ResolvePairing().

Referenced by QwSubsystemArrayParity::operator=().

Here is the call graph for this function:

Here is the caller graph for this function:

PrintInfo()

void QwSubsystemArray::PrintInfo

(

)

const

Print some information about the subsystem.

Definition at line 575 of file QwSubsystemArray.cc.

{
  if (!empty()) {
    for (const_iterator subsys = begin(); subsys != end(); ++subsys) {
      (*subsys)->PrintInfo();
    }
  }
}

PrintParamFileList()

void QwSubsystemArray::PrintParamFileList

(

)

const

Print list of parameter files.

Definition at line 797 of file QwSubsystemArray.cc.

{
  if (not empty()) {
    for (const_iterator subsys = begin(); subsys != end(); ++subsys)
      {
        (*subsys)->PrintDetectorMaps(true);
      }
  }
}

Referenced by main().

Here is the caller graph for this function:

ProcessConfigurationBuffer()

Int_t QwSubsystemArray::ProcessConfigurationBuffer	(	const ROCID_t	roc_id,
		const BankID_t	bank_id,
		UInt_t *	buffer,
		UInt_t	num_words )

Process the event buffer for configuration events.

Definition at line 408 of file QwSubsystemArray.cc.

{
  if (!empty())
    for (iterator subsys = begin(); subsys != end(); ++subsys){
      (*subsys)->ProcessConfigurationBuffer(roc_id, bank_id, buffer, num_words);
    }
  return 0;
}

Referenced by QwEventBuffer::FillSubsystemConfigurationData().

Here is the caller graph for this function:

ProcessEvBuffer()

Int_t QwSubsystemArray::ProcessEvBuffer	(	const UInt_t	event_type,
		const ROCID_t	roc_id,
		const BankID_t	bank_id,
		UInt_t *	buffer,
		UInt_t	num_words )

Process the event buffer for events.

Definition at line 437 of file QwSubsystemArray.cc.

{
  if (!empty()) {
    SetDataLoaded(kTRUE);
    for (iterator subsys = begin(); subsys != end(); ++subsys) {
      (*subsys)->ProcessEvBuffer(event_type, roc_id, bank_id, buffer, num_words);
    }
  }
  return 0;
}

References SetDataLoaded().

Referenced by QwEventBuffer::FillSubsystemData().

Here is the call graph for this function:

Here is the caller graph for this function:

ProcessEvent()

void QwSubsystemArray::ProcessEvent

(

)

Process the decoded data in this event.

Definition at line 454 of file QwSubsystemArray.cc.

{
  if (!empty() && HasDataLoaded()) {
    std::for_each(begin(), end(), boost::mem_fn(&VQwSubsystem::ProcessEvent));
    std::for_each(begin(), end(), boost::mem_fn(&VQwSubsystem::ExchangeProcessedData));
    std::for_each(begin(), end(), boost::mem_fn(&VQwSubsystem::ProcessEvent_2));
  }
}

References VQwSubsystem::ExchangeProcessedData(), HasDataLoaded(), VQwSubsystem::ProcessEvent(), and VQwSubsystem::ProcessEvent_2().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

ProcessOptions()

void QwSubsystemArray::ProcessOptions ( QwOptions & options )

inline

Process configuration options (default behavior)

Definition at line 118 of file QwSubsystemArray.h.

{ ProcessOptionsSubsystems(options); };

References ProcessOptionsSubsystems().

Referenced by main(), and main().

Here is the call graph for this function:

Here is the caller graph for this function:

ProcessOptionsSubsystems()

void QwSubsystemArray::ProcessOptionsSubsystems

(

QwOptions &

options

)

Process configuration options for all subsystems in the array.

Handle configuration options for all subsystems in the array

Parameters

options

Options

Definition at line 314 of file QwSubsystemArray.cc.

{
  LoadAllEventRanges(options);
 
  for (iterator subsys_iter = begin(); subsys_iter != end(); ++subsys_iter) {
    VQwSubsystem* subsys = dynamic_cast<VQwSubsystem*>(subsys_iter->get());
    subsys->ProcessOptions(options);
  }
}

References LoadAllEventRanges(), and VQwSubsystem::ProcessOptions().

Referenced by ProcessOptions().

Here is the call graph for this function:

Here is the caller graph for this function:

ProcessOptionsToplevel()

void QwSubsystemArray::ProcessOptionsToplevel

(

QwOptions &

options

)

Process configuration options for the subsystem array itself.

Handle configuration options for the subsystem array itself

Parameters

options

Options

Definition at line 299 of file QwSubsystemArray.cc.

{
  // Filename to use for subsystem creation (single filename could be expanded
  // to a list)
  fSubsystemsMapFile = options.GetValue<std::string>("detectors");
  // Subsystems to disable
  fSubsystemsDisabledByName = options.GetValueVector<std::string>("disable-by-name");
  fSubsystemsDisabledByType = options.GetValueVector<std::string>("disable-by-type");
}

References fSubsystemsDisabledByName, fSubsystemsDisabledByType, fSubsystemsMapFile, QwOptions::GetValue(), and QwOptions::GetValueVector().

Referenced by QwSubsystemArray().

Here is the call graph for this function:

Here is the caller graph for this function:

push_back() [1/2]

void QwSubsystemArray::push_back

(

std::shared_ptr< VQwSubsystem >

subsys

)

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

Parameters

subsys

Subsystem to add to the array

Definition at line 842 of file QwSubsystemArray.cc.

{
 
 if (subsys.get() == NULL) {
   QwError << "QwSubsystemArray::push_back(): NULL subsys"
           << QwLog::endl;
   //  This is an empty subsystem...
   //  Do nothing for now.
 
 } else if (!this->empty() && GetSubsystemByName(subsys->GetName())){
   //  There is already a subsystem with this name!
   QwError << "QwSubsystemArray::push_back(): subsys " << subsys->GetName()
           << " already exists" << QwLog::endl;
 
 } else if (!fnCanContain(subsys.get())) {
   //  There is no support for this type of subsystem
   QwError << "QwSubsystemArray::push_back(): subsys " << subsys->GetName()
           << " is not supported by this subsystem array" << QwLog::endl;
 
 } else {
   std::shared_ptr<VQwSubsystem> subsys_tmp(subsys);
   SubsysPtrs::push_back(subsys_tmp);
   InvalidateResolvedDispatchCache();
 
   // Set the parent of the subsystem to this array
   subsys_tmp->SetParent(this);
 
   // Update the event type mask
   // Note: Active bits in the mask indicate event types that are accepted
   fEventTypeMask |= subsys_tmp->GetEventTypeMask();
 
   // Instruct the subsystem to publish variables
   if (subsys_tmp->PublishInternalValues() == kFALSE) {
     QwError << "Not all variables for " << subsys_tmp->GetName()
             << " could be published!" << QwLog::endl;
   }
 }
}

References QwLog::endl(), fEventTypeMask, fnCanContain, GetSubsystemByName(), InvalidateResolvedDispatchCache(), and QwError.

Here is the call graph for this function:

push_back() [2/2]

void QwSubsystemArray::push_back

(

VQwSubsystem *

subsys

)

Add the subsystem to this array.

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

Parameters

subsys

Subsystem to add to the array

Definition at line 237 of file QwSubsystemArray.cc.

{
  if (subsys == NULL) {
    QwError << "QwSubsystemArray::push_back(): NULL subsys"
            << QwLog::endl;
    //  This is an empty subsystem...
    //  Do nothing for now.
 
  } else if (!this->empty() && GetSubsystemByName(subsys->GetName())){
    //  There is already a subsystem with this name!
    QwError << "QwSubsystemArray::push_back(): subsys " << subsys->GetName()
            << " already exists" << QwLog::endl;
 
  } else if (!fnCanContain(subsys)) {
    //  There is no support for this type of subsystem
    QwError << "QwSubsystemArray::push_back(): subsys " << subsys->GetName()
            << " is not supported by this subsystem array" << QwLog::endl;
 
  } else {
    std::shared_ptr<VQwSubsystem> subsys_tmp(subsys);
    SubsysPtrs::push_back(subsys_tmp);
    InvalidateResolvedDispatchCache();
 
    // Set the parent of the subsystem to this array
    subsys_tmp->SetParent(this);
 
    // Update the event type mask
    // Note: Active bits in the mask indicate event types that are accepted
    fEventTypeMask |= subsys_tmp->GetEventTypeMask();
  }
}

References QwLog::endl(), fEventTypeMask, fnCanContain, VQwSubsystem::GetName(), GetSubsystemByName(), InvalidateResolvedDispatchCache(), and QwError.

Referenced by LoadSubsystemsFromParameterFile().

Here is the call graph for this function:

Here is the caller graph for this function:

RandomizeEventData()

void QwSubsystemArray::RandomizeEventData	(	int	helicity = 0,
		double	time = 0.0 )

Randomize the data in this event.

Definition at line 472 of file QwSubsystemArray.cc.

{
  if (!empty())
    for (iterator subsys = begin(); subsys != end(); ++subsys) {
      (*subsys)->RandomizeEventData(helicity, time);
    }
}

Referenced by main().

Here is the caller graph for this function:

ResolvePairing()

void QwSubsystemArray::ResolvePairing ( const QwSubsystemArray & source, const char * context ) const

protected

Definition at line 85 of file QwSubsystemArray.cc.

{
  BuildResolvedSelf();
  const Bool_t cache_valid =
      (fResolvedPeer == &source)
      && (fResolvedPeerSlots.size() == source.size())
      && (fResolvedPairCompatible.size() == source.size());
  if (cache_valid) return;
 
  fResolvedPeer = &source;
  fResolvedPeerSlots.assign(source.size(), nullptr);
  fResolvedPairCompatible.assign(source.size(), kFALSE);
  if (this->size() != source.size()) return;
 
  for (size_t i = 0; i < source.size(); ++i) {
    VQwSubsystem* ptr1 = fResolvedSelf[i];
    VQwSubsystem* ptr2 = source.at(i).get();
    fResolvedPeerSlots[i] = ptr2;
    if (ptr1 == nullptr || ptr2 == nullptr) continue;
 
    if (typeid(*ptr1) == typeid(*ptr2)) {
      fResolvedPairCompatible[i] = kTRUE;
    } else {
      QwError << context << " types do not match at slot " << i << QwLog::endl;
      QwError << " typeid(*ptr1)=" << typeid(*ptr1).name()
              << " but typeid(*ptr2)=" << typeid(*ptr2).name()
              << QwLog::endl;
    }
  }
}

References BuildResolvedSelf(), QwLog::endl(), fResolvedPairCompatible, fResolvedPeer, fResolvedPeerSlots, fResolvedSelf, QwError, and QwSubsystemArray().

Referenced by operator=().

Here is the call graph for this function:

Here is the caller graph for this function:

SetCodaEventNumber()

void QwSubsystemArray::SetCodaEventNumber ( UInt_t evtnum )

inline

Set the internal record of the CODA event number.

Definition at line 80 of file QwSubsystemArray.h.

{ fCodaEventNumber = evtnum; };

References fCodaEventNumber.

Referenced by ClearEventData(), and QwEventBuffer::FillSubsystemData().

Here is the caller graph for this function:

SetCodaEventType()

void QwSubsystemArray::SetCodaEventType ( UInt_t evttype )

inline

Set the internal record of the CODA event type.

Definition at line 82 of file QwSubsystemArray.h.

{ fCodaEventType = evttype; };

References fCodaEventType.

Referenced by ClearEventData(), and QwEventBuffer::FillSubsystemData().

Here is the caller graph for this function:

SetCodaRunNumber()

void QwSubsystemArray::SetCodaRunNumber ( UInt_t runnum )

inline

Set the internal record of the CODA run number.

Definition at line 76 of file QwSubsystemArray.h.

{ fCodaRunNumber = runnum; };

References fCodaRunNumber.

Referenced by QwEventBuffer::FillSubsystemData().

Here is the caller graph for this function:

SetCodaSegmentNumber()

void QwSubsystemArray::SetCodaSegmentNumber ( UInt_t segnum )

inline

Set the internal record of the CODA segment number.

Definition at line 78 of file QwSubsystemArray.h.

{ fCodaSegmentNumber = segnum; };

References fCodaSegmentNumber.

Referenced by QwEventBuffer::FillSubsystemData().

Here is the caller graph for this function:

SetDataLoaded()

void QwSubsystemArray::SetDataLoaded ( const Bool_t flag )

inline

Set data loaded flag.

Definition at line 107 of file QwSubsystemArray.h.

{ fHasDataLoaded = flag; };

References fHasDataLoaded.

Referenced by ClearEventData(), and ProcessEvBuffer().

Here is the caller graph for this function:

SetEventTypeMask()

void QwSubsystemArray::SetEventTypeMask ( const UInt_t mask )

inline

Set event type mask.

Definition at line 93 of file QwSubsystemArray.h.

{ fEventTypeMask = mask; };

References fEventTypeMask.

ShareHistograms()

void QwSubsystemArray::ShareHistograms

(

const QwSubsystemArray &

source

)

Share the histograms with another subsystem.

Definition at line 529 of file QwSubsystemArray.cc.

{
  if (!empty() && !source.empty()) {
    if (this->size() == source.size()) {
      for (size_t i = 0; i < source.size(); ++i) {
        this->at(i)->ShareHistograms(source.at(i).get());
      }
    }
  }
}

References QwSubsystemArray().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

UpdateEventTypeMask()

UInt_t QwSubsystemArray::UpdateEventTypeMask ( )

inline

Update the event type mask from the subsystems.

Definition at line 97 of file QwSubsystemArray.h.

                               {
    for (iterator subsys_iter = begin(); subsys_iter != end(); ++subsys_iter) {
      VQwSubsystem* subsys = dynamic_cast<VQwSubsystem*>(subsys_iter->get());
      fEventTypeMask |= subsys->GetEventTypeMask();
    }
    return fEventTypeMask;
  };

References fEventTypeMask, and VQwSubsystem::GetEventTypeMask().

Here is the call graph for this function:

Field Documentation

fBadEventRange

std::vector< std::pair<UInt_t,UInt_t> > QwSubsystemArray::fBadEventRange

protected

Definition at line 289 of file QwSubsystemArray.h.

Referenced by QwSubsystemArrayParity::CheckBadEventRange(), and LoadAllEventRanges().

fCodaEventNumber

UInt_t QwSubsystemArray::fCodaEventNumber

protected

CODA event number as provided by QwEventBuffer.

Definition at line 270 of file QwSubsystemArray.h.

Referenced by QwSubsystemArrayParity::AccumulateRunningSum(), QwSubsystemArrayParity::CheckBadEventRange(), ConstructBranch(), ConstructBranch(), GetCodaEventNumber(), QwSubsystemArrayParity::operator+=(), QwSubsystemArrayParity::operator-=(), operator=(), QwSubsystemArray(), and SetCodaEventNumber().

fCodaEventType

UInt_t QwSubsystemArray::fCodaEventType

protected

CODA event type as provided by QwEventBuffer.

Definition at line 271 of file QwSubsystemArray.h.

Referenced by ConstructBranch(), ConstructBranch(), GetCodaEventType(), operator=(), QwSubsystemArray(), and SetCodaEventType().

fCodaRunNumber

UInt_t QwSubsystemArray::fCodaRunNumber

protected

Index of this data element in root tree.

CODA run number as provided by QwEventBuffer

Definition at line 268 of file QwSubsystemArray.h.

Referenced by GetCodaRunNumber(), QwSubsystemArray(), and SetCodaRunNumber().

fCodaSegmentNumber

UInt_t QwSubsystemArray::fCodaSegmentNumber

protected

CODA segment number as provided by QwEventBuffer.

Definition at line 269 of file QwSubsystemArray.h.

Referenced by GetCodaSegmentNumber(), QwSubsystemArray(), and SetCodaSegmentNumber().

fEventTypeMask

UInt_t QwSubsystemArray::fEventTypeMask

protected

Mask of event types.

Definition at line 273 of file QwSubsystemArray.h.

Referenced by GetEventTypeMask(), push_back(), push_back(), QwSubsystemArray(), QwSubsystemArray(), SetEventTypeMask(), and UpdateEventTypeMask().

fHasDataLoaded

Bool_t QwSubsystemArray::fHasDataLoaded

protected

Has this array gotten data to be processed?

Definition at line 274 of file QwSubsystemArray.h.

Referenced by HasDataLoaded(), QwSubsystemArray(), and SetDataLoaded().

fnCanContain

CanContainFn QwSubsystemArray::fnCanContain

protected

Function to determine which subsystems we can accept.

Definition at line 278 of file QwSubsystemArray.h.

Referenced by LoadSubsystemsFromParameterFile(), push_back(), push_back(), QwSubsystemArray(), and QwSubsystemArray().

fResolvedPairCompatible

std::vector<Bool_t> QwSubsystemArray::fResolvedPairCompatible

mutableprotected

Definition at line 296 of file QwSubsystemArray.h.

Referenced by BuildResolvedSelf(), InvalidateResolvedDispatchCache(), operator=(), and ResolvePairing().

fResolvedPeer

const QwSubsystemArray* QwSubsystemArray::fResolvedPeer = nullptr

mutableprotected

Definition at line 294 of file QwSubsystemArray.h.

Referenced by BuildResolvedSelf(), InvalidateResolvedDispatchCache(), and ResolvePairing().

fResolvedPeerSlots

std::vector<VQwSubsystem*> QwSubsystemArray::fResolvedPeerSlots

mutableprotected

Definition at line 295 of file QwSubsystemArray.h.

Referenced by BuildResolvedSelf(), InvalidateResolvedDispatchCache(), operator=(), and ResolvePairing().

fResolvedSelf

std::vector<VQwSubsystem*> QwSubsystemArray::fResolvedSelf

mutableprotected

Definition at line 293 of file QwSubsystemArray.h.

Referenced by BuildResolvedSelf(), InvalidateResolvedDispatchCache(), operator=(), and ResolvePairing().

fSubsystemsDisabledByName

std::vector<std::string> QwSubsystemArray::fSubsystemsDisabledByName

private

List of disabled types.

Definition at line 305 of file QwSubsystemArray.h.

Referenced by LoadSubsystemsFromParameterFile(), ProcessOptionsToplevel(), and QwSubsystemArray().

fSubsystemsDisabledByType

std::vector<std::string> QwSubsystemArray::fSubsystemsDisabledByType

private

List of disabled names.

Definition at line 306 of file QwSubsystemArray.h.

Referenced by LoadSubsystemsFromParameterFile(), ProcessOptionsToplevel(), and QwSubsystemArray().

fSubsystemsMapFile

std::string QwSubsystemArray::fSubsystemsMapFile

private

Filename of the global detector map.

Definition at line 304 of file QwSubsystemArray.h.

Referenced by ProcessOptionsToplevel(), QwSubsystemArray(), and QwSubsystemArray().

fTreeArrayIndex

size_t QwSubsystemArray::fTreeArrayIndex

protected

Definition at line 265 of file QwSubsystemArray.h.

Referenced by ConstructBranchAndVector(), FillTreeVector(), and QwSubsystemArray().

fWindowPeriod

double QwSubsystemArray::fWindowPeriod

protected

Definition at line 319 of file QwSubsystemArray.h.

Referenced by GetWindowPeriod(), and QwSubsystemArrayParity::LoadMockDataParameters().

---

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

• QwSubsystemArray.h
• QwSubsystemArray.cc