ASCIICondDbSvc Class Reference

#include <ASCIICondDbSvc.h>

Inheritance diagram for ASCIICondDbSvc:

Collaboration diagram for ASCIICondDbSvc:

Public Member Functions
	ASCIICondDbSvc (const std::string &name, ISvcLocator *svc)
	~ASCIICondDbSvc ()=default
virtual StatusCode	initialize () override
virtual StatusCode	finalize () override
virtual StatusCode	getRange (const std::string &, const EventContext &, EventIDRange &, IASCIICondDbSvc::dbData_t &) const override
virtual void	dump () const override
void	dump (std::ostringstream &) const

Private Types
typedef std::map< std::string, std::vector< IOVEntryT< IASCIICondDbSvc::dbData_t > > >	registry_t

Private Member Functions
bool	parse (EventIDRange &t, const std::string &s)
bool	parse (IOVEntryT< IASCIICondDbSvc::dbData_t > &t, const std::string &s)
StatusCode	readDbFile (const std::string &)

Private Attributes
Gaudi::Property< std::string >	m_file {this, "CondFile", "", "cond db file name"}
Gaudi::Property< unsigned int >	m_lbn {this, "LBN", 1, "explicit lumi block number"}
registry_t	m_registry
std::mutex	m_lock

Detailed Description

Definition at line 21 of file ASCIICondDbSvc.h.

Member Typedef Documentation

registry_t

typedef std::map<std::string, std::vector<IOVEntryT<IASCIICondDbSvc::dbData_t> > > ASCIICondDbSvc::registry_t

private

Definition at line 51 of file ASCIICondDbSvc.h.

Constructor & Destructor Documentation

ASCIICondDbSvc()

ASCIICondDbSvc::ASCIICondDbSvc	(	const std::string &	name,
		ISvcLocator *	svc )

Definition at line 25 of file ASCIICondDbSvc.cxx.

                                                                          :
  base_class(name,svcLoc)
{}

~ASCIICondDbSvc()

ASCIICondDbSvc::~ASCIICondDbSvc ( )

default

Member Function Documentation

dump() [1/2]

void ASCIICondDbSvc::dump ( ) const

overridevirtual

Definition at line 122 of file ASCIICondDbSvc.cxx.

                           {
 
  std::ostringstream ost;
  dump(ost);
 
  info() << ost.str() << endmsg;
 
}

dump() [2/2]

void ASCIICondDbSvc::dump

(

std::ostringstream &

ost

)

const

Definition at line 135 of file ASCIICondDbSvc.cxx.

                                                {
 
  std::lock_guard<std::mutex> lock(m_lock);
 
  ost << "ASCIICondDbSvc::dump()";
 
  ost << "\n";
    
}

finalize()

StatusCode ASCIICondDbSvc::finalize ( )

overridevirtual

Definition at line 148 of file ASCIICondDbSvc.cxx.

                         {
 
  ATH_MSG_DEBUG( "ASCIICondDbSvc::finalize()" );
 
  if (msgLvl(MSG::DEBUG)) {
    std::ostringstream ost;
    dump(ost);
    
    ATH_MSG_DEBUG( ost.str() );
  }
 
  for ( auto e : m_registry ) {
    for ( auto ie : e.second ) {
      delete ie.objPtr();
      ie.setPtr(0);
    }
  }
 
 
  return StatusCode::SUCCESS;
 
}

getRange()

StatusCode ASCIICondDbSvc::getRange ( const std::string & dbKey, const EventContext & ctx, EventIDRange & rng, IASCIICondDbSvc::dbData_t & val ) const

overridevirtual

Definition at line 240 of file ASCIICondDbSvc.cxx.

                                                                         {
 
  std::lock_guard<std::mutex> lock(m_lock);
 
  registry_t::const_iterator itr = m_registry.find(dbKey);
 
  if (itr == m_registry.end()) {
    error() << "getRange: no dbKey " << dbKey << " found in registry" 
            << endmsg;
    return StatusCode::FAILURE;
  }
 
  for (const IOVEntryT<IASCIICondDbSvc::dbData_t>& e : itr->second) {
    debug() << "compare " << e.range() << " with " << ctx.eventID()
            << endmsg;
    if (e.range().isInRange(EventIDBase(ctx.eventID()))) {
      rng = e.range();
      val = *(e.objPtr());
      return StatusCode::SUCCESS;
    }
  }
 
  error() << "getRange: no range for Time " << ctx.eventID() 
          << " found for dbKey "  << dbKey << endmsg;
 
  return StatusCode::FAILURE;
}

initialize()

StatusCode ASCIICondDbSvc::initialize ( )

overridevirtual

Definition at line 32 of file ASCIICondDbSvc.cxx.

                           {
 
  // Initialise mother class in order to print DEBUG messages during initialize()
  StatusCode sc(AthService::initialize());
  msg().setLevel( m_outputLevel.value() );
 
  if (!sc.isSuccess()) {
    warning () << "Base class could not be initialized" << endmsg;
    return StatusCode::FAILURE;
  }
 
  if (m_file == "") {
    ATH_MSG_DEBUG("db file not set");
    return StatusCode::SUCCESS;
  }
 
  if (readDbFile(m_file).isFailure()) {
    return StatusCode::FAILURE;
  }
 
  std::ostringstream ost;
  ost << " Printing CondDB registry";
  for (const auto& e : m_registry) {
    ost << std::endl << "  - id: " << e.first << "  r:";
    for (const IOVEntryT<IASCIICondDbSvc::dbData_t>& r : e.second) {
      ost << "  " << r.range() << " :: " << *r.objPtr();
    }
  }
 
  ATH_MSG_DEBUG( ost.str() );  
 
  return StatusCode::SUCCESS;
 
}

parse() [1/2]

bool ASCIICondDbSvc::parse ( EventIDRange & t, const std::string & s )

private

Definition at line 174 of file ASCIICondDbSvc.cxx.

                                                         {
 
  boost::smatch m;
  boost::regex_match(s,m,rr);
 
  // for (auto res : m) {
  //   cout << " - " << res << endl;
  // }
 
  if (m.size() != 5) { return false; }
 
  // set run# and timestamp
  EventIDBase start(std::stoi(m[1]), EventIDBase::UNDEFEVT, std::stoi(m[2]));
  EventIDBase   end(std::stoi(m[3]), EventIDBase::UNDEFEVT, std::stoi(m[4]));
 
  start.set_lumi_block(m_lbn);
  end.set_lumi_block(m_lbn);
  
  t = EventIDRange(start, end);
 
  return true;
 
}

parse() [2/2]

bool ASCIICondDbSvc::parse ( IOVEntryT< IASCIICondDbSvc::dbData_t > & t, const std::string & s )

private

Definition at line 201 of file ASCIICondDbSvc.cxx.

                                                                                {
 
  boost::smatch m;
  boost::regex_match(s,m,ref);
 
  if (m.size() != 6) { return false; }
 
  // set run#, lumi and timestamp
  // EventIDBase start(std::stoi(m[1]), EventIDBase::UNDEFEVT, std::stoi(m[2]));
  // EventIDBase   end(std::stoi(m[3]), EventIDBase::UNDEFEVT, std::stoi(m[4]));
  // start.set_lumi_block(m_lbn);
  // end.set_lumi_block(m_lbn);
 
  // set lumi and Timestamp
  EventIDBase start(0, EventIDBase::UNDEFEVT,
                    std::stoi(m[2]));
  EventIDBase   end(EventIDBase::UNDEFNUM, EventIDBase::UNDEFEVT,
                    std::stoi(m[4]));
  start.set_lumi_block(std::stoi(m[1]));
  end.set_lumi_block(std::stoi(m[3]));
 
  // Set Run/Lumi
  // EventIDBase start(std::stoi(m[1]), EventIDBase::UNDEFEVT);
  // EventIDBase   end(std::stoi(m[3]), EventIDBase::UNDEFEVT);
  // start.set_lumi_block(std::stoi(m[2]));
  // end.set_lumi_block(std::stoi(m[4]));
  
  ie.setRange(EventIDRange(start,end));
  
  IASCIICondDbSvc::dbData_t *v = new IASCIICondDbSvc::dbData_t( std::stof(m[5]) );
  ie.setPtr(v);
 
  return true;
 
}

readDbFile()

StatusCode ASCIICondDbSvc::readDbFile ( const std::string & fname )

private

Definition at line 69 of file ASCIICondDbSvc.cxx.

                                                 {
 
  StatusCode sc(StatusCode::SUCCESS);
 
  ATH_MSG_DEBUG("reading cond db from \"" << fname << "\"");
 
  std::ifstream ifs (fname);
  std::string line;
  if(ifs.is_open()) {
 
    typedef boost::tokenizer<boost::char_separator<char> > tokenizer;
    boost::char_separator<char> sep(" ");
 
    IOVEntryT<IASCIICondDbSvc::dbData_t> ie;
 
    while( getline (ifs, line) ) {
      
      // ignore anything after a "#" and blank lines
      size_t fh = line.find("#");
      if(fh != std::string::npos) 
        line.erase(fh,line.length()-fh);
      if (line.length() == 0) continue;
      
      tokenizer tokens(line, sep);
      auto it = tokens.begin();
      
      std::string dbKey = *it;
      
      ++it;
      
      while (it != tokens.end()) {
        if (parse(ie,*it)) {
          m_registry[dbKey].push_back( ie );
        } else {
          error() << "while reading " << fname << " problem parsing " << *it 
                  << " in line\n" << line << endmsg;
          sc = StatusCode::FAILURE;
        }
        ++it;
      }
    }
    ifs.close();
  } else {
    error() << "unable to open file " << (std::string) m_file << endmsg;
    sc = StatusCode::FAILURE;
  }
 
  return sc;
 
}

Member Data Documentation

m_file

Gaudi::Property<std::string> ASCIICondDbSvc::m_file {this, "CondFile", "", "cond db file name"}

private

Definition at line 48 of file ASCIICondDbSvc.h.

{this, "CondFile", "", "cond db file name"};

m_lbn

Gaudi::Property<unsigned int> ASCIICondDbSvc::m_lbn {this, "LBN", 1, "explicit lumi block number"}

private

Definition at line 49 of file ASCIICondDbSvc.h.

{this, "LBN", 1, "explicit lumi block number"};

m_lock

std::mutex ASCIICondDbSvc::m_lock

mutableprivate

Definition at line 54 of file ASCIICondDbSvc.h.

m_registry

registry_t ASCIICondDbSvc::m_registry

private

Definition at line 52 of file ASCIICondDbSvc.h.

---

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

• ASCIICondDbSvc.h
• ASCIICondDbSvc.cxx