#include <txrx_worker_client_sim.h>
|
| TxRxWorkerClientSim (size_t core_offset, size_t tid, size_t interface_count, size_t interface_offset, Config *const config, size_t *rx_frame_start, moodycamel::ConcurrentQueue< EventData > *event_notify_q, moodycamel::ConcurrentQueue< EventData > *tx_pending_q, moodycamel::ProducerToken &tx_producer, moodycamel::ProducerToken ¬ify_producer, std::vector< RxPacket > &rx_memory, std::byte *const tx_memory, std::mutex &sync_mutex, std::condition_variable &sync_cond, std::atomic< bool > &can_proceed) |
|
| TxRxWorkerClientSim ()=delete |
|
| ~TxRxWorkerClientSim () final |
|
void | DoTxRx () final |
|
| TxRxWorker (size_t core_offset, size_t tid, size_t interface_count, size_t interface_offset, size_t channels_per_interface, Config *const config, size_t *rx_frame_start, moodycamel::ConcurrentQueue< EventData > *event_notify_q, moodycamel::ConcurrentQueue< EventData > *tx_pending_q, moodycamel::ProducerToken &tx_producer, moodycamel::ProducerToken ¬ify_producer, std::vector< RxPacket > &rx_memory, std::byte *const tx_memory, std::mutex &sync_mutex, std::condition_variable &sync_cond, std::atomic< bool > &can_proceed) |
|
| TxRxWorker ()=delete |
|
virtual | ~TxRxWorker () |
|
virtual void | Start () |
|
virtual void | Stop () |
|
size_t | Id () const |
|
bool | Started () const |
|
bool | Running () const |
|
◆ TxRxWorkerClientSim() [1/2]
TxRxWorkerClientSim::TxRxWorkerClientSim |
( |
size_t |
core_offset, |
|
|
size_t |
tid, |
|
|
size_t |
interface_count, |
|
|
size_t |
interface_offset, |
|
|
Config *const |
config, |
|
|
size_t * |
rx_frame_start, |
|
|
moodycamel::ConcurrentQueue< EventData > * |
event_notify_q, |
|
|
moodycamel::ConcurrentQueue< EventData > * |
tx_pending_q, |
|
|
moodycamel::ProducerToken & |
tx_producer, |
|
|
moodycamel::ProducerToken & |
notify_producer, |
|
|
std::vector< RxPacket > & |
rx_memory, |
|
|
std::byte *const |
tx_memory, |
|
|
std::mutex & |
sync_mutex, |
|
|
std::condition_variable & |
sync_cond, |
|
|
std::atomic< bool > & |
can_proceed |
|
) |
| |
◆ TxRxWorkerClientSim() [2/2]
TxRxWorkerClientSim::TxRxWorkerClientSim |
( |
| ) |
|
|
delete |
◆ ~TxRxWorkerClientSim()
TxRxWorkerClientSim::~TxRxWorkerClientSim |
( |
| ) |
|
|
finaldefault |
◆ DequeueSend()
size_t TxRxWorkerClientSim::DequeueSend |
( |
| ) |
|
|
private |
◆ DoTxRx()
void TxRxWorkerClientSim::DoTxRx |
( |
| ) |
|
|
finalvirtual |
◆ RecvEnqueue()
std::vector< Packet * > TxRxWorkerClientSim::RecvEnqueue |
( |
size_t |
interface_id | ) |
|
|
private |
◆ tx_pkt_pilot_
std::vector<uint8_t> TxRxWorkerClientSim::tx_pkt_pilot_ |
|
private |
◆ tx_pkt_zeros_
std::vector<uint8_t> TxRxWorkerClientSim::tx_pkt_zeros_ |
|
private |
◆ udp_comm_
std::vector<std::unique_ptr<UDPComm> > TxRxWorkerClientSim::udp_comm_ |
|
private |
The documentation for this class was generated from the following files: