DimRpcWriter Class Reference

#include <DimRpcWriter.h>

List of all members.

Public Types
typedef const std::string	WriterArgType
Public Member Functions
	DimRpcWriter (WriterArgType &name)
virtual	~DimRpcWriter ()
int	writeEvent (void *pevt, int size)
int	close ()
int	stat ()
Private Member Functions
	DimRpcWriter ()
Private Attributes
int	m_inCode
DimRpcInfo *	m_rpc
Static Private Attributes
static pthread_mutex_t	m_rpcLock = PTHREAD_MUTEX_INITIALIZER

---

Detailed Description

Definition at line 10 of file DimRpcWriter.h.

---

Member Typedef Documentation

typedef const std::string DimRpcWriter::WriterArgType

Definition at line 14 of file DimRpcWriter.h.

---

Constructor & Destructor Documentation

DimRpcWriter::DimRpcWriter

(

WriterArgType &

name

)

Definition at line 10 of file DimRpcWriter.cxx.

References m_rpc, ClientErrHandler::registerInstance(), and DistBossCode::ServerTimeout.

   : m_inCode(0)
{
   if ( name.empty() ) {
      throw RawExMessage("[NetDataWriter] The name of DistBoss Server was not set!");
   }

   ClientErrHandler::registerInstance();

   m_rpc = new DimRpcInfo(name.c_str(), 5, DistBossCode::ServerTimeout);
}

DimRpcWriter::~DimRpcWriter

(

)

[virtual]

Definition at line 22 of file DimRpcWriter.cxx.

References m_rpc.

{
   delete m_rpc;
}

DimRpcWriter::DimRpcWriter

(

)

[private]

---

Member Function Documentation

int DimRpcWriter::close

(

)

Definition at line 75 of file DimRpcWriter.cxx.

{
   return 0;
}

int DimRpcWriter::stat

(

)

Definition at line 80 of file DimRpcWriter.cxx.

References m_inCode.

{
   return m_inCode;
}

int DimRpcWriter::writeEvent	(	void *	pevt,
		int	size
	)

Definition at line 27 of file DimRpcWriter.cxx.

References genRecEmupikp::i, m_inCode, m_rpc, m_rpcLock, DistBossCode::ServerError, DistBossCode::ServerTimeout, DistBossCode::StatusFinalize, and DistBossCode::StatusSuccess.

{
   static int nn = 0;
   ++nn;

   for ( int i = 1; i < 7; ++i ) {
      pthread_mutex_lock( &m_rpcLock );

      m_rpc->setData(pevt, size);
      int inCode = m_rpc->getInt();

      pthread_mutex_unlock( &m_rpcLock );


      if ( inCode != DistBossCode::StatusSuccess) {
         if ( inCode == DistBossCode::ServerTimeout) {
            if ( i < 6 ) {
               int sec = i;
               std::cout << "[NetDataWriter] Event " << nn << " timeout. Sleep " << sec << "s before retry." << std::endl;
               sleep(sec);
               std::cout << "[NetDataWriter] Event " << nn << " now retry time " << i << " ..." << std::endl;
               continue;
            }
            else {
               m_inCode = inCode;
               throw RawExMessage("[NetDataWriter] Failed to retry server. Stop this client!");
            }
         }
         else if ( inCode == DistBossCode::ServerError) {
            m_inCode = inCode;
            throw RawExMessage("[NetDataWriter] Received server ERROR code!");
         }
         else {
            m_inCode = inCode;
            throw RawExMessage("[NetDataWriter] Unknown server code!");
         }
      }

      if ( size == 4 && *((int*)pevt) == DistBossCode::StatusFinalize) {
         throw ReachEndOfFileList();
      }

      break;
   }

   return 0;
}

---

Member Data Documentation

int DimRpcWriter::m_inCode [private]

Definition at line 32 of file DimRpcWriter.h.

Referenced by stat(), and writeEvent().

DimRpcInfo* DimRpcWriter::m_rpc [private]

Definition at line 33 of file DimRpcWriter.h.

Referenced by DimRpcWriter(), writeEvent(), and ~DimRpcWriter().

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

Definition at line 35 of file DimRpcWriter.h.

Referenced by writeEvent().

---