ReadLumiBlock Class Reference

Helper class to read in lumi block length info from COOL for a run. More...

#include <ReadLumiBlock.h>

Inheritance diagram for ReadLumiBlock:

Collaboration diagram for ReadLumiBlock:

Public Member Functions
	ReadLumiBlock ()
	Construct helper class for reading in lumi block length from COOL. More...
	~ReadLumiBlock ()
bool	updateLumiBlocks (uint32_t run, MsgStream &msg)
	Load information for. More...
float	getLumiBlockLength (uint32_t lb, MsgStream &msg) const
void	setConnectionCOOL (const std::string &id)
	Set which COOL instance to connect to (run1, run2) More...
bool	getTriedSetup ()
	True when a connection attempt has been made. More...
cool::DatabaseId &	cool_id ()
	Get reference to COOL database ID. More...
cool::IDatabasePtr &	cool_ptr ()
	Get reference to COOL database ptr. More...
const std::string &	cool_source () const
	Get name of COOL data source. More...
uint32_t	getRun () const
	Get run number. More...

Private Member Functions
bool	dbIsOpen ()
	Check if DB connection is open. More...
void	closeDb (MsgStream &msg)
	Close DB connection. More...
bool	openDb (bool readOnly, MsgStream &msg)
	Open a DB connection. More...

Private Attributes
std::map< uint32_t, uint64_t >	m_lbLength
cool::DatabaseId	m_cool_id
cool::DatabaseId	m_cool_id_run1
cool::DatabaseId	m_cool_id_run2
cool::IDatabasePtr	m_cool_ptr
std::string	m_cool_source
uint32_t	m_run
bool	m_triedSetup

Detailed Description

Helper class to read in lumi block length info from COOL for a run.

Definition at line 28 of file ReadLumiBlock.h.

Constructor & Destructor Documentation

ReadLumiBlock()

ReadLumiBlock::ReadLumiBlock

(

)

Construct helper class for reading in lumi block length from COOL.

Definition at line 26 of file ReadLumiBlock.cxx.

  :m_cool_id(),
   m_cool_id_run1("COOLONL_TRIGGER/COMP200"),
   m_cool_id_run2("COOLONL_TRIGGER/CONDBR2"),
   m_cool_source(),
   m_run(0),
   m_triedSetup(false)
{
}

~ReadLumiBlock()

ReadLumiBlock::~ReadLumiBlock

(

)

Definition at line 37 of file ReadLumiBlock.cxx.

{
}

Member Function Documentation

closeDb()

void ReadLumiBlock::closeDb ( MsgStream &  msg )

private

Close DB connection.

Definition at line 138 of file ReadLumiBlock.cxx.

{
  try {
    if(dbIsOpen()) {
      msg << MSG::DEBUG << "ReadLumiBlock::closeDd - closing database '" << m_cool_id << endmsg;
      m_cool_ptr->closeDatabase();
    }
  } catch(std::exception& e) {
    msg << MSG::ERROR << "ReadLumiBlock::closeDB - COOL exception caught: " << e.what() << endmsg;
      msg << MSG::ERROR << "   could not close COOL database: " << m_cool_id << endmsg;
  }
  return;
}

cool_id()

cool::DatabaseId& ReadLumiBlock::cool_id ( )

inline

Get reference to COOL database ID.

Definition at line 43 of file ReadLumiBlock.h.

cool_ptr()

cool::IDatabasePtr& ReadLumiBlock::cool_ptr ( )

inline

Get reference to COOL database ptr.

Definition at line 44 of file ReadLumiBlock.h.

cool_source()

const std::string& ReadLumiBlock::cool_source ( ) const

inline

Get name of COOL data source.

Definition at line 46 of file ReadLumiBlock.h.

dbIsOpen()

bool ReadLumiBlock::dbIsOpen ( )

private

Check if DB connection is open.

Definition at line 113 of file ReadLumiBlock.cxx.

{ 
  return m_cool_ptr.use_count() > 0 && m_cool_ptr->isOpen();
}

getLumiBlockLength()

float ReadLumiBlock::getLumiBlockLength	(	uint32_t	lb,
		MsgStream &	msg
	)		const

Returns

Length of lb

Definition at line 102 of file ReadLumiBlock.cxx.

{
 
    if (m_lbLength.count(lb) != 1) {
        msg << MSG::INFO << "Unknown lumiblock number " << lb << endmsg;
        return 60.0; // Sensible default
    }
    return m_lbLength.at(lb) * 1e-9; // Convert from ns
}

getRun()

uint32_t ReadLumiBlock::getRun ( ) const

inline

Get run number.

Definition at line 48 of file ReadLumiBlock.h.

getTriedSetup()

bool ReadLumiBlock::getTriedSetup ( )

inline

True when a connection attempt has been made.

Definition at line 41 of file ReadLumiBlock.h.

openDb()

bool ReadLumiBlock::openDb ( bool  readOnly, MsgStream &  msg  )

private

Open a DB connection.

Definition at line 119 of file ReadLumiBlock.cxx.

{
  if(dbIsOpen()) return true;
 
  try {
    msg << MSG::DEBUG << "ReadLumiBlock::openDb - opening database '" << m_cool_id << "'" << endmsg;
    m_cool_ptr = databaseService().openDatabase(m_cool_id, readOnly);
    
    return true;
  } catch(cool::DatabaseDoesNotExist& e) {
    msg << MSG::ERROR << "ReadLumiBlock::openDb - COOL exception caught: " << e.what() << endmsg;
      msg << MSG::ERROR << "   could not open database: " << m_cool_id << endmsg;
    return false;
  }
 
  return false;
}

setConnectionCOOL()

void ReadLumiBlock::setConnectionCOOL ( const std::string &  id )

inline

Set which COOL instance to connect to (run1, run2)

Definition at line 40 of file ReadLumiBlock.h.

updateLumiBlocks()

bool ReadLumiBlock::updateLumiBlocks	(	uint32_t	run,
		MsgStream &	msg
	)

Load information for.

Parameters

run

Definition at line 42 of file ReadLumiBlock.cxx.

{
  //
  // Read configuration keys from COOL
  //
  m_triedSetup = true;
  m_cool_source.clear();
  m_run = run;
 
  if (m_run < 238742) m_cool_id = m_cool_id_run1;
  else                m_cool_id = m_cool_id_run2;
 
  cool::ValidityKey since(run);
  cool::ValidityKey until(run);
  cool::ValidityKey maskLB(0xffffffff);
  
  since <<= 32; // upper 31 bits are run number
  until <<= 32; // upper 31 bits are run number 
  until  += maskLB;
 
  if (!dbIsOpen()) { 
    if (!openDb(true, msg)) {
      msg << MSG::FATAL << "updateLumiBlocks - failed to open DB... " << m_cool_id << endmsg;    
      return false;
    }
  }
 
  if (m_cool_ptr->existsFolder("/TRIGGER/LUMI/LBLB")) {
 
    msg << MSG::INFO << "ReadRunData - reading folder: /TRIGGER/LUMI/LBLB" << endmsg;
 
    cool::IFolderPtr folderLB = m_cool_ptr->getFolder("/TRIGGER/LUMI/LBLB");
    cool::IObjectIteratorPtr objectsLB = folderLB->browseObjects(since, until, 0);
 
    while ( objectsLB -> goToNext() ) {
      const cool::IObject &obj = objectsLB->currentRef();
      const cool::IRecord &payload = obj.payload();
      const uint32_t lumi = (obj.since()  & 0xffff);
 
      const uint64_t start = payload["StartTime"].data<cool::UInt63>();
      const uint64_t end = payload["EndTime"].data<cool::UInt63>();
      const uint64_t length = end - start;
 
      m_lbLength[lumi] = length;
 
      msg << MSG::DEBUG << "  run=" << run
                        << "   LB=" << lumi
                          << "   Start=" << start
                          << "   End=" << end
                          << "   Length=" << length << endmsg;
    }
  } else { 
    msg << MSG::INFO << "ReadRunData - missing COOL folder: /TRIGGER/LUMI/LBLB in " << m_cool_id << endmsg; 
  }
  // more lumi info can be got from http://acode-browser.usatlas.bnl.gov/lxr/source/atlas/Trigger/TrigCost/TrigCostRate/src/ReadCool.cxx
 
  closeDb(msg);
  return true;
}

Member Data Documentation

m_cool_id

cool::DatabaseId ReadLumiBlock::m_cool_id

private

Definition at line 60 of file ReadLumiBlock.h.

m_cool_id_run1

cool::DatabaseId ReadLumiBlock::m_cool_id_run1

private

Definition at line 61 of file ReadLumiBlock.h.

m_cool_id_run2

cool::DatabaseId ReadLumiBlock::m_cool_id_run2

private

Definition at line 62 of file ReadLumiBlock.h.

m_cool_ptr

cool::IDatabasePtr ReadLumiBlock::m_cool_ptr

private

Definition at line 63 of file ReadLumiBlock.h.

m_cool_source

std::string ReadLumiBlock::m_cool_source

private

Definition at line 65 of file ReadLumiBlock.h.

m_lbLength

std::map<uint32_t, uint64_t> ReadLumiBlock::m_lbLength

private

Definition at line 58 of file ReadLumiBlock.h.

m_run

uint32_t ReadLumiBlock::m_run

private

Definition at line 66 of file ReadLumiBlock.h.

m_triedSetup

bool ReadLumiBlock::m_triedSetup

private

Definition at line 67 of file ReadLumiBlock.h.

---

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

• ReadLumiBlock.h
• ReadLumiBlock.cxx