concurrent_queue_wrapper.h

Go to the documentation of this file.

 
#ifndef CONCURRENT_QUEUE_WRAPPER_H_
#define CONCURRENT_QUEUE_WRAPPER_H_
 
#include <cstddef>
 
#include "concurrentqueue.h"
#include "message.h"
#include "symbols.h"
#include "utils.h"
 
static inline void TryEnqueueFallback(
    moodycamel::ConcurrentQueue<EventData>* mc_queue,
    moodycamel::ProducerToken* producer_token, const EventData& event) {
  if (!mc_queue->try_enqueue(*producer_token, event)) {
    std::printf("Need more memory\n");
    RtAssert(mc_queue->enqueue(*producer_token, event),
             "Message enqueue failed");
  }
}
 
static inline void TryEnqueueFallback(
    moodycamel::ConcurrentQueue<EventData>* mc_queue, const EventData& event) {
  if (!mc_queue->try_enqueue(event)) {
    std::printf("Need more memory\n");
    RtAssert(mc_queue->enqueue(event), "Message enqueue failed");
  }
}
 
static inline void TryEnqueueBulkFallback(
    moodycamel::ConcurrentQueue<EventData>* mc_queue,
    moodycamel::ProducerToken* producer_token, const EventData* event_list,
    size_t num_events) {
  if (!mc_queue->try_enqueue_bulk(*producer_token, event_list, num_events)) {
    std::printf("Need more memory\n");
    RtAssert(mc_queue->enqueue_bulk(*producer_token, event_list, num_events),
             "Message bulk enqueue failed\n");
  }
}
 
#endif  // CONCURRENT_QUEUE_WRAPPER_H_