|
|
|
#include <iDie.h>
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_ |
| 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); }
| void iDie::actionPerformed | ( | xdata::Event & | e | ) |
Definition at line 83 of file iDie.cc.
References ExpressReco_HICollisions_FallBack::e, and 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(), CrabTask::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, ExpressReco_HICollisions_FallBack::e, 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) |
| 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, 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 CrabTask::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(), and parsePathHisto().
{
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 | ( | ) |
xdata::String evf::iDie::class_ [private] |
xdata::String evf::iDie::configString_ [private] |
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] |
xdata::String evf::iDie::hostname_ [private] |
xdata::UnsignedInteger32 evf::iDie::instance_ [private] |
unsigned int evf::iDie::last_ls_ [private] |
Definition at line 140 of file iDie.h.
Referenced by parseModuleHisto().
Logger evf::iDie::log_ [private] |
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] |
unsigned int evf::iDie::totalCores_ [private] |
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] |
1.7.3