queue.hpp

Go to the documentation of this file.

 
#include <cassert>
#include <cstdint>
#include <functional>
#include <gsl/span>
#include <memory>
#include <optional>
#include <tbb/concurrent_queue.h>
#include <utility>
 
#include <rtctk/componentFramework/bufferManager.hpp>
 
#ifndef RTCTK_REUSABLECOMPONENT_TELREPUB_QUEUE_HPP
#define RTCTK_REUSABLECOMPONENT_TELREPUB_QUEUE_HPP
 
namespace rtctk::telRepub {
 
static constexpr size_t MAX_THREAD_NAME = 15;
 
struct PacketFrame {
    using BufferReference = rtctk::componentFramework::BufferManager::BufferReference;
    std::shared_ptr<BufferReference> reference;
    gsl::span<uint8_t> data;
};
 
using QueueElement = PacketFrame;
using Queue = tbb::concurrent_bounded_queue<QueueElement>;
using QueuePtr = std::shared_ptr<Queue>;
 
}  // namespace rtctk::telRepub
 
#endif  // RTCTK_REUSABLECOMPONENT_TELREPUB_QUEUE_HPP