simulator.h

Go to the documentation of this file.

 
#ifndef SIMULATOR_H_
#define SIMULATOR_H_
 
#include <emmintrin.h>
#include <immintrin.h>
#include <unistd.h>
 
#include <algorithm>
#include <iostream>
#include <memory>
#include <queue>
#include <system_error>
#include <tuple>
#include <vector>
 
#include "concurrentqueue.h"
#include "config.h"
#include "gettime.h"
#include "memory_manage.h"
#include "message.h"
#include "receiver.h"
#include "sender.h"
#include "signal_handler.h"
 
class Simulator {
 public:
  /* optimization parameters for block transpose (see the slides for more
   * details) */
  static constexpr size_t kTransposeBlockSize = 8;
  static constexpr size_t kTransposeBlockNum = 256;
  /* dequeue bulk size, used to reduce the overhead of dequeue in main thread
   */
  static constexpr size_t kDequeueBulkSize = 32;
  static constexpr size_t kDequeueBulkSizeSingle = 8;
 
  Simulator(Config* cfg, size_t task_thread_num, size_t core_offset,
            size_t sender_delay);
 
  ~Simulator();
 
  void Start();
  void Stop();
 
  inline void UpdateFrameCount(int* frame_count);
  void UpdateRxCounters(size_t frame_id, size_t frame_id_in_buffer,
                        size_t symbol_id, size_t ant_id);
  void PrintPerFrameDone(PrintType print_type, size_t frame_id);
 
 private:
  size_t task_thread_num_;
  size_t socket_rx_thread_num_;
  size_t socket_tx_thread_num_;
  size_t core_offset_;
 
  /* lookup table for 16 QAM, real and imag */
 
  Config* config_;
  std::unique_ptr<Receiver> receiver_;
  std::unique_ptr<Sender> sender_;
 
  Table<char> socket_buffer_;
  size_t socket_buffer_size_;
 
  /* status checkers used by master thread */
  /* used to check if RX for all antennas and all symbols in a frame is done
   * (max: BS_ANT_NUM * dl symbols) */
  size_t* rx_counter_packets_;
 
  /*****************************************************
   * Concurrent queues
   *****************************************************/
  /* main thread message queue for data receiving */
  moodycamel::ConcurrentQueue<EventData> message_queue_;
  /* main thread message queue for task completion*/
  moodycamel::ConcurrentQueue<EventData> complete_task_queue_;
 
  /* Tokens */
  moodycamel::ProducerToken** rx_ptoks_ptr_;
 
  /*****************************************************
   * Timestamps and counters used in worker threads
   *****************************************************/
  Table<double> frame_start_;
  double* frame_start_receive_;
  double* frame_end_receive_;
  double* frame_start_tx_;
  double* frame_end_tx_;
 
  void InitializeQueues();
  void InitializeBuffers();
  void FreeBuffers();
  void FreeQueues();
};
 
#endif  // SIMULATOR_H_