QwEventBuffer Class Reference

Event buffer management for reading and processing CODA data. More...

#include <QwEventBuffer.h>

Collaboration diagram for QwEventBuffer:

Public Member Functions
	QwEventBuffer ()
	Default constructor.
virtual	~QwEventBuffer ()
void	ProcessOptions (QwOptions &options)
	Sets internal flags based on the QwOptions.
void	PrintRunTimes ()
TString	GetRunLabel () const
	Returns a string like <run#> or <run#>.<file#>
Bool_t	AreRunletsSplit () const
	Return true if file segments are being separated for.
Int_t	GetRunNumber () const
	Return CODA file run number.
Int_t	GetSegmentNumber () const
	Return CODA file segment number.
std::pair< UInt_t, UInt_t >	GetEventRange () const
Int_t	OpenNextStream ()
	Opens the event stream (file or ET) based on the internal flags.
Int_t	CloseStream ()
	Closes a currently open event stream.
void	SetDataDirectory (const TString datadir)
const TString &	GetDataFile () const
const TString &	GetDataDirectory () const
Int_t	ReOpenStream ()
Int_t	OpenDataFile (UInt_t current_run, Short_t seg)
Int_t	OpenDataFile (UInt_t current_run, const TString rw="R")
Int_t	OpenDataFile (const TString filename, const TString rw="R")
Int_t	CloseDataFile ()
Int_t	OpenETStream (TString computer, TString session, int mode, const TString stationname="")
Int_t	CloseETStream ()
Bool_t	IsPhysicsEvent ()
Int_t	GetPhysicsEventNumber ()
Int_t	GetEventNumber ()
Bool_t	GetNextEventRange ()
	Read the next requested event range, return true if success.
Bool_t	GetNextRunRange ()
	Read the next requested run range, return true if success.
Bool_t	GetNextRunNumber ()
	Get the next run in the active run range, proceed to next range if needed.
void	VerifyCodaVersion (const UInt_t *buffer)
Int_t	GetNextEvent ()
Int_t	GetEvent ()
Int_t	WriteEvent (int *buffer)
Bool_t	IsOnline ()
Bool_t	IsROCConfigurationEvent ()
Bool_t	IsEPICSEvent ()
Bool_t	FillSubsystemConfigurationData (QwSubsystemArray &subsystems)
Bool_t	FillSubsystemData (QwSubsystemArray &subsystems)
Bool_t	FillEPICSData (QwEPICSEvent &epics)
template<class T>
Bool_t	FillObjectWithEventData (T &t)
void	ResetControlParameters ()
void	ReportRunSummary ()
Int_t	EncodeSubsystemData (QwSubsystemArray &subsystems)
Int_t	EncodePrestartEvent (int runnumber, int runtype=0)
Int_t	EncodeGoEvent ()
Int_t	EncodePauseEvent ()
Int_t	EncodeEndEvent ()
TString	GetStartSQLTime ()
TString	GetEndSQLTime ()
time_t	GetStartUnixTime ()
time_t	GetEndUnixTime ()
void	ResetFlags ()

Static Public Member Functions
static void	DefineOptions (QwOptions &options)
static void	SetDefaultDataDirectory (const std::string &dir)
static void	SetDefaultDataFileStem (const std::string &stem)
static void	SetDefaultDataFileExtension (const std::string &extension)

Static Public Attributes
static const Int_t	kRunNotSegmented = -20
static const Int_t	kNoNextDataFile = -30
static const Int_t	kFileHandleNotConfigured = -40
static const UInt_t	kNullDataWord = 0x4e554c4c

Protected Types
enum	CodaStreamMode { fEvStreamNull , fEvStreamFile , fEvStreamET }
typedef ULong64_t	RocBankLabel_t
	Methods and data members needed to find marker words.

Protected Member Functions
Int_t	GetFileEvent ()
Int_t	GetEtEvent ()
Int_t	WriteFileEvent (int *buffer)
Int_t	WriteEtEvent (int *buffer)
Bool_t	DataFileIsSegmented ()
Int_t	CloseThisSegment ()
Int_t	OpenNextSegment ()
const TString &	DataFile (const UInt_t run, const Short_t seg)
std::size_t	CheckForMarkerWords (QwSubsystemArray &subsystems)
UInt_t	FindMarkerWord (UInt_t markerID, UInt_t *buffer, UInt_t num_words)
UInt_t	GetMarkerWord (UInt_t markerID)

Protected Attributes
Bool_t	fOnline
TString	fETHostname
TString	fETSession
TString	fETStationName
Int_t	fETWaitMode
Bool_t	fExitOnEnd
Bool_t	fEventRateLimitEnabled {false}
Double_t	fMaxEventRate {0.0}
std::chrono::duration< double >	fMinEventInterval
std::chrono::duration< double >	fAccumulatedDelay {0.0}
std::chrono::steady_clock::time_point	fLastEventTime
Bool_t	fChainDataFiles
std::pair< Int_t, Int_t >	fRunRange
std::string	fRunListFileName
std::unique_ptr< QwParameterFile >	fRunListFile
std::vector< Int_t >	fRunRangeMinList
std::vector< Int_t >	fRunRangeMaxList
std::pair< UInt_t, UInt_t >	fEventRange
std::string	fEventListFileName
std::unique_ptr< QwParameterFile >	fEventListFile
std::vector< UInt_t >	fEventList
std::pair< Int_t, Int_t >	fSegmentRange
TString	fDataFileStem
TString	fDataFileExtension
TString	fDataDirectory
TString	fDataFile
enum QwEventBuffer::CodaStreamMode	fEvStreamMode
THaCodaData *	fEvStream
Int_t	fCurrentRun
Bool_t	fRunIsSegmented
std::vector< Int_t >	fRunSegments
std::vector< Int_t >::iterator	fRunSegmentIterator
Double_t	fCleanParameter [3]
	Scan data/clean data from the green monster.
TStopwatch	fRunTimer
	Timer used for runlet processing loop.
TStopwatch	fStopwatch
	Timer used for internal timing.
std::unordered_map< RocBankLabel_t, std::vector< UInt_t > >	fMarkerList
std::unordered_map< RocBankLabel_t, std::vector< UInt_t > >	fOffsetList
RocBankLabel_t	fThisRocBankLabel
UInt_t	fNumPhysicsEvents
UInt_t	fStartingPhysicsEvent
Bool_t	fSingleFile
VEventDecoder *	decoder

Static Protected Attributes
static std::string	fDefaultDataDirectory = "/adaq1/data1/apar"
static std::string	fDefaultDataFileStem = "QwRun_"
static std::string	fDefaultDataFileExtension = "log"

Private Member Functions
void	ClearEventData (std::vector< VQwSubsystem * > &subsystems)
Bool_t	FillSubsystemConfigurationData (std::vector< VQwSubsystem * > &subsystems)
Bool_t	FillSubsystemData (std::vector< VQwSubsystem * > &subsystems)

Private Attributes
Int_t	fDataVersionVerify = 0
Int_t	fDataVersion

Detailed Description

Event buffer management for reading and processing CODA data.

Manages the reading of CODA event data files, including support for segmented files, run lists, and event stream processing. Handles event decoding via pluggable decoder classes and provides iteration over events and runs.

Definition at line 47 of file QwEventBuffer.h.

Member Typedef Documentation

RocBankLabel_t

typedef ULong64_t QwEventBuffer::RocBankLabel_t

protected

Methods and data members needed to find marker words.

Definition at line 276 of file QwEventBuffer.h.

Member Enumeration Documentation

CodaStreamMode

enum QwEventBuffer::CodaStreamMode

protected

Enumerator
fEvStreamNull
fEvStreamFile
fEvStreamET

Definition at line 255 of file QwEventBuffer.h.

{fEvStreamNull, fEvStreamFile, fEvStreamET} fEvStreamMode;

Constructor & Destructor Documentation

QwEventBuffer()

QwEventBuffer::QwEventBuffer

(

)

Default constructor.

Definition at line 56 of file QwEventBuffer.cc.

  :    fRunListFile(nullptr),
       fEventListFile(nullptr),
       fDataFileStem(fDefaultDataFileStem),
       fDataFileExtension(fDefaultDataFileExtension),
       fDataDirectory(fDefaultDataDirectory),
       fEvStreamMode(fEvStreamNull),
       fEvStream(NULL),
       fCurrentRun(-1),
       fNumPhysicsEvents(0),
       fSingleFile(kFALSE),
             decoder(NULL)
{
  //  Set up the signal handler.
  globalEXIT=0;
  signal(SIGINT,  sigint_handler);// ctrl+c
  signal(SIGTERM, sigint_handler);// kill in shell // 15
  //  signal(SIGTSTP, sigint_handler);// ctrl+z // 20
  onlineRestart=0;
  signal(SIGUSR1, sigusr_handler);
 
  fCleanParameter[0] = 0.0;
  fCleanParameter[1] = 0.0;
  fCleanParameter[2] = 0.0;
}

References decoder, fCleanParameter, fCurrentRun, fDataDirectory, fDataFileExtension, fDataFileStem, fDefaultDataDirectory, fDefaultDataFileExtension, fDefaultDataFileStem, fEventListFile, fEvStream, fEvStreamMode, fEvStreamNull, fNumPhysicsEvents, fRunListFile, fSingleFile, globalEXIT, onlineRestart, sigint_handler(), and sigusr_handler().

Here is the call graph for this function:

~QwEventBuffer()

virtual QwEventBuffer::~QwEventBuffer ( )

inlinevirtual

Definition at line 71 of file QwEventBuffer.h.

                           {
    // Delete event stream
    if (fEvStream != NULL) {
      delete fEvStream;
      fEvStream = NULL;
    }
      // Delete Decoder
      if(decoder != NULL) {
            delete decoder;
            decoder = NULL;
      }
  };

References decoder, and fEvStream.

Member Function Documentation

AreRunletsSplit()

Bool_t QwEventBuffer::AreRunletsSplit ( ) const

inline

Return true if file segments are being separated for.

Definition at line 93 of file QwEventBuffer.h.

                                   {
    return (fRunIsSegmented && !fChainDataFiles);
  };

References fChainDataFiles, and fRunIsSegmented.

CheckForMarkerWords()

std::size_t QwEventBuffer::CheckForMarkerWords ( QwSubsystemArray & subsystems )

protected

Definition at line 1313 of file QwEventBuffer.cc.

{
  QwDebug << "QwEventBuffer::GetMarkerWordList:  start function" <<QwLog::endl;
  fThisRocBankLabel = decoder->GetROC();
  fThisRocBankLabel = fThisRocBankLabel<<32;
  fThisRocBankLabel += decoder->GetSubbankTag();
  if (fMarkerList.count(fThisRocBankLabel)==0){
    std::vector<UInt_t> tmpvec;
    subsystems.GetMarkerWordList(decoder->GetROC(), decoder->GetSubbankTag(), tmpvec);
    fMarkerList.emplace(fThisRocBankLabel, tmpvec);
    fOffsetList.emplace(fThisRocBankLabel, std::vector<UInt_t>(tmpvec.size(),0));
  }
  QwDebug << "QwEventBuffer::GetMarkerWordList:  fMarkerList.count(fThisRocBankLabel)=="
      << fMarkerList.count(fThisRocBankLabel)
      << " fMarkerList.at(fThisRocBankLabel).size()=="
      << fMarkerList.at(fThisRocBankLabel).size()
      << QwLog::endl;
  return fMarkerList.at(fThisRocBankLabel).size();
}

References decoder, QwLog::endl(), fMarkerList, fOffsetList, fThisRocBankLabel, QwSubsystemArray::GetMarkerWordList(), and QwDebug.

Referenced by FillSubsystemData().

Here is the call graph for this function:

Here is the caller graph for this function:

ClearEventData()

void QwEventBuffer::ClearEventData ( std::vector< VQwSubsystem * > & subsystems )

private

CloseDataFile()

Int_t QwEventBuffer::CloseDataFile

(

)

Definition at line 1275 of file QwEventBuffer.cc.

{
  Int_t status = kFileHandleNotConfigured;
  if (fEvStreamMode==fEvStreamFile){
    status = fEvStream->codaClose();
  }
  return status;
}

References fEvStream, fEvStreamFile, fEvStreamMode, and kFileHandleNotConfigured.

Referenced by CloseStream(), CloseThisSegment(), and main().

Here is the caller graph for this function:

CloseETStream()

Int_t QwEventBuffer::CloseETStream

(

)

Definition at line 1303 of file QwEventBuffer.cc.

{
  Int_t status = kFileHandleNotConfigured;
  if (fEvStreamMode==fEvStreamET){
    status = fEvStream->codaClose();
  }
  return status;
}

References fEvStream, fEvStreamET, fEvStreamMode, and kFileHandleNotConfigured.

Referenced by CloseStream().

Here is the caller graph for this function:

CloseStream()

Int_t QwEventBuffer::CloseStream

(

)

Closes a currently open event stream.

Definition at line 428 of file QwEventBuffer.cc.

{
  //  Stop the timers.
  fRunTimer.Stop();
  fStopwatch.Stop();
  QwWarning << "Starting CloseStream."
        << QwLog::endl;
  Int_t status = kFileHandleNotConfigured;
  if (fEvStreamMode==fEvStreamFile
      && (fRunIsSegmented && !fChainDataFiles) ){
    //  The run is segmented and we are not chaining the
    //  segments together in the event loop, so close
    //  the current segment.
    status = CloseThisSegment();
  } else if (fEvStreamMode==fEvStreamFile) {
    status = CloseDataFile();
  } else if (fEvStreamMode==fEvStreamFile){
    status = CloseETStream();
  }
  return status;
}

References CloseDataFile(), CloseETStream(), CloseThisSegment(), QwLog::endl(), fChainDataFiles, fEvStreamFile, fEvStreamMode, fRunIsSegmented, fRunTimer, fStopwatch, kFileHandleNotConfigured, and QwWarning.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

CloseThisSegment()

Int_t QwEventBuffer::CloseThisSegment ( )

protected

Definition at line 1135 of file QwEventBuffer.cc.

{
  Int_t status = kFileHandleNotConfigured;
  Int_t last_runsegment;
  if (fRunIsSegmented){
    last_runsegment = *fRunSegmentIterator;
    fRunSegmentIterator++;
    if (fRunSegmentIterator <= fRunSegments.end()){
      QwMessage << "Closing run segment " << last_runsegment <<"."
        << QwLog::endl;
      status = CloseDataFile();
    }
  } else {
    //  Don't try to close a nonsegmented file; we will explicitly
    //  use CloseDataFile() later.
  }
  return status;
}

References CloseDataFile(), QwLog::endl(), fRunIsSegmented, fRunSegmentIterator, fRunSegments, kFileHandleNotConfigured, and QwMessage.

Referenced by CloseStream(), and GetFileEvent().

Here is the call graph for this function:

Here is the caller graph for this function:

DataFile()

const TString & QwEventBuffer::DataFile ( const UInt_t run, const Short_t seg = -1 )

protected

Definition at line 1016 of file QwEventBuffer.cc.

{
  if(!fSingleFile){
    TString basename = fDataFileStem + Form("%u.",run) + fDataFileExtension;
    if(seg == -1){
      fDataFile = fDataDirectory + basename;
    } else {
      fDataFile = fDataDirectory + basename + Form(".%d",seg);
    }
  }
  return fDataFile;
}

References fDataDirectory, fDataFile, fDataFileExtension, fDataFileStem, and fSingleFile.

Referenced by OpenDataFile(), and OpenNextSegment().

Here is the caller graph for this function:

DataFileIsSegmented()

Bool_t QwEventBuffer::DataFileIsSegmented ( )

protected

Definition at line 1030 of file QwEventBuffer.cc.

{
  glob_t globbuf;
 
  TString searchpath;
  TString scanvalue;
  Int_t   local_segment;
 
  std::vector<Int_t> tmp_segments;
  std::vector<Int_t> local_index;
 
  /*  Clear and set up the fRunSegments vector. */
  tmp_segments.clear();
  fRunSegments.clear();
  fRunSegments.resize(0);
  fRunIsSegmented = kFALSE;
 
  searchpath = fDataFile;
  glob(searchpath.Data(), GLOB_ERR, NULL, &globbuf);
 
  if(fSingleFile){
 
    fRunIsSegmented = kFALSE;
 
  } else if (globbuf.gl_pathc == 1){
    /* The base file name exists.                               *
     * Do not look for file segments.                           */
    fRunIsSegmented = kFALSE;
 
  } else {
    /* The base file name does not exist.                       *
     * Look for file segments.                                  */
    QwWarning << "File " << fDataFile << " does not exist!\n"
          << "      Trying to find run segments for run "
          << fCurrentRun << "...  ";
 
    searchpath.Append(".[0-9]*");
    glob(searchpath.Data(), GLOB_ERR, NULL, &globbuf);
 
    if (globbuf.gl_pathc == 0){
      /* There are no file segments and no base file            *
       * Produce and error message and exit.                    */
      QwError << "\n      There are no file segments either!!" << QwLog::endl;
 
      // This could mean a single gzipped file!
      fRunIsSegmented = kFALSE;
 
    } else {
      /* There are file segments.                               *
       * Determine the segment numbers and fill fRunSegments    *
       * to indicate the existing file segments.                */
 
      QwMessage << "OK" << QwLog::endl;
      scanvalue = fDataFile + ".%d";
 
      /*  Get the list of segment numbers in file listing       *
       *  order.                                                */
      for (size_t iloop=0;iloop<globbuf.gl_pathc;++iloop){
        /*  Extract the segment numbers from the file name.     */
        sscanf(globbuf.gl_pathv[iloop], scanvalue.Data(), &local_segment);
        tmp_segments.push_back(local_segment);
      }
      local_index.resize(tmp_segments.size(),0);
      /*  Get the list of segments sorted numerically in        *
       *  increasing order.                                     */
      TMath::Sort(static_cast<int>(tmp_segments.size()),&(tmp_segments[0]),&(local_index[0]),
                  kFALSE);
      /*  Put the segments into numerical order in fRunSegments.  Add  *
       *  only those segments requested (though always add segment 0). */
      QwMessage << "      Found the segment(s): ";
      size_t printed = 0;
      for (size_t iloop=0; iloop<tmp_segments.size(); ++iloop){
        local_segment = tmp_segments[local_index[iloop]];
        if (printed++) QwMessage << ", ";
    QwMessage << local_segment ;
    if (local_segment == 0 ||
        ( fSegmentRange.first <= local_segment &&
          local_segment <= fSegmentRange.second ) ) {
      fRunSegments.push_back(local_segment);
    } else {
      QwMessage << " (skipped)" ;
    }
      }
      QwMessage << "." << QwLog::endl;
      fRunSegmentIterator = fRunSegments.begin();
 
      fRunIsSegmented = kTRUE;
 
      /* If the first requested segment hasn't been found,
     forget everything. */
      if ( local_segment < fSegmentRange.first ) {
    QwError << "First requested run segment "
        << fSegmentRange.first << " not found.\n";
    fRunSegments.pop_back();
    fRunSegmentIterator = fRunSegments.begin();
    fRunIsSegmented = kTRUE; // well, it is true.
      }
    }
  }
  globfree(&globbuf);
  return fRunIsSegmented;
}

References QwLog::endl(), fCurrentRun, fDataFile, fRunIsSegmented, fRunSegmentIterator, fRunSegments, fSegmentRange, fSingleFile, QwError, QwMessage, and QwWarning.

Referenced by OpenDataFile().

Here is the call graph for this function:

Here is the caller graph for this function:

DefineOptions()

void QwEventBuffer::DefineOptions ( QwOptions & options )

static

Defines configuration options for QwEventBuffer class using QwOptions functionality.

Parameters

options

Options object

Definition at line 88 of file QwEventBuffer.cc.

{
  // Define the execution options
  options.AddDefaultOptions()
    ("online", po::value<bool>()->default_bool_value(false),
     "use online data stream");
  options.AddDefaultOptions()
    ("online.RunNumber", po::value<int>()->default_bool_value(0),
     "Effective run number to be used by online system to find the parameter files");
  options.AddDefaultOptions()
    ("run,r", po::value<string>()->default_value("0:0"),
     "run range in format #[:#]");
  options.AddDefaultOptions()
    ("data,d", po::value<string>()->default_value(fDefaultDataDirectory),
     "data directory, also $QW_DATA");
  options.AddDefaultOptions()
    ("runlist", po::value<string>()->default_value(""),
     "run list file name");
  options.AddDefaultOptions()
    ("event,e", po::value<string>()->default_value("0:"),
     "event range in format #[:#]");
  options.AddDefaultOptions()
    ("segment,s", po::value<string>()->default_value("0:"),
     "run segment range in format #[:#]");
  options.AddDefaultOptions()
    ("chainfiles", po::value<bool>()->default_bool_value(false),
     "chain file segments together, do not analyze them separately");
  options.AddDefaultOptions()
    ("codafile-stem", po::value<string>()->default_value(fDefaultDataFileStem),
     "stem of the input CODA filename");
  options.AddDefaultOptions()
    ("codafile-ext", po::value<string>()->default_value(fDefaultDataFileExtension),
     "extension of the input CODA filename");
  options.AddOptions()
    ("directfile", po::value<string>(),
    "Run over single event file");
  //  Special flag to allow sub-bank IDs less than 31
  options.AddDefaultOptions()
    ("allow-low-subbank-ids", po::value<bool>()->default_bool_value(false),
     "allow the sub-bank ids to be 31 or less, when using this flag, all ROCs must be sub-banked");
  //  Options specific to the ET clients
  options.AddOptions("ET system options")
    ("ET.hostname", po::value<string>(),
     "Name of the ET session's host machine --- Only used in online mode\nDefaults to the environment variable $HOSTNAME");
  options.AddOptions("ET system options")
    ("ET.session", po::value<string>(),
     "ET session name --- Only used in online mode\nDefaults to the environment variable $SESSION");
  options.AddOptions("ET system options")
    ("ET.station", po::value<string>(),
     "ET station name --- Only used in online mode");
  options.AddOptions("ET system options")
    ("ET.waitmode", po::value<int>()->default_value(0),
     "ET system wait mode: 0 is wait-forever, 1 is timeout \"quickly\"  --- Only used in online mode");
  options.AddOptions("ET system options")
    ("ET.exit-on-end", po::value<bool>()->default_value(false),
     "Exit the event loop if the end event is found. JAPAN remains open and waits for the next run. --- Only used in online mode");
  options.AddOptions("CodaVersion")
    ("coda-version", po::value<int>()->default_value(3),
     "Sets the Coda Version. Allowed values = {2,3}. \nThis is needed for writing and reading mock data. Mock data needs to be written and read with the same Coda Version.");
  options.AddOptions("Event rate limiting")
    ("max-event-rate", po::value<double>()->default_value(0.0),
     "Maximum event write rate in Hz (0 = disabled, no rate limiting)");
}

References QwOptions::AddDefaultOptions(), QwOptions::AddOptions(), fDefaultDataDirectory, fDefaultDataFileExtension, and fDefaultDataFileStem.

Referenced by QwOptions::DefineOptions().

Here is the call graph for this function:

Here is the caller graph for this function:

EncodeEndEvent()

Int_t QwEventBuffer::EncodeEndEvent

(

)

Definition at line 774 of file QwEventBuffer.cc.

{
  int buffer[5];
  int localtime  = (int)time(0);
  int eventcount = 0;
  decoder->EncodeEndEventHeader(buffer, eventcount, localtime);
  return WriteEvent(buffer);
}

References decoder, and WriteEvent().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

EncodeGoEvent()

Int_t QwEventBuffer::EncodeGoEvent

(

)

Definition at line 758 of file QwEventBuffer.cc.

{
  int buffer[5];
  int localtime  = (int)time(0);
  int eventcount = 0;
  decoder->EncodeGoEventHeader(buffer, eventcount, localtime);
  return WriteEvent(buffer);
}

References decoder, and WriteEvent().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

EncodePauseEvent()

Int_t QwEventBuffer::EncodePauseEvent

(

)

Definition at line 766 of file QwEventBuffer.cc.

{
  int buffer[5];
  int localtime  = (int)time(0);
  int eventcount = 0;
  decoder->EncodePauseEventHeader(buffer, eventcount, localtime);
  return WriteEvent(buffer);
}

References decoder, and WriteEvent().

Here is the call graph for this function:

EncodePrestartEvent()

Int_t QwEventBuffer::EncodePrestartEvent	(	int	runnumber,
		int	runtype = 0 )

Definition at line 751 of file QwEventBuffer.cc.

{
  int buffer[5];
  int localtime  = (int)time(0);
  decoder->EncodePrestartEventHeader(buffer, runnumber, runtype, localtime);
  return WriteEvent(buffer);
}

References decoder, and WriteEvent().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

EncodeSubsystemData()

Int_t QwEventBuffer::EncodeSubsystemData

(

QwSubsystemArray &

subsystems

)

Definition at line 691 of file QwEventBuffer.cc.

{
  // Encode the data in the elements of the subsystem array
  std::vector<UInt_t> buffer;
  std::vector<ROCID_t> ROCList;
  subsystems.EncodeEventData(buffer);
  subsystems.GetROCIDList(ROCList);
  // Add CODA event header
    std::vector<UInt_t> header = decoder->EncodePHYSEventHeader(ROCList);
 
  // Copy the encoded event buffer into an array of integers,
  // as expected by the CODA routines.
  // Size of the event buffer in long words
  int* codabuffer = new int[header.size() + buffer.size() + 1];
  // First entry contains the buffer size
  int k = 0;
  codabuffer[k++] = header.size() + buffer.size();
  for (size_t i = 0; i < header.size(); i++)
    codabuffer[k++] = header.at(i);
  for (size_t i = 0; i < buffer.size(); i++)
    codabuffer[k++] = buffer.at(i);
 
  // Now write the buffer to the stream
  Int_t status = WriteEvent(codabuffer);
  // delete the buffer
  delete[] codabuffer;
  // and report success or fail
  return status;
}

References decoder, QwSubsystemArray::EncodeEventData(), QwSubsystemArray::GetROCIDList(), and WriteEvent().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

FillEPICSData()

Bool_t QwEventBuffer::FillEPICSData

(

QwEPICSEvent &

epics

)

Definition at line 942 of file QwEventBuffer.cc.

{
  // QwVerbose << "QwEventBuffer::FillEPICSData:  "
//    << Form("Length: %d; Tag: 0x%x; Bank ID num: 0x%x; ",
//        fEvtLength, fEvtTag, fIDBankNum)
//    << Form("Evt type: 0x%x; Evt number %d; Evt Class 0x%.8x; ",
//        fEvtType(), fEvtNumber, fEvtClass)
//    << Form("Status Summary: 0x%.8x; Words so far %d",
//        fStatSum, fWordsSoFar)
//    << QwLog::endl;
 
 
  ///
  Bool_t okay = kTRUE;
  if (! IsEPICSEvent()){
    okay = kFALSE;
    return okay;
  }
  QwVerbose << "QwEventBuffer::FillEPICSData:  "
        << QwLog::endl;
  //  Loop through the data buffer in this event.
  UInt_t *localbuff = (UInt_t*)(fEvStream->getEvBuffer());
  if (decoder->GetBankDataType()==0x10){
    while ((okay = decoder->DecodeSubbankHeader(&localbuff[decoder->GetWordsSoFar()]))){
      //  If this bank has further subbanks, restart the loop.
      if (decoder->GetSubbankType() == 0x10) continue;
      //  If this bank only contains the word 'NULL' then skip
      //  this bank.
      if (decoder->GetFragLength()==1 && localbuff[decoder->GetWordsSoFar()]==kNullDataWord){
    decoder->AddWordsSoFarAndFragLength();
    continue;
      }
 
      if (decoder->GetSubbankType() == 0x3){
    //  This is an ASCII string bank.  Try to decode it and
    //  pass it to the EPICS class.
    char* tmpchar = (Char_t*)&localbuff[decoder->GetWordsSoFar()];
 
    epics.ExtractEPICSValues(string(tmpchar), GetEventNumber());
    QwVerbose << "test for GetEventNumber =" << GetEventNumber() << QwLog::endl;// always zero, wrong.
 
      }
 
 
      decoder->AddWordsSoFarAndFragLength();
 
//     QwDebug << "QwEventBuffer::FillEPICSData:  "
//      << "Ending loop: fWordsSoFar=="<<GetWordsSoFar()
//      <<QwLog::endl;
//     QwMessage<<"\nQwEventBuffer::FillEPICSData: fWordsSoFar = "<<GetWordsSoFar()<<QwLog::endl;
 
 
    }
  } else {
    // Single bank in the event, use event headers.
    if (decoder->GetBankDataType() == 0x3){
      //  This is an ASCII string bank.  Try to decode it and
      //  pass it to the EPICS class.
      Char_t* tmpchar = (Char_t*)&localbuff[decoder->GetWordsSoFar()];
 
      QwError << tmpchar << QwLog::endl;
 
      epics.ExtractEPICSValues(string(tmpchar), GetEventNumber());
 
    }
 
  }
 
  //std::cout<<"\nEpics data coming!! "<<GetWordsSoFar()<<std::endl;
  QwVerbose << "QwEventBuffer::FillEPICSData:  End of routine"
        << QwLog::endl;
  return okay;
}

References decoder, QwLog::endl(), QwEPICSEvent::ExtractEPICSValues(), fEvStream, GetEventNumber(), IsEPICSEvent(), kNullDataWord, QwError, and QwVerbose.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

FillObjectWithEventData()

template<class T>

Bool_t QwEventBuffer::FillObjectWithEventData

(

T &

t

)

Template to fill any object with data from a CODA event.

The classes for which this template can be specialized must have the following three methods defined:

• Bool_t T::CanUseThisEventType(const UInt_t event_type);
• Bool_t T::ClearEventData(const UInt_t event_type);
• Int_t T::ProcessBuffer(const UInt_t event_type, const ROCID_t roc_id, const BankID_t bank_id, const UInt_t banktype, UInt_t* buffer, UInt_t num_words);

Definition at line 295 of file QwEventBuffer.h.

                                                                           {
  ///  Template to fill any object with data from a CODA event.
  ///
  ///  The classes for which this template can be specialized
  ///  must have the following three methods defined:
  ///
  ///  - Bool_t T::CanUseThisEventType(const UInt_t event_type);
  ///  - Bool_t T::ClearEventData(const UInt_t event_type);
  ///  - Int_t  T::ProcessBuffer(const UInt_t event_type,
  ///       const ROCID_t roc_id, const BankID_t bank_id,
  ///       const UInt_t banktype, UInt_t* buffer, UInt_t num_words);
  ///
  Bool_t okay = kFALSE;
  UInt_t *localbuff = (UInt_t*)(fEvStream->getEvBuffer());
 
  if (decoder->GetFragLength()==1 && localbuff[decoder->GetWordsSoFar()]==kNullDataWord){
    decoder->AddWordsSoFarAndFragLength();
  } else if (object.CanUseThisEventType(decoder->GetEvtType())){
    //  Clear the old event information from the object
    object.ClearEventData(decoder->GetEvtType());
    //  Loop through the data buffer in this event.
    if (decoder->GetBankDataType() == 0x10){
      //  This bank is subbanked; loop through subbanks
      while ((okay = decoder->DecodeSubbankHeader(&localbuff[decoder->GetWordsSoFar()]))){
    //  If this bank has further subbanks, restart the loop.
    if (decoder->GetSubbankType() == 0x10) continue;
    //  If this bank only contains the word 'NULL' then skip
    //  this bank.
    if (decoder->GetFragLength()==1 && localbuff[decoder->GetWordsSoFar()]==kNullDataWord){
      decoder->AddWordsSoFarAndFragLength();
      continue;
    }
    object.ProcessBuffer(decoder->GetEvtType(), decoder->GetROC(), decoder->GetSubbankTag(), decoder->GetSubbankType(),
                 &localbuff[decoder->GetWordsSoFar()],
                 decoder->GetFragLength());
    decoder->AddWordsSoFarAndFragLength();
      }
    } else {
      //  This is a single bank of some type
      object.ProcessBuffer(decoder->GetEvtType(), 0, decoder->GetBankDataType(),
               &localbuff[decoder->GetWordsSoFar()],
               decoder->GetEvtLength());
    }
  }
  return okay;
}

References decoder, fEvStream, and kNullDataWord.

FillSubsystemConfigurationData() [1/2]

Bool_t QwEventBuffer::FillSubsystemConfigurationData

(

QwSubsystemArray &

subsystems

)

Passes the data for the configuration events into each subsystem object. Each object is responsible for recognizing the configuration data which it ought to decode. NOTE TO DAQ PROGRAMMERS: The configuration event for a ROC must have the same subbank structure as the physics events for that ROC.

Definition at line 787 of file QwEventBuffer.cc.

{
  ///  Passes the data for the configuration events into each subsystem
  ///  object.  Each object is responsible for recognizing the configuration
  ///  data which it ought to decode.
  ///  NOTE TO DAQ PROGRAMMERS:
  ///      The configuration event for a ROC must have the same
  ///      subbank structure as the physics events for that ROC.
  Bool_t okay = kTRUE;
  UInt_t rocnum = decoder->GetEvtType() - 0x90;
  QwMessage << "QwEventBuffer::FillSubsystemConfigurationData:  "
        << "Found configuration event for ROC"
        << rocnum
        << QwLog::endl;
    decoder->PrintDecoderInfo(QwMessage);
  //  Loop through the data buffer in this event.
  UInt_t *localbuff = (UInt_t*)(fEvStream->getEvBuffer());
    decoder->DecodeEventIDBank(localbuff);
  while ((okay = decoder->DecodeSubbankHeader(&localbuff[decoder->GetWordsSoFar()]))){
    //  If this bank has further subbanks, restart the loop.
    if (decoder->GetSubbankType() == 0x10) {
      QwMessage << "This bank has further subbanks, restart the loop" << QwLog::endl;
      continue;
    }
    //  If this bank only contains the word 'NULL' then skip
    //  this bank.
    if (decoder->GetFragLength()==1 && localbuff[decoder->GetWordsSoFar()]==kNullDataWord){
      decoder->AddWordsSoFarAndFragLength();
      QwMessage << "Skip this bank" << QwLog::endl;
      continue;
    }
 
    //  Subsystems may be configured to accept data in formats
    //  other than 32 bit integer (banktype==1), but the
    //  bank type is not provided.  Subsystems must be able
    //  to process their data knowing only the ROC and bank tags.
    //
    //  After trying the data in each subsystem, bump the
    //  fWordsSoFar to move to the next bank.
 
    subsystems.ProcessConfigurationBuffer(rocnum, decoder->GetSubbankTag(),
                      &localbuff[decoder->GetWordsSoFar()],
                      decoder->GetFragLength());
    decoder->AddWordsSoFarAndFragLength();
    QwDebug << "QwEventBuffer::FillSubsystemConfigurationData:  "
        << "Ending loop: fWordsSoFar=="<<decoder->GetWordsSoFar()
        <<QwLog::endl;
  }
 
  return okay;
}

References decoder, QwLog::endl(), fEvStream, kNullDataWord, QwSubsystemArray::ProcessConfigurationBuffer(), QwDebug, and QwMessage.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

FillSubsystemConfigurationData() [2/2]

Bool_t QwEventBuffer::FillSubsystemConfigurationData ( std::vector< VQwSubsystem * > & subsystems )

private

FillSubsystemData() [1/2]

Bool_t QwEventBuffer::FillSubsystemData

(

QwSubsystemArray &

subsystems

)

Definition at line 839 of file QwEventBuffer.cc.

{
  //  Initialize local flag
  Bool_t okay = kTRUE;
 
  //  Reload the data buffer and decode the header again, this allows
  //  multiple calls to this function for different subsystem arrays.
  UInt_t *localbuff = (UInt_t*)(fEvStream->getEvBuffer());
 
    decoder->DecodeEventIDBank(localbuff);
 
  //  Clear the old event information from the subsystems.
  subsystems.ClearEventData();
 
  //  Pass CODA run, segment, event number and type to the subsystem array.
  subsystems.SetCodaRunNumber(fCurrentRun);
  subsystems.SetCodaSegmentNumber(fRunIsSegmented? *fRunSegmentIterator: 0);
  subsystems.SetCodaEventNumber(decoder->GetEvtNumber());
  subsystems.SetCodaEventType(decoder->GetEvtType());
 
  // If this event type is masked for the subsystem array, return right away
  if (((0x1 << (decoder->GetEvtType() - 1)) & subsystems.GetEventTypeMask()) == 0) {
    return kTRUE;
  }
 
  UInt_t offset;
 
  //  Loop through the data buffer in this event.
  while ((okay = decoder->DecodeSubbankHeader(&localbuff[decoder->GetWordsSoFar()]))){
 
    //  If this bank has further subbanks, restart the loop.
    if (decoder->GetSubbankType() == 0x10) continue;
 
    //  If this bank only contains the word 'NULL' then skip
    //  this bank.
    if (decoder->GetFragLength() == 1 && localbuff[decoder->GetWordsSoFar()]==kNullDataWord) {
      decoder->AddWordsSoFarAndFragLength();
      continue;
    }
 
    // if (GetSubbankType() == 0x85) {
    //   std::cout << "ProcessEventBuffer: , SubbankTag= "<< GetSubbankTag()<<" FragLength="<<GetFragLength() <<std::endl;
    // }
 
//     QwDebug << "QwEventBuffer::FillSubsystemData:  "
//      << "Beginning loop: fWordsSoFar=="<<GetWordsSoFar()
//      <<QwLog::endl;
 
    //  Loop through the subsystems and try to store the data
    //  from this bank in each subsystem.
    //
    //  Subsystems may be configured to accept data in formats
    //  other than 32 bit integer (banktype==1), but the
    //  bank type is not provided.  Subsystems must be able
    //  to process their data knowing only the ROC and bank tags.
    //
    //  After trying the data in each subsystem, bump the
    //  fWordsSoFar to move to the next bank.
 
        // TODO:
        // What is special about this subbank?
    if( decoder->GetROC() == 0 && decoder->GetSubbankTag()==0x6101) {
      //std::cout << "ProcessEventBuffer: ROC="<<GetROC()<<", SubbankTag="<< GetSubbankTag()<<", FragLength="<<GetFragLength() <<std::endl;
      fCleanParameter[0]=localbuff[decoder->GetWordsSoFar()+decoder->GetFragLength()-4];//clean data
      fCleanParameter[1]=localbuff[decoder->GetWordsSoFar()+decoder->GetFragLength()-3];//scan data 1
      fCleanParameter[2]=localbuff[decoder->GetWordsSoFar()+decoder->GetFragLength()-2];//scan data 2
      //std::cout << "ProcessEventBuffer: ROC="<<GetROC()<<", SubbankTag="<< GetSubbankTag()
      //        <<", FragLength="<<GetFragLength() << " " <<fCleanParameter[0]<< " " <<fCleanParameter[1]<< " " <<fCleanParameter[2]<<std::endl;
 
    }
 
    subsystems.SetCleanParameters(fCleanParameter);
 
    std::size_t nmarkers = CheckForMarkerWords(subsystems);
    if (nmarkers>0) {
      //  There are markerwords for this ROC/Bank
      for (size_t i=0; i<nmarkers; i++){
        offset = FindMarkerWord(i,&localbuff[decoder->GetWordsSoFar()],decoder->GetFragLength());
          BankID_t tmpbank = GetMarkerWord(i);
        tmpbank = ((tmpbank)<<32) + decoder->GetSubbankTag();
        offset++; //  Skip the marker word
        subsystems.ProcessEvBuffer(decoder->GetEvtType(), decoder->GetROC(), tmpbank,
                     &localbuff[decoder->GetWordsSoFar()+offset],
                     decoder->GetFragLength()-offset);
      }
    } else {
      QwDebug << "QwEventBuffer::FillSubsystemData:  "
          << "fROC=="<<decoder->GetROC() << ", GetSubbankTag()==" << decoder->GetSubbankTag()
          << QwLog::endl;
      subsystems.ProcessEvBuffer(decoder->GetEvtType(), decoder->GetROC(), decoder->GetSubbankTag(),
                 &localbuff[decoder->GetWordsSoFar()],
                 decoder->GetFragLength());
    }
    decoder->AddWordsSoFarAndFragLength();
//     QwDebug << "QwEventBuffer::FillSubsystemData:  "
//      << "Ending loop: fWordsSoFar=="<<GetWordsSoFar()
//      <<QwLog::endl;
  }
  return okay;
}

References CheckForMarkerWords(), QwSubsystemArray::ClearEventData(), decoder, QwLog::endl(), fCleanParameter, fCurrentRun, fEvStream, FindMarkerWord(), fRunIsSegmented, fRunSegmentIterator, QwSubsystemArray::GetEventTypeMask(), GetMarkerWord(), kNullDataWord, QwSubsystemArray::ProcessEvBuffer(), QwDebug, QwSubsystemArray::SetCleanParameters(), QwSubsystemArray::SetCodaEventNumber(), QwSubsystemArray::SetCodaEventType(), QwSubsystemArray::SetCodaRunNumber(), and QwSubsystemArray::SetCodaSegmentNumber().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

FillSubsystemData() [2/2]

Bool_t QwEventBuffer::FillSubsystemData ( std::vector< VQwSubsystem * > & subsystems )

private

FindMarkerWord()

UInt_t QwEventBuffer::FindMarkerWord ( UInt_t markerID, UInt_t * buffer, UInt_t num_words )

protected

Definition at line 1338 of file QwEventBuffer.cc.

                                                                                        {
  UInt_t markerpos  = fOffsetList.at(fThisRocBankLabel).at(markerindex);
  UInt_t markerval  = fMarkerList.at(fThisRocBankLabel).at(markerindex);
  if (markerpos < num_words && buffer[markerpos] == markerval){
    // The marker word is where it was last time
    return markerpos;
  } else {
    for (size_t i=0; i<num_words; i++){
      if (buffer[i] == markerval){
    fOffsetList.at(fThisRocBankLabel).at(markerindex) = i;
    markerpos = i;
    break;
      }
    }
  }
  return markerpos;
}

References fMarkerList, fOffsetList, and fThisRocBankLabel.

Referenced by FillSubsystemData().

Here is the caller graph for this function:

GetDataDirectory()

const TString & QwEventBuffer::GetDataDirectory ( ) const

inline

Definition at line 116 of file QwEventBuffer.h.

{return fDataDirectory;};

References fDataDirectory.

Referenced by main().

Here is the caller graph for this function:

GetDataFile()

const TString & QwEventBuffer::GetDataFile ( ) const

inline

Definition at line 115 of file QwEventBuffer.h.

{return fDataFile;};

References fDataFile.

GetEndSQLTime()

TString QwEventBuffer::GetEndSQLTime

(

)

Definition at line 736 of file QwEventBuffer.cc.

{
    return decoder->GetEndSQLTime();
}

References decoder.

Referenced by main().

Here is the caller graph for this function:

GetEndUnixTime()

time_t QwEventBuffer::GetEndUnixTime

(

)

Definition at line 746 of file QwEventBuffer.cc.

{
    return decoder->GetEndUnixTime();
}

References decoder.

GetEtEvent()

Int_t QwEventBuffer::GetEtEvent ( )

protected

Definition at line 591 of file QwEventBuffer.cc.

                               {
  Int_t status = CODA_OK;
  //  Do we want to have any loop here to wait for a bad
  //  read to be cleared?
  status = fEvStream->codaRead();
  if (status != CODA_OK) {
    globalEXIT = 1;
    }
  return status;
}

References fEvStream, and globalEXIT.

Referenced by GetEvent().

Here is the caller graph for this function:

GetEvent()

Int_t QwEventBuffer::GetEvent

(

)

Definition at line 523 of file QwEventBuffer.cc.

{
  Int_t status = kFileHandleNotConfigured;
  ResetFlags();
  if (fEvStreamMode==fEvStreamFile){
    status = GetFileEvent();
  } else if (fEvStreamMode==fEvStreamET){
    status = GetEtEvent();
  }
  if (status == CODA_OK){
    // Coda Data was loaded correctly
    UInt_t* evBuffer = (UInt_t*)fEvStream->getEvBuffer();
    if(fDataVersionVerify == 0){ // Default = 0 => Undetermined
        VerifyCodaVersion(evBuffer);
    }
    decoder->DecodeEventIDBank(evBuffer);
  }
  return status;
}

References decoder, fDataVersionVerify, fEvStream, fEvStreamET, fEvStreamFile, fEvStreamMode, GetEtEvent(), GetFileEvent(), kFileHandleNotConfigured, ResetFlags(), and VerifyCodaVersion().

Referenced by GetNextEvent().

Here is the call graph for this function:

Here is the caller graph for this function:

GetEventNumber()

Int_t QwEventBuffer::GetEventNumber ( )

inline

Definition at line 133 of file QwEventBuffer.h.

{ return decoder->GetEvtNumber(); };

References decoder.

Referenced by FillEPICSData(), and main().

Here is the caller graph for this function:

GetEventRange()

std::pair< UInt_t, UInt_t > QwEventBuffer::GetEventRange ( ) const

inline

Definition at line 103 of file QwEventBuffer.h.

                                                {
    return fEventRange;
  };

References fEventRange.

GetFileEvent()

Int_t QwEventBuffer::GetFileEvent ( )

protected

Definition at line 573 of file QwEventBuffer.cc.

                                 {
  Int_t status = CODA_OK;
  //  Try to get a new event.  If the EOF occurs,
  //  and the run is segmented, try to open the
  //  next segment and read a new event; repeat
  //  if needed.
  do {
    status = fEvStream->codaRead();
    if (fChainDataFiles && status == EOF){
      CloseThisSegment();
      //  Crash out of the loop if we can't open the
      //  next segment!
      if (OpenNextSegment()!=CODA_OK) break;
    }
  } while (fChainDataFiles && status == EOF);
  return status;
}

References CloseThisSegment(), fChainDataFiles, fEvStream, and OpenNextSegment().

Referenced by GetEvent().

Here is the call graph for this function:

Here is the caller graph for this function:

GetMarkerWord()

UInt_t QwEventBuffer::GetMarkerWord ( UInt_t markerID )

protected

Definition at line 1333 of file QwEventBuffer.cc.

                                                  {
  return fMarkerList.at(fThisRocBankLabel).at(markerID);
};

References fMarkerList, and fThisRocBankLabel.

Referenced by FillSubsystemData().

Here is the caller graph for this function:

GetNextEvent()

Int_t QwEventBuffer::GetNextEvent

(

)

Definition at line 452 of file QwEventBuffer.cc.

{
  //  This will return for read errors,
  //  non-physics events, and for physics
  //  events that are within the event range.
  Int_t status = CODA_OK;
  do {
    status = GetEvent();
    if (globalEXIT == 1) {
      //  QUESTION:  Should we continue to loop once we've
      //  reached the maximum event, to allow access to
      //  non-physics events?
      //  For now, mock up EOF if we've reached the maximum event.
      status = EOF;
    }
    if (decoder->GetEvtNumber() > fEventRange.second) {
      do {
        if (GetNextEventRange()) status = CODA_OK;
        else status = EOF;
      } while (decoder->GetEvtNumber() < fEventRange.first);
    }
    //  While we're in a run segment which was not requested (which
    //  should happen only when reading the zeroth segment for startup
    //  information), pretend that there's an event cut causing us to
    //  ignore events.  Read configuration events only from the first
    //  part of the file.
    if (fRunIsSegmented && GetSegmentNumber() < fSegmentRange.first) {
      fEventRange.first = decoder->GetEvtNumber() + 1;
      if (decoder->GetEvtNumber() > 1000) status = EOF;
    }
    if (fOnline && fExitOnEnd && decoder->GetEndTime()>0){
      // fExitOnEnd exits the event loop only and does not exit JAPAN.
      // The root file gets processed and JAPAN immediately waits for the next run.
      // We considered adding a exit-JAPAN-on-end flag that quits JAPAN but decided
      // we didn't have a use case for it. If quitting JAPAN is desired, just set:
      // globalEXIT = 1
      // -- mrc (01/21/25)
      QwMessage << "Caught End Event (end time=="<< decoder->GetEndTime()
        << ").  Exit event loop." << QwLog::endl;
      status = EOF;
    }
    if (fOnline && onlineRestart){
      onlineRestart=0;
      status = EOF;
    }
  } while (status == CODA_OK  &&
           IsPhysicsEvent()   &&
           (decoder->GetEvtNumber() < fEventRange.first
         || decoder->GetEvtNumber() > fEventRange.second)
          );
  if (status == CODA_OK  && IsPhysicsEvent()) fNumPhysicsEvents++;
 
  //  Progress meter (this should probably produce less output in production)
  int nevents = 10000;
  if (IsPhysicsEvent() && decoder->GetEvtNumber() > 0 && decoder->GetEvtNumber() % nevents == 0) {
    QwMessage << "Processing event " << decoder->GetEvtNumber() << " ";
    fStopwatch.Stop();
    double efficiency = 100.0 * fStopwatch.CpuTime() / fStopwatch.RealTime();
    QwMessage << "(" << fStopwatch.CpuTime()*1e3/nevents << " ms per event with ";
    QwMessage << efficiency << "% efficiency)";
    fStopwatch.Reset();
    fStopwatch.Start();
    QwMessage << QwLog::endl;
  } else if (decoder->GetEvtNumber() > 0 && decoder->GetEvtNumber() % 100 == 0) {
    QwVerbose << "Processing event " << decoder->GetEvtNumber() << QwLog::endl;
  }
 
  return status;
}

References decoder, QwLog::endl(), fEventRange, fExitOnEnd, fNumPhysicsEvents, fOnline, fRunIsSegmented, fSegmentRange, fStopwatch, GetEvent(), GetNextEventRange(), GetSegmentNumber(), globalEXIT, IsPhysicsEvent(), onlineRestart, QwMessage, and QwVerbose.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

GetNextEventRange()

Bool_t QwEventBuffer::GetNextEventRange

(

)

Read the next requested event range, return true if success.

Definition at line 293 of file QwEventBuffer.cc.

                                        {
  // If there is an event list, open the next section
  if (fEventListFile && !fEventListFile->IsEOF()) {
    std::string eventrange;
    // Find next non-whitespace, non-comment, non-empty line, before EOF
    do {
      fEventListFile->ReadNextLine(eventrange);
      fEventListFile->TrimWhitespace();
      fEventListFile->TrimComment('#');
    } while (fEventListFile->LineIsEmpty() && !fEventListFile->IsEOF());
    // If EOF return false; no next event range
    if (fEventListFile->IsEOF()) return kFALSE;
    // Parse the event range
    fEventRange = QwParameterFile::ParseIntRange(":",eventrange);
    QwMessage << "Next event range is " << eventrange << QwLog::endl;
    return kTRUE;
  }
  return kFALSE;
}

References QwLog::endl(), fEventListFile, fEventRange, QwParameterFile::ParseIntRange(), and QwMessage.

Referenced by GetNextEvent(), and GetNextRunRange().

Here is the call graph for this function:

Here is the caller graph for this function:

GetNextRunNumber()

Bool_t QwEventBuffer::GetNextRunNumber

(

)

Get the next run in the active run range, proceed to next range if needed.

Definition at line 335 of file QwEventBuffer.cc.

                                       {
  // First run
  if (fCurrentRun == -1) {
    fCurrentRun = fRunRange.first;
    return kTRUE;
  // Run is in range
  } else if (fCurrentRun < fRunRange.second) {
    fCurrentRun++;
    return kTRUE;
  // Run is not in range, get new range
  } else if (GetNextRunRange()) {
    fCurrentRun = fRunRange.first;
    return kTRUE;
  }
  return kFALSE;
}

References fCurrentRun, fRunRange, and GetNextRunRange().

Referenced by OpenNextStream().

Here is the call graph for this function:

Here is the caller graph for this function:

GetNextRunRange()

Bool_t QwEventBuffer::GetNextRunRange

(

)

Read the next requested run range, return true if success.

Definition at line 314 of file QwEventBuffer.cc.

                                      {
  // If there is a run list, open the next section
  std::string runrange;
  if (fRunListFile && !fRunListFile->IsEOF() &&
     (fEventListFile = fRunListFile->ReadNextSection(runrange))) {
    // Parse the run range
    fRunRange = QwParameterFile::ParseIntRange(":",runrange);
    QwMessage << "Next run range is " << runrange << QwLog::endl;
    // If there is no event range for this run range, set to default of 0:MAXINT
    if (! GetNextEventRange()) {
      QwWarning << "No valid event range in run list file: "
                << fEventListFile->GetLine() << ". "
                << "Assuming the full event range." << QwLog::endl;
      fEventRange = QwParameterFile::ParseIntRange(":","0:");
    }
    return kTRUE;
  }
  return kFALSE;
}

References QwLog::endl(), fEventListFile, fEventRange, fRunListFile, fRunRange, GetNextEventRange(), QwParameterFile::ParseIntRange(), QwMessage, and QwWarning.

Referenced by GetNextRunNumber(), and ProcessOptions().

Here is the call graph for this function:

Here is the caller graph for this function:

GetPhysicsEventNumber()

Int_t QwEventBuffer::GetPhysicsEventNumber ( )

inline

Definition at line 132 of file QwEventBuffer.h.

{return fNumPhysicsEvents;};

References fNumPhysicsEvents.

Referenced by main().

Here is the caller graph for this function:

GetRunLabel()

TString QwEventBuffer::GetRunLabel

(

)

const

Returns a string like <run#> or <run#>.<file#>

Definition at line 352 of file QwEventBuffer.cc.

{
  TString runlabel = Form("%d",fCurrentRun);
  if (fRunIsSegmented && ! fChainDataFiles){
    runlabel += Form(".%03d",*fRunSegmentIterator);
  }
  return runlabel;
}

References fChainDataFiles, fCurrentRun, fRunIsSegmented, and fRunSegmentIterator.

Referenced by main().

Here is the caller graph for this function:

GetRunNumber()

Int_t QwEventBuffer::GetRunNumber ( ) const

inline

Return CODA file run number.

Definition at line 97 of file QwEventBuffer.h.

{return fCurrentRun;};

References fCurrentRun.

Referenced by main(), and PrintRunTimes().

Here is the caller graph for this function:

GetSegmentNumber()

Int_t QwEventBuffer::GetSegmentNumber ( ) const

inline

Return CODA file segment number.

Definition at line 99 of file QwEventBuffer.h.

                                 {
    return fRunSegments.size() ? *fRunSegmentIterator : 0;
  };

References fRunSegmentIterator, and fRunSegments.

Referenced by GetNextEvent(), and main().

Here is the caller graph for this function:

GetStartSQLTime()

TString QwEventBuffer::GetStartSQLTime

(

)

Definition at line 731 of file QwEventBuffer.cc.

{
    return decoder->GetStartSQLTime();
}

References decoder.

Referenced by main().

Here is the caller graph for this function:

GetStartUnixTime()

time_t QwEventBuffer::GetStartUnixTime

(

)

Definition at line 741 of file QwEventBuffer.cc.

{
    return decoder->GetStartUnixTime();
}

References decoder.

IsEPICSEvent()

Bool_t QwEventBuffer::IsEPICSEvent ( )

inline

Definition at line 151 of file QwEventBuffer.h.

                       {
    return ( decoder->IsEPICSEvent() ); // Defined in CodaDecoder.h
    }

References decoder.

Referenced by FillEPICSData(), and main().

Here is the caller graph for this function:

IsOnline()

Bool_t QwEventBuffer::IsOnline ( )

inline

Definition at line 145 of file QwEventBuffer.h.

{return fOnline;};

References fOnline.

Referenced by main(), and main().

Here is the caller graph for this function:

IsPhysicsEvent()

Bool_t QwEventBuffer::IsPhysicsEvent ( )

inline

Definition at line 128 of file QwEventBuffer.h.

                          {
        return ( decoder->IsPhysicsEvent() );
  };

References decoder.

Referenced by GetNextEvent(), and main().

Here is the caller graph for this function:

IsROCConfigurationEvent()

Bool_t QwEventBuffer::IsROCConfigurationEvent ( )

inline

Definition at line 147 of file QwEventBuffer.h.

                                  {
    return ( decoder->IsROCConfigurationEvent() );
  };

References decoder.

Referenced by main().

Here is the caller graph for this function:

OpenDataFile() [1/3]

Int_t QwEventBuffer::OpenDataFile	(	const TString	filename,
		const TString	rw = "R" )

Definition at line 1221 of file QwEventBuffer.cc.

{
  if (fEvStreamMode==fEvStreamNull){
    QwDebug << "QwEventBuffer::OpenDataFile:  File handle doesn't exist.\n"
        << "                              Try to open a new file handle!"
        << QwLog::endl;
    fEvStream = new THaCodaFile();
    fEvStreamMode = fEvStreamFile;
  } else if (fEvStreamMode!=fEvStreamFile){
    QwError << "QwEventBuffer::OpenDataFile:  The stream is not configured as an input\n"
        << "                              file stream!  Can't deal with this!\n"
        << QwLog::endl;
    exit(1);
  }
  fDataFile = filename;
 
  if (rw.Contains("w",TString::kIgnoreCase)) {
    // If we open a file for write access, let's suppose
    // we've given the path we want to use.
    QwMessage << "Opening data file:  " << fDataFile << QwLog::endl;
  } else {
    //  Let's try to find the data file for read access.
    glob_t globbuf;
    glob(fDataFile.Data(), GLOB_ERR, NULL, &globbuf);
    if (globbuf.gl_pathc == 0){
      //  Can't find the file; try in the "fDataDirectory".
      fDataFile = fDataDirectory + filename;
      glob(fDataFile.Data(), GLOB_ERR, NULL, &globbuf);
    }
    if (globbuf.gl_pathc == 0){
      //  Can't find the file; try gzipped.
      fDataFile = filename + ".gz";
      glob(fDataFile.Data(), GLOB_ERR, NULL, &globbuf);
    }
    if (globbuf.gl_pathc == 0){
      //  Can't find the file; try gzipped in the "fDataDirectory".
      fDataFile = fDataDirectory + filename + ".gz";
      glob(fDataFile.Data(), GLOB_ERR, NULL, &globbuf);
    }
    if (globbuf.gl_pathc == 1){
      QwMessage << "Opening data file:  " << fDataFile << QwLog::endl;
    } else {
      fDataFile = filename;
      QwError << "Unable to find "
              << filename.Data()  << " or "
              << (fDataDirectory + filename).Data()  << QwLog::endl;
    }
    globfree(&globbuf);
  }
  return fEvStream->codaOpen(fDataFile, rw);
}

References QwLog::endl(), fDataDirectory, fDataFile, fEvStream, fEvStreamFile, fEvStreamMode, fEvStreamNull, QwDebug, QwError, and QwMessage.

Here is the call graph for this function:

OpenDataFile() [2/3]

Int_t QwEventBuffer::OpenDataFile	(	UInt_t	current_run,
		const TString	rw = "R" )

Definition at line 1205 of file QwEventBuffer.cc.

{
  Int_t status;
  fCurrentRun = current_run;
  DataFile(fCurrentRun);
  if (DataFileIsSegmented()){
    status = OpenNextSegment();
  } else {
    status = OpenDataFile(DataFile(fCurrentRun),rw);
  }
  return status;
}

References DataFile(), DataFileIsSegmented(), fCurrentRun, OpenDataFile(), and OpenNextSegment().

Here is the call graph for this function:

OpenDataFile() [3/3]

Int_t QwEventBuffer::OpenDataFile	(	UInt_t	current_run,
		Short_t	seg )

Definition at line 1191 of file QwEventBuffer.cc.

{
  fCurrentRun = current_run;
 
  fRunSegments.clear();
  fRunIsSegmented = kTRUE;
 
  fRunSegments.push_back(seg);
  fRunSegmentIterator = fRunSegments.begin();
  return OpenNextSegment();
}

References fCurrentRun, fRunIsSegmented, fRunSegmentIterator, fRunSegments, and OpenNextSegment().

Referenced by main(), OpenDataFile(), OpenNextSegment(), OpenNextStream(), and ReOpenStream().

Here is the call graph for this function:

Here is the caller graph for this function:

OpenETStream()

Int_t QwEventBuffer::OpenETStream	(	TString	computer,
		TString	session,
		int	mode,
		const TString	stationname = "" )

Definition at line 1285 of file QwEventBuffer.cc.

{
  Int_t status = CODA_OK;
  if (fEvStreamMode==fEvStreamNull){
#ifdef __CODA_ET
    if (stationname != ""){
      fEvStream = new THaEtClient(computer, session, mode, stationname.Data());
    } else {
      fEvStream = new THaEtClient(computer, session, mode);
    }
    fEvStreamMode = fEvStreamET;
#endif
  }
  return status;
}

References fEvStream, fEvStreamET, fEvStreamMode, and fEvStreamNull.

Referenced by OpenNextStream(), and ReOpenStream().

Here is the caller graph for this function:

OpenNextSegment()

Int_t QwEventBuffer::OpenNextSegment ( )

protected

Definition at line 1156 of file QwEventBuffer.cc.

{
  Int_t status;
  if (! fRunIsSegmented){
    /*  We are processing a non-segmented run.            *
     *  We should not have entered this routine, but      *
     *  since we are here, don't do anything.             */
    status = kRunNotSegmented;
 
  } else if (fRunSegments.size()==0){
    /*  There are actually no file segments located.      *
     *  Return "kNoNextDataFile", but don't print an      *
     *  error message.                                    */
    status = kNoNextDataFile;
 
  } else if (fRunSegmentIterator >= fRunSegments.begin() &&
             fRunSegmentIterator <  fRunSegments.end() ) {
    QwMessage << "Trying to open run segment " << *fRunSegmentIterator << QwLog::endl;
    status = OpenDataFile(DataFile(fCurrentRun,*fRunSegmentIterator),"R");
 
  } else if (fRunSegmentIterator == fRunSegments.end() ) {
    /*  We have reached the last run segment. */
    QwMessage << "There are no run segments remaining." << QwLog::endl;
    status = kNoNextDataFile;
 
  } else {
    QwError << "QwEventBuffer::OpenNextSegment(): Unrecognized error" << QwLog::endl;
    status = CODA_ERROR;
  }
  return status;
}

References DataFile(), QwLog::endl(), fCurrentRun, fRunIsSegmented, fRunSegmentIterator, fRunSegments, kNoNextDataFile, kRunNotSegmented, OpenDataFile(), QwError, and QwMessage.

Referenced by GetFileEvent(), OpenDataFile(), OpenDataFile(), OpenNextStream(), and ReOpenStream().

Here is the call graph for this function:

Here is the caller graph for this function:

OpenNextStream()

Int_t QwEventBuffer::OpenNextStream

(

)

Opens the event stream (file or ET) based on the internal flags.

Definition at line 382 of file QwEventBuffer.cc.

{
  Int_t status = CODA_ERROR;
  if (globalEXIT==1) {
    //  We want to exit, so don't open the next stream.
    status = CODA_ERROR;
  } else if (fOnline) {
    /* Modify the call below for your ET system, if needed.
       OpenETStream( ET host name , $SESSION , mode)
       mode=0: wait forever
       mode=1: timeout quickly
    */
    QwMessage << "Try to open the ET station with HOSTNAME=="
          << fETHostname
          << ", SESSION==" << fETSession << "."
          << QwLog::endl;
    status = OpenETStream(fETHostname, fETSession, fETWaitMode, fETStationName);
 
  } else {
    //  Try to open the next data file for the current run,
    //  but only if we haven't hit the event limit.
    if (fCurrentRun != -1 && !fChainDataFiles
    && decoder->GetEvtNumber() <= fEventRange.second) {
      status = OpenNextSegment();
    }
    while (status != CODA_OK && GetNextRunNumber()) {
      status = OpenDataFile(fCurrentRun);
      if (status == CODA_ERROR){
    //  The data file can't be opened.
    //  Get ready to process the next run.
    QwError << "ERROR:  Unable to find data files for run "
        << fCurrentRun << ".  Moving to the next run.\n"
        << QwLog::endl;
      }
    }
 
  }
  //  Grab the starting event counter
  fStartingPhysicsEvent = fNumPhysicsEvents;
  //  Start the timers.
  fRunTimer.Reset();
  fRunTimer.Start();
  fStopwatch.Start();
  return status;
}

References decoder, QwLog::endl(), fChainDataFiles, fCurrentRun, fETHostname, fETSession, fETStationName, fETWaitMode, fEventRange, fNumPhysicsEvents, fOnline, fRunTimer, fStartingPhysicsEvent, fStopwatch, GetNextRunNumber(), globalEXIT, OpenDataFile(), OpenETStream(), OpenNextSegment(), QwError, and QwMessage.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

PrintRunTimes()

void QwEventBuffer::PrintRunTimes

(

)

Definition at line 276 of file QwEventBuffer.cc.

{
  UInt_t nevents = fNumPhysicsEvents - fStartingPhysicsEvent;
  if (nevents==0) nevents=1;
  QwMessage << QwLog::endl
        << "Analysis of run " << GetRunNumber() << QwLog::endl
        << fNumPhysicsEvents << " physics events were processed"<< QwLog::endl
        << "CPU time used:  " << fRunTimer.CpuTime() << " s "
        << "(" << 1000.0 * fRunTimer.CpuTime() / nevents << " ms per event)" << QwLog::endl
        << "Real time used: " << fRunTimer.RealTime() << " s "
        << "(" << 1000.0 * fRunTimer.RealTime() / nevents << " ms per event)" << QwLog::endl
        << QwLog::endl;
}

References QwLog::endl(), fNumPhysicsEvents, fRunTimer, fStartingPhysicsEvent, GetRunNumber(), and QwMessage.

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

ProcessOptions()

void QwEventBuffer::ProcessOptions

(

QwOptions &

options

)

Sets internal flags based on the QwOptions.

Definition at line 152 of file QwEventBuffer.cc.

{
  fOnline     = options.GetValue<bool>("online");
  if (fOnline){
    fETWaitMode  = options.GetValue<int>("ET.waitmode");
    fExitOnEnd  = options.GetValue<bool>("ET.exit-on-end");
#ifndef __CODA_ET
    QwError << "Online mode will not work without the CODA libraries!"
        << QwLog::endl;
    exit(EXIT_FAILURE);
#else
    if (options.HasValue("online.RunNumber")) {
      fCurrentRun = options.GetValue<int>("online.RunNumber");
    }
    if (options.HasValue("ET.station")) {
      fETStationName = options.GetValue<string>("ET.station");
    } else {
      fETStationName = "";
    }
    if (options.HasValue("ET.hostname")) {
      fETHostname = options.GetValue<string>("ET.hostname");
    } else {
      fETHostname = getenv("HOSTNAME");
    }
    if (options.HasValue("ET.session")) {
      fETSession = options.GetValue<string>("ET.session");
    } else {
      fETSession = getenv("SESSION");
    }
    if (fETHostname.Length() == 0 || fETSession.Length() == 0) {
      TString tmp = "";
      if (fETHostname == NULL || fETHostname.Length() == 0)
    tmp += " \"HOSTNAME\"";
      if (fETSession == NULL ||  fETSession.Length() == 0){
    if (tmp.Length() > 0)
      tmp += " and";
    tmp += " ET \"SESSION\"";
      }
      QwError << "The" << tmp
          << " variable(s) is(are) not defined in your environment.\n"
          << "        This is needed to run the online analysis."
          << QwLog::endl;
      exit(EXIT_FAILURE);
    }
#endif
  }
  if(options.HasValue("directfile")){
      fSingleFile = kTRUE;
      fDataFile = options.GetValue<string>("directfile");
  } else {
      fSingleFile = kFALSE;
  }
  fDataDirectory = options.GetValue<string>("data");
  if (fDataDirectory.Length() == 0){
    QwError << "ERROR:  Can't get the data directory in the QwEventBuffer creator."
        << QwLog::endl;
  } else if (! fDataDirectory.EndsWith("/")) {
      fDataDirectory.Append("/");
  }
 
  fRunRange = options.GetIntValuePair("run");
  fEventRange = options.GetIntValuePair("event");
  fSegmentRange = options.GetIntValuePair("segment");
  fRunListFileName = options.GetValue<string>("runlist");
  fChainDataFiles = options.GetValue<bool>("chainfiles");
  fDataFileStem = options.GetValue<string>("codafile-stem");
  fDataFileExtension = options.GetValue<string>("codafile-ext");
    fDataVersion = options.GetValue<int>("coda-version");
 
    if(fDataVersion == 2){
        decoder = new Coda2EventDecoder();
    } else if(fDataVersion == 3) {
        decoder = new Coda3EventDecoder();
    } else{
        QwError << "Invalid Coda Version. Only versions 2 and 3 are supported. "
                        << "Please set using --coda-version 2(3)" << QwLog::endl;
    exit(EXIT_FAILURE);
    }
 
    decoder->SetAllowLowSubbankIDs( options.GetValue<bool>("allow-low-subbank-ids") );
 
  // Process event rate limiting option
  fMaxEventRate = options.GetValue<double>("max-event-rate");
  if (fMaxEventRate > 0.0) {
    fEventRateLimitEnabled = true;
    fMinEventInterval = std::chrono::duration<double>(1.0 / fMaxEventRate);
    QwMessage << "Event rate limiting enabled: " << fMaxEventRate << " Hz "
              << "(minimum interval: " << (1000.0 / fMaxEventRate) << " ms)" 
              << QwLog::endl;
  } else {
    fEventRateLimitEnabled = false;
  }
  fLastEventTime = std::chrono::steady_clock::now();
 
  // Open run list file
  /* runlist file format example:
     [5253]
     234
     246
     256
     345:456
     567:789
     [5259]
     [5260]
     0:10000
     [5261:5270]
     9000:10000
    - for run 5253 it will analyze three individual events, and two event ranges
    - for run 5259 it will analyze the entire run (all segments)
    - for run 5260 it will analyze the first 10000 events
    - for runs 5261 through 5270 it will analyze the events 9000 through 10000)
  */
  if (fRunListFileName.size() > 0) {
    fRunListFile = std::make_unique<QwParameterFile>(fRunListFileName);
    fEventListFile = nullptr;
    if (! GetNextRunRange()) {
      QwWarning << "No run range found in run list file: " << fRunListFile->GetLine() << QwLog::endl;
    }
  } else {
    fRunListFile = nullptr;
    fEventListFile = nullptr;
  }
}

References decoder, QwLog::endl(), fChainDataFiles, fCurrentRun, fDataDirectory, fDataFile, fDataFileExtension, fDataFileStem, fDataVersion, fETHostname, fETSession, fETStationName, fETWaitMode, fEventListFile, fEventRange, fEventRateLimitEnabled, fExitOnEnd, fLastEventTime, fMaxEventRate, fMinEventInterval, fOnline, fRunListFile, fRunListFileName, fRunRange, fSegmentRange, fSingleFile, QwOptions::GetIntValuePair(), GetNextRunRange(), QwOptions::GetValue(), QwOptions::HasValue(), QwError, QwMessage, and QwWarning.

Referenced by main(), and main().

Here is the call graph for this function:

Here is the caller graph for this function:

ReOpenStream()

Int_t QwEventBuffer::ReOpenStream

(

)

Definition at line 361 of file QwEventBuffer.cc.

{
  Int_t status = CODA_ERROR;
  //  Reset the physics event counter
  fNumPhysicsEvents = fStartingPhysicsEvent;
 
  if (fOnline) {
    // Online stream
    status = OpenETStream(fETHostname, fETSession, fETWaitMode, fETStationName);
  } else {
    // Offline data file
    if (fRunIsSegmented)
      // Segmented
      status = OpenNextSegment();
    else
      // Not segmented
      status = OpenDataFile(fCurrentRun);
  }
  return status;
}

References fCurrentRun, fETHostname, fETSession, fETStationName, fETWaitMode, fNumPhysicsEvents, fOnline, fRunIsSegmented, fStartingPhysicsEvent, OpenDataFile(), OpenETStream(), and OpenNextSegment().

Referenced by main(), and main().

Here is the call graph for this function:

Here is the caller graph for this function:

ReportRunSummary()

void QwEventBuffer::ReportRunSummary

(

)

Definition at line 726 of file QwEventBuffer.cc.

{
    decoder->ReportRunSummary();
}

References decoder.

Referenced by main(), and main().

Here is the caller graph for this function:

ResetControlParameters()

void QwEventBuffer::ResetControlParameters

(

)

Definition at line 722 of file QwEventBuffer.cc.

{
    decoder->ResetControlParameters();
}

References decoder.

Referenced by main().

Here is the caller graph for this function:

ResetFlags()

void QwEventBuffer::ResetFlags

(

)

Definition at line 784 of file QwEventBuffer.cc.

                              {
}

Referenced by GetEvent(), and WriteEvent().

Here is the caller graph for this function:

SetDataDirectory()

void QwEventBuffer::SetDataDirectory ( const TString datadir )

inline

Definition at line 112 of file QwEventBuffer.h.

{fDataDirectory = datadir;}

References fDataDirectory.

SetDefaultDataDirectory()

static void QwEventBuffer::SetDefaultDataDirectory ( const std::string & dir )

inlinestatic

Definition at line 50 of file QwEventBuffer.h.

                                                            {
    fDefaultDataDirectory = dir;
  }

References fDefaultDataDirectory.

SetDefaultDataFileExtension()

static void QwEventBuffer::SetDefaultDataFileExtension ( const std::string & extension )

inlinestatic

Definition at line 56 of file QwEventBuffer.h.

                                                                      {
    fDefaultDataFileExtension = extension;
  }

References fDefaultDataFileExtension.

SetDefaultDataFileStem()

static void QwEventBuffer::SetDefaultDataFileStem ( const std::string & stem )

inlinestatic

Definition at line 53 of file QwEventBuffer.h.

                                                            {
    fDefaultDataFileStem = stem;
  }

References fDefaultDataFileStem.

VerifyCodaVersion()

void QwEventBuffer::VerifyCodaVersion

(

const UInt_t *

buffer

)

Definition at line 548 of file QwEventBuffer.cc.

{
    if(buffer[0] == 0) return;
    UInt_t header = buffer[1];
    int top = (header & 0xff000000) >> 24;
    int bot = (header & 0xff      );
    fDataVersionVerify = 0;     // Default
    if( (top == 0xff) && (bot != 0xcc) ){
        fDataVersionVerify = 3; // Coda 3
    } else if( (top != 0xff) && (bot == 0xcc) ){
        fDataVersionVerify = 2; // Coda 2
    }
    // Validate
    if( (fDataVersion != fDataVersionVerify) && (fDataVersionVerify != 0 ) ){
        QwError << "QwEventBuffer::GetEvent:  Coda Version is not recognized" << QwLog::endl;
        QwError << "fDataVersion == " << fDataVersion
                << ", but it looks like the data is from Coda Version "
                << fDataVersionVerify
                << "\nTry running with --coda-version " << fDataVersionVerify
                << "\nExiting ... " << QwLog::endl;
        globalEXIT = 1;
    }
    return;
}

References QwLog::endl(), fDataVersion, fDataVersionVerify, globalEXIT, and QwError.

Referenced by GetEvent().

Here is the call graph for this function:

Here is the caller graph for this function:

WriteEtEvent()

Int_t QwEventBuffer::WriteEtEvent ( int * buffer )

protected

Definition at line 664 of file QwEventBuffer.cc.

{
  Int_t status = CODA_OK;
  //  fEvStream is of inherited type THaCodaData,
  //  but codaWrite for ET is defined in THaEtClient.
#ifdef __CODA_ET
  // Get the buffer length from the first word (CODA event header)
  UInt_t* ubuffer = (UInt_t*)buffer;
  UInt_t event_length = ubuffer[0];  // First word is event length in words
  
  if( event_length == 0 || event_length > MAXEVLEN ) {
    QwError << "WriteEtEvent: Invalid event length: " << event_length << QwLog::endl;
    return CODA_ERROR;
  }
  
  status = ((THaEtClient*)fEvStream)->codaWrite(ubuffer, event_length);
  if( status != CODA_OK ) {
    QwError << "WriteEtEvent: codaWrite failed with status " << status << QwLog::endl;
  }
#else
  QwError << "WriteEtEvent: ET support not compiled in" << QwLog::endl;
  status = CODA_ERROR;
#endif
  return status;
}

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

Referenced by WriteEvent().

Here is the call graph for this function:

Here is the caller graph for this function:

WriteEvent()

Int_t QwEventBuffer::WriteEvent

(

int *

buffer

)

Definition at line 603 of file QwEventBuffer.cc.

{
  Int_t status = kFileHandleNotConfigured;
  ResetFlags();
  
  // Rate limiting: sleep until minimum interval has elapsed, accounting for accumulated delays
  if (fEventRateLimitEnabled) {
    auto now = std::chrono::steady_clock::now();
    auto elapsed = now - fLastEventTime;
 
    if (elapsed < fMinEventInterval) {
      // We're ahead of schedule - need to wait
      auto target_sleep = fMinEventInterval - elapsed;
      
      // Reduce sleep time by accumulated delay (time we're behind)
      auto actual_sleep = target_sleep - fAccumulatedDelay;
      
      if (actual_sleep > std::chrono::duration<double>(0)) {
        // Still need to sleep after compensation
        auto sleep_until_time = now + actual_sleep;
        std::this_thread::sleep_until(sleep_until_time);
        
        // We've compensated for some or all of the accumulated delay
        fAccumulatedDelay -= (target_sleep - actual_sleep);
        if (fAccumulatedDelay < std::chrono::duration<double>(0)) {
          fAccumulatedDelay = std::chrono::duration<double>(0);
        }
      } else {
        // Accumulated delay is larger than needed sleep - don't sleep at all
        fAccumulatedDelay -= target_sleep;
      }
    } else {
      // We're behind schedule - accumulate the delay
      auto delay = elapsed - fMinEventInterval;
      fAccumulatedDelay += delay;
    }
    fLastEventTime = std::chrono::steady_clock::now();
  }
  
  if (fEvStreamMode==fEvStreamFile){
    status = WriteFileEvent(buffer);
  } else if (fEvStreamMode==fEvStreamET) {
    status = WriteEtEvent(buffer);
  }
 
  if (globalEXIT == 1) {
    status = CODA_ERROR;
  }
 
  return status;
}

References fAccumulatedDelay, fEventRateLimitEnabled, fEvStreamET, fEvStreamFile, fEvStreamMode, fLastEventTime, fMinEventInterval, globalEXIT, kFileHandleNotConfigured, ResetFlags(), WriteEtEvent(), and WriteFileEvent().

Referenced by EncodeEndEvent(), EncodeGoEvent(), EncodePauseEvent(), EncodePrestartEvent(), and EncodeSubsystemData().

Here is the call graph for this function:

Here is the caller graph for this function:

WriteFileEvent()

Int_t QwEventBuffer::WriteFileEvent ( int * buffer )

protected

Definition at line 655 of file QwEventBuffer.cc.

{
  Int_t status = CODA_OK;
  //  fEvStream is of inherited type THaCodaData,
  //  but codaWrite is only defined for THaCodaFile.
  status = ((THaCodaFile*)fEvStream)->codaWrite((UInt_t*) buffer);
  return status;
}

References fEvStream.

Referenced by WriteEvent().

Here is the caller graph for this function:

Field Documentation

decoder

VEventDecoder* QwEventBuffer::decoder

protected

Definition at line 292 of file QwEventBuffer.h.

Referenced by CheckForMarkerWords(), EncodeEndEvent(), EncodeGoEvent(), EncodePauseEvent(), EncodePrestartEvent(), EncodeSubsystemData(), FillEPICSData(), FillObjectWithEventData(), FillSubsystemConfigurationData(), FillSubsystemData(), GetEndSQLTime(), GetEndUnixTime(), GetEvent(), GetEventNumber(), GetNextEvent(), GetStartSQLTime(), GetStartUnixTime(), IsEPICSEvent(), IsPhysicsEvent(), IsROCConfigurationEvent(), OpenNextStream(), ProcessOptions(), QwEventBuffer(), ReportRunSummary(), ResetControlParameters(), and ~QwEventBuffer().

fAccumulatedDelay

std::chrono::duration<double> QwEventBuffer::fAccumulatedDelay {0.0}

protected

Definition at line 203 of file QwEventBuffer.h.

{0.0};

Referenced by WriteEvent().

fChainDataFiles

Bool_t QwEventBuffer::fChainDataFiles

protected

Definition at line 206 of file QwEventBuffer.h.

Referenced by AreRunletsSplit(), CloseStream(), GetFileEvent(), GetRunLabel(), OpenNextStream(), and ProcessOptions().

fCleanParameter

Double_t QwEventBuffer::fCleanParameter[3]

protected

Scan data/clean data from the green monster.

Definition at line 268 of file QwEventBuffer.h.

Referenced by FillSubsystemData(), and QwEventBuffer().

fCurrentRun

Int_t QwEventBuffer::fCurrentRun

protected

Definition at line 258 of file QwEventBuffer.h.

Referenced by DataFileIsSegmented(), FillSubsystemData(), GetNextRunNumber(), GetRunLabel(), GetRunNumber(), OpenDataFile(), OpenDataFile(), OpenNextSegment(), OpenNextStream(), ProcessOptions(), QwEventBuffer(), and ReOpenStream().

fDataDirectory

TString QwEventBuffer::fDataDirectory

protected

Definition at line 228 of file QwEventBuffer.h.

Referenced by DataFile(), GetDataDirectory(), OpenDataFile(), ProcessOptions(), QwEventBuffer(), and SetDataDirectory().

fDataFile

TString QwEventBuffer::fDataFile

protected

Definition at line 229 of file QwEventBuffer.h.

Referenced by DataFile(), DataFileIsSegmented(), GetDataFile(), OpenDataFile(), and ProcessOptions().

fDataFileExtension

TString QwEventBuffer::fDataFileExtension

protected

Definition at line 226 of file QwEventBuffer.h.

Referenced by DataFile(), ProcessOptions(), and QwEventBuffer().

fDataFileStem

TString QwEventBuffer::fDataFileStem

protected

Definition at line 225 of file QwEventBuffer.h.

Referenced by DataFile(), ProcessOptions(), and QwEventBuffer().

fDataVersion

Int_t QwEventBuffer::fDataVersion

private

Definition at line 188 of file QwEventBuffer.h.

Referenced by ProcessOptions(), and VerifyCodaVersion().

fDataVersionVerify

Int_t QwEventBuffer::fDataVersionVerify = 0

private

Definition at line 187 of file QwEventBuffer.h.

Referenced by GetEvent(), and VerifyCodaVersion().

fDefaultDataDirectory

std::string QwEventBuffer::fDefaultDataDirectory = "/adaq1/data1/apar"

staticprotected

Definition at line 221 of file QwEventBuffer.h.

Referenced by DefineOptions(), QwEventBuffer(), and SetDefaultDataDirectory().

fDefaultDataFileExtension

std::string QwEventBuffer::fDefaultDataFileExtension = "log"

staticprotected

Definition at line 223 of file QwEventBuffer.h.

Referenced by DefineOptions(), QwEventBuffer(), and SetDefaultDataFileExtension().

fDefaultDataFileStem

std::string QwEventBuffer::fDefaultDataFileStem = "QwRun_"

staticprotected

Definition at line 222 of file QwEventBuffer.h.

Referenced by DefineOptions(), QwEventBuffer(), and SetDefaultDataFileStem().

fETHostname

TString QwEventBuffer::fETHostname

protected

Definition at line 193 of file QwEventBuffer.h.

Referenced by OpenNextStream(), ProcessOptions(), and ReOpenStream().

fETSession

TString QwEventBuffer::fETSession

protected

Definition at line 194 of file QwEventBuffer.h.

Referenced by OpenNextStream(), ProcessOptions(), and ReOpenStream().

fETStationName

TString QwEventBuffer::fETStationName

protected

Definition at line 195 of file QwEventBuffer.h.

Referenced by OpenNextStream(), ProcessOptions(), and ReOpenStream().

fETWaitMode

Int_t QwEventBuffer::fETWaitMode

protected

Definition at line 196 of file QwEventBuffer.h.

Referenced by OpenNextStream(), ProcessOptions(), and ReOpenStream().

fEventList

std::vector<UInt_t> QwEventBuffer::fEventList

protected

Definition at line 215 of file QwEventBuffer.h.

fEventListFile

std::unique_ptr<QwParameterFile> QwEventBuffer::fEventListFile

protected

Definition at line 214 of file QwEventBuffer.h.

Referenced by GetNextEventRange(), GetNextRunRange(), ProcessOptions(), and QwEventBuffer().

fEventListFileName

std::string QwEventBuffer::fEventListFileName

protected

Definition at line 213 of file QwEventBuffer.h.

fEventRange

std::pair<UInt_t, UInt_t> QwEventBuffer::fEventRange

protected

Definition at line 212 of file QwEventBuffer.h.

Referenced by GetEventRange(), GetNextEvent(), GetNextEventRange(), GetNextRunRange(), OpenNextStream(), and ProcessOptions().

fEventRateLimitEnabled

Bool_t QwEventBuffer::fEventRateLimitEnabled {false}

protected

Definition at line 200 of file QwEventBuffer.h.

{false};

Referenced by ProcessOptions(), and WriteEvent().

fEvStream

THaCodaData* QwEventBuffer::fEvStream

protected

Definition at line 256 of file QwEventBuffer.h.

Referenced by CloseDataFile(), CloseETStream(), FillEPICSData(), FillObjectWithEventData(), FillSubsystemConfigurationData(), FillSubsystemData(), GetEtEvent(), GetEvent(), GetFileEvent(), OpenDataFile(), OpenETStream(), QwEventBuffer(), WriteEtEvent(), WriteFileEvent(), and ~QwEventBuffer().

fEvStreamMode

enum QwEventBuffer::CodaStreamMode QwEventBuffer::fEvStreamMode

protected

Referenced by CloseDataFile(), CloseETStream(), CloseStream(), GetEvent(), OpenDataFile(), OpenETStream(), QwEventBuffer(), and WriteEvent().

fExitOnEnd

Bool_t QwEventBuffer::fExitOnEnd

protected

Definition at line 197 of file QwEventBuffer.h.

Referenced by GetNextEvent(), and ProcessOptions().

fLastEventTime

std::chrono::steady_clock::time_point QwEventBuffer::fLastEventTime

protected

Definition at line 204 of file QwEventBuffer.h.

Referenced by ProcessOptions(), and WriteEvent().

fMarkerList

std::unordered_map<RocBankLabel_t, std::vector<UInt_t> > QwEventBuffer::fMarkerList

protected

Definition at line 277 of file QwEventBuffer.h.

Referenced by CheckForMarkerWords(), FindMarkerWord(), and GetMarkerWord().

fMaxEventRate

Double_t QwEventBuffer::fMaxEventRate {0.0}

protected

Definition at line 201 of file QwEventBuffer.h.

{0.0};

Referenced by ProcessOptions().

fMinEventInterval

std::chrono::duration<double> QwEventBuffer::fMinEventInterval

protected

Definition at line 202 of file QwEventBuffer.h.

Referenced by ProcessOptions(), and WriteEvent().

fNumPhysicsEvents

UInt_t QwEventBuffer::fNumPhysicsEvents

protected

Definition at line 286 of file QwEventBuffer.h.

Referenced by GetNextEvent(), GetPhysicsEventNumber(), OpenNextStream(), PrintRunTimes(), QwEventBuffer(), and ReOpenStream().

fOffsetList

std::unordered_map<RocBankLabel_t, std::vector<UInt_t> > QwEventBuffer::fOffsetList

protected

Definition at line 278 of file QwEventBuffer.h.

Referenced by CheckForMarkerWords(), and FindMarkerWord().

fOnline

Bool_t QwEventBuffer::fOnline

protected

Definition at line 192 of file QwEventBuffer.h.

Referenced by GetNextEvent(), IsOnline(), OpenNextStream(), ProcessOptions(), and ReOpenStream().

fRunIsSegmented

Bool_t QwEventBuffer::fRunIsSegmented

protected

Definition at line 260 of file QwEventBuffer.h.

Referenced by AreRunletsSplit(), CloseStream(), CloseThisSegment(), DataFileIsSegmented(), FillSubsystemData(), GetNextEvent(), GetRunLabel(), OpenDataFile(), OpenNextSegment(), and ReOpenStream().

fRunListFile

std::unique_ptr<QwParameterFile> QwEventBuffer::fRunListFile

protected

Definition at line 209 of file QwEventBuffer.h.

Referenced by GetNextRunRange(), ProcessOptions(), and QwEventBuffer().

fRunListFileName

std::string QwEventBuffer::fRunListFileName

protected

Definition at line 208 of file QwEventBuffer.h.

Referenced by ProcessOptions().

fRunRange

std::pair<Int_t, Int_t> QwEventBuffer::fRunRange

protected

Definition at line 207 of file QwEventBuffer.h.

Referenced by GetNextRunNumber(), GetNextRunRange(), and ProcessOptions().

fRunRangeMaxList

std::vector<Int_t> QwEventBuffer::fRunRangeMaxList

protected

Definition at line 210 of file QwEventBuffer.h.

fRunRangeMinList

std::vector<Int_t> QwEventBuffer::fRunRangeMinList

protected

Definition at line 210 of file QwEventBuffer.h.

fRunSegmentIterator

std::vector<Int_t>::iterator QwEventBuffer::fRunSegmentIterator

protected

Definition at line 264 of file QwEventBuffer.h.

Referenced by CloseThisSegment(), DataFileIsSegmented(), FillSubsystemData(), GetRunLabel(), GetSegmentNumber(), OpenDataFile(), and OpenNextSegment().

fRunSegments

std::vector<Int_t> QwEventBuffer::fRunSegments

protected

Definition at line 263 of file QwEventBuffer.h.

Referenced by CloseThisSegment(), DataFileIsSegmented(), GetSegmentNumber(), OpenDataFile(), and OpenNextSegment().

fRunTimer

TStopwatch QwEventBuffer::fRunTimer

protected

Timer used for runlet processing loop.

Definition at line 271 of file QwEventBuffer.h.

Referenced by CloseStream(), OpenNextStream(), and PrintRunTimes().

fSegmentRange

std::pair<Int_t, Int_t> QwEventBuffer::fSegmentRange

protected

Definition at line 217 of file QwEventBuffer.h.

Referenced by DataFileIsSegmented(), GetNextEvent(), and ProcessOptions().

fSingleFile

Bool_t QwEventBuffer::fSingleFile

protected

Definition at line 289 of file QwEventBuffer.h.

Referenced by DataFile(), DataFileIsSegmented(), ProcessOptions(), and QwEventBuffer().

fStartingPhysicsEvent

UInt_t QwEventBuffer::fStartingPhysicsEvent

protected

Definition at line 287 of file QwEventBuffer.h.

Referenced by OpenNextStream(), PrintRunTimes(), and ReOpenStream().

fStopwatch

TStopwatch QwEventBuffer::fStopwatch

protected

Timer used for internal timing.

Definition at line 272 of file QwEventBuffer.h.

Referenced by CloseStream(), GetNextEvent(), and OpenNextStream().

fThisRocBankLabel

RocBankLabel_t QwEventBuffer::fThisRocBankLabel

protected

Definition at line 281 of file QwEventBuffer.h.

Referenced by CheckForMarkerWords(), FindMarkerWord(), and GetMarkerWord().

kFileHandleNotConfigured

const Int_t QwEventBuffer::kFileHandleNotConfigured = -40

static

Definition at line 63 of file QwEventBuffer.h.

Referenced by CloseDataFile(), CloseETStream(), CloseStream(), CloseThisSegment(), GetEvent(), and WriteEvent().

kNoNextDataFile

const Int_t QwEventBuffer::kNoNextDataFile = -30

static

Definition at line 62 of file QwEventBuffer.h.

Referenced by OpenNextSegment().

kNullDataWord

const UInt_t QwEventBuffer::kNullDataWord = 0x4e554c4c

static

This is the ASCII character array 'NULL', and is used by the DAQ to indicate a known empty buffer.

Definition at line 65 of file QwEventBuffer.h.

Referenced by FillEPICSData(), FillObjectWithEventData(), FillSubsystemConfigurationData(), and FillSubsystemData().

kRunNotSegmented

const Int_t QwEventBuffer::kRunNotSegmented = -20

static

Definition at line 61 of file QwEventBuffer.h.

Referenced by OpenNextSegment().

---

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

• QwEventBuffer.h
• QwEventBuffer.cc