recorder_thread.h

Go to the documentation of this file.

/*
 Copyright (c) 2018-2020
 RENEW OPEN SOURCE LICENSE: http://renew-wireless.org/license
 
----------------------------------------------------------------------
Event based message queue thread class for the recorder worker
---------------------------------------------------------------------
*/
#ifndef SOUNDER_RECORDER_THREAD_H_
#define SOUNDER_RECORDER_THREAD_H_
 
#include <condition_variable>
#include <mutex>
 
#include "recorder_worker.h"
 
namespace Sounder {
class RecorderThread {
 public:
  //    enum RecordEventType { kThreadTermination, kTaskRecord };
  //
  //    struct RecordEvent_data {
  //        RecordEventType event_type;
  //        int data;
  //        SampleBuffer* rx_buffer;
  //        size_t rx_buff_size;
  //    };
 
  RecorderThread(Config* in_cfg, size_t thread_id, int core, size_t queue_size,
                 size_t antenna_offset, size_t num_antennas,
                 bool wait_signal = true);
  ~RecorderThread();
 
  void Start(void);
  void Stop(void);
  bool DispatchWork(Event_data event);
 
 private:
  /*Main threading loop */
  void DoRecording(void);
  void HandleEvent(Event_data event);
  void Finalize();
 
  //1 - Producer (dispatcher), 1 - Consumer
  moodycamel::ConcurrentQueue<Event_data> event_queue_;
  moodycamel::ProducerToken producer_token_;
  RecorderWorker worker_;
  std::thread thread_;
 
  size_t id_;
  size_t packet_data_length_;
 
  /* >= 0 to assign a core to the thread
         * <0   to disable thread core assignment */
  int core_alloc_;
 
  /* Synchronization for startup and sleeping */
  /* Setting wait signal to false will disable the thread waiting on new message
         * may cause excessive CPU load for infrequent messages.  
         * However, when the message processing time ~= queue posting time the mutex could 
         * become unnecessary work
         */
  bool wait_signal_;
  std::mutex sync_;
  std::condition_variable condition_;
  bool running_;
};
};  // namespace Sounder
 
#endif /* SOUNDER_RECORDER_THREAD_H_ */