UdpTransport.h

Go to the documentation of this file.

// $Id: UdpTransport.h 4543 2020-06-10 07:21:48Z 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 HADAQ_UDPTRANSPORT_H
#define HADAQ_UDPTRANSPORT_H
 
#ifndef DABC_SocketThread
#include "dabc/SocketThread.h"
#endif
 
 #ifndef DABC_Pointer
#include "dabc/Pointer.h"
#endif
 
#ifndef DABC_DataTransport
#include "dabc/DataTransport.h"
#endif
 
#ifndef HADAQ_HadaqTypeDefs
#include "hadaq/HadaqTypeDefs.h"
#endif
 
namespace hadaq {
 
   class DataTransport;
   class NewTransport;
   class TerminalModule;
 
   struct TransportInfo {
      int                fNPort;           
 
      uint64_t           fTotalRecvPacket;
      uint64_t           fTotalDiscardPacket;
      uint64_t           fTotalDiscard32Packet;
      uint64_t           fTotalArtificialLosts;
      uint64_t           fTotalArtificialSkip;
      uint64_t           fTotalRecvBytes;
      uint64_t           fTotalDiscardBytes;
      uint64_t           fTotalProducedBuffers;
 
      void ClearCounters()
      {
         fTotalRecvPacket = 0;
         fTotalDiscardPacket = 0;
         fTotalDiscard32Packet = 0;
         fTotalArtificialLosts = 0;
         fTotalArtificialSkip = 0;
         fTotalRecvBytes = 0;
         fTotalDiscardBytes = 0;
         fTotalProducedBuffers = 0;
      }
 
      TransportInfo(int port) : fNPort(port) { ClearCounters(); }
 
      std::string GetDiscardString()
      {
         std::string res = dabc::number_to_str(fTotalDiscardPacket);
 
         if (fTotalArtificialLosts > 0)
            res = std::string("*") + dabc::number_to_str(fTotalArtificialLosts);
 
         return res;
      }
 
      std::string GetDiscard32String()
      {
 
         std::string res = dabc::number_to_str(fTotalDiscard32Packet);
 
         if (fTotalArtificialSkip > 0)
            res = std::string("#") + dabc::number_to_str(fTotalArtificialSkip);
 
         return res;
      }
 
   };
 
   // ==================================================================================
 
   class NewAddon : public dabc::SocketAddon,
                    public TransportInfo {
      protected:
 
         friend class TerminalModule;  // use only to access statistic, nothing else
         friend class NewTransport;
 
         dabc::Pointer      fTgtPtr;          
         unsigned           fMTU;             
         void*              fMtuBuffer;       
         int                fSkipCnt;         
         int                fSendCnt;         
         int                fMaxLoopCnt;      
         double             fReduce;          
         double             fLostRate;        
         int                fLostCnt;         
         bool               fDebug;           
         bool               fRunning;         
         dabc::TimeStamp    fLastProcTm;      
         double             fMaxProcDist;     
 
         virtual void ProcessEvent(const dabc::EventId&);
 
         virtual long Notify(const std::string&, int);
 
         /* Use codes which are valid for Read_Start */
         bool ReadUdp();
 
         bool CloseBuffer();
 
      public:
         NewAddon(int fd, int nport, int mtu, bool debug, int maxloop, double reduce, double lost);
         virtual ~NewAddon();
 
         bool HasBuffer() const { return !fTgtPtr.null(); }
 
         static int OpenUdp(const std::string &host, int nport, int rcvbuflen);
   };
 
   // ==================================================================================
 
   class NewTransport : public dabc::Transport {
 
      protected:
 
         int            fIdNumber;     
         unsigned       fNumReadyBufs; 
         bool           fBufAssigned;  
         int            fLastSendCnt;  
         dabc::TimeStamp fLastDebugTm;     
 
         virtual void ProcessTimerEvent(unsigned timer);
 
         virtual int ExecuteCommand(dabc::Command cmd);
 
      public:
         NewTransport(dabc::Command, const dabc::PortRef& inpport, NewAddon* addon, double flush = 1, double heartbeat = -1);
         virtual ~NewTransport();
 
         virtual bool StartTransport();
         virtual bool StopTransport();
 
         virtual bool ProcessSend(unsigned port);
         virtual bool ProcessBuffer(unsigned pool);
 
         bool AssignNewBuffer(unsigned pool, NewAddon* addon = nullptr);
         void BufferReady();
         void FlushBuffer(bool onclose = false);
 
   };
 
}
 
#endif