TGo4Socket.h

Go to the documentation of this file.

// $Id$
//-----------------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//         Experiment Data Processing at EE department, GSI
//-----------------------------------------------------------------------
// Copyright (C) 2000- GSI Helmholtzzentrum fuer 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 "RtypesCore.h"

class TObject;
class TBuffer;
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 = nullptr);
     virtual char *RecvRaw(const char *name = nullptr);

     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;   

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

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

  private:

    Bool_t fbClientMode{kFALSE};

    Bool_t fbOpen{kFALSE};

    TSocket *fxSocket{nullptr};

    TServerSocket *fxServerSocket{nullptr};

    Int_t fiPort{0};

    char *fxLocalBuffer{nullptr}; 

    TBuffer *fxBuffer{nullptr};
};

#endif