onlinemonitor/faspmonitor/TFaspSource.cxx (r4864/r3724)

Go to the documentation of this file.

#include "TFaspSource.h"

#include "TClass.h"

#include <stdlib.h>

#include "TGo4EventErrorException.h"
#include "TGo4EventEndException.h"
#include "TGo4EventTimeoutException.h"
#include "TGo4UserSourceParameter.h"
#include "TGo4MbsEvent.h"
#include "TGo4Log.h"

#include "base/commons.h"

TFaspSource::TFaspSource(const char* name,
       const char* args,
       Int_t port) :
       TGo4EventSource(name),
       fbIsOpen(kFALSE),
       fxFile(0)
{
   SetName(name);
   Open();
}

TFaspSource::TFaspSource(TGo4UserSourceParameter* par) :
        TGo4EventSource(" "),
        fbIsOpen(kFALSE),
        fxFile(0)
{
        if(par) {
                SetName(par->GetName());
                Open();
        } else {
           TGo4Log::Info("TFaspSource constructor with zero parameter!");
        }
}

TFaspSource::TFaspSource() :
        TGo4EventSource("default Fasp source"),
        fbIsOpen(kFALSE),
        fxFile(0)
{
}

TFaspSource::~TFaspSource()
{
        Close();
}

Bool_t TFaspSource::CheckEventClass(TClass* cl)
{
        return cl->InheritsFrom(TGo4MbsEvent::Class());
}

Bool_t TFaspSource::BuildEvent(TGo4EventElement* dest)
{
        TGo4MbsEvent* evnt = dynamic_cast<TGo4MbsEvent*> (dest);
        if (evnt==0) return kFALSE;
        // this generic loop is intended to handle buffers with several events. we keep it here,
        // although our "buffers" consists of single events.

   uint8_t rawbuf[44];
   size_t rz = fread(rawbuf, 1, 44, fxFile);

   if (rz<44) {
      Close();
      SetEventStatus(1);
      throw TGo4EventEndException(this);
   }

   unsigned id = rawbuf[34] * 0x10000 + rawbuf[35] * 0x100 + rawbuf[36];

   Int_t fiEventLen = 44 / sizeof(Short_t);
   UInt_t fullid = roc::proc_FASP /* | (boardNumber() << 16) | (msgFormat() << 24) */;
   evnt->AddSubEvent(fullid, (Short_t*) rawbuf, fiEventLen+2, kTRUE);
   evnt->SetDlen(fiEventLen+2+4); // total length of pseudo mbs event

   evnt->SetCount(id);

        return kTRUE;
}

Int_t TFaspSource::Open()
{
        if(fbIsOpen) return -1;

        fxFile =  fopen(GetName(),"r");
        if(fxFile==0)   {
                SetCreateStatus(1);
                SetErrMess(Form("Eror opening user file:%s", GetName()));
                throw TGo4EventErrorException(this);
        }

        fbIsOpen = kTRUE;
        return 0;
}

Int_t TFaspSource::Close()
{
        if(!fbIsOpen) return -1;
        fclose(fxFile); fxFile = 0;
        fbIsOpen = kFALSE;
        return 0;
}