EventWriter Class Reference

#include <EventWriter.h>

List of all members.

Public Member Functions
	EventWriter (const std::string &name, ISvcLocator *pSvcLocator)
	~EventWriter ()
StatusCode	initialize ()
StatusCode	execute ()
StatusCode	finalize ()
Private Types
typedef std::vector< DataStoreItem * >	Items
typedef std::vector< std::string >	ItemNames
Private Member Functions
virtual std::string	getJobOptions ()
virtual std::string	getDecayOptions ()
StatusCode	getSvc ()
void	addItem (Items &itms, const std::string &descriptor)
void	clearItems (Items &items)
DataStoreItem *	findItem (const std::string &path)
StatusCode	collectObjects ()
Private Attributes
IDataManagerSvc *	m_pDataManager
IDataProviderSvc *	m_pDataProvider
IConversionSvc *	m_pConversionSvc
IDataStoreAgent *	m_pAgent
DataStoreItem *	m_currentItem
RootInterface *	m_pRootInterface
RootCnvSvc *	m_cnvSvc
TRecTrackEvent *	m_trkEvt
TDigiEvent *	m_digiEvt
TMcEvent *	m_mcEvt
THltEvent *	m_hltEvt
TEvtHeader *	m_evtHd
commonData	m_common
TFile *	m_single_outputFiles
TTree *	m_single_outputTrees
TTree *	m_jobInfoTree
int	st
string	m_dofileName
string	m_dofileName_1
Items	m_itemList
ItemNames	m_itemNames
std::vector< std::string >	m_jobOptions
std::string	m_bossVer
std::string	m_decayOptions
TJobInfo *	jobInfo
int	m_mode
std::string	m_svrName
TBossFullEvent *	m_TFullEvt
NetDataWriter *	m_writer
int	m_bufsize
char *	m_cbuf

---

Detailed Description

Definition at line 32 of file EventWriter.h.

---

Member Typedef Documentation

typedef std::vector<std::string> EventWriter::ItemNames [private]

Definition at line 60 of file EventWriter.h.

typedef std::vector<DataStoreItem*> EventWriter::Items [private]

Definition at line 59 of file EventWriter.h.

---

Constructor & Destructor Documentation

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

Definition at line 22 of file EventWriter.cxx.

References m_dofileName, m_itemNames, and m_mode.

                                                                        :
  Algorithm(name, pSvcLocator)
{
  m_itemNames.push_back("/Event");
  m_itemNames.push_back("/Event/EventHeader");
  m_itemNames.push_back("/Event/Navigator");

  m_itemNames.push_back("/Event/Digi");
  m_itemNames.push_back("/Event/Digi/MdcDigiCol");
  m_itemNames.push_back("/Event/Digi/TofDigiCol");
  m_itemNames.push_back("/Event/Digi/EmcDigiCol");
  m_itemNames.push_back("/Event/Digi/MucDigiCol");

  m_itemNames.push_back("/Event/Hlt");
  m_itemNames.push_back("/Event/Hlt/HltRawCol");
  m_itemNames.push_back("/Event/Hlt/HltInf");
  //m_itemNames.push_back("/Event/Hlt/DstHltInf");

  m_itemNames.push_back("/Event/Recon");
  //  m_itemNames.push_back("/Event/Recon/RecMdcHitCol");  
  m_itemNames.push_back("/Event/Recon/RecMdcTrackCol"); 
  //   m_itemNames.push_back("/Event/Recon/MdcHOTCol"); 
  m_itemNames.push_back("/Event/Recon/RecMdcDedxCol");
  //    m_itemNames.push_back("/Event/Recon/RecMdcDedxHitCol");
  m_itemNames.push_back("/Event/Recon/RecMdcKalTrackCol");
  //   m_itemNames.push_back("/Event/Recon/RecMdcKalHelixSegCol");
  m_itemNames.push_back("/Event/Recon/RecEsTimeCol");
  m_itemNames.push_back("/Event/Recon/RecExtTrackCol");
  //    m_itemNames.push_back("/Event/Recon/RecBTofHitCol");     
  //    m_itemNames.push_back("/Event/Recon/RecETofHitCol");    
  m_itemNames.push_back("/Event/Recon/RecTofTrackCol");     
  //    m_itemNames.push_back("/Event/Recon/RecBTofCalHitCol");
  //    m_itemNames.push_back("/Event/Recon/RecETofCalHitCol");   
  m_itemNames.push_back("/Event/Recon/RecEmcHitCol");    
  m_itemNames.push_back("/Event/Recon/RecEmcClusterCol");
  m_itemNames.push_back("/Event/Recon/RecEmcShowerCol");
  //    m_itemNames.push_back("/Event/Recon/MucRecHitCol");
  m_itemNames.push_back("/Event/Recon/RecMucTrackCol"); 
  m_itemNames.push_back("/Event/Recon/EvtRecEvent");
  m_itemNames.push_back("/Event/Recon/EvtRecTrackCol");
  //    m_itemNames.push_back("/Event/Recon/EvtRecVertexCol");    

  // Part 1: Declare the properties
  declareProperty("digiRootOutputFile",m_dofileName = "event.rec");
  declareProperty("ItemList",m_itemNames);
  declareProperty("RunMode", m_mode = 2);
}

EventWriter::~EventWriter

(

)

Definition at line 71 of file EventWriter.cxx.

References Bes_Common::INFO, and msgSvc().

                         {
  // Part 1: Get the messaging service, print where you are
  MsgStream log(msgSvc(), name());
  log << MSG::INFO << " EventWriter ~EventWriter()" << endreq;



}

---

Member Function Documentation

void EventWriter::addItem	(	Items &	itms,
		const std::string &	descriptor
	)			[private]

Definition at line 242 of file EventWriter.cxx.

References Bes_Common::DEBUG, findItem(), msgSvc(), RealDBUtil::npos, and deljobs::string.

Referenced by getSvc().

                                                                    {
  MsgStream log(msgSvc(), name());
  int level = 0;
  size_t sep = descriptor.rfind("#");
  std::string obj_path (descriptor,0,sep);
  std::string slevel   (descriptor,sep+1,descriptor.length());
  if ( slevel == "*" )  {
    level = 9999999;
  }
  else   {
    level = atoi(slevel.c_str());
  }
  size_t idx = obj_path.find("/",1);
  while (idx != std::string::npos)  {
    std::string sub_item = obj_path.substr(0,idx);
    if ( 0 == findItem(sub_item) )   {
      addItem(itms, sub_item+"#1");
    }
    idx = obj_path.find("/",idx+1);
  }
  DataStoreItem* item = new DataStoreItem(obj_path, level);
  log << MSG::DEBUG << "Adding OutputStream item " << item->path()
    << " with " << item->depth()
    << " level(s)." << endreq;
  itms.push_back( item );
}

void EventWriter::clearItems

(

Items &

items

)

[private]

Definition at line 270 of file EventWriter.cxx.

References genRecEmupikp::i.

Referenced by getSvc().

                                            {
  for ( Items::iterator i = itms.begin(); i != itms.end(); i++ )    {
    delete (*i);
  }
  itms.erase(itms.begin(), itms.end());
}

StatusCode EventWriter::collectObjects

(

)

[private]

Definition at line 287 of file EventWriter.cxx.

References calibUtil::ERROR, genRecEmupikp::i, m_currentItem, m_itemList, m_pConversionSvc, m_pDataProvider, and msgSvc().

Referenced by execute().

                                      {
  MsgStream log(msgSvc(), name());
  StatusCode status = StatusCode::SUCCESS;
  Items::iterator i;

  // Traverse the tree and collect the requested objects
  //    status = m_pConversionSvc->connectOutput(f_rootOutputFile.c_str(), "recreate");

  for ( i = m_itemList.begin(); i != m_itemList.end(); i++ )    {
    DataObject* obj = 0;
    IOpaqueAddress *pAddress = 0;
    m_currentItem = (*i);

    status = m_pDataProvider->retrieveObject(m_currentItem->path(), obj);
    if ( status.isSuccess() )  {
      status = m_pConversionSvc->createRep(obj, pAddress);
      //IRegistry *pReg = obj->registry();
      //pReg->setAddress(pAddress);
      //status = m_pConversionSvc->fillRepRefs(pReg->address(), *i);
    }
    else  {
      log << MSG::ERROR << "Cannot write mandatory object(s) (Not found): "
        << m_currentItem->path() << endreq;
    }
  }


  return status;
}

StatusCode EventWriter::execute

(

)

Definition at line 177 of file EventWriter.cxx.

References commonData::clear(), collectObjects(), Bes_Common::FATAL, TEvtHeader::getEventId(), Bes_Common::INFO, jobInfo, m_bufsize, m_cbuf, m_common, m_dofileName, commonData::m_dstEvt, commonData::m_EvtHeader, commonData::m_EvtNavigator, commonData::m_evtRecObject, commonData::m_hltEvt, m_jobInfoTree, commonData::m_mcEvt, m_mode, commonData::m_recEvt, commonData::m_rectrackEvt, m_single_outputFiles, m_single_outputTrees, m_TFullEvt, commonData::m_trigEvt, m_writer, msgSvc(), TBossFullEvent::reset(), TBossFullEvent::setDigiEvent(), TBossFullEvent::setDstEvent(), TBossFullEvent::setEvtHeader(), TBossFullEvent::setEvtRecObject(), TBossFullEvent::setHltEvent(), TBossFullEvent::setMcEvent(), TBossFullEvent::setRecTrackEvent(), TBossFullEvent::setTrigEvent(), st, and PthrWriterBufPool< Writer, PoolSize >::writeEvent().

                                {

  // Part 1: Get the messaging service, print where you are
  MsgStream log(msgSvc(), name());
  log << MSG::INFO << "EventWriter execute()" << endreq;
  collectObjects();

  if ( m_mode == 2 ) {  //OfflineMode
     if(st!=1){
        if(m_common.m_rectrackEvt) m_single_outputTrees->Branch("TRecEvent","TRecTrackEvent",&m_common.m_rectrackEvt,3200000,1);
        if(m_common.m_evtRecObject) m_single_outputTrees->Branch("TEvtRecObject","TEvtRecObject",&m_common.m_evtRecObject,3200000,1);
        if(m_common.m_dstEvt)  m_single_outputTrees->Branch("TDstEvent","TDstEvent",&m_common.m_dstEvt,3200000,1);
        if(m_common.m_recEvt) m_single_outputTrees->Branch("TDigiEvent","TDigiEvent",&m_common.m_recEvt,3200000,1);
        if(m_common.m_EvtHeader) m_single_outputTrees->Branch("TEvtHeader","TEvtHeader",&m_common.m_EvtHeader,3200000,1);
        if(m_common.m_EvtNavigator) m_single_outputTrees->Branch("TEvtNavigator","TEvtNavigator",&m_common.m_EvtNavigator,3200000,1);
        if(m_common.m_hltEvt) m_single_outputTrees->Branch("THltEvent","THltEvent",&m_common.m_hltEvt,3200000,1);
        if(m_common.m_mcEvt) m_single_outputTrees->Branch("TMcEvent","TMcEvent",&m_common.m_mcEvt,3200000,1);
        if(m_common.m_trigEvt) m_single_outputTrees->Branch("TTrigEvent","TTrigEvent",&m_common.m_trigEvt,3200000,1);
        m_jobInfoTree->Branch("JobInfo",&jobInfo);
        st=1;
     }

     if(m_single_outputFiles->IsZombie()||(!m_single_outputFiles->IsOpen())){
        std::cout<<"EventWriter ERROR::The ROOT File:"<<m_dofileName.c_str()<<"status is false"<<std::endl;
        exit(1);
     }
     int nb = m_single_outputTrees->Fill();
     if(nb==-1)
     {
        log << MSG::FATAL << "Error in fill tree (EventWriter) "<<m_single_outputTrees->GetName() << " with "<<nb<<" bytes" <<endreq;
        exit(1);
     }

     m_single_outputFiles = m_single_outputTrees->GetCurrentFile();
  }
  else if ( m_mode == 3 ) {  //DistBossMode
     m_TFullEvt->setEvtHeader(m_common.m_EvtHeader);
     m_TFullEvt->setDigiEvent(m_common.m_recEvt);  //TDigiEvent
     m_TFullEvt->setDstEvent(m_common.m_dstEvt);
     m_TFullEvt->setMcEvent(m_common.m_mcEvt);
     m_TFullEvt->setTrigEvent(m_common.m_trigEvt);
     m_TFullEvt->setHltEvent(m_common.m_hltEvt);
     m_TFullEvt->setRecTrackEvent(m_common.m_rectrackEvt);
     m_TFullEvt->setEvtRecObject(m_common.m_evtRecObject);

     // Might it be able to optimize within higher version of ROOT?
     TBufferFile m_TBuffer(TBufferFile::kWrite, m_bufsize-12, m_cbuf+4, false);
     m_TBuffer.WriteObject(m_TFullEvt);
     if ( m_TBuffer.Buffer() != (m_cbuf+4) ) {
        m_bufsize = m_TBuffer.Length() + 12;
        m_cbuf = new char[m_bufsize];
        memcpy(m_cbuf+4, m_TBuffer.Buffer(), m_TBuffer.Length());
        m_TBuffer.SetBit(TBuffer::kIsOwner);
     }
     *((int*)m_cbuf) = m_common.m_EvtHeader->getEventId();
     m_writer->writeEvent( (void*)m_cbuf, m_TBuffer.Length()+4 );

     m_TFullEvt->reset();
  }

  m_common.clear();

  return StatusCode::SUCCESS;
}

StatusCode EventWriter::finalize

(

)

Definition at line 321 of file EventWriter.cxx.

References Bes_Common::FATAL, getDecayOptions(), getJobOptions(), Bes_Common::INFO, jobInfo, m_bossVer, m_cbuf, m_decayOptions, m_dofileName, m_jobInfoTree, m_jobOptions, m_mode, m_single_outputFiles, m_TFullEvt, m_writer, msgSvc(), TJobInfo::setBossVer(), TJobInfo::setDecayOptions(), TJobInfo::setJobOptions(), st, DistBossCode::StatusFinalize, deljobs::string, and PthrWriterBufPool< Writer, PoolSize >::writeEvent().

                                 {

   // Part 1: Get the messaging service, print where you are
   MsgStream log(msgSvc(), name());
   int st =1;
   std::cout<<"11111111111111111111111111"<<std::endl;

   if ( m_mode == 2 ) {  //OfflineMode
      m_bossVer = getenv("BES_RELEASE"); 
      log << MSG::INFO << "fill boss version: "<<m_bossVer << endreq; 

      string tmpJobOptions = getJobOptions(); 
      m_jobOptions.push_back( tmpJobOptions ); 

      if(m_decayOptions.size()==0) 
         m_decayOptions = getDecayOptions(); 

      jobInfo->setBossVer(m_bossVer); 
      jobInfo->setJobOptions(m_jobOptions); 
      jobInfo->setDecayOptions(m_decayOptions); 

      m_jobInfoTree->Fill(); 

      st = m_single_outputFiles->Write();
      if(st==0) 
      {
         log << MSG::FATAL <<"can not write to the file "<<m_dofileName.c_str()<<endreq;
         exit(1);
      }
      m_single_outputFiles->Close();

      delete m_single_outputFiles;
      delete  jobInfo;
   }

   if ( m_mode == 3 ) {  //DistBossMode
      int code = DistBossCode::StatusFinalize;
      m_writer->writeEvent((void*)&code, 4);
      delete m_writer;
      delete m_TFullEvt;
      delete [] m_cbuf;
   }

   log << MSG::INFO << "EventWriter finalize()" << endreq;
   return StatusCode::SUCCESS;
}

DataStoreItem * EventWriter::findItem

(

const std::string &

path

)

[private]

Definition at line 278 of file EventWriter.cxx.

References genRecEmupikp::i, and m_itemList.

Referenced by addItem().

                                            {
  for (Items::const_iterator i=m_itemList.begin(); i != m_itemList.end(); ++i)  {
    if ( (*i)->path() == path )  return (*i);
  }
  return 0;
}

std::string EventWriter::getDecayOptions

(

)

[private, virtual]

Definition at line 397 of file EventWriter.cxx.

References DataInfoSvc::getDecayOptions(), Bes_Common::INFO, msgSvc(), deljobs::string, and Bes_Common::WARNING.

Referenced by finalize().

{ 
   MsgStream log(msgSvc(), name());
   ISvcLocator* svcLocator = Gaudi::svcLocator(); 
   IDataInfoSvc *tmpInfoSvc; 
   DataInfoSvc* jobInfoSvc; 
   string decayOptions; 
   StatusCode status = svcLocator->service("DataInfoSvc",tmpInfoSvc); 
   if (status.isSuccess()) { 
      log << MSG::INFO << "get the DataInfoSvc" << endreq; 
      jobInfoSvc=dynamic_cast<DataInfoSvc *>(tmpInfoSvc); 
      decayOptions = jobInfoSvc->getDecayOptions(); 
      log << MSG::INFO << "get decay options" << endreq 
         << decayOptions << endreq; 
   }else { 
      log << MSG::WARNING << "could not get the DataInfoSvc. Ignore it." << endreq; 
   } 
   return decayOptions; 
} 

std::string EventWriter::getJobOptions

(

)

[private, virtual]

Definition at line 372 of file EventWriter.cxx.

References Bes_Common::INFO, boss::jobOptions, msgSvc(), and deljobs::string.

Referenced by finalize().

{ 
   MsgStream log(msgSvc(), name());  
   IInterface* iface = Gaudi::createApplicationMgr(); 
   //SmartIF<IProperty> propMgr ( IID_IProperty, iface ); 
   SmartIF<IProperty> propMgr ( iface );
   std::string path; 
   propMgr->getProperty( "JobOptionsPath", path); 
   log << MSG::INFO << "JobOptions file for current job: " <<path << endreq; 
   ifstream fin(path.c_str()); 
   string jobOptions; 
   string tempString; 
   while(getline(fin,tempString)) 
   { 
      if( tempString.size()>0 && tempString.find("//")>tempString.size() ) 
      { 
         jobOptions += tempString; 
         jobOptions += "\n"; 
      } 
   } 
   log << MSG::INFO << "JobOptions: " << endreq 
      << jobOptions << endreq; 
   return jobOptions; 
} 

StatusCode EventWriter::getSvc

(

)

[private]

Definition at line 159 of file EventWriter.cxx.

References addItem(), clearItems(), calibUtil::ERROR, genRecEmupikp::i, Bes_Common::INFO, m_itemList, m_itemNames, and msgSvc().

Referenced by initialize().

                              {
  MsgStream log(msgSvc(), name());
  log << MSG::INFO << "getSvc()" << endreq;
  StatusCode status = StatusCode::SUCCESS;
  if(m_itemNames.empty()) {
    log << MSG::ERROR << "no ItemList from the jobOption" << endreq;
    return StatusCode::FAILURE;
  } 
  //   ItemNames        m_itemNames;
  clearItems(m_itemList);
  ItemNames::iterator i;
  for (i = m_itemNames.begin(); i != m_itemNames.end(); i++){
    addItem(m_itemList, *i);
  }
  return status;
}

StatusCode EventWriter::initialize

(

)

Definition at line 81 of file EventWriter.cxx.

References DistBossCode::ClientReady, Bes_Common::FATAL, getSvc(), IID_IRootCnvSvc, Bes_Common::INFO, jobInfo, m_bufsize, m_cbuf, m_cnvSvc, m_dofileName, m_jobInfoTree, m_mode, m_pConversionSvc, m_pDataProvider, m_single_outputFiles, m_single_outputTrees, m_svrName, m_TFullEvt, m_writer, msgSvc(), st, and PthrWriterBufPool< Writer, PoolSize >::writeEvent().

                                  {

  // Part 1: Get the messaging service, print where you are
  MsgStream log(msgSvc(), name());
  log << MSG::INFO << " EventWriter initialize()" << endreq;


  //   StatusCode status = Converter::initialize();

  //   if ( status.isSuccess() )   {

  IService* isvc = 0;

  StatusCode status = serviceLocator()->service("RootCnvSvc", isvc, false);

  if ( !status.isSuccess() )   status = serviceLocator()->service("EventCnvSvc", isvc, true);

  if ( status.isSuccess() )   {

    status = isvc->queryInterface(IID_IRootCnvSvc, (void**)&m_cnvSvc);

  }


  status = serviceLocator()->service("EventCnvSvc", m_pConversionSvc, true);
  if ( !status.isSuccess() ) {
    log << MSG::FATAL << "Unable to locate IConversionSvc interface"
      << endreq;
    return status;
  }


  status = serviceLocator()->service("EventDataSvc", m_pDataProvider, true);
  if ( !status.isSuccess() ) {
    log << MSG::FATAL << "Unable to locate IDataProviderSvc interface"
      << endreq;
    return status;
  }

  //  }

  if ( m_mode == 2 ) {  //OfflineMode
     m_single_outputFiles = new TFile(m_dofileName.c_str(), "RECREATE");
     if(m_single_outputFiles->IsZombie()||(!m_single_outputFiles->IsWritable())){
        std::cout<<"EventWriter ERROR::Can't not open file"<<m_dofileName.c_str()<<std::endl;
        exit(1);
     }

     m_single_outputTrees = new TTree("Event","Event");
     m_jobInfoTree = new TTree("JobInfoTree","Job info"); 
     jobInfo = new TJobInfo;
  }
  else if ( m_mode == 3 ) {  //DistBossMode
     status = DistBoss::GetPropertyValue<std::string>("DistBoss", "ServerName", m_svrName);
     m_TFullEvt = new TBossFullEvent;
     m_writer   = new NetDataWriter(m_svrName+'/'+name());
     m_bufsize  = 512*1024;
     m_cbuf     = new char[m_bufsize];
     int code = DistBossCode::ClientReady;
     m_writer->writeEvent((void*)&code, 4);
  }
  else {
     log << MSG::FATAL << "Unvalid RunMode @ initialize(): " << m_mode << endreq;
     exit(1);
  }

  status = getSvc();
  if ( !status.isSuccess() ) {
    log << MSG::FATAL << "can not getSvc"  << endreq;
    return status;
  }
  st=0;

  return StatusCode::SUCCESS;
}

---

Member Data Documentation

TJobInfo* EventWriter::jobInfo [private]

Definition at line 79 of file EventWriter.h.

Referenced by execute(), finalize(), and initialize().

std::string EventWriter::m_bossVer [private]

Definition at line 77 of file EventWriter.h.

Referenced by finalize().

int EventWriter::m_bufsize [private]

Definition at line 86 of file EventWriter.h.

Referenced by execute(), and initialize().

char* EventWriter::m_cbuf [private]

Definition at line 87 of file EventWriter.h.

Referenced by execute(), finalize(), and initialize().

RootCnvSvc* EventWriter::m_cnvSvc [private]

Definition at line 50 of file EventWriter.h.

Referenced by initialize().

commonData EventWriter::m_common [private]

Definition at line 62 of file EventWriter.h.

Referenced by execute().

DataStoreItem* EventWriter::m_currentItem [private]

Definition at line 48 of file EventWriter.h.

Referenced by collectObjects().

std::string EventWriter::m_decayOptions [private]

Definition at line 78 of file EventWriter.h.

Referenced by finalize().

TDigiEvent* EventWriter::m_digiEvt [private]

Definition at line 52 of file EventWriter.h.

string EventWriter::m_dofileName [private]

Definition at line 67 of file EventWriter.h.

Referenced by EventWriter(), execute(), finalize(), and initialize().

string EventWriter::m_dofileName_1 [private]

Definition at line 68 of file EventWriter.h.

TEvtHeader* EventWriter::m_evtHd [private]

Definition at line 55 of file EventWriter.h.

THltEvent* EventWriter::m_hltEvt [private]

Definition at line 54 of file EventWriter.h.

Items EventWriter::m_itemList [private]

Definition at line 69 of file EventWriter.h.

Referenced by collectObjects(), findItem(), and getSvc().

ItemNames EventWriter::m_itemNames [private]

Definition at line 70 of file EventWriter.h.

Referenced by EventWriter(), and getSvc().

TTree* EventWriter::m_jobInfoTree [private]

Definition at line 65 of file EventWriter.h.

Referenced by execute(), finalize(), and initialize().

std::vector<std::string> EventWriter::m_jobOptions [private]

Definition at line 76 of file EventWriter.h.

Referenced by finalize().

TMcEvent* EventWriter::m_mcEvt [private]

Definition at line 53 of file EventWriter.h.

int EventWriter::m_mode [private]

Definition at line 82 of file EventWriter.h.

Referenced by EventWriter(), execute(), finalize(), and initialize().

IDataStoreAgent* EventWriter::m_pAgent [private]

Definition at line 47 of file EventWriter.h.

IConversionSvc* EventWriter::m_pConversionSvc [private]

Definition at line 46 of file EventWriter.h.

Referenced by collectObjects(), and initialize().

IDataManagerSvc* EventWriter::m_pDataManager [private]

Definition at line 44 of file EventWriter.h.

IDataProviderSvc* EventWriter::m_pDataProvider [private]

Definition at line 45 of file EventWriter.h.

Referenced by collectObjects(), and initialize().

RootInterface* EventWriter::m_pRootInterface [private]

Definition at line 49 of file EventWriter.h.

TFile* EventWriter::m_single_outputFiles [private]

Definition at line 63 of file EventWriter.h.

Referenced by execute(), finalize(), and initialize().

TTree* EventWriter::m_single_outputTrees [private]

Definition at line 64 of file EventWriter.h.

Referenced by execute(), and initialize().

std::string EventWriter::m_svrName [private]

Definition at line 83 of file EventWriter.h.

Referenced by initialize().

TBossFullEvent* EventWriter::m_TFullEvt [private]

Definition at line 84 of file EventWriter.h.

Referenced by execute(), finalize(), and initialize().

TRecTrackEvent* EventWriter::m_trkEvt [private]

Definition at line 51 of file EventWriter.h.

NetDataWriter* EventWriter::m_writer [private]

Definition at line 85 of file EventWriter.h.

Referenced by execute(), finalize(), and initialize().

int EventWriter::st [private]

Definition at line 66 of file EventWriter.h.

Referenced by execute(), finalize(), and initialize().

---