WriterRpc< Writer > Class Template Reference

#include <WriterRpc.h>

Inheritance diagram for WriterRpc< Writer >:

List of all members.

Public Member Functions
	WriterRpc (const std::string &svrName, const std::string &fname)
virtual	~WriterRpc ()
int	wait_to_end ()
Private Member Functions
void	rpcHandler ()
void	clearBak (int clientId)
	WriterRpc ()
Private Attributes
int	m_evtDone
int	m_inCode
int	m_outCode
int	m_size
void *	m_pEvt
PthrWriterBufPool< Writer > *	m_writer
std::string	m_svrName
std::map< int, AutoEnlargeBuffer * >	m_evtBak

---

Detailed Description

template<class Writer>
class WriterRpc< Writer >

Definition at line 11 of file WriterRpc.h.

---

Constructor & Destructor Documentation

template<class Writer>

WriterRpc< Writer >::WriterRpc	(	const std::string &	svrName,
		const std::string &	fname
	)

Definition at line 8 of file WriterRpc.cc.

References WriterRpc< Writer >::m_svrName, and WriterRpc< Writer >::m_writer.

   : DimRpc(svrName.c_str(), "I", "I"),
     m_evtDone(0)
{
   m_writer = new PthrWriterBufPool<Writer>(fname);

   m_svrName = svrName.substr( svrName.find_last_of('/')+1 );
}

template<class Writer>

WriterRpc< Writer >::~WriterRpc

(

)

[virtual]

Definition at line 18 of file WriterRpc.cc.

References WriterRpc< Writer >::clearBak(), WriterRpc< Writer >::m_evtBak, WriterRpc< Writer >::m_evtDone, WriterRpc< Writer >::m_svrName, WriterRpc< Writer >::m_writer, PthrWriterBufPool< Writer, PoolSize >::stat(), DistBossCode::StatusFinalize, and PthrWriterBufPool< Writer, PoolSize >::writeEvent().

{
   if ( m_writer->stat() == 0 ) {
      while ( m_evtBak.size() > 0 ) {
         clearBak(-1);
      }
      if ( dis_get_n_clients(itsIdOut) > 0 ) {
         std::cout << "[" << m_svrName << "] PROBLEMS @ TERMINATING. FORCE TO QUIT" << std::endl;
      }
      int code = DistBossCode::StatusFinalize;
      m_writer->writeEvent(&code, 4);
   }

   delete m_writer;

   for (std::map<int, AutoEnlargeBuffer*>::iterator it = m_evtBak.begin(); it != m_evtBak.end(); ++it) {
      delete it->second;
   }

   std::cout << "[" << m_svrName << "] Terminated. Total events processed: " << m_evtDone << std::endl;
}

template<class Writer>

WriterRpc< Writer >::WriterRpc

(

)

[private]

---

Member Function Documentation

template<class Writer>

void WriterRpc< Writer >::clearBak

(

int

clientId

)

[private]

Definition at line 105 of file WriterRpc.cc.

References WriterRpc< Writer >::m_evtBak, WriterRpc< Writer >::m_evtDone, WriterRpc< Writer >::m_writer, and PthrWriterBufPool< Writer, PoolSize >::writeEvent().

Referenced by WriterRpc< Writer >::rpcHandler(), and WriterRpc< Writer >::~WriterRpc().

{
   std::map<int, AutoEnlargeBuffer*>::iterator it = (clientId<0) ? m_evtBak.begin() : m_evtBak.find( clientId );
   if ( it != m_evtBak.end() ) {
      m_writer->writeEvent( it->second->data(), it->second->size() );
      ++m_evtDone;

      delete it->second;
      m_evtBak.erase(it);
   }
}

template<class Writer>

void WriterRpc< Writer >::rpcHandler

(

)

[private]

Definition at line 60 of file WriterRpc.cc.

References WriterRpc< Writer >::clearBak(), DistBossCode::ClientReady, WriterRpc< Writer >::m_evtBak, WriterRpc< Writer >::m_evtDone, WriterRpc< Writer >::m_pEvt, WriterRpc< Writer >::m_size, WriterRpc< Writer >::m_svrName, WriterRpc< Writer >::m_writer, DistBossCode::ServerTimeout, delete_small_size::size, DistBossCode::StatusFinalize, DistBossCode::StatusSuccess, and PthrWriterBufPool< Writer, PoolSize >::writeEvent().

{
   m_size = getSize();
   m_pEvt = getData();

   int clientId = DimServer::getClientId();
   int  outCode = DistBossCode::StatusSuccess;

   if ( m_size == 4 ) {
      unsigned int inCode = *(unsigned int*)m_pEvt;

      if ( inCode == DistBossCode::StatusFinalize ) {
         std::cout << "[" << m_svrName << "] Client [" << DimServer::getClientName() << "] finalized" << std::endl;
         clearBak(clientId);
         if ( dis_get_n_clients(itsIdOut) <= 1 ) {
            m_writer->writeEvent(m_pEvt, m_size);
         }
      }
      else if ( inCode == DistBossCode::ClientReady ) {
         std::cout << "[" << m_svrName << "] Client [" << DimServer::getClientName() << "] connected" << std::endl;
      }
   }
   else if ( m_size > 4 ) {
      std::map<int, AutoEnlargeBuffer*>::iterator it = m_evtBak.find( clientId );
      if ( it == m_evtBak.end() ) {
         m_evtBak[clientId] = new AutoEnlargeBuffer();
         m_evtBak[clientId]->copy(m_pEvt, m_size );
      }

      void* pbak = m_evtBak[clientId]->data();
      if ( *(int*)pbak != *(int*)m_pEvt ) {
         m_writer->writeEvent(pbak, m_evtBak[clientId]->size());
         ++m_evtDone;
      }

      m_evtBak[clientId]->copy(m_pEvt, m_size );
   }
   else {
      outCode = DistBossCode::ServerTimeout;
   }

   setData(outCode);
}

template<class Writer>

int WriterRpc< Writer >::wait_to_end

(

)

[virtual]

Implements RpcInterface.

Definition at line 41 of file WriterRpc.cc.

References genRecEmupikp::i.

{
   int nClients = 0;
   int i = 0;

   do {
      // wait for all the clients dis-connecting to this server
      // and force the server to stop when the total waiting time
      // is greater than 10s(5*1s)
      if ( ++i > 5 ) break;
      sleep(2);
      nClients = dis_get_n_clients(itsIdOut);
   }
   while ( nClients > 0 );

   return nClients;
}

---

Member Data Documentation

template<class Writer>

std::map<int, AutoEnlargeBuffer*> WriterRpc< Writer >::m_evtBak [private]

Definition at line 44 of file WriterRpc.h.

Referenced by WriterRpc< Writer >::clearBak(), WriterRpc< Writer >::rpcHandler(), and WriterRpc< Writer >::~WriterRpc().

template<class Writer>

int WriterRpc< Writer >::m_evtDone [private]

Definition at line 32 of file WriterRpc.h.

Referenced by WriterRpc< Writer >::clearBak(), WriterRpc< Writer >::rpcHandler(), and WriterRpc< Writer >::~WriterRpc().

template<class Writer>

int WriterRpc< Writer >::m_inCode [private]

Definition at line 34 of file WriterRpc.h.

template<class Writer>

int WriterRpc< Writer >::m_outCode [private]

Definition at line 35 of file WriterRpc.h.

template<class Writer>

void* WriterRpc< Writer >::m_pEvt [private]

Definition at line 38 of file WriterRpc.h.

Referenced by WriterRpc< Writer >::rpcHandler().

template<class Writer>

int WriterRpc< Writer >::m_size [private]

Definition at line 37 of file WriterRpc.h.

Referenced by WriterRpc< Writer >::rpcHandler().

template<class Writer>

std::string WriterRpc< Writer >::m_svrName [private]

Definition at line 42 of file WriterRpc.h.

Referenced by WriterRpc< Writer >::rpcHandler(), WriterRpc< Writer >::WriterRpc(), and WriterRpc< Writer >::~WriterRpc().

template<class Writer>

PthrWriterBufPool<Writer>* WriterRpc< Writer >::m_writer [private]

Definition at line 40 of file WriterRpc.h.

Referenced by WriterRpc< Writer >::clearBak(), WriterRpc< Writer >::rpcHandler(), WriterRpc< Writer >::WriterRpc(), and WriterRpc< Writer >::~WriterRpc().

---