DimRpcReader Class Reference

#include <DimRpcReader.h>

Public Types
typedef const std::string	ReaderArgType
typedef const std::string	ReaderArgType

Public Member Functions
	DimRpcReader (ReaderArgType &name)
virtual	~DimRpcReader ()
const uint32_t *	nextEvent ()
const uint32_t *	currentEvent () const
uint32_t	runNo ()
std::string	currentFile ()
uint32_t	stat ()
	DimRpcReader (ReaderArgType &name)
virtual	~DimRpcReader ()
const uint32_t *	nextEvent ()
const uint32_t *	currentEvent () const
uint32_t	runNo ()
std::string	currentFile ()
uint32_t	stat ()

Detailed Description

Definition at line 11 of file DistBoss/NetDataReader/NetDataReader-00-00-06/NetDataReader/DimRpcReader.h.

Member Typedef Documentation

ReaderArgType [1/2]

typedef const std::string DimRpcReader::ReaderArgType

Definition at line 15 of file DistBoss/NetDataReader/NetDataReader-00-00-06/NetDataReader/DimRpcReader.h.

ReaderArgType [2/2]

typedef const std::string DimRpcReader::ReaderArgType

Definition at line 15 of file InstallArea/include/NetDataReader/NetDataReader/DimRpcReader.h.

Constructor & Destructor Documentation

DimRpcReader() [1/2]

DimRpcReader::DimRpcReader

(

ReaderArgType &

name

)

Definition at line 11 of file DimRpcReader.cxx.

{
   if ( name.empty() ) {
      throw RawExMessage("[NetDataReader] The name of DistBoss EvtServer was not set!");
   }
 
   ClientErrHandler::registerInstance();
 
   m_buffer = new AutoEnlargeBuffer(128*1024);
 
   m_rpc = new DimRpcInfo(name.c_str(), 5, DistBossCode::ServerTimeout);
}

Referenced by DimRpcReader().

~DimRpcReader() [1/2]

DimRpcReader::~DimRpcReader ( )

virtual

Definition at line 24 of file DimRpcReader.cxx.

{
   delete m_rpc;
}

DimRpcReader() [2/2]

DimRpcReader::DimRpcReader

(

ReaderArgType &

name

)

~DimRpcReader() [2/2]

virtual DimRpcReader::~DimRpcReader ( )

virtual

Member Function Documentation

currentEvent() [1/2]

const uint32_t * DimRpcReader::currentEvent

(

)

const

Definition at line 85 of file DimRpcReader.cxx.

{
   return (const uint32_t*)m_buffer->data();
}

currentEvent() [2/2]

const uint32_t * DimRpcReader::currentEvent

(

)

const

currentFile() [1/2]

std::string DimRpcReader::currentFile

(

)

Definition at line 97 of file DimRpcReader.cxx.

{
   pthread_mutex_lock( &m_rpcLock );
 
   m_outCode = DistBossCode::GetFileName;
   m_rpc->setData(m_outCode);
   // should check status code here, correct it in future
   std::string fname((char*)m_rpc->getData());
 
   pthread_mutex_unlock( &m_rpcLock );
 
   return fname;
}

currentFile() [2/2]

std::string DimRpcReader::currentFile

(

)

nextEvent() [1/2]

const uint32_t * DimRpcReader::nextEvent

(

)

Definition at line 29 of file DimRpcReader.cxx.

{
   static int nn = 0;
   ++nn;
 
   int theCode = DistBossCode::GetEvent;
 
   for ( int i = 1; i < 7; ++i ) {
      pthread_mutex_lock( &m_rpcLock );
 
      m_outCode = theCode;
      m_rpc->setData(m_outCode);
      int size = m_rpc->getSize();
      void* data = m_rpc->getData();
      m_buffer->copy(data, size);
 
      pthread_mutex_unlock( &m_rpcLock );
 
      if ( size > 4 ) {
     return (const uint32_t*)m_buffer->data();
      }
      else if ( size == 4 ) {
     m_inCode = *((const uint32_t*)m_buffer->data());
     if ( m_inCode == DistBossCode::NoMoreEvents ) {
        throw RawExMessage("[NetDataReader] Reach the end, no more events left.");
     }
     else if ( m_inCode == DistBossCode::ServerTimeout) {
        if ( i < 6 ) {
           int sec = i;
           std::cout << "[NetDataReader] Event " << nn << " timeout. Sleep " << sec << "s before retry." << std::endl;
           sleep(sec);
           std::cout << "[NetDataReader] Event " << nn << " now retry time " << i << " ..." << std::endl;
           theCode = DistBossCode::RetryEvent;
           continue;
        }
        else {
           throw RawExMessage("[NetDataReader] Failed to retry server. Stop this client!");
        }
     }
     else if ( m_inCode == DistBossCode::ServerError ) {
        throw RawExMessage("[NetDataReader] DistBossServer ERROR !!!");
     }
     else {
        throw RawExMessage("[NetDataReader] Unknown server code !!!");
     }
      }
      else {
     throw RawExMessage("[NetDataReader] Invalid data from server !!!");
      }
 
      break;
   }
 
   return 0;
}

nextEvent() [2/2]

const uint32_t * DimRpcReader::nextEvent

(

)

runNo() [1/2]

uint32_t DimRpcReader::runNo

(

)

Definition at line 90 of file DimRpcReader.cxx.

{
    //FIXME: this is a place holder for runNo()
    //fill it in the future
    return 0xFFFFFFFF;
}

runNo() [2/2]

uint32_t DimRpcReader::runNo

(

)

stat() [1/2]

uint32_t DimRpcReader::stat

(

)

Definition at line 111 of file DimRpcReader.cxx.

{
   return 0;
}

stat() [2/2]

uint32_t DimRpcReader::stat

(

)

---

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

• DistBoss/NetDataReader/NetDataReader-00-00-06/NetDataReader/DimRpcReader.h
• InstallArea/include/NetDataReader/NetDataReader/DimRpcReader.h
• DimRpcReader.cxx