ManagedMonitorToolBase::OfflineStream Class Reference

#include <ManagedMonitorToolBase.h>

Inheritance diagram for ManagedMonitorToolBase::OfflineStream:

Collaboration diagram for ManagedMonitorToolBase::OfflineStream:

Public Member Functions
	OfflineStream (const std::string &fileKey, AthenaMonManager::DataType_t, AthenaMonManager::Environment_t)
virtual	~OfflineStream ()
virtual std::string	getStreamName (const ManagedMonitorToolBase *tool, const MonGroup &group, const std::string &objName, bool usePreviousInterval=false)
	A function that converts a MonGroup of logical parameters into a physical output stream name. More...
virtual std::string	getDirectoryName (const ManagedMonitorToolBase *tool, const MonGroup &group, const std::string &objName, const bool usePreviousInterval)
	A function that returns TDirectory path in a file that corresponds to a given MonGroup and object name. More...
void	updateRunLB ()

Static Public Member Functions
static void	parseString (const std::string &streamName, std::string &root, std::string &rem)
	A helper non-virtual function, parses id string. More...

Private Member Functions
	OfflineStream ()
void	getLBrange (int *, int *, int, int)

Private Attributes
const std::string	m_fileKey
uint32_t	m_prev_run_number
uint32_t	m_prev_lumi_block
std::set< std::string >	m_ebNames

Detailed Description

Definition at line 814 of file ManagedMonitorToolBase.h.

Constructor & Destructor Documentation

OfflineStream() [1/2]

ManagedMonitorToolBase::OfflineStream::OfflineStream ( const std::string &  fileKey, AthenaMonManager::DataType_t  , AthenaMonManager::Environment_t    )

inline

Definition at line 816 of file ManagedMonitorToolBase.h.

               : m_fileKey(fileKey),
                 m_prev_run_number(0),
                 m_prev_lumi_block(0) { }

~OfflineStream()

virtual ManagedMonitorToolBase::OfflineStream::~OfflineStream ( )

inlinevirtual

Definition at line 822 of file ManagedMonitorToolBase.h.

{ }

OfflineStream() [2/2]

ManagedMonitorToolBase::OfflineStream::OfflineStream ( )

inlineprivate

Definition at line 828 of file ManagedMonitorToolBase.h.

{ }

Member Function Documentation

getDirectoryName()

std::string ManagedMonitorToolBase::OfflineStream::getDirectoryName ( const ManagedMonitorToolBase *  tool, const MonGroup &  group, const std::string &  objName, const bool  usePreviousInterval  )

virtual

A function that returns TDirectory path in a file that corresponds to a given MonGroup and object name.

Implements ManagedMonitorToolBase::StreamNameFcn.

Definition at line 2304 of file ManagedMonitorToolBase.cxx.

{
    std::string streamName = getStreamName(tool, group, objName, usePreviousInterval);
    std::string root, rem;
    parseString(streamName, root, rem);
    // Remove object name at the end
    // to obtain directory path
    rem.erase(rem.rfind('/'), rem.length()); 
    return rem;
}

getLBrange()

void ManagedMonitorToolBase::OfflineStream::getLBrange ( int *  start, int *  end, int  LB, int  length  )

private

Definition at line 2207 of file ManagedMonitorToolBase.cxx.

                                                     {
   if(start && end) {
      *start = ((LB-1)/length) * length + 1;
      *end = *start + length - 1;
   }
}

getStreamName()

std::string ManagedMonitorToolBase::OfflineStream::getStreamName ( const ManagedMonitorToolBase *  tool, const MonGroup &  group, const std::string &  objName, bool  usePreviousInterval = false  )

virtual

A function that converts a MonGroup of logical parameters into a physical output stream name.

Implements ManagedMonitorToolBase::StreamNameFcn.

Definition at line 2216 of file ManagedMonitorToolBase.cxx.

{
   std::ostringstream streamName;
 
   //bool isTemp =    ( group.level() == ManagedMonitorToolBase::transient );
   bool isTemp = false;
 
   bool useRunFolders = group.interval() != all;
 
   bool useLBFolders =    ( useRunFolders )
      && ( group.interval() == ManagedMonitorToolBase::lumiBlock );
 
   bool useLowStatInterval =    ( useRunFolders )
      && ( group.interval() == ManagedMonitorToolBase::lowStat );
 
   bool useMedStatInterval =    ( useRunFolders )
      && ( group.interval() == ManagedMonitorToolBase::medStat );
 
   bool useHigStatInterval =    ( useRunFolders )
      && ( group.interval() == ManagedMonitorToolBase::higStat );
 
   bool useEBFolders = ( group.interval() == ManagedMonitorToolBase::eventsBlock );
 
   if( !isTemp ) {
      streamName << "/" << m_fileKey << "/";
   }
 
   if( useRunFolders ) {
      if (usePreviousInterval && (group.interval() == ManagedMonitorToolBase::run) )
          streamName << "run_" << m_prev_run_number << "/";
      else
          streamName << "run_" << AthenaMonManager::runNumber() << "/";
   }
 
   int currentLB = AthenaMonManager::lumiBlockNumber();
   if( useLBFolders ) {
      if (usePreviousInterval && (group.interval() == ManagedMonitorToolBase::lumiBlock) )
          streamName << "lb_" << m_prev_lumi_block << "/";
      else
          streamName << "lb_" << currentLB << "/";
   }
   else if( useLowStatInterval ) {
      int start, end;
      if (usePreviousInterval && (group.interval() == ManagedMonitorToolBase::lowStat) )
          getLBrange(&start, &end, m_prev_lumi_block, AthenaMonManager::getLBsLowStat());
      else
          getLBrange(&start, &end, currentLB, AthenaMonManager::getLBsLowStat());
      streamName << "lowStat_LB" << start << "-" << end << "/";
   }
   else if( useMedStatInterval ) {
      int start, end;
      getLBrange(&start, &end, currentLB, AthenaMonManager::getLBsMedStat());
      streamName << "medStat_LB" << start << "-" << end << "/";
   }
   else if( useHigStatInterval ) {
      int start, end;
      getLBrange(&start, &end, currentLB, AthenaMonManager::getLBsHigStat());
      streamName << "higStat_LB" << start << "-" << end << "/";
   }
   else if( useEBFolders ) {
      // The number of events in an EventsBlock can vary for each ManagedMonitorToolBase object,
      // so there is no global way to determine when an EventsBlock has rolled over.
   
      // determine an eventsBlock number     
      long eventsBlockNumber = 1;       // assign some dafault value 
      long procNEventsProp = tool->get_procNEventsProp(); 
      unsigned int nEvents = tool->get_nEvents();
      if (procNEventsProp > 0) {
          eventsBlockNumber = (long) nEvents / procNEventsProp;
          if ((nEvents % procNEventsProp) != 0)
              eventsBlockNumber++;
       }
     
      // lower eventsBlock number by 1 if usePreviousInterval is true; 
      if (usePreviousInterval) {
          eventsBlockNumber--;
      }
      
      streamName << "eb_" << eventsBlockNumber << "/";
   }
 
   streamName << group.system() << "/" << objName;
 
   return streamName.str();
}

parseString()

void ManagedMonitorToolBase::StreamNameFcn::parseString ( const std::string &  streamName, std::string &  root, std::string &  rem  )

staticinherited

A helper non-virtual function, parses id string.

String format: id = /root/rem The method is needed to separate root stream from the directory in a file. E.g. typical streamName is /TestMon/run_211670/lb_360/spacepointVsEvent_managed

• TestMon is the stream from configuration file (svcMgr.THistSvc.Output += ["TestMon DATAFILE='TestMon.root' OPT='RECREATE'"])
• run_211670/lb_360/ - directory path
• spacepointVsEvent_managed - object name

in this case, root = TestMon rem = run_211670/lb_360/spacepointVsEvent_managed

Definition at line 2415 of file ManagedMonitorToolBase.cxx.

                                                                          {
  std::string::size_type pos = streamName.find('/');
 
  if (pos == std::string::npos) {
    root = "";
    rem = streamName;
    return;
  }
 
  if (pos == 0) {
    parseString(streamName.substr(1,streamName.length()),root,rem);
  } else {
    root = streamName.substr(0,pos);
    rem = streamName.substr(pos+1,streamName.length());
  }
 
}

updateRunLB()

void ManagedMonitorToolBase::OfflineStream::updateRunLB

(

)

Definition at line 2317 of file ManagedMonitorToolBase.cxx.

              {
  m_prev_run_number = AthenaMonManager::runNumber();
  m_prev_lumi_block = AthenaMonManager::lumiBlockNumber();
}

Member Data Documentation

m_ebNames

std::set<std::string> ManagedMonitorToolBase::OfflineStream::m_ebNames

private

Definition at line 833 of file ManagedMonitorToolBase.h.

m_fileKey

const std::string ManagedMonitorToolBase::OfflineStream::m_fileKey

private

Definition at line 829 of file ManagedMonitorToolBase.h.

m_prev_lumi_block

uint32_t ManagedMonitorToolBase::OfflineStream::m_prev_lumi_block

private

Definition at line 832 of file ManagedMonitorToolBase.h.

m_prev_run_number

uint32_t ManagedMonitorToolBase::OfflineStream::m_prev_run_number

private

Definition at line 832 of file ManagedMonitorToolBase.h.

---

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

• ManagedMonitorToolBase.h
• ManagedMonitorToolBase.cxx