api.h

Go to the documentation of this file.

// $Id: api.h 3862 2018-05-11 10:06:18Z 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_api
#define MBS_api
 
 
#ifndef MBS_MbsTypeDefs
#include "mbs/MbsTypeDefs.h"
#endif
 
#ifndef DABC_ModuleAsync
#include "dabc/ModuleAsync.h"
#endif
 
#ifndef MBS_Iterator
#include "mbs/Iterator.h"
#endif
 
#ifndef MBS_Monitor
#include "mbs/Monitor.h"
#endif
 
namespace mbs {
 
   class ReadoutHandle;
 
   class ReadoutModule : public dabc::ModuleAsync {
      protected:
 
         friend class ReadoutHandle;
 
         mbs::ReadIterator fIter;    
         dabc::TimeStamp fLastNotFullTm; 
         dabc::TimeStamp fCurBufTm;      
         dabc::Command fCmd;             
 
         virtual int ExecuteCommand(dabc::Command cmd);
 
         void ProcessData();
 
         virtual void ProcessInputEvent(unsigned port);
 
         virtual void ProcessTimerEvent(unsigned timer);
 
         virtual int AcceptBuffer(dabc::Buffer& buf) { return dabc::cmd_false; }
 
         bool GetEventInTime(double maxage);
 
      public:
 
         ReadoutModule(const std::string &name, dabc::Command cmd);
 
   };
 
   // =================================================================================
 
   class ReadoutHandle : protected dabc::ModuleAsyncRef {
 
      DABC_REFERENCE(ReadoutHandle, dabc::ModuleAsyncRef, ReadoutModule)
 
      
      static ReadoutHandle Connect(const std::string &url)
      {
         return DoConnect(url, "mbs::ReadoutModule");
      }
 
      bool null() const { return dabc::ModuleAsyncRef::null(); }
 
      bool Disconnect();
 
      mbs::EventHeader* NextEvent(double tmout = 1.0, double maxage = -1.);
 
      mbs::EventHeader* GetEvent();
 
      protected:
 
 
      static ReadoutHandle DoConnect(const std::string &url, const char* classname);
 
   };
 
   // ==========================================================================
 
   class MonitorHandle : protected dabc::ModuleAsyncRef {
 
       DABC_REFERENCE(MonitorHandle, dabc::ModuleAsyncRef, Monitor)
 
       
       static MonitorHandle Connect(const std::string &mbsnode, int cmdport = 6019, int logport = 6007, int statport = 6008);
 
       bool null() const { return dabc::ModuleAsyncRef::null(); }
 
       bool Disconnect();
 
       bool MbsCmd(const std::string &cmd, double tmout=5.);
   };
 
}
 
 
#endif