#include <TGo4Socket.h>

Public Member Functions
	TGo4Socket (Bool_t IsClient)
virtual	~TGo4Socket ()
virtual Int_t	Open (const char *host, Int_t port, Bool_t keepservsock=kFALSE)
virtual Int_t	Close (Option_t *opt="")
virtual Int_t	Send (TObject *obj)
virtual Int_t	Send (const char *name)
virtual TObject *	Recv (const char *name=0)
virtual char *	RecvRaw (const char *name=0)
Bool_t	IsOpen () const
Bool_t	IsClientMode () const
Int_t	GetPort () const
Int_t	SendBuffer (TBuffer *buf)
Int_t	ReceiveBuffer ()
const TBuffer *	GetBuffer () const
Static Public Attributes
static const Int_t	fguOPENWAIT = 200
static const Int_t	fgiOPENCYCLES = 6
static const Int_t	fgiBUFLENGTH = 256
static const Int_t	fgiBUFINITSIZE = 65536
static const Int_t	fgiBUFEXTRASPACE = 8
static const char *	fgcGOON = "-I- go on"
static const Int_t	fgiISOWNER = BIT(14)
Protected Member Functions
	TGo4Socket ()
void	ReallocBuffer (TBuffer *buffer, Int_t oldsize, Int_t newsize)
Private Attributes
Bool_t	fbClientMode
Bool_t	fbOpen
TSocket *	fxSocket
TServerSocket *	fxServerSocket
Int_t	fiPort
char *	fxLocalBuffer
TBuffer *	fxBuffer

Detailed Description

Definition at line 23 of file TGo4Socket.h.

Constructor & Destructor Documentation

TGo4Socket::TGo4Socket ( Bool_t IsClient )

Definition at line 53 of file TGo4Socket.cxx.

References TGo4Log::Debug(), TGo4SocketSignalHandler::DisableSigPipe(), fbClientMode, fgiBUFINITSIZE, fgiBUFLENGTH, fxBuffer, fxLocalBuffer, GO4TRACE, TGo4SocketSignalHandler::SetSigWINCH(), and TGo4Buffer.

TGo4Socket::~TGo4Socket ( ) [virtual]

Definition at line 79 of file TGo4Socket.cxx.

References fxBuffer, fxLocalBuffer, fxServerSocket, fxSocket, and GO4TRACE.

TGo4Socket::TGo4Socket ( ) [protected]

Member Function Documentation

Int_t TGo4Socket::Close ( Option_t * opt = "" ) [virtual]

Definition at line 227 of file TGo4Socket.cxx.

References fbOpen, fxSocket, and GO4TRACE.

Referenced by TGo4TaskHandler::CloseChannels(), TGo4TaskHandler::Connect(), TGo4TaskHandler::DisConnect(), TGo4ObjClient::DisconnectServer(), TGo4TaskHandler::ServerRequest(), TGo4ServerTask::StopConnectorThread(), TGo4ServerTask::TimerConnect(), TGo4HistogramServer::TimerConnect(), TGo4HistogramServer::~TGo4HistogramServer(), and TGo4TaskManager::~TGo4TaskManager().

const TBuffer* TGo4Socket::GetBuffer ( ) const [inline]

Access the internal receiving buffer of this socket.

Definition at line 58 of file TGo4Socket.h.

References fxBuffer.

Referenced by TGo4ObjClient::ReceiveBuffer(), TGo4StatusRunnable::Run(), TGo4DataRunnable::Run(), and TGo4CommandRunnable::Run().

Int_t TGo4Socket::GetPort ( ) const [inline]

Definition at line 40 of file TGo4Socket.h.

References fiPort.

Referenced by TGo4TaskManager::GetNegotiationPort(), TGo4HistogramServer::GetObjPort(), and TGo4TaskHandler::WaitGetPort().

Bool_t TGo4Socket::IsClientMode ( ) const [inline]

Definition at line 38 of file TGo4Socket.h.

References fbClientMode.

Bool_t TGo4Socket::IsOpen ( ) const [inline]

Definition at line 36 of file TGo4Socket.h.

References fbOpen.

Referenced by TGo4TaskHandlerRunnable::CheckTransportOpen(), TGo4TaskHandler::ConnectClientChannel(), TGo4TaskHandler::ConnectServerChannel(), ReceiveBuffer(), Recv(), RecvRaw(), Send(), SendBuffer(), TGo4ServerTask::TimerConnect(), and TGo4HistogramServer::TimerConnect().

Int_t TGo4Socket::Open	(	const char *	host,
		Int_t	port,
		Bool_t	keepservsock = `kFALSE`
	)			`[virtual]`

Definition at line 107 of file TGo4Socket.cxx.

References TGo4Log::Debug(), fbClientMode, fbOpen, fgcGOON, fgiOPENCYCLES, fguOPENWAIT, fiPort, fxServerSocket, fxSocket, and GO4TRACE.

Referenced by TGo4TaskHandler::ConnectClientChannel(), TGo4ObjClient::ConnectServer(), TGo4TaskHandler::ServerRequest(), TGo4ServerTask::StopConnectorThread(), TGo4TaskManager::TGo4TaskManager(), TGo4ServerTask::TimerConnect(), and TGo4HistogramServer::TimerConnect().

void TGo4Socket::ReallocBuffer	(	TBuffer *	buffer,
		Int_t	oldsize,
		Int_t	newsize
	)			`[protected]`

Reallocate the fixed input buffer if necessary

Definition at line 498 of file TGo4Socket.cxx.

References fgiBUFEXTRASPACE, and fgiISOWNER.

Referenced by ReceiveBuffer().

Int_t TGo4Socket::ReceiveBuffer ( )

Receive raw buffer and fill the internal TBuffer of this socket instance with it.

Definition at line 293 of file TGo4Socket.cxx.

References TGo4Log::Debug(), fgiBUFINITSIZE, fxBuffer, fxSocket, GO4TRACE, IsOpen(), and ReallocBuffer().

Referenced by TGo4ObjClient::ReceiveBuffer(), TGo4StatusRunnable::Run(), TGo4DataRunnable::Run(), and TGo4CommandRunnable::Run().

TObject * TGo4Socket::Recv ( const char * name = 0 ) [virtual]

Definition at line 456 of file TGo4Socket.cxx.

References TGo4Log::Debug(), fxSocket, GO4TRACE, and IsOpen().

char * TGo4Socket::RecvRaw ( const char * name = 0 ) [virtual]

Int_t TGo4Socket::Send ( const char * name ) [virtual]

Definition at line 390 of file TGo4Socket.cxx.

References TGo4Log::Debug(), fgiBUFLENGTH, fxLocalBuffer, fxSocket, GO4TRACE, and IsOpen().

Int_t TGo4Socket::Send ( TObject * obj ) [virtual]

Int_t TGo4Socket::SendBuffer ( TBuffer * buf )

Send raw buffer of external TBuffer object. Method will prepare raw buffer as a TMessage, i.e. the receiving side should be able to receive it by root TSocket message protocol.

Definition at line 237 of file TGo4Socket.cxx.

References TGo4Log::Debug(), fxSocket, GO4TRACE, and IsOpen().

Referenced by TGo4StatusRunnable::Run(), TGo4DataRunnable::Run(), TGo4CommandRunnable::Run(), and TGo4HistogramServer::SendObject().