onlinemonitor/rocmonitor/TRocEvent.cxx (r4864/r3721)

Go to the documentation of this file.

/* Generated by Together */

#include "TRocEvent.h"

#include "TGo4Log.h"

UInt_t    TRocEvent::ConfigRocs[MAX_ROC] = SET_ROCS;

Bool_t TRocMessageExtended::RocOrder( const TRocMessageExtended &messageToCompare) const
{
   if( uRocEpochCycle < messageToCompare.GetRocCycle() )      // messageToCompare in next Cycle
      return kTRUE;
   else if( uRocEpochCycle > messageToCompare.GetRocCycle() ) // messageToCompare in prev Cycle
      return kFALSE;
   else if( uRocEpoch < messageToCompare.GetRocEpoch() )      // messageToCompare in next Epoch
      return kTRUE;
   else if( uRocEpoch > messageToCompare.GetRocEpoch() )      // messageToCompare in prev Epoch
      return kFALSE;
   else  // Same cycle and same epoch!
   {
      UInt_t typ1 = fxMessage.getMessageType();
      UInt_t typ2 = (messageToCompare.GetRocMessage()).getMessageType();
      if( typ1 == roc::MSG_SYS && typ2 == roc::MSG_SYS)       // Both External synch messages
      {
         if( fxMessage.getField(23,12) <= (messageToCompare.GetRocMessage()).getField(23,12) )
            return kTRUE;
         else return kFALSE;
      }
      else if( typ1 == roc::MSG_SYS )                        // Only this message is Ext Synch
      {
         if( ((fxMessage.getField(23,12))<<7) <= (messageToCompare.GetRocMessage()).getGet4Ts() )
            return kTRUE;
         else return kFALSE;
      }
      else if(  typ2 == roc::MSG_SYS)                        // Only messageToCompare is Ext Synch
      {
         if( fxMessage.getGet4Ts() <= (((messageToCompare.GetRocMessage()).getField(23,12))<<7) )
            return kTRUE;
         else return kFALSE;
      }
      else                                                   // Both are data messages
      {
         if( fxMessage.getGet4Ts() <= (messageToCompare.GetRocMessage()).getGet4Ts() )
            return kTRUE;
         else return kFALSE;
      }
   }
}
Bool_t TRocMessageExtended::LocalOrder( const TRocMessageExtended &messageToCompare) const
{
   if( uLocalEpochCycle < messageToCompare.GetLocalCycle() )      // messageToCompare in next Cycle
      return kTRUE;
   else if( uLocalEpochCycle > messageToCompare.GetLocalCycle() ) // messageToCompare in prev Cycle
      return kFALSE;
   else if( uLocalEpoch < messageToCompare.GetLocalEpoch() )      // messageToCompare in next Epoch
      return kTRUE;
   else if( uLocalEpoch > messageToCompare.GetLocalEpoch() )      // messageToCompare in prev Epoch
      return kFALSE;
   else  // Same cycle and same epoch!
   {
      UInt_t typ1 = fxMessage.getMessageType();
      UInt_t typ2 = (messageToCompare.GetRocMessage()).getMessageType();
      if( typ1 == roc::MSG_SYS && typ2 == roc::MSG_SYS)       // Both External synch messages
      {
         if( fxMessage.getField(23,12) <= (messageToCompare.GetRocMessage()).getField(23,12) )
            return kTRUE;
         else return kFALSE;
      }
      else if( typ1 == roc::MSG_SYS )                        // Only this message is Ext Synch
      {
         if( ((fxMessage.getField(23,12))<<7) <= (messageToCompare.GetRocMessage()).getGet4Ts() )
            return kTRUE;
         else return kFALSE;
      }
      else if(  typ2 == roc::MSG_SYS)                        // Only messageToCompare is Ext Synch
      {
         if( fxMessage.getGet4Ts() <= (((messageToCompare.GetRocMessage()).getField(23,12))<<7) )
            return kTRUE;
         else return kFALSE;
      }
      else                                                   // Both are data messages
      {
         if( fxMessage.getGet4Ts() <= (messageToCompare.GetRocMessage()).getGet4Ts() )
            return kTRUE;
         else return kFALSE;
      }
   }
}

#define BIN_SIZE_IN_NS         0.05
#define EPOCH_IN_BINS     524288
#define EPOCH_IN_NS        26214.4
#define CYCLE_IN_EPOCHS  1048576
Double_t TRocMessageExtended::RocSpacing( const TRocMessageExtended &messageToCompare) const
{
   UInt_t typ1 = fxMessage.getMessageType();
   UInt_t typ2 = (messageToCompare.GetRocMessage()).getMessageType();
   if( roc::MSG_GET4 != typ1 || roc::MSG_GET4 != typ2 ) // not a hit info
      return -1;
   // distance between two messages in bin multiplied by 0.05 ns.
   double dSpacing = BIN_SIZE_IN_NS * (double) ( (double) (messageToCompare.GetRocMessage()).getGet4Ts() -
                  (double)fxMessage.getGet4Ts() );
   // When messages are not in the same epoch
   // the time  has to be corrected
   if ( uRocEpoch != messageToCompare.GetRocEpoch() )
   {
      if( uRocEpochCycle != messageToCompare.GetRocCycle() )
      {
         dSpacing += EPOCH_IN_NS * (double) ( (double)messageToCompare.GetRocEpoch() -
                                          (double)uRocEpoch +
                                          (double)CYCLE_IN_EPOCHS * (double) ( (double)messageToCompare.GetRocCycle() -
                                          (double)uRocEpochCycle )  );
      }
      else
      {
         dSpacing += EPOCH_IN_NS * (double) ( (double)messageToCompare.GetRocEpoch() -
                                       (double)uRocEpoch );
      }
   }
   // returns time in ns.
   return dSpacing;
}
Double_t TRocMessageExtended::LocalSpacing( const TRocMessageExtended &messageToCompare) const
{
   UInt_t typ1 = fxMessage.getMessageType();
   UInt_t typ2 = (messageToCompare.GetRocMessage()).getMessageType();
   if( roc::MSG_GET4 != typ1 || roc::MSG_GET4 != typ2 ) // not a hit info
      return -1;
   // distance between two messages in bin multiplied by 0.05 ns.
   double dSpacing = BIN_SIZE_IN_NS * (double) ( (double) (messageToCompare.GetRocMessage()).getGet4Ts() -
                  (double)fxMessage.getGet4Ts() );
   // When messages are not in the same epoch
   // the time  has to be corrected
   if ( uLocalEpoch != messageToCompare.GetLocalEpoch() )
   {
      if( uLocalEpochCycle != messageToCompare.GetLocalCycle() )
      {
         dSpacing += EPOCH_IN_NS * (double) ( (double)messageToCompare.GetLocalEpoch() -
                                          (double)uLocalEpoch +
                                          (double)CYCLE_IN_EPOCHS * (double) ( (double)messageToCompare.GetLocalCycle() -
                                          (double)uLocalEpochCycle )  );
      }
      else
      {
         dSpacing += EPOCH_IN_NS * (double) ( (double)messageToCompare.GetLocalEpoch() -
                                       (double)uLocalEpoch );
      }
   }
   // returns time in ns.
   return dSpacing;
}

void TRocMessageExtended::Print( unsigned kind ) const
{
    fxMessage.printData( kind, fuFulltime >> 14 );
}

TRocData::TRocData() : TGo4EventElement()
{
}


TRocData::TRocData(const char* name, Short_t id) :
   TGo4EventElement(name,name,id)
{
   TGo4Log::Info("TRocData: Create instance %s with composite id %d", name, id);
   // the following are not cleared between events, but initialized at on submit:
   fLastTriggerTm=0;
   for(int snc=0; snc<MAX_SYNC;++snc)
      fLastSyncTm[snc]=0;
}


TRocData::~TRocData()
{
}

void  TRocData::Clear(Option_t *t)
{
   fExtMessages.clear();
   vMessageEventBuffer.clear();
   // note: we do not clear last trigger/sync timestamps here

//   printf("Clear TRocData\n");
}




TRocEvent::TRocEvent(const char* name, Short_t id) :
         TGo4CompositeEvent(name,name,id)
{
   TGo4Log::Info("TRocEvent: Create instance %s with composite id %d", name, id);
   TString modname;
   for(int roc=0; roc<MAX_ROC;++roc)
   {
      if(TRocEvent::ConfigRocs[roc]==0) continue; // skip empty ROC ids
      //modname.Form("ROC%02d%02d",id,roc); // branch names should be unique in complete tree!
      modname.Form("ROC%02d",roc); // however, for better readibility of tree, we assume we have only one ROC composite!
      addEventElement(new TRocData(modname.Data(),roc));
   }
}

TRocEvent::TRocEvent() :
         TGo4CompositeEvent()
{
}

TRocEvent::~TRocEvent()
{
}

ULong64_t TRocEvent::CalcGlobalTime(Double_t deltaTrigger)
{

   ULong64_t rev=fLastGlobalTriggerTm;
   rev+=deltaTrigger;
   return rev;
}