The Raw COPPER class ver.1 ( the latest version since May, 2014 ) This class stores data received by COPPER via belle2linkt Data from all detectors except PXD are stored in this class. More...

#include <PreRawCOPPERFormat_latest.h>

Inheritance diagram for PreRawCOPPERFormat_latest:

Public Types
enum	{ POS_MAGIC_B2LHSLB = 0 , SIZE_B2LHSLB_HEADER = 1 }

enum	{ POS_TT_CTIME_TYPE = 0 , POS_TT_TAG = 1 , POS_TT_UTIME = 2 , POS_EXP_RUN = 3 , POS_B2L_CTIME = 4 , SIZE_B2LFEE_HEADER = 5 }

enum	{ POS_TT_CTIME_B2LFEE = 0 , POS_CHKSUM_B2LFEE = 1 , SIZE_B2LFEE_TRAILER = 2 }

enum	{ POS_CHKSUM_B2LHSLB = 0 , SIZE_B2LHSLB_TRAILER = 1 }

enum	{ B2LHSLB_HEADER_MAGIC = 0xFFAA0000 , B2LHSLB_TRAILER_MAGIC = 0xFF550000 }

enum	{ DATA_FORMAT_VERSION = 4 }
	Format version number. More...

enum	{ SIZE_COPPER_DRIVER_HEADER = 0 , SIZE_COPPER_DRIVER_TRAILER = 0 }

enum	{ SIZE_COPPER_HEADER = 0 }

enum	{ SIZE_COPPER_TRAILER = 0 }

enum	{ ONLINE_REMOVED_DATA = 15 }

enum	{ POS_NWORDS = 0 , POS_NODE_ID = 6 }

enum	{ POS_FTSW_ID_OLD = 5 , TEMP_POS_NWORDS_HEADER = 1 , OLD_FTSW_NWORDS_HEADER = 6 }

Public Member Functions
	PreRawCOPPERFormat_latest ()
	Default constructor.

virtual	~PreRawCOPPERFormat_latest ()
	Constructor using existing pointer to raw data buffer.

int	GetDetectorNwords (int n, int finesse_num) OVERRIDE_CPP17
	get Detector buffer length

unsigned int	GetCOPPERCounter (int n) OVERRIDE_CPP17
	get posistion of COPPER block in unit of word

virtual int *	GetExpRunSubrunBuf (int n) OVERRIDE_CPP17
	get b2l block from "FEE b2link header"

virtual unsigned int	GetB2LFEE32bitEventNumber (int n) OVERRIDE_CPP17
	get b2l block from "FEE b2link header"

unsigned int	GetMagicDriverHeader (int n) OVERRIDE_CPP17
	get magic word of COPPER driver header

unsigned int	GetMagicFPGAHeader (int n) OVERRIDE_CPP17
	get magic word of COPPER FPGA header

unsigned int	GetMagicFPGATrailer (int n) OVERRIDE_CPP17
	get magic word of COPPER FPGA trailer

unsigned int	GetMagicDriverTrailer (int n) OVERRIDE_CPP17
	get magic word of COPPER driver trailer

unsigned int	GetTrailerChksum (int n) OVERRIDE_CPP17
	get a checksum on trailer

bool	CheckCOPPERMagic (int n) OVERRIDE_CPP17
	Check if COPPER Magic words are correct.

unsigned int	FillTopBlockRawHeader (unsigned int m_node_id, unsigned int prev_eve32, unsigned int prev_exprunsubrun_no, unsigned int *cur_exprunsubrun_no) OVERRIDE_CPP17
	should be called by DeSerializerCOPPER.cc and fill contents in RawHeader

unsigned int	GetDriverChkSum (int n) OVERRIDE_CPP17
	read COPPER driver's checksum value

unsigned int	CalcDriverChkSum (int n) OVERRIDE_CPP17
	calc COPPER driver's checksum value

void	CheckData (int n, unsigned int prev_evenum, unsigned int cur_evenum, unsigned int prev_copper_ctr, unsigned int cur_copper_ctr, unsigned int prev_exprunsubrun_no, unsigned int *cur_exprunsubrun_no) OVERRIDE_CPP17
	check data contents

void	CheckUtimeCtimeTRGType (int n) OVERRIDE_CPP17
	check data contents

int	CheckB2LHSLBMagicWords (int *finesse_buf, int finesse_nwords)
	check magic words of B2link HSLB header/trailer

int	CalcReducedDataSize (int *bufin, int nwords, int num_events, int num_nodes)
	reduce and merge header/trailer

void	CopyReducedData (int bufin, int nwords, int num_events, int num_nodes, int buf_to, int *nwords_to)
	reduce and merge header/trailer

int	CalcReducedNwords (int n)
	calculate reduced data size

int	CopyReducedBuffer (int n, int *buf_to)
	copy data to reduced buffer

int	CheckCRC16 (int n, int finesse_num)
	check CRC16 in B2LFEE trailer

int *	PackDetectorBuf (int packed_buf_nwords, int detector_buf_1st, int nwords_1st, int detector_buf_2nd, int nwords_2nd, int detector_buf_3rd, int nwords_3rd, int *detector_buf_4th, int nwords_4th, RawCOPPERPackerInfo rawcprpacker_info) OVERRIDE_CPP17
	Pack data (format ver. = -1 -> Select the latest format version)

int *	PackDetectorBuf (int packed_buf_nwords, int const(&detector_buf_ch)[MAX_PCIE40_CH], int const(&nwords_ch)[MAX_PCIE40_CH], RawCOPPERPackerInfo rawcpr_info) OVERRIDE_CPP17
	Pack data (format ver. = -1 -> Select the latest format version)

int *	GetDetectorBuffer (int n, int finesse_num) OVERRIDE_CPP17
	Get a pointer to detector buffer.

bool	CheckOnlineRemovedDataBit (int n, int finesse_num) OVERRIDE_CPP17
	check if this channel's data has been removed on a readout PC for CDC online "masking" True : data contents was removed on a readout PC

int	Get1stDetectorNwords (int n) OVERRIDE_CPP17 FINAL_CPP17
	get Detector buffer length of slot A

int	Get2ndDetectorNwords (int n) OVERRIDE_CPP17 FINAL_CPP17
	get Detector buffer length of slot B

int	Get3rdDetectorNwords (int n) OVERRIDE_CPP17 FINAL_CPP17
	get Detector buffer length of slot C

int	Get4thDetectorNwords (int n) OVERRIDE_CPP17 FINAL_CPP17
	get Detector buffer length of slot D

int *	Get1stDetectorBuffer (int n) OVERRIDE_CPP17 FINAL_CPP17
	get Detector buffer of slot A

int *	Get2ndDetectorBuffer (int n) OVERRIDE_CPP17 FINAL_CPP17
	get Detector Buffer of slot B

int *	Get3rdDetectorBuffer (int n) OVERRIDE_CPP17 FINAL_CPP17
	get Detector Buffer of slot C

int *	Get4thDetectorBuffer (int n) OVERRIDE_CPP17 FINAL_CPP17
	get Detector Buffer of slot D

int *	GetRawTrlBufPtr (int n) OVERRIDE_CPP17
	get buffer pointer of rawcopper trailer

int	GetExpNo (int n) OVERRIDE_CPP17
	get Experimental # from header

unsigned int	GetExpRunSubrun (int n) OVERRIDE_CPP17
	get Experimental # from header

int	GetRunNo (int n) OVERRIDE_CPP17
	Exp# (10bit) run# (14bit) restart # (8bit)

int	GetSubRunNo (int n) OVERRIDE_CPP17
	get run # (14bit)

unsigned int	GetEveNo (int n) OVERRIDE_CPP17
	get subrun #(8bit)

int	GetDataType (int n) OVERRIDE_CPP17
	get contents of header

int	GetTruncMask (int n) OVERRIDE_CPP17
	get contents of header

unsigned int	GetErrorBitFlag (int n) OVERRIDE_CPP17
	get contents of header

void	AddErrorBitFlag (int n, unsigned int error_bit_flag) OVERRIDE_CPP17
	Add Detected Error bitflag.

int	GetPacketCRCError (int n) OVERRIDE_CPP17
	check CRC packet Error

int	GetEventCRCError (int n) OVERRIDE_CPP17
	check CRC event Error

unsigned int	GetNodeID (int n) OVERRIDE_CPP17
	get node-ID from data

virtual int	GetNumFINESSEBlock (int n) OVERRIDE_CPP17
	get # of FINNESEs which contains data

int	Get1stFINESSENwords (int n) OVERRIDE_CPP17 FINAL_CPP17
	get data size of FINESSE slot A buffer

int	Get2ndFINESSENwords (int n) OVERRIDE_CPP17 FINAL_CPP17
	get data size of FINESSE slot B buffer

int	Get3rdFINESSENwords (int n) OVERRIDE_CPP17 FINAL_CPP17
	get data size of FINESSE slot C buffer

int	Get4thFINESSENwords (int n) OVERRIDE_CPP17 FINAL_CPP17
	get data size of FINESSE slot D buffer

int	GetOffset1stFINESSE (int n) OVERRIDE_CPP17 FINAL_CPP17
	get # of offset words for FINESSE slot A buffer position

int	GetOffset2ndFINESSE (int n) OVERRIDE_CPP17 FINAL_CPP17
	get # of offset words for FINESSE slot B buffer position

int	GetOffset3rdFINESSE (int n) OVERRIDE_CPP17 FINAL_CPP17
	get # of offset words for FINESSE slot C buffer position

int	GetOffset4thFINESSE (int n) OVERRIDE_CPP17 FINAL_CPP17
	get # of offset words for FINESSE slot D buffer position

unsigned int	GetTTCtimeTRGType (int n) OVERRIDE_CPP17
	get b2l block from "FEE b2link header"

unsigned int	GetTTUtime (int n) OVERRIDE_CPP17
	Check if COPPER Magic words are correct.

int	GetTTCtime (int n) OVERRIDE_CPP17
	Get ctime.

int	GetTRGType (int n) OVERRIDE_CPP17
	Get trgtype.

void	GetTTTimeVal (int n, struct timeval *tv) OVERRIDE_CPP17
	Get timeval.

int	GetMaxNumOfCh (int n) OVERRIDE_CPP17
	Get the max number of channels in a readout board.

int *	GetFINESSEBuffer (int n, int finesse_num) OVERRIDE_CPP17
	Get a pointer to a FINESSE buffer.

int	GetFINESSENwords (int n, int finesse_num) OVERRIDE_CPP17
	Get the size of a finesse buffer.

void	CompareHeaderValue (int n, const unsigned int(&input_val)[MAX_PCIE40_CH], std::vector< std::vector< unsigned int > > &summary_table) OVERRIDE_CPP17
	Check header value of all channels.

virtual int *	GetRawHdrBufPtr (int n)
	get buffer pointer of rawcopper header(Currently same as GetBufferPos)

virtual int *	Get1stFINESSEBuffer (int n)
	get FINESSE buffer pointer for slot A

virtual int *	Get2ndFINESSEBuffer (int n)
	get FINESSE buffer pointer for slot B

virtual int *	Get3rdFINESSEBuffer (int n)
	get FINESSE buffer pointer for slot C

virtual int *	Get4thFINESSEBuffer (int n)
	get FINESSE buffer pointer for slot D

virtual int	GetEventCRC16Value (int n, int finesse_num)
	Get Event CRC16 value.

virtual int	GetOffsetFINESSE (int n, int finesse)
	get # of offset words

virtual unsigned int	CalcXORChecksum (int *buf, int nwords)
	calc XOR checksum

virtual void	GetNodeName (int n, char *node_name, int bufsize)
	Get hostname of a node from the RawCOPPER header.

virtual void	GetNodeName (char *node_name, unsigned int node_id, int bufsize)
	Get hostname of a node from an argument.

virtual void	SetBuffer (int *bufin, int nwords, int delete_flag, int num_events, int num_nodes)
	set buffer ( delete_flag : m_buffer is freeed( = 0 )/ not freeed( = 1 ) in Destructer )

virtual int	TotalBufNwords ()
	Get total length of m_buffer.

virtual int	GetBufferPos (int n)
	get position of data block in word

virtual int *	GetBuffer (int n)
	get nth buffer pointer

virtual int *	GetWholeBuffer ()
	get pointer to buffer(m_buffer)

virtual int	GetNumEntries ()
	get # of data blocks = (# of nodes)*(# of events)

virtual int	GetNumNodes ()
	get # of data sources(e.g. # of COPPER boards) in m_buffer

virtual int	GetNumEvents ()
	get # of events in m_buffer

virtual int	GetPreAllocFlag ()
	get malloc_flag

virtual int	GetBlockNwords (int n)
	get size of a data block

virtual int	CheckFTSWID (int n)
	get FTSW ID to check whether this data block is FTSW data or not

virtual int	CheckTLUID (int n)
	get FTSW ID to check whether this data block is FTSW data or not

virtual void	CopyBlock (int n, int *buf_to)
	Copy one datablock to buffer.

virtual void	PrintData (int *buf, int nwords)
	print data

Public Attributes
PostRawCOPPERFormat_latest	m_reduced_rawcpr
	data fromat after size reduction

RawHeader_latest	tmp_header
	header ( not recorded )

RawTrailer_latest	tmp_trailer
	trailer ( not recorded )

Protected Attributes
int	m_nwords
	number of words of buffer

int	m_num_nodes
	number of nodes in this object

int	m_num_events
	number of events in this object

int *	m_buffer
	Buffer.

int	m_use_prealloc_buf
	not recorded

Detailed Description

The Raw COPPER class ver.1 ( the latest version since May, 2014 ) This class stores data received by COPPER via belle2linkt Data from all detectors except PXD are stored in this class.

Definition at line 30 of file PreRawCOPPERFormat_latest.h.

Member Enumeration Documentation

◆ anonymous enum

anonymous enum

Definition at line 178 of file PreRawCOPPERFormat_latest.h.

         {
      POS_MAGIC_B2LHSLB = 0,
      //      POS_EVE_CNT_B2LHSLB = 1,
      SIZE_B2LHSLB_HEADER = 1
    };

◆ anonymous enum

anonymous enum

Definition at line 186 of file PreRawCOPPERFormat_latest.h.

         {
      POS_TT_CTIME_TYPE = 0,
      POS_TT_TAG = 1,
      POS_TT_UTIME = 2,
      POS_EXP_RUN = 3,
      POS_B2L_CTIME = 4,
      SIZE_B2LFEE_HEADER = 5
    };

◆ anonymous enum

anonymous enum

Definition at line 199 of file PreRawCOPPERFormat_latest.h.

         {
      POS_TT_CTIME_B2LFEE = 0,
      POS_CHKSUM_B2LFEE = 1,
      SIZE_B2LFEE_TRAILER = 2
    };

◆ anonymous enum

anonymous enum

Definition at line 209 of file PreRawCOPPERFormat_latest.h.

         {
      POS_CHKSUM_B2LHSLB = 0,
      SIZE_B2LHSLB_TRAILER = 1
    };

◆ anonymous enum

anonymous enum

Definition at line 217 of file PreRawCOPPERFormat_latest.h.

         {
      B2LHSLB_HEADER_MAGIC = 0xFFAA0000,
      B2LHSLB_TRAILER_MAGIC = 0xFF550000
    };

◆ anonymous enum

anonymous enum

inherited

Format version number.

Definition at line 230 of file RawCOPPERFormat_latest.h.

         {
      DATA_FORMAT_VERSION = 4
    };

◆ anonymous enum

anonymous enum

inherited

Definition at line 237 of file RawCOPPERFormat_latest.h.

         {
      SIZE_COPPER_DRIVER_HEADER = 0,
      SIZE_COPPER_DRIVER_TRAILER = 0
    };

◆ anonymous enum

anonymous enum

inherited

Definition at line 243 of file RawCOPPERFormat_latest.h.

         {
      SIZE_COPPER_HEADER = 0
    };

◆ anonymous enum

anonymous enum

inherited

Definition at line 248 of file RawCOPPERFormat_latest.h.

         {
      SIZE_COPPER_TRAILER = 0
    };

◆ anonymous enum

anonymous enum

inherited

Definition at line 255 of file RawCOPPERFormat_latest.h.

         {
      ONLINE_REMOVED_DATA = 15
    };

◆ anonymous enum

anonymous enum

inherited

Definition at line 75 of file RawDataBlockFormat.h.

         {
      POS_NWORDS = 0,
      POS_NODE_ID = 6
    };

◆ anonymous enum

anonymous enum

inherited

Definition at line 80 of file RawDataBlockFormat.h.

         {
      // Tentatively needed to distinguish new and old FTSW format, which will be changed in Nov. 2013
      POS_FTSW_ID_OLD = 5,
      TEMP_POS_NWORDS_HEADER = 1,
      OLD_FTSW_NWORDS_HEADER = 6
    };

Constructor & Destructor Documentation

◆ PreRawCOPPERFormat_latest()

PreRawCOPPERFormat_latest ( )

Default constructor.

Definition at line 20 of file PreRawCOPPERFormat_latest.cc.

21{

22}

◆ ~PreRawCOPPERFormat_latest()

~PreRawCOPPERFormat_latest ( )

virtual

Constructor using existing pointer to raw data buffer.

Destructor

Definition at line 24 of file PreRawCOPPERFormat_latest.cc.

25{

26}

Member Function Documentation

◆ CalcDriverChkSum()

unsigned int CalcDriverChkSum ( int n )

virtual

calc COPPER driver's checksum value

Implements RawCOPPERFormat.

Definition at line 28 of file PreRawCOPPERFormat_latest.cc.

{
  int min = GetBufferPos(n) + tmp_header.RAWHEADER_NWORDS;
  int max = GetBufferPos(n) + GetBlockNwords(n)
            - tmp_trailer.RAWTRAILER_NWORDS - SIZE_COPPER_DRIVER_TRAILER;
  unsigned int chksum = 0;
  for (int i = min; i < max; i++) {
    chksum ^= m_buffer[ i ];
  }
  return chksum;
}

◆ CalcReducedDataSize()

int CalcReducedDataSize	(	int *	bufin,
		int	nwords,
		int	num_events,
		int	num_nodes
	)

reduce and merge header/trailer

Definition at line 465 of file PreRawCOPPERFormat_latest.cc.

{
  //
  // Calculate reduced length for a total RawDataBlock (containing multiple data blocks)
  //
  RawDataBlockFormat radblk_fmt;
  int delete_flag = 0;
  radblk_fmt.SetBuffer(bufin, nwords, delete_flag, num_events, num_nodes);
 
  int reduced_nwords = 0;
  for (int k = 0; k < radblk_fmt.GetNumEvents(); k++) {
    int num_nodes_in_sendblock = radblk_fmt.GetNumNodes();
    for (int l = 0; l < num_nodes_in_sendblock; l++) {
      int entry_id = l + k * num_nodes_in_sendblock;
 
      if (radblk_fmt.CheckFTSWID(entry_id) || radblk_fmt.CheckTLUID(entry_id)) {
        reduced_nwords += radblk_fmt.GetBlockNwords(entry_id);
      } else {
        PreRawCOPPERFormat_latest temp_prerawcpr;
        int temp_delete_flag = 0, temp_num_eve = 1, temp_num_nodes = 1;
 
        // Call CalcReducedNwords
        temp_prerawcpr.SetBuffer(radblk_fmt.GetBuffer(entry_id),
                                 radblk_fmt.GetBlockNwords(entry_id),
                                 temp_delete_flag, temp_num_eve,
                                 temp_num_nodes);
        reduced_nwords += temp_prerawcpr.CalcReducedNwords(0);
      }
    }
  }
  return reduced_nwords;
 
}

◆ CalcReducedNwords()

int CalcReducedNwords ( int n )

calculate reduced data size

Definition at line 536 of file PreRawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported. Exiting...: \n%s %s %d\n",
          __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return -1;
}

◆ CalcXORChecksum()

unsigned int CalcXORChecksum	(	int *	buf,
		int	nwords
	)

virtualinherited

calc XOR checksum

Definition at line 24 of file RawCOPPERFormat.cc.

{
  unsigned int checksum = 0;
  for (int i = 0; i < nwords; i++) {
    checksum = checksum ^ buf[ i ];
  }
  return checksum;
}

◆ CheckB2LHSLBMagicWords()

int CheckB2LHSLBMagicWords	(	int *	finesse_buf,
		int	finesse_nwords
	)

check magic words of B2link HSLB header/trailer

Definition at line 558 of file PreRawCOPPERFormat_latest.cc.

{
 
  if ((finesse_buf[ POS_MAGIC_B2LHSLB ] & 0xFFFF0000) == B2LHSLB_HEADER_MAGIC &&
      ((finesse_buf[ finesse_nwords - SIZE_B2LHSLB_TRAILER + POS_CHKSUM_B2LHSLB ] & 0xFFFF0000)
       == B2LHSLB_TRAILER_MAGIC)) {
    return 1;
  } else {
    PrintData(m_buffer, m_nwords);
    char err_buf[500];
    sprintf(err_buf,
            "Invalid B2LHSLB magic words : header 0x%x (= should be ffaa**** ) or trailer 0x%x (= should be ff55**** ). Exiting... :%s %s %d\n",
            finesse_buf[ POS_MAGIC_B2LHSLB ],
            finesse_buf[ finesse_nwords - SIZE_B2LHSLB_TRAILER + POS_CHKSUM_B2LHSLB ],
            __FILE__, __PRETTY_FUNCTION__, __LINE__);
#ifndef NO_ERROR_STOP
    printf("%s", err_buf); fflush(stdout);
    B2FATAL(err_buf);
#endif
  }
}

◆ CheckCOPPERMagic()

bool CheckCOPPERMagic ( int n )

virtual

Check if COPPER Magic words are correct.

Implements RawCOPPERFormat.

Definition at line 282 of file PreRawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported. Exiting...: \n%s %s %d\n",
          __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return false;
}

◆ CheckCRC16()

int CheckCRC16	(	int	n,
		int	finesse_num
	)

check CRC16 in B2LFEE trailer

Definition at line 582 of file PreRawCOPPERFormat_latest.cc.

{
  //
  // Calculate CRC16
  //
  int* buf = GetFINESSEBuffer(n, finesse_num) +  SIZE_B2LHSLB_HEADER;
  int nwords = GetFINESSENwords(n, finesse_num) - (static_cast<int>(SIZE_B2LHSLB_HEADER) + SIZE_B2LFEE_TRAILER +
                                                   SIZE_B2LHSLB_TRAILER);
  unsigned short temp_crc16 = CalcCRC16LittleEndian(0xffff, buf, nwords);
 
  //
  // Compare CRC16 with B2LCRC16
  //
  buf = GetFINESSEBuffer(n, finesse_num) +  GetFINESSENwords(n, finesse_num)
        - ((SIZE_B2LFEE_TRAILER - POS_CHKSUM_B2LFEE) + SIZE_B2LHSLB_TRAILER) ;
 
  if ((unsigned short)(*buf & 0xFFFF) != temp_crc16) {
    char err_buf[500];
    char hostname[128];
    GetNodeName(n, hostname, sizeof(hostname));
    PrintData(GetBuffer(n), *(GetBuffer(n) + tmp_header.POS_NWORDS));
    printf("[FATAL] %s ch=%d : ERROR_EVENT : PRE CRC16 error : slot %c : B2LCRC16 %x Calculated CRC16 %x : Nwords of FINESSE buf %d\n",
           hostname, finesse_num,
           65 + finesse_num, *buf, temp_crc16, GetFINESSENwords(n, finesse_num));
    int* temp_buf = GetFINESSEBuffer(n, finesse_num);
    for (int k = 0; k <  GetFINESSENwords(n, finesse_num); k++) {
      printf("%.8x ", temp_buf[ k ]);
      if ((k + 1) % 10 == 0) {
        printf("\n");
      }
    }
    printf("\n");
    fflush(stdout);
    sprintf(err_buf,
            "[FATAL] %s ch=%d : ERROR_EVENT : slot %c : B2LCRC16 (%.4x) differs from one ( %.4x) calculated by PreRawCOPPERfromat class. Exiting...\n %s %s %d\n",
            hostname, finesse_num,
            65 + finesse_num, (unsigned short)(*buf & 0xFFFF), temp_crc16,
            __FILE__, __PRETTY_FUNCTION__, __LINE__);
    printf("%s", err_buf); fflush(stdout);
    B2FATAL(err_buf); // to reduce multiple error messages
  }
  return 1;
 
}

◆ CheckData()

void CheckData	(	int	n,
		unsigned int	prev_evenum,
		unsigned int *	cur_evenum,
		unsigned int	prev_copper_ctr,
		unsigned int *	cur_copper_ctr,
		unsigned int	prev_exprunsubrun_no,
		unsigned int *	cur_exprunsubrun_no
	)

virtual

check data contents

Implements RawCOPPERFormat.

Definition at line 124 of file PreRawCOPPERFormat_latest.cc.

{
 
  char err_buf[3000];
  int err_flag = 0;
 
  //
  // Event # check
  //
  *cur_evenum_rawcprhdr = GetEveNo(n);
  unsigned int evenum_feehdr = GetB2LFEE32bitEventNumber(n);
  if (*cur_evenum_rawcprhdr != evenum_feehdr) {
    char hostname[128];
    GetNodeName(n, hostname, sizeof(hostname));
    sprintf(err_buf,
            "[FATAL] %s ch=%d : ERROR_EVENT : Event # in PreRawCOPPERFormat_latest header and FEE header is different : cprhdr 0x%x feehdr 0x%x : Exiting... : eve 0x%x exp %d run %d sub %d\n%s %s %d\n",
            hostname, -1,
            *cur_evenum_rawcprhdr, evenum_feehdr,
            GetEveNo(n), GetExpNo(n), GetRunNo(n), GetSubRunNo(n),
            __FILE__, __PRETTY_FUNCTION__, __LINE__);
    err_flag = 1;
  }
 
  //
  // Check incrementation of event #
  //
  *cur_exprunsubrun_no = GetExpRunSubrun(n);
  *cur_copper_ctr = GetCOPPERCounter(n);
  if (prev_exprunsubrun_no == *cur_exprunsubrun_no) {
    if ((unsigned int)(prev_evenum + 1) != *cur_evenum_rawcprhdr) {
      char hostname[128];
      GetNodeName(n, hostname, sizeof(hostname));
      sprintf(err_buf,
              "[FATAL] %s ch=%d : ERROR_EVENT : Event # jump : i %d prev 0x%x cur 0x%x : prevrun %.8x currun %.8x: Exiting... : eve 0x%x exp %d run %d sub %d\n%s %s %d\n",
              hostname, -1,
              n, prev_evenum, *cur_evenum_rawcprhdr, prev_exprunsubrun_no, *cur_exprunsubrun_no,
              GetEveNo(n), GetExpNo(n), GetRunNo(n), GetSubRunNo(n),
              __FILE__, __PRETTY_FUNCTION__, __LINE__);
      err_flag = 1;
    }
    if ((unsigned int)(prev_copper_ctr + 1) != *cur_copper_ctr) {
      char hostname[128];
      GetNodeName(n, hostname, sizeof(hostname));
      sprintf(err_buf,
              "[FATAL] %s ch=%d : ERROR_EVENT : COPPER counter jump : i %d prev 0x%x cur 0x%x : eve 0x%x exp %d run %d sub %d\n%s %s %d\n",
              hostname, -1,
              n, prev_copper_ctr, *cur_copper_ctr,
              GetEveNo(n), GetExpNo(n), GetRunNo(n), GetSubRunNo(n),
              __FILE__, __PRETTY_FUNCTION__, __LINE__);
      err_flag = 1;
    }
  } else {
    printf("[DEBUG] New run started. cur run %.8x prev. run %.8x cur eve %.8x prev eve %8.x : eve 0x%x exp %d run %d sub %d\n",
           *cur_exprunsubrun_no, prev_exprunsubrun_no, *cur_evenum_rawcprhdr, prev_evenum,
           GetEveNo(n), GetExpNo(n), GetRunNo(n), GetSubRunNo(n));
 
    // Check if the first event of a run is zero.
    if ((unsigned int)GetRunNo(n) != (prev_exprunsubrun_no & RawHeader_latest::RUNNO_MASK) >> RawHeader_latest::RUNNO_SHIFT) {
      if (*cur_evenum_rawcprhdr != 0) {
 
        unsigned int eve[MAX_PCIE40_CH];
        for (int i = 0; i < MAX_PCIE40_CH ; ++i) {
          eve[ i ] = 0xbaadf00d;
          if (GetFINESSENwords(n, i) > 0) {
            int pos_nwords = GetOffsetFINESSE(n, i) + SIZE_B2LHSLB_HEADER + POS_TT_TAG;
            eve[ i ] = m_buffer[ pos_nwords ];
          }
        }
 
        vector<vector<unsigned int>> summary_table;
        CompareHeaderValue(n, eve, summary_table);
        char hostname[128];
        GetNodeName(n, hostname, sizeof(hostname));
        sprintf(err_buf,
                "[FATAL] %s ch=%d : ERROR_EVENT : Invalid Event # at the beginning of the run (It should be zero.): preveve 0x%x cureve 0x%x : prev(exp %u run %u sub %u ) cur(exp %u run %u sub %u ) (",
                hostname, -1,
                prev_evenum, *cur_evenum_rawcprhdr,
                prev_exprunsubrun_no >> 22, (prev_exprunsubrun_no >> 8) & 0x3FFF, prev_exprunsubrun_no & 0xFF,
                *cur_exprunsubrun_no >> 22, (*cur_exprunsubrun_no >> 8) & 0x3FFF, *cur_exprunsubrun_no & 0xFF);
 
        char err_buf_temp[2500];
        for (unsigned i = 0; i < summary_table.size(); ++i) {
          memcpy(err_buf_temp, err_buf, sizeof(err_buf_temp));
          sprintf(err_buf, "%s [ch= %u ,val= %u (# of chs= %u )] ",
                  err_buf_temp,
                  summary_table.at(i).at(0), summary_table.at(i).at(2), summary_table.at(i).at(1));
        }
        memcpy(err_buf_temp, err_buf, sizeof(err_buf_temp));
        sprintf(err_buf, "%s Exiting... : eve 0x%x exp %d run %d sub %d\n%s %s %d\n",
                err_buf_temp,
                GetEveNo(n), GetExpNo(n), GetRunNo(n), GetSubRunNo(n),
                __FILE__, __PRETTY_FUNCTION__, __LINE__);
        err_flag = 1;
      }
    }
  }
 
 
 
  //
  // Check is utime and ctime_trgtype same over different FINESSE data
  //
  CheckUtimeCtimeTRGType(n);
 
  //
  // Check checksum calculated by COPPER driver
  //
  if (GetDriverChkSum(n) != CalcDriverChkSum(n)) {
    char hostname[128];
    GetNodeName(n, hostname, sizeof(hostname));
    sprintf(err_buf,
            "[FATAL] %s ch=%d : ERROR_EVENT : COPPER driver checkSum error : block %d : length %d eve 0x%x : Trailer chksum 0x%.8x : calcd. now 0x%.8x : eve 0x%x exp %d run %d sub %d\n%s %s %d\n",
            hostname, -1,
            n, GetBlockNwords(n), *cur_evenum_rawcprhdr, GetDriverChkSum(n), CalcDriverChkSum(n),
            GetEveNo(n), GetExpNo(n), GetRunNo(n), GetSubRunNo(n),
            __FILE__, __PRETTY_FUNCTION__, __LINE__);
    err_flag = 1;
  }
 
  //
  // Check checksum calculated by DeSerializerCOPPER()
  //
  tmp_trailer.SetBuffer(GetRawTrlBufPtr(n));
  unsigned int xor_chksum = CalcXORChecksum(GetBuffer(n), GetBlockNwords(n) - tmp_trailer.GetTrlNwords());
  if (tmp_trailer.GetChksum() != xor_chksum) {
    char hostname[128];
    GetNodeName(n, hostname, sizeof(hostname));
    sprintf(err_buf,
            "[FATAL] %s ch=%d : ERROR_EVENT : PreRawCOPPERFormat_latest checksum error : block %d : length %d eve 0x%x : Trailer chksum 0x%.8x : calcd. now 0x%.8x : eve 0x%x exp %d run %d sub %d\n %s %s %d\n",
            hostname, -1,
            n, GetBlockNwords(n), *cur_evenum_rawcprhdr, tmp_trailer.GetChksum(), xor_chksum,
            GetEveNo(n), GetExpNo(n), GetRunNo(n), GetSubRunNo(n),
            __FILE__, __PRETTY_FUNCTION__, __LINE__);
    err_flag = 1;
  }
 
  if (err_flag == 1) {
    printf("%s", err_buf); fflush(stdout);
    printf("[DEBUG] ========== dump a data blcok : block # %d==========\n", n);
    PrintData(GetBuffer(n), GetBlockNwords(n));
    for (int i = 0; i < MAX_PCIE40_CH; i++) {
      printf("[DEBUG] ========== CRC check : block # %d finesse %d ==========\n", n, i);
      if (GetFINESSENwords(n, i) > 0) {
        CheckCRC16(n, i);
      }
    }
    printf("[DEBUG] ========== No CRC error : block %d =========\n", n);
    //    string err_str = err_buf;    throw (err_str);
    B2FATAL(err_buf); // to reduce multiple error messages
  }
 
  return;
 
}

◆ CheckFTSWID()

int CheckFTSWID ( int n )

virtualinherited

get FTSW ID to check whether this data block is FTSW data or not

Definition at line 73 of file RawDataBlockFormat.cc.

{
  int pos = POS_NODE_ID;
  if (m_buffer[ GetBufferPos(n) + TEMP_POS_NWORDS_HEADER ] == OLD_FTSW_NWORDS_HEADER) {
    pos =  POS_FTSW_ID_OLD;
  }
 
  if ((m_buffer[ GetBufferPos(n) + pos ] & 0xffffff00) == 0x54544400) {     // "TTD" + format version ( 0x20=DESY, 0x31=2018/7/11)
    return 1;
  } else {
    return 0;
  }
}

◆ CheckTLUID()

int CheckTLUID ( int n )

virtualinherited

get FTSW ID to check whether this data block is FTSW data or not

Definition at line 88 of file RawDataBlockFormat.cc.

{
  int pos = POS_NODE_ID;
  if (m_buffer[ GetBufferPos(n) + TEMP_POS_NWORDS_HEADER ] == OLD_FTSW_NWORDS_HEADER) {
    pos =  POS_FTSW_ID_OLD;
  }
  if (m_buffer[ GetBufferPos(n) + pos ] == 0x544c5520) { // "TLU "
    return 1;
  } else {
    return 0;
  }
}

◆ CheckUtimeCtimeTRGType()

void CheckUtimeCtimeTRGType ( int n )

virtual

check data contents

Implements RawCOPPERFormat.

Definition at line 292 of file PreRawCOPPERFormat_latest.cc.

{
 
#ifdef USE_B2LFEE_FORMAT_BOTH_VER1_AND_2
  CheckB2LFEEHeaderVersion(n);
#endif
  int err_flag = 0;
  int flag = 0;
  unsigned int temp_utime = 0, temp_ctime_trgtype = 0, temp_eve = 0, temp_exprun = 0;
  unsigned int temp_ctime_trgtype_footer, temp_eve_footer;
  unsigned int utime[MAX_PCIE40_CH], ctime_trgtype[MAX_PCIE40_CH], eve[MAX_PCIE40_CH], exprun[MAX_PCIE40_CH];
  char err_buf[4000];
 
  memset(utime, 0, sizeof(utime));
  memset(ctime_trgtype, 0, sizeof(ctime_trgtype));
  memset(eve, 0, sizeof(eve));
  memset(exprun, 0, sizeof(exprun));
 
  int first_ch = 0;
  for (int i = 0; i < MAX_PCIE40_CH; i++) {
    int finesse_nwords = GetFINESSENwords(n, i);
    if (finesse_nwords > 0) {
      int offset_finesse = GetOffsetFINESSE(n, i);
      ctime_trgtype[ i ] = m_buffer[ offset_finesse + SIZE_B2LHSLB_HEADER + POS_TT_CTIME_TYPE ];
      utime[ i ] = m_buffer[ offset_finesse + SIZE_B2LHSLB_HEADER + POS_TT_UTIME ];
      eve[ i ] = m_buffer[ offset_finesse + SIZE_B2LHSLB_HEADER + POS_TT_TAG ];
      exprun[ i ] = m_buffer[ offset_finesse + SIZE_B2LHSLB_HEADER + POS_EXP_RUN ];
      temp_ctime_trgtype_footer =
        m_buffer[ offset_finesse + finesse_nwords - (static_cast<int>(SIZE_B2LFEE_TRAILER) + SIZE_B2LHSLB_TRAILER) + POS_TT_CTIME_B2LFEE ];
      temp_eve_footer =
        m_buffer[ offset_finesse + finesse_nwords - (static_cast<int>(SIZE_B2LFEE_TRAILER) + SIZE_B2LHSLB_TRAILER) + POS_CHKSUM_B2LFEE ];
 
      if (flag == 0) {
        temp_ctime_trgtype = ctime_trgtype[ i ];
        temp_utime = utime[ i ];
        temp_eve = eve[ i ];
        temp_exprun = exprun[ i ];
        flag = 1;
        first_ch = i;
      } else {
        if (temp_ctime_trgtype != ctime_trgtype[ i ] || temp_utime != utime[ i ] ||
            temp_eve != eve[ i ] || temp_exprun != exprun[ i ]) {
          char hostname[128];
          GetNodeName(n, hostname, sizeof(hostname));
          if (err_flag == 0) {
            for (int j = 0; j < MAX_PCIE40_CH; j++) {
              if (GetFINESSENwords(n, j) > 0) {
                printf("[DEBUG] %s ch=%d : FINESSE #=%d buffsize %d ctimeTRGtype 0x%.8x utime 0x%.8x eve 0x%.8x exprun 0x%.8x\n",
                       hostname, -1,
                       j, GetFINESSENwords(n, j), ctime_trgtype[ j ], utime[ j ], eve[ j ], exprun[ j ]);
              }
            }
          }
 
          char err_buf_1[2500], err_buf_2[3000], err_buf_3[3500];
          sprintf(err_buf_1,
                  "[FATAL] %s ch=%d : ERROR_EVENT : mismatch header value over FINESSEs. Exiting...",
                  hostname, -1);
          sprintf(err_buf_2,
                  "%s FINESSE #=%d buffsize %d ctimeTRGtype 0x%.8x utime 0x%.8x eve 0x%.8x exprun 0x%.8x",
                  err_buf_1,
                  first_ch, GetFINESSENwords(n, first_ch), ctime_trgtype[ first_ch ], utime[ first_ch ], eve[ first_ch ], exprun[ first_ch ]);
          sprintf(err_buf_3,
                  "%s FINESSE #=%d buffsize %d ctimeTRGtype 0x%.8x utime 0x%.8x eve 0x%.8x exprun 0x%.8x",
                  err_buf_2,
                  i, GetFINESSENwords(n, i), ctime_trgtype[ i ], utime[ i ], eve[ i ], exprun[ i ]);
          sprintf(err_buf, "%s\n %s %s %d\n",
                  err_buf_3,
                  __FILE__, __PRETTY_FUNCTION__, __LINE__);
          printf("%s", err_buf); fflush(stdout);
 
          err_flag = 1;
          break;
        } else if (temp_ctime_trgtype != temp_ctime_trgtype_footer ||
                   (temp_eve & 0xffff) != ((temp_eve_footer >> 16) & 0xffff)) {
          char hostname[128];
          GetNodeName(n, hostname, sizeof(hostname));
          sprintf(err_buf,
                  "[FATAL] %s ch=%d : ERROR_EVENT : mismatch(finesse %d) between header(ctime %.8x eve %.8x) and footer(ctime %.8x eve_crc16 %.8x). Exiting...\n %s %s %d\n",
                  hostname, i,
                  i,  temp_ctime_trgtype,  temp_eve, temp_ctime_trgtype_footer, temp_eve_footer,
                  __FILE__, __PRETTY_FUNCTION__, __LINE__);
          printf("%s", err_buf); fflush(stdout);
          err_flag = 1;
        }
      }
    }
  }
 
  if (err_flag != 0) {
    for (int i = 0; i < MAX_PCIE40_CH; i++) {
      if (GetFINESSENwords(n, i) > 0) {
        printf("[DEBUG] ========== CRC check : block # %d finesse %d ==========\n", n, i);
        CheckCRC16(n, i);
        printf("[DEBUG] ========== CRC check is done. : block %d =========\n", n);
      }
    }
#ifndef NO_ERROR_STOP
    //    string err_str = err_buf; throw (err_str);
    B2FATAL(err_buf); // to reduce multiple error messages
#endif
  }
  return;
}

◆ CompareHeaderValue()

void CompareHeaderValue	(	int	n,
		const unsigned int(&)	input_val[MAX_PCIE40_CH],
		std::vector< std::vector< unsigned int > > &	summary_table
	)

virtualinherited

Check header value of all channels.

Reimplemented from RawCOPPERFormat.

Definition at line 256 of file RawCOPPERFormat_latest.cc.

{
 
  //
  // Format of summary_table
  //  <The 1st channel of a value> <# of channels of the value> <the value>
  //
  std::vector<std::vector<unsigned int>> temp;
  for (int i = 0; i < MAX_PCIE40_CH; i++) {
    if (GetFINESSENwords(n, i) > 0) {
 
      int same_flag = 0;
      for (unsigned j = 0; j < summary_table.size(); ++j) {
        if (input_val[i] == summary_table.at(j).at(2)) {
          summary_table.at(j).at(1)++;
          same_flag = 1;
          break;
        }
      }
      if (same_flag == 0) {
        summary_table.push_back({ static_cast<unsigned int>(i), 1, input_val[i] });
      }
    }
  }
  sort(summary_table.begin(), summary_table.end(), [](const std::vector<unsigned int>& alpha,
  const std::vector<unsigned int>& beta) {return alpha.at(1) < beta.at(1);});
  return;
}

◆ CopyBlock()

void CopyBlock	(	int	n,
		int *	buf_to
	)

virtualinherited

Copy one datablock to buffer.

Definition at line 173 of file RawDataBlockFormat.cc.

{
  memcpy(buf_to, GetBuffer(n), GetBlockNwords(n) * sizeof(int));
  return;
}

◆ CopyReducedBuffer()

int CopyReducedBuffer	(	int	n,
		int *	buf_to
	)

copy data to reduced buffer

Definition at line 547 of file PreRawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported. Exiting...: \n%s %s %d\n",
          __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return -1;
}

◆ CopyReducedData()

void CopyReducedData	(	int *	bufin,
		int	nwords,
		int	num_events,
		int	num_nodes,
		int *	buf_to,
		int *	nwords_to
	)

reduce and merge header/trailer

Definition at line 500 of file PreRawCOPPERFormat_latest.cc.

{
  //
  // Make a reduced buffer a total RawDataBlock (containing multiple data blocks)
  //
  RawDataBlockFormat radblk_fmt;
  int delete_flag = 0;
  radblk_fmt.SetBuffer(bufin, nwords, delete_flag, num_events, num_nodes);
 
  int pos_nwords_to = 0;
  for (int k = 0; k < radblk_fmt.GetNumEvents(); k++) {
    int num_nodes_in_sendblock = radblk_fmt.GetNumNodes();
    for (int l = 0; l < num_nodes_in_sendblock; l++) {
      int entry_id = l + k * num_nodes_in_sendblock;
      if (radblk_fmt.CheckFTSWID(entry_id) ||
          radblk_fmt.CheckTLUID(entry_id)) {
        radblk_fmt.CopyBlock(entry_id, buf_to + pos_nwords_to);
        pos_nwords_to += radblk_fmt.GetBlockNwords(entry_id);
 
      } else {
        SetBuffer(radblk_fmt.GetBuffer(entry_id),
                  radblk_fmt.GetBlockNwords(entry_id), 0, 1, 1);
 
        pos_nwords_to += CopyReducedBuffer(0, buf_to + pos_nwords_to);
 
 
      }
    }
  }
 
  *nwords_to = pos_nwords_to;
 
  return ;
}

◆ FillTopBlockRawHeader()

unsigned int FillTopBlockRawHeader	(	unsigned int	m_node_id,
		unsigned int	prev_eve32,
		unsigned int	prev_exprunsubrun_no,
		unsigned int *	cur_exprunsubrun_no
	)

virtual

should be called by DeSerializerCOPPER.cc and fill contents in RawHeader

Implements RawCOPPERFormat.

Definition at line 397 of file PreRawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported. Exiting...: \n%s %s %d\n",
          __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return 0;
}

◆ Get1stDetectorBuffer()

int * Get1stDetectorBuffer ( int n )

virtualinherited

get Detector buffer of slot A

Implements RawCOPPERFormat.

Definition at line 174 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return NULL;
}

◆ Get1stDetectorNwords()

int Get1stDetectorNwords ( int n )

virtualinherited

get Detector buffer length of slot A

Implements RawCOPPERFormat.

Definition at line 92 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return 0;
}

◆ Get1stFINESSENwords()

int Get1stFINESSENwords ( int n )

virtualinherited

get data size of FINESSE slot A buffer

Implements RawCOPPERFormat.

Definition at line 133 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return 0;
}

◆ Get2ndDetectorBuffer()

int * Get2ndDetectorBuffer ( int n )

virtualinherited

get Detector Buffer of slot B

Implements RawCOPPERFormat.

Definition at line 184 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return NULL;
}

◆ Get2ndDetectorNwords()

int Get2ndDetectorNwords ( int n )

virtualinherited

get Detector buffer length of slot B

Implements RawCOPPERFormat.

Definition at line 102 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return 0;
}

◆ Get2ndFINESSENwords()

int Get2ndFINESSENwords ( int n )

virtualinherited

get data size of FINESSE slot B buffer

Implements RawCOPPERFormat.

Definition at line 143 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return 0;
}

◆ Get3rdDetectorBuffer()

int * Get3rdDetectorBuffer ( int n )

virtualinherited

get Detector Buffer of slot C

Implements RawCOPPERFormat.

Definition at line 194 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return NULL;
}

◆ Get3rdDetectorNwords()

int Get3rdDetectorNwords ( int n )

virtualinherited

get Detector buffer length of slot C

Implements RawCOPPERFormat.

Definition at line 112 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return 0;
}

◆ Get3rdFINESSENwords()

int Get3rdFINESSENwords ( int n )

virtualinherited

get data size of FINESSE slot C buffer

Implements RawCOPPERFormat.

Definition at line 153 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return 0;
}

◆ Get4thDetectorBuffer()

int * Get4thDetectorBuffer ( int n )

virtualinherited

get Detector Buffer of slot D

Implements RawCOPPERFormat.

Definition at line 204 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return NULL;
}

◆ Get4thDetectorNwords()

int Get4thDetectorNwords ( int n )

virtualinherited

get Detector buffer length of slot D

Implements RawCOPPERFormat.

Definition at line 122 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return 0;
}

◆ Get4thFINESSENwords()

int Get4thFINESSENwords ( int n )

virtualinherited

get data size of FINESSE slot D buffer

Implements RawCOPPERFormat.

Definition at line 163 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return 0;
}

◆ GetB2LFEE32bitEventNumber()

unsigned int GetB2LFEE32bitEventNumber ( int n )

virtual

get b2l block from "FEE b2link header"

Implements RawCOPPERFormat.

Definition at line 40 of file PreRawCOPPERFormat_latest.cc.

{
 
#ifndef READ_OLD_B2LFEE_FORMAT_FILE
 
  int err_flag = 0;
  unsigned int eve_num = 0;
  int flag = 0;
  unsigned int eve[MAX_PCIE40_CH];
  for (int i = 0; i < MAX_PCIE40_CH; i++) {
    eve[ i ] = 0xbaadf00d;
    if (GetFINESSENwords(n, i) > 0) {
      int pos_nwords = GetOffsetFINESSE(n, i) + SIZE_B2LHSLB_HEADER + POS_TT_TAG;
      eve[ i ] = m_buffer[ pos_nwords ];
      if (flag != 1) eve_num = eve[ i ];
      if (eve_num != eve[ i ]) err_flag = 1;
      flag = 1;
    }
  }
 
  if (flag == 0) {
    PrintData(m_buffer, m_nwords);
    char err_buf[500];
    char hostname[128];
    GetNodeName(n, hostname, sizeof(hostname));
    sprintf(err_buf,
            "[FATAL] %s ch=%d : ERROR_EVENT : No HSLB data in COPPER data. Exiting... : eve 0x%x exp %d run %d sub %d\n %s %s %d\n",
            hostname, -1,
            GetEveNo(n), GetExpNo(n), GetRunNo(n), GetSubRunNo(n),
            __FILE__, __PRETTY_FUNCTION__, __LINE__);
    printf("%s", err_buf); fflush(stdout);
    //    string err_str = err_buf; throw (err_str);
    B2FATAL(err_buf); // to reduce multiple error messages
  }
 
  if (err_flag == 1) {
    vector<vector<unsigned int>> summary_table;
    CompareHeaderValue(n, eve, summary_table);
 
    char err_buf[3000];
    char err_buf_temp[2500];
    char hostname[128];
    GetNodeName(n, hostname, sizeof(hostname));
    sprintf(err_buf, "[FATAL] %s ch=%d : ERROR_EVENT : CORRUPTED DATA: Different event number over HSLBs :", hostname, -1);
    for (unsigned i = 0; i < summary_table.size(); ++i) {
      memcpy(err_buf_temp, err_buf, sizeof(err_buf_temp));
      sprintf(err_buf, "%s [ch= %u ,val= %u (# of chs= %u )] ",
              err_buf_temp,
              summary_table.at(i).at(0), summary_table.at(i).at(2), summary_table.at(i).at(1));
    }
    memcpy(err_buf_temp, err_buf, sizeof(err_buf_temp));
    sprintf(err_buf, "%s : eve 0x%x exp %d run %d sub %d\n%s %s %d\n",
            err_buf_temp,
            GetEveNo(n), GetExpNo(n), GetRunNo(n), GetSubRunNo(n),
            __FILE__, __PRETTY_FUNCTION__, __LINE__);
 
    printf("[DEBUG] %s\n", err_buf);
    PrintData(m_buffer, m_nwords);
    for (int i = 0; i < MAX_PCIE40_CH; ++i) {
      printf("[DEBUG] ========== CRC check : block # %d finesse %d ==========\n", n, i);
      if (GetFINESSENwords(n, i) > 0) {
        CheckCRC16(n, i);
      }
    }
    printf("[DEBUG] ========== No CRC error. : block %d =========\n", n);
#ifndef NO_ERROR_STOP
    //    string err_str = err_buf; throw (err_str);
    B2FATAL(err_buf); // to reduce multiple error messages
#endif //NO_ERROR_STOP
  }
  return eve_num;
 
#else // READ_OLD_B2LFEE_FORMAT_FILE
 
  char err_buf[500];
  sprintf(err_buf, "[FATAL] You need comment out READ_OLD_B2LFEE_FORMAT_FILE if you are handling a new data format\n%s %s %d\n",
          __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("%s", err_buf); fflush(stdout);
  B2FATAL(err_buf); // to reduce multiple error messages
#endif // READ_OLD_B2LFEE_FORMAT_FILE
 
}

◆ GetBlockNwords()

int GetBlockNwords ( int n )

virtualinherited

get size of a data block

Definition at line 107 of file RawDataBlockFormat.cc.

{
  int size;
  if (n == (m_num_events * m_num_nodes) - 1) {
    size =  m_nwords - GetBufferPos(n);
  } else {
    size = GetBufferPos(n + 1) - GetBufferPos(n);
  }
  return size;
}

◆ GetBuffer()

int * GetBuffer ( int n )

virtualinherited

get nth buffer pointer

Definition at line 124 of file RawDataBlockFormat.cc.

{
  int pos_nwords = GetBufferPos(n);
  return &(m_buffer[ pos_nwords ]);
}

◆ GetBufferPos()

int GetBufferPos ( int n )

virtualinherited

get position of data block in word

Definition at line 30 of file RawDataBlockFormat.cc.

{
  if (m_buffer == NULL || m_nwords <= 0) {
    char err_buf[500];
    sprintf(err_buf, "[FATAL] RawPacket buffer(%p) is not available or length(%d) is not set.\n %s %s %d\n",
            m_buffer, m_nwords, __FILE__, __PRETTY_FUNCTION__, __LINE__);
    printf("%s", err_buf); fflush(stdout);
    B2FATAL(err_buf);
  }
 
  if (n >= (m_num_events * m_num_nodes)) {
    char err_buf[500];
    sprintf(err_buf, "[FATAL] Invalid COPPER block No. (%d : max %d ) is specified. Exiting... \n %s %s %d\n",
            n, (m_num_events * m_num_nodes), __FILE__, __PRETTY_FUNCTION__, __LINE__);
    printf("%s", err_buf); fflush(stdout);
    B2FATAL(err_buf);
  }
 
  int pos_nwords = 0;
  for (int i = 1; i <= n ; i++) {
    if (m_buffer[ pos_nwords ] <= 0) {
      char err_buf[500];
      sprintf(err_buf,
              "[FATAL] ERROR_EVENT : length of this data block is strange ( %d words ). Maybe data is corrupted or RawHeader info has not been filled yet. Exiting...",
              m_buffer[ pos_nwords ]);
      printf("%s", err_buf);
      B2FATAL(err_buf);
    } else {
      pos_nwords +=      m_buffer[ pos_nwords ];
    }
    if (pos_nwords >= m_nwords) {
      char err_buf[500];
      sprintf(err_buf, "[FATAL] ERROR_EVENT : value of pos_nwords(%d) is larger than m_nwords(%d). Exiting...\n %s %s %d\n",
              pos_nwords, m_nwords, __FILE__, __PRETTY_FUNCTION__, __LINE__);
      printf("%s", err_buf); fflush(stdout);
      B2FATAL(err_buf); // to reduce multiple error messages
    }
  }
  return pos_nwords;
 
}

◆ GetEventCRC16Value()

int GetEventCRC16Value	(	int	n,
		int	finesse_num
	)

virtualinherited

Get Event CRC16 value.

Reimplemented in PostRawCOPPERFormat_latest, and PostRawCOPPERFormat_v2.

Definition at line 145 of file RawCOPPERFormat.cc.

{
  char err_buf[500];
  sprintf(err_buf,
          "[FATAL] This function is not supported in the version of  RawCOPPER format that you're using. n=%d fin=%d : %s %s %d: Exiting...\n",
          n, finesse_num, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("%s\n", err_buf); fflush(stdout);
  B2FATAL(err_buf);
  return -1;
}

◆ GetNodeName() [1/2]

void GetNodeName	(	char *	node_name,
		unsigned int	node_id,
		int	bufsize
	)

virtualinherited

Get hostname of a node from an argument.

Definition at line 200 of file RawCOPPERFormat.cc.

{
  if (node_name == NULL || node_id == 0 || bufsize < 20) {
    char err_buf[500];
    sprintf(err_buf,
            "[FATAL] Null pointer or strange node_id(%.8x)in an argument of this function. Exiting... : \n%s %s %d\n",
            node_id,
            __FILE__, __PRETTY_FUNCTION__, __LINE__);
    printf("%s", err_buf); fflush(stdout);
    B2FATAL(err_buf); // to reduce multiple error messages
  } else {
    sprintf(node_name, "cpr%u",
            (10 * (node_id >> 28) + (node_id >> 24)) * 1000 +
            (node_id & COPPERID_MASK));
  }
}

◆ GetNodeName() [2/2]

void GetNodeName	(	int	n,
		char *	node_name,
		int	bufsize
	)

virtualinherited

Get hostname of a node from the RawCOPPER header.

Definition at line 182 of file RawCOPPERFormat.cc.

{
  unsigned int node_id = GetNodeID(n);
  if (node_name == NULL || node_id == 0 || bufsize < 20) {
    char err_buf[500];
    sprintf(err_buf,
            "[FATAL] Null pointer or strange node_id(%.8x)in an argument of this function. Exiting... : \n%s %s %d\n",
            node_id,
            __FILE__, __PRETTY_FUNCTION__, __LINE__);
    printf("%s", err_buf); fflush(stdout);
    B2FATAL(err_buf); // to reduce multiple error messages
  } else {
    sprintf(node_name, "cpr%u",
            (10 * (node_id >> 28) + (node_id >> 24)) * 1000 +
            (node_id & COPPERID_MASK));
  }
}

◆ GetNumEntries()

virtual int GetNumEntries ( )

inlinevirtualinherited

get # of data blocks = (# of nodes)*(# of events)

Definition at line 49 of file RawDataBlockFormat.h.

49{ return m_num_events * m_num_nodes; }

◆ GetNumEvents()

virtual int GetNumEvents ( )

inlinevirtualinherited

get # of events in m_buffer

Definition at line 55 of file RawDataBlockFormat.h.

55{ return m_num_events; }

◆ GetNumFINESSEBlock()

int GetNumFINESSEBlock ( int n )

virtualinherited

get # of FINNESEs which contains data

Implements RawCOPPERFormat.

Definition at line 30 of file RawCOPPERFormat_latest.cc.

{
  int cnt = 0;
  for (int i = 0; i < 4; i++) {
    if (GetFINESSENwords(n, i) > 0) {
      cnt++;
    }
  }
  return cnt;
}

◆ GetNumNodes()

virtual int GetNumNodes ( )

inlinevirtualinherited

get # of data sources(e.g. # of COPPER boards) in m_buffer

Definition at line 52 of file RawDataBlockFormat.h.

52{ return m_num_nodes; }

◆ GetOffset1stFINESSE()

int GetOffset1stFINESSE ( int n )

virtualinherited

get # of offset words for FINESSE slot A buffer position

Implements RawCOPPERFormat.

Definition at line 214 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return 0;
}

◆ GetOffset2ndFINESSE()

int GetOffset2ndFINESSE ( int n )

virtualinherited

get # of offset words for FINESSE slot B buffer position

Reimplemented from RawCOPPERFormat.

Definition at line 225 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return 0;
}

◆ GetOffset3rdFINESSE()

int GetOffset3rdFINESSE ( int n )

virtualinherited

get # of offset words for FINESSE slot C buffer position

Reimplemented from RawCOPPERFormat.

Definition at line 236 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return 0;
}

◆ GetOffset4thFINESSE()

int GetOffset4thFINESSE ( int n )

virtualinherited

get # of offset words for FINESSE slot D buffer position

Reimplemented from RawCOPPERFormat.

Definition at line 246 of file RawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported.(block %d) Exiting...: \n%s %s %d\n",
          n, __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return 0;
}

◆ GetOffsetFINESSE()

int GetOffsetFINESSE	(	int	n,
		int	finesse
	)

virtualinherited

get # of offset words

Definition at line 36 of file RawCOPPERFormat.cc.

{
  switch (finesse_num) {
    case 0 :
      return GetOffset1stFINESSE(n);
      break;
    case 1 :
      return GetOffset2ndFINESSE(n);
      break;
    case 2 :
      return GetOffset3rdFINESSE(n);
      break;
    case 3 :
      return GetOffset4thFINESSE(n);
      break;
    default :
      break;
  }
 
  char err_buf[500];
  sprintf(err_buf, "[FATAL] Specifined FINESSE number( = %d ) is invalid. Exiting...\n%s %s %d\n", finesse_num,
          __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("%s", err_buf); fflush(stdout);
  B2FATAL(err_buf);
}

◆ GetPreAllocFlag()

virtual int GetPreAllocFlag ( )

inlinevirtualinherited

get malloc_flag

Definition at line 58 of file RawDataBlockFormat.h.

58{ return m_use_prealloc_buf; }

Belle2::RawDataBlockFormat::m_use_prealloc_buf

int m_use_prealloc_buf

not recorded

Definition: RawDataBlockFormat.h:102

◆ GetWholeBuffer()

int * GetWholeBuffer ( )

virtualinherited

get pointer to buffer(m_buffer)

Definition at line 119 of file RawDataBlockFormat.cc.

{
  return m_buffer;
}

◆ PackDetectorBuf() [1/2]

int * PackDetectorBuf	(	int *	packed_buf_nwords,
		int *const(&)	detector_buf_ch[MAX_PCIE40_CH],
		int const(&)	nwords_ch[MAX_PCIE40_CH],
		RawCOPPERPackerInfo	rawcpr_info
	)

virtual

Pack data (format ver. = -1 -> Select the latest format version)

Reimplemented from RawCOPPERFormat.

Definition at line 643 of file PreRawCOPPERFormat_latest.cc.

{
  int* packed_buf = NULL;
  int poswords_to = 0;
 
  // calculate the event length
  int length_nwords = tmp_header.GetHdrNwords() + SIZE_COPPER_HEADER + SIZE_COPPER_TRAILER + tmp_trailer.GetTrlNwords();
 
  for (int i = 0; i < MAX_PCIE40_CH; i++) {
    if (detector_buf_ch[ i ] == NULL || nwords_ch[ i ] <= 0) continue;    // for an empty FINESSE slot
    length_nwords += nwords_ch[ i ];
    length_nwords += static_cast<int>(SIZE_B2LHSLB_HEADER) + SIZE_B2LFEE_HEADER + SIZE_B2LFEE_TRAILER + SIZE_B2LHSLB_TRAILER;
  }
 
  // allocate buffer
  packed_buf = new int[ length_nwords ];
  memset(packed_buf, 0, sizeof(int) * length_nwords);
 
  //
  // Fill RawHeader
  //
  tmp_header.SetBuffer(packed_buf);
 
  packed_buf[ tmp_header.POS_NWORDS ] = length_nwords; // total length
  packed_buf[ tmp_header.POS_VERSION_HDRNWORDS ] = 0x7f7f8000
                                                   | ((DATA_FORMAT_VERSION << tmp_header.FORMAT_VERSION_SHIFT) & tmp_header.FORMAT_VERSION__MASK)
                                                   | tmp_header.RAWHEADER_NWORDS; // ver.#, header length
  packed_buf[ tmp_header.POS_EXP_RUN_NO ] = (rawcpr_info.exp_num << tmp_header.EXP_SHIFT)
                                            | (rawcpr_info.run_subrun_num & 0x003FFFFF);   // exp. and run #
  packed_buf[ tmp_header.POS_EVE_NO ] = rawcpr_info.eve_num; // eve #
  packed_buf[ tmp_header.POS_TTCTIME_TRGTYPE ] = (rawcpr_info.tt_ctime & 0x7FFFFFF) << 4;   // tt_ctime
  packed_buf[ tmp_header.POS_TTUTIME ] = rawcpr_info.tt_utime; // tt_utime
  packed_buf[ tmp_header.POS_NODE_ID ] = rawcpr_info.node_id; // node ID
 
  // fill the positions of finesse buffers
  int ch = 0;
  packed_buf[ tmp_header.POS_CH_POS_TABLE + ch ] = tmp_header.RAWHEADER_NWORDS;
  for (int i = 1; i < MAX_PCIE40_CH; i++) {
    ch = i;
    if (nwords_ch[ ch - 1 ] == 0) {
      packed_buf[ tmp_header.POS_CH_POS_TABLE + ch ] = packed_buf[ tmp_header.POS_CH_POS_TABLE + (ch - 1) ];
    } else {
      packed_buf[ tmp_header.POS_CH_POS_TABLE + ch ] = packed_buf[ tmp_header.POS_CH_POS_TABLE + (ch - 1) ] +
                                                       nwords_ch[ ch - 1 ] + SIZE_B2LHSLB_HEADER + SIZE_B2LFEE_HEADER  + SIZE_B2LFEE_TRAILER + SIZE_B2LHSLB_TRAILER;
    }
  }
  poswords_to += tmp_header.GetHdrNwords();
 
  // Fill FINESSE buffer
  for (int i = 0; i < MAX_PCIE40_CH; i++) {
    if (detector_buf_ch[ i ] == NULL || nwords_ch[ i ] <= 0) continue;     // for an empty FINESSE slot
 
    // Fill b2link HSLB header
    packed_buf[ poswords_to + POS_MAGIC_B2LHSLB ] = 0xffaa0000 | (0xffff & rawcpr_info.eve_num);
    poswords_to += SIZE_B2LHSLB_HEADER;
    int* crc16_start = &(packed_buf[ poswords_to ]);
 
    // Fill b2link FEE header
    packed_buf[ poswords_to + POS_TT_CTIME_TYPE ] = (rawcpr_info.tt_ctime & 0x7FFFFFF) << 4;
    unsigned int temp_ctime_type = packed_buf[ poswords_to + POS_TT_CTIME_TYPE ];
    packed_buf[ poswords_to + POS_TT_TAG ] = rawcpr_info.eve_num;
    packed_buf[ poswords_to + POS_TT_UTIME ] = rawcpr_info.tt_utime;
    packed_buf[ poswords_to + POS_EXP_RUN ] = (rawcpr_info.exp_num << tmp_header.EXP_SHIFT) | (rawcpr_info.run_subrun_num &
                                              0x003FFFFF);   // exp. and run #
    packed_buf[ poswords_to + POS_B2L_CTIME ] = (rawcpr_info.b2l_ctime & 0x7FFFFFF) << 4;
    poswords_to += SIZE_B2LFEE_HEADER;
 
    // copy the 1st Detector Buffer
    memcpy(packed_buf + poswords_to, detector_buf_ch[ i ], nwords_ch[ i ]*sizeof(int));
    poswords_to += nwords_ch[ i ];
 
    // Fill b2link b2tt-tag trailer
    packed_buf[ poswords_to + POS_TT_CTIME_B2LFEE ] = temp_ctime_type;
 
    // Fill b2link FEE trailer
    unsigned short crc16 = CalcCRC16LittleEndian(0xffff, crc16_start, nwords_ch[ i ] + SIZE_B2LFEE_HEADER);
    packed_buf[ poswords_to + POS_CHKSUM_B2LFEE ] = ((0xffff & rawcpr_info.eve_num) << 16) | (crc16 & 0xffff);
    poswords_to += SIZE_B2LFEE_TRAILER;
 
    // Fill b2link HSLB trailer
    packed_buf[ poswords_to + POS_CHKSUM_B2LHSLB ] = 0xff550000;
    poswords_to += SIZE_B2LHSLB_TRAILER;
  }
 
  // Calculate RawCOPPER checksum and fill RawTrailer
  unsigned int chksum = 0;
  for (int i = 0; i < poswords_to; i++) {
    chksum ^= packed_buf[ i ];
  }
  packed_buf[ poswords_to + tmp_trailer.POS_CHKSUM ] = chksum;
 
  packed_buf[ poswords_to + tmp_trailer.POS_TERM_WORD ] = tmp_trailer.MAGIC_WORD_TERM_TRAILER;
  poswords_to += tmp_trailer.GetTrlNwords();
 
  *packed_buf_nwords = poswords_to;
  return packed_buf;
}

◆ PackDetectorBuf() [2/2]

int * PackDetectorBuf	(	int *	packed_buf_nwords,
		int *	detector_buf_1st,
		int	nwords_1st,
		int *	detector_buf_2nd,
		int	nwords_2nd,
		int *	detector_buf_3rd,
		int	nwords_3rd,
		int *	detector_buf_4th,
		int	nwords_4th,
		RawCOPPERPackerInfo	rawcprpacker_info
	)

virtual

Pack data (format ver. = -1 -> Select the latest format version)

Implements RawCOPPERFormat.

Definition at line 627 of file PreRawCOPPERFormat_latest.cc.

{
  char err_buf[500];
  sprintf(err_buf, "[FATAL] This function is not supported. (%u) Exiting...: \n%s %s %d\n",
          rawcpr_info.eve_num,
          __FILE__, __PRETTY_FUNCTION__, __LINE__);
  printf("[DEBUG] %s\n", err_buf);
  B2FATAL(err_buf);
  return NULL;
}

◆ PrintData()

void PrintData	(	int *	buf,
		int	nwords
	)

virtualinherited

print data

Definition at line 161 of file RawDataBlockFormat.cc.

{
  printf("[DEBUG] ");
  for (int i = 0; i < nwords; i++) {
    printf("%.8x ", buf[ i ]);
    if (i % 10 == 9) printf("\n[DEBUG] ");
  }
  printf("\n[DEBUG] ");
  printf("\n");
  return;
}

◆ SetBuffer()

void SetBuffer	(	int *	bufin,
		int	nwords,
		int	delete_flag,
		int	num_events,
		int	num_nodes
	)

virtualinherited

set buffer ( delete_flag : m_buffer is freeed( = 0 )/ not freeed( = 1 ) in Destructer )

Definition at line 131 of file RawDataBlockFormat.cc.

{
 
  if (bufin == NULL) {
    char err_buf[500];
    sprintf(err_buf, "[DEBUG] bufin is NULL. Exting...\n");
    printf("%s", err_buf); fflush(stdout);
    B2FATAL(err_buf);
  }
 
  if (!m_use_prealloc_buf && m_buffer != NULL) delete[] m_buffer;
 
  if (delete_flag == 0) {
    m_use_prealloc_buf = true;
  } else {
    m_use_prealloc_buf = false;
  }
 
  m_nwords = nwords;
  m_buffer = bufin;
 
  m_num_nodes = num_nodes;
  m_num_events = num_events;
 
  return;
 
}

◆ TotalBufNwords()

int TotalBufNwords ( )

virtualinherited

Get total length of m_buffer.

Definition at line 101 of file RawDataBlockFormat.cc.

{
  return m_nwords;
}

Member Data Documentation

◆ m_buffer

int* m_buffer

protectedinherited

Buffer.

Definition at line 98 of file RawDataBlockFormat.h.

◆ m_num_events

int m_num_events

protectedinherited

number of events in this object

Definition at line 95 of file RawDataBlockFormat.h.

◆ m_num_nodes

int m_num_nodes

protectedinherited

number of nodes in this object

Definition at line 92 of file RawDataBlockFormat.h.

◆ m_nwords

int m_nwords

protectedinherited

number of words of buffer

Definition at line 89 of file RawDataBlockFormat.h.

◆ m_reduced_rawcpr

PostRawCOPPERFormat_latest m_reduced_rawcpr

data fromat after size reduction

Definition at line 223 of file PreRawCOPPERFormat_latest.h.

◆ m_use_prealloc_buf

int m_use_prealloc_buf

protectedinherited

not recorded

flag for deleting m_buffer in destructer( 0:delete, 1: not delete) When using pre-allocated buffer, the buffer should be reused and not deleted in the destructer

Definition at line 102 of file RawDataBlockFormat.h.

◆ tmp_header

RawHeader_latest tmp_header

inherited

header ( not recorded )

Definition at line 260 of file RawCOPPERFormat_latest.h.

◆ tmp_trailer

RawTrailer_latest tmp_trailer

inherited

trailer ( not recorded )

Definition at line 263 of file RawCOPPERFormat_latest.h.

The documentation for this class was generated from the following files:

rawdata/dataobjects/include/PreRawCOPPERFormat_latest.h
rawdata/dataobjects/src/PreRawCOPPERFormat_latest.cc

Public Types

Public Member Functions

Public Attributes

Protected Attributes

Detailed Description

Member Enumeration Documentation

◆ anonymous enum

◆ anonymous enum

◆ anonymous enum

◆ anonymous enum

◆ anonymous enum

◆ anonymous enum

◆ anonymous enum

◆ anonymous enum

◆ anonymous enum

◆ anonymous enum

◆ anonymous enum

◆ anonymous enum

Constructor & Destructor Documentation

◆ PreRawCOPPERFormat_latest()

◆ ~PreRawCOPPERFormat_latest()

Member Function Documentation

◆ CalcDriverChkSum()

◆ CalcReducedDataSize()

◆ CalcReducedNwords()

◆ CalcXORChecksum()

◆ CheckB2LHSLBMagicWords()

◆ CheckCOPPERMagic()

◆ CheckCRC16()

◆ CheckData()

◆ CheckFTSWID()

◆ CheckTLUID()

◆ CheckUtimeCtimeTRGType()

◆ CompareHeaderValue()

◆ CopyBlock()

◆ CopyReducedBuffer()

◆ CopyReducedData()

◆ FillTopBlockRawHeader()

◆ Get1stDetectorBuffer()

◆ Get1stDetectorNwords()

◆ Get1stFINESSENwords()

◆ Get2ndDetectorBuffer()

◆ Get2ndDetectorNwords()

◆ Get2ndFINESSENwords()

◆ Get3rdDetectorBuffer()

◆ Get3rdDetectorNwords()

◆ Get3rdFINESSENwords()

◆ Get4thDetectorBuffer()

◆ Get4thDetectorNwords()

◆ Get4thFINESSENwords()

◆ GetB2LFEE32bitEventNumber()

◆ GetBlockNwords()

◆ GetBuffer()

◆ GetBufferPos()

◆ GetEventCRC16Value()

◆ GetNodeName() [1/2]

◆ GetNodeName() [2/2]

◆ GetNumEntries()

◆ GetNumEvents()

◆ GetNumFINESSEBlock()

◆ GetNumNodes()

◆ GetOffset1stFINESSE()

◆ GetOffset2ndFINESSE()

◆ GetOffset3rdFINESSE()

◆ GetOffset4thFINESSE()

◆ GetOffsetFINESSE()

◆ GetPreAllocFlag()

◆ GetWholeBuffer()

◆ PackDetectorBuf() [1/2]

◆ PackDetectorBuf() [2/2]

◆ PrintData()

◆ SetBuffer()

◆ TotalBufNwords()

Member Data Documentation

◆ m_buffer

◆ m_num_events

◆ m_num_nodes

◆ m_nwords

◆ m_reduced_rawcpr

◆ m_use_prealloc_buf