#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: