RPCDCCLinkMapHandler Class Reference

#include <RPCDCCLinkMapHandler.h>

Inheritance diagram for RPCDCCLinkMapHandler:

Public Member Functions
void	getNewObjects () override
std::string	id () const override
	RPCDCCLinkMapHandler (edm::ParameterSet const &config)
	~RPCDCCLinkMapHandler () override
Public Member Functions inherited from popcon::PopConSourceHandler< RPCDCCLinkMap >
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 ()
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 >
Container	m_iovs
std::vector< std::pair< RPCDCCLinkMap *, Time_t > >	m_to_transfer
std::string	m_userTextLog

Additional Inherited Members
Public Types inherited from popcon::PopConSourceHandler< RPCDCCLinkMap >
typedef std::map< Time_t, std::shared_ptr< RPCDCCLinkMap > >	Container
typedef std::unique_ptr< RPCDCCLinkMap >	Ref
typedef PopConSourceHandler< RPCDCCLinkMap >	self
typedef cond::Time_t	Time_t
typedef RPCDCCLinkMap	value_type
Protected Member Functions inherited from popcon::PopConSourceHandler< RPCDCCLinkMap >
cond::persistency::Session &	dbSession () const

Detailed Description

Definition at line 17 of file RPCDCCLinkMapHandler.h.

Constructor & Destructor Documentation

RPCDCCLinkMapHandler()

RPCDCCLinkMapHandler::RPCDCCLinkMapHandler

(

edm::ParameterSet const &

config

)

Definition at line 25 of file RPCDCCLinkMapHandler.cc.

References cond::persistency::ConnectionPool::configure(), connection_, 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::~RPCDCCLinkMapHandler ( )

override

Definition at line 36 of file RPCDCCLinkMapHandler.cc.

{}

Member Function Documentation

getNewObjects()

void RPCDCCLinkMapHandler::getNewObjects ( )

overridevirtual

Implements popcon::PopConSourceHandler< RPCDCCLinkMap >.

Definition at line 38 of file RPCDCCLinkMapHandler.cc.

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

                                         {
  edm::LogInfo("RPCDCCLinkMapHandler") << "getNewObjects";
  cond::TagInfo_t const& tag_info = tagInfo();
  if (since_run_ < tag_info.lastInterval.since)
    throw cms::Exception("RPCDCCLinkMapHandler") << "Refuse to create RPCDCCLinkMap for run " << since_run_
                                                 << ", older than most recent tag" << tag_info.lastInterval.since;

  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::unique_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("");

  std::unique_ptr<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 (auto const& link : dcc_link_map) {
      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.release(), since_run_));
}

id()

std::string RPCDCCLinkMapHandler::id ( ) const

overridevirtual

Implements popcon::PopConSourceHandler< RPCDCCLinkMap >.

Definition at line 109 of file RPCDCCLinkMapHandler.cc.

References id_.

{ return id_; }

Member Data Documentation

connect_

std::string RPCDCCLinkMapHandler::connect_

protected

Definition at line 32 of file RPCDCCLinkMapHandler.h.

Referenced by getNewObjects().

connection_

cond::persistency::ConnectionPool RPCDCCLinkMapHandler::connection_

protected

Definition at line 33 of file RPCDCCLinkMapHandler.h.

Referenced by getNewObjects(), and RPCDCCLinkMapHandler().

data_tag_

std::string RPCDCCLinkMapHandler::data_tag_

protected

Definition at line 27 of file RPCDCCLinkMapHandler.h.

id_

std::string RPCDCCLinkMapHandler::id_

protected

Definition at line 26 of file RPCDCCLinkMapHandler.h.

Referenced by id().

since_run_

cond::Time_t RPCDCCLinkMapHandler::since_run_

protected

Definition at line 28 of file RPCDCCLinkMapHandler.h.

Referenced by getNewObjects().

txt_file_

std::string RPCDCCLinkMapHandler::txt_file_

protected

Definition at line 30 of file RPCDCCLinkMapHandler.h.

Referenced by getNewObjects().