#include <FelixFragment.hh>

Inheritance diagram for dune::FelixFragmentCompressed:

Public Member Functions
	FelixFragmentCompressed (const artdaq::Fragment &fragment)

	~FelixFragmentCompressed ()

uint8_t	sof (const unsigned &frame_ID=0) const

uint8_t	version (const unsigned &frame_ID=0) const

uint8_t	fiber_no (const unsigned &frame_ID=0) const

uint8_t	slot_no (const unsigned &frame_ID=0) const

uint8_t	crate_no (const unsigned &frame_ID=0) const

uint8_t	mm (const unsigned &frame_ID=0) const

uint8_t	oos (const unsigned &frame_ID=0) const

uint16_t	wib_errors (const unsigned &frame_ID=0) const

uint64_t	timestamp (const unsigned &frame_ID=0) const

uint16_t	wib_counter (const unsigned &frame_ID=0) const

uint8_t	s1_error (const unsigned &frame_ID, const uint8_t &block_num) const

uint8_t	s2_error (const unsigned &frame_ID, const uint8_t &block_num) const

uint16_t	checksum_a (const unsigned &frame_ID, const uint8_t &block_num) const

uint16_t	checksum_b (const unsigned &frame_ID, const uint8_t &block_num) const

uint16_t	coldata_convert_count (const unsigned &frame_ID, const uint8_t &block_num) const

uint16_t	error_register (const unsigned &frame_ID, const uint8_t &block_num) const

uint8_t	hdr (const unsigned &frame_ID, const uint8_t &block_num, const uint8_t &hdr_num) const

adc_t	get_ADC (const unsigned &frame_ID, const uint8_t channel_ID) const

void	print_timestamps () const

void	print (const unsigned i) const

void	print_frames () const

size_t	total_words () const

size_t	total_frames () const

size_t	total_adc_values () const

const artdaq::Fragment	uncompressed_fragment () const

Public Member Functions inherited from dune::FelixFragmentBase
	FelixFragmentBase (const artdaq::Fragment &fragment)

virtual	~FelixFragmentBase ()

virtual size_t	adc_range (int daq_adc_bits=12)

const uint8_t *	dataBeginBytes () const

size_t	dataSizeBytes () const

Protected Attributes
artdaq::Fragment	uncompfrag_

const FelixFragmentBase *	flxfrag

Protected Attributes inherited from dune::FelixFragmentBase
Metadata	meta_

const void *	artdaq_Fragment_

size_t	sizeBytes_

Private Member Functions
int	decompress_copy (const artdaq::Fragment &src, artdaq::Fragment &dst)

int	internal_inflate (const void src, uint srcLen, void dst, uint dstLen)

Detailed Description

Definition at line 498 of file FelixFragment.hh.

Constructor & Destructor Documentation

dune::FelixFragmentCompressed::FelixFragmentCompressed ( const artdaq::Fragment & fragment )

inline

Definition at line 573 of file FelixFragment.hh.

       : FelixFragmentBase(fragment) {
     // Decompress.
     decompress_copy(fragment, uncompfrag_);
     // std::cout << decompress_copy(fragment, uncompfrag_) << " returned from
     // decompress_copy\n";
 
     // Update metadata.
     meta_.compressed = 0;
     uncompfrag_.setMetadata(meta_);
     if (meta_.reordered) {
       flxfrag = new FelixFragmentReordered(uncompfrag_);
     } else {
       flxfrag = new FelixFragmentUnordered(uncompfrag_);
     }
   }

dune::FelixFragmentCompressed::~FelixFragmentCompressed ( )

inline

Definition at line 590 of file FelixFragment.hh.

590 { delete flxfrag; }

dune::FelixFragmentCompressed::flxfrag

const FelixFragmentBase * flxfrag

Definition: FelixFragment.hh:678

Member Function Documentation

uint16_t dune::FelixFragmentCompressed::checksum_a	(	const unsigned &	frame_ID,
		const uint8_t &	block_num
	)		const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 631 of file FelixFragment.hh.

                                                       {
     return flxfrag->checksum_a(frame_ID, block_num);
   }

uint16_t dune::FelixFragmentCompressed::checksum_b	(	const unsigned &	frame_ID,
		const uint8_t &	block_num
	)		const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 635 of file FelixFragment.hh.

                                                       {
     return flxfrag->checksum_b(frame_ID, block_num);
   }

uint16_t dune::FelixFragmentCompressed::coldata_convert_count	(	const unsigned &	frame_ID,
		const uint8_t &	block_num
	)		const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 639 of file FelixFragment.hh.

                                                                  {
     return flxfrag->coldata_convert_count(frame_ID, block_num);
   }

uint8_t dune::FelixFragmentCompressed::crate_no ( const unsigned & frame_ID = 0 ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 605 of file FelixFragment.hh.

                                                        {
     return flxfrag->crate_no(frame_ID);
   }

int dune::FelixFragmentCompressed::decompress_copy	(	const artdaq::Fragment &	src,
		artdaq::Fragment &	dst
	)

inlineprivate

Definition at line 500 of file FelixFragment.hh.

                                                                       {
     // Determine and reserve new fragment size.
     long unsigned int uncompSizeBytes;
     if (meta_.reordered) {
       uncompSizeBytes = meta_.num_frames * (sizeof(dune::WIBHeader) +
                                             4 * sizeof(dune::ColdataHeader) +
                                             256 * sizeof(dune::adc_t));
       // Account for bitfields
       uncompSizeBytes += (meta_.num_frames + 7) / 8;
     } else {
       uncompSizeBytes = meta_.num_frames * sizeof(dune::FelixFrame);
     }
     dst.resizeBytes(uncompSizeBytes);
 
     int num_bytes = internal_inflate(src.dataBeginBytes(), src.dataSizeBytes(),
                                      dst.dataBeginBytes(), dst.dataSizeBytes());
 
     return num_bytes;
   }

uint16_t dune::FelixFragmentCompressed::error_register	(	const unsigned &	frame_ID,
		const uint8_t &	block_num
	)		const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 643 of file FelixFragment.hh.

                                                           {
     return flxfrag->error_register(frame_ID, block_num);
   }

uint8_t dune::FelixFragmentCompressed::fiber_no ( const unsigned & frame_ID = 0 ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 599 of file FelixFragment.hh.

                                                        {
     return flxfrag->fiber_no(frame_ID);
   }

adc_t dune::FelixFragmentCompressed::get_ADC	(	const unsigned &	frame_ID,
		const uint8_t	channel_ID
	)		const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 653 of file FelixFragment.hh.

                                                                           {
     return flxfrag->get_ADC(frame_ID, channel_ID);
   }

uint8_t dune::FelixFragmentCompressed::hdr	(	const unsigned &	frame_ID,
		const uint8_t &	block_num,
		const uint8_t &	hdr_num
	)		const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 647 of file FelixFragment.hh.

                                             {
     return flxfrag->hdr(frame_ID, block_num, hdr_num);
   }

int dune::FelixFragmentCompressed::internal_inflate	(	const void *	src,
		uint	srcLen,
		void *	dst,
		uint	dstLen
	)

inlineprivate

Definition at line 520 of file FelixFragment.hh.

                                                                              {
     z_stream strm = {0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0};
     strm.total_in = strm.avail_in = srcLen;
     strm.total_out = strm.avail_out = dstLen;
     strm.next_in = (Bytef*)src;
     strm.next_out = (Bytef*)dst;
 
     strm.zalloc = Z_NULL;
     strm.zfree = Z_NULL;
     strm.opaque = Z_NULL;
 
     unsigned read = 0;
     unsigned write = 0;
     int err = 0;
 
     while (read < srcLen && write < dstLen) {
       strm.next_in = (Bytef*)src + read;
       strm.next_out = (Bytef*)dst + write;
 
       unsigned to_read = srcLen - read;
       unsigned to_write = dstLen - write;
 
       if (to_read < 20) {
         // This cant possibly be a frag
         break;
       }
 
       strm.total_in = strm.avail_in = to_read;
       strm.total_out = strm.avail_out = to_write;
 
       inflateInit2(&strm, MAX_WBITS | 16);
       err = inflate(&strm, Z_FINISH);
       // Just return the source if data error.
       if (err == Z_DATA_ERROR) {
         std::cout << "Warning: decompression data error. Returning compressed "
                      "fragment.\n";
         memcpy(dst, src, srcLen);
         return srcLen;
       }
       inflateEnd(&strm);
 
       read += to_read - strm.avail_in;
       write += to_write - strm.avail_out;
 
       if (err < 0) {
         break;
       }
     }
 
     return write;
   }

uint8_t dune::FelixFragmentCompressed::mm ( const unsigned & frame_ID = 0 ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 608 of file FelixFragment.hh.

                                                  {
     return flxfrag->mm(frame_ID);
   }

uint8_t dune::FelixFragmentCompressed::oos ( const unsigned & frame_ID = 0 ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 611 of file FelixFragment.hh.

                                                   {
     return flxfrag->oos(frame_ID);
   }

void dune::FelixFragmentCompressed::print ( const unsigned i ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 660 of file FelixFragment.hh.

660 { return flxfrag->print(i); }

dune::FelixFragmentBase::print

virtual void print(const unsigned i) const =0

dune::FelixFragmentCompressed::flxfrag

const FelixFragmentBase * flxfrag

Definition: FelixFragment.hh:678

void dune::FelixFragmentCompressed::print_frames ( ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 662 of file FelixFragment.hh.

662 { return flxfrag->print_frames(); }

dune::FelixFragmentBase::print_frames

virtual void print_frames() const =0

dune::FelixFragmentCompressed::flxfrag

const FelixFragmentBase * flxfrag

Definition: FelixFragment.hh:678

void dune::FelixFragmentCompressed::print_timestamps ( ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 658 of file FelixFragment.hh.

658 { return flxfrag->print_timestamps(); }

dune::FelixFragmentBase::print_timestamps

virtual void print_timestamps() const =0

dune::FelixFragmentCompressed::flxfrag

const FelixFragmentBase * flxfrag

Definition: FelixFragment.hh:678

uint8_t dune::FelixFragmentCompressed::s1_error	(	const unsigned &	frame_ID,
		const uint8_t &	block_num
	)		const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 625 of file FelixFragment.hh.

                                                                              {
     return flxfrag->s1_error(frame_ID, block_num);
   }

uint8_t dune::FelixFragmentCompressed::s2_error	(	const unsigned &	frame_ID,
		const uint8_t &	block_num
	)		const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 628 of file FelixFragment.hh.

                                                                              {
     return flxfrag->s2_error(frame_ID, block_num);
   }

uint8_t dune::FelixFragmentCompressed::slot_no ( const unsigned & frame_ID = 0 ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 602 of file FelixFragment.hh.

                                                       {
     return flxfrag->slot_no(frame_ID);
   }

uint8_t dune::FelixFragmentCompressed::sof ( const unsigned & frame_ID = 0 ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 593 of file FelixFragment.hh.

                                                   {
     return flxfrag->sof(frame_ID);
   }

uint64_t dune::FelixFragmentCompressed::timestamp ( const unsigned & frame_ID = 0 ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 617 of file FelixFragment.hh.

                                                          {
     return flxfrag->timestamp(frame_ID);
   }

size_t dune::FelixFragmentCompressed::total_adc_values ( ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 669 of file FelixFragment.hh.

669 { return flxfrag->total_adc_values(); }

dune::FelixFragmentCompressed::flxfrag

const FelixFragmentBase * flxfrag

Definition: FelixFragment.hh:678

dune::FelixFragmentBase::total_adc_values

virtual size_t total_adc_values() const =0

size_t dune::FelixFragmentCompressed::total_frames ( ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 667 of file FelixFragment.hh.

667 { return flxfrag->total_frames(); }

dune::FelixFragmentBase::total_frames

virtual size_t total_frames() const =0

dune::FelixFragmentCompressed::flxfrag

const FelixFragmentBase * flxfrag

Definition: FelixFragment.hh:678

size_t dune::FelixFragmentCompressed::total_words ( ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 665 of file FelixFragment.hh.

665 { return flxfrag->total_words(); }

dune::FelixFragmentBase::total_words

virtual size_t total_words() const =0

dune::FelixFragmentCompressed::flxfrag

const FelixFragmentBase * flxfrag

Definition: FelixFragment.hh:678

const artdaq::Fragment dune::FelixFragmentCompressed::uncompressed_fragment ( ) const

inline

Definition at line 672 of file FelixFragment.hh.

672 { return uncompfrag_; }

dune::FelixFragmentCompressed::uncompfrag_

artdaq::Fragment uncompfrag_

Definition: FelixFragment.hh:676

uint8_t dune::FelixFragmentCompressed::version ( const unsigned & frame_ID = 0 ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 596 of file FelixFragment.hh.

                                                       {
     return flxfrag->version(frame_ID);
   }

uint16_t dune::FelixFragmentCompressed::wib_counter ( const unsigned & frame_ID = 0 ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 620 of file FelixFragment.hh.

                                                            {
     return flxfrag->wib_counter(frame_ID);
   }

uint16_t dune::FelixFragmentCompressed::wib_errors ( const unsigned & frame_ID = 0 ) const

inlinevirtual

Implements dune::FelixFragmentBase.

Definition at line 614 of file FelixFragment.hh.

                                                           {
     return flxfrag->wib_errors(frame_ID);
   }

Member Data Documentation

const FelixFragmentBase* dune::FelixFragmentCompressed::flxfrag

protected

Definition at line 678 of file FelixFragment.hh.

artdaq::Fragment dune::FelixFragmentCompressed::uncompfrag_

protected

Definition at line 676 of file FelixFragment.hh.

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

dune-raw-data/dune-raw-data/Overlays/FelixFragment.hh

Public Member Functions

Protected Attributes

Private Member Functions

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation