MacThreadClient Class Reference

The MAC thread that runs alongside the PHY processing at the Agora server or client. More...

#include <mac_thread_client.h>

Collaboration diagram for MacThreadClient:

Public Member Functions
	MacThreadClient (Config *const cfg, size_t core_offset, PtrCube< kFrameWnd, kMaxSymbols, kMaxUEs, int8_t > &decoded_buffer, Table< int8_t > *ul_bits_buffer, Table< int8_t > *ul_bits_buffer_status, moodycamel::ConcurrentQueue< EventData > *rx_queue, moodycamel::ConcurrentQueue< EventData > *tx_queue, const std::string &log_filename="")
	~MacThreadClient ()
void	RunEventLoop ()

Static Public Attributes
static constexpr char	kDefaultLogFilename [] = "data/mac_log_client"
static constexpr size_t	kMaxPktsPerUE = 64
static constexpr size_t	kSNRWindowSize = 100

Private Member Functions
void	ProcessRxFromPhy ()
void	ProcessCodeblocksFromPhy (EventData event)
void	ProcessSnrReportFromPhy (EventData event)
void	ProcessControlInformation ()
void	ProcessUdpPacketsFromApps (RBIndicator ri)
void	ProcessUdpPacketsFromAppsClient (const char *payload, RBIndicator ri)

Private Attributes
Config *const	cfg_
const double	freq_ghz_
const size_t	tsc_delta_
const size_t	core_offset_
FILE *	log_file_
std::string	log_filename_
std::unique_ptr< UDPComm >	udp_comm_
std::unique_ptr< UDPServer >	udp_control_channel_
std::vector< std::byte >	udp_pkt_buf_
std::vector< std::byte >	udp_control_buf_
size_t	last_mac_pkt_rx_tsc_ = 0
size_t	next_tx_frame_id_ = 0
size_t	next_radio_id_ = 0
size_t	scheduler_next_frame_id_ = 0
FastRand	fast_rand_
struct {
std::array< std::vector< std::byte >, kMaxUEs >   frame_data_
std::array< size_t, kMaxUEs >   n_filled_in_frame_
std::array< std::queue< float >, kMaxUEs >   snr_
std::vector< std::vector< size_t > >   data_size_
}	server_
PtrCube< kFrameWnd, kMaxSymbols, kMaxUEs, int8_t > &	decoded_buffer_
struct {
std::array< size_t, kMaxUEs >   ul_bits_buffer_id_
Table< int8_t > *   ul_bits_buffer_
Table< int8_t > *   ul_bits_buffer_status_
}	client_
moodycamel::ConcurrentQueue< EventData > *	rx_queue_
moodycamel::ConcurrentQueue< EventData > *	tx_queue_
std::unique_ptr< DoCRC >	crc_obj_

Detailed Description

The MAC thread that runs alongside the PHY processing at the Agora server or client.

This thread receives UDP data packets from remote apps and forwards them to Agora. It receives decoded symbols from Agora and forwards UDP data packets to applications.

Constructor & Destructor Documentation

MacThreadClient()

MacThreadClient::MacThreadClient	(	Config *const	cfg,
		size_t	core_offset,
		PtrCube< kFrameWnd, kMaxSymbols, kMaxUEs, int8_t > &	decoded_buffer,
		Table< int8_t > *	ul_bits_buffer,
		Table< int8_t > *	ul_bits_buffer_status,
		moodycamel::ConcurrentQueue< EventData > *	rx_queue,
		moodycamel::ConcurrentQueue< EventData > *	tx_queue,
		const std::string &	log_filename = ""
	)

Here is the call graph for this function:

~MacThreadClient()

MacThreadClient::~MacThreadClient

(

)

Here is the call graph for this function:

Member Function Documentation

ProcessCodeblocksFromPhy()

void MacThreadClient::ProcessCodeblocksFromPhy ( EventData  event )

private

Spot to be optimized #1

Spot to be optimized #2 – left shift data over to remove padding

Here is the call graph for this function:

Here is the caller graph for this function:

ProcessControlInformation()

void MacThreadClient::ProcessControlInformation ( )

private

Here is the call graph for this function:

Here is the caller graph for this function:

ProcessRxFromPhy()

void MacThreadClient::ProcessRxFromPhy ( )

private

Here is the call graph for this function:

Here is the caller graph for this function:

ProcessSnrReportFromPhy()

void MacThreadClient::ProcessSnrReportFromPhy ( EventData  event )

private

Here is the caller graph for this function:

ProcessUdpPacketsFromApps()

void MacThreadClient::ProcessUdpPacketsFromApps ( RBIndicator  ri )

private

Here is the call graph for this function:

Here is the caller graph for this function:

ProcessUdpPacketsFromAppsClient()

void MacThreadClient::ProcessUdpPacketsFromAppsClient ( const char *  payload, RBIndicator  ri  )

private

Here is the call graph for this function:

Here is the caller graph for this function:

RunEventLoop()

void MacThreadClient::RunEventLoop

(

)

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

cfg_

Config* const MacThreadClient::cfg_

private

client_

struct { ... } MacThreadClient::client_

core_offset_

const size_t MacThreadClient::core_offset_

private

crc_obj_

std::unique_ptr<DoCRC> MacThreadClient::crc_obj_

private

data_size_

std::vector<std::vector<size_t> > MacThreadClient::data_size_

decoded_buffer_

PtrCube<kFrameWnd, kMaxSymbols, kMaxUEs, int8_t>& MacThreadClient::decoded_buffer_

private

fast_rand_

FastRand MacThreadClient::fast_rand_

private

frame_data_

std::array<std::vector<std::byte>, kMaxUEs> MacThreadClient::frame_data_

freq_ghz_

const double MacThreadClient::freq_ghz_

private

kDefaultLogFilename

constexpr char MacThreadClient::kDefaultLogFilename[] = "data/mac_log_client"

staticconstexpr

kMaxPktsPerUE

constexpr size_t MacThreadClient::kMaxPktsPerUE = 64

staticconstexpr

kSNRWindowSize

constexpr size_t MacThreadClient::kSNRWindowSize = 100

staticconstexpr

last_mac_pkt_rx_tsc_

size_t MacThreadClient::last_mac_pkt_rx_tsc_ = 0

private

log_file_

FILE* MacThreadClient::log_file_

private

log_filename_

std::string MacThreadClient::log_filename_

private

n_filled_in_frame_

std::array<size_t, kMaxUEs> MacThreadClient::n_filled_in_frame_

next_radio_id_

size_t MacThreadClient::next_radio_id_ = 0

private

next_tx_frame_id_

size_t MacThreadClient::next_tx_frame_id_ = 0

private

rx_queue_

moodycamel::ConcurrentQueue<EventData>* MacThreadClient::rx_queue_

private

scheduler_next_frame_id_

size_t MacThreadClient::scheduler_next_frame_id_ = 0

private

server_

struct { ... } MacThreadClient::server_

snr_

std::array<std::queue<float>, kMaxUEs> MacThreadClient::snr_

tsc_delta_

const size_t MacThreadClient::tsc_delta_

private

tx_queue_

moodycamel::ConcurrentQueue<EventData>* MacThreadClient::tx_queue_

private

udp_comm_

std::unique_ptr<UDPComm> MacThreadClient::udp_comm_

private

udp_control_buf_

std::vector<std::byte> MacThreadClient::udp_control_buf_

private

udp_control_channel_

std::unique_ptr<UDPServer> MacThreadClient::udp_control_channel_

private

udp_pkt_buf_

std::vector<std::byte> MacThreadClient::udp_pkt_buf_

private

ul_bits_buffer_

Table<int8_t>* MacThreadClient::ul_bits_buffer_

ul_bits_buffer_id_

std::array<size_t, kMaxUEs> MacThreadClient::ul_bits_buffer_id_

ul_bits_buffer_status_

Table<int8_t>* MacThreadClient::ul_bits_buffer_status_

---

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

• src/mac/mac_thread_client.h
• src/mac/mac_thread_client.cc