SocketTransport.h

Go to the documentation of this file.

// $Id: SocketTransport.h 4469 2020-04-15 12:53:59Z linev $
 
/************************************************************
 * The Data Acquisition Backbone Core (DABC)                *
 ************************************************************
 * Copyright (C) 2009 -                                     *
 * GSI Helmholtzzentrum fuer Schwerionenforschung GmbH      *
 * Planckstr. 1, 64291 Darmstadt, Germany                   *
 * Contact:  http://dabc.gsi.de                             *
 ************************************************************
 * This software can be used under the GPL license          *
 * agreements as stated in LICENSE.txt file                 *
 * which is part of the distribution.                       *
 ************************************************************/
 
#ifndef DABC_SocketTransport
#define DABC_SocketTransport
 
#ifndef DABC_SocketThread
#include "dabc/SocketThread.h"
#endif
 
#ifndef DABC_NetworkTransport
#include "dabc/NetworkTransport.h"
#endif
 
namespace dabc {
 
   class SocketNetworkInetrface : public SocketIOAddon,
                                  public NetworkInetrface {
      protected:
 
         typedef Queue<uint32_t> RecIdsQueue;
 
         char*       fHeaders;
         RecIdsQueue fSendQueue;
         RecIdsQueue fRecvQueue;
         int         fRecvStatus;  
         uint32_t    fRecvRecid;   
         int         fSendStatus;  
         uint32_t    fSendRecid;   
 
         std::string fMcastAddr;   
 
         virtual long Notify(const std::string&, int);
 
         virtual void OnSendCompleted();
         virtual void OnRecvCompleted();
 
         virtual void OnSocketError(int msg, const std::string &info);
 
      public:
         SocketNetworkInetrface(int fd, bool datagram = false);
         virtual ~SocketNetworkInetrface();
 
         void SetMCastAddr(const std::string addr) { fMcastAddr = addr; }
 
         virtual void AllocateNet(unsigned fulloutputqueue, unsigned fullinputqueue);
         virtual void SubmitSend(uint32_t recid);
         virtual void SubmitRecv(uint32_t recid);
   };
}
 
#endif