Agora  1.2.0
Agora project
Agora_recorder::Recorder Class Reference

#include <recorder.h>

Collaboration diagram for Agora_recorder::Recorder:

Public Member Functions

 Recorder (const Config *in_cfg, size_t core_start=0u)
 
 ~Recorder ()
 
void DoIt ()
 
moodycamel::ConcurrentQueue< EventData > & GetRecorderQueue ()
 

Private Member Functions

void Gc ()
 

Private Attributes

const Configcfg_
 
size_t rx_thread_buff_size_
 
std::vector< std::unique_ptr< RecorderThread > > recorders_
 
moodycamel::ConcurrentQueue< EventDatamessage_queue_
 
const size_t main_dispatch_core_
 
const size_t recorder_core_
 
size_t num_writter_threads_
 

Static Private Attributes

static const int kSampleBufferFrameNum = 80
 
static const int kDequeueBulkSize = 5
 

Constructor & Destructor Documentation

◆ Recorder()

Agora_recorder::Recorder::Recorder ( const Config in_cfg,
size_t  core_start = 0u 
)
explicit
Here is the call graph for this function:

◆ ~Recorder()

Agora_recorder::Recorder::~Recorder ( )
Here is the call graph for this function:

Member Function Documentation

◆ DoIt()

void Agora_recorder::Recorder::DoIt ( )
Here is the call graph for this function:

◆ Gc()

void Agora_recorder::Recorder::Gc ( )
private
Here is the caller graph for this function:

◆ GetRecorderQueue()

moodycamel::ConcurrentQueue<EventData>& Agora_recorder::Recorder::GetRecorderQueue ( )
inline

Member Data Documentation

◆ cfg_

const Config* Agora_recorder::Recorder::cfg_
private

◆ kDequeueBulkSize

const int Agora_recorder::Recorder::kDequeueBulkSize = 5
staticprivate

◆ kSampleBufferFrameNum

const int Agora_recorder::Recorder::kSampleBufferFrameNum = 80
staticprivate

◆ main_dispatch_core_

const size_t Agora_recorder::Recorder::main_dispatch_core_
private

◆ message_queue_

moodycamel::ConcurrentQueue<EventData> Agora_recorder::Recorder::message_queue_
private

◆ num_writter_threads_

size_t Agora_recorder::Recorder::num_writter_threads_
private

◆ recorder_core_

const size_t Agora_recorder::Recorder::recorder_core_
private

◆ recorders_

std::vector<std::unique_ptr<RecorderThread> > Agora_recorder::Recorder::recorders_
private

◆ rx_thread_buff_size_

size_t Agora_recorder::Recorder::rx_thread_buff_size_
private

The documentation for this class was generated from the following files: