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 ()
void	handle (const Incident &)
int	xmlrpc (int evtNum)
std::string	getJobOutputFile ()

Detailed Description

Definition at line 12 of file JobInfoSvc.h.

Constructor & Destructor Documentation

JobInfoSvc()

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

Definition at line 23 of file JobInfoSvc.cxx.

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

Referenced by JobInfoSvc().

~JobInfoSvc()

JobInfoSvc::~JobInfoSvc ( )

inline

Definition at line 16 of file JobInfoSvc.h.

{};

Member Function Documentation

finalize()

StatusCode JobInfoSvc::finalize

(

)

Definition at line 75 of file JobInfoSvc.cxx.

                                {
  MsgStream log( msgSvc(), name() );
  log << MSG::INFO << "in finalize" << endmsg;
 
  // 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

(

)

Definition at line 108 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;
  //         }
  //     }
  // }
 
  auto evtCnvSvcProp    = serviceLocator()->service<IProperty>( "EventCnvSvc" );
  auto properties_event = evtCnvSvcProp->getProperties();
  for ( auto prop : properties_event )
    if ( prop->name() == "digiRootOutputFile" )
    {
      outputFileName = prop->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;
  //         }
  //     }
  // }
 
  auto rootCnvSvcProp  = serviceLocator()->service<IProperty>( "RootCnvSvc" );
  auto properties_root = rootCnvSvcProp->getProperties();
  for ( auto prop : properties_root )
    if ( prop->name() == "digiRootOutputFile" )
    {
      outputFileName = prop->toString();
      break;
    }
 
  // FIXME for RawDataCnvSvc
 
  return outputFileName;
}

Referenced by initialize().

handle()

void JobInfoSvc::handle

(

const Incident &

inc

)

Definition at line 63 of file JobInfoSvc.cxx.

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

initialize()

StatusCode JobInfoSvc::initialize

(

)

Definition at line 31 of file JobInfoSvc.cxx.

                                  {
  MsgStream log( msgSvc(), name() );
  log << MSG::INFO << "in initialize" << endmsg;
 
  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;
}

xmlrpc()

int JobInfoSvc::xmlrpc

(

int

evtNum

)

Definition at line 88 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 << endmsg; }
  else
  {
    log << MSG::ERROR << " Error in execute " << m_xmlrpcMethod << endmsg;
    return -1;
  }
 
  return 0;
}

Referenced by finalize(), and initialize().

---

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

• JobInfoSvc.h
• JobInfoSvc.cxx