RENEWLab  1.1.0
RENEW project
Sounder::Hdf5Reader Class Reference

#include <hdf5_reader.h>

Collaboration diagram for Sounder::Hdf5Reader:

Public Member Functions

 Hdf5Reader (Config *in_cfg, moodycamel::ConcurrentQueue< Event_data > &msg_queue, SampleBuffer *tx_buffer, size_t thread_id, int core, size_t queue_size, bool wait_signal=true)
 
 ~Hdf5Reader ()
 
void Start (void)
 
void Stop (void)
 
bool DispatchWork (Event_data event)
 
Event_data ReadFrame (Event_data event, int *offset)
 

Private Member Functions

void DoReading (void)
 
void Finalize ()
 

Private Attributes

moodycamel::ConcurrentQueue< Event_data > & msg_queue_
 
moodycamel::ConcurrentQueue< Event_dataevent_queue_
 
moodycamel::ProducerToken producer_token_
 
SampleBuffertx_buffer_
 
Configconfig_
 
std::thread thread_
 
size_t id_
 
size_t packet_data_length_
 
int core_alloc_
 
bool wait_signal_
 
std::mutex sync_
 
std::condition_variable condition_
 
bool running_
 
std::vector< FILE * > fp
 

Constructor & Destructor Documentation

◆ Hdf5Reader()

Sounder::Hdf5Reader::Hdf5Reader ( Config in_cfg,
moodycamel::ConcurrentQueue< Event_data > &  msg_queue,
SampleBuffer tx_buffer,
size_t  thread_id,
int  core,
size_t  queue_size,
bool  wait_signal = true 
)
Here is the call graph for this function:

◆ ~Hdf5Reader()

Sounder::Hdf5Reader::~Hdf5Reader ( )
Here is the call graph for this function:

Member Function Documentation

◆ DispatchWork()

bool Sounder::Hdf5Reader::DispatchWork ( Event_data  event)
Here is the caller graph for this function:

◆ DoReading()

void Sounder::Hdf5Reader::DoReading ( void  )
private
Here is the call graph for this function:
Here is the caller graph for this function:

◆ Finalize()

void Sounder::Hdf5Reader::Finalize ( )
private
Here is the call graph for this function:
Here is the caller graph for this function:

◆ ReadFrame()

Event_data Sounder::Hdf5Reader::ReadFrame ( Event_data  event,
int *  offset 
)
Here is the call graph for this function:
Here is the caller graph for this function:

◆ Start()

void Sounder::Hdf5Reader::Start ( void  )
Here is the call graph for this function:
Here is the caller graph for this function:

◆ Stop()

void Sounder::Hdf5Reader::Stop ( void  )
Here is the call graph for this function:
Here is the caller graph for this function:

Member Data Documentation

◆ condition_

std::condition_variable Sounder::Hdf5Reader::condition_
private

◆ config_

Config* Sounder::Hdf5Reader::config_
private

◆ core_alloc_

int Sounder::Hdf5Reader::core_alloc_
private

◆ event_queue_

moodycamel::ConcurrentQueue<Event_data> Sounder::Hdf5Reader::event_queue_
private

◆ fp

std::vector<FILE*> Sounder::Hdf5Reader::fp
private

◆ id_

size_t Sounder::Hdf5Reader::id_
private

◆ msg_queue_

moodycamel::ConcurrentQueue<Event_data>& Sounder::Hdf5Reader::msg_queue_
private

◆ packet_data_length_

size_t Sounder::Hdf5Reader::packet_data_length_
private

◆ producer_token_

moodycamel::ProducerToken Sounder::Hdf5Reader::producer_token_
private

◆ running_

bool Sounder::Hdf5Reader::running_
private

◆ sync_

std::mutex Sounder::Hdf5Reader::sync_
private

◆ thread_

std::thread Sounder::Hdf5Reader::thread_
private

◆ tx_buffer_

SampleBuffer* Sounder::Hdf5Reader::tx_buffer_
private

◆ wait_signal_

bool Sounder::Hdf5Reader::wait_signal_
private

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