RawDataInputSvc Class Reference

#include <RawDataInputSvc.h>

Inheritance diagram for RawDataInputSvc:

Public Member Functions
	RawDataInputSvc (const std::string &name, ISvcLocator *svcloc)
virtual	~RawDataInputSvc ()
virtual StatusCode	initialize ()
virtual StatusCode	finalize ()
virtual RAWEVENT *	nextEvent ()
virtual RAWEVENT *	currentEvent ()
virtual bool	setCurrentEvent (RAWEVENT *m_onlinere)
std::string	currentFile () const
int	runMode ()
uint32_t	runNo ()
const SniperJSON &	config (const std::string &key)
OfflineRevise *	offlineRevisor ()

Detailed Description

Definition at line 24 of file RawDataInputSvc.h.

Constructor & Destructor Documentation

RawDataInputSvc()

RawDataInputSvc::RawDataInputSvc	(	const std::string &	name,
		ISvcLocator *	svcloc )

Definition at line 26 of file RawDataInputSvc.cxx.

   :base_class(name,svcloc), 
  m_re(0),
  m_reader(0),
  m_sds(0),
  m_robs(0)
{
   // Get a pointer to the Job Options Service
   IJobOptionsSvc* jobSvc;
   Gaudi::svcLocator()->service("JobOptionsSvc", jobSvc);
 
   PropertyMgr m_propMgr;
   // 0-NormalNetMode, 1-OnlineMode, 2-OfflineMode, 3-DistBossMode
   m_propMgr.declareProperty("RunMode",    m_mode = 2);
   m_propMgr.declareProperty("KeepRandomTrigEvt", m_keepRdm = true);
   m_propMgr.declareProperty("InputFiles", m_inputFiles);
   m_propMgr.declareProperty("Config4Revise", m_conf4Revise);
 
   jobSvc->setMyProperties("RawDataInputSvc", &m_propMgr);
}

Referenced by RawDataInputSvc().

~RawDataInputSvc()

RawDataInputSvc::~RawDataInputSvc ( )

virtual

Definition at line 48 of file RawDataInputSvc.cxx.

{
  //MsgStream log(messageService(), name() );
  //log << MSG::DEBUG << "RawDataInputSvc Destructor called " << endreq;
}

Member Function Documentation

config()

const SniperJSON & RawDataInputSvc::config ( const std::string & key )

inline

Definition at line 50 of file RawDataInputSvc.h.

{ return m_json[key]; }

currentEvent()

RAWEVENT * RawDataInputSvc::currentEvent ( )

virtual

Get a pointer to the current event.

Definition at line 287 of file RawDataInputSvc.cxx.

{
  // Return a pointer to the  raw event.
  //std::cout << "RawDataCnv -> Return a pointer to the  raw event." << std::endl;
  //std::cout << "It is the first time to call the currentEvent()" << std::endl;
  return m_re; 
}

currentFile()

std::string RawDataInputSvc::currentFile ( ) const

inline

Definition at line 43 of file RawDataInputSvc.h.

{ return m_reader->currentFile(); }

finalize()

StatusCode RawDataInputSvc::finalize ( )

virtual

Definition at line 101 of file RawDataInputSvc.cxx.

                                     {
  // clean up 
  if ( m_re ) {
    delete m_re;
    m_re = 0;
  }
 
  if ( m_reader ) {
    delete m_reader;
    m_reader = 0;
  }
 
  delete m_revisor;
 
  if ( m_sds )  delete m_sds;
  if ( m_robs ) delete m_robs;
 
  return StatusCode::SUCCESS;
}

initialize()

StatusCode RawDataInputSvc::initialize ( )

virtual

Definition at line 55 of file RawDataInputSvc.cxx.

{
   //MsgStream log(messageService(), name() );
   //log << MSG::DEBUG << " in RawDataInputSvc::initialize()" << endreq;
 
   //StatusCode sc=  IRawDataInputSvc::initialize();
   //if(!sc.isSuccess()) {
   //  log << MSG::ERROR << "failed to initialize IRawDataInputSvc" << endreq;
   //  return sc;
   //}
 
#ifndef OnlineMode
   if ( m_mode > 1 ) {
      try {
     if ( m_mode == 2 ) {  //OfflineMode
        if ( m_inputFiles.empty() ) return StatusCode::SUCCESS;
        m_reader = new RawFileReader(m_inputFiles); 
     }
     else if ( m_mode == 3 ) {  //DistBossMode
        DistBoss::GetPropertyValue<std::string>("DistBoss", "ServerName", m_evtServer);
        m_reader = new NetDataReader(m_evtServer+"/RawEvtSvc");
     }
     else {
        throw RawExMessage("RawDataInputSvc: Invalid RunMode!");
     }
      }
      catch (RawFileException& ex) {
     ex.print();
     return StatusCode::FAILURE;
      }
 
      m_re = new RAWEVENT;
 
      m_sds =  new const uint32_t*[64];
      m_robs = new const uint32_t*[256];
   }
#endif
 
   std::ifstream cf(m_conf4Revise.c_str());
   m_json = SniperJSON::load(cf);
 
   m_revisor = new OfflineRevise(m_json["ETS_FIX"]);
 
   return StatusCode::SUCCESS;
}

nextEvent()

RAWEVENT * RawDataInputSvc::nextEvent ( )

virtual

Definition at line 122 of file RawDataInputSvc.cxx.

                                     {
 
  //MsgStream log(messageService(), name() );
#ifndef OnlineMode
  //OfflineMode and DistBossMode
   m_re->reset();
 
   try {
      RawEvent f;
      const uint32_t* ef = 0;
      do {
         f.assign( m_reader->nextEvent());
         if (!f.check()) {
            std::cerr << "Found invalid event (traceback):" << std::endl;
            std::exit(1);
         }
         //1.print basic event information
         //     log << MSG::DEBUG<< "run" << f.run_no() << " [Event No. #" << f.global_id()
         // << "] " << f.fragment_size_word() << " words in "
         // << f.nchildren() << " subdetectors "
         // << endreq;
 
         //fucd: get event filter information
         f.event_filter_info(ef);
         if ( !ef ) {
            //log << MSG::ERROR << "Event Filter Data Failed!!!" << endreq;
            exit(1);
         }
         else {
            //log << MSG::DEBUG<< "Event Filter Information*********" <<std::hex<<endreq
            //   <<*ef<< "  "<<*(ef+1)<<"  "<<*(ef+2)<<"  "<<*(ef+3)<<std::dec<<endreq;
            if ( ! m_keepRdm && ((*ef)>>31) != 0 ) {
               continue;
            }
         }
         break;
      } while (true);
 
      m_re->setRunNo(f.run_no());
      m_re->setEventNo(f.global_id());
      m_re->setTime(f.time());
      m_re->addReHltRaw((uint32_t*)ef, 4);
 
      //set HV status and get all robs
      uint32_t hv_status = 0;
      int      nrobs = 0;
      int      nsds  = f.children(m_sds, 64);
      for ( int sdi = 0; sdi < nsds; ++sdi )  {
     eformat::SubDetectorFragment<const uint32_t*> sd(m_sds[sdi]);
 
     if ( sd.nspecific() != 0 ) {
        const uint32_t* specific_header;
        sd.specific_header(specific_header);
        uint32_t source_id_number = sd.source_id();
        source_id_number <<= 8;
        source_id_number >>= 24;
        switch( source_id_number ) {
           case 161:
          hv_status |= ((8 | ((*specific_header)&0x7)) << 8);
          break;
           case 162:
          hv_status |= ((8 | ((*specific_header)&0x7)) << 4);
          break;
           case 164:
          hv_status |= (8 | ((*specific_header)&0x7));
          break;
           default:
          break;
        }
     }
 
     nrobs += eformat::get_robs(m_sds[sdi], m_robs+nrobs, 256-nrobs);
      }
 
      m_re->setFlag1( hv_status );
 
      //log << MSG::INFO << " nrobs: " << nrobs << endreq;
      for (int robi = 0; robi < nrobs; robi++) {
     eformat::ROBFragment<uint32_t*> rob((uint32_t*)m_robs[robi]);
     //uint32_t detev_type = rob.rod_detev_type();
     uint32_t* dataptr = NULL;
     rob.rod_data(dataptr);
 
     //log << MSG::DEBUG<< "addReHltRaw" << endreq;
     uint32_t source_id_number = rob.rod_source_id();
     //std::cout<<"#####source_id_number#####"<<source_id_number<<std::endl;
     source_id_number <<= 8;
     source_id_number >>= 24;
     //std::cout<<"#####(source_id_number<<24)>>29#####"<<source_id_number<<std::endl;
 
         if ((rob.rod_detev_type() & 0x2) != 0) {
             if ( source_id_number == 165 ) {
                 m_re->addReEtsDigi(dataptr, rob.rod_ndata());  // ETS
             }
             continue;  //bad data or ETS
         }
 
     //be careful here!!!
     switch(source_id_number) {
        case 161:
           m_re->addReMdcDigi(dataptr, rob.rod_ndata());
           break;
        case 163:
           m_re->addReEmcDigi(dataptr, rob.rod_ndata());
           break;
        case 162:
           m_re->addReTofDigi(dataptr, rob.rod_ndata());
           break;
        case 167:  //ETF(MRPC)
           m_re->addReEtfDigi(dataptr, rob.rod_ndata());
           break;
        case 164:
           m_re->addReMucDigi(dataptr, rob.rod_ndata());
           break;
        case 165:  // trigger !!!
           //std::cout << "Get Trigger Data -" << std::endl;
           //for (int i = 0; i < rob.rod_ndata(); i++) {
           //  std::cout << "\t0x" << std::hex << dataptr[i] << std::dec << std::endl;
           //}
           m_re->addReTrigGTD(dataptr, rob.rod_ndata());
           break;
        case 166:
           m_re->addReZddDigi(dataptr, rob.rod_ndata());
           break;
        case 124:  // EventFilter
           m_re->addReHltRaw(dataptr, rob.rod_ndata());
           break;
        case 241:  // McParticle
           m_re->addMcParticle(dataptr, rob.rod_ndata());
           break;
        default:
           //log << MSG::ERROR << "no such subdetector type: " << source_id_number << endreq;
           break;
     }
      }
   }
   catch (RawFileException& ex) {
      ex.print();
      if ( m_reader->stat()&4 ) {  // fstream badbit is set
          std::cerr << std::endl << "reading ifstream error !!!" << std::endl;
          exit(1);
      }
      delete m_re;
      m_re = NULL;
   }
   catch (eformat::Issue& ex) {
      std::cerr << std::endl << "Uncaught eformat issue: " << ex.what() << std::endl;
   }
   catch (ers::Issue& ex) {
      std::cerr << std::endl << "Uncaught ERS issue: " << ex.what() << std::endl;
   }
   catch (std::exception& ex) {
      std::cerr << std::endl << "Uncaught std exception: " << ex.what() << std::endl;
   }
   catch (...) {
      std::cerr << std::endl << "Uncaught unknown exception" << std::endl;
   }
#endif
 
   return m_re;
}

offlineRevisor()

OfflineRevise * RawDataInputSvc::offlineRevisor ( )

inline

Definition at line 52 of file RawDataInputSvc.h.

{ return m_revisor; }

runMode()

int RawDataInputSvc::runMode ( )

inline

Definition at line 46 of file RawDataInputSvc.h.

{ return m_mode; }

runNo()

uint32_t RawDataInputSvc::runNo ( )

inline

Definition at line 48 of file RawDataInputSvc.h.

{ return m_reader->runNo(); }

Referenced by DetVerSvcPack::funcInputRaw().

setCurrentEvent()

bool RawDataInputSvc::setCurrentEvent ( RAWEVENT * m_onlinere )

virtual

Definition at line 295 of file RawDataInputSvc.cxx.

{
   //std::cout << "setCurrentEvent(RAWEVENT* m_onlinere)" << std::endl;
   return (m_re = m_onlinere);
}

---

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

• RawDataInputSvc.h
• RawDataInputSvc.cxx