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
struct CDR_testing::appendablestruct

Public Functions

id (7) long l
key id (5) char c
id (3) string str
id (1) double d
struct ExtendedTypes_testing::appendablestruct_larger

Public Members

char c
char d
struct ExtendedTypes_testing::appendablestruct_smaller

Public Members

char c
struct CDR_testing::array_struct

Public Members

key char c [5]
long l[5]
struct CDR_testing::base

Subclassed by CDR_testing::derived

Public Members

string str
key char c
struct regression_models::Base

Subclassed by regression_models::Derived

Public Members

Nested Member_Base
struct CDR_testing::basicstruct

Public Members

long l
key char c
string str
double d
struct CDR_testing::bitmask_struct

Public Members

key bm1 c
bm2 d
union CDR_testing::bitmask_union

Public Members

bm1 c
bm2 d
unsigned short s
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
struct Keyhash::BStringKey

Public Members

key string< 11 > s
unsigned long x
class CDRStreamer : public Test

Fixture for the DataWriter tests

Public Functions

inline CDRStreamer()
inline void SetUp()
inline void TearDown()

Public Members

bytes BS_basic_normal{0x00, 0x01, 0xE2, 0x40, 'g', 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x07, 'a', 'b', 'c', 'd', 'e', 'f', '\0', 0x00, 0x00, 0x00, 0x00, 0x00, 0x40, 0x84, 0x72, 0x91, 0x68, 0x72, 0xB0, 0x21}
bytes BS_basic_key = {'g'}
bytes BS_xcdrv2_normal{0x00, 0x01, 0xE2, 0x40, 'g', 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x07, 'a', 'b', 'c', 'd', 'e', 'f', '\0', 0x00, 0x40, 0x84, 0x72, 0x91, 0x68, 0x72, 0xB0, 0x21}
bytes AS_xcdr_v2_normal{0x00, 0x00, 0x00, 0x1C, 0x00, 0x01, 0xE2, 0x40, 'g', 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x07, 'a', 'b', 'c', 'd', 'e', 'f', '\0', 0x00, 0x40, 0x84, 0x72, 0x91, 0x68, 0x72, 0xB0, 0x21}
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
struct CDR_testing::d_hdr_sequences

Public Types

typedef sequence<sequence<enum_8>> l

Public Members

key enum_8 c [4]
class DataModels : public Test

Fixture for the DataModels tests

Public Functions

inline DataModels()
inline void SetUp()
inline void TearDown()
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)
struct CDR_testing::derived : public CDR_testing::base

Public Members

string str_d
char c_d
struct regression_models::Derived : public regression_models::Base

Public Members

short Member_Derived
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)
union regression_models::duplicate_sequences_union

Public Members

seq_ulong_arr c_0
seq_ulong c_1
union regression_models::duplicate_types_union

Public Members

long l_1
td_l l_2
double d_1
s_1 s_s_1
s_2 s_s_2
default __pad0__
union regression_models::duplicate_types_union_2

Public Members

long b_1[5]
long_array_5 b_2
long_array_7 b_3
long b_4[2][3]
long_array_2 b_5[3]
long_array_6 b_6
long b_7
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
class EntityTesting : public Test

Fixture for the testing the generated entity properties

Public Functions

inline void SetUp()
inline void TearDown()
struct CDR_testing::enum_struct

Public Members

key enum_8 c
enum_16 b
enum_32 a
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
struct DataModels_testing::explicit_defaults_struct

Public Functions

default (123) long l
default (.456) double d
default ('a') char c
default ("def") string s
default (5) test_bitmask b
class ExtendedTypes : public Test

Fixture for the ExtendedTypes tests

Public Functions

inline ExtendedTypes()
inline void SetUp()
inline void TearDown()
template<class MSGIN, class MSGOUT, class S>
inline void validate(const MSGIN &in, bool exp_write_result = true, bool exp_read_result = true, bool exp_contents = true)
template<class MSGIN, class MSGOUT, class S>
inline void validate_deeper(const MSGIN &in, bool exp_write_result = true, bool exp_read_result = true, bool exp_contents = true)
struct external_testing::external_struct

Public Types

external sequence< double > external_sequence_double

Public Members

external long external_long
external string external_string
struct ExtendedTypes_testing::finalstruct_larger

Public Members

char c
char d
struct ExtendedTypes_testing::finalstruct_smaller

Public Members

char c
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
struct DataModels_testing::implicit_defaults_struct

Public Members

long l
double d
char c
string s
test_enum e
test_bitmask b
struct CDR_testing::inner

Public Members

char c_inner
long l_inner
struct Entity_testing::L1_k

Public Members

char a
key char b
struct Entity_testing::L1_u

Public Members

char a
char b
struct Entity_testing::L2_k_k

Public Members

L1_k a
key L1_k b
struct Entity_testing::L2_k_u

Public Members

L1_u a
key L1_u b
struct Entity_testing::L2_u_u

Public Members

L1_u a
L1_u b
struct Entity_testing::L3_k_k_k

Public Members

L2_k_k a
key L2_k_k b
struct Entity_testing::L3_k_k_u

Public Members

L2_k_u a
key L2_k_u b
struct Entity_testing::L3_k_u_u

Public Members

L2_u_u a
key L2_u_u b
struct Entity_testing::L3_u_u_u

Public Members

L2_u_u a
L2_u_u b
struct Keyhash::LargeKey

Public Members

key unsigned long a [5]
unsigned long x
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 UnBounded::Msg

Public Types

typedef sequence<long> unbounded_sequence_long
typedef sequence<boolean> unbounded_sequence_bool

Public Members

string unbounded_string
struct Endianness::Msg

Public Members

char chars[3]
unsigned long l
struct CDR_testing::must_understand_struct

Public Functions

id (1) char a

Public Members

must_understand char b
key char c
struct CDR_testing::mutablestruct

Public Functions

id (7) long l
key id (5) char c
id (3) string str
id (1) double d
struct ExtendedTypes_testing::mutablestruct_a

Public Functions

id (0) char a
id (2) char c
id (4) char e
struct ExtendedTypes_testing::mutablestruct_b

Public Functions

id (1) char b
id (2) char c
id (3) char d
struct regression_models::Nested

Public Members

short Member_Nested
struct Keyhash::NoKey

Public Members

unsigned long x
struct CDR_testing::optional_appendable_struct

Public Functions

optional (true) char a
optional (false) char b

Public Members

key char c
struct CDR_testing::optional_array_struct

Public Members

key char c
char l[5]
struct CDR_testing::optional_final_struct

Public Functions

optional (true) char a
optional (false) char b

Public Members

key char c
struct CDR_testing::optional_mutable_struct

Public Functions

optional (true) char a
optional (false) char b

Public Members

key char c
struct CDR_testing::outer

Public Members

inner a
inner b
key inner c
struct Entity_testing::P1_k

Public Members

char a
char b
struct Entity_testing::P1_u

Public Members

char a
char b
struct Entity_testing::P2_k_k

Public Members

P1_k a
P1_k b
struct Entity_testing::P2_k_u

Public Members

P1_u a
P1_u b
struct Entity_testing::P2_u_u

Public Members

P1_u a
P1_u b
struct Entity_testing::P3_k_k

Public Members

P2_k_k a
P2_k_k b
struct Entity_testing::P3_k_u

Public Members

P2_k_u a
P2_k_u b
struct Entity_testing::P3_u_u

Public Members

P2_u_u a
P2_u_u b
struct CDR_testing::pragma_keys

Public Members

sub_2 c
sub_2 d
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
class Regression : public Test

Fixture for the Regression tests

Public Functions

inline Regression()
inline void SetUp()
inline void TearDown()
struct regression_models::s_1

Public Members

string d[2]
struct traits_models::s_1

Public Members

string d[2]
struct regression_models::s_2

Public Members

s_1 c[2]
struct traits_models::s_2

Public Members

s_1 c[2]
struct regression_models::s_appendable

Public Members

key string s
struct regression_models::s_bm1

Public Members

bm1 c[3]
struct regression_models::s_e1

Public Members

e1_arr c
struct regression_models::s_final

Public Members

key string s
struct regression_models::s_inner

Public Members

char ch
struct regression_models::s_o

Public Members

long c
struct regression_models::s_o_2

Public Members

long c
long d
struct regression_models::s_o_td

Public Members

td_l c
struct regression_models::s_td_bool_seq_arr

Public Members

td_bool_seq_arr c
struct regression_models::s_u

Public Members

key V c
struct regression_models::s_u_struct_arr

Public Members

u_struct_arr c
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
struct CDR_testing::sequence_struct

Public Types

key sequence< char > c
typedef sequence<long> l
struct CDR_testing::sequence_struct_mutable

Public Types

key sequence< char > c
typedef sequence<long> l
struct ExtendedTypes_testing::sequences_of_final_larger

Public Types

typedef sequence<finalstruct_larger> c
struct ExtendedTypes_testing::sequences_of_final_smaller

Public Types

typedef sequence<finalstruct_smaller> c
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, endianness end)

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 SetDurabilityServiceHistory(int32_t depth)
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 bool must_use_iceoryx, const dds::sub::LoanedSamples<T> &samples, const T &test_data)
inline void run_communication_test(const bool must_use_iceoryx, const dds::sub::qos::DataReaderQos &r_qos, const dds::pub::qos::DataWriterQos &w_qos, const int32_t num_samples)
inline void expect_no_communication(const dds::sub::qos::DataReaderQos &r_qos, const dds::pub::qos::DataWriterQos &w_qos)
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::qos::TopicQos t_qos
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
iox::cxx::optional<iox::popo::Subscriber<T, iceoryx_header_t>> iceoryx_subscriber

Public Static Attributes

static constexpr char TOPIC_NAME[] = "datareader_test_topic"
struct Keyhash::SmallKey

Public Members

key unsigned long k
unsigned long x
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
struct Keyhash::StringKey

Public Members

key string s
unsigned long x
struct regression_models::struct_seq_e1

Public Members

seq_e1 c
struct TraitTest::StructDefault

Public Members

long l
struct TraitTest::StructNested

Public Members

long l
struct TraitTest::StructTopic

Public Members

long l
struct CDR_testing::sub_1

Public Members

long l_1
long l_2
struct CDR_testing::sub_2

Public Members

sub_1 s_1
sub_1 s_2
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 regression_models::td_1

Public Members

long l
struct traits_models::td_1

Public Members

long l
struct regression_models::td_3

Public Members

td_2 c
struct traits_models::td_3

Public Members

td_2 c
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

key long long_1
long long_2
long long_3
struct Space::Type2

Public Members

key long long_1
long long_2
long long_3
Enumeration enum_1
struct CDR_testing::typedef_base_struct

Public Members

key td_sequence_char c
td_sequence_char l
struct CDR_testing::typedef_constr_struct

Public Members

key td_sequence_struct c
td_sequence_struct l
union regression_models::U

Public Members

short s
union Endianness::U

Public Members

double d
string str
default __pad0__
union regression_models::u_s_inner

Public Members

seq_td_s_inner c
td_td_s_inner d
union regression_models::u_struct_arr

Public Members

s_inner c_1[1]
union CDR_testing::un

Public Members

char c
short s
long l
default __pad0__
union CDR_testing::un_k

Public Members

char c
short s
long l
default __pad0__
struct CDR_testing::union_struct

Public Members

key un c
struct CDR_testing::union_struct_k

Public Members

key un_k c
union TraitTest::UnionDefault

Public Members

long l
double d
union TraitTest::UnionNested

Public Members

long l
double d
struct Endianness::UnionStr

Public Members

U u
union TraitTest::UnionTopic

Public Members

long l
double d
union regression_models::V

Public Members

U u
union regression_models::W

Public Members

char c[2]
char d[2][3]
e1 x[3]
e1_arr y
e1 z
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 CDR_testing

Typedefs

typedef sequence<char> td_sequence_char
typedef sequence<base> td_sequence_struct

Enums

enum enum_32

Values:

enumerator first_32
enumerator second_32
enumerator third_32
enumerator fourth_32

Functions

bit_bound (8) enum enum_8
bit_bound (16) enum enum_16
bit_bound (15) bitmask bm1
namespace DataModels_testing

Enums

enum test_enum

Values:

enumerator e_0
enumerator e_1
enumerator e_2

Variables

bitmask test_bitmask{f_0, f_1, f_2}
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 Entity_testing
namespace ExtendedTypes_testing
namespace external_testing
namespace HelloWorldData
namespace Keyhash
namespace org
namespace eclipse
namespace cyclone
namespace core
namespace org::eclipse::cyclone::core::cdr

Functions

void serdata_from_ser_copyin_fragchain (unsigned char *__restrict cursor, const struct nn_rdata *fragchain, size_t size)
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 regression_models

Typedefs

typedef long td_l
typedef sequence<td_1> td_2
typedef double td_d
typedef e1 e1_arr[3]
typedef long long_array_5[5]
typedef long long_array_7[7]
typedef long long_array_2[2]
typedef long_array_2 long_array_6[3]
typedef unsigned long ulong_arr[4]
typedef sequence<ulong_arr> seq_ulong_arr
typedef sequence<unsigned long> seq_ulong
typedef boolean td_bool
typedef sequence<td_bool> td_bool_seq_arr
typedef s_inner td_s_inner
typedef td_s_inner td_td_s_inner
typedef sequence<td_s_inner> seq_td_s_inner
typedef sequence<e1, 3> seq_e1

Functions

bit_bound (8) @appendable enum e1
bit_bound (16) bitmask bm1
namespace Space

Enums

enum Enumeration

Values:

enumerator VALUE1
enumerator VALUE2
namespace traits_models

Typedefs

typedef sequence<td_1> td_2

Functions

data_representation (XCDR2) struct s_3
namespace TraitTest
namespace UnBounded
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/fragchain.cpp src/org/eclipse/cyclonedds/core/cdr/cdr_stream.cpp src/org/eclipse/cyclonedds/core/cdr/basic_cdr_ser.cpp src/org/eclipse/cyclonedds/core/cdr/entity_properties.cpp src/org/eclipse/cyclonedds/core/cdr/extended_cdr_v1_ser.cpp src/org/eclipse/cyclonedds/core/cdr/extended_cdr_v2_ser.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 data/CdrDataModels.idl data/CdrDataModels_pragma.idl data/EntityProperties.idl data/EntityProperties_pragma.idl data/ExtendedTypesModels.idl data/RegressionModels.idl data/RegressionModels_pragma.idl data/ExternalModels.idl data/TraitsModels.idl WARNINGS no-implicit-extensibility) configure_file(config_simple.xml.in config_simple.xml @ONLY) if(ENABLE_SHM) find_package(iceoryx_posh REQUIRED) find_package(iceoryx_posh_testing 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 CDRStreamer.cpp GeneratedEntities.cpp ExtendedTypes.cpp Regression.cpp External.cpp DataModels.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 basic_cdr_ser.cpp
#include <>
file cdr_stream.cpp
#include <>
#include <>
#include <>
#include <>
file entity_properties.cpp
#include <>
#include <>
#include <>
#include <>
file extended_cdr_v1_ser.cpp
#include <>
#include <>
file extended_cdr_v2_ser.cpp
#include <>
#include <>
file fragchain.cpp
#include “”
#include “”
#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 “”

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 “”
#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 CDRStreamer.cpp
#include “”
#include <>
#include “”
#include “”

Defines

read_test(test_struct, key_struct, normal_bytes, key_bytes, streamer)
read_test_fail(test_struct, key_struct, key_bytes, streamer)
read_deeper_test(test_struct, key_struct, normal_bytes, key_bytes, streamer)
write_test(test_struct, key_struct, normal_bytes, key_bytes, streamer)
write_test_fail(test_struct, key_struct, key_bytes, streamer)
readwrite_test(test_struct, key_struct, normal_bytes, key_bytes, streamer)
readwrite_test_fail(test_struct, key_struct, key_bytes, streamer)
readwrite_deeper_test(test_struct, key_struct, normal_bytes, key_bytes, streamer)
stream_test(test_struct, cdr_normal_bytes, key_bytes)
stream_test_union(test_struct, key_struct, cdr_normal_bytes, key_bytes)
stream_test_fail_basic(test_struct, xcdr_v1_normal_bytes, xcdr_v2_normal_bytes, key_bytes)
stream_deeper_test(test_struct, cdr_normal_bytes, cdr_delimited_bytes, key_bytes)

Typedefs

typedef std::vector<unsigned char> bytes

Functions

template<typename T, typename S>
void VerifyWrite(const T &in, const bytes &out, S stream, bool as_key, bool write_success = true, bool compare_success = true)
template<typename T, typename S>
void VerifyRead(const bytes &in, const T &out, S stream, bool as_key, bool read_success = true, bool compare_success = true)
template<typename T, typename S>
void VerifyReadOneDeeper(const bytes &in, const T &out, S stream, bool as_key)
TEST_F(CDRStreamer, cdr_boundary)
TEST_F(CDRStreamer, cdr_basic)
TEST_F(CDRStreamer, cdr_appendable)
TEST_F(CDRStreamer, cdr_mutable)
TEST_F(CDRStreamer, cdr_nested)
TEST_F(CDRStreamer, cdr_inherited)
TEST_F(CDRStreamer, cdr_sequence)
TEST_F(CDRStreamer, cdr_array)
TEST_F(CDRStreamer, cdr_typedef)
TEST_F(CDRStreamer, cdr_union)
TEST_F(CDRStreamer, cdr_pragma)
TEST_F(CDRStreamer, cdr_enum)
TEST_F(CDRStreamer, cdr_optional)
TEST_F(CDRStreamer, cdr_must_understand)
TEST_F(CDRStreamer, d_header_insertion)
TEST_F(CDRStreamer, cdr_bitmask)
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 CdrDataModels.idl
file CdrDataModels_pragma.idl
file EntityProperties.idl
file EntityProperties_pragma.idl
file ExtendedTypesModels.idl
file ExternalModels.idl
file HelloWorldData.idl
file RegressionModels.idl
file RegressionModels_pragma.idl
file Serialization.idl
file Space.idl
file TraitsModels.idl
file DataModels.cpp
#include “”
#include <>
#include “”

Functions

TEST_F(DataModels, implicit_defaults)
TEST_F(DataModels, explicit_defaults)
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, 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 ExtendedTypes.cpp
#include “”
#include <>
#include “”

Typedefs

typedef std::vector<char> bytes

Functions

TEST_F(ExtendedTypes, final)
TEST_F(ExtendedTypes, appendable)
TEST_F (ExtendedTypes, mutable)
TEST_F(ExtendedTypes, sequences_final)
file External.cpp
#include “”
#include <>
#include <>
#include “”
#include <>

Functions

TEST(External, constructing)
TEST(External, assigning)
TEST(External, accessing)
TEST(External, locking)
TEST(External, reading_writing)
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 GeneratedEntities.cpp
#include “”
#include <>
#include “”
#include “”

Functions

void compare_endpoints_with_entity(const key_endpoint &ke, const entity_properties &props)
template<typename T>
void test_props(const std::list<std::list<uint32_t>> &endpoints)
TEST_F(EntityTesting, entity_properties_annotation)
TEST_F(EntityTesting, entity_properties_pragma)
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 Regression.cpp
#include “”
#include <>
#include “”
#include “”

Defines

readwrite_test(test_struct, test_cdr, streamer)

Typedefs

typedef std::vector<unsigned char> bytes

Functions

template<typename T, typename S>
void VerifyWrite(const T &in, const bytes &out, S stream, bool as_key = false, bool write_success = true, bool compare_success = true)
template<typename T, typename S>
void VerifyRead(const bytes &in, const T &out, S stream, bool as_key = false, bool read_success = true, bool compare_success = true)
TEST_F(Regression, d_header_insertion)
TEST_F(Regression, member_completeness_unions)
TEST_F(Regression, optional_of_typedef)
TEST_F(Regression, optionals_delimiters_unbalance)
TEST_F(Regression, propagate_xtypes_version_reqs)
TEST_F(Regression, union_duplicate_types)
TEST_F(Regression, delimiters_bitmask)
TEST_F(Regression, emumerators_properties)
TEST_F(Regression, delimiters_emumerators)
TEST_F(Regression, arrays_in_union_case)
TEST_F(Regression, direct_typedef_of_primitive)
TEST_F(Regression, union_array_case)
TEST_F(Regression, direct_typedef_of_struct)
TEST_F(Regression, typedef_of_sequence_of_enums)
TEST_F(Regression, key_value_of_appendables)
file Serdata.cpp
#include <>
#include “”
#include “”
#include <>

Typedefs

using kh_t = std::array<unsigned char, 16>

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)
template<typename T>
static void test_keyhash(const T &sample, const kh_t &expected, const kh_t &expected_md5)
TEST_F(Serdata, keyhash_nokey)
TEST_F(Serdata, keyhash_smallkey)
TEST_F(Serdata, keyhash_largekey)
TEST_F(Serdata, keyhash_stringkey)
TEST_F(Serdata, keyhash_bstringkey)
file SharedMemory.cpp
#include <>
#include “”
#include “”
#include “”
#include “”
#include “”
#include “”
#include “”
#include “”
#include “”
#include “”
#include <>

Defines

EXPECT_THROW_EXCEPTION(statement, error_msg)

Typedefs

using TestTypes = ::testing::Types<Space::Type1, Space::Type2, HelloWorldData::Msg, Bounded::Msg, UnBounded::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, writer_invalid_shm_qos)
TYPED_TEST(SharedMemoryTest, reader_invalid_shm_qos)
TYPED_TEST(SharedMemoryTest, reliable_reader_does_not_match_best_effort_writer)
TYPED_TEST(SharedMemoryTest, best_effort_reader_receives_data_from_reliable_writer_via_shm)
TYPED_TEST(SharedMemoryTest, tl_reader_with_lower_history_depth_receives_data_via_shm)
TYPED_TEST(SharedMemoryTest, tl_reader_with_larger_history_depth_receives_data_via_shm)
TYPED_TEST(SharedMemoryTest, tl_reader_does_not_match_volatile_writer)
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 “”
#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)
template<typename T>
void test_representations(extensibility ext, allowable_encodings_t encodings)
TEST_F(Topic, data_representation)

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

TEST_F(WaitSet, status_condition_trigger)

Check that the status conditions are triggered correctly

The test checks for trigger of status condition in the following sequence

  1. Status Condition is create and initialized with StatusMask::none()

  2. Specific status mask is enabled on status condition (requested_incompatible_qos())

  3. Status condition is attached to the waitset

  4. The test checks for the trigger for an event which happend before enabling the status mask

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