QwEventBuffer Class Reference

#include <QwEventBuffer.h>

Inheritance diagram for QwEventBuffer:

Collaboration diagram for QwEventBuffer:

Public Member Functions
	QwEventBuffer ()
	Default constructor. More...
virtual	~QwEventBuffer ()
void	ProcessOptions (QwOptions &options)
	Sets internal flags based on the QwOptions. More...
void	PrintRunTimes ()
TString	GetRunLabel () const
	Returns a string like <run#> or <run#>.<file#> More...
Bool_t	AreRunletsSplit () const
	Return true if file segments are being separated for. More...
Int_t	GetRunNumber () const
	Return CODA file run number. More...
Int_t	GetSegmentNumber () const
	Return CODA file segment number. More...
std::pair< UInt_t, UInt_t >	GetEventRange () const
Int_t	OpenNextStream ()
	Opens the event stream (file or ET) based on the internal flags. More...
Int_t	CloseStream ()
	Closes a currently open event stream. More...
void	SetDataDirectory (const TString datadir)
const TString &	GetDataFile () 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	GetEventNumber ()
Bool_t	GetNextEventRange ()
	Read the next requested event range, return true if success. More...
Bool_t	GetNextRunRange ()
	Read the next requested run range, return true if success. More...
Bool_t	GetNextRunNumber ()
	Get the next run in the active run range, proceed to next range if needed. More...
Int_t	GetNextEvent ()
Int_t	GetEvent ()
Int_t	WriteEvent (int *buffer)
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)
Int_t	EncodeSubsystemData (QwSubsystemArray &subsystems)
Int_t	EncodePrestartEvent (int runnumber, int runtype=0)
Int_t	EncodeGoEvent ()
Int_t	EncodePauseEvent ()
Int_t	EncodeEndEvent ()
void	ResetFlags ()
Public Member Functions inherited from MQwCodaControlEvent
	MQwCodaControlEvent ()
	~MQwCodaControlEvent ()
void	ResetControlParameters ()
void	ProcessControlEvent (UInt_t evtype, UInt_t *buffer)
void	ReportRunSummary ()
UInt_t	GetStartTime ()
UInt_t	GetPrestartTime ()
UInt_t	GetPrestartRunNumber ()
UInt_t	GetRunType ()
UInt_t	GetGoTime (int index=0)
UInt_t	GetGoEventCount (int index=0)
UInt_t	GetPauseTime (int index=0)
UInt_t	GetPauseEventCount (int index=0)
UInt_t	GetEndTime ()
UInt_t	GetEndEventCount ()
TString	GetStartSQLTime ()
TString	GetEndSQLTime ()
time_t	GetStartUnixTime ()
time_t	GetEndUnixTime ()

Static Public Member Functions
static void	DefineOptions (QwOptions &options)
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 }
Protected Types inherited from MQwCodaControlEvent
enum	EventTypes {   kSYNC_EVENT = 16, kPRESTART_EVENT = 17, kGO_EVENT = 18, kPAUSE_EVENT = 19,   kEND_EVENT = 20 }

Protected Member Functions
Int_t	GetFileEvent ()
Int_t	GetEtEvent ()
Int_t	WriteFileEvent (int *buffer)
Bool_t	DataFileIsSegmented ()
Int_t	CloseThisSegment ()
Int_t	OpenNextSegment ()
void	DecodeEventIDBank (UInt_t *buffer)
Bool_t	DecodeSubbankHeader (UInt_t *buffer)
const TString &	DataFile (const UInt_t run, const Short_t seg)
void	SetEventLength (const ULong_t tmplength)
void	SetEventType (const UInt_t tmptype)
void	SetWordsSoFar (const ULong_t tmpwords)
Protected Member Functions inherited from MQwCodaControlEvent
void	ProcessSync (UInt_t local_time, UInt_t statuscode)
void	ProcessPrestart (UInt_t local_time, UInt_t local_runnumber, UInt_t local_runtype)
void	ProcessGo (UInt_t local_time, UInt_t evt_count)
void	ProcessPause (UInt_t local_time, UInt_t evt_count)
void	ProcessEnd (UInt_t local_time, UInt_t evt_count)

Protected Attributes
Bool_t	fOnline
TString	fETHostname
TString	fETSession
TString	fETStationName
Bool_t	fChainDataFiles
std::pair< Int_t, Int_t >	fRunRange
std::string	fRunListFileName
QwParameterFile *	fRunListFile
std::vector< Int_t >	fRunRangeMinList
std::vector< Int_t >	fRunRangeMaxList
std::pair< UInt_t, UInt_t >	fEventRange
std::string	fEventListFileName
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
Bool_t	fPhysicsEventFlag
UInt_t	fEvtLength
UInt_t	fWordsSoFar
UInt_t	fEvtType
UInt_t	fEvtTag
UInt_t	fBankDataType
UInt_t	fIDBankNum
UInt_t	fEvtNumber
	CODA event number; only defined for physics events. More...
UInt_t	fEvtClass
UInt_t	fStatSum
Double_t	fCleanParameter [3]
	Scan data/clean data from the green monster. More...
UInt_t	fFragLength
UInt_t	fSubbankTag
UInt_t	fSubbankType
UInt_t	fSubbankNum
UInt_t	fROC
TStopwatch	fRunTimer
	Timer used for runlet processing loop. More...
TStopwatch	fStopwatch
	Timer used for internal timing. More...
UInt_t	fNumPhysicsEvents
UInt_t	fStartingPhysicsEvent
Protected Attributes inherited from MQwCodaControlEvent
Bool_t	fFoundControlEvents
UInt_t	fPrestartTime
UInt_t	fPrestartRunNumber
UInt_t	fRunType
UInt_t	fEndTime
UInt_t	fEndEventCount
UInt_t	fNumberPause
std::vector< UInt_t >	fPauseEventCount
std::vector< UInt_t >	fPauseTime
UInt_t	fNumberGo
std::vector< UInt_t >	fGoEventCount
std::vector< UInt_t >	fGoTime
UInt_t	fStartTime
TDatime	fPrestartDatime
TDatime	fStartDatime
TDatime	fEndDatime

Static Protected Attributes
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)

Detailed Description

Definition at line 33 of file QwEventBuffer.h.

Member Enumeration Documentation

enum QwEventBuffer::CodaStreamMode

protected

Enumerator
fEvStreamNull
fEvStreamFile
fEvStreamET

Definition at line 216 of file QwEventBuffer.h.

{fEvStreamNull, fEvStreamFile, fEvStreamET} fEvStreamMode;

Constructor & Destructor Documentation

QwEventBuffer::QwEventBuffer

(

)

Default constructor.

Definition at line 42 of file QwEventBuffer.cc.

References QwLog::endl(), fCleanParameter, fDataDirectory, globalEXIT, QwError, and sigint_handler().

  :    fDataFileStem(fDefaultDataFileStem),
       fDataFileExtension(fDefaultDataFileExtension),
       fEvStreamMode(fEvStreamNull),
       fEvStream(NULL),
       fCurrentRun(-1),
       fRunIsSegmented(kFALSE),
       fPhysicsEventFlag(kFALSE),
       fEvtNumber(0),
       fNumPhysicsEvents(0)
{
  //  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

  fDataDirectory = getenv("QW_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("/");
  }

  fCleanParameter[0] = 0.0;
  fCleanParameter[1] = 0.0;
  fCleanParameter[2] = 0.0;
}

Here is the call graph for this function:

virtual QwEventBuffer::~QwEventBuffer ( )

inlinevirtual

Definition at line 54 of file QwEventBuffer.h.

References fEvStream, and fRunListFile.

                           {
    // Delete event stream
    if (fEvStream != NULL) {
      delete fEvStream;
      fEvStream = NULL;
    }
    // Delete run list file
    if (fRunListFile != NULL) {
      delete fRunListFile;
      fRunListFile = NULL;
    }
  };

Member Function Documentation

Bool_t QwEventBuffer::AreRunletsSplit ( ) const

inline

Return true if file segments are being separated for.

Definition at line 76 of file QwEventBuffer.h.

References fChainDataFiles, and fRunIsSegmented.

Referenced by QwParityDB::GetAnalysisID(), QwParityDB::GetRunletID(), and QwParityDB::SetRunletID().

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

Here is the caller graph for this function:

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

private

Int_t QwEventBuffer::CloseDataFile

(

)

Definition at line 1162 of file QwEventBuffer.cc.

References fEvStream, fEvStreamFile, fEvStreamMode, and kFileHandleNotConfigured.

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

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

Here is the caller graph for this function:

Int_t QwEventBuffer::CloseETStream

(

)

Definition at line 1190 of file QwEventBuffer.cc.

References fEvStream, fEvStreamFile, fEvStreamMode, and kFileHandleNotConfigured.

Referenced by CloseStream().

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

Here is the caller graph for this function:

Int_t QwEventBuffer::CloseStream

(

)

Closes a currently open event stream.

Definition at line 339 of file QwEventBuffer.cc.

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

Referenced by main().

{
  //  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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Int_t QwEventBuffer::CloseThisSegment ( )

protected

Definition at line 1022 of file QwEventBuffer.cc.

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

Referenced by CloseStream(), and GetFileEvent().

{
  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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

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

protected

Definition at line 909 of file QwEventBuffer.cc.

References fDataDirectory, fDataFile, fDataFileExtension, and fDataFileStem.

Referenced by OpenDataFile(), and OpenNextSegment().

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

Here is the caller graph for this function:

Bool_t QwEventBuffer::DataFileIsSegmented ( )

protected

Definition at line 921 of file QwEventBuffer.cc.

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

Referenced by OpenDataFile().

{
  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 (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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void QwEventBuffer::DecodeEventIDBank ( UInt_t *  buffer )

protected

Definition at line 582 of file QwEventBuffer.cc.

References fBankDataType, fEvtClass, fEvtNumber, fEvtTag, fEvtType, fIDBankNum, fPhysicsEventFlag, fStatSum, fWordsSoFar, MQwCodaControlEvent::ProcessControlEvent(), SetEventLength(), SetEventType(), and SetWordsSoFar().

Referenced by FillSubsystemData(), and GetEvent().

{
  UInt_t local_datatype;
  UInt_t local_eventtype;

  fPhysicsEventFlag = kFALSE;

  if ( buffer[0] == 0 ){
    /*****************************************************************
     *  This buffer is empty.                                        *
     *****************************************************************/
    SetEventLength(1);     //  Pretend that there is one word.
    SetWordsSoFar(1);      //  Mark that we've read the word already.
    SetEventType(0);
    fEvtTag       = 0;
    fBankDataType = 0;
    fIDBankNum    = 0;
    fEvtNumber    = 0;
    fEvtClass     = 0;
    fStatSum      = 0;
  } else {
    /*****************************************************************
     *  This buffer contains data; fill the event ID parameters.     *
     *****************************************************************/
    //  First word is the number of long-words in the buffer.
    SetEventLength(buffer[0]+1);

    // Second word contains the event type, for CODA events.
    fEvtTag   = (buffer[1] & 0xFFFF0000) >> 16;  // (bits(31-16));
    local_datatype = (buffer[1] & 0xFF00) >> 8;  // (bits(15-8));
    fIDBankNum = (buffer[1] & 0xFF);             // (bits(7-0));
    if ( fIDBankNum == 0xCC) {
      //  This is a CODA event bank; the event type is equal to
      //  the event tag.
      local_eventtype = fEvtTag;
      SetEventType(local_eventtype);
      fBankDataType = local_datatype;

      // local_eventtype is unsigned int and always positive
      if (/* local_eventtype >= 0 && */ local_eventtype <= 15) {
        //  This is a physics event; record the event number, event
        //  classification, and status summary.
        fEvtNumber = buffer[4];
        fEvtClass  = buffer[5];
        fStatSum   = buffer[6];
  fPhysicsEventFlag = kTRUE;
        //  Now skip to the first ROC data bank.
        SetWordsSoFar(7);
      } else {
        //  This is not a physics event, but is still in the CODA
        //  event format.  The first two words have been examined.
        fEvtNumber = 0;
        fEvtClass  = 0;
        fStatSum   = 0;
        SetWordsSoFar(2);
  //  Run this event through the Control event processing.
  //  If it is not a control event, nothing will happen.
  ProcessControlEvent(fEvtType, &buffer[fWordsSoFar]);
      }
    } else {
      //  This is not an event in the CODA event bank format,
      //  but it still follows the CEBAF common event format.
      //  Arbitrarily set the event type to "fEvtTag".
      //  The first two words have been examined.
      SetEventType(fEvtTag);
      fEvtNumber = 0;
      fEvtClass  = 0;
      fStatSum   = 0;
      SetWordsSoFar(2);
    }
  }
  // std::cout<< 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)
  //     << std::endl;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Bool_t QwEventBuffer::DecodeSubbankHeader ( UInt_t *  buffer )

protected

Definition at line 872 of file QwEventBuffer.cc.

References QwLog::endl(), fEvtLength, fFragLength, fROC, fSubbankNum, fSubbankTag, fSubbankType, fWordsSoFar, and QwError.

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

                                                       {
  //  This function will decode the header information from
  //  either a ROC bank or a subbank.  It will also bump
  //  fWordsSoFar to be referring to the first word of
  //  the subbank's data.
  //
  //  NOTE TO DAQ PROGRAMMERS:
  //      All internal subbank tags MUST be defined to
  //      be greater than 31.
  Bool_t okay = kTRUE;
  if (fWordsSoFar == fEvtLength){
    //  We have reached the end of this event.
    okay = kFALSE;
  } else {
    fFragLength   = buffer[0] - 1;  // This is the number of words in the data block
    fSubbankTag   = (buffer[1]&0xFFFF0000)>>16; // Bits 16-31
    fSubbankType  = (buffer[1]&0xFF00)>>8;      // Bits 8-15
    fSubbankNum   = (buffer[1]&0xFF);           // Bits 0-7
    if (fSubbankTag<=31){
      //  Subbank tags between 0 and 31 indicate this is
      //  a ROC bank.
      fROC        = fSubbankTag;
      fSubbankTag = 0;
    }
    if (fWordsSoFar+2+fFragLength > fEvtLength){
      //  Trouble, because we'll have too many words!
      QwError << "fWordsSoFar+2+fFragLength=="<<fWordsSoFar+2+fFragLength
    << " and fEvtLength==" << fEvtLength
    << QwLog::endl;
      okay = kFALSE;
    }
    fWordsSoFar   += 2;
  }
  return okay;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void QwEventBuffer::DefineOptions ( QwOptions &  options )

static

Defines configuration options for QwEventBuffer class using QwOptions functionality.

Parameters

options

Options object

Definition at line 78 of file QwEventBuffer.cc.

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

Referenced by QwOptions::DefineOptions().

{
  // 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()
    ("runlist", po::value<string>()->default_value(""),
     "run list file example \n[5253]\n 234\n 246\n 256\n 345:456\n 567:789\n [5259]\n [5260]\n 0:10000\n [5261:5270]\n 9000:10000\n- for run 5253 it will analyze three individual events, and two event ranges \n- for run 5259 it will analyze the entire run (all segments) \n- for run 5260 it will analyze the first 10000 events \n- for runs 5261 through 5270 it will analyze the events 9000 through 10000)");
  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 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"); 
}

Here is the call graph for this function:

Here is the caller graph for this function:

Int_t QwEventBuffer::EncodeEndEvent

(

)

Definition at line 563 of file QwEventBuffer.cc.

References MQwCodaControlEvent::kEND_EVENT, MQwCodaControlEvent::ProcessEnd(), and WriteEvent().

Referenced by main().

{
  int buffer[5];
  int localtime = (int) time(0);
  int eventcount = 0;
  buffer[0] = 4; // length
  buffer[1] = ((kEND_EVENT << 16) | (0x01 << 8) | 0xCC);
  buffer[2] = localtime;
  buffer[3] = 0; // (unused)
  buffer[4] = eventcount;
  ProcessEnd(localtime, eventcount);
  return WriteEvent(buffer);
}

Here is the call graph for this function:

Here is the caller graph for this function:

Int_t QwEventBuffer::EncodeGoEvent

(

)

Definition at line 537 of file QwEventBuffer.cc.

References MQwCodaControlEvent::kGO_EVENT, MQwCodaControlEvent::ProcessGo(), and WriteEvent().

Referenced by main().

{
  int buffer[5];
  int localtime = (int) time(0);
  int eventcount = 0;
  buffer[0] = 4; // length
  buffer[1] = ((kGO_EVENT << 16) | (0x01 << 8) | 0xCC);
  buffer[2] = localtime;
  buffer[3] = 0; // (unused)
  buffer[4] = eventcount;
  ProcessGo(localtime, eventcount);
  return WriteEvent(buffer);
}

Here is the call graph for this function:

Here is the caller graph for this function:

Int_t QwEventBuffer::EncodePauseEvent

(

)

Definition at line 550 of file QwEventBuffer.cc.

References MQwCodaControlEvent::kPAUSE_EVENT, MQwCodaControlEvent::ProcessPause(), and WriteEvent().

{
  int buffer[5];
  int localtime = (int) time(0);
  int eventcount = 0;
  buffer[0] = 4; // length
  buffer[1] = ((kPAUSE_EVENT << 16) | (0x01 << 8) | 0xCC);
  buffer[2] = localtime;
  buffer[3] = 0; // (unused)
  buffer[4] = eventcount;
  ProcessPause(localtime, eventcount);
  return WriteEvent(buffer);
}

Here is the call graph for this function:

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

Definition at line 525 of file QwEventBuffer.cc.

References MQwCodaControlEvent::kPRESTART_EVENT, MQwCodaControlEvent::ProcessPrestart(), and WriteEvent().

Referenced by main().

{
  int buffer[5];
  int localtime = (int) time(0);
  buffer[0] = 4; // length
  buffer[1] = ((kPRESTART_EVENT << 16) | (0x01 << 8) | 0xCC);
  buffer[2] = localtime;
  buffer[3] = runnumber;
  buffer[4] = runtype;
  ProcessPrestart(localtime, runnumber, runtype);
  return WriteEvent(buffer);
}

Here is the call graph for this function:

Here is the caller graph for this function:

Int_t QwEventBuffer::EncodeSubsystemData

(

QwSubsystemArray &

subsystems

)

Definition at line 486 of file QwEventBuffer.cc.

References QwSubsystemArray::EncodeEventData(), fEvtNumber, and WriteEvent().

Referenced by main().

{
  // Encode the data in the elements of the subsystem array
  std::vector<UInt_t> buffer;
   subsystems.EncodeEventData(buffer);

  // Add CODA event header
  std::vector<UInt_t> header;
  header.push_back((0x0001 << 16) | (0x10 << 8) | 0xCC);
    // event type | event data type | event ID (0xCC for CODA event)
  header.push_back(4);  // size of header field
  header.push_back((0xC000 << 16) | (0x01 << 8) | 0x00);
    // bank type | bank data type (0x01 for uint32) | bank ID (0x00 for header event)
  header.push_back(++fEvtNumber); // event number (initialized to 0,
    // so increment before use to agree with CODA number)
  header.push_back(1);  // event class
  header.push_back(0);  // status summary

  // 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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Bool_t QwEventBuffer::FillEPICSData

(

QwEPICSEvent &

epics

)

Definition at line 798 of file QwEventBuffer.cc.

References DecodeSubbankHeader(), QwLog::endl(), QwEPICSEvent::ExtractEPICSValues(), fBankDataType, fEvStream, fFragLength, fSubbankType, fWordsSoFar, GetEventNumber(), IsEPICSEvent(), kNullDataWord, QwError, and QwVerbose.

Referenced by main().

{
  // 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 (fBankDataType==0x10){
    while ((okay = DecodeSubbankHeader(&localbuff[fWordsSoFar]))){
    //  If this bank has further subbanks, restart the loop.
    if (fSubbankType == 0x10) continue;
    //  If this bank only contains the word 'NULL' then skip
    //  this bank.
    if (fFragLength==1 && localbuff[fWordsSoFar]==kNullDataWord){
      fWordsSoFar += fFragLength;
      continue;
    }

    if (fSubbankType == 0x3){
      //  This is an ASCII string bank.  Try to decode it and
      //  pass it to the EPICS class.
      char* tmpchar = (Char_t*)&localbuff[fWordsSoFar];

      epics.ExtractEPICSValues(string(tmpchar), GetEventNumber());
      QwVerbose << "test for GetEventNumber =" << GetEventNumber() << QwLog::endl;// always zero, wrong.

    }


    fWordsSoFar += fFragLength;

//     QwDebug << "QwEventBuffer::FillEPICSData:  "
//      << "Ending loop: fWordsSoFar=="<<fWordsSoFar
//      <<QwLog::endl;
//     QwMessage<<"\nQwEventBuffer::FillEPICSData: fWordsSoFar = "<<fWordsSoFar<<QwLog::endl;


  }
  } else {
    // Single bank in the event, use event headers.
    if (fBankDataType == 0x3){
      //  This is an ASCII string bank.  Try to decode it and
      //  pass it to the EPICS class.
      Char_t* tmpchar = (Char_t*)&localbuff[fWordsSoFar];

      QwError << tmpchar << QwLog::endl;

      epics.ExtractEPICSValues(string(tmpchar), GetEventNumber());

    }

  }

  //std::cout<<"\nEpics data coming!! "<<fWordsSoFar<<std::endl;

  return okay;
}

Here is the call graph for this function:

Here is the caller graph for this function:

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 UInt_t roc_id, const UInt_t bank_id, const UInt_t banktype, UInt_t* buffer, UInt_t num_words);

Definition at line 261 of file QwEventBuffer.h.

References DecodeSubbankHeader(), fBankDataType, fEvStream, fEvtLength, fEvtType, fFragLength, fROC, fSubbankTag, fSubbankType, fWordsSoFar, and kNullDataWord.

                                                                           {
  ///  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 UInt_t roc_id, const UInt_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 (fFragLength==1 && localbuff[fWordsSoFar]==kNullDataWord){
    fWordsSoFar += fFragLength;
  } else if (object.CanUseThisEventType(fEvtType)){
    //  Clear the old event information from the object
    object.ClearEventData(fEvtType);
    //  Loop through the data buffer in this event.
    if (fBankDataType == 0x10){
      //  This bank is subbanked; loop through subbanks
      while ((okay = DecodeSubbankHeader(&localbuff[fWordsSoFar]))){
  //  If this bank has further subbanks, restart the loop.
  if (fSubbankType == 0x10) continue;
  //  If this bank only contains the word 'NULL' then skip
  //  this bank.
  if (fFragLength==1 && localbuff[fWordsSoFar]==kNullDataWord){
    fWordsSoFar += fFragLength;
    continue;
  }
  object.ProcessBuffer(fEvtType, fROC, fSubbankTag, fSubbankType,
           &localbuff[fWordsSoFar],
           fFragLength);
  fWordsSoFar += fFragLength;
      }
    } else {
      //  This is a single bank of some type
      object.ProcessBuffer(fEvtType, 0, fBankDataType,
         &localbuff[fWordsSoFar],
         fEvtLength);
    }
  }
  return okay;
}

Here is the call graph for this function:

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 663 of file QwEventBuffer.cc.

References DecodeSubbankHeader(), QwLog::endl(), fEvStream, fEvtClass, fEvtNumber, fEvtType, fFragLength, fSubbankTag, fSubbankType, fWordsSoFar, kNullDataWord, QwSubsystemArray::ProcessConfigurationBuffer(), QwDebug, and QwMessage.

Referenced by main().

{
  ///  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 = fEvtType - 0x90;
  QwMessage << "QwEventBuffer::FillSubsystemConfigurationData:  "
      << "Found configuration event for ROC"
      << rocnum
      << QwLog::endl;
  QwMessage << Form("Evt type: 0x%x; Evt number %d; Evt Class 0x%.8x; ",
         fEvtType, fEvtNumber, fEvtClass)
      << QwLog::endl;
  //  Loop through the data buffer in this event.
  UInt_t *localbuff = (UInt_t*)(fEvStream->getEvBuffer());
  while ((okay = DecodeSubbankHeader(&localbuff[fWordsSoFar]))){
    //  If this bank has further subbanks, restart the loop.
    if (fSubbankType == 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 (fFragLength==1 && localbuff[fWordsSoFar]==kNullDataWord){
      fWordsSoFar += fFragLength;
      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, fSubbankTag,
            &localbuff[fWordsSoFar],
            fFragLength);
    fWordsSoFar += fFragLength;
    QwDebug << "QwEventBuffer::FillSubsystemConfigurationData:  "
      << "Ending loop: fWordsSoFar=="<<fWordsSoFar
      <<QwLog::endl;
  }
  return okay;
}

Here is the call graph for this function:

Here is the caller graph for this function:

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

private

Bool_t QwEventBuffer::FillSubsystemData

(

QwSubsystemArray &

subsystems

)

Definition at line 715 of file QwEventBuffer.cc.

References QwSubsystemArray::ClearEventData(), DecodeEventIDBank(), DecodeSubbankHeader(), fCleanParameter, fCurrentRun, fEvStream, fEvtNumber, fEvtType, fFragLength, fROC, fRunIsSegmented, fRunSegmentIterator, fSubbankTag, fSubbankType, fWordsSoFar, QwSubsystemArray::GetEventTypeMask(), kNullDataWord, QwSubsystemArray::ProcessEvBuffer(), QwSubsystemArray::SetCleanParameters(), QwSubsystemArray::SetCodaEventNumber(), QwSubsystemArray::SetCodaEventType(), QwSubsystemArray::SetCodaRunNumber(), and QwSubsystemArray::SetCodaSegmentNumber().

Referenced by main().

{
  //  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());
  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(fEvtNumber);
  subsystems.SetCodaEventType(fEvtType);



  // If this event type is masked for the subsystem array, return right away
  if (((0x1 << (fEvtType - 1)) & subsystems.GetEventTypeMask()) == 0) {
    return kTRUE;
  }

  //  Loop through the data buffer in this event.
  while ((okay = DecodeSubbankHeader(&localbuff[fWordsSoFar]))){

    //  If this bank has further subbanks, restart the loop.
    if (fSubbankType == 0x10) continue;

    //  If this bank only contains the word 'NULL' then skip
    //  this bank.
    if (fFragLength == 1 && localbuff[fWordsSoFar]==kNullDataWord) {
      fWordsSoFar += fFragLength;
      continue;
    }

    // if (fSubbankType == 0x85) {
    //   std::cout << "ProcessEventBuffer: , SubbankTag= "<< fSubbankTag<<" FragLength="<<fFragLength <<std::endl;
    // }

//     QwDebug << "QwEventBuffer::FillSubsystemData:  "
//      << "Beginning loop: fWordsSoFar=="<<fWordsSoFar
//      <<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.

    if( fROC == 0 && fSubbankTag==0x6101) {
      //std::cout << "ProcessEventBuffer: ROC="<<fROC<<", SubbankTag="<< fSubbankTag<<", FragLength="<<fFragLength <<std::endl;
      fCleanParameter[0]=localbuff[fWordsSoFar+fFragLength-4];//clean data
      fCleanParameter[1]=localbuff[fWordsSoFar+fFragLength-3];//scan data 1
      fCleanParameter[2]=localbuff[fWordsSoFar+fFragLength-2];//scan data 2
      //std::cout << "ProcessEventBuffer: ROC="<<fROC<<", SubbankTag="<< fSubbankTag
      //    <<", FragLength="<<fFragLength << " " <<fCleanParameter[0]<< " " <<fCleanParameter[1]<< " " <<fCleanParameter[2]<<std::endl;

    }
    
    subsystems.SetCleanParameters(fCleanParameter);

    subsystems.ProcessEvBuffer(fEvtType, fROC, fSubbankTag,
             &localbuff[fWordsSoFar],
             fFragLength);
    fWordsSoFar += fFragLength;
//     QwDebug << "QwEventBuffer::FillSubsystemData:  "
//      << "Ending loop: fWordsSoFar=="<<fWordsSoFar
//      <<QwLog::endl;
  }
  return okay;
}

Here is the call graph for this function:

Here is the caller graph for this function:

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

private

const TString& QwEventBuffer::GetDataFile ( ) const

inline

Definition at line 98 of file QwEventBuffer.h.

References fDataFile.

{return fDataFile;};

Int_t QwEventBuffer::GetEtEvent ( )

protected

Definition at line 452 of file QwEventBuffer.cc.

References fEvStream, and globalEXIT.

Referenced by GetEvent().

                               {
  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_EXIT)
    globalEXIT = 1;
  return status;
}

Here is the caller graph for this function:

Int_t QwEventBuffer::GetEvent

(

)

Definition at line 419 of file QwEventBuffer.cc.

References DecodeEventIDBank(), fEvStream, fEvStreamET, fEvStreamFile, fEvStreamMode, GetEtEvent(), GetFileEvent(), kFileHandleNotConfigured, and ResetFlags().

Referenced by GetNextEvent(), main(), and QwTrackingDataserver::NextEvent().

{
  Int_t status = kFileHandleNotConfigured;
  ResetFlags();
  if (fEvStreamMode==fEvStreamFile){
    status = GetFileEvent();
  } else if (fEvStreamMode==fEvStreamET){
    status = GetEtEvent();
  }
  if (status == CODA_OK){
    DecodeEventIDBank((UInt_t*)(fEvStream->getEvBuffer()));
  }
  return status;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Int_t QwEventBuffer::GetEventNumber ( )

inline

Definition at line 115 of file QwEventBuffer.h.

References fEvtNumber.

Referenced by FillEPICSData(), and main().

{ return fEvtNumber; };

Here is the caller graph for this function:

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

inline

Definition at line 86 of file QwEventBuffer.h.

References fEventRange.

Referenced by QwParityDB::SetAnalysisID().

                                                {
    return fEventRange;
  };

Here is the caller graph for this function:

Int_t QwEventBuffer::GetFileEvent ( )

protected

Definition at line 434 of file QwEventBuffer.cc.

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

Referenced by GetEvent().

                                 {
  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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Int_t QwEventBuffer::GetNextEvent

(

)

Definition at line 363 of file QwEventBuffer.cc.

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

Referenced by main().

{
  //  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 (fEvtNumber > fEventRange.second) {
      do {
        if (GetNextEventRange()) status = CODA_OK;
        else status = EOF;
      } while (fEvtNumber < 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 = fEvtNumber + 1;
      if (fEvtNumber > 1000) status = EOF;
    }
  } while (status == CODA_OK  &&
           IsPhysicsEvent()   &&
           (fEvtNumber < fEventRange.first
         || fEvtNumber > fEventRange.second)
          );
  if (status == CODA_OK  && IsPhysicsEvent()) fNumPhysicsEvents++;

  //  Progress meter (this should probably produce less output in production)
  int nevents = 10000;
  if (IsPhysicsEvent() && fEvtNumber > 0 && fEvtNumber % nevents == 0) {
    QwMessage << "Processing event " << fEvtNumber << " ";
    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 (fEvtNumber > 0 && fEvtNumber % 100 == 0) {
    QwVerbose << "Processing event " << fEvtNumber << QwLog::endl;
  }

  return status;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Bool_t QwEventBuffer::GetNextEventRange

(

)

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

Definition at line 202 of file QwEventBuffer.cc.

References QwLog::endl(), fEventListFile, fEventRange, QwParameterFile::IsEOF(), QwParameterFile::LineIsEmpty(), QwParameterFile::ParseIntRange(), QwMessage, QwParameterFile::ReadNextLine(), QwParameterFile::TrimComment(), and QwParameterFile::TrimWhitespace().

Referenced by GetNextEvent(), and GetNextRunRange().

                                        {
  // 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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Bool_t QwEventBuffer::GetNextRunNumber

(

)

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

Definition at line 246 of file QwEventBuffer.cc.

References fCurrentRun, fRunRange, and GetNextRunRange().

Referenced by OpenNextStream().

                                       {
  // 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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Bool_t QwEventBuffer::GetNextRunRange

(

)

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

Definition at line 223 of file QwEventBuffer.cc.

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

Referenced by GetNextRunNumber(), and ProcessOptions().

                                      {
  // Delete any open event list file before moving to next run
  if (fEventListFile) delete fEventListFile;
  // 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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

TString QwEventBuffer::GetRunLabel

(

)

const

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

Definition at line 263 of file QwEventBuffer.cc.

References fChainDataFiles, fCurrentRun, fRunIsSegmented, and fRunSegmentIterator.

Referenced by main().

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

Here is the caller graph for this function:

Int_t QwEventBuffer::GetRunNumber ( ) const

inline

Return CODA file run number.

Definition at line 80 of file QwEventBuffer.h.

References fCurrentRun.

Referenced by QwParityDB::GetAnalysisID(), QwParityDB::GetRunID(), QwParityDB::GetRunletID(), main(), PrintRunTimes(), QwParityDB::SetRunID(), QwParityDB::SetRunletID(), and QwParityDB::SetupOneRun().

{return fCurrentRun;};

Here is the caller graph for this function:

Int_t QwEventBuffer::GetSegmentNumber ( ) const

inline

Return CODA file segment number.

Definition at line 82 of file QwEventBuffer.h.

References fRunSegmentIterator, and fRunSegments.

Referenced by QwParityDB::GetAnalysisID(), GetNextEvent(), QwParityDB::GetRunletID(), main(), and QwParityDB::SetRunletID().

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

Here is the caller graph for this function:

Bool_t QwEventBuffer::IsEPICSEvent ( )

inline

Definition at line 130 of file QwEventBuffer.h.

References fEvtType.

Referenced by FillEPICSData(), and main().

                       {
    //  What are the correct codes for our EPICS events?
    //return (fEvtType>=160 && fEvtType<=170);// epics event type is only with tag="160"
    return (fEvtType>=160 && fEvtType<=190);// epics event type is only with tag="180" from July 2010 running
  };

Here is the caller graph for this function:

Bool_t QwEventBuffer::IsPhysicsEvent ( )

inline

Definition at line 110 of file QwEventBuffer.h.

References fEvtType, and fIDBankNum.

Referenced by GetNextEvent(), and main().

                          {
    // fEvtType is an unsigned integer, hence always positive
    return ((fIDBankNum == 0xCC) && ( /* fEvtType >= 0 && */ fEvtType <= 15));
  };

Here is the caller graph for this function:

Bool_t QwEventBuffer::IsROCConfigurationEvent ( )

inline

Definition at line 126 of file QwEventBuffer.h.

References fEvtType.

Referenced by main().

                                  {
    return (fEvtType>=0x90 && fEvtType<=0xaf);
  };

Here is the caller graph for this function:

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

Definition at line 1078 of file QwEventBuffer.cc.

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

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

{
  fCurrentRun = current_run;

  fRunSegments.clear();
  fRunIsSegmented = kTRUE;

  fRunSegments.push_back(seg);
  fRunSegmentIterator = fRunSegments.begin();
  return OpenNextSegment();
}

Here is the call graph for this function:

Here is the caller graph for this function:

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

Definition at line 1092 of file QwEventBuffer.cc.

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

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

Here is the call graph for this function:

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

Definition at line 1108 of file QwEventBuffer.cc.

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

{
  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);
}

Here is the call graph for this function:

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

Definition at line 1172 of file QwEventBuffer.cc.

References fEvStream, fEvStreamET, fEvStreamMode, and fEvStreamNull.

Referenced by OpenNextStream(), and ReOpenStream().

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

Here is the caller graph for this function:

Int_t QwEventBuffer::OpenNextSegment ( )

protected

Definition at line 1043 of file QwEventBuffer.cc.

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

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

{
  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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Int_t QwEventBuffer::OpenNextStream

(

)

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

Definition at line 293 of file QwEventBuffer.cc.

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

Referenced by main().

{
  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, 0, 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
  && fEvtNumber <= 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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void QwEventBuffer::PrintRunTimes

(

)

Definition at line 185 of file QwEventBuffer.cc.

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

Referenced by main().

{
  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;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void QwEventBuffer::ProcessOptions

(

QwOptions &

options

)

Sets internal flags based on the QwOptions.

Definition at line 120 of file QwEventBuffer.cc.

References QwLog::endl(), fChainDataFiles, fCurrentRun, fDataFileExtension, fDataFileStem, fETHostname, fETSession, fETStationName, fEventListFile, fEventRange, fOnline, fRunListFile, fRunListFileName, fRunRange, fSegmentRange, QwOptions::GetIntValuePair(), QwParameterFile::GetLine(), GetNextRunRange(), QwOptions::GetValue(), QwOptions::HasValue(), QwError, and QwWarning.

Referenced by main().

{
  fOnline     = options.GetValue<bool>("online");
  if (fOnline){
#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)
  tmp += " \"HOSTNAME\"";
      if (fETSession == NULL){
  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
  }
  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");

  // Open run list file
  if (fRunListFileName.size() > 0) {
    fRunListFile = new QwParameterFile(fRunListFileName);
    fEventListFile = 0;
    if (! GetNextRunRange()) {
      QwWarning << "No run range found in run list file: " << fRunListFile->GetLine() << QwLog::endl;
    }
  } else {
    fRunListFile = 0;
    fEventListFile = 0;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

Int_t QwEventBuffer::ReOpenStream

(

)

Definition at line 272 of file QwEventBuffer.cc.

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

Referenced by main().

{
  Int_t status = CODA_ERROR;
  //  Reset the physics event counter
  fNumPhysicsEvents = fStartingPhysicsEvent;

  if (fOnline) {
    // Online stream
    status = OpenETStream(fETHostname, fETSession, 0, fETStationName);
  } else {
    // Offline data file
    if (fRunIsSegmented)
      // Segmented
      status = OpenNextSegment();
    else
      // Not segmented
      status = OpenDataFile(fCurrentRun);
  }
  return status;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void QwEventBuffer::ResetFlags

(

)

Definition at line 578 of file QwEventBuffer.cc.

Referenced by GetEvent(), and WriteEvent().

                              {
}

Here is the caller graph for this function:

void QwEventBuffer::SetDataDirectory ( const TString  datadir )

inline

Definition at line 95 of file QwEventBuffer.h.

References fDataDirectory.

{fDataDirectory = datadir;}

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

inlinestatic

Definition at line 39 of file QwEventBuffer.h.

References fDefaultDataFileExtension.

                                                                      {
  fDefaultDataFileExtension = extension;
  }

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

inlinestatic

Definition at line 36 of file QwEventBuffer.h.

References fDefaultDataFileStem.

Referenced by main().

                                                            {
  fDefaultDataFileStem = stem;
  }

Here is the caller graph for this function:

void QwEventBuffer::SetEventLength ( const ULong_t  tmplength )

inlineprotected

Definition at line 209 of file QwEventBuffer.h.

References fEvtLength.

Referenced by DecodeEventIDBank().

{fEvtLength = tmplength;};

Here is the caller graph for this function:

void QwEventBuffer::SetEventType ( const UInt_t  tmptype )

inlineprotected

Definition at line 210 of file QwEventBuffer.h.

References fEvtType.

Referenced by DecodeEventIDBank().

{fEvtType = tmptype;};

Here is the caller graph for this function:

void QwEventBuffer::SetWordsSoFar ( const ULong_t  tmpwords )

inlineprotected

Definition at line 211 of file QwEventBuffer.h.

References fWordsSoFar.

Referenced by DecodeEventIDBank().

{fWordsSoFar = tmpwords;};

Here is the caller graph for this function:

Int_t QwEventBuffer::WriteEvent

(

int *

buffer

)

Definition at line 463 of file QwEventBuffer.cc.

References QwLog::endl(), fEvStreamET, fEvStreamFile, fEvStreamMode, kFileHandleNotConfigured, QwMessage, ResetFlags(), and WriteFileEvent().

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

{
  Int_t status = kFileHandleNotConfigured;
  ResetFlags();
  if (fEvStreamMode==fEvStreamFile){
    status = WriteFileEvent(buffer);
  } else if (fEvStreamMode==fEvStreamET) {
    QwMessage << "No support for writing to ET streams" << QwLog::endl;
    status = CODA_ERROR;
  }
  return status;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Int_t QwEventBuffer::WriteFileEvent ( int *  buffer )

protected

Definition at line 476 of file QwEventBuffer.cc.

References fEvStream.

Referenced by WriteEvent().

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

Here is the caller graph for this function:

Field Documentation

UInt_t QwEventBuffer::fBankDataType

protected

Definition at line 237 of file QwEventBuffer.h.

Referenced by DecodeEventIDBank(), FillEPICSData(), and FillObjectWithEventData().

Bool_t QwEventBuffer::fChainDataFiles

protected

Definition at line 166 of file QwEventBuffer.h.

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

Double_t QwEventBuffer::fCleanParameter[3]

protected

Scan data/clean data from the green monster.

Definition at line 244 of file QwEventBuffer.h.

Referenced by FillSubsystemData(), and QwEventBuffer().

Int_t QwEventBuffer::fCurrentRun

protected

Definition at line 219 of file QwEventBuffer.h.

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

TString QwEventBuffer::fDataDirectory

protected

Definition at line 187 of file QwEventBuffer.h.

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

TString QwEventBuffer::fDataFile

protected

Definition at line 188 of file QwEventBuffer.h.

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

TString QwEventBuffer::fDataFileExtension

protected

Definition at line 185 of file QwEventBuffer.h.

Referenced by DataFile(), and ProcessOptions().

TString QwEventBuffer::fDataFileStem

protected

Definition at line 184 of file QwEventBuffer.h.

Referenced by DataFile(), and ProcessOptions().

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

staticprotected

Definition at line 182 of file QwEventBuffer.h.

Referenced by DefineOptions(), and SetDefaultDataFileExtension().

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

staticprotected

Definition at line 181 of file QwEventBuffer.h.

Referenced by DefineOptions(), and SetDefaultDataFileStem().

TString QwEventBuffer::fETHostname

protected

Definition at line 162 of file QwEventBuffer.h.

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

TString QwEventBuffer::fETSession

protected

Definition at line 163 of file QwEventBuffer.h.

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

TString QwEventBuffer::fETStationName

protected

Definition at line 164 of file QwEventBuffer.h.

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

std::vector<UInt_t> QwEventBuffer::fEventList

protected

Definition at line 175 of file QwEventBuffer.h.

QwParameterFile* QwEventBuffer::fEventListFile

protected

Definition at line 174 of file QwEventBuffer.h.

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

std::string QwEventBuffer::fEventListFileName

protected

Definition at line 173 of file QwEventBuffer.h.

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

protected

Definition at line 172 of file QwEventBuffer.h.

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

THaCodaData* QwEventBuffer::fEvStream

protected

Definition at line 217 of file QwEventBuffer.h.

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

enum QwEventBuffer::CodaStreamMode QwEventBuffer::fEvStreamMode

protected

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

UInt_t QwEventBuffer::fEvtClass

protected

Definition at line 241 of file QwEventBuffer.h.

Referenced by DecodeEventIDBank(), and FillSubsystemConfigurationData().

UInt_t QwEventBuffer::fEvtLength

protected

Definition at line 231 of file QwEventBuffer.h.

Referenced by DecodeSubbankHeader(), FillObjectWithEventData(), and SetEventLength().

UInt_t QwEventBuffer::fEvtNumber

protected

CODA event number; only defined for physics events.

Definition at line 240 of file QwEventBuffer.h.

Referenced by DecodeEventIDBank(), EncodeSubsystemData(), FillSubsystemConfigurationData(), FillSubsystemData(), GetEventNumber(), GetNextEvent(), and OpenNextStream().

UInt_t QwEventBuffer::fEvtTag

protected

Definition at line 236 of file QwEventBuffer.h.

Referenced by DecodeEventIDBank().

UInt_t QwEventBuffer::fEvtType

protected

Definition at line 234 of file QwEventBuffer.h.

Referenced by DecodeEventIDBank(), FillObjectWithEventData(), FillSubsystemConfigurationData(), FillSubsystemData(), IsEPICSEvent(), IsPhysicsEvent(), IsROCConfigurationEvent(), and SetEventType().

UInt_t QwEventBuffer::fFragLength

protected

Definition at line 246 of file QwEventBuffer.h.

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

UInt_t QwEventBuffer::fIDBankNum

protected

Definition at line 238 of file QwEventBuffer.h.

Referenced by DecodeEventIDBank(), and IsPhysicsEvent().

UInt_t QwEventBuffer::fNumPhysicsEvents

protected

Definition at line 256 of file QwEventBuffer.h.

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

Bool_t QwEventBuffer::fOnline

protected

Definition at line 161 of file QwEventBuffer.h.

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

Bool_t QwEventBuffer::fPhysicsEventFlag

protected

Definition at line 229 of file QwEventBuffer.h.

Referenced by DecodeEventIDBank().

UInt_t QwEventBuffer::fROC

protected

Definition at line 250 of file QwEventBuffer.h.

Referenced by DecodeSubbankHeader(), FillObjectWithEventData(), and FillSubsystemData().

Bool_t QwEventBuffer::fRunIsSegmented

protected

Definition at line 221 of file QwEventBuffer.h.

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

QwParameterFile* QwEventBuffer::fRunListFile

protected

Definition at line 169 of file QwEventBuffer.h.

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

std::string QwEventBuffer::fRunListFileName

protected

Definition at line 168 of file QwEventBuffer.h.

Referenced by ProcessOptions().

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

protected

Definition at line 167 of file QwEventBuffer.h.

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

std::vector<Int_t> QwEventBuffer::fRunRangeMaxList

protected

Definition at line 170 of file QwEventBuffer.h.

std::vector<Int_t> QwEventBuffer::fRunRangeMinList

protected

Definition at line 170 of file QwEventBuffer.h.

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

protected

Definition at line 225 of file QwEventBuffer.h.

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

std::vector<Int_t> QwEventBuffer::fRunSegments

protected

Definition at line 224 of file QwEventBuffer.h.

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

TStopwatch QwEventBuffer::fRunTimer

protected

Timer used for runlet processing loop.

Definition at line 252 of file QwEventBuffer.h.

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

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

protected

Definition at line 177 of file QwEventBuffer.h.

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

UInt_t QwEventBuffer::fStartingPhysicsEvent

protected

Definition at line 257 of file QwEventBuffer.h.

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

UInt_t QwEventBuffer::fStatSum

protected

Definition at line 242 of file QwEventBuffer.h.

Referenced by DecodeEventIDBank().

TStopwatch QwEventBuffer::fStopwatch

protected

Timer used for internal timing.

Definition at line 253 of file QwEventBuffer.h.

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

UInt_t QwEventBuffer::fSubbankNum

protected

Definition at line 249 of file QwEventBuffer.h.

Referenced by DecodeSubbankHeader().

UInt_t QwEventBuffer::fSubbankTag

protected

Definition at line 247 of file QwEventBuffer.h.

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

UInt_t QwEventBuffer::fSubbankType

protected

Definition at line 248 of file QwEventBuffer.h.

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

UInt_t QwEventBuffer::fWordsSoFar

protected

Definition at line 232 of file QwEventBuffer.h.

Referenced by DecodeEventIDBank(), DecodeSubbankHeader(), FillEPICSData(), FillObjectWithEventData(), FillSubsystemConfigurationData(), FillSubsystemData(), and SetWordsSoFar().

const Int_t QwEventBuffer::kFileHandleNotConfigured = -40

static

Definition at line 46 of file QwEventBuffer.h.

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

const Int_t QwEventBuffer::kNoNextDataFile = -30

static

Definition at line 45 of file QwEventBuffer.h.

Referenced by OpenNextSegment().

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 48 of file QwEventBuffer.h.

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

const Int_t QwEventBuffer::kRunNotSegmented = -20

static

Definition at line 44 of file QwEventBuffer.h.

Referenced by OpenNextSegment().

---

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

• QwEventBuffer.h
• QwEventBuffer.cc