#include <RPCDCCLinkMapHandler.h>

Inheritance diagram for RPCDCCLinkMapHandler:

Public Member Functions
void	getNewObjects ()

std::string	id () const

	RPCDCCLinkMapHandler (edm::ParameterSet const &_config)

	~RPCDCCLinkMapHandler ()

Public Member Functions inherited from popcon::PopConSourceHandler< RPCDCCLinkMap >
void	convertFromOld ()

Summary *	dummySummary (typename OldContainer::value_type const &) const

void	initialize (const cond::persistency::Session &dbSession, cond::TagInfo_t const &tagInfo, cond::LogDBEntry_t const &logDBEntry)

Ref	lastPayload () const

cond::LogDBEntry_t const &	logDBEntry () const

std::pair< Container const *, std::string const >	operator() (const cond::persistency::Session &session, cond::TagInfo_t const &tagInfo, cond::LogDBEntry_t const &logDBEntry) const

	PopConSourceHandler ()

Container const &	returnData ()

void	sort ()

cond::TagInfo_t const &	tagInfo () const

std::string const &	userTextLog () const

virtual	~PopConSourceHandler ()

Protected Attributes
std::string	connect_

cond::persistency::ConnectionPool	connection_

std::string	data_tag_

std::string	id_

cond::Time_t	since_run_

std::string	txt_file_

Protected Attributes inherited from popcon::PopConSourceHandler< RPCDCCLinkMap >
OldContainer	m_to_transfer

std::string	m_userTextLog

Additional Inherited Members
Public Types inherited from popcon::PopConSourceHandler< RPCDCCLinkMap >
typedef std::vector< Triplet >	Container

typedef std::vector< std::pair < RPCDCCLinkMap *, cond::Time_t > >	OldContainer

typedef PopConSourceHandler < RPCDCCLinkMap >	self

typedef cond::Summary	Summary

typedef cond::Time_t	Time_t

typedef RPCDCCLinkMap	value_type

Protected Member Functions inherited from popcon::PopConSourceHandler< RPCDCCLinkMap >
int	add (value_type payload, Summary summary, Time_t time)

Detailed Description

Definition at line 17 of file RPCDCCLinkMapHandler.h.

Constructor & Destructor Documentation

RPCDCCLinkMapHandler::RPCDCCLinkMapHandler ( edm::ParameterSet const & _config )

Definition at line 25 of file RPCDCCLinkMapHandler.cc.

References cond::persistency::ConnectionPool::configure(), connection_, edm::ParameterSet::getParameter(), and cond::persistency::ConnectionPool::setParameters().

     : id_(_config.getParameter<std::string>("identifier"))
     , data_tag_(_config.getParameter<std::string>("dataTag"))
     , since_run_(_config.getParameter<unsigned long long>("sinceRun"))
     , txt_file_(_config.getUntrackedParameter<std::string>("txtFile", ""))
     , connect_(_config.getParameter<std::string>("connect"))
 {
     edm::LogInfo("RPCDCCLinkMapHandler") << "Configuring Input Connection";
     connection_.setParameters(_config.getParameter<edm::ParameterSet>("DBParameters"));
     connection_.configure();
 }

RPCDCCLinkMapHandler::~RPCDCCLinkMapHandler ( )

Definition at line 37 of file RPCDCCLinkMapHandler.cc.

38 {}

Member Function Documentation

void RPCDCCLinkMapHandler::getNewObjects ( )

virtual

Implements popcon::PopConSourceHandler< RPCDCCLinkMap >.

Definition at line 40 of file RPCDCCLinkMapHandler.cc.

References connect_, connection_, cond::persistency::ConnectionPool::createCoralSession(), Exception, RPCDCCLinkMap::getMap(), RPCLBLink::getName(), cond::TagInfo_t::lastInterval, popcon::PopConSourceHandler< RPCDCCLinkMap >::m_to_transfer, RPCLBLinkNameParser::parse(), RPCLBLink::setConnector(), RPCLBLink::setLinkBoard(), since_run_, AlCaHLTBitMon_QueryRunRegistry::string, popcon::PopConSourceHandler< RPCDCCLinkMap >::tagInfo(), and txt_file_.

 {
     edm::LogInfo("RPCDCCLinkMapHandler") << "getNewObjects";
     cond::TagInfo const & _tag_info = tagInfo();
     if (since_run_ < _tag_info.lastInterval.first)
         throw cms::Exception("RPCDCCLinkMapHandler") << "Refuse to create RPCDCCLinkMap for run " << since_run_
                                                      << ", older than most recent tag" << _tag_info.lastInterval.first;
 
     edm::LogInfo("RPCDCCLinkMapHandler") << "Opening read-only Input Session";
     auto _input_session = connection_.createCoralSession(connect_, false); // writeCapable
     edm::LogInfo("RPCDCCLinkMapHandler") << "Started Input Transaction";
     _input_session->transaction().start(true); // readOnly
 
     std::auto_ptr<coral::IQuery> _query(_input_session->schema("CMS_RPC_CONF").newQuery());
     _query->addToTableList("DCCBOARD");
     _query->addToTableList("TRIGGERBOARD");
     _query->addToTableList("BOARDBOARDCONN");
     _query->addToTableList("BOARD");
 
     _query->addToOutputList("DCCBOARD.FEDNUMBER", "DCC");
     _query->addToOutputList("TRIGGERBOARD.DCCINPUTCHANNELNUM", "DCC_INPUT");
     _query->addToOutputList("BOARDBOARDCONN.COLLECTORBOARDINPUTNUM", "TB_INPUT");
     _query->addToOutputList("BOARD.NAME", "LB_NAME");
 
     coral::AttributeList _query_condition_data;
     _query->setCondition("TRIGGERBOARD.DCCBOARD_DCCBOARDID=DCCBOARD.DCCBOARDID"
                          " AND BOARDBOARDCONN.BOARD_COLLECTORBOARDID=TRIGGERBOARD.TRIGGERBOARDID"
                          " AND BOARD.BOARDID=BOARDBOARDCONN.BOARD_BOARDID"
                          , _query_condition_data);
 
     int _dcc(0), _dcc_input(0), _tb_input(0);
     std::string _lb_name("");
 
     RPCDCCLinkMap * _dcc_link_map_object = new RPCDCCLinkMap();
     RPCDCCLinkMap::map_type & _dcc_link_map
         = _dcc_link_map_object->getMap();
     RPCLBLink _lb_link;
 
     edm::LogInfo("RPCDCCLinkMapHandler") << "Execute query";
     coral::ICursor & _cursor(_query->execute());
     while (_cursor.next()) {
         coral::AttributeList const & _row(_cursor.currentRow());
 
         // RPCLBLink
         _lb_name = _row["LB_NAME"].data<std::string>();
         RPCLBLinkNameParser::parse(_lb_name, _lb_link);
         if (_lb_name != _lb_link.getName())
             edm::LogWarning("RPCDCCLinkMapHandler") << "Mismatch LinkBoard Name: " << _lb_name << " vs " << _lb_link;
         _lb_link.setLinkBoard().setConnector(); // MLB to link
 
         _dcc = _row["DCC"].data<long long>();
         _dcc_input = _row["DCC_INPUT"].data<long long>();
         _tb_input = _row["TB_INPUT"].data<long long>();
 
         _dcc_link_map.insert(std::pair<RPCDCCLink, RPCLBLink>(RPCDCCLink(_dcc, _dcc_input, _tb_input)
                                                               , _lb_link));
     }
     _cursor.close();
 
     _input_session->transaction().commit();
 
     if (!txt_file_.empty()) {
         edm::LogInfo("RPCDCCLinkMapHandler") << "Fill txtFile";
         std::ofstream _ofstream(txt_file_);
         for (RPCDCCLinkMap::map_type::const_iterator _link = _dcc_link_map.begin()
                  ; _link != _dcc_link_map.end() ; ++_link) {
             _ofstream << _link->first << ": " << _link->second << std::endl;
         }
     }
 
     edm::LogInfo("RPCDCCLinkMapHandler") << "Add to transfer list";
     m_to_transfer.push_back(std::make_pair(_dcc_link_map_object, since_run_));
 }