WriterRpc< Writer > Class Template Reference

#include <WriterRpc.h>

Inheritance diagram for WriterRpc< Writer >:

Public Member Functions
	WriterRpc (const std::string &svrName, const std::string &fname)
virtual	~WriterRpc ()
int	wait_to_end ()
Public Member Functions inherited from RpcInterface
virtual	~RpcInterface ()
virtual int	wait_to_end ()=0

Detailed Description

template<class Writer>
class WriterRpc< Writer >

Definition at line 11 of file WriterRpc.h.

Constructor & Destructor Documentation

WriterRpc()

template<class Writer >

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

Definition at line 8 of file WriterRpc.cc.

   : DimRpc(svrName.c_str(), "I", "I"),
     m_evtDone(0)
{
   m_writer = new PthrWriterBufPool<Writer>(fname);
 
   m_svrName = svrName.substr( svrName.find_last_of('/')+1 );
}

~WriterRpc()

template<class Writer >

WriterRpc< Writer >::~WriterRpc

virtual

Definition at line 18 of file WriterRpc.cc.

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

Member Function Documentation

wait_to_end()

template<class Writer >

int WriterRpc< Writer >::wait_to_end

virtual

Implements RpcInterface.

Definition at line 41 of file WriterRpc.cc.

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

---

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

• WriterRpc.h
• WriterRpc.cc