dune::RceFragment Class Reference

#include <RceFragment.hh>

Public Member Functions
	RceFragment (artdaq::Fragment const &fragment)
	RceFragment (const uint64_t *data_ptr)
int	size () const
TpcStreamUnpack const *	get_stream (int i) const
void	hexdump (std::ostream &out, int n_words=10) const
void	save (const std::string &filepath) const

Static Public Member Functions
static RceFragments	from_container_frags (const artdaq::Fragments &frags)

Private Member Functions
void	_init ()

Private Attributes
std::unique_ptr< DataFragmentUnpack >	_data_fragment
std::unique_ptr< TpcFragmentUnpack >	_tpc_fragment
int	_n_streams = 0
const uint64_t *	_data_ptr

Detailed Description

Definition at line 19 of file RceFragment.hh.

Constructor & Destructor Documentation

dune::RceFragment::RceFragment

(

artdaq::Fragment const &

fragment

)

Definition at line 17 of file RceFragment.cc.

                                                        :
    _data_ptr((uint64_t const*)(afrag.dataBeginBytes() + 12))
{
    _init();
}

dune::RceFragment::RceFragment

(

const uint64_t *

data_ptr

)

Definition at line 11 of file RceFragment.cc.

                                                     : 
    _data_ptr(data_ptr)
{
    _init();
}

Member Function Documentation

void dune::RceFragment::_init ( )

private

Definition at line 23 of file RceFragment.cc.

{
    HeaderFragmentUnpack const header (_data_ptr);
    if ( header.isData() )
    {
        _data_fragment = std::make_unique<DataFragmentUnpack>(_data_ptr);
        //  if (_data_fragment->isTpcNormal())
        // {

        _tpc_fragment = std::make_unique<TpcFragmentUnpack>(*_data_fragment);
        _n_streams = _tpc_fragment->getNStreams();

        // }
        //else
        // {
        //std::cout << "Fragment skipped in RceFragment::_init() because not TpcNormal." << std::endl;
        //}
    }
    else
    {
      //std::cout << "Fragment skipped in RceFragment::_init() because header says is not data." << std::endl;
    }
}

dune::RceFragments dune::RceFragment::from_container_frags ( const artdaq::Fragments &  frags )

static

Definition at line 79 of file RceFragment.cc.

{
    RceFragments rces;

    for (auto const& frag: frags)
        {
                artdaq::ContainerFragment cfrag(frag);
                for (size_t ii = 0 ; ii < cfrag.block_count(); ++ii)
                {
                        auto* data_ptr = (uint8_t*) (cfrag.dataBegin());
                        data_ptr += cfrag.fragmentIndex(ii);

                        size_t afrag_size = 16;
                        artdaq::Fragment afrag;
                        afrag.resizeBytes(afrag_size);
                        memcpy(afrag.headerAddress(), data_ptr, afrag_size);

                        int afrag_header_bytes = afrag.dataBeginBytes() 
                - afrag.headerBeginBytes();

            data_ptr += afrag_header_bytes;
            data_ptr += 12;

            dune::RceFragment rce((uint64_t*) data_ptr);
            rces.push_back(std::move(rce));
        }
    }
    //return std::move(rces);
    return rces;
}

TpcStreamUnpack const * dune::RceFragment::get_stream

(

int

i

)

const

Definition at line 48 of file RceFragment.cc.

{
    if (_n_streams <= 0)
        return nullptr;
    return _tpc_fragment->getStream(i);
}

void dune::RceFragment::hexdump	(	std::ostream &	out,
		int	n_words = 10
	)		const

Definition at line 55 of file RceFragment.cc.

{
    out << std::hex;
    for (int i = 0; i < n_words; ++i)
        out << *(_data_ptr + i) << " ";
    out << std::dec << std::endl;
}

void dune::RceFragment::save

(

const std::string &

filepath

)

const

Definition at line 63 of file RceFragment.cc.

{
    // TODO check header
    uint64_t header = *_data_ptr;
    size_t bytes = (header >> 8) & 0xffffff;
    bytes *= sizeof(uint64_t);

    std::ofstream b_stream(filepath.c_str(),
            std::fstream::out | std::fstream::binary);

    char const* data = reinterpret_cast<decltype(data)>(_data_ptr);
    b_stream.write(data, bytes);
    b_stream.close();
}

int dune::RceFragment::size ( ) const

inline

Definition at line 25 of file RceFragment.hh.

{ return _n_streams; }

Member Data Documentation

std::unique_ptr<DataFragmentUnpack> dune::RceFragment::_data_fragment

private

Definition at line 35 of file RceFragment.hh.

const uint64_t* dune::RceFragment::_data_ptr

private

Definition at line 38 of file RceFragment.hh.

int dune::RceFragment::_n_streams = 0

private

Definition at line 37 of file RceFragment.hh.

std::unique_ptr<TpcFragmentUnpack> dune::RceFragment::_tpc_fragment

private

Definition at line 36 of file RceFragment.hh.

---

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

• dune-raw-data/dune-raw-data/Overlays/RceFragment.hh
• dune-raw-data/dune-raw-data/Overlays/RceFragment.cc