Eclipse Cyclone DDS C++ API Reference

struct action_thread_args

Public Functions

inline action_thread_args()

Public Members

std::string action
dds::core::cond::WaitSet *waitSet
dds::core::cond::GuardCondition *guard
dds::core::cond::StatusCondition *readerStatus
dds::sub::DataReader<Space::Type1> *reader
dds::pub::DataWriter<Space::Type1> *writer
test_semaphore *semStart
test_semaphore *semReady
bool result
std::string message
class Bounds : public Test

Fixture for the tests

Public Functions

inline Bounds()
inline void SetUp()
inline void TakeAndVerifyBoundedString(size_t N)
inline void TakeAndVerifyBoundedSequence(size_t N)
inline void TakeAndVerifyBooleanSequence(size_t N)
inline void TearDown()
inline void TryWriteBoundedString(size_t N)
inline void TryWriteBoundedSequence(size_t N)
inline void TryWriteBooleanSequence(size_t N)

Public Members

dds::domain::DomainParticipant participant
dds::pub::Publisher publisher
dds::sub::Subscriber subscriber
dds::topic::Topic<Bounded::Msg> topic
dds::pub::DataWriter<Bounded::Msg> writer
dds::sub::DataReader<Bounded::Msg> reader
std::string partition
class Condition : public Test

Fixture for the tests

Public Functions

inline Condition()
inline void SetUp()
inline void TearDown()

Public Members

dds::domain::DomainParticipant participant
dds::pub::Publisher publisher
dds::sub::Subscriber subscriber
dds::topic::Topic<Space::Type1> topic
dds::pub::DataWriter<Space::Type1> writer
dds::sub::DataReader<Space::Type1> reader
std::string partition
FunctorStatusCondition functor_status_cond
FunctorGuardCondition functor_guard_cond
FunctorReadCondition functor_read_cond
bool handlerExecuted
FunctorCondition functor_cond
class ConditionStore

Public Functions

inline ConditionStore(const dds::core::cond::Condition &c)
inline const dds::core::cond::Condition &get()

Private Members

const dds::core::cond::Condition cond
class Conversions : public Test

Fixture for the Topic tests

Public Functions

inline Conversions()
inline void CreateParticipant()
inline void CreatePublisher()
inline void CreateSubscriber()
inline void CreateTopic()
inline void CreateWriter()
inline void CreateReader()
inline void SetUp()
inline void TearDown()

Public Members

dds::domain::DomainParticipant participant
dds::pub::Publisher publisher
dds::sub::Subscriber subscriber
dds::topic::Topic<Space::Type1> topic
dds::pub::DataWriter<Space::Type1> writer
dds::sub::DataReader<Space::Type1> reader
class DataReader : public Test

Fixture for the DataReader tests

Public Functions

inline DataReader()
inline void SetUp()
inline void CreateParticipant()
inline void CreateTopic()
inline void CreateWriter()
inline void CreateReader()
inline void SetupWriter()
inline void SetupReader()
inline void SetupCommunication()
inline std::vector<Space::Type1> WriteData(int32_t instances_cnt)
inline void ReadFirstSamples(uint32_t cnt)
inline void CheckData(const dds::sub::LoanedSamples<Space::Type1> &samples, const std::vector<Space::Type1> &test_data, const dds::sub::status::DataState &test_state = dds::sub::status::DataState(dds::sub::status::SampleState::not_read(), dds::sub::status::ViewState::new_view(), dds::sub::status::InstanceState::alive()))
inline void CheckData(const std::vector<dds::sub::Sample<Space::Type1>> &samples, const std::vector<Space::Type1> &test_data)
inline void TearDown()

Public Members

dds::domain::DomainParticipant participant
dds::sub::Subscriber subscriber
dds::pub::Publisher publisher
dds::topic::Topic<Space::Type1> topic
dds::sub::DataReader<Space::Type1> reader
dds::pub::DataWriter<Space::Type1> writer
dds::sub::qos::DataReaderQos reliable_qos
dds::sub::qos::DataReaderQos timebased_qos
std::string partition
class DataReaderListener : public virtual dds::sub::NoOpDataReaderListener<HelloWorldData::Msg>

Public Functions

inline DataReaderListener()

Public Members

dds::sub::DataReader<HelloWorldData::Msg> requested_incompatible_qos_reader
dds::core::status::RequestedIncompatibleQosStatus requested_incompatible_qos_status
dds::sub::DataReader<HelloWorldData::Msg> subscription_matched_reader
dds::core::status::SubscriptionMatchedStatus subscription_matched_status
dds::sub::DataReader<HelloWorldData::Msg> data_available_reader
dds::sub::DataReader<HelloWorldData::Msg> sample_lost_reader
dds::core::status::SampleLostStatus sample_lost_status
dds::sub::DataReader<HelloWorldData::Msg> sample_rejected_reader
dds::core::status::SampleRejectedStatus sample_rejected_status
dds::sub::DataReader<HelloWorldData::Msg> liveliness_changed_reader
dds::core::status::LivelinessChangedStatus liveliness_changed_status

Protected Functions

inline virtual void on_requested_incompatible_qos(dds::sub::DataReader<HelloWorldData::Msg> &reader, const dds::core::status::RequestedIncompatibleQosStatus &status)
inline virtual void on_subscription_matched(dds::sub::DataReader<HelloWorldData::Msg> &reader, const dds::core::status::SubscriptionMatchedStatus &status)
inline virtual void on_data_available(dds::sub::DataReader<HelloWorldData::Msg> &reader)
inline virtual void on_sample_lost(dds::sub::DataReader<HelloWorldData::Msg> &reader, const dds::core::status::SampleLostStatus &status)
inline virtual void on_sample_rejected(dds::sub::DataReader<HelloWorldData::Msg> &reader, const dds::core::status::SampleRejectedStatus &status)
inline virtual void on_liveliness_changed(dds::sub::DataReader<HelloWorldData::Msg> &reader, const dds::core::status::LivelinessChangedStatus &status)
class DataReaderManipulatorSelector : public Test

Fixture for the DataReader tests

Public Functions

inline DataReaderManipulatorSelector()
inline void SetUp()
inline std::vector<Space::Type1> CreateSamples(int32_t instances_start, int32_t instances_end, int32_t samples_start, int32_t samples_end)
inline void WriteData(const std::vector<Space::Type1> &samples)
inline void CheckData(const dds::sub::LoanedSamples<Space::Type1> &samples, const std::vector<Space::Type1> &test_data, const dds::sub::status::DataState &test_state = dds::sub::status::DataState(dds::sub::status::SampleState::not_read(), dds::sub::status::ViewState::new_view(), dds::sub::status::InstanceState::alive()))
inline void CheckData(const std::vector<dds::sub::Sample<Space::Type1>> &samples, const std::vector<Space::Type1> &test_data, const dds::sub::status::DataState &test_state = dds::sub::status::DataState(dds::sub::status::SampleState::not_read(), dds::sub::status::ViewState::new_view(), dds::sub::status::InstanceState::alive()))
inline void TearDown()

Public Members

dds::domain::DomainParticipant participant
dds::sub::Subscriber subscriber
dds::pub::Publisher publisher
dds::topic::Topic<Space::Type1> topic
dds::sub::DataReader<Space::Type1> reader
dds::pub::DataWriter<Space::Type1> writer
dds::sub::status::DataState already_read
class DataReaderSelector : public Test

Fixture for the DataReader tests

Public Functions

inline DataReaderSelector()
inline void SetUp()
inline std::vector<Space::Type1> CreateSamples(int32_t instances_start, int32_t instances_end, int32_t samples_start, int32_t samples_end)
inline void WriteData(const std::vector<Space::Type1> &samples)
inline void CheckData(const dds::sub::LoanedSamples<Space::Type1> &samples, const std::vector<Space::Type1> &test_data, const dds::sub::status::DataState &test_state = dds::sub::status::DataState(dds::sub::status::SampleState::not_read(), dds::sub::status::ViewState::new_view(), dds::sub::status::InstanceState::alive()))
inline void CheckData(const std::vector<dds::sub::Sample<Space::Type1>> &samples, const std::vector<Space::Type1> &test_data, const dds::sub::status::DataState &test_state = dds::sub::status::DataState(dds::sub::status::SampleState::not_read(), dds::sub::status::ViewState::new_view(), dds::sub::status::InstanceState::alive()))
inline void TearDown()

Public Members

dds::domain::DomainParticipant participant
dds::sub::Subscriber subscriber
dds::pub::Publisher publisher
dds::topic::Topic<Space::Type1> topic
dds::sub::DataReader<Space::Type1> reader
dds::pub::DataWriter<Space::Type1> writer
dds::sub::status::DataState already_read
class DataWriter : public Test

Fixture for the DataWriter tests

Public Functions

inline DataWriter()
inline void SetUp()
inline void CreateParticipant()
inline void CreateTopic(bool order_source)
inline void CreateWriter(bool order_source)
inline void CreateReader(bool order_source)
inline void SetupWriter(bool order_source)
inline void SetupReader(bool order_source)
inline void SetupCommunication(bool order_source)
inline void GenerateDataInstanceHandle(const Space::Type1 &sample, dds::core::InstanceHandle &ih, bool order_source)
inline void ReadAndCheckAllType1(const std::vector<Space::Type1> &testDataList, const dds::sub::status::DataState &testState, bool take)
inline void ReadAndCheckSampleType1(const Space::Type1 &testData, const dds::sub::status::DataState &testState, bool take)
inline void TearDown()

Public Members

dds::domain::DomainParticipant participant
dds::sub::Subscriber subscriber
dds::pub::Publisher publisher
dds::topic::Topic<Space::Type1> topic
dds::sub::DataReader<Space::Type1> reader
dds::pub::DataWriter<Space::Type1> writer
dds::pub::qos::DataWriterQos besteffort_qos
dds::pub::qos::DataWriterQos lifespan_qos
std::string partition
class DataWriterListener : public virtual dds::pub::NoOpDataWriterListener<HelloWorldData::Msg>

Public Functions

inline DataWriterListener()

Public Members

dds::pub::DataWriter<HelloWorldData::Msg> offered_incompatible_qos_writer
dds::core::status::OfferedIncompatibleQosStatus offered_incompatible_qos_status
dds::pub::DataWriter<HelloWorldData::Msg> publication_matched_writer
dds::core::status::PublicationMatchedStatus publication_matched_status

Protected Functions

inline virtual void on_offered_incompatible_qos(dds::pub::DataWriter<HelloWorldData::Msg> &writer, const dds::core::status::OfferedIncompatibleQosStatus &status)
inline virtual void on_publication_matched(dds::pub::DataWriter<HelloWorldData::Msg> &writer, const ::dds::core::status::PublicationMatchedStatus &status)
class DomainParticipantListener : public virtual NoOpDomainParticipantListener

Public Functions

inline DomainParticipantListener()

Public Members

dds::sub::Subscriber data_on_readers_subscriber
dds::sub::AnyDataReader data_available_reader

Protected Functions

inline virtual void on_data_on_readers(dds::sub::Subscriber &subs)
inline virtual void on_data_available(dds::sub::AnyDataReader &reader)
class EntityStatus : public Test

Fixture for entity status tests

Public Functions

inline EntityStatus()
inline void SetUp()
inline void TearDown()

Public Members

dds::domain::DomainParticipant par
dds::pub::Publisher pub
dds::sub::Subscriber sub
dds::topic::Topic<HelloWorldData::Msg> topic
struct Endianness::Enums

Public Members

test_enum e_1
test_enum e_arr[4]
class org::eclipse::cyclonedds::core::utils::ExceptionFactory

Public Functions

inline ExceptionFactory()
inline ~ExceptionFactory()
inline void prepare(int32_t _code, const char *_file, int32_t _line, const char *_signature, const char *_descr)
inline void throw_exception()
inline std::string message()

Private Functions

inline void prepare_context()

Private Members

std::string description
std::string context
std::string function
std::string file
const char *signature
int32_t code
int32_t line
class FindDataReader : public Test

Fixture for the Topic finding and discovering tests

Public Functions

inline void SetUp()
inline void CreateReaders()

Public Members

dds::domain::DomainParticipant participant = dds::core::null
dds::sub::Subscriber subscriber = dds::core::null
dds::topic::Topic<Space::Type1> topic1 = dds::core::null
dds::topic::Topic<Space::Type2> topic2 = dds::core::null
dds::sub::DataReader<Space::Type1> reader1A = dds::core::null
dds::sub::DataReader<Space::Type1> reader1B = dds::core::null
dds::sub::DataReader<Space::Type2> reader2 = dds::core::null
class FindDataWriter : public Test

Fixture for the Topic finding and discovering tests

Public Functions

inline void SetUp()
inline void CreateWriters()

Public Members

dds::domain::DomainParticipant participant = dds::core::null
dds::pub::Publisher publisher = dds::core::null
dds::topic::Topic<Space::Type1> topic1 = dds::core::null
dds::topic::Topic<Space::Type2> topic2 = dds::core::null
dds::pub::DataWriter<Space::Type1> writer1A = dds::core::null
dds::pub::DataWriter<Space::Type1> writer1B = dds::core::null
dds::pub::DataWriter<Space::Type2> writer2 = dds::core::null
class FindTopic : public Test

Fixture for the Topic finding and discovering tests

Public Functions

inline void SetUp()
inline void CreateTopics()
inline void Create2ndParticipant()

Public Members

dds::domain::DomainParticipant dp = dds::core::null
dds::domain::DomainParticipant dp2 = dds::core::null
dds::topic::Topic<Space::Type1> topic1 = dds::core::null
dds::topic::Topic<Space::Type1> topic2 = dds::core::null
dds::topic::Topic<Space::Type1> topic3 = dds::core::null
dds::topic::Topic<Space::Type2> topic_ = dds::core::null
dds::topic::ContentFilteredTopic<Space::Type1> cfTopic1 = dds::core::null
dds::topic::ContentFilteredTopic<Space::Type1> cfTopic2 = dds::core::null
dds::topic::ContentFilteredTopic<Space::Type1> cfTopic3 = dds::core::null
std::map<std::string, dds::topic::Topic<Space::Type1>> topic1Map
std::map<std::string, dds::topic::Topic<Space::Type2>> topic2Map
std::vector<dds::topic::Topic<Space::Type1>> topicList
class FunctorCondition

Public Functions

inline FunctorCondition(bool &handlerExecuted)
inline void operator()()
inline void operator()(dds::core::cond::Condition&)

Private Members

bool &handlerExecuted
class FunctorGuardCondition

Public Functions

inline void operator()(dds::core::cond::Condition&)
class FunctorReadCondition

Public Functions

inline void operator()(dds::sub::cond::ReadCondition)
class FunctorReadConditionSample

Public Functions

inline FunctorReadConditionSample(const Space::Type1 &sample)
inline void operator()(const dds::sub::cond::ReadCondition &cond)

Private Members

const Space::Type1 &expectedSample
class FunctorStatusCondition

Public Functions

inline void operator()(dds::core::cond::StatusCondition)
struct guard_thread_args

Public Functions

inline guard_thread_args()

Public Members

dds::core::cond::GuardCondition *guard
dds_duration_t delay
class GuardCondHandler

Public Functions

inline GuardCondHandler(bool &guardHandlerExecuted)
inline void operator()()
inline void operator()(dds::core::cond::Condition&)

Private Members

bool &guardHandlerExecuted
class Listener : public Test

Public Functions

inline Listener()
inline void SetUp()
inline void TearDown()

Public Members

dds::domain::DomainParticipant participant
dds::topic::Topic<HelloWorldData::Msg> topic
dds::pub::Publisher publisher
dds::sub::Subscriber subscriber
class listener_stress : public Test

Fixture for listener stress tests

Public Functions

inline listener_stress()
inline void SetUp()
inline void create_readers(dds::sub::Subscriber &sub_, dds::topic::Topic<HelloWorldData::Msg> &topic_, bool withListener)
inline void TearDown()

Public Members

dds::domain::DomainParticipant dp
dds::topic::Topic<HelloWorldData::Msg> topic
dds::pub::Publisher pub
dds::sub::Subscriber sub
TestDomainParticipantListener participantListener
TestSubscriberListener subListener
ddsrt_thread_t threadId[20]
ddsrt_threadattr_t threadAttr
dds_duration_t delay = 200000000
struct HelloWorldData::Msg

Public Members

long userID

User ID

string message

message

struct Bounded::Msg

Public Types

typedef sequence<long, 255> bounded_sequence
typedef sequence<boolean, 255> boolean_sequence

Public Members

string<255> bounded_string
struct Endianness::Msg

Public Members

char chars[3]
unsigned long l
class Publisher : public Test

Fixture for the DataWriter tests

Public Functions

inline Publisher()
inline void SetUp()
inline void CreatePublisher()
inline void TearDown()

Public Members

dds::domain::DomainParticipant participant
dds::pub::Publisher publisher
std::string partition
dds::pub::qos::PublisherQos partition_qos
class PublisherListener : public virtual NoOpPublisherListener

Public Functions

inline PublisherListener()

Public Members

dds::pub::AnyDataWriter publication_matched_writer
dds::core::status::PublicationMatchedStatus publication_matched_status

Protected Functions

inline virtual void on_publication_matched(dds::pub::AnyDataWriter &writer, const ::dds::core::status::PublicationMatchedStatus &status)
class Query : public Test

Fixture for the DataReader tests

Public Functions

inline Query()
inline void SetUp()
inline void check(const dds::sub::Query &query, const std::string &expected_expression, const std::vector<std::string> &expected_params)
inline void TearDown()

Public Members

dds::domain::DomainParticipant participant
dds::sub::Subscriber subscriber
dds::topic::Topic<Space::Type1> topic
dds::sub::DataReader<Space::Type1> reader
std::vector<std::string> params
std::string expression
class ReadCondHandler

Public Functions

inline ReadCondHandler(bool &readHandlerExecuted)
inline void operator()(dds::sub::DataReader<Space::Type1>&)
inline void operator()(dds::core::cond::Condition&)

Private Members

bool &readHandlerExecuted
struct org::eclipse::cyclonedds::sub::ReaderCopyInfo

Public Members

const org::eclipse::cyclonedds::sub::AnyDataReaderDelegate *helper
const void *key
struct Endianness::SeqEnums

Public Types

typedef sequence<test_enum> e_seq
struct Endianness::Seqs

Public Types

typedef sequence<boolean> b_seq
typedef sequence<char> c_seq
typedef sequence<short> s_seq
typedef sequence<long> l_seq
typedef sequence<long long> ll_seq
class Serdata : public Test

Fixture for the tests

Public Functions

inline Serdata()
inline void SetUp()
inline void TearDown()
inline Endianness::Msg &getMsg(endianness end)
template<typename T>
inline void validate(const T &msg, const std::vector<uint8_t> &exp_le, const std::vector<uint8_t> &exp_be)

Public Members

ddsi_sertype *m_st = nullptr

Private Functions

template<typename T>
inline void validate_impl(const T &msg, const std::vector<uint8_t> &exp, bool swap)

Private Members

ddscxx_serdata<Endianness::Msg> *sd = nullptr
unsigned char *ptr = nullptr
template<class T>
class SharedMemoryTest : public RouDi_GTest

Fixture for the shared memory tests with RouDi

Public Types

using TopicType = T

Public Functions

inline SharedMemoryTest()
inline void SetUp()
inline void CreateParticipant()
inline void CreateTopic()
inline void CreateWriter(dds::pub::qos::DataWriterQos w_qos)
inline void CreateReader(dds::sub::qos::DataReaderQos r_qos)
inline void SetupWriter()
inline void SetupReader()
inline void SetupCommunication(dds::sub::qos::DataReaderQos r_qos = dds::sub::qos::DataReaderQos{}, dds::pub::qos::DataWriterQos w_qos = dds::pub::qos::DataWriterQos{})
inline void WaitForData()
inline std::vector<T> WriteData(const int32_t instances_cnt)
inline void CheckData(const dds::sub::LoanedSamples<T> &samples, const std::vector<T> &test_data, const dds::sub::status::DataState &test_state = dds::sub::status::DataState(dds::sub::status::SampleState::not_read(), dds::sub::status::ViewState::new_view(), dds::sub::status::InstanceState::alive()))
inline void run_communication_test(const dds::sub::qos::DataReaderQos &r_qos, const dds::pub::qos::DataWriterQos &w_qos, const int32_t num_samples)
inline void run_loan_support_api_test(const bool valid_r_shm_qos, const bool valid_w_shm_qos)
inline void TearDown()

Public Members

dds::domain::DomainParticipant participant
dds::sub::Subscriber subscriber
dds::pub::Publisher publisher
dds::topic::Topic<T> topic
dds::sub::DataReader<T> reader
dds::pub::DataWriter<T> writer
dds::sub::cond::ReadCondition rc
dds::core::cond::WaitSet waitset
class StatusCondHandler

Public Functions

inline StatusCondHandler(bool &statusHandlerExecuted)
inline void operator()(dds::core::Entity&)
inline void operator()(dds::core::cond::Condition&)

Private Members

bool &statusHandlerExecuted
class Subscriber : public Test

Fixture for the DataReader tests

Public Functions

inline Subscriber()
inline void SetUp()
inline void CreateSubscriber()
inline void TearDown()

Public Members

dds::domain::DomainParticipant participant
dds::sub::Subscriber subscriber
std::string partition
dds::sub::qos::SubscriberQos partition_qos
class SubscriberListener : public virtual NoOpSubscriberListener

Public Functions

inline SubscriberListener()

Public Members

dds::sub::AnyDataReader subscription_matched_reader
dds::core::status::SubscriptionMatchedStatus subscription_matched_status
dds::sub::Subscriber data_on_readers_subscriber
dds::sub::AnyDataReader data_available_reader

Protected Functions

inline virtual void on_subscription_matched(dds::sub::AnyDataReader &reader, const dds::core::status::SubscriptionMatchedStatus &status)
inline virtual void on_data_on_readers(dds::sub::Subscriber &subs)
inline virtual void on_data_available(dds::sub::AnyDataReader &reader)
struct test_semaphore

Public Functions

inline test_semaphore()
inline ~test_semaphore()

Public Members

ddsrt_cond_t cond
ddsrt_mutex_t mutex
int value
class TestDataReaderListener : public virtual dds::sub::NoOpDataReaderListener<HelloWorldData::Msg>

Public Functions

inline TestDataReaderListener()

Protected Functions

inline virtual void on_data_available(dds::sub::DataReader<HelloWorldData::Msg>&)
class TestDomainParticipantListener : public virtual NoOpDomainParticipantListener

Public Functions

inline TestDomainParticipantListener()

Protected Functions

inline virtual void on_data_available(dds::sub::AnyDataReader&)
class TestPublisherListener : public virtual NoOpPublisherListener
class TestReader1Listener : public virtual dds::sub::NoOpDataReaderListener<Space::Type1>

Trying to use the operator>> to get the QoS, causes a compile error because it can’t decide to choose between operator>>(qos) and operator>>(functor). Dummy listener for the DataWriter tests

class TestSubscriberListener : public virtual NoOpSubscriberListener

Public Functions

inline TestSubscriberListener()

Protected Functions

inline virtual void on_data_available(dds::sub::AnyDataReader&)
class TestTopic1Listener : public virtual dds::topic::NoOpTopicListener<Space::Type1>

Dummy listener for the Topic tests

class TestWriter1Listener : public virtual dds::pub::NoOpDataWriterListener<Space::Type1>

Dummy listener for the DataWriter tests

class Topic : public Test

Fixture for the Topic tests

Public Functions

inline Topic()
inline void SetUp()
inline void CreateTopic()
inline void CreateTopics()
inline void TearDown()

Public Members

dds::domain::DomainParticipant participant
dds::topic::Topic<Space::Type1> topic
dds::topic::Topic<Space::Type1> topic1A
dds::topic::Topic<Space::Type1> topic1B
dds::topic::Topic<Space::Type2> topic2A
dds::topic::Topic<Space::Type2> topic2B
dds::topic::qos::TopicQos reliable_qos
dds::topic::qos::TopicQos lifespan_qos
class TopicListener : public virtual dds::topic::NoOpTopicListener<HelloWorldData::Msg>
struct Space::Type1

Public Members

long long_1
long long_2
long long_3
struct Space::Type2

Public Members

long long_1
long long_2
long long_3
Enumeration enum_1
union Endianness::U

Public Members

double d
string str
default __pad0__
struct Endianness::UnionStr

Public Members

U u
class WaitSet : public Test

Fixture for the tests

Public Functions

inline WaitSet()
inline void SetUp()
inline void TearDown()

Public Members

dds::domain::DomainParticipant participant
dds::pub::Publisher publisher
dds::sub::Subscriber subscriber
dds::topic::Topic<Space::Type1> topic
dds::pub::DataWriter<Space::Type1> writer
dds::sub::DataReader<Space::Type1> reader
dds::core::cond::WaitSet waitSet
dds::sub::cond::ReadCondition readerCond
dds::core::cond::StatusCondition readerStatus
dds::core::cond::GuardCondition guard
dds::core::status::StatusMask statusMask
bool statusHandlerExecuted
bool guardHandlerExecuted
StatusCondHandler statusCondHandler
GuardCondHandler guardCondHandler
writer_thread_args writerThreadArgs
guard_thread_args guardThreadArgs
action_thread_args actionThreadArgs
ddsrt_thread_t threadId
ddsrt_threadattr_t threadAttr
test_semaphore start_sem
test_semaphore ready_sem
struct writer_thread_args

Public Functions

inline writer_thread_args()

Public Members

dds::pub::DataWriter<Space::Type1> *writer
dds_duration_t delay
namespace [anonymous]
namespace Bounded
namespace dds
namespace core
namespace policy
namespace status
namespace dds::domain

Functions

void ignore(const dds::domain::DomainParticipant &dp, const dds::core::InstanceHandle &handle)
namespace qos
namespace dds::pub

Functions

void ignore(const dds::domain::DomainParticipant &dp, const dds::core::InstanceHandle &handle)
namespace qos
namespace dds::sub

Functions

void ignore(const dds::domain::DomainParticipant &dp, const dds::core::InstanceHandle &handle)
const Subscriber builtin_subscriber(const dds::domain::DomainParticipant &dp)
namespace qos
namespace status
namespace qos
namespace Endianness

Enums

enum test_enum

Values:

enumerator zeroth
enumerator first
enumerator second
enumerator third
enumerator fourth
enumerator fifth
namespace HelloWorldData
namespace org
namespace eclipse
namespace cyclonedds
namespace core
namespace cdr
namespace policy
namespace org::eclipse::cyclonedds::core::utils

Functions

std::string &pretty_function(std::string &s)
std::string &convert_classname(std::string &s)
namespace domain
namespace qos
namespace pub
namespace qos
namespace org::eclipse::cyclonedds::sub

Functions

template<typename T>
dds::sub::DataReader<T> create_builtin_reader(SubscriberDelegate &subscriber, const std::string &topic_name)
namespace qos
namespace org::eclipse::cyclonedds::topic

Functions

dds::topic::TopicDescription find_topic_description(const dds::domain::DomainParticipant &dp, const std::string &topic_name)
dds::topic::AnyTopic find_any_topic(const dds::domain::DomainParticipant &dp, const std::string &topic_name)
bool simple_key(const std::vector<unsigned char> &in, ddsi_keyhash_t &out)
bool complex_key(const std::vector<unsigned char> &in, ddsi_keyhash_t &out)
namespace qos
namespace Space

Enums

enum Enumeration

Values:

enumerator VALUE1
enumerator VALUE2
file CMakeLists.txt

Functions

include (GenerateExportHeader) set(sources src/dds/core/Duration.cpp src/dds/core/Exception.cpp src/dds/core/Reference.cpp src/dds/core/Time.cpp src/dds/core/policy/CorePolicy.cpp src/dds/core/status/State.cpp src/dds/domain/discovery.cpp src/dds/domain/find.cpp src/dds/pub/pubdiscovery.cpp src/dds/sub/subdiscovery.cpp src/dds/sub/subfind.cpp src/dds/sub/status/DataState.cpp src/org/eclipse/cyclonedds/core/Mutex.cpp src/org/eclipse/cyclonedds/core/ObjectDelegate.cpp src/org/eclipse/cyclonedds/core/DDScObjectDelegate.cpp src/org/eclipse/cyclonedds/core/ObjectSet.cpp src/org/eclipse/cyclonedds/core/EntityDelegate.cpp src/org/eclipse/cyclonedds/core/ReportUtils.cpp src/org/eclipse/cyclonedds/core/ListenerDispatcher.cpp src/org/eclipse/cyclonedds/core/InstanceHandleDelegate.cpp src/org/eclipse/cyclonedds/core/EntitySet.cpp src/org/eclipse/cyclonedds/core/MiscUtils.cpp src/org/eclipse/cyclonedds/core/cdr/cdr_stream.cpp src/org/eclipse/cyclonedds/core/cond/ConditionDelegate.cpp src/org/eclipse/cyclonedds/core/cond/GuardConditionDelegate.cpp src/org/eclipse/cyclonedds/core/cond/StatusConditionDelegate.cpp src/org/eclipse/cyclonedds/core/cond/WaitSetDelegate.cpp src/org/eclipse/cyclonedds/core/policy/PolicyDelegate.cpp src/org/eclipse/cyclonedds/domain/Domain.cpp src/org/eclipse/cyclonedds/domain/DomainWrap.cpp src/org/eclipse/cyclonedds/domain/DomainParticipantDelegate.cpp src/org/eclipse/cyclonedds/domain/DomainParticipantRegistry.cpp src/org/eclipse/cyclonedds/domain/qos/DomainParticipantQosDelegate.cpp src/org/eclipse/cyclonedds/pub/AnyDataWriterDelegate.cpp src/org/eclipse/cyclonedds/pub/PublisherDelegate.cpp src/org/eclipse/cyclonedds/pub/qos/DataWriterQosDelegate.cpp src/org/eclipse/cyclonedds/pub/qos/PublisherQosDelegate.cpp src/org/eclipse/cyclonedds/sub/qos/DataReaderQosDelegate.cpp src/org/eclipse/cyclonedds/sub/AnyDataReaderDelegate.cpp src/org/eclipse/cyclonedds/sub/SubscriberDelegate.cpp src/org/eclipse/cyclonedds/sub/BuiltinSubscriberDelegate.cpp src/org/eclipse/cyclonedds/sub/QueryDelegate.cpp src/org/eclipse/cyclonedds/sub/cond/ReadConditionDelegate.cpp src/org/eclipse/cyclonedds/sub/cond/QueryConditionDelegate.cpp src/org/eclipse/cyclonedds/sub/qos/SubscriberQosDelegate.cpp src/org/eclipse/cyclonedds/topic/find.cpp src/org/eclipse/cyclonedds/topic/hash.cpp src/org/eclipse/cyclonedds/topic/AnyTopicDelegate.cpp src/org/eclipse/cyclonedds/topic/FilterDelegate.cpp src/org/eclipse/cyclonedds/topic/TopicDescriptionDelegate.cpp src/org/eclipse/cyclonedds/topic/qos/TopicQosDelegate.cpp) if(BUILD_SHARED_LIBS OR NOT DEFINED BUILD_SHARED_LIBS) add_library(ddscxx SHARED $
else () add_library(ddscxx $
endif () set_target_properties(ddscxx PROPERTIES VERSION $
file CMakeLists.txt

Functions

find_package (GTest REQUIRED) idlcxx_generate(TARGET ddscxx_test_types FILES data/Space.idl data/HelloWorldData.idl data/Serialization.idl) configure_file(config_simple.xml.in config_simple.xml @ONLY) if(ENABLE_SHM) find_package(iceoryx_posh REQUIRED) find_package(iceoryx_posh_roudi_environment REQUIRED) endif() set(sources Bounded.cpp EntityStatus.cpp Listener.cpp ListenerStress.cpp DomainParticipant.cpp Exception.cpp Conversions.cpp FindDataWriter.cpp FindDataReader.cpp FindTopic.cpp Topic.cpp Publisher.cpp Serdata.cpp Subscriber.cpp DataWriter.cpp DataReader.cpp DataReaderSelector.cpp DataReaderManipulatorSelector.cpp Duration.cpp Time.cpp Query.cpp WaitSet.cpp Qos.cpp Condition.cpp Util.cpp) if(ENABLE_SHM) list(APPEND sources SharedMemory.cpp) endif() add_executable(ddscxx_tests $
file Duration.cpp
#include <>
#include <>
#include <>
#include <>
#include <>

Defines

MS
MiS
NS
file Duration.cpp
#include “”
#include <>

Functions

static dds::core::Duration dur_3s5ns_base (3, 5)
static dds::core::Duration dur_2s4ns (2, 4)
static dds::core::Duration dur_2s5ns (2, 5)
static dds::core::Duration dur_2s6ns (2, 6)
static dds::core::Duration dur_3s4ns (3, 4)
static dds::core::Duration dur_3s5ns (3, 5)
static dds::core::Duration dur_3s6ns (3, 6)
static dds::core::Duration dur_4s4ns (4, 4)
static dds::core::Duration dur_4s5ns (4, 5)
static dds::core::Duration dur_4s6ns (4, 6)
TEST(Duration, plus)
TEST(Duration, plus_is)
TEST(Duration, minus)
TEST(Duration, minus_is)
TEST(Duration, times)
TEST(Duration, times_is)
TEST(Duration, divide)
TEST(Duration, nanosec)
TEST(Duration, microsec)
TEST(Duration, millisec)
TEST(Duration, sec)
TEST(Duration, greater)
TEST(Duration, greater_then)
TEST(Duration, equals)
TEST(Duration, not_equals)
TEST(Duration, less_then)
TEST(Duration, less)
TEST(Duration, compare)
file Exception.cpp
#include <>
#include <>

Defines

DEFINE_LE_EXCEPTION(EXP)
DEFINE_RE_EXCEPTION(EXP)
file Exception.cpp
#include “”
#include <>

Functions

TEST(Exception, Error)
TEST(Exception, InvalidDataError)
TEST(Exception, PreconditionNotMetError)
TEST(Exception, UnsupportedError)
TEST(Exception, NotEnabledError)
TEST(Exception, InconsistentPolicyError)
TEST(Exception, ImmutablePolicyError)
TEST(Exception, AlreadyClosedError)
TEST(Exception, IllegalOperationError)
TEST(Exception, OutOfResourcesError)
TEST(Exception, TimeoutError)
TEST(Exception, InvalidDowncastError)
TEST(Exception, NullReferenceError)
TEST(Exception, InvalidArgumentError)
file CorePolicy.cpp
#include <>
#include <>
file Reference.cpp
#include <>
file State.cpp
#include <>
file Time.cpp
#include <>
#include <>
#include <>
#include <>
#include <>

Defines

MS
MiS
NS

Functions

const dds::core::Time operator+(const dds::core::Time &lhs, const dds::core::Duration &rhs)
const dds::core::Time operator+(const dds::core::Duration &lhs, const dds::core::Time &rhs)
const dds::core::Time operator-(const dds::core::Time &lhs, const dds::core::Duration &rhs)
file Time.cpp
#include “”
#include <>

Functions

static dds::core::Time time_3s5ns_base (3, 5)
static dds::core::Time time_2s4ns (2, 4)
static dds::core::Time time_2s5ns (2, 5)
static dds::core::Time time_2s6ns (2, 6)
static dds::core::Time time_3s4ns (3, 4)
static dds::core::Time time_3s5ns (3, 5)
static dds::core::Time time_3s6ns (3, 6)
static dds::core::Time time_4s4ns (4, 4)
static dds::core::Time time_4s5ns (4, 5)
static dds::core::Time time_4s6ns (4, 6)
TEST(Time, plus)
TEST(Time, plus_is)
TEST(Time, minus)
TEST(Time, minus_is)
TEST(Time, nanosec)
TEST(Time, microsec)
TEST(Time, millisec)
TEST(Time, sec)
TEST(Time, greater)
TEST(Time, greater_then)
TEST(Time, equals)
TEST(Time, not_equals)
TEST(Time, less_then)
TEST(Time, less)
TEST(Time, compare)
file discovery.cpp
#include <>
file find.cpp
#include <>
file find.cpp
#include <>
file pubdiscovery.cpp
#include <>
file DataState.cpp
#include <>
file subdiscovery.cpp
#include <>
file subfind.cpp
#include <>
file cdr_stream.cpp
#include <>
#include <>
#include <>
#include <>
file ConditionDelegate.cpp
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include “”
file GuardConditionDelegate.cpp
#include <>
#include <>
file ShadowParticipant.cpp
#include <>
#include “”
file StatusConditionDelegate.cpp
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include “”
file WaitSetDelegate.cpp
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
file DDScObjectDelegate.cpp
#include <>
#include <>
#include <>
#include “”
file EntityDelegate.cpp
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include “”
#include “”
#include <>
file EntitySet.cpp
#include <>
#include <>
file InstanceHandleDelegate.cpp
#include <>
#include “”
file ListenerDispatcher.cpp
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include “”

Defines

DDS_FN_EXPORT

Functions

void callback_on_inconsistent_topic(dds_entity_t topic, dds_inconsistent_topic_status_t status, void *arg)
void callback_on_offered_deadline_missed(dds_entity_t writer, dds_offered_deadline_missed_status_t status, void *arg)
void callback_on_offered_incompatible_qos(dds_entity_t writer, dds_offered_incompatible_qos_status_t status, void *arg)
void callback_on_liveliness_lost(dds_entity_t writer, dds_liveliness_lost_status_t status, void *arg)
void callback_on_publication_matched(dds_entity_t writer, dds_publication_matched_status_t status, void *arg)
void callback_on_requested_deadline_missed(dds_entity_t reader, dds_requested_deadline_missed_status_t status, void *arg)
void callback_on_requested_incompatible_qos(dds_entity_t reader, dds_requested_incompatible_qos_status_t status, void *arg)
void callback_on_sample_rejected(dds_entity_t reader, dds_sample_rejected_status_t status, void *arg)
void callback_on_liveliness_changed(dds_entity_t reader, dds_liveliness_changed_status_t status, void *arg)
void callback_on_data_available(dds_entity_t reader, void *arg)
void callback_on_subscription_matched(dds_entity_t reader, dds_subscription_matched_status_t status, void *arg)
void callback_on_sample_lost(dds_entity_t reader, dds_sample_lost_status_t status, void *arg)
void callback_on_data_readers(dds_entity_t subscriber, void *arg)
file MiscUtils.cpp
#include <>
#include “”
#include “”
file Mutex.cpp
#include <>
#include “”
#include “”
file ObjectDelegate.cpp
#include “”
#include <>
file ObjectSet.cpp
#include <>
#include <>
file PolicyDelegate.cpp
#include <>
#include <>
#include <>
#include <>
#include “”
#include “”
file ReportUtils.cpp
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>

Defines

ISOCPP_REPORT_BUFLEN
file Domain.cpp
#include “”
#include “”
file DomainParticipantDelegate.cpp
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
file DomainParticipantRegistry.cpp
#include <>
file DomainWrap.cpp
#include <>
#include <>
#include <>
file DomainParticipantQosDelegate.cpp
#include <>
#include <>
#include <>
file AnyDataWriterDelegate.cpp
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include “”
#include “”
file PublisherDelegate.cpp
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
file DataWriterQosDelegate.cpp
#include <>
#include <>
#include <>
file PublisherQosDelegate.cpp
#include <>
#include <>
#include <>
file AnyDataReaderDelegate.cpp
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include “”
#include “”
#include “”
file BuiltinSubscriberDelegate.cpp
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include “”
file QueryConditionDelegate.cpp
#include <>
#include <>
file ReadConditionDelegate.cpp
#include <>
#include <>
#include <>
file DataReaderQosDelegate.cpp
#include <>
#include <>
#include <>
file SubscriberQosDelegate.cpp
#include <>
#include <>
#include <>
file QueryDelegate.cpp
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
file SubscriberDelegate.cpp
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
#include <>
file AnyTopicDelegate.cpp
#include <>
#include <>
#include <>
#include <>
#include “”

Defines

MAX_TOPIC_NAME_LENGTH
file FilterDelegate.cpp
#include <>
file hash.cpp
#include <>
#include “”
#include <>
file TopicQosDelegate.cpp
#include <>
#include <>
#include <>
file TopicDescriptionDelegate.cpp
#include <>
#include <>
file Bounded.cpp
#include <>
#include <>
#include “Util.hpp”
#include “”
#include “”

Functions

TEST_F(Bounds, strings)

Test writing below, at and beyond bound (255 chars)

TEST_F(Bounds, sequence)

Test writing below, at and beyond bound (255 chars)

TEST_F(Bounds, boolean)

Test writing below, at and beyond bound (255 chars)

file Condition.cpp
#include <>
#include “”
#include “”

Functions

template<typename T>
void wait_for_data(dds::sub::DataReader<T> dr)
TEST_F(Condition, create)

Test creating conditions (status, guard and read)

TEST_F(Condition, handler)

Test handlers for conditions (tested on GuardCondition)

TEST_F(Condition, status_condition)

Test StatusCondition

TEST_F(Condition, status_condition_entity)

Test creating status condition on all entities

TEST_F(Condition, guard_condition)

Test GuardCondition

TEST_F(Condition, read_condition)

Test ReadCondition

TEST_F(Condition, read_condition_functor)

Test read condition functor

TEST_F(Condition, query_condition)

Test query condition

TEST_F(Condition, conversion_null)

Test conversion of null condition objects

TEST_F(Condition, conversion)

Test conversion of condition objects

TEST_F(Condition, conversion_invalid)

Test invalid conversion

file Conversions.cpp
#include <>
#include “”
#include “”

Functions

TEST_F(Conversions, participant_entity_to)

Tests

TEST_F(Conversions, participant_entity_from)
TEST_F(Conversions, participant_entity_null)
TEST_F(Conversions, participant_entity_invalid)
TEST_F(Conversions, participant_entity_implicit)
TEST_F(Conversions, publisher_entity_to)
TEST_F(Conversions, publisher_entity_from)
TEST_F(Conversions, publisher_entity_null)
TEST_F(Conversions, publisher_entity_invalid)
TEST_F(Conversions, publisher_entity_implicit)
TEST_F(Conversions, subscriber_entity_to)
TEST_F(Conversions, subscriber_entity_from)
TEST_F(Conversions, subscriber_entity_null)
TEST_F(Conversions, subscriber_entity_invalid)
TEST_F(Conversions, subscriber_entity_implicit)
TEST_F(Conversions, topic_any_to)
TEST_F(Conversions, topic_any_from)
TEST_F(Conversions, topic_any_null)
TEST_F(Conversions, topic_any_invalid)
TEST_F(Conversions, topic_any_implicit)
TEST_F(Conversions, topic_description_to)
TEST_F(Conversions, topic_description_from)
TEST_F(Conversions, topic_description_null)
TEST_F(Conversions, topic_description_invalid)
TEST_F(Conversions, topic_description_implicit)
TEST_F(Conversions, topic_entity_to)
TEST_F(Conversions, topic_entity_from)
TEST_F(Conversions, topic_entity_null)
TEST_F(Conversions, topic_entity_invalid)
TEST_F(Conversions, topic_entity_implicit)
TEST_F(Conversions, writer_any_to)
TEST_F(Conversions, writer_any_from)
TEST_F(Conversions, writer_any_null)
TEST_F(Conversions, writer_any_invalid)
TEST_F(Conversions, writer_any_implicit)
TEST_F(Conversions, writer_entity_to)
TEST_F(Conversions, writer_entity_from)
TEST_F(Conversions, writer_entity_null)
TEST_F(Conversions, writer_entity_invalid)
TEST_F(Conversions, writer_entity_implicit)
TEST_F(Conversions, reader_any_to)
TEST_F(Conversions, reader_any_from)
TEST_F(Conversions, reader_any_null)
TEST_F(Conversions, reader_any_invalid)
TEST_F(Conversions, reader_any_implicit)
TEST_F(Conversions, reader_entity_to)
TEST_F(Conversions, reader_entity_from)
TEST_F(Conversions, reader_entity_null)
TEST_F(Conversions, reader_entity_invalid)
TEST_F(Conversions, reader_entity_implicit)
file HelloWorldData.idl
file Serialization.idl
file Space.idl
file DataReader.cpp
#include <>
#include “”
#include “”

Functions

TEST_F(DataReader, null)

Tests Tests

TEST_F(DataReader, create_subscriber_null)
TEST_F(DataReader, create_topic_null)
TEST_F(DataReader, create_cftopic_null)
TEST_F(DataReader, create)
TEST_F(DataReader, subscriber)
TEST_F(DataReader, topic_description)
TEST_F(DataReader, qos_default)
TEST_F(DataReader, qos_nondefault_constructor)
TEST_F(DataReader, qos_immutable_constructor)
TEST_F(DataReader, qos_nondefault_set)
TEST_F(DataReader, qos_immutable_set)
TEST_F(DataReader, qos_nondefault_shift)
TEST_F(DataReader, qos_immutable_shift)
TEST_F(DataReader, read)
TEST_F(DataReader, read_no_data)
TEST_F(DataReader, read_shift_LoanedSamples)
TEST_F(DataReader, read_SamplesFWIterator)
TEST_F(DataReader, read_SamplesBIIterator)
TEST_F(DataReader, read_default_filter_read)
TEST_F(DataReader, read_default_filter_not_read)
TEST_F(DataReader, read_default_filter_new_view)
TEST_F(DataReader, read_default_filter_not_new_view)
TEST_F(DataReader, read_default_filter_alive)
TEST_F(DataReader, read_default_filter_not_alive_disposed)
TEST_F(DataReader, read_default_filter_not_alive_no_writers)
TEST_F(DataReader, take)
TEST_F(DataReader, take_no_data)
TEST_F(DataReader, take_SamplesFWIterator)
TEST_F(DataReader, take_SamplesBIIterator)
TEST_F(DataReader, take_default_filter_read)
TEST_F(DataReader, take_default_filter_not_read)
TEST_F(DataReader, take_default_filter_new_view)
TEST_F(DataReader, take_default_filter_not_new_view)
TEST_F(DataReader, take_default_filter_alive)
TEST_F(DataReader, take_default_filter_not_alive_disposed)
TEST_F(DataReader, take_default_filter_not_alive_no_writers)
TEST_F(DataReader, readtake1)
TEST_F(DataReader, readtake2)
TEST_F(DataReader, lookup_instance)
TEST_F(DataReader, key_value_by_sample)
TEST_F(DataReader, key_value_by_topic)
TEST_F(DataReader, use_after_close)
TEST_F(DataReader, use_after_deletion)

Variables

static TestReader1Listener reader1Listener
file DataReaderManipulatorSelector.cpp
#include <>
#include “”
#include “”

Functions

TEST_F(DataReaderManipulatorSelector, reader_null)

Tests

TEST_F(DataReaderManipulatorSelector, implicit_read)
TEST_F(DataReaderManipulatorSelector, implicit_take)
TEST_F(DataReaderManipulatorSelector, implicit_instance)
TEST_F(DataReaderManipulatorSelector, implicit_next_instance)
TEST_F(DataReaderManipulatorSelector, implicit_state)
TEST_F(DataReaderManipulatorSelector, implicit_content)
TEST_F(DataReaderManipulatorSelector, implicit_max_samples)
TEST_F(DataReaderManipulatorSelector, implicit_multiple)
TEST_F(DataReaderManipulatorSelector, explicit_read)
TEST_F(DataReaderManipulatorSelector, explicit_take)
TEST_F(DataReaderManipulatorSelector, explicit_instance)
TEST_F(DataReaderManipulatorSelector, explicit_next_instance)
TEST_F(DataReaderManipulatorSelector, explicit_state)
TEST_F(DataReaderManipulatorSelector, explicit_content)
TEST_F(DataReaderManipulatorSelector, explicit_max_samples)
TEST_F(DataReaderManipulatorSelector, explicit_multiple)
file DataReaderSelector.cpp
#include <>
#include “”
#include “Util.hpp”
#include “”

Functions

TEST_F(DataReaderSelector, reader_null)

Tests

TEST_F(DataReaderSelector, implicit)
TEST_F(DataReaderSelector, implicit_instance)
TEST_F(DataReaderSelector, implicit_next_instance)
TEST_F(DataReaderSelector, implicit_state)
TEST_F(DataReaderSelector, implicit_content)
TEST_F(DataReaderSelector, implicit_max_samples)
TEST_F(DataReaderSelector, implicit_multiple)
TEST_F(DataReaderSelector, read_LoanedSamples)
TEST_F(DataReaderSelector, read_LoanedSamples_instance)
TEST_F(DataReaderSelector, read_LoanedSamples_next_instance)
TEST_F(DataReaderSelector, read_LoanedSamples_state)
TEST_F(DataReaderSelector, read_LoanedSamples_content)
TEST_F(DataReaderSelector, read_LoanedSamples_max_samples)
TEST_F(DataReaderSelector, read_LoanedSamples_multiple)
TEST_F(DataReaderSelector, read_FWIterator)
TEST_F(DataReaderSelector, read_FWIterator_instance)
TEST_F(DataReaderSelector, read_FWIterator_next_instance)
TEST_F(DataReaderSelector, read_FWIterator_state)
TEST_F(DataReaderSelector, read_FWIterator_content)
TEST_F(DataReaderSelector, read_FWIterator_max_samples)
TEST_F(DataReaderSelector, read_FWIterator_multiple)
TEST_F(DataReaderSelector, read_BIIterator)
TEST_F(DataReaderSelector, read_BIIterator_instance)
TEST_F(DataReaderSelector, read_BIIterator_next_instance)
TEST_F(DataReaderSelector, read_BIIterator_state)
TEST_F(DataReaderSelector, read_BIIterator_content)
TEST_F(DataReaderSelector, read_BIIterator_max_samples)
TEST_F(DataReaderSelector, read_BIIterator_multiple)
TEST_F(DataReaderSelector, take_LoanedSamples)
TEST_F(DataReaderSelector, take_LoanedSamples_instance)
TEST_F(DataReaderSelector, take_LoanedSamples_next_instance)
TEST_F(DataReaderSelector, take_LoanedSamples_state)
TEST_F(DataReaderSelector, take_LoanedSamples_content)
TEST_F(DataReaderSelector, take_LoanedSamples_max_samples)
TEST_F(DataReaderSelector, take_LoanedSamples_multiple)
TEST_F(DataReaderSelector, take_FWIterator)
TEST_F(DataReaderSelector, take_FWIterator_instance)
TEST_F(DataReaderSelector, take_FWIterator_next_instance)
TEST_F(DataReaderSelector, take_FWIterator_state)
TEST_F(DataReaderSelector, take_FWIterator_content)
TEST_F(DataReaderSelector, take_FWIterator_max_samples)
TEST_F(DataReaderSelector, take_FWIterator_multiple)
TEST_F(DataReaderSelector, take_BIIterator)
TEST_F(DataReaderSelector, take_BIIterator_instance)
TEST_F(DataReaderSelector, take_BIIterator_next_instance)
TEST_F(DataReaderSelector, take_BIIterator_state)
TEST_F(DataReaderSelector, take_BIIterator_content)
TEST_F(DataReaderSelector, take_BIIterator_max_samples)
TEST_F(DataReaderSelector, take_BIIterator_multiple)
file DataWriter.cpp
#include “”
#include <>
#include “”

Functions

TEST_F(DataWriter, null)

Tests

TEST_F(DataWriter, create_publisher_null)
TEST_F(DataWriter, create_topic_null)
TEST_F(DataWriter, create)
TEST_F(DataWriter, publisher)
TEST_F(DataWriter, topic_description)
TEST_F(DataWriter, qos_default)
TEST_F(DataWriter, qos_nondefault_constructor)
TEST_F(DataWriter, qos_immutable_constructor)
TEST_F(DataWriter, qos_nondefault_set)
TEST_F(DataWriter, qos_immutable_set)
TEST_F(DataWriter, qos_nondefault_shift)
TEST_F(DataWriter, qos_immutable_shift)
TEST_F(DataWriter, write_data)
TEST_F(DataWriter, write_InstanceHandle)
TEST_F(DataWriter, write_TopicInstance)
TEST_F(DataWriter, write_iter)
TEST_F(DataWriter, write_data_with_timestamp)
TEST_F(DataWriter, write_InstanceHandle_with_timestamp)
TEST_F(DataWriter, write_TopicInstance_with_timestamp)
TEST_F(DataWriter, write_iter_with_timestamp)
TEST_F(DataWriter, writedispose)
TEST_F(DataWriter, dispose_instance)
TEST_F(DataWriter, dispose_instance_2nd)
TEST_F(DataWriter, dispose_instance_after_read)
TEST_F(DataWriter, matched_subscriptions_sequence)
TEST_F(DataWriter, matched_subscriptions_array)
TEST_F(DataWriter, shift_sample)
TEST_F(DataWriter, shift_pair_timestamp)
TEST_F(DataWriter, shift_pair_InstanceHandle)
TEST_F(DataWriter, lookup_instance)
TEST_F(DataWriter, unregister_instance)
TEST_F(DataWriter, unregister_instance_InstanceHandle)
TEST_F(DataWriter, unregister_instance_with_timestamp)
TEST_F(DataWriter, unregister_instance_InstanceHandle_with_timestamp)
TEST_F(DataWriter, register_instance_with_timestamp)
TEST_F(DataWriter, key_value_ti)
TEST_F(DataWriter, key_value_sample)
TEST_F(DataWriter, topic)
TEST_F(DataWriter, use_after_close)
TEST_F(DataWriter, use_after_deletion)

Variables

static TestWriter1Listener writer1Listener
file DomainParticipant.cpp
#include “”
#include <>
#include “”
#include “”
#include “”

Functions

TEST(DomainParticipant, null)
TEST(DomainParticipant, create_with_conf)
TEST(DomainParticipant, create_with_str_conffile)
TEST(DomainParticipant, create_with_str_conf)
TEST(DomainParticipant, recreate_with_str_conf)
TEST(DomainParticipant, create_with_str_conf_default)
TEST(DomainParticipant, create_with_str_conf_invalid)
TEST(DomainParticipant, create_without_conf)
TEST(DomainParticipant, create_multiple)
TEST(DomainParticipant, create_invalid)
TEST(DomainParticipant, recreate_after_delete)
TEST(DomainParticipant, recreate_after_close)
TEST(DomainParticipant, use_after_close)
TEST(DomainParticipant, use_after_deletion)
TEST(DomainParticipant, find_none)
TEST(DomainParticipant, find_wrong)
TEST(DomainParticipant, find_deleted)
TEST(DomainParticipant, find_one)
TEST(DomainParticipant, find_multiple)
TEST(DomainParticipant, find_first)
TEST(DomainParticipant, find_second)
TEST(DomainParticipant, ignore_none)
TEST(DomainParticipant, ignore_one)
TEST(DomainParticipant, non_default_constructor)
TEST(DomainParticipant, current_time)
TEST(DomainParticipant, default__qos)

Variables

static const char *simple_config_uri = "file://config_simple.xml"
static const std::string simple_config = "<CycloneDDS><Domain><Id>any</Id></Domain></CycloneDDS>"
TestDomainParticipantListener participantListener
file EntityStatus.cpp
#include <>
#include <>
#include “”
#include <>
#include “Util.hpp”
#include “”

Functions

TEST_F(EntityStatus, publication_matched)
TEST_F(EntityStatus, subscription_matched)
TEST_F(EntityStatus, incompatible_qos)
TEST_F(EntityStatus, sample_lost)
TEST_F(EntityStatus, sample_rejected)
TEST_F(EntityStatus, liveliness_changed)
file FindDataReader.cpp
#include <>
#include <>
#include “”
#include “”

Defines

TOPIC1_NAME
TOPIC2_NAME
TOPIC3_NAME

Functions

TEST_F(FindDataReader, BinIterator_tname_find_with_empty)

Tests

TEST_F(FindDataReader, BinIterator_tname_find_with_other_type)
TEST_F(FindDataReader, BinIterator_tname_find_nonexisting)
TEST_F(FindDataReader, BinIterator_tname_find)
TEST_F(FindDataReader, BinIterator_tname_find_any)
TEST_F(FindDataReader, BinIterator_tdesc_find_with_empty)
TEST_F(FindDataReader, BinIterator_tdesc_find_with_other_type)
TEST_F(FindDataReader, BinIterator_tdesc_find)
TEST_F(FindDataReader, BinIterator_tdesc_find_any)
TEST_F(FindDataReader, FwdIterator_tname_find_with_empty)
TEST_F(FindDataReader, FwdIterator_tname_find_with_other_type)
TEST_F(FindDataReader, FwdIterator_tname_find_nonexisting)
TEST_F(FindDataReader, FwdIterator_tname_find)
TEST_F(FindDataReader, FwdIterator_tname_find_any)
TEST_F(FindDataReader, FwdIterator_tdesc_find_with_empty)
TEST_F(FindDataReader, FwdIterator_tdesc_find_with_other_type)
TEST_F(FindDataReader, FwdIterator_tdesc_find)
TEST_F(FindDataReader, FwdIterator_tdesc_find_any)
TEST_F(FindDataReader, ignore)
file FindDataWriter.cpp
#include <>
#include <>
#include “”
#include “”

Defines

TOPIC1_NAME
TOPIC2_NAME

Functions

TEST_F(FindDataWriter, BinIterator_find_with_empty)

Tests

TEST_F(FindDataWriter, BinIterator_find_with_other_type)
TEST_F(FindDataWriter, BinIterator_find_nonexisting)
TEST_F(FindDataWriter, BinIterator_find)
TEST_F(FindDataWriter, BinIterator_find_any)
TEST_F(FindDataWriter, FwdIterator_find_with_empty)
TEST_F(FindDataWriter, FwdIterator_find_with_other_type)
TEST_F(FindDataWriter, FwdIterator_find_nonexisting)
TEST_F(FindDataWriter, FwdIterator_find)
TEST_F(FindDataWriter, FwdIterator_find_any)
TEST_F(FindDataWriter, ignore)
file FindTopic.cpp
#include “”
#include <>
#include “”
#include <>

Defines

TOPIC1_NAME_1
TOPIC1_NAME_2
TOPIC1_NAME_3
TOPIC__NAME
CF_TOPIC1_NAME_1
CF_TOPIC1_NAME_2
CF_TOPIC1_NAME_3

Functions

TEST_F(FindTopic, find_with_null)

Tests

TEST_F(FindTopic, find_with_empty)
TEST_F(FindTopic, find_with_other_type)
TEST_F(FindTopic, find_nonexisting)
TEST_F(FindTopic, find_first)
TEST_F(FindTopic, find_last)
TEST_F(FindTopic, find_any)
TEST_F(FindTopic, find_description)
TEST_F(FindTopic, discover_with_null)
TEST_F(FindTopic, discover_with_empty)
TEST_F(FindTopic, discover_with_other_type)
TEST_F(FindTopic, discover_nonexisting)
TEST_F(FindTopic, discover_first)
TEST_F(FindTopic, discover_last)
TEST_F(FindTopic, discover_any)
TEST_F(FindTopic, discover_description)
TEST_F(FindTopic, discover_list_with_null)
TEST_F(FindTopic, discover_list)
TEST_F(FindTopic, discover_on_2nd)
TEST_F(FindTopic, discover_any_on_2nd)
TEST_F(FindTopic, discover_description_on_2nd)
file Listener.cpp
#include <>
#include <>
#include <>
#include “”
#include “”
#include “”
#include “”
#include “Util.hpp”
#include “”

Functions

static uint32_t waitfor_cb(uint32_t expected, dds_time_t timeout)
static uint32_t waitfor_cb(uint32_t expected)
static void reset_cb()
TEST_F(Listener, participant_with_listener)
TEST_F(Listener, already_closed_participant)
TEST_F(Listener, participant_without_listener)
TEST_F(Listener, topic_without_listener)
TEST_F(Listener, topic_with_listener)
TEST_F(Listener, already_closed_topic)
TEST_F(Listener, publisher_without_listener)
TEST_F(Listener, publisher_with_listener)
TEST_F(Listener, already_closed_publisher)
TEST_F(Listener, subscriber_without_listener)
TEST_F(Listener, subscriber_with_listener)
TEST_F(Listener, already_closed_subscriber)
TEST_F(Listener, writer_without_listener)
TEST_F(Listener, writer_with_listener)
TEST_F(Listener, already_closed_writer)
TEST_F(Listener, reader_without_listener)
TEST_F(Listener, reader_with_listener)
TEST_F(Listener, already_closed_reader)
TEST_F(Listener, incorrect_listener_mask)
TEST_F(Listener, sample_lost)
TEST_F(Listener, sample_rejected)
TEST_F(Listener, liveliness_changed)
TEST_F(Listener, DISABLED_incompatible_qos)
TEST_F(Listener, publication_matched)
TEST_F(Listener, subscription_matched)
TEST_F(Listener, publication_subscription_matched)
TEST_F(Listener, data_available)
TEST_F(Listener, data_available_subscriber)
TEST_F(Listener, data_available_participant)
TEST_F(Listener, DISABLED_propagation)

Variables

static uint32_t cb_called = 0
static ddsrt_mutex_t g_mutex
static ddsrt_cond_t g_cond
file ListenerStress.cpp
#include <>
#include <>
#include “”
#include “”
#include “”
#include <>
#include “”

Defines

MAX_WRITERS
MAX_READERS

Functions

static uint32_t writer_thread(void *arg)
TEST_F(listener_stress, DISABLED_data_available_reader)
TEST_F(listener_stress, DISABLED_data_available_subscriber)
TEST_F(listener_stress, DISABLED_data_available_participant)

Variables

static ddsrt_mutex_t g_mutex
static bool stop_writer_thread = false
static std::vector<dds::pub::DataWriter<HelloWorldData::Msg>> writers
file Publisher.cpp
#include “”
#include <>
#include “”
#include “”

Functions

TEST_F(Publisher, null)

Tests

TEST_F(Publisher, create_multiple)
TEST_F(Publisher, non_default_constructor)
TEST_F(Publisher, wait_for_acknowledgments)
TEST_F(Publisher, participant)
TEST_F(Publisher, default__qos)
TEST_F(Publisher, use_after_close)
TEST_F(Publisher, use_after_deletion)

Variables

TestPublisherListener publisherListener
file Qos.cpp
#include “”
#include <>

Functions

dds::core::ByteSeq nonDefaultByteSeq (4, 0xAA)
UserData nonDefaultUserData(nonDefaultByteSeq)
EntityFactory nonDefaultEntityFactory (false)
TopicData nonDefaultTopicData(nonDefaultByteSeq)
Durability nonDefaultDurability(dds::core::policy::DurabilityKind::TRANSIENT_LOCAL)
Deadline nonDefaultDeadline (dds::core::Duration(100, 100))
LatencyBudget nonDefaultBudget (dds::core::Duration(5))
Liveliness nonDefaultLiveliness (dds::core::policy::LivelinessKind::MANUAL_BY_PARTICIPANT, dds::core::Duration(0, 8))
Reliability nonDefaultReliability (dds::core::policy::ReliabilityKind::RELIABLE, dds::core::Duration(8, 8))
DestinationOrder nonDefaultOrder(dds::core::policy::DestinationOrderKind::BY_SOURCE_TIMESTAMP)
History nonDefaultHistory (dds::core::policy::HistoryKind::KEEP_ALL, 17)
ResourceLimits nonDefaultResources (200, 10, 50)
TransportPriority nonDefaultPriority (19)
Lifespan nonDefaultLifespan(dds::core::Duration::zero())
Ownership nonDefaultOwnership(dds::core::policy::OwnershipKind::EXCLUSIVE)
Presentation nonDefaultPresentation (dds::core::policy::PresentationAccessScopeKind::TOPIC, true, false)
Partition nonDefaultPartition ("ExamplePartition")
GroupData nonDefaultGdata(nonDefaultByteSeq)
WriterDataLifecycle nonDefaultWdLifecycle (true)
TimeBasedFilter nonDefaultTbFilter (dds::core::Duration(14, 14))
ReaderDataLifecycle nonDefaultRdLifecycle (dds::core::Duration(1, 1), dds::core::Duration(2, 2))
TEST(Qos, DomainParticipant)
TEST(Qos, Topic)
TEST(Qos, Publisher)
TEST(Qos, Subscriber)
TEST(Qos, DataWriter)
TEST(Qos, DataReader)
TEST(Qos, invalid_values)
TEST(Qos, invalid_policies)
TEST(Qos, policy_name)

Variables

UserData tmpUserData
EntityFactory tmpEntityFactory
TopicData tmpTopicData
Durability tmpDurability
Deadline tmpDeadline
LatencyBudget tmpBudget
Liveliness tmpLiveliness
Reliability tmpReliability
DestinationOrder tmpOrder
History tmpHistory
ResourceLimits tmpResources
TransportPriority tmpPriority
Lifespan tmpLifespan
Ownership tmpOwnership
Presentation tmpPresentation
Partition tmpPartition
GroupData tmpGdata
WriterDataLifecycle tmpWdLifecycle
TimeBasedFilter tmpTbFilter
ReaderDataLifecycle tmpRdLifecycle
file Query.cpp
#include “”
#include <>
#include “”

Functions

TEST_F(Query, null)

Tests

TEST_F(Query, create_reader_null)
TEST_F(Query, create_params_none)
TEST_F(Query, create_params_vector)
TEST_F(Query, create_params_iter)
TEST_F(Query, expression)
TEST_F(Query, add_parameter)
TEST_F(Query, parameters)
file Serdata.cpp
#include <>
#include “”
#include “”
#include <>

Functions

TEST_F(Serdata, alignment)
TEST_F(Serdata, deserialization_big_endianness)
TEST_F(Serdata, deserialization_little_endianness)
TEST_F(Serdata, serialization_big_endianness)
TEST_F(Serdata, serialization_sequences)
TEST_F(Serdata, serialization_enums)
TEST_F(Serdata, serialization_unions)
file SharedMemory.cpp
#include <>
#include “”
#include “”
#include “”
#include “”
#include “”
#include “”

Defines

EXPECT_THROW_EXCEPTION(statement, error_msg)

Typedefs

using TestTypes = ::testing::Types<Space::Type1, HelloWorldData::Msg, Bounded::Msg>

Tests

Functions

TYPED_TEST_SUITE (SharedMemoryTest, TestTypes,)
TYPED_TEST(SharedMemoryTest, writer_reader_valid_shm_qos)
TYPED_TEST(SharedMemoryTest, writer_reader_default_qos)
TYPED_TEST(SharedMemoryTest, writer_valid_shm_qos)
TYPED_TEST(SharedMemoryTest, reader_valid_shm_qos)
TYPED_TEST(SharedMemoryTest, invalid_shm_qos)
TYPED_TEST(SharedMemoryTest, loan_sample)
file Subscriber.cpp
#include “”
#include <>
#include “”
#include “”

Functions

TEST_F(Subscriber, null)

Tests

TEST_F(Subscriber, create_multiple)
TEST_F(Subscriber, non_default_constructor)
TEST_F(Subscriber, participant)
TEST_F(Subscriber, default_qos)
TEST_F(Subscriber, use_after_close)
TEST_F(Subscriber, use_after_deletion)
TEST_F(Subscriber, builtin)

Variables

TestSubscriberListener subscriberListener
file Topic.cpp
#include “”
#include <>
#include “”

Functions

TEST_F(Topic, null)

Tests

TEST_F(Topic, create_null)
TEST_F(Topic, create)
TEST_F(Topic, create_same)
TEST_F(Topic, create_conflict)
TEST_F(Topic, name)
TEST_F(Topic, type_name_default)
TEST_F(Topic, type_name_nondefault)
TEST_F(Topic, domain_participant)
TEST_F(Topic, qos_default)
TEST_F(Topic, qos_nondefault_constructor)
TEST_F(Topic, qos_immutable_constructor)
TEST_F(Topic, qos_nondefault_set)
TEST_F(Topic, qos_immutable_set)
TEST_F(Topic, qos_nondefault_shift)
TEST_F(Topic, qos_immutable_shift)
TEST_F(Topic, inconsistent_topic_status)
TEST_F(Topic, close_busy)
TEST_F(Topic, traits)
TEST_F(Topic, use_after_close)
TEST_F(Topic, use_after_deletion)

Variables

TestTopic1Listener topic1Listener
file Util.cpp
#include “”
#include “”
#include “”
#include “”
#include “Util.hpp”

Functions

char *create_unique_topic_name(const char *prefix, char *name, size_t size)
file Util.hpp
#include <>
#include <>

Functions

char *create_unique_topic_name(const char *prefix, char *name, size_t size)
file WaitSet.cpp
#include <>
#include “”
#include “”
#include “”
#include “”
#include “Util.hpp”
#include “”

Defines

TA_ATTACH_REMOVE_CONDITION
TA_ATTACH_CLOSE_READER
TA_ADD_GUARD_CONDITION
TA_WAITSET_DESTRUCTOR

Functions

void test_sem_lock(test_semaphore *sem)
bool test_sem_wait(test_semaphore *sem, const dds_duration_t timeout)
void test_sem_post(test_semaphore *sem)
static uint32_t guard_thread(void *arg)
static uint32_t writer_thread(void *arg)
static uint32_t test_action_thread(void *arg)
TEST_F(WaitSet, null)

Test null assignment for WaitSets

TEST_F(WaitSet, create)

Test creating WaitSet

TEST_F(WaitSet, attach_conditions)

Test attach condition to WaitSet

TEST_F(WaitSet, wait_timeout)

Test wait() timeout

TEST_F(WaitSet, wait_reader_status)

Test waiting for StatusCondition

TEST_F(WaitSet, wait_reader_timeout)

Test timeout when waiting for StatusCondition

TEST_F(WaitSet, guard_trigger_during_wait)

Test GuardCondition trigger during wait

TEST_F(WaitSet, guard_trigger_before_wait)

Test GuardCondition trigger before wait

TEST_F(WaitSet, multiple_conditions)

Test adding multiple conditions to WaitSet

TEST_F(WaitSet, multiple_conditions_handlers)

Add multiple conditions to a WaitSet and check if all handlers functors are executed with a dispatch

TEST_F(WaitSet, dispatch_timeout)

Test the time-out for WaitSet dispatch function

TEST_F(WaitSet, multiple_conditions_same)

Check the same condition can be added more than once

TEST_F(WaitSet, detach_condition_nonexisting)

Check that a remove of a not attached condition returns false

TEST_F(WaitSet, attach_detach_during_wait)

Check that it is possible to remove and attach conditions while waiting

TEST_F(WaitSet, attach_detach_guard_during_wait)

Remove and add guard conditions while waiting

TEST_F(WaitSet, destructor)

Check if the waitset destructor does not deadlock

TEST_F(WaitSet, DISABLED_attach_detach_multiple_during_wait)

Check that it is possible to remove and attach multiple conditions while waiting

TODO: disabled because the conditions are currently not removed from the waitset

group ExamplesdcpsHelloWorldisocpp
dir /home/vsts/work/1
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse/cyclonedds/core/cdr
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse/cyclonedds/sub/cond
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse/cyclonedds/core/cond
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse/cyclonedds/core
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/dds/core
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse/cyclonedds
dir /home/vsts/work/1/s/repos/cyclonedds-cxx
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/tests/data
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/dds
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/dds/domain
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse/cyclonedds/domain
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse
dir /home
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse/cyclonedds/core/policy
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/dds/core/policy
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/dds/pub
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse/cyclonedds/pub
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse/cyclonedds/domain/qos
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse/cyclonedds/pub/qos
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse/cyclonedds/topic/qos
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse/cyclonedds/sub/qos
dir /home/vsts/work/1/s/repos
dir /home/vsts/work/1/s
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/dds/sub/status
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/dds/core/status
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/dds/sub
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse/cyclonedds/sub
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/tests
dir /home/vsts/work/1/s/repos/cyclonedds-cxx/src/ddscxx/src/org/eclipse/cyclonedds/topic
dir /home/vsts
dir /home/vsts/work