Agora  1.2.0
Agora project
TxRxWorkerDpdk Member List

This is the complete list of members for TxRxWorkerDpdk, including all inherited members.

bs_rru_addr_TxRxWorkerDpdkprivate
bs_server_addr_TxRxWorkerDpdkprivate
can_proceed_TxRxWorkerprotected
cfg_TxRxWorkerprivate
channels_per_interface_TxRxWorkerprotected
cond_TxRxWorkerprotected
Configuration()TxRxWorkerinlineprotected
core_offset_TxRxWorkerprotected
DequeueSend()TxRxWorkerDpdkprivate
dest_mac_TxRxWorkerDpdkprivate
DoTxRx() finalTxRxWorkerDpdkvirtual
dpdk_phy_port_queues_TxRxWorkerDpdkprivate
event_notify_q_TxRxWorkerprivate
Filter(rte_mbuf *packet, uint16_t port_id, uint16_t queue_id)TxRxWorkerDpdkprivate
GetPendingTxEvents(size_t max_events=0)TxRxWorkerprotected
GetRxPacket()TxRxWorkerprotected
GetTxPacket(size_t frame, size_t symbol, size_t ant)TxRxWorkerprotected
GetUlTxPacket(size_t frame, size_t symbol, size_t ant)TxRxWorkerprotected
Id() constTxRxWorkerinline
interface_offset_TxRxWorkerprotected
kDebugTxMemoryTxRxWorkerstatic
mbuf_pool_TxRxWorkerDpdkprivate
mutex_TxRxWorkerprotected
notify_producer_token_TxRxWorkerprivate
NotifyComplete(const EventData &complete_event)TxRxWorkerprotected
num_interfaces_TxRxWorkerprotected
RecvEnqueue(uint16_t port_id, uint16_t queue_id)TxRxWorkerDpdkprivate
ReturnRxPacket(RxPacket &unused_packet)TxRxWorkerprotected
Running() constTxRxWorkerinline
running_TxRxWorkerprotected
rx_frame_start_TxRxWorkerprotected
rx_memory_TxRxWorkerprivate
rx_memory_idx_TxRxWorkerprivate
src_mac_TxRxWorkerDpdkprivate
Start() finalTxRxWorkerDpdkvirtual
Started() constTxRxWorkerinline
started_TxRxWorkerprivate
Stop() finalTxRxWorkerDpdkvirtual
thread_TxRxWorkerprivate
tid_TxRxWorkerprotected
tx_memory_TxRxWorkerprivate
tx_pending_q_TxRxWorkerprivate
tx_producer_token_TxRxWorkerprivate
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 &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)TxRxWorker
TxRxWorker()=deleteTxRxWorker
TxRxWorkerDpdk()=deleteTxRxWorkerDpdk
TxRxWorkerDpdk(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, std::vector< std::pair< uint16_t, uint16_t >> dpdk_phy, rte_mempool *mbuf_pool)TxRxWorkerDpdk
WaitSync()TxRxWorkerprotected
~TxRxWorker()TxRxWorkervirtual
~TxRxWorkerDpdk() finalTxRxWorkerDpdk