Agora  1.2.0
Agora project
concurrent_queue_wrapper.h File Reference
#include <cstddef>
#include "concurrentqueue.h"
#include "message.h"
#include "symbols.h"
#include "utils.h"
Include dependency graph for concurrent_queue_wrapper.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions

static void TryEnqueueFallback (moodycamel::ConcurrentQueue< EventData > *mc_queue, moodycamel::ProducerToken *producer_token, const EventData &event)
 
static void TryEnqueueFallback (moodycamel::ConcurrentQueue< EventData > *mc_queue, const EventData &event)
 
static void TryEnqueueBulkFallback (moodycamel::ConcurrentQueue< EventData > *mc_queue, moodycamel::ProducerToken *producer_token, const EventData *event_list, size_t num_events)
 

Function Documentation

◆ TryEnqueueBulkFallback()

static void TryEnqueueBulkFallback ( moodycamel::ConcurrentQueue< EventData > *  mc_queue,
moodycamel::ProducerToken producer_token,
const EventData event_list,
size_t  num_events 
)
inlinestatic

Enqueue a batch of events to a concurrent queue and print a warning message if we're short on queue space

Here is the call graph for this function:
Here is the caller graph for this function:

◆ TryEnqueueFallback() [1/2]

static void TryEnqueueFallback ( moodycamel::ConcurrentQueue< EventData > *  mc_queue,
const EventData event 
)
inlinestatic

Enqueue one event to a concurrent queue and print a warning message if we're short on queue space

Here is the call graph for this function:

◆ TryEnqueueFallback() [2/2]

static void TryEnqueueFallback ( moodycamel::ConcurrentQueue< EventData > *  mc_queue,
moodycamel::ProducerToken producer_token,
const EventData event 
)
inlinestatic

Enqueue one event to a concurrent queue and print a warning message if we're short on queue space

Here is the call graph for this function:
Here is the caller graph for this function: