TGo4MbsSource.h

Go to the documentation of this file.

// $Id$
//-----------------------------------------------------------------------
//       The GSI Online Offline Object Oriented (Go4) Project
//         Experiment Data Processing at EE department, GSI
//-----------------------------------------------------------------------
// Copyright (C) 2000- GSI Helmholtzzentrum fuer Schwerionenforschung GmbH
//                     Planckstr. 1, 64291 Darmstadt, Germany
// Contact:            http://go4.gsi.de
//-----------------------------------------------------------------------
// This software can be used under the license agreements as stated
// in Go4License.txt file which is part of the distribution.
//-----------------------------------------------------------------------
 
#ifndef TGO4MBSSOURCE_H
#define TGO4MBSSOURCE_H
 
#include "TGo4EventSource.h"
 
extern "C" {
   #include "f_evt.h"
   #include "s_filhe.h"
   #include "s_bufhe.h"
}
 
class TGo4MbsEvent;
class TGo4MbsSubEvent;
class TGo4MbsSourceParameter;

class TGo4MbsSourcePrintPar : public TObject {
 
  public:
    TGo4MbsSourcePrintPar() : TObject() {}
    virtual ~TGo4MbsSourcePrintPar() {}
    Int_t fiNum{0};
    Int_t fiSid{0};
    Int_t fiLong{0};
    Int_t fiHex{0};
    Int_t fiData{0};
  ClassDefOverride(TGo4MbsSourcePrintPar, 1)
};

 
class TGo4MbsSource : public TGo4EventSource {
  public:

    TGo4MbsSource();
 
    TGo4MbsSource(const char *name, Int_t mode);
 
    TGo4MbsSource(TGo4MbsSourceParameter *par, Int_t mode);
 
    virtual ~TGo4MbsSource();

    Bool_t CheckEventClass(TClass *cl) override;

    Bool_t BuildEvent(TGo4EventElement *dest) override;

    virtual Int_t Close();

    virtual Int_t Open();

    virtual Int_t NextEvent();

    void BuildMbsEvent(TGo4MbsEvent *target);

    TGo4MbsSubEvent *BuildMbsSubEvent(TGo4MbsEvent *target, Int_t fullID, Short_t *source, Int_t datalength);

    void SetStartEvent(UInt_t firstindex) { fuStartEvent = firstindex; }
 
    void SetStopEvent(UInt_t lastindex) { fuStopEvent = lastindex; }
 
    void SetEventInterval(UInt_t skipinterval) { fuEventInterval = skipinterval; }
 
    void SetTimeout(Int_t time) { fiTimeout = time; }
 
    void SetPort(Int_t port) { fiPort = port; }

    s_filhe *GetInfoHeader() const { return fxInfoHeader; }

    virtual s_bufhe *GetBufferHeader();

    static const UInt_t fguLONGBYCHAR;

    static const UInt_t fguSHORTBYCHAR;

    static const UInt_t fguLONGBYSHORT;

    static const UInt_t fguEVHEBYCHAR;

    void SetPrintEvent(Int_t num = 1, Int_t sid = -1, Int_t longw = 1, Int_t hexw = 1, Int_t dataw = 0);
 
    void SetDataCopyMode(Bool_t on) { fbDataCopyMode = on; }
 
    static void SetPollingMode(Bool_t on = kTRUE);
 
  private:

    Int_t fiMode{0};
 
    Int_t fiRetryCnt{0};   
 
    Int_t GetMode() const { return fiMode; }
 
  protected:

    s_evt_channel *fxInputChannel{nullptr}; 
 
    s_ve10_1 *fxEvent{nullptr}; 

    s_bufhe *fxBuffer{nullptr}; 

    s_filhe *fxInfoHeader{nullptr}; 
 
    Bool_t fbIsOpen{kFALSE};

    Bool_t fbDataCopyMode{kFALSE};

    ULong_t fuEventCounter{0};

    Bool_t fbFirstEvent{kFALSE};

    ULong_t fuStartEvent{0};

    ULong_t fuStopEvent{0};

    ULong_t fuEventInterval{0};

    Int_t fiTimeout{0};
 
    Bool_t fbPollingMode{kFALSE}; 

    Int_t fiPort{0};

    TGo4MbsSourcePrintPar fxPrEventPar; 
 
    static Bool_t gbPollingMode;  
 
  ClassDefOverride(TGo4MbsSource, 3)
 
};
 
#endif //TGO4MBSSOURCE_H