DimRpcWriter Class Reference

#include <DimRpcWriter.h>

Public Types
typedef const std::string	WriterArgType
typedef const std::string	WriterArgType

Public Member Functions
	DimRpcWriter (WriterArgType &name)
virtual	~DimRpcWriter ()
int	writeEvent (void *pevt, int size)
int	close ()
int	stat ()
	DimRpcWriter (WriterArgType &name)
virtual	~DimRpcWriter ()
int	writeEvent (void *pevt, int size)
int	close ()
int	stat ()

Detailed Description

Definition at line 10 of file DistBoss/NetDataWriter/NetDataWriter-00-00-03/NetDataWriter/DimRpcWriter.h.

Member Typedef Documentation

WriterArgType [1/2]

typedef const std::string DimRpcWriter::WriterArgType

Definition at line 14 of file DistBoss/NetDataWriter/NetDataWriter-00-00-03/NetDataWriter/DimRpcWriter.h.

WriterArgType [2/2]

typedef const std::string DimRpcWriter::WriterArgType

Definition at line 14 of file InstallArea/include/NetDataWriter/NetDataWriter/DimRpcWriter.h.

Constructor & Destructor Documentation

DimRpcWriter() [1/2]

DimRpcWriter::DimRpcWriter

(

WriterArgType &

name

)

Definition at line 10 of file DimRpcWriter.cxx.

   : 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);
}

Referenced by DimRpcWriter().

~DimRpcWriter() [1/2]

DimRpcWriter::~DimRpcWriter ( )

virtual

Definition at line 22 of file DimRpcWriter.cxx.

{
   delete m_rpc;
}

DimRpcWriter() [2/2]

DimRpcWriter::DimRpcWriter

(

WriterArgType &

name

)

~DimRpcWriter() [2/2]

virtual DimRpcWriter::~DimRpcWriter ( )

virtual

Member Function Documentation

close() [1/2]

int DimRpcWriter::close

(

)

Definition at line 75 of file DimRpcWriter.cxx.

{
   return 0;
}

close() [2/2]

int DimRpcWriter::close

(

)

stat() [1/2]

int DimRpcWriter::stat

(

)

Definition at line 80 of file DimRpcWriter.cxx.

{
   return m_inCode;
}

stat() [2/2]

int DimRpcWriter::stat

(

)

writeEvent() [1/2]

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

Definition at line 27 of file DimRpcWriter.cxx.

{
   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;
}

writeEvent() [2/2]

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

---

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

• DistBoss/NetDataWriter/NetDataWriter-00-00-03/NetDataWriter/DimRpcWriter.h
• InstallArea/include/NetDataWriter/NetDataWriter/DimRpcWriter.h
• DimRpcWriter.cxx