RawDataCnvSvc Class Reference

#include <RawDataCnvSvc.h>

Inheritance diagram for RawDataCnvSvc:

List of all members.

Public Member Functions
virtual StatusCode	initialize ()
virtual StatusCode	finalize ()
virtual StatusCode	declareObject (const IRawDataCnvSvc::Leaf &leaf)
	Associates a path on TDS with a particular converter.
virtual StatusCode	queryInterface (const InterfaceID &riid, void **ppvInterface)
	Override inherited queryInterface due to enhanced interface.
virtual StatusCode	createAddress (long svc_type, const CLID &clid, const std::string *par, const unsigned long *ip, IOpaqueAddress *&refpAddress)
virtual StatusCode	createAddress (long storageType, const CLID &clid, const std::string &, IOpaqueAddress *&refpAddress)
Protected Member Functions
virtual StatusCode	addConverters ()=0
StatusCode	updateServiceState (IOpaqueAddress *pAddress)
	Update state of the service.
	RawDataCnvSvc (const std::string &name, ISvcLocator *svc, long storageTyp)
virtual	~RawDataCnvSvc ()
Private Types
typedef std::map< std::string, Leaf * >	LeafMap
	Map with leaf entries containing TDS paths.
Private Attributes
LeafMap	m_leaves
Friends
class	SvcFactory< RawDataCnvSvc >

---

Detailed Description

class RawDataCnvSvc Conversion Service which coordinates all of converters.

When a component requests an item not yet available on the TDS, the RawDataCnvSvc is called to find the appropriate converter to gain access to the data and put it on the TDS.

Based on GLAST's EfbCnvSvc

Definition at line 23 of file RawDataCnvSvc.h.

---

Member Typedef Documentation

typedef std::map<std::string, Leaf*> RawDataCnvSvc::LeafMap [private]

Map with leaf entries containing TDS paths.

Definition at line 28 of file RawDataCnvSvc.h.

---

Constructor & Destructor Documentation

RawDataCnvSvc::RawDataCnvSvc	(	const std::string &	name,
		ISvcLocator *	svc,
		long	storageTyp
	)			[protected]

Definition at line 23 of file RawDataCnvSvc.cxx.

: ConversionSvc(name, svc, storageType)              
{
}

virtual RawDataCnvSvc::~RawDataCnvSvc

(

)

[inline, protected, virtual]

Definition at line 61 of file RawDataCnvSvc.h.

{ };

---

Member Function Documentation

virtual StatusCode RawDataCnvSvc::addConverters

(

)

[protected, pure virtual]

Implemented in PackedRawDataCnvSvc.

Referenced by initialize().

StatusCode RawDataCnvSvc::createAddress	(	long	storageType,
		const CLID &	clid,
		const std::string &	,
		IOpaqueAddress *&	refpAddress
	)			[virtual]

Definition at line 184 of file RawDataCnvSvc.cxx.

References createAddress().

{
  return createAddress(storageType, clid, NULL, NULL, refpAddress);
}

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

Definition at line 162 of file RawDataCnvSvc.cxx.

References calibUtil::ERROR, and msgSvc().

Referenced by createAddress(), and updateServiceState().

{
    MsgStream log( msgSvc(), name() );
    
    if (storageType != repSvcType() ) {
        log << MSG::ERROR << "bad storage type" << storageType << endreq;
        return StatusCode::FAILURE;
    }

    refpAddress = new GenericAddress(storageType,
                                     clid,
                                     "",  
                                     "",
                                     0);

    return StatusCode::SUCCESS;
}

StatusCode RawDataCnvSvc::declareObject

(

const IRawDataCnvSvc::Leaf &

leaf

)

[virtual]

Associates a path on TDS with a particular converter.

Implements IRawDataCnvSvc.

Definition at line 83 of file RawDataCnvSvc.cxx.

References m_leaves, IRawDataCnvSvc::Leaf::path, and dchain::value_type().

Referenced by PackedRawDataCnvSvc::addConverters().

                                                                        {
    // Purpose and Method:  Callback from each of the individual converters that allows
    //  association of TDS path and converter.
    Leaf* ll = new Leaf(leaf);
    std::pair<LeafMap::iterator, bool> p = m_leaves.insert(LeafMap::value_type( leaf.path, ll) );
    if( p.second )    {
        return StatusCode::SUCCESS;
    }
    delete ll;
    return StatusCode::FAILURE;
}

StatusCode RawDataCnvSvc::finalize

(

)

[virtual]

Definition at line 74 of file RawDataCnvSvc.cxx.

References m_leaves.

                                       {
    StatusCode status = ConversionSvc::finalize();
    for (LeafMap::iterator k = m_leaves.begin(); k != m_leaves.end(); k++ )   {
        delete (*k).second;
    }
    m_leaves.erase(m_leaves.begin(), m_leaves.end());
    return status;
}

StatusCode RawDataCnvSvc::initialize

(

)

[virtual]

Reimplemented in PackedRawDataCnvSvc.

Definition at line 28 of file RawDataCnvSvc.cxx.

References addConverters(), calibUtil::ERROR, for, ganga-rec::j, m_leaves, and deljobs::string.

Referenced by PackedRawDataCnvSvc::initialize().

                                         {
    // Purpose and Method:  Setup Converter Service.
    //   Associate RawDataCnvSvc with the EventDataSvc
    //   Associate the list of known converters with this RawDataCnvSvc.

    MsgStream log(messageService(), name());
 
    StatusCode iret;
    StatusCode status = ConversionSvc::initialize();
    if ( status.isSuccess() )   {

        IDataProviderSvc *pIDP = 0;
        // Set event data service
        status = service("EventDataSvc", pIDP, true);
        if ( status.isSuccess() )   {
            status = setDataProvider ( pIDP );
        }
        else    {
            return status;
        }

        // Add converters to the service 
        status = addConverters();
        if ( !status.isSuccess() )   {
          log << MSG::ERROR << "Unable to add converters to the service" << endreq;
          return status;
        }

        // Now we have to configure the map of leaves
        // Which should contain the association of converters with 
        // paths on the TDS
        for (LeafMap::iterator k = m_leaves.begin(); k != m_leaves.end(); k++ )   {
            std::string path = (*k).first;
            for (LeafMap::iterator j = m_leaves.begin(); j != m_leaves.end(); j++ )   {
                std::string pp = (*j).first.substr(0, (*j).first.rfind("/"));
                if ( path == pp && path != (*j).first )   {
                    (*k).second->push_back((*j).second);
                }
            }
        }
        
    }

    return status;
}

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

Override inherited queryInterface due to enhanced interface.

Reimplemented in PackedRawDataCnvSvc.

Definition at line 150 of file RawDataCnvSvc.cxx.

References IID_IRawDataCnvSvc().

                                                                                      {
    if ( IID_IRawDataCnvSvc == riid )  {
        *ppvInterface = (IRawDataCnvSvc*)this;
    }
    else  {
        // Interface is not directly availible: try out a base class
        return ConversionSvc::queryInterface(riid, ppvInterface);
    }
    addRef();
    return StatusCode::SUCCESS;
}

StatusCode RawDataCnvSvc::updateServiceState

(

IOpaqueAddress *

pAddress

)

[protected]

Update state of the service.

Reimplemented in PackedRawDataCnvSvc.

Definition at line 96 of file RawDataCnvSvc.cxx.

References createAddress(), if(), ir, m_leaves, msgSvc(), and deljobs::string.

Referenced by PackedRawDataCnvSvc::updateServiceState().

                                                                        {
    
    // not sure about the use of recid or bank...
    MsgStream log(msgSvc(), name());
    
    StatusCode status = INVALID_ADDRESS;
    IRegistry* ent = pAddress->registry();

    if ( 0 != ent )   {
      SmartIF<IDataManagerSvc> iaddrReg( dataProvider());
 //       if ( 0 != iaddrReg )   {
      status = StatusCode::SUCCESS;
      std::string path = ent->identifier();

      LeafMap::iterator itm = m_leaves.find(path);
      if ( itm != m_leaves.end() ) {
        IRawDataCnvSvc::Leaf* leaf = (*itm).second;
        if ( 0 != leaf )    {
          //ipar[0] = leaf->userParameter;
          for ( Leaf::iterator il = leaf->begin(); il != leaf->end(); il++ )   {
            IOpaqueAddress* newAddr = 0;
            unsigned long ipars[2] = {0, 0}; //{(*il)->userParameter, new_rid};
            const std::string spars[2] = {"", ""}; //{par[0], (*il)->bank};
            /* fix for Gaidi V16r4  -- Weidong Li 2005.10.25 
            StatusCode ir =
              addressCreator()->createAddress(storageType, 
                                              (*il)->clid, 
                                              spars, 
                                              ipars,
                                              newAddr);
            */
            StatusCode ir = createAddress(repSvcType(), 
                                              (*il)->clid, 
                                              spars, 
                                              ipars,
                                              newAddr);
            if ( ir.isSuccess() )   {
              ir = iaddrReg->registerAddress((*il)->path, newAddr);            
              if ( !ir.isSuccess() )    {
                newAddr->release();
                status = ir;
              }
            }
          }
        }
      }
    }
    else  {
       status = NO_INTERFACE;
    }
    
    return status;
}

---

Friends And Related Function Documentation

friend class SvcFactory< RawDataCnvSvc > [friend]

Definition at line 25 of file RawDataCnvSvc.h.

---

Member Data Documentation

LeafMap RawDataCnvSvc::m_leaves [private]

Definition at line 29 of file RawDataCnvSvc.h.

Referenced by declareObject(), finalize(), initialize(), and updateServiceState().

---