#include <receiver.h>
|
| Receiver (Config *config, moodycamel::ConcurrentQueue< Event_data > *in_queue, std::vector< moodycamel::ConcurrentQueue< Event_data > * > tx_queue, std::vector< moodycamel::ProducerToken * > tx_ptoks, std::vector< moodycamel::ConcurrentQueue< Event_data > * > cl_tx_queue, std::vector< moodycamel::ProducerToken * > cl_tx_ptoks) |
|
| ~Receiver () |
|
std::vector< pthread_t > | startRecvThreads (SampleBuffer *rx_buffer, size_t n_rx_threads, SampleBuffer *tx_buffer, unsigned in_core_id=0) |
|
void | completeRecvThreads (const std::vector< pthread_t > &recv_thread) |
|
std::vector< pthread_t > | startClientThreads (SampleBuffer *rx_buffer, SampleBuffer *tx_buffer, unsigned in_core_id=0) |
|
void | go () |
|
void | loopRecv (int tid, int core_id, SampleBuffer *rx_buffer) |
|
void | baseTxBeacon (int radio_id, int cell, int frame_id, long long base_time) |
|
int | baseTxData (int radio_id, int cell, int frame_id, long long base_time) |
|
void | notifyPacket (NodeType node_type, int frame_id, int slot_id, int ant_id, int buff_size, int offset=0) |
|
void | clientTxRx (int tid) |
|
void | clientSyncTxRx (int tid, int core_id, SampleBuffer *rx_buffer) |
|
int | syncSearch (std::vector< std::complex< int16_t >> sync_buff, size_t sync_num_samps) |
|
void | initBuffers () |
|
void | clientTxPilots (size_t user_id, long long base_time) |
|
int | clientTxData (int tid, int frame_id, long long base_time) |
|
◆ Receiver()
◆ ~Receiver()
◆ baseTxBeacon()
void Receiver::baseTxBeacon |
( |
int |
radio_id, |
|
|
int |
cell, |
|
|
int |
frame_id, |
|
|
long long |
base_time |
|
) |
| |
◆ baseTxData()
int Receiver::baseTxData |
( |
int |
radio_id, |
|
|
int |
cell, |
|
|
int |
frame_id, |
|
|
long long |
base_time |
|
) |
| |
◆ clientSyncTxRx()
void Receiver::clientSyncTxRx |
( |
int |
tid, |
|
|
int |
core_id, |
|
|
SampleBuffer * |
rx_buffer |
|
) |
| |
◆ clientTxData()
int Receiver::clientTxData |
( |
int |
tid, |
|
|
int |
frame_id, |
|
|
long long |
base_time |
|
) |
| |
◆ clientTxPilots()
void Receiver::clientTxPilots |
( |
size_t |
user_id, |
|
|
long long |
base_time |
|
) |
| |
◆ clientTxRx()
void Receiver::clientTxRx |
( |
int |
tid | ) |
|
◆ clientTxRx_launch()
void * Receiver::clientTxRx_launch |
( |
void * |
in_context | ) |
|
|
static |
◆ completeRecvThreads()
void Receiver::completeRecvThreads |
( |
const std::vector< pthread_t > & |
recv_thread | ) |
|
◆ go()
◆ initBuffers()
void Receiver::initBuffers |
( |
| ) |
|
◆ loopRecv()
void Receiver::loopRecv |
( |
int |
tid, |
|
|
int |
core_id, |
|
|
SampleBuffer * |
rx_buffer |
|
) |
| |
◆ loopRecv_launch()
void * Receiver::loopRecv_launch |
( |
void * |
in_context | ) |
|
|
static |
◆ notifyPacket()
void Receiver::notifyPacket |
( |
NodeType |
node_type, |
|
|
int |
frame_id, |
|
|
int |
slot_id, |
|
|
int |
ant_id, |
|
|
int |
buff_size, |
|
|
int |
offset = 0 |
|
) |
| |
◆ startClientThreads()
◆ startRecvThreads()
◆ syncSearch()
int Receiver::syncSearch |
( |
std::vector< std::complex< int16_t >> |
sync_buff, |
|
|
size_t |
sync_num_samps |
|
) |
| |
◆ base_radio_set_
◆ bs_tx_buffer_
◆ cl_tx_buffer_
◆ cl_tx_ptoks_
std::vector<moodycamel::ProducerToken*> Receiver::cl_tx_ptoks_ |
|
private |
◆ cl_tx_queue_
◆ clientRadioSet_
◆ config_
◆ message_queue_
moodycamel::ConcurrentQueue<Event_data>* Receiver::message_queue_ |
|
private |
◆ pilotbuffA
◆ pilotbuffB
◆ thread_num_
size_t Receiver::thread_num_ |
|
private |
◆ tx_ptoks_
std::vector<moodycamel::ProducerToken*> Receiver::tx_ptoks_ |
|
private |
◆ tx_queue_
◆ txFrameDelta
size_t Receiver::txFrameDelta |
|
private |
◆ txTimeDelta
size_t Receiver::txTimeDelta |
|
private |
◆ zeros
The documentation for this class was generated from the following files: