evf::iDie Class Reference

#include <iDie.h>

Inheritance diagram for evf::iDie:

Classes
struct	sorted_indices

Public Member Functions
void	actionPerformed (xdata::Event &e)
void	defaultWeb (xgi::Input *in, xgi::Output *out) throw (xgi::exception::Exception)
void	detailsTable (xgi::Input *in, xgi::Output *out) throw (xgi::exception::Exception)
void	dumpTable (xgi::Input *in, xgi::Output *out) throw (xgi::exception::Exception)
xoap::MessageReference	fsmCallback (xoap::MessageReference msg) throw (xoap::exception::Exception)
void	iChoke (xgi::Input *in, xgi::Output *out) throw (xgi::exception::Exception)
void	iChokeMiniInterface (xgi::Input *in, xgi::Output *out) throw (xgi::exception::Exception)
	iDie (xdaq::ApplicationStub *s)
void	postEntry (xgi::Input *in, xgi::Output *out) throw (xgi::exception::Exception)
void	postEntryiChoke (xgi::Input *in, xgi::Output *out) throw (xgi::exception::Exception)
void	summaryTable (xgi::Input *in, xgi::Output *out) throw (xgi::exception::Exception)
void	updater (xgi::Input *in, xgi::Output *out) throw (xgi::exception::Exception)
	XDAQ_INSTANTIATOR ()
virtual	~iDie ()

Private Member Functions
void	parseModuleHisto (const char *, unsigned int)
void	parseModuleLegenda (std::string)
void	parsePathHisto (const unsigned char *, unsigned int)
void	parsePathLegenda (std::string)
void	reset ()

Private Attributes
xdata::String	class_
xdata::String	configString_
std::vector< int >	cpuentries_
std::vector< std::vector< int > >	cpustat_
fmap	fus_
xdata::String	hostname_
xdata::UnsignedInteger32	instance_
unsigned int	last_ls_
Logger	log_
std::vector< std::string >	mapmod_
std::vector< std::string >	mappath_
unsigned int	nstates_
xdata::UnsignedInteger32	runNumber_
unsigned int	totalCores_
std::vector< TriggerReportStatic >	trp_
std::vector< int >	trpentries_
xdata::String	url_

Detailed Description

Definition at line 46 of file iDie.h.

Constructor & Destructor Documentation

iDie::iDie

(

xdaq::ApplicationStub *

s

)

Definition at line 33 of file iDie.cc.

References class_, configString_, defaultWeb(), detailsTable(), dumpTable(), fsmCallback(), hostname_, iChoke(), instance_, postEntry(), postEntryiChoke(), runNumber_, summaryTable(), updater(), and url_.

  : xdaq::Application(s)
  , log_(getApplicationLogger())
  , instance_(0)
  , runNumber_(0)
  , totalCores_(0)
  , nstates_(0)
  , cpustat_(std::vector<std::vector<int> >(0))
  , last_ls_(0)
{
  // initialize application info
  url_     =
    getApplicationDescriptor()->getContextDescriptor()->getURL()+"/"+
    getApplicationDescriptor()->getURN();
  class_   =getApplicationDescriptor()->getClassName();
  instance_=getApplicationDescriptor()->getInstance();
  hostname_=getApplicationDescriptor()->getContextDescriptor()->getURL();
  
  //soap interface
  xoap::bind(this,&evf::iDie::fsmCallback,"Configure",XDAQ_NS_URI);
  xoap::bind(this,&evf::iDie::fsmCallback,"Enable",   XDAQ_NS_URI);
  xoap::bind(this,&evf::iDie::fsmCallback,"Stop",     XDAQ_NS_URI);
  xoap::bind(this,&evf::iDie::fsmCallback,"Halt",     XDAQ_NS_URI);

  // web interface
  xgi::bind(this,&evf::iDie::defaultWeb,  "Default");
  xgi::bind(this,&evf::iDie::summaryTable,"summary");
  xgi::bind(this,&evf::iDie::detailsTable,"details");
  xgi::bind(this,&evf::iDie::dumpTable,   "dump"   );
  xgi::bind(this,&evf::iDie::updater,     "updater");
  xgi::bind(this,&evf::iDie::iChoke,      "iChoke" );

  xgi::bind(this,&evf::iDie::postEntry,       "postEntry");
  xgi::bind(this,&evf::iDie::postEntryiChoke, "postChoke");
  //  gui_->setSmallAppIcon("/evf/images/Hilton.gif");
  //  gui_->setLargeAppIcon("/evf/images/Hilton.gif");

  xdata::InfoSpace *ispace = getApplicationInfoSpace();
  ispace->fireItemAvailable("parameterSet",         &configString_                );
  ispace->fireItemAvailable("runNumber",            &runNumber_                   );
  getApplicationInfoSpace()->addItemChangedListener("runNumber",              this);
}

iDie::~iDie ( )

virtual

Definition at line 78 of file iDie.cc.

{
}

Member Function Documentation

void iDie::actionPerformed

(

xdata::Event &

e

)

Definition at line 83 of file iDie.cc.

References reset().

{
  
  if (e.type()=="ItemChangedEvent" ) {
    std::string item = dynamic_cast<xdata::ItemChangedEvent&>(e).itemName();
    
    if ( item == "runNumber") {
      LOG4CPLUS_WARN(getApplicationLogger(),
             "New Run was started - iDie will reset");
      reset();
    }
    
  }
}

void iDie::defaultWeb	(	xgi::Input *	in,
		xgi::Output *	out
	)
throw	(	xgi::exception::Exception
	)

Definition at line 160 of file iDie.cc.

References evf::internal::fu::ccount, recoMuon::in, dbtoconf::out, reset(), DTTTrigCorrFirst::run, and sistrip::runNumber_.

Referenced by iDie().

{
  cgicc::Cgicc cgi(in);
  std::string method = cgi.getEnvironment().getRequestMethod();
  if(method == "POST"){
    unsigned int run;
    std::vector<cgicc::FormEntry> el1 = cgi.getElements();
    cgi.getElement("run",el1);
    if(el1.size()!=0){
      run = el1[0].getIntegerValue();
      if(run > runNumber_.value_ || runNumber_.value_==0){
    if(runNumber_.value_!=0) reset();
    runNumber_.value_ = run;
      }
    }
    internal::fu fuinstance;

    fuinstance.ccount = 0;
    std::string hostname = cgi.getEnvironment().getRemoteHost();
    std::transform(hostname.begin(), hostname.end(),
           hostname.begin(), ::toupper);
    fus_[hostname] = fuinstance;
  }
  else{
    *out << "<!DOCTYPE HTML PUBLIC \"-//W3C//DTD HTML 4.0 Transitional//EN\">" 
     << "<html><head><title>" << getApplicationDescriptor()->getClassName()
     << getApplicationDescriptor()->getInstance() << "</title>"
     << "<meta http-equiv=\"REFRESH\" content=\"0;url=/evf/html/idiePage.html\">"
     << "</head></html>";
  }
}

void iDie::detailsTable	(	xgi::Input *	in,
		xgi::Output *	out
	)
throw	(	xgi::exception::Exception
	)

Definition at line 208 of file iDie.cc.

References i, cmsPerfSuiteHarvest::now, and dbtoconf::out.

Referenced by iDie().

{
  timeval tv;
  gettimeofday(&tv,0);
  time_t now = tv.tv_sec;
  for(ifmap i = fus_.begin(); i != fus_.end(); i++)
    if((*i).second.ccount != 0){
      *out << "<tr><td " 
       << (now-(*i).second.tstamp<300 ? "style=\"background-color:red\"" : "")
       << ">"<<(*i).first<<"</td><td>" 
       << (*i).second.ccount << "</td>"
       << "<td onClick=loaddump(\'" << url_.value_ << "/dump?name="
       << (*i).first << "\')>" << (*i).second.cpids.back()
       << "</td><td>" <<(*i).second.signals.back() 
       << "</td></tr>" << std::endl;
    }
}

void iDie::dumpTable	(	xgi::Input *	in,
		xgi::Output *	out
	)
throw	(	xgi::exception::Exception
	)

Definition at line 228 of file iDie.cc.

References gather_cfg::cout, recoMuon::in, and dbtoconf::out.

Referenced by iDie().

{
  cgicc::Cgicc cgi(in); 

  std::vector<cgicc::FormEntry> el1;
  cgi.getElement("name",el1);
  if(el1.size()!=0){
    std::string hostname = el1[0].getValue();
    std::transform(hostname.begin(), hostname.end(),
           hostname.begin(), ::toupper);
    ifmap fi = fus_.find(hostname);    
    if(fi!=fus_.end()){
      *out << (*fi).second.stacktraces.back() << std::endl;
    }
    else{ 
      for(fi=fus_.begin(); fi != fus_.end(); fi++) 
    std::cout << "known hosts: " << (*fi).first << std::endl;
    }
  }
}

xoap::MessageReference iDie::fsmCallback	(	xoap::MessageReference	msg	)
throw	(	xoap::exception::Exception
	)

Definition at line 99 of file iDie.cc.

References edmPickEvents::command, edm::hlt::Exception, i, runTheMatrix::msg, python.Node::node, and evf::utils::state.

Referenced by iDie().

{
  
  xoap::SOAPPart     part    =msg->getSOAPPart();
  xoap::SOAPEnvelope env     =part.getEnvelope();
  xoap::SOAPBody     body    =env.getBody();
  DOMNode           *node    =body.getDOMNode();
  DOMNodeList       *bodyList=node->getChildNodes();
  DOMNode           *command =0;
  std::string             commandName;
  
  for (unsigned int i=0;i<bodyList->getLength();i++) {
    command = bodyList->item(i);
    if(command->getNodeType() == DOMNode::ELEMENT_NODE) {
      commandName = xoap::XMLCh2String(command->getLocalName());
      break;
    }
  }
  
  if (commandName.empty()) {
    XCEPT_RAISE(xoap::exception::Exception,"Command not found.");
  }
  
  // fire appropriate event and create according response message
  try {

    // response string
    xoap::MessageReference reply = xoap::createMessage();
    xoap::SOAPEnvelope envelope  = reply->getSOAPPart().getEnvelope();
    xoap::SOAPName responseName  = envelope.createName(commandName+"Response",
                               "xdaq",XDAQ_NS_URI);
    xoap::SOAPBodyElement responseElem =
      envelope.getBody().addBodyElement(responseName);
    
    std::string state;
    // generate correct return state string
    if(commandName == "Configure") state = "Ready";
    else if(commandName == "Enable") state = "Enabled";
    else if(commandName == "Stop") state = "Ready";
    else if(commandName == "Halt") state = "Halted";
    else state = "BOH";

    xoap::SOAPName    stateName     = envelope.createName("state",
                              "xdaq",XDAQ_NS_URI);
    xoap::SOAPElement stateElem     = responseElem.addChildElement(stateName);
    xoap::SOAPName    attributeName = envelope.createName("stateName",
                              "xdaq",XDAQ_NS_URI);
    stateElem.addAttribute(attributeName,state);
    
    return reply;
  }
  catch (toolbox::fsm::exception::Exception & e) {
    XCEPT_RETHROW(xoap::exception::Exception,"invalid command.",e);
  } 
  


}

void iDie::iChoke	(	xgi::Input *	in,
		xgi::Output *	out
	)
throw	(	xgi::exception::Exception
	)

Definition at line 257 of file iDie.cc.

References begin, gather_cfg::cout, i, evf::iDie::sorted_indices::ii(), recoMuon::in, j, dbtoconf::out, and tmp.

Referenced by iDie().

{
  cgicc::Cgicc cgi(in);
  unsigned int i = 0;
//   while(i<mapmod_.size()){
//     *out << i << " " << mapmod_[i] << std::endl;
//     ++i;
//   }
  std::cout << "iChoke, last_ls= " << last_ls_ << std::endl;
  if(last_ls_==0) return;
  *out << "Last ls=" << last_ls_ << "Cpu statistics=" 
       << cpuentries_[last_ls_-1] << std::endl;
  *out << "================" << std::endl;
  sorted_indices tmp(cpustat_[last_ls_-1]);
  //  std::sort(tmp.begin(),tmp.end());// figure out how to remap indices of legenda
  while(i<nstates_){
    if(tmp[i]!=0) *out << mapmod_[tmp.ii(i)] << " " << float(tmp[i])/float(cpuentries_[last_ls_-1]) << std::endl;
    i++;
  }
  *out << "\n\n\n";
  unsigned int begin = last_ls_<10 ? 0 : last_ls_-10;
  for(i=begin; i < last_ls_; i++)
    *out << std::setw(9) << i +1 << " ";
  *out << std::endl;
  for(i=begin; i < last_ls_; i++)
    *out << "----------";
  *out << std::endl;
  for(i=begin; i < last_ls_; i++)
    *out << std::setw(8) << float(cpustat_[i][2])/float(cpuentries_[i]) << " ";
  *out << std::endl;
  *out << "\n\n\n";
  begin = last_ls_<10 ? 0 : last_ls_-10;
  for(i=begin; i < last_ls_; i++)
    *out << std::setw(9) << i +1 << " ";
  *out << std::endl;
  for(i=begin; i < last_ls_; i++)
    *out << "----------";
  *out << std::endl;
  for(i=begin; i < last_ls_; i++)
    *out << std::setw(8) << float(trp_[i].eventSummary.totalEventsPassed)/float(trp_[i].eventSummary.totalEvents) << " "; 
  *out << std::endl;
  for(i=begin; i < last_ls_; i++)
    *out << std::setw(8) << trp_[i].eventSummary.totalEvents << " "; 
  *out << std::endl;

  for(int j = 0; j < trp_[last_ls_-1].trigPathsInMenu; j++)
    {
      for(i=begin; i < last_ls_; i++)
    *out << std::setw(8) << trp_[i].trigPathSummaries[j].timesPassed << "("
         << trp_[i].trigPathSummaries[j].timesPassedL1 << ")("
         << trp_[i].trigPathSummaries[j].timesPassedPs << ") ";
      *out << mappath_[j];
      *out << std::endl;
    }
  for(int j = 0; j < trp_[last_ls_-1].endPathsInMenu; j++)
    {
      for(i=begin; i < last_ls_; i++)
    *out << std::setw(8) << trp_[i].endPathSummaries[j].timesPassed << " ";
      *out << mappath_[j+trp_[last_ls_-1].trigPathsInMenu];
      *out << std::endl;
    }


}

void iDie::iChokeMiniInterface	(	xgi::Input *	in,
		xgi::Output *	out
	)
throw	(	xgi::exception::Exception
	)

Definition at line 251 of file iDie.cc.

{
}

void iDie::parseModuleHisto ( const char *  crp, unsigned int  lsid  )

private

Definition at line 459 of file iDie.cc.

References gather_cfg::cout, cpuentries_, cpustat_, i, last_ls_, and nstates_.

{
  std::cout << "parseModuleHisto ls=" << lsid << std::endl; 
  if(last_ls_ < lsid) last_ls_ = lsid; 
  int *trp = (int*)crp;
  if(lsid>=cpustat_.size()){
    cpustat_.resize(lsid,std::vector<int>(nstates_,0));
    cpuentries_.resize(lsid,0);
  }
  for(unsigned int i=0;i<nstates_; i++)
    {
      cpustat_[lsid-1][i] += trp[i];
      cpuentries_[lsid-1] += trp[i];
    }
}

void iDie::parseModuleLegenda ( std::string  leg )

private

Definition at line 442 of file iDie.cc.

References mapmod_, nstates_, and EcalElecEmulTccFlatFileProducerFromTPG_cfg::tokens.

{
  mapmod_.clear();
  //  if(cpustat_) delete cpustat_;
  boost::char_separator<char> sep(",");
  boost::tokenizer<boost::char_separator<char> > tokens(leg, sep);
  for (boost::tokenizer<boost::char_separator<char> >::iterator tok_iter = tokens.begin();
       tok_iter != tokens.end(); ++tok_iter){
    mapmod_.push_back((*tok_iter));
  }
  nstates_ = mapmod_.size();
  //  cpustat_ = new int[nstates_];
//   for(int i = 0; i < nstates_; i++)
//     cpustat_[i]=0;   
//   cpuentries_ = 0;
}

void iDie::parsePathHisto ( const unsigned char *  crp, unsigned int  lsid  )

private

Definition at line 489 of file iDie.cc.

References evf::funcs::addToReport(), gather_cfg::cout, evf::funcs::reset(), trp_, and trpentries_.

{
  std::cout << "parsePathHisto ls=" << lsid << std::endl; 
  TriggerReportStatic *trp = (TriggerReportStatic*)crp;
  if(lsid>=trp_.size()){
    trp_.resize(lsid);
    funcs::reset(&trp_[lsid-1]);
    trpentries_.resize(lsid,0);
  }
  funcs::addToReport(&trp_[lsid-1],trp,lsid);
  trpentries_[lsid-1]++;
}

void iDie::parsePathLegenda ( std::string  leg )

private

Definition at line 476 of file iDie.cc.

References gather_cfg::cout, mappath_, and EcalElecEmulTccFlatFileProducerFromTPG_cfg::tokens.

{
  std::cout << "parsePathLegenda" << std::endl;
  std::cout << leg << std::endl;
  mappath_.clear();
  boost::char_separator<char> sep(",");
  boost::tokenizer<boost::char_separator<char> > tokens(leg, sep);
  for (boost::tokenizer<boost::char_separator<char> >::iterator tok_iter = tokens.begin();
       tok_iter != tokens.end(); ++tok_iter){
    mappath_.push_back((*tok_iter));
  }
}

void iDie::postEntry	(	xgi::Input *	in,
		xgi::Output *	out
	)
throw	(	xgi::exception::Exception
	)

Definition at line 324 of file iDie.cc.

References gather_cfg::cout, edm::getName(), reco::JetExtendedAssociation::getValue(), query::host, i, recoMuon::in, cmsPerfSuiteHarvest::now, and DTTTrigCorrFirst::run.

Referenced by iDie().

{
  std::cout << "postEntry " << std::endl;
  timeval tv;
  gettimeofday(&tv,0);
  time_t now = tv.tv_sec;
  cgicc::Cgicc cgi(in); 
  unsigned int run = 0;
  pid_t cpid = 0;
  /*  cgicc::CgiEnvironment cgie(in);
  cout << "query = "  << cgie.getContentLength() << endl;
  */
  std::vector<cgicc::FormEntry> el1;
  el1 = cgi.getElements();
  for(unsigned int i = 0; i < el1.size(); i++)
    std::cout << "name="<<el1[i].getName() << std::endl;
  el1.clear();
  cgi.getElement("run",el1);
  if(el1.size()!=0)
    {
      run =  el1[0].getIntegerValue();
    }
  el1.clear();
  cgi.getElement("stacktrace",el1);
  if(el1.size()!=0)
    {
      cpid = run;
      //      std::cout << "=============== stacktrace =============" << std::endl;
      //      std::cout << el1[0].getValue() << std::endl;
      if(el1[0].getValue().find("Dead")==0){

    std::string host = cgi.getEnvironment().getRemoteHost();
    std::transform(host.begin(), host.end(),
               host.begin(), ::toupper);
    ifmap fi = fus_.find(host);
    if(fi!=fus_.end()){
      fus_.erase(fi);
    }
      }
      else{
    totalCores_++;
    std::string st = el1[0].getValue();
    std::string sig; 
    size_t psig = st.find("signal");
    if(psig != std::string::npos)
      sig = st.substr(psig,9);
    std::string host = cgi.getEnvironment().getRemoteHost();
    std::transform(host.begin(), host.end(),
               host.begin(), ::toupper);
    ifmap fi = fus_.find(host);
    if(fi!=fus_.end()){
      (*fi).second.tstamp = now;
      (*fi).second.ccount++;
      (*fi).second.cpids.push_back(cpid);
      (*fi).second.signals.push_back(sig);
      (*fi).second.stacktraces.push_back(st);
    }
      }
    }
  el1.clear();
  cgi.getElement("legenda",el1);
  if(el1.size()!=0)
    {
      parsePathLegenda(el1[0].getValue());
    }
  cgi.getElement("trp",el1);
  if(el1.size()!=0)
    {
      unsigned int lsid = run;
      parsePathHisto((unsigned char*)(el1[0].getValue().c_str()),lsid);
    }
  el1.clear();


}

void iDie::postEntryiChoke	(	xgi::Input *	in,
		xgi::Output *	out
	)
throw	(	xgi::exception::Exception
	)

Definition at line 402 of file iDie.cc.

References gather_cfg::cout, edm::getName(), reco::JetExtendedAssociation::getValue(), i, and recoMuon::in.

Referenced by iDie().

{
  std::cout << "postEntryiChoke " << std::endl;
  unsigned int lsid = 0;
  cgicc::Cgicc cgi(in); 
  /*  cgicc::CgiEnvironment cgie(in);
  cout << "query = "  << cgie.getContentLength() << endl;
  */
  std::vector<cgicc::FormEntry> el1;
  el1 = cgi.getElements();
  for(unsigned int i = 0; i < el1.size(); i++)
    std::cout << "name="<<el1[i].getName() << std::endl;
  el1.clear();
  cgi.getElement("run",el1);
  if(el1.size()!=0)
    {
      lsid =  el1[0].getIntegerValue();
    }
  el1.clear();
  cgi.getElement("legenda",el1);
  if(el1.size()!=0)
    {
      parseModuleLegenda(el1[0].getValue());
    }
  cgi.getElement("trp",el1);
  if(el1.size()!=0)
    {
      parseModuleHisto(el1[0].getStrippedValue().c_str(),lsid);
    }
  el1.clear();
}

void iDie::reset ( void  )

private

Definition at line 436 of file iDie.cc.

References fus_, and totalCores_.

Referenced by actionPerformed().

{
  fus_.erase(fus_.begin(),fus_.end());
  totalCores_=0;
}

void iDie::summaryTable	(	xgi::Input *	in,
		xgi::Output *	out
	)
throw	(	xgi::exception::Exception
	)

Definition at line 200 of file iDie.cc.

References dbtoconf::out.

Referenced by iDie().

{
    *out << "<tr><td>"<<fus_.size()<<"</td><td>" << totalCores_ 
     << "</td><td></td></tr>" << std::endl;
}

void iDie::updater	(	xgi::Input *	in,
		xgi::Output *	out
	)
throw	(	xgi::exception::Exception
	)

Definition at line 194 of file iDie.cc.

References dbtoconf::out, and sistrip::runNumber_.

Referenced by iDie().

{
  *out << runNumber_.value_ << std::endl;
}

evf::iDie::XDAQ_INSTANTIATOR

(

)

Member Data Documentation

xdata::String evf::iDie::class_

private

Definition at line 128 of file iDie.h.

Referenced by iDie().

xdata::String evf::iDie::configString_

private

Definition at line 132 of file iDie.h.

Referenced by iDie().

std::vector<int> evf::iDie::cpuentries_

private

Definition at line 137 of file iDie.h.

Referenced by parseModuleHisto().

std::vector<std::vector<int> > evf::iDie::cpustat_

private

Definition at line 138 of file iDie.h.

Referenced by parseModuleHisto().

fmap evf::iDie::fus_

private

Definition at line 133 of file iDie.h.

Referenced by reset().

xdata::String evf::iDie::hostname_

private

Definition at line 130 of file iDie.h.

Referenced by iDie().

xdata::UnsignedInteger32 evf::iDie::instance_

private

Definition at line 129 of file iDie.h.

Referenced by iDie().

unsigned int evf::iDie::last_ls_

private

Definition at line 140 of file iDie.h.

Referenced by parseModuleHisto().

Logger evf::iDie::log_

private

Definition at line 124 of file iDie.h.

std::vector<std::string> evf::iDie::mapmod_

private

Definition at line 139 of file iDie.h.

Referenced by parseModuleLegenda().

std::vector<std::string> evf::iDie::mappath_

private

Definition at line 143 of file iDie.h.

Referenced by parsePathLegenda().

unsigned int evf::iDie::nstates_

private

Definition at line 136 of file iDie.h.

Referenced by parseModuleHisto(), and parseModuleLegenda().

xdata::UnsignedInteger32 evf::iDie::runNumber_

private

Definition at line 131 of file iDie.h.

Referenced by iDie().

unsigned int evf::iDie::totalCores_

private

Definition at line 135 of file iDie.h.

Referenced by reset().

std::vector<TriggerReportStatic> evf::iDie::trp_

private

Definition at line 141 of file iDie.h.

Referenced by parsePathHisto().

std::vector<int> evf::iDie::trpentries_

private

Definition at line 142 of file iDie.h.

Referenced by parsePathHisto().

xdata::String evf::iDie::url_

private

Definition at line 127 of file iDie.h.

Referenced by iDie().