JobInfoSvc Class Reference

#include <JobInfoSvc.h>

Inheritance diagram for JobInfoSvc:

Public Member Functions
	JobInfoSvc (const std::string &name, ISvcLocator *pSvcLocator)
	~JobInfoSvc ()
StatusCode	initialize ()
StatusCode	finalize ()
StatusCode	queryInterface (const InterfaceID &riid, void **ppvInterface)
void	handle (const Incident &)
int	xmlrpc (int evtNum)
std::string	getJobOutputFile ()
virtual int	xmlrpc (int evtNum)=0
virtual std::string	getJobOutputFile ()=0

Additional Inherited Members
Static Public Member Functions inherited from IJobInfoSvc
static const InterfaceID &	interfaceID ()

Detailed Description

Definition at line 11 of file JobInfoSvc.h.

Constructor & Destructor Documentation

JobInfoSvc()

JobInfoSvc::JobInfoSvc	(	const std::string &	name,
		ISvcLocator *	pSvcLocator
	)

Definition at line 27 of file JobInfoSvc.cxx.

                                                                      :
  Service(name, pSvcLocator) {
    declareProperty("xmlrpcServer", m_xmlrpcServer = "202.122.37.68");
    declareProperty("xmlrpcPort",   m_xmlrpcPort = 8080);
    declareProperty("xmlrpcUrl",    m_xmlrpcUrl = "/bemp/xmlrpc");
    declareProperty("xmlrpcMethod", m_xmlrpcMethod = "SetJobInfo.setEvtNum");
  }

~JobInfoSvc()

JobInfoSvc::~JobInfoSvc ( )

inline

Definition at line 17 of file JobInfoSvc.h.

{};

Member Function Documentation

finalize()

StatusCode JobInfoSvc::finalize

(

)

Definition at line 81 of file JobInfoSvc.cxx.

                                {
  MsgStream log(msgSvc(), name());
  log << MSG::INFO << "in finalize" << endreq;
 
  //Keep this line for log file output please!
  std::cout<< "JobInfoSvc: totle event number =  "<< m_count << std::endl;
 
  //Save event number to job manage database
  xmlrpc(m_count);
 
  return StatusCode::SUCCESS;
}

getJobOutputFile()

std::string JobInfoSvc::getJobOutputFile ( )

virtual

Implements IJobInfoSvc.

Definition at line 113 of file JobInfoSvc.cxx.

                                      {
  MsgStream log(msgSvc(), name());
  std::string outputFileName = "";
 
  IJobOptionsSvc* jobSvc; 
  Gaudi::svcLocator()->service("JobOptionsSvc", jobSvc);
 
  const std::vector<const Property*>* properties_event = jobSvc->getProperties("EventCnvSvc");
  if (properties_event != NULL) {
    for (unsigned int i = 0; i < properties_event->size(); i++) {
      if ((*properties_event)[i]->name() == "digiRootOutputFile") {
    outputFileName = (*properties_event)[i]->toString();
    break;
      }
    }
  }
 
  const std::vector<const Property*>* properties_root = jobSvc->getProperties("RootCnvSvc");
  if (properties_root != NULL) {
    for (unsigned int i = 0; i < properties_root->size(); i++) {
      if ((*properties_root)[i]->name() == "digiRootOutputFile") {
    outputFileName = (*properties_root)[i]->toString();
    break;
      }
    }
  }
 
  //FIXME for RawDataCnvSvc
 
  return outputFileName;
}

Referenced by initialize().

handle()

void JobInfoSvc::handle

(

const Incident &

inc

)

Definition at line 69 of file JobInfoSvc.cxx.

                                          {
  MsgStream log( messageService(), name() );
 
  log << MSG::DEBUG << "handle: " << inc.type() << endreq;
  if ( inc.type() == "BeginEvent" ){
    log << MSG::DEBUG << "Begin Event" << endreq;
    //count execute time
    m_count++;
  }
}

initialize()

StatusCode JobInfoSvc::initialize

(

)

Definition at line 35 of file JobInfoSvc.cxx.

                                 {
  MsgStream log( msgSvc(), name() );
  log << MSG::INFO << "in initialize" << endreq;
 
  StatusCode sc = Service::initialize();
  if( sc.isFailure() ) return sc;
 
  IIncidentSvc* incsvc;
  sc = service("IncidentSvc", incsvc);
  int priority = 100;
  if( sc.isSuccess() ){
    incsvc -> addListener(this, "BeginEvent", priority);
  }
 
  m_outputFileName = getJobOutputFile();
  m_count = 0;
 
  //Set initialize value of real event number
  xmlrpc(-1);
 
  return StatusCode::SUCCESS;
}

queryInterface()

StatusCode JobInfoSvc::queryInterface	(	const InterfaceID &	riid,
		void **	ppvInterface
	)

Definition at line 58 of file JobInfoSvc.cxx.

{
  if ( IJobInfoSvc::interfaceID().versionMatch(riid) )    {
    *ppvInterface = (IJobInfoSvc*)this;
  }else{ 
    return Service::queryInterface(riid, ppvInterface);
  }
  addRef();
  return StatusCode::SUCCESS;
}

xmlrpc()

int JobInfoSvc::xmlrpc ( int  evtNum )

virtual

Implements IJobInfoSvc.

Definition at line 94 of file JobInfoSvc.cxx.

                                {
  MsgStream log(msgSvc(), name());
 
  XmlRpcClient c(m_xmlrpcServer.c_str(), m_xmlrpcPort, m_xmlrpcUrl.c_str());
  XmlRpcValue args, result;
 
  args[0] = m_outputFileName; 
  args[1] = evtNum;
 
  if (args[0] != "" && c.execute(m_xmlrpcMethod.c_str(), args, result)){
    log << MSG::INFO << " set evtNum = "<< evtNum << endreq;
  }else{
    log << MSG::ERROR<< " Error in execute "<< m_xmlrpcMethod << endreq;
    return -1;
  }
 
  return 0;
}

Referenced by finalize(), and initialize().

---

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

• JobInfoSvc.h
• JobInfoSvc.cxx