onlinemonitor/spadicV10monitor/TSpadicV10Source.cxx (r4864/r3724)

Go to the documentation of this file.

#include "TSpadicV10Source.h"


#include <errno.h>
#include <stdlib.h>
#include <limits.h>

#include "TClass.h"

#include "TGo4Log.h"
#include "TGo4UserSourceParameter.h"
#include "TGo4MbsEvent.h"
//#include "TGo4MbsSubEvent.h"
#include "TGo4EventErrorException.h"
#include "TGo4EventTimeoutException.h"
#include "TGo4EventEndException.h"
#include "base/commons.h"

#include "sp605/Message.h"


#define SPADICV10SOURCE_EVENTBUF 4096

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

TSpadicV10Source::TSpadicV10Source(TGo4UserSourceParameter* par) :
   TGo4EventSource(),
   fbIsOpen(kFALSE),
   fxFile(0),
   fArg(),
   fBoard(0),
   fFullId(0)
{
   TGo4Log::Debug(" New SpadicV10Source %s: par: %s", GetName(), par->GetName());

   fArg = par->GetName();

   //cout << " !!! SPADICV1 !!!   NOT IMPLEMENTED !!!
   TGo4Log::Info("Create New SpadicV10Source  arg: %s", fArg.Data());


   Open();
}

TSpadicV10Source::TSpadicV10Source() :
      TGo4EventSource(),
      fbIsOpen(kFALSE),
      fxFile(0),
      fArg(),
      fBoard(0),
      fFullId(0)
{
}


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

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

Bool_t TSpadicV10Source::BuildEvent(TGo4EventElement* dest)
{
   TGo4MbsEvent* mbs = (TGo4MbsEvent*) dest;

   //if (fBoard==0) throw TGo4EventErrorException(this);

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

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

   static uint16_t data[SPADICV10SOURCE_EVENTBUF]; // intermediate buffer for single mbs event
   uint16_t* pdata = &data[0];
   unsigned len(0);
   int8_t spadicid =-1;

   char sbuf[1024], buffer[1024];
   while (len < SPADICV10SOURCE_EVENTBUF) {
      // read another event from open file into our buffer
      do {
         fxFile->getline(sbuf, sizeof(sbuf), '\n'); // read whole line
         if (fxFile->eof() || !fxFile->good()) {
            // reached last line or read error?
            SetCreateStatus(1);
            SetErrMess(Form("End of input file %s", GetName()));
            SetEventStatus(1);
            throw TGo4EventEndException(this);
         }
      } while (strstr(sbuf, "#") || strstr(sbuf, "!")); // skip any comments

      Int_t status = 1;
      // process on event information in our buffer
      // scan the last input line for values:
      uint16_t val = 0;
      errno = 0; /* To distinguish success/failure after call */
      val = strtol(sbuf, 0, 16); // interpret string as hex value
      //cout << " value="<<hex<<val << endl;
      len++;
      if ((errno == ERANGE && (val == LONG_MAX || val == LONG_MIN))
            || (errno != 0 && val == 0)) {
         status = 1;
      } else {
         status = 0; // only ok if at least one value scanned
         *pdata++ = val;

      } // if errno

      // test here for error in input event

      if (status != 0) {
         mbs->SetValid(kFALSE);
         // somethings wrong, display error message from f_evt_error()
         SetErrMess("TSpadicV10Source Event Source --  ERROR !!!");
         throw TGo4EventErrorException(this);
      }

      // set lower bits of groupid as spadicid in crate number:
      if(spadicid<0)
      {
         uint8_t head = (val >> 12) & 0xF;
          if (head == 0x8) {
            //cout <<"TSpadicV10Source found begin of message word"<< hex << (int) val<< dec << endl;
            spadicid= (val >> 4) & 0x7F;
            //cout <<"TSpadicV10Source found spadic id:"<< (int) spadicid << endl;
            }
      }


      // check here for correct message termination near end of buffer
      unsigned delta = SPADICV10SOURCE_EVENTBUF - len;
      if (delta < 50) {
         uint8_t head = (val >> 12) & 0xF;
         if (head == 0xB) {
//            cout
//                  << "TSpadicV10Source::BuildEvent Found final end of message at delta:"
//                  << delta << endl;
            break;
         } else if (head == 0xC) {
//            cout
//                  << "TSpadicV10Source::BuildEvent Found final buffer  overflow message at delta:"
//                  << delta << endl;
            break;
         } else if (head == 0xD) {
//            cout
//                  << "TSpadicV10Source::BuildEvent Found final epoch marker at delta:"
//                  << delta << endl;
            break;
         } else if (head == 0xF) {
//            cout
//                  << "TSpadicV10Source::BuildEvent Found final info message at delta:"
//                  << delta << endl;
            break;
         } // if head
      } // if delta

   } // while len
     //cout <<"----- BuildEvent added subevent of len "<<len<<", fullid:"<<fFullId<<endl;
   TGo4MbsSubEvent* sub = mbs->AddSubEvent(fFullId, (Short_t*) &data, len + 2);
   // sub->SetSubcrate(spadicid); set sp605 here later
   mbs->SetValid(kTRUE);

   return kTRUE;
}


Int_t TSpadicV10Source::Open()
{
   if (fbIsOpen) return -1;
   // open connection/file
   fxFile = new std::ifstream(fArg.Data());
   if ((fxFile == 0) || !fxFile->good()) {
      delete fxFile;
      fxFile = 0;
      SetCreateStatus(1);
      SetErrMess(Form("Eror opening user file:%s", GetName()));
      throw TGo4EventErrorException(this);
   }
   fbIsOpen = kTRUE;
   fFullId = (0x0000FFFF & roc::proc_SpadicV10Raw) |              // this is procid - Go4 identifier for different data kinds
             (0x00FF0000 & (0 << 16)) |                           // this is subcrate - sp605 id
             (0xFF000000 & (sp605::formatSpadic10Direct << 24));  // this is control  - message format
   return 0;
}


Int_t TSpadicV10Source::Close()
{
   if(!fbIsOpen) return -1;

   delete fxFile;
   fxFile = 0;
   fbIsOpen = kFALSE;
   return 0;
}