ConsumerList Class Reference

#include <ConsumerList.h>

List of all members.

Public Types
enum	{   Unknown = 0, Dead = 1, Running = 2, Stopped = 3,   Crashed = 4, Finished = 5 }
Public Member Functions
	ConsumerList (TString sitename="")
	~ConsumerList ()
int	nEntries () const
const TString &	consumername (int i) const
const TString &	hostname (int i) const
int	port (int i) const
int	nevents (int i) const
int	runnumber (int i) const
int	status (int i) const
const char *	statusString (int i) const
const TString &	updateTime (int i) const
int	readWebPage ()
void	setPort (int i, int port)
void	setNevents (int i, int nev)
void	setStatus (int i, int status)
void	setRunnumber (int i, int runn)
void	setUpdateTime (int i, char *tm)
int	watchServers (const int port, const char *filename)
void	test ()
void	print (std::ostream &output=std::cout) const
void	addEntry (TString nam, TString hostnam, int port, int nev, int runn, int stat, TString tm="")
void	removeEntry (const char *hostname, int port)
int	sendList (const char *host, const int port)
int	writeWebPage (const char *filename)
Static Public Member Functions
bool	sortbyName (const ConsumerEntry a, const ConsumerEntry b)
Private Member Functions
	ConsumerList (const ConsumerList &sm)
Private Attributes
std::vector< ConsumerEntry >	_consumerlist
TString	_websitename
const char *	_statusnames [6]

---

Member Enumeration Documentation

anonymous enum

Enumeration values: Unknown  Dead  Running  Stopped  Crashed  Finished  Definition at line 57 of file ConsumerList.h. { Unknown = 0, Dead = 1, Running = 2, Stopped = 3, Crashed = 4, Finished = 5 };

---

Constructor & Destructor Documentation

ConsumerList::ConsumerList (  TString  sitename = ""  )

Definition at line 37 of file ConsumerList.cc. References _statusnames. : _websitename(sitename) { _statusnames[Unknown] = "Unknown"; _statusnames[Dead] = "Dead"; _statusnames[Running] = "Running"; _statusnames[Stopped] = "Stopped"; _statusnames[Crashed] = "Crashed"; _statusnames[Finished] = "Finished"; }

ConsumerList::~ConsumerList (   )

Definition at line 47 of file ConsumerList.cc. { }

ConsumerList::ConsumerList (  const ConsumerList &  sm  )  [private]

Definition at line 51 of file ConsumerList.cc. { }

---

Member Function Documentation

void ConsumerList::addEntry (  TString  nam, TString  hostnam, int  port, int  nev, int  runn, int  stat, TString  tm = "" )

Definition at line 402 of file ConsumerList.cc. References _consumerlist, port, and removeEntry(). Referenced by DisplayServer::updateStateManager(). { //try to remove old entry first removeEntry(hostnam,port); _consumerlist.push_back(ConsumerEntry(nam,hostnam,port,nev,runn,stat,tm)); }

const TString & ConsumerList::consumername (  int  i  )  const

Definition at line 60 of file ConsumerList.cc. References _consumerlist. { return _consumerlist[i].name; }

const TString & ConsumerList::hostname (  int  i  )  const

Definition at line 65 of file ConsumerList.cc. References _consumerlist. Referenced by ConsumerList::ConsumerEntry::ConsumerEntry(). { return _consumerlist[i].hostname; }

int ConsumerList::nEntries (   )  const

Definition at line 55 of file ConsumerList.cc. References _consumerlist. { return _consumerlist.size(); }

int ConsumerList::nevents (  int  i  )  const

Definition at line 75 of file ConsumerList.cc. References _consumerlist. Referenced by ConsumerList::ConsumerEntry::ConsumerEntry(). { return _consumerlist[i].nevents; }

int ConsumerList::port (  int  i  )  const

Definition at line 70 of file ConsumerList.cc. References _consumerlist. Referenced by ConsumerList::ConsumerEntry::ConsumerEntry(). { return _consumerlist[i].port; }

void ConsumerList::print (  std::ostream &  output = std::cout  )  const

Definition at line 328 of file ConsumerList.cc. References _consumerlist, _statusnames, ConsumerList::ConsumerEntry::hostname, ConsumerList::ConsumerEntry::name, ConsumerList::ConsumerEntry::nevents, ConsumerList::ConsumerEntry::port, and ConsumerList::ConsumerEntry::runnumber. Referenced by HistoDisplay::MenuConnectStatus(). { output << "ConsumerList:" << endl; output.width(15); output.setf(ios::left,ios::adjustfield); output << "name"; output.width(30); output.setf(ios::left,ios::adjustfield); output << "hostname"; output.width(6); output.setf(ios::right,ios::adjustfield); output << "port"; output.width(7); output.setf(ios::right,ios::adjustfield); output << " runn"; output.width(8); output.setf(ios::right,ios::adjustfield); output << "events"; output.width(10); output.setf(ios::right,ios::adjustfield); output << " status" << endl; for(std::vector<ConsumerEntry>::const_iterator iter = _consumerlist.begin(); iter != _consumerlist.end(); ++iter) { output.width(15); output.setf(ios::left,ios::adjustfield); output << iter->name; output.width(30); output.setf(ios::left,ios::adjustfield); output << iter->hostname; output.width(6); output.setf(ios::right,ios::adjustfield); output << iter->port; output.width(7); output.setf(ios::right,ios::adjustfield); output << iter->runnumber; output.width(8); output.setf(ios::right,ios::adjustfield); output << iter->nevents; output.width(10); output.setf(ios::right,ios::adjustfield); output << _statusnames[iter->status] << endl; } }

int ConsumerList::readWebPage (   )

Definition at line 202 of file ConsumerList.cc. References _consumerlist, _statusnames, _websitename, ConsumerList::ConsumerEntry::hostname, ConsumerList::ConsumerEntry::name, ConsumerList::ConsumerEntry::nevents, ConsumerList::ConsumerEntry::port, ConsumerList::ConsumerEntry::runnumber, and ConsumerList::ConsumerEntry::status. Referenced by HistoDisplay::MenuConnectStatus(). { ostrstream message; string page,temp; unsigned int pos,last,pos2=0; char buffer[5000]; TUrl website(_websitename); //open Socket connection TSocket sock(website.GetHost(),website.GetPort()); if(!(sock.IsValid())) return 0; // build request message << "GET " << website.GetFile() << " HTTP/1.0\rHost:" << website.GetHost() << ":" << website.GetPort() << "\n\rAccept: */*\n\r\n\r" << ends; // get page temp = message.str(); if (sock.SendRaw(temp.c_str(),temp.length()) != (Int_t)temp.length()) return 0; sock.RecvRaw(buffer,5000); sock.Close(); // check title page = buffer; pos = page.find("<title>")+7; temp = page.substr(pos,page.find("</title>")-pos); if (temp != "Consumer Status Page") return 0; //fill the consumerlist _consumerlist.erase(_consumerlist.begin(),_consumerlist.end()); pos = page.find("<tr>"); last = page.rfind("</tr>"); if (pos==page.rfind("<tr>")) return 0; //no entries pos = page.find("<tr>",pos+3); while(pos<last) { //read line ConsumerEntry ent; pos = page.find("<td>",pos) + 4; temp = page.substr(pos,page.find("</td>",pos)-pos).c_str(); pos2 = temp.find(">"); cout << temp << " " << pos2 << endl; if(pos2 > 0) ent.name = temp.substr(pos2 + 1,temp.rfind("</font>")-pos2-1).c_str(); else ent.name = temp.c_str(); pos = page.find("<td>",pos) + 4; temp = page.substr(pos,page.find("</td>",pos)-pos).c_str(); pos2 = temp.find(">");cout << temp << " " << pos2 << endl; if(pos2 > 0) ent.hostname = temp.substr(pos2 + 1,temp.rfind("</font>")-pos2-1).c_str(); else ent.hostname = temp.c_str(); pos = page.find("<td>",pos) + 4; ent.port = atoi(page.substr(pos,page.find("</td>",pos)-pos).c_str()); pos = page.find("<td>",pos) + 4; ent.runnumber = atoi(page.substr(pos,page.find("</td>",pos)-pos).c_str()); pos = page.find("<td>",pos) + 4; ent.nevents = atoi(page.substr(pos,page.find("</td>",pos)-pos).c_str()); pos = page.find("<td>",pos) + 4; temp = page.substr(pos,page.find("</td>",pos)-pos); pos2 = temp.find(">") ;cout << temp << " " << pos2 << endl; if(pos2 > 0) temp = temp.substr(pos2 + 1,temp.rfind("</font>") - pos2 - 1).c_str(); for(int i = 0; i < 6; i++) if (strcmp(temp.c_str(),_statusnames[i])==0) { ent.status = i; break; } pos = page.find("</tr>",pos); _consumerlist.push_back(ent); } return 1; }

void ConsumerList::removeEntry (  const char *  hostname, int  port )

Definition at line 126 of file ConsumerList.cc. References _consumerlist. Referenced by addEntry(), and watchServers(). { std::vector<ConsumerEntry>::iterator pos = _consumerlist.end(); for(std::vector<ConsumerEntry>::iterator iter = _consumerlist.begin(); iter != _consumerlist.end(); ++iter) if((iter->hostname == hostname)&&(iter->port == port)) pos = iter; if(pos!=_consumerlist.end()) _consumerlist.erase(pos); }

int ConsumerList::runnumber (  int  i  )  const

Definition at line 80 of file ConsumerList.cc. References _consumerlist. Referenced by ConsumerList::ConsumerEntry::ConsumerEntry(). { return _consumerlist[i].runnumber; }

int ConsumerList::sendList (  const char *  host, const int  port )

Definition at line 373 of file ConsumerList.cc. References _consumerlist, ConsumerList::ConsumerEntry::hostname, ConsumerList::ConsumerEntry::name, ConsumerList::ConsumerEntry::nevents, ConsumerList::ConsumerEntry::port, port, ConsumerList::ConsumerEntry::runnumber, and ConsumerList::ConsumerEntry::status. { ostrstream message; string temp; TSocket sock(host,port); if (!(sock.IsValid())) { cout << "ConsumerList::sendList: socket not valid" << endl; return 0; } message << "ConsumerList" << endl; for(std::vector<ConsumerEntry>::const_iterator iter = _consumerlist.begin(); iter != _consumerlist.end(); ++iter) message << iter->name << endl << iter->hostname << endl << iter->port << endl << iter->runnumber << endl << iter->nevents << endl << iter->status << endl; message << "END" << endl; temp = message.str(); if (sock.SendRaw(temp.c_str(),temp.length()) != (Int_t)temp.length()) { sock.Close(); return 0; } sock.Close(); return 1; }

void ConsumerList::setNevents (  int  i, int  nev )

Definition at line 105 of file ConsumerList.cc. References _consumerlist. Referenced by timer(). { _consumerlist[i].nevents = nev; }

void ConsumerList::setPort (  int  i, int  port )

Definition at line 100 of file ConsumerList.cc. References _consumerlist. { _consumerlist[i].port = port; }

void ConsumerList::setRunnumber (  int  i, int  runn )

Definition at line 115 of file ConsumerList.cc. References _consumerlist. Referenced by timer(). { _consumerlist[i].runnumber = runn; }

void ConsumerList::setStatus (  int  i, int  status )

Definition at line 110 of file ConsumerList.cc. References _consumerlist. Referenced by abbruch(), and DisplayServer::pollConsumer(). { _consumerlist[i].status = status; }

void ConsumerList::setUpdateTime (  int  i, char *  tm )

Definition at line 120 of file ConsumerList.cc. References _consumerlist. { _consumerlist[i].time = tm; }

bool ConsumerList::sortbyName (  const ConsumerEntry  a, const ConsumerEntry  b )  [static]

Definition at line 424 of file ConsumerList.cc. References ConsumerList::ConsumerEntry::name. { return a.name < b.name; }

int ConsumerList::status (  int  i  )  const

Definition at line 85 of file ConsumerList.cc. References _consumerlist. Referenced by ConsumerList::ConsumerEntry::ConsumerEntry(). { return _consumerlist[i].status; }

const char * ConsumerList::statusString (  int  i  )  const

Definition at line 90 of file ConsumerList.cc. References _consumerlist, and _statusnames. { return _statusnames[_consumerlist[i].status]; }

void ConsumerList::test (   )

Definition at line 191 of file ConsumerList.cc. { //unused: const time_t zeit = time(0); /* _consumerlist.push_back(ConsumerEntry("YMon","b0dau31.fnal.gov" ,9090,10,10001,1,ctime(&zeit))); _consumerlist.push_back(ConsumerEntry("WedgeMon","b0dap30.fnal.gov",9091,110,10001,Crashed,ctime(&zeit))); _consumerlist.push_back(ConsumerEntry("XMon","b0dap30.fnal.gov",9092,200,10001,Running,ctime(&zeit))); */ }

const TString & ConsumerList::updateTime (  int  i  )  const

Definition at line 95 of file ConsumerList.cc. References _consumerlist. { return _consumerlist[i].time; }

int ConsumerList::watchServers (  const int  port, const char *  filename )

Definition at line 136 of file ConsumerList.cc. References _consumerlist, ConsumerList::ConsumerEntry::hostname, ConsumerList::ConsumerEntry::name, ConsumerList::ConsumerEntry::nevents, ConsumerList::ConsumerEntry::port, port, removeEntry(), ConsumerList::ConsumerEntry::runnumber, ConsumerList::ConsumerEntry::status, ConsumerList::ConsumerEntry::time, and writeWebPage(). { //unused: TMonitor *monitor = new TMonitor; // open sockets TServerSocket ss(port,kTRUE); if(!(ss.IsValid())) { cout << "ConsumerList::watchServers: serversocket not valid" << endl; return 0; } writeWebPage(filename); while(1) { //cout << "waiting for first connection" << endl; TSocket *sock = ss.Accept(); //cout << "connected from " << sock->GetInetAddress().GetHostName() << endl; char buffer[1000]; string word; sock->RecvRaw(buffer,1000); istrstream message(buffer); //cout << buffer << endl; message >> word; if(word=="ConsumerList") { message >> word; while((word != "END") && message) { // search for name and remove old entry // add new entry ConsumerEntry entry; entry.name = word.c_str(); message >> entry.hostname; message >> entry.port; message >> entry.runnumber; message >> entry.nevents; message >> entry.status; message >> word; // search for hostname and port and remove old entry removeEntry(entry.hostname,entry.port); const time_t zeit = time(0); entry.time = ctime(&zeit); if((entry.status==Running)||(entry.status==Crashed)|| (entry.status==Unknown) && message) _consumerlist.push_back(entry); //cout << word << endl; } //print(); writeWebPage(filename); } // remove connection sock->Close(); delete sock; } }

int ConsumerList::writeWebPage (  const char *  filename  )

Definition at line 273 of file ConsumerList.cc. References _consumerlist, _statusnames, _websitename, ConsumerList::ConsumerEntry::hostname, ConsumerList::ConsumerEntry::name, ConsumerList::ConsumerEntry::nevents, ConsumerList::ConsumerEntry::port, ConsumerList::ConsumerEntry::runnumber, and ConsumerList::ConsumerEntry::time. Referenced by watchServers(). { // sort consumerlist std::sort(_consumerlist.begin(),_consumerlist.end(),sortbyName); const time_t zeit = time(0); //open file std::ofstream page(filename); if (!page) return 0; //write head of page page << "<html> \n <head> \n <title>Consumer Status Page</title>" << endl;; page << "<meta http-equiv=\"cache-control\" content=\"no-cache\">" << endl; page << "<meta http-equiv=\"pragma\" content=\"no-cache\">" << endl; page << "<meta http-equiv=\"Refresh\" content=\"30;url=" << _websitename << "\" >" << endl; page << "<br><br><br><center><h1><u><font color=\"#FF0000\"> Consumer Status Page</center></font></u></h1> \n"; page << "\n </head> \n <body background=\"home/cdfii_ybgr.jpg\"> \n "; page << "<img src=\"home/cdfii_logo.gif\" align=right alt=\"CDF II\" height=100 width=100> \n"; page << "<br><br><br><br><br><br><br><br><br> \n Status of Consumer Processes: \n"; page << "<br> \n <center> <table BORDER COLS=7 WIDTH=\"100%\" NOSAVE> \n"; page << "<tr> \n <td> Consumer </td> \n \n"; page << "<td>Hostname</td> \n \n <td>Port</td> \n \n"; page << "<td>Run number</td> \n \n" ; page << "<td># of Events processed</td> \n \n <td>Status</td>"; page << "\n \n <td>Time</td> \n </tr> \n"; // fill table for(std::vector<ConsumerEntry>::const_iterator iter = _consumerlist.begin(); iter != _consumerlist.end(); ++iter) { if(iter->status == Crashed) page << "<tr> \n <td>" << "<font color=\"#FF0000\">" << iter->name << "</font></td><td>" << "<font color=\"#FF0000\">" << iter->hostname << "</font>" << "</td><td>" << iter->port << "</td><td>" << iter->runnumber << "</td><td>" << iter->nevents << "</td><td>" << "<font color=\"#FF0000\">" <<_statusnames[iter->status] << "</font>" << "</td><td>" << iter->time << "</td></tr>\n"; else page << "<tr> \n <td>" << iter->name << "</td><td>" << iter->hostname << "</td><td>" << iter->port << "</td><td>" << iter->runnumber << "</td><td>" << iter->nevents << "</td><td>" << _statusnames[iter->status] << "</td><td>" << iter->time << "</td></tr>\n"; } // write end of page , time stamp page << "</center> </table>\n"; page << "<br> <br> <br> \n Last Update:" << ctime(&zeit) << "<br> \n"; page << "</body>\n </html> \n"; page.close(); return 1; }

---

Member Data Documentation

std::vector<ConsumerEntry> ConsumerList::_consumerlist [private]

Definition at line 83 of file ConsumerList.h. Referenced by addEntry(), consumername(), hostname(), nEntries(), nevents(), port(), print(), readWebPage(), removeEntry(), runnumber(), sendList(), setNevents(), setPort(), setRunnumber(), setStatus(), setUpdateTime(), status(), statusString(), updateTime(), watchServers(), and writeWebPage().

const char* ConsumerList::_statusnames[6] [private]

Definition at line 85 of file ConsumerList.h. Referenced by ConsumerList(), print(), readWebPage(), statusString(), and writeWebPage().

TString ConsumerList::_websitename [private]

Definition at line 84 of file ConsumerList.h. Referenced by readWebPage(), and writeWebPage().

---

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

• ConsumerList.h
• ConsumerList.cc

---