Agora  1.2.0
Agora project
ChSimRxStorage Class Reference

#include <chsim_worker_storage.h>

Collaboration diagram for ChSimRxStorage:

Public Member Functions

 ChSimRxStorage (size_t tid, size_t core_id, size_t rx_packet_size, size_t socket_offset, size_t socket_number, std::vector< std::unique_ptr< UDPComm >> *udp_comm, ChSimRxBuffer *rx_output_storage, moodycamel::ConcurrentQueue< EventData > *response_queue)
 
size_t Id () const
 
size_t CoreId () const
 
size_t PacketLength () const
 
size_t SocketOffset () const
 
size_t SocketNumber () const
 
UDPCommSocket (size_t id)
 
void TransferRxData (size_t frame, size_t symbol, size_t ant, const short *input, size_t data_size)
 
moodycamel::ConcurrentQueue< EventData > & ResponseQueue ()
 

Private Attributes

size_t tid_
 
size_t core_id_
 
size_t rx_packet_size_
 
size_t socket_offset_
 
size_t socket_number_
 
std::vector< std::unique_ptr< UDPComm > > *const comm_
 
ChSimRxBuffer *const rx_output_
 
moodycamel::ConcurrentQueue< EventData > *const response_queue_
 

Constructor & Destructor Documentation

◆ ChSimRxStorage()

ChSimRxStorage::ChSimRxStorage ( size_t  tid,
size_t  core_id,
size_t  rx_packet_size,
size_t  socket_offset,
size_t  socket_number,
std::vector< std::unique_ptr< UDPComm >> *  udp_comm,
ChSimRxBuffer rx_output_storage,
moodycamel::ConcurrentQueue< EventData > *  response_queue 
)
inline

Member Function Documentation

◆ CoreId()

size_t ChSimRxStorage::CoreId ( ) const
inline
Here is the caller graph for this function:

◆ Id()

size_t ChSimRxStorage::Id ( ) const
inline
Here is the caller graph for this function:

◆ PacketLength()

size_t ChSimRxStorage::PacketLength ( ) const
inline
Here is the caller graph for this function:

◆ ResponseQueue()

moodycamel::ConcurrentQueue<EventData>& ChSimRxStorage::ResponseQueue ( )
inline
Here is the caller graph for this function:

◆ Socket()

UDPComm* ChSimRxStorage::Socket ( size_t  id)
inline
Here is the caller graph for this function:

◆ SocketNumber()

size_t ChSimRxStorage::SocketNumber ( ) const
inline
Here is the caller graph for this function:

◆ SocketOffset()

size_t ChSimRxStorage::SocketOffset ( ) const
inline
Here is the caller graph for this function:

◆ TransferRxData()

void ChSimRxStorage::TransferRxData ( size_t  frame,
size_t  symbol,
size_t  ant,
const short *  input,
size_t  data_size 
)
inline
Here is the call graph for this function:
Here is the caller graph for this function:

Member Data Documentation

◆ comm_

std::vector<std::unique_ptr<UDPComm> >* const ChSimRxStorage::comm_
private

◆ core_id_

size_t ChSimRxStorage::core_id_
private

◆ response_queue_

moodycamel::ConcurrentQueue<EventData>* const ChSimRxStorage::response_queue_
private

◆ rx_output_

ChSimRxBuffer* const ChSimRxStorage::rx_output_
private

◆ rx_packet_size_

size_t ChSimRxStorage::rx_packet_size_
private

◆ socket_number_

size_t ChSimRxStorage::socket_number_
private

◆ socket_offset_

size_t ChSimRxStorage::socket_offset_
private

◆ tid_

size_t ChSimRxStorage::tid_
private

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