Main Page | Namespace List | Class Hierarchy | Alphabetical List | Class List | Directories | File List | Namespace Members | Class Members | File Members | Related Pages

DimRpcReader Class Reference

#include <DimRpcReader.h>

List of all members.

Public Types

typedef const std::string ReaderArgType
typedef const std::string ReaderArgType

Public Member Functions

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

Private Member Functions

 DimRpcReader ()
 DimRpcReader ()

Private Attributes

AutoEnlargeBuffer * m_buffer
AutoEnlargeBuffer * m_buffer
int m_inCode
int m_outCode
DimRpcInfo * m_rpc
DimRpcInfo * m_rpc

Static Private Attributes

pthread_mutex_t m_rpcLock = PTHREAD_MUTEX_INITIALIZER

Member Typedef Documentation

typedef const std::string DimRpcReader::ReaderArgType
 

typedef const std::string DimRpcReader::ReaderArgType
 

Constructor & Destructor Documentation

DimRpcReader::DimRpcReader (  ReaderArgType &  name  ) 
  

00012 {
00013    if ( name.empty() ) {
00014       throw RawExMessage("[NetDataReader] The name of DistBoss EvtServer was not set!");
00015    }
00016 
00017    ClientErrHandler::registerInstance();
00018 
00019    m_buffer = new AutoEnlargeBuffer(128*1024);
00020 
00021    m_rpc = new DimRpcInfo(name.c_str(), 5, DistBossCode::ServerTimeout);
00022 }

DimRpcReader::~DimRpcReader (   )  [virtual]
  

00025 {
00026    delete m_rpc;
00027 }

DimRpcReader::DimRpcReader (   )  [private]
 

DimRpcReader::DimRpcReader (  ReaderArgType &  name  ) 
 

virtual DimRpcReader::~DimRpcReader (   )  [virtual]
 

DimRpcReader::DimRpcReader (   )  [private]
 

Member Function Documentation

const uint32_t* DimRpcReader::currentEvent (   )  const
 

const uint32_t * DimRpcReader::currentEvent (   )  const
  

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

std::string DimRpcReader::currentFile (   ) 
 

std::string DimRpcReader::currentFile (   ) 
  

00091 {
00092    pthread_mutex_lock( &m_rpcLock );
00093 
00094    m_outCode = DistBossCode::GetFileName;
00095    m_rpc->setData(m_outCode);
00096    // should check status code here, correct it in future
00097    std::string fname((char*)m_rpc->getData());
00098 
00099    pthread_mutex_unlock( &m_rpcLock );
00100 
00101    return fname;
00102 }

const uint32_t* DimRpcReader::nextEvent (   ) 
 

const uint32_t * DimRpcReader::nextEvent (   ) 
  

00030 {
00031    static int nn = 0;
00032    ++nn;
00033 
00034    int theCode = DistBossCode::GetEvent;
00035 
00036    for ( int i = 1; i < 7; ++i ) {
00037       pthread_mutex_lock( &m_rpcLock );
00038 
00039       m_outCode = theCode;
00040       m_rpc->setData(m_outCode);
00041       int size = m_rpc->getSize();
00042       void* data = m_rpc->getData();
00043       m_buffer->copy(data, size);
00044 
00045       pthread_mutex_unlock( &m_rpcLock );
00046 
00047       if ( size > 4 ) {
00048          return (const uint32_t*)m_buffer->data();
00049       }
00050       else if ( size == 4 ) {
00051          m_inCode = *((const uint32_t*)m_buffer->data());
00052          if ( m_inCode == DistBossCode::NoMoreEvents ) {
00053             throw RawExMessage("[NetDataReader] Reach the end, no more events left.");
00054          }
00055          else if ( m_inCode == DistBossCode::ServerTimeout) {
00056             if ( i < 6 ) {
00057                int sec = i;
00058                std::cout << "[NetDataReader] Event " << nn << " timeout. Sleep " << sec << "s before retry." << std::endl;
00059                sleep(sec);
00060                std::cout << "[NetDataReader] Event " << nn << " now retry time " << i << " ..." << std::endl;
00061                theCode = DistBossCode::RetryEvent;
00062                continue;
00063             }
00064             else {
00065                throw RawExMessage("[NetDataReader] Failed to retry server. Stop this client!");
00066             }
00067          }
00068          else if ( m_inCode == DistBossCode::ServerError ) {
00069             throw RawExMessage("[NetDataReader] DistBossServer ERROR !!!");
00070          }
00071          else {
00072             throw RawExMessage("[NetDataReader] Unknown server code !!!");
00073          }
00074       }
00075       else {
00076          throw RawExMessage("[NetDataReader] Invalid data from server !!!");
00077       }
00078 
00079       break;
00080    }
00081 
00082    return 0;
00083 }

uint32_t DimRpcReader::stat (   ) 
 

uint32_t DimRpcReader::stat (   ) 
  

00105 {
00106    return 0;
00107 }

Member Data Documentation

AutoEnlargeBuffer* DimRpcReader::m_buffer [private]
 

AutoEnlargeBuffer* DimRpcReader::m_buffer [private]
 

int DimRpcReader::m_inCode [private]
 

int DimRpcReader::m_outCode [private]
 

DimRpcInfo* DimRpcReader::m_rpc [private]
 

DimRpcInfo* DimRpcReader::m_rpc [private]
 

pthread_mutex_t DimRpcReader::m_rpcLock = PTHREAD_MUTEX_INITIALIZER [static, private]
 

The documentation for this class was generated from the following files:
Generated on Wed Feb 2 15:58:00 2011 for BOSS6.5.5 by  doxygen 1.3.9.1