SocketDevice.h

Go to the documentation of this file.

// $Id: SocketDevice.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_SocketDevice
#define DABC_SocketDevice
 
#ifndef DABC_Device
#include "dabc/Device.h"
#endif
 
namespace dabc {
 
   class NewConnectRec;
   class SocketProtocolAddon;
 
   class SocketDevice : public Device {
 
      friend class SocketProtocolAddon;
      friend class SocketCommandChannel;
 
      protected:
 
         PointersVector         fConnRecs; // list of connections recs
         PointersVector         fProtocols; // list of protocol start processors
         long                   fConnCounter;
         std::string            fBindHost;   // host name used for socket binding
         int                    fBindPort;   // selected port number
         std::string            fCmdChannelId; // server id of command channel, which will redirect sockets
 
         virtual double ProcessTimeout(double last_diff);
 
         virtual int ExecuteCommand(Command cmd);
 
         bool CleanupRecs(double tmout);
 
         void AddRec(NewConnectRec* rec);
 
         void DestroyRec(NewConnectRec* rec, bool res);
 
         NewConnectRec* _FindRec(const char* connid);
 
         void ServerProtocolRequest(SocketProtocolAddon* proc, const char* inmsg, char* outmsg);
 
         bool ProtocolCompleted(SocketProtocolAddon* proc, const char* inmsg);
 
         void RemoveProtocolAddon(SocketProtocolAddon* proc, bool res);
 
         int HandleManagerConnectionRequest(Command cmd);
 
         std::string StartServerAddon();
 
      public:
         enum {
            headerConnect = 175404571, // 32-bit value used to identify connect request,
            ProtocolMsgSize = 100      // total length of request buffer size
         };
 
         virtual std::string RequiredThrdClass() const { return typeSocketThread; }
         virtual const char* ClassName() const { return dabc::typeSocketDevice; }
 
         SocketDevice(const std::string &name, Command cmd);
         virtual ~SocketDevice();
 
   };
 
}
 
#endif