serial::Hdf5OutputSink Class Reference

#include "hdf5_output_sink.h"

Inheritance diagram for serial::Hdf5OutputSink:

Collaboration diagram for serial::Hdf5OutputSink:

Classes
struct	Impl

Public Member Functions
	Hdf5OutputSink (std::string output_dir, std::shared_ptr< core::OutputMetadataCollector > metadata_collector=nullptr)
	~Hdf5OutputSink () override
	Hdf5OutputSink (const Hdf5OutputSink &)=delete
Hdf5OutputSink &	operator= (const Hdf5OutputSink &)=delete
void	initializeRun (const core::OutputConfig &config, std::string simulation_name) override
std::uint32_t	registerStream (const core::ReceiverStreamDescriptor &stream) override
void	openStream (std::uint32_t stream_id, RealType first_sample_time) override
void	submitBlock (const core::ReceiverSampleBlock &block) override
void	emitContextHeartbeat (RealType simulation_time) override
void	closeStream (std::uint32_t stream_id) override
core::OutputStats	finalize () override
virtual void	submitBlocks (const std::span< const ReceiverSampleBlock > blocks)
virtual OutputStats	snapshotStats () const

Detailed Description

Definition at line 21 of file hdf5_output_sink.h.

Constructor & Destructor Documentation

Hdf5OutputSink() [1/2]

serial::Hdf5OutputSink::Hdf5OutputSink	(	std::string	output_dir,
		std::shared_ptr< core::OutputMetadataCollector >	metadata_collector = nullptr
	)

Definition at line 329 of file hdf5_output_sink.cpp.

                                                                                                  :
        _impl(std::make_unique<Impl>(std::move(output_dir), std::move(metadata_collector)))
    {
    }

~Hdf5OutputSink()

serial::Hdf5OutputSink::~Hdf5OutputSink ( )

override

Definition at line 335 of file hdf5_output_sink.cpp.

    {
        if (_impl)
        {
            try
            {
                (void)_impl->finalize();
            }
            catch (...)
            {
            }
        }
    }

References max.

Hdf5OutputSink() [2/2]

serial::Hdf5OutputSink::Hdf5OutputSink ( const Hdf5OutputSink &  )

delete

Member Function Documentation

closeStream()

void serial::Hdf5OutputSink::closeStream ( std::uint32_t  stream_id )

overridevirtual

Implements core::ReceiverOutputSink.

Definition at line 368 of file hdf5_output_sink.cpp.

{ _impl->closeStream(stream_id); }

emitContextHeartbeat()

void serial::Hdf5OutputSink::emitContextHeartbeat ( RealType  simulation_time )

overridevirtual

Implements core::ReceiverOutputSink.

Definition at line 366 of file hdf5_output_sink.cpp.

{}

finalize()

core::OutputStats serial::Hdf5OutputSink::finalize ( )

overridevirtual

Implements core::ReceiverOutputSink.

Definition at line 370 of file hdf5_output_sink.cpp.

{ return _impl->finalize(); }

initializeRun()

void serial::Hdf5OutputSink::initializeRun ( const core::OutputConfig &  config, std::string  simulation_name  )

overridevirtual

Implements core::ReceiverOutputSink.

Definition at line 349 of file hdf5_output_sink.cpp.

    {
        _impl->initializeRun(config, simulation_name);
    }

References max.

openStream()

void serial::Hdf5OutputSink::openStream ( std::uint32_t  stream_id, RealType  first_sample_time  )

overridevirtual

Implements core::ReceiverOutputSink.

Definition at line 359 of file hdf5_output_sink.cpp.

    {
        _impl->openStream(stream_id, first_sample_time);
    }

operator=()

Hdf5OutputSink & serial::Hdf5OutputSink::operator= ( const Hdf5OutputSink &  )

delete

registerStream()

std::uint32_t serial::Hdf5OutputSink::registerStream ( const core::ReceiverStreamDescriptor &  stream )

overridevirtual

Implements core::ReceiverOutputSink.

Definition at line 354 of file hdf5_output_sink.cpp.

    {
        return _impl->registerStream(stream);
    }

snapshotStats()

virtual OutputStats core::ReceiverOutputSink::snapshotStats ( ) const

virtualinherited

Reimplemented in serial::vita49::Vita49OutputSink.

Definition at line 219 of file receiver_output.h.

{ return {}; }

submitBlock()

void serial::Hdf5OutputSink::submitBlock ( const core::ReceiverSampleBlock &  block )

overridevirtual

Implements core::ReceiverOutputSink.

Definition at line 364 of file hdf5_output_sink.cpp.

{ _impl->submitBlock(block); }

References max.

submitBlocks()

virtual void core::ReceiverOutputSink::submitBlocks ( const std::span< const ReceiverSampleBlock >  blocks )

virtualinherited

Reimplemented in serial::vita49::Vita49OutputSink.

Definition at line 209 of file receiver_output.h.

        {
            for (const auto& block : blocks)
            {
                submitBlock(block);
            }
        }

References max, and core::ReceiverOutputSink::submitBlock().

Here is the call graph for this function:

---

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

• packages/libfers/src/serial/hdf5_output_sink.h
• packages/libfers/src/serial/hdf5_output_sink.cpp