onlinemonitor/rocmonitor/TGet4MessageFull.cxx (r4864/r2196)

Go to the documentation of this file.

#include "TGet4MessageFull.h"

TGet4MessageFull::TGet4MessageFull( void )
{
   uRocEpoch        = 0;
   uRocEpochCycle   = 0;

   uLocalEpoch      = 0;
   uLocalEpochCycle = 0;
}
TGet4MessageFull::TGet4MessageFull( roc::Message & messIn, UInt_t rocEpochIn,
                                          UInt_t rocCycleIn, UInt_t localEpochIn, 
                                          UInt_t localCycleIn)
{
   mDataMessages    = messIn;
   uRocEpoch        = rocEpochIn;
   uRocEpochCycle   = rocCycleIn;

   uLocalEpoch      = localEpochIn;
   uLocalEpochCycle = localCycleIn;
}


Bool_t TGet4MessageFull::SetMessageFull( roc::Message & messIn, UInt_t rocEpochIn,
                                          UInt_t rocCycleIn, UInt_t localEpochIn, 
                                          UInt_t localCycleIn)
{
   mDataMessages    = messIn;
   uRocEpoch        = rocEpochIn;
   uRocEpochCycle   = rocCycleIn;

   uLocalEpoch      = localEpochIn;
   uLocalEpochCycle = localCycleIn;

   return kTRUE;
}
Bool_t TGet4MessageFull::SetMessage( roc::Message & messIn)
{
   mDataMessages    = messIn;

   return kTRUE;
}
Bool_t TGet4MessageFull::SetRocEpoch( UInt_t rocEpochIn)
{
   uRocEpoch        = rocEpochIn;

   return kTRUE;
}
Bool_t TGet4MessageFull::SetRocCycle( UInt_t rocCycleIn)
{
   uRocEpochCycle   = rocCycleIn;

   return kTRUE;
}
Bool_t TGet4MessageFull::SetLocalEpoch( UInt_t localEpochIn)
{
   uLocalEpoch      = localEpochIn;

   return kTRUE;
}
Bool_t TGet4MessageFull::SetLocalCycle( UInt_t localCycleIn)
{
   uLocalEpochCycle = localCycleIn;

   return kTRUE;
}

roc::Message TGet4MessageFull::GetMessage() const
{
   return mDataMessages;
}
UInt_t TGet4MessageFull::GetRocEpoch() const
{
   return uRocEpoch;
}
UInt_t TGet4MessageFull::GetRocCycle() const
{
   return uRocEpochCycle;
}
UInt_t TGet4MessageFull::GetLocalEpoch() const
{
   return uLocalEpoch;
}
UInt_t TGet4MessageFull::GetLocalCycle() const
{
   return uLocalEpochCycle;
}

/* This is the function used to sort Messages in the filled vectors
 * For this, it compares the timestamps, taking into account whether the
 * message is a data message or an external synchronization message
 */
bool TGet4MessageFull::operator<(const TGet4MessageFull &rhs) const
{ 
   if( kTRUE == LocalOrder( rhs ) )
      return true;
      else return false; 
}
Bool_t TGet4MessageFull::RocOrder( const TGet4MessageFull &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 = mDataMessages.getMessageType();
      UInt_t typ2 = (messageToCompare.GetMessage()).getMessageType();
      if( typ1 == roc::MSG_SYS && typ2 == roc::MSG_SYS)       // Both External synch messages
      {
         if( mDataMessages.getField(23,12) <= (messageToCompare.GetMessage()).getField(23,12) )
            return kTRUE;
         else return kFALSE;
      }
      else if( typ1 == roc::MSG_SYS )                        // Only this message is Ext Synch
      {
         if( ((mDataMessages.getField(23,12))<<7) <= (messageToCompare.GetMessage()).getGet4Ts() )
            return kTRUE;
         else return kFALSE;
      }
      else if(  typ2 == roc::MSG_SYS)                        // Only messageToCompare is Ext Synch
      {
         if( mDataMessages.getGet4Ts() <= (((messageToCompare.GetMessage()).getField(23,12))<<7) )
            return kTRUE;
         else return kFALSE;
      }
      else                                                   // Both are data messages
      {
         if( mDataMessages.getGet4Ts() <= (messageToCompare.GetMessage()).getGet4Ts() )
            return kTRUE;
         else return kFALSE;
      }
   }
}
Bool_t TGet4MessageFull::LocalOrder( const TGet4MessageFull &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 = mDataMessages.getMessageType();
      UInt_t typ2 = (messageToCompare.GetMessage()).getMessageType();
      if( typ1 == roc::MSG_SYS && typ2 == roc::MSG_SYS)       // Both External synch messages
      {
         if( mDataMessages.getField(23,12) <= (messageToCompare.GetMessage()).getField(23,12) )
            return kTRUE;
         else return kFALSE;
      }
      else if( typ1 == roc::MSG_SYS )                        // Only this message is Ext Synch
      {
         if( ((mDataMessages.getField(23,12))<<7) <= (messageToCompare.GetMessage()).getGet4Ts() )
            return kTRUE;
         else return kFALSE;
      }
      else if(  typ2 == roc::MSG_SYS)                        // Only messageToCompare is Ext Synch
      {
         if( mDataMessages.getGet4Ts() <= (((messageToCompare.GetMessage()).getField(23,12))<<7) )
            return kTRUE;
         else return kFALSE;
      }
      else                                                   // Both are data messages
      {
         if( mDataMessages.getGet4Ts() <= (messageToCompare.GetMessage()).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 TGet4MessageFull::RocSpacing( const TGet4MessageFull &messageToCompare) const
{     
   // distance between two messages in bin multiplied by 0.05 ns.
   double dSpacing = BIN_SIZE_IN_NS * (double) ( (double) (messageToCompare.GetMessage()).getGet4Ts() -
                  (double)mDataMessages.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 TGet4MessageFull::LocalSpacing( const TGet4MessageFull &messageToCompare) const
{   
   // distance between two messages in bin multiplied by 0.05 ns.
   double dSpacing = BIN_SIZE_IN_NS * (double) ( (double) (messageToCompare.GetMessage()).getGet4Ts() -
                  (double)mDataMessages.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;
}