CalibRootCnvSvc Class Reference

--------------------------------------------------------------------------- More...

#include <CalibRootCnvSvc.h>

Inheritance diagram for CalibRootCnvSvc:

List of all members.

Public Member Functions
virtual StatusCode	queryInterface (const InterfaceID &riid, void **ppvInterface)
virtual StatusCode	writeToRoot (const std::string &outputFile, const std::string &tdsPath)
virtual StatusCode	writeToRoot (const std::string &outputFile, CalibData::CalibBase1 *calib)
virtual StatusCode	updateObj (IOpaqueAddress *pAddress, DataObject *pObject)
virtual StatusCode	initialize ()
virtual StatusCode	finalize ()
virtual StatusCode	createAddress (long svc_type, const CLID &clid, const std::string *par, const unsigned long *ip, IOpaqueAddress *&refpAddress)
std::string	getrootfile ()
StatusCode	decodeDescription (const std::string &oldpath, std::string &realpath)
Static Public Member Functions
static const InterfaceID &	interfaceID ()
Protected Member Functions
	CalibRootCnvSvc (const std::string &name, ISvcLocator *svc)
virtual	~CalibRootCnvSvc ()
Private Attributes
IConversionSvc *	m_detPersSvc
	Handle to the IConversionSvc interface of the DetectorPersistencySvc.
IDataProviderSvc *	m_detDataSvc
	Handle to IDataProviderSvc interface of CalibDataSvc.
std::string	m_rootfile [10]
Friends
class	SvcFactory< CalibRootCnvSvc >
	Only factories can access protected constructors.

---

Detailed Description

---------------------------------------------------------------------------

A conversion service for GLAST calibration bulk data in ROOT format.

Author:

J. Bogart

Date:

July 2004

Definition at line 42 of file CalibRootCnvSvc.h.

---

Constructor & Destructor Documentation

CalibRootCnvSvc::CalibRootCnvSvc	(	const std::string &	name,
		ISvcLocator *	svc
	)			[protected]

Definition at line 23 of file CalibRootCnvSvc.cxx.

References m_rootfile, and deljobs::string.

                                                 :
  ConversionSvc(name, svc, CALIBROOT_StorageType),
  m_detPersSvc(0), m_detDataSvc(0)   {
  //huangb add
  declareProperty("Mdcrootfile",m_rootfile[0]= std::string("no rootfile"));
  declareProperty("Tofrootfile",m_rootfile[1]= std::string("no rootfile"));
  declareProperty("Dedxrootfile",m_rootfile[2]= std::string("no rootfile"));
  declareProperty("Emcrootfile",m_rootfile[3]= std::string("no rootfile"));
  declareProperty("Mucrootfile",m_rootfile[4]= std::string("no rootfile"));
  declareProperty("EsTimerootfile",m_rootfile[5]= std::string("no rootfile"));
  declareProperty("EstTofrootfile",m_rootfile[6]= std::string("no rootfile"));
  declareProperty("TofQElecrootfile",m_rootfile[7]= std::string("no rootfile"));
  declareProperty("TofSimrootfile",m_rootfile[8]= std::string("no rootfile"));
  declareProperty("DedxSimrootfile",m_rootfile[9]= std::string("no rootfile"));
  // Some day might have a property to declare having to do with path to
  // xml files.
}

virtual CalibRootCnvSvc::~CalibRootCnvSvc

(

)

[inline, protected, virtual]

Definition at line 50 of file CalibRootCnvSvc.h.

{}

---

Member Function Documentation

StatusCode CalibRootCnvSvc::createAddress	(	long	svc_type,
		const CLID &	clid,
		const std::string *	par,
		const unsigned long *	ip,
		IOpaqueAddress *&	refpAddress
	)			[virtual]

Create a ROOT address using explicit arguments to identify a single object

Parameters:

	svc_type	the service type
	CLID	the CLID of the ROOT Element for which an address is created
	par	an array of three strings containing the format version, calibration type name and the flavor, in this order
	ip	has a single element, the serial number of the MySQL row which corresponds to this element
	refpAddress	the new address created

Returns:

a StatusCode giving the status of the address creation

Definition at line 141 of file CalibRootCnvSvc.cxx.

References CALIBROOT_StorageType, CLID_Calib_DedxCal, CLID_Calib_EmcCal, CLID_Calib_EsTimeCal, CLID_Calib_EstTofCal, CLID_Calib_MdcCal, CLID_Calib_MucCal, CLID_Calib_TofCal, CLID_Calib_TofSim, CLID_Dedx_Sim, CLID_TofQ_Elec, Bes_Common::DEBUG, decodeDescription(), calibUtil::ERROR, Bes_Common::INFO, m_rootfile, msgSvc(), deljobs::string, and Bes_Common::WARNING.

                                                                          {
  MsgStream log( msgSvc(), name() );
   log << MSG::DEBUG<<"here is the createAddress in the CalibRootCnvSvc"<<endreq;
   if (svc_type != CALIBROOT_StorageType) {
    log << MSG::ERROR << "bad storage type" << (int)svc_type << endreq;
    return StatusCode::FAILURE;
  }
   std::cout<<"clid=="<<clid<<std::endl;
    std::string dataIdent;
    std::string fullpath;
    int index=-99;
    if(clid==6412) return StatusCode::SUCCESS;
    if(clid==CLID_Calib_MdcCal) 
      { index=0;}
    else if(clid==CLID_Calib_TofCal)
      {index =1;}
    else if(clid==CLID_Calib_DedxCal)
      {index =2;}
    else if(clid==CLID_Calib_EmcCal)
      {index =3;}
    else if(clid==CLID_Calib_MucCal)
      {index =4;}
    else if(clid==CLID_Calib_EsTimeCal)   
       {index =5;} 
    else if(clid==CLID_Calib_EstTofCal)
      {index =6;}
     else if(clid==CLID_TofQ_Elec)
      {index =7;}
     else if(clid==CLID_Calib_TofSim)
      {index =8;}
     else if(clid==CLID_Dedx_Sim)
      {index =9;}

    else{ 
      log << MSG::WARNING<<"Wrong CLID"<<endreq;
    }
    std::cout<<"index=="<<index<<std::endl;
  //see if svctype set in the CalibDataSvc is MYSQL_StorageType or  CALIBROOT_StorageType
 /* IInstrumentName* iInstrumentName;
  StatusCode sc = m_detDataSvc->queryInterface(IID_IInstrumentName,
                                    (void**) &iInstrumentName);

  if ( !sc.isSuccess() ) {
    log << MSG::ERROR
        << "Cannot query IInstrumentName interface of CalibDataSvc"
        << endreq;
    return sc;
  } else {
    log << MSG::DEBUG
        << "Retrieved IInstrumentName interface of CalibDataSvc"
        << endreq;
  }

   int svctype = iInstrumentName->getsvctype();
    if(svctype== CALIBROOT_StorageType)
      {
*/ 
//      dataIdent = m_rootfile[index];
if(m_rootfile[index]=="no rootfile")
{
log << MSG::INFO<<"no sepcified calibration file path of type "<< index <<endreq;
return StatusCode::FAILURE;
}
        decodeDescription(m_rootfile[index],dataIdent);
        fullpath = par[0];
  /*    }

   if(svctype== MYSQL_StorageType)
      {   log << MSG::INFO<<"rootfile is not set in the jobOption,get it from MySQL"<<endreq;
      dataIdent = par[0];
      fullpath = par[1];
      }

   if ((svctype != CALIBROOT_StorageType)&&(svctype!= MYSQL_StorageType)) {
    log << MSG::ERROR << "bad storage type" << (int)svctype << endreq;
    return StatusCode::FAILURE;
  }
*/

   // std::string dataIdent(par[0]); // file identifier for PDS version of data
   log << MSG::INFO<<"dataIdent is:"<<dataIdent<<endreq;
   //std::string fullpath(par[1]);  // path within TCDS for the object
   log << MSG::INFO<<"fullpath is :"<<fullpath<<endreq;
 
 
   int runfrm = ip[0];
   int runto = ip[1];
  
   // for now have to ignore fmtVersion because of defective implementation
  // of GenericAddress. If we want it, should probably write new
  // opaque address implementation for this package to use.  All
  // dealings with (calibration) opaque addresses are confined to
  // the CalibSvc package.
  refpAddress = new GenericAddress(CALIBROOT_StorageType,
                                   clid,
                                   dataIdent,  
                                   fullpath,
                                   runfrm,
                                   runto);
                                   
  return StatusCode::SUCCESS; 

}

StatusCode CalibRootCnvSvc::decodeDescription	(	const std::string &	oldpath,
		std::string &	realpath
	)

Definition at line 307 of file CalibRootCnvSvc.cxx.

References genRecEmupikp::i, msgSvc(), RealDBUtil::npos, and deljobs::string.

Referenced by createAddress().

{
  MsgStream log(msgSvc(), "CalibMySQLCnvSvc");
 
   if(oldpath[0]!='$'){
     realpath=oldpath;
   }
  if(oldpath[0]=='$'){
    std::string::size_type idx =oldpath.find("/");
     if( std::string::npos != idx )
   {  std::string relpath;
      for(int i=1;i<idx-1;i++){
        relpath[i-1] = oldpath[i];
      }
      std::string otherpath;
      for(int i=idx-1;i<oldpath.size();i++){
        otherpath[i-idx+1]=oldpath[i];
      }
    realpath =  std::string(getenv(relpath.c_str()))+otherpath;
    }
   if( std::string::npos == idx ){
     std::string relpath;
      for(int i=1;i<oldpath.size();i++){
        relpath[i-1] = oldpath[i];
      }
     realpath = std::string(getenv(relpath.c_str()));
   }
   }

  return StatusCode::SUCCESS;
}

StatusCode CalibRootCnvSvc::finalize

(

)

[virtual]

Definition at line 134 of file CalibRootCnvSvc.cxx.

                                     {
  // If anything was allocated, get rid of it.  So far, nothing was.

  return ConversionSvc::finalize();
}

std::string CalibRootCnvSvc::getrootfile

(

)

[inline, virtual]

Implements ICalibRootSvc.

Definition at line 91 of file CalibRootCnvSvc.h.

References m_rootfile.

        { return m_rootfile[0];}

StatusCode CalibRootCnvSvc::initialize

(

)

[virtual]

Definition at line 57 of file CalibRootCnvSvc.cxx.

References Bes_Common::DEBUG, calibUtil::ERROR, m_detDataSvc, m_detPersSvc, and msgSvc().

                                       {
  StatusCode sc = ConversionSvc::initialize();

  MsgStream log(msgSvc(), "CalibRootCnvSvc");

  if (!sc.isSuccess()) return sc;

  // Locate the Calib Data Service.  Since it inherits from DataSvc
  // it has to implement IDataProviderSvc
  m_detDataSvc = 0;
  /*sc = serviceLocator()->getService 
    ("CalibDataSvc",  IID_IDataProviderSvc,(IInterface*&) m_detDataSvc);*/
  sc = serviceLocator()->getService 
    ("CalibDataSvc",  IDataProviderSvc::interfaceID(),(IInterface*&) m_detDataSvc);
  if ( !sc.isSuccess() ) {
    log << MSG::ERROR << "Could not locate CalibDataSvc" << endreq;
    return sc;
  }

 /*  IInstrumentName* iInstrumentName;
  sc = m_detDataSvc->queryInterface(IID_IInstrumentName,
                                    (void**) &iInstrumentName);
*/
  // Set the CalibDataSvc as data provider service
  sc = setDataProvider(m_detDataSvc);
  if ( !sc.isSuccess() ) {
    log << MSG::ERROR << "Could not set data provider" << endreq;
    return sc;
  }
  //huangb add 
 sc = setProperties();

  // Locate IConversionSvc interface of the DetectorPersistencySvc
  sc = serviceLocator()->service 
    ("DetectorPersistencySvc", m_detPersSvc, true);
  if ( !sc.isSuccess() ) {
    log << MSG::ERROR 
        << "Cannot locate IConversionSvc interface of DetectorPersistencySvc"
        << endreq;
    return sc;
  } else {
    log << MSG::DEBUG 
        << "Retrieved IConversionSvc interface of DetectorPersistencySvc"
        << endreq;
  }
  
  // Query the IAddressCreator interface of the detector persistency service
  IAddressCreator* iAddrCreator;
/*  sc = m_detPersSvc->queryInterface(IID_IAddressCreator, 

                                    (void**) &iAddrCreator);*/

  sc = m_detPersSvc->queryInterface(IAddressCreator::interfaceID(), 
                                    (void**) &iAddrCreator);
  if ( !sc.isSuccess() ) {
    log << MSG::ERROR 
        << "Cannot query IAddressCreator interface of DetectorPersistencySvc" 
        << endreq;
    return sc;
  } else {
    log << MSG::DEBUG 
        << "Retrieved IAddressCreator interface of DetectorPersistencySvc" 
        << endreq;
  }
  log << MSG::DEBUG 
      << "Set it as the address creator of the CalibRootCnvSvc" << endreq;
  sc = setAddressCreator(iAddrCreator);
  if ( !sc.isSuccess() ) {
    log << MSG::ERROR   << "Cannot set the address creator" << endreq;
    return sc;
  }

  // set properties if there are any??

  return sc;
}

static const InterfaceID& ICalibRootSvc::interfaceID

(

)

[inline, static, inherited]

Definition at line 36 of file ICalibRootSvc.h.

References IID_ICalibRootSvc().

{ return IID_ICalibRootSvc; }

StatusCode CalibRootCnvSvc::queryInterface	(	const InterfaceID &	riid,
		void **	ppvInterface
	)			[virtual]

Definition at line 42 of file CalibRootCnvSvc.cxx.

References IID_ICalibRootSvc().

                                                               {
  /* Uncomment if choose to derive from abstract root conv. interface */
  if (IID_ICalibRootSvc.versionMatch(riid))  {
    *ppvInterface = (ICalibRootSvc*)this;
  }
  else {
    // Interface is not directly availible: try out a base class
    return ConversionSvc::queryInterface(riid, ppvInterface);
    /*  }  */
  addRef();
  }
  return StatusCode::SUCCESS;
}

StatusCode CalibRootCnvSvc::updateObj	(	IOpaqueAddress *	pAddress,
		DataObject *	pObject
	)			[virtual]

Definition at line 290 of file CalibRootCnvSvc.cxx.

References Bes_Common::DEBUG, and msgSvc().

                                                                  {

  //  using facilities::Timestamp;

   MsgStream log(msgSvc(), "CalibRootCnvSvc" );
   
   // Don't update when we're using enter time
   log << MSG::DEBUG << "CalibRootCnvSvc::updateObj starting ...."<<endreq;
   /*
   if (!m_useEventTime) 
     {  log << MSG::DEBUG << "Method updateObj needn't update" << endreq;
        return StatusCode::SUCCESS;
     }
   */
}

StatusCode CalibRootCnvSvc::writeToRoot	(	const std::string &	outputFile,
		CalibData::CalibBase1 *	calib
	)			[virtual]

Implements ICalibRootSvc.

Definition at line 270 of file CalibRootCnvSvc.cxx.

References RootCalBaseCnv::createRoot(), and msgSvc().

                                                                     {
  MsgStream log(msgSvc(), name() );
 // Find converter corresponding to this object
  IConverter* converter = ConversionSvc::converter(pCalib->clID());
  if (!converter) {
    log << "No converter found for object with CLID  " << pCalib->clID()
        << endreq;
    return StatusCode::FAILURE;
  }
  RootCalBaseCnv* pCnv = dynamic_cast<RootCalBaseCnv*>(converter);
  if (!pCnv) {
    log << "Converter for CLID " << pCalib->clID() <<  " not of proper type" 
        << endreq;
    return StatusCode::FAILURE;
  }
  // Call its createRoot method
  return pCnv->createRoot(outfile, pCalib);
}

StatusCode CalibRootCnvSvc::writeToRoot	(	const std::string &	outputFile,
		const std::string &	tdsPath
	)			[virtual]

Method to write a ROOT file corresponding to TDS object

Parameters:

fileName

the name of the file to be written

Returns:

the document issued from the parsing

Implements ICalibRootSvc.

Definition at line 249 of file CalibRootCnvSvc.cxx.

References m_detDataSvc, and msgSvc().

                                                                  {
  MsgStream log( msgSvc(), name() );

  // Find corresponding object
  DataObject* pObj;
  m_detDataSvc->findObject(tdsPath, pObj);
  if (!pObj) {
    log << "No object in TDS with path " << tdsPath << endreq;
    return StatusCode::FAILURE;
  }

  CalibData::CalibBase1* pCalib = 
    dynamic_cast<CalibData::CalibBase1*> (pObj);

  if (!pCalib) {
    log << "Object with path " << tdsPath << " not of proper type" << endreq;
    return StatusCode::FAILURE;
  }
  return writeToRoot(outfile, pCalib);
}

---

Friends And Related Function Documentation

friend class SvcFactory< CalibRootCnvSvc > [friend]

Only factories can access protected constructors.

Definition at line 45 of file CalibRootCnvSvc.h.

---

Member Data Documentation

IDataProviderSvc* CalibRootCnvSvc::m_detDataSvc [private]

Handle to IDataProviderSvc interface of CalibDataSvc.

Definition at line 113 of file CalibRootCnvSvc.h.

Referenced by initialize(), and writeToRoot().

IConversionSvc* CalibRootCnvSvc::m_detPersSvc [private]

Handle to the IConversionSvc interface of the DetectorPersistencySvc.

Definition at line 110 of file CalibRootCnvSvc.h.

Referenced by initialize().

std::string CalibRootCnvSvc::m_rootfile[10] [private]

Definition at line 114 of file CalibRootCnvSvc.h.

Referenced by CalibRootCnvSvc(), createAddress(), and getrootfile().

---