ServerTransport.h

Go to the documentation of this file.

// $Id: ServerTransport.h 4115 2018-10-05 08:24:43Z 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 MBS_ServerTransport
#define MBS_ServerTransport
 
#ifndef DABC_Transport
#include "dabc/Transport.h"
#endif
 
#ifndef DABC_SocketThread
#include "dabc/SocketThread.h"
#endif
 
#ifndef DABC_DataIO
#include "dabc/DataIO.h"
#endif
 
#ifndef DABC_eventsapi
#include "dabc/eventsapi.h"
#endif
 
#ifndef MBS_MbsTypeDefs
#include "mbs/MbsTypeDefs.h"
#endif
 
namespace mbs {
 
   class ServerOutputAddon : public dabc::SocketIOAddon,
                             public dabc::DataOutput {
      protected:
 
         enum OutputState {
            oInit,             // when object created
            oInitReq,          // get request before init block was send
            oWaitingReq,       // waiting request from client
            oWaitingReqBack,   // waiting request from client and need to make call-back
            oWaitingBuffer,
            oSendingEvents,    // sending events
            oSendingLastEvent, // waiting for completion of last event
            oSendingBuffer,
            oDoingClose,
            oError
         };
 
         OutputState           fState;
 
         int                   fKind; // see EMbsServerKinds values
         mbs::TransportInfo    fServInfo; // data, send by transport server in the beginning
         char                  f_sbuf[12]; // input buffer to get request
         mbs::BufferHeader     fHeader;
         long                  fSendBuffers;
         long                  fDroppedBuffers;
         dabc::EventsIteratorRef fIter;
         mbs::EventHeader      fEvHdr;  // additional MBS event header (for non-MBS events)
         mbs::SubeventHeader   fSubHdr; // additional MBS subevent header (for non-MBS events)
         uint32_t              fEvCounter; // special events counter
         uint32_t              fSubevId;  // full id of subevent
         bool                  fHasExtraRequest;
 
         // from addon
         virtual void OnThreadAssigned();
         virtual void OnSendCompleted();
         virtual void OnRecvCompleted();
 
         void MakeCallback(unsigned sz);
 
         virtual double ProcessTimeout(double last_diff);
 
         virtual void OnSocketError(int err, const std::string &info);
 
         virtual dabc::WorkerAddon* Write_GetAddon() { return this; }
 
      public:
         ServerOutputAddon(int fd, int kind, dabc::EventsIteratorRef& iter, uint32_t subid);
         virtual ~ServerOutputAddon();
 
         void FillServInfo(int32_t maxbytes, bool isnewformat);
         void SetServerKind(int kind) { fKind = kind; }
 
         // code from the DataOutput
         virtual unsigned Write_Check();
         virtual unsigned Write_Buffer(dabc::Buffer& buf);
         virtual double Write_Timeout() { return 0.1; }
   };
 
 
   // ===============================================================================
 
   class ServerTransport : public dabc::Transport {
      protected:
 
         int fKind;             
         int fPortNum;          
         int fSlaveQueueLength; 
         int fClientsLimit;     
         int fDoingClose;       
         bool fBlocking;        
         bool fDeliverAll;      
         std::string fIterKind; 
         uint32_t fSubevId;     
 
         virtual bool StartTransport();
         virtual bool StopTransport();
 
         virtual int ExecuteCommand(dabc::Command cmd);
 
         virtual bool ProcessRecv(unsigned) { return SendNextBuffer(); }
         virtual bool ProcessSend(unsigned) { return SendNextBuffer(); }
 
         bool SendNextBuffer();
 
         void ProcessConnectionActivated(const std::string &name, bool on);
 
      public:
 
         ServerTransport(dabc::Command cmd, const dabc::PortRef &outport,
                         int kind, int portnum,
                         dabc::SocketServerAddon *connaddon,
                         const dabc::Url& url);
         virtual ~ServerTransport();
 
   };
}
 
#endif