ddsPubThread.hpp File Reference

DDS agnostic topic publioshing thread. More...

#include <boost/thread/thread.hpp>
#include "repubBuf.hpp"
#include <boost/lockfree/spsc_queue.hpp>
#include <chrono>
#include <iostream>
#include "rtctk/componentFramework/ddsCommon.hpp"
#include "rtctk/componentFramework/logger.hpp"

Go to the source code of this file.

Classes
struct	rtctk::telRepub::topicT
	structure where aggregation of the MUDPI topic payload is done, and put to the queue for DDS publishing More...
class	rtctk::telRepub::PubThreadBase< Q_SIZE >
	DDS publisher thread class that provides queue with aggregated topic to be published by DDS. More...
class	rtctk::telRepub::PubThread< T, Q_SIZE, TDW >

Namespaces
	rtctk
	rtctk::telRepub

Variables
uint32_t const	rtctk::telRepub::MAX_TOPIC_SIZE = 2560000

Detailed Description

DDS agnostic topic publioshing thread.

Copyright

(c) Copyright ESO 2021 All Rights Reserved ESO (eso.org) is an Intergovernmental Organisation, and therefore special legal conditions apply.