MessageInfo Class Reference

#include <agora_buffer.h>

Public Member Functions
	MessageInfo (size_t queue_size)
	~MessageInfo ()
moodycamel::ProducerToken *	GetPtok (EventType event_type, size_t qid)
moodycamel::ConcurrentQueue< EventData > *	GetConq (EventType event_type, size_t qid)
moodycamel::ConcurrentQueue< EventData > &	GetCompQueue (size_t qid)
moodycamel::ProducerToken *	GetWorkerPtok (size_t qid, size_t worker_id)

Private Member Functions
void	Alloc (size_t queue_size)
void	Free ()

Private Attributes
std::array< moodycamel::ConcurrentQueue< EventData >, kScheduleQueues >	complete_task_queue_
std::array< std::array< moodycamel::ProducerToken *, kMaxThreads >, kScheduleQueues >	worker_ptoks_ptr_
std::array< std::array< SchedInfo, kNumEventTypes >, kScheduleQueues >	sched_info_arr_

Constructor & Destructor Documentation

MessageInfo()

MessageInfo::MessageInfo ( size_t  queue_size )

inlineexplicit

Here is the call graph for this function:

~MessageInfo()

MessageInfo::~MessageInfo ( )

inline

Here is the call graph for this function:

Member Function Documentation

Alloc()

void MessageInfo::Alloc ( size_t  queue_size )

inlineprivate

Here is the caller graph for this function:

Free()

void MessageInfo::Free ( )

inlineprivate

Here is the caller graph for this function:

GetCompQueue()

moodycamel::ConcurrentQueue<EventData>& MessageInfo::GetCompQueue ( size_t  qid )

inline

Here is the caller graph for this function:

GetConq()

moodycamel::ConcurrentQueue<EventData>* MessageInfo::GetConq ( EventType  event_type, size_t  qid  )

inline

Here is the caller graph for this function:

GetPtok()

moodycamel::ProducerToken* MessageInfo::GetPtok ( EventType  event_type, size_t  qid  )

inline

GetWorkerPtok()

moodycamel::ProducerToken* MessageInfo::GetWorkerPtok ( size_t  qid, size_t  worker_id  )

inline

Here is the caller graph for this function:

Member Data Documentation

complete_task_queue_

std::array<moodycamel::ConcurrentQueue<EventData>, kScheduleQueues> MessageInfo::complete_task_queue_

private

sched_info_arr_

std::array<std::array<SchedInfo, kNumEventTypes>, kScheduleQueues> MessageInfo::sched_info_arr_

private

worker_ptoks_ptr_

std::array<std::array<moodycamel::ProducerToken*, kMaxThreads>, kScheduleQueues> MessageInfo::worker_ptoks_ptr_

private

---

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

• src/agora/agora_buffer.h