onlinemonitor/rocmonitor/TRocSource.cxx (r4864/r3724)

Go to the documentation of this file.

#include "TRocSource.h"

#include "TClass.h"

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

// class required only to use methods, which are available in TGo4MbsSource

TRocSource::TRocSource(TGo4UserSourceParameter* par) :
   TGo4EventSource(),
   fArg(),
   fBoard(0),
   fFullId(0)
{
   TGo4Log::Debug(" New RocSource %s: par: %s", GetName(), par->GetName());

   fArg = par->GetName();

   TGo4Log::Info(" !!! ROC !!!   Create New RocSource  arg: %s", fArg.Data());

   Open();
}

TRocSource::TRocSource() : TGo4EventSource(), fArg(), fBoard(0)
{
}


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

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

Bool_t TRocSource::BuildEvent(TGo4EventElement* dest)
{
   if (fBoard==0) throw TGo4EventErrorException(this);

   void* buf(0);
   unsigned len(0);

   if (!fBoard->getNextBuffer(buf,len, 5.))
      throw TGo4EventTimeoutException(this);

   TGo4MbsEvent* mbs = (TGo4MbsEvent*) dest;

   return mbs->AddSubEvent(fFullId, (Short_t*) buf, len/sizeof(Short_t) + 2) != 0;
}


Int_t TRocSource::Open()
{
   if(fBoard!=0) return -1;

   fBoard = roc::Board::Connect(fArg.Data(), roc::roleDAQ);

   if (fBoard==0) return -1;

            //  procid - data type, subcrate - rocnumber, control - message type

   fFullId = roc::proc_RawData | (fBoard->rocNumber() << 16) | (fBoard->getMsgFormat() << 24); //
   
   fBoard->setFlushTimeout(0.1);

   fBoard->startDaq();

   return 0;
}


Int_t TRocSource::Close()
{
   if(fBoard==0) return -1;

   fBoard->stopDaq();

   roc::Board::Close(fBoard);

   fFullId = 0;

   return 0;
}