TGo4Socket.h

Go to the documentation of this file.

// $Id: TGo4Socket.h 884 2012-11-10 16:47:22Z linev $
//-----------------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//         Experiment Data Processing at EE department, GSI
//-----------------------------------------------------------------------
// Copyright (C) 2000- GSI Helmholtzzentrum f�r Schwerionenforschung GmbH
//                     Planckstr. 1, 64291 Darmstadt, Germany
// Contact:            http://go4.gsi.de
//-----------------------------------------------------------------------
// This software can be used under the license agreements as stated
// in Go4License.txt file which is part of the distribution.
//-----------------------------------------------------------------------

#ifndef TGO4SOCKET_H
#define TGO4SOCKET_H

#include "Rtypes.h"

class TObject;
class TSocket;
class TServerSocket;

class TGo4Socket {
  public:
     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 { return fbOpen; }

     Bool_t IsClientMode() const { return fbClientMode; }

     Int_t GetPort() const { return fiPort; }

     Int_t SendBuffer(TBuffer* buf);

     Int_t ReceiveBuffer();

     const TBuffer * GetBuffer() const { return fxBuffer; }

     static const Int_t fguOPENWAIT;

     static const Int_t fgiOPENCYCLES;

     static const Int_t fgiBUFLENGTH;

     static const Int_t fgiBUFINITSIZE;

     static const Int_t fgiBUFEXTRASPACE;

     static const char* fgcGOON;   

     static const Int_t fgiISOWNER;

  protected:
    TGo4Socket();  // not implemented, only for compiler to avoid calling of default

    void ReallocBuffer(TBuffer* buffer, Int_t oldsize, Int_t newsize);

  private:

    Bool_t fbClientMode;

    Bool_t fbOpen;

    TSocket * fxSocket;

    TServerSocket * fxServerSocket;

    Int_t fiPort;

    char* fxLocalBuffer; 

    TBuffer * fxBuffer;
};

#endif