Struct test_UDPv4TransportDescriptor

Inheritance Relationships

Base Type

Struct Documentation

struct test_UDPv4TransportDescriptor : public eprosima::fastdds::rtps::SocketTransportDescriptor

UDP v4 Test Transport configuration

Public Types

typedef std::function<bool(eprosima::fastdds::rtps::CDRMessage_t &msg)> filter

Custom message filtering functions.

typedef std::function<bool(const Locator &destination)> DestinationLocatorFilter

Locator filtering function.

Public Functions

FASTDDS_EXPORTED_API test_UDPv4TransportDescriptor()

Constructor.

virtual ~test_UDPv4TransportDescriptor() = default

Destructor.

virtual TransportInterface *create_transport() const override

Create transport using the parameters defined within the Descriptor.

FASTDDS_EXPORTED_API test_UDPv4TransportDescriptor(const test_UDPv4TransportDescriptor &t) = delete

Copy constructor.

FASTDDS_EXPORTED_API test_UDPv4TransportDescriptor & operator= (const test_UDPv4TransportDescriptor &t)=delete

Copy assignment.

FASTDDS_EXPORTED_API test_UDPv4TransportDescriptor(test_UDPv4TransportDescriptor &&t) = delete

Move constructor.

FASTDDS_EXPORTED_API test_UDPv4TransportDescriptor & operator= (test_UDPv4TransportDescriptor &&t)=delete

Move assignment.

FASTDDS_EXPORTED_API bool operator== (const test_UDPv4TransportDescriptor &t) const

Comparison operator.

Public Members

std::shared_ptr<TestUDPv4TransportOptions> test_transport_options = std::make_shared<TestUDPv4TransportOptions>()

Test transport options.

mutable std::atomic<uint8_t> dropDataMessagesPercentage = {0}

Test shim parameters Percentage of data messages being dropped

mutable std::atomic<uint8_t> dropParticipantBuiltinDataMessagesPercentage = {0}

Percentage of Data[P] messages being dropped.

mutable std::atomic<uint8_t> dropPublicationBuiltinDataMessagesPercentage = {0}

Percentage of Data[W] messages being dropped.

mutable std::atomic<uint8_t> dropSubscriptionBuiltinDataMessagesPercentage = {0}

Percentage of Data[R] messages being dropped.

filter drop_data_messages_filter_ = [](fastdds::rtps::CDRMessage_t&){return false;}

Filtering function for dropping data messages.

filter drop_builtin_data_messages_filter_ = [](fastdds::rtps::CDRMessage_t&){return false;}

Filtering function for dropping builtin data messages.

bool dropParticipantBuiltinTopicData = false

Flag to enable dropping of discovery Participant DATA(P) messages.

bool dropPublicationBuiltinTopicData = false

Flag to enable dropping of discovery Writer DATA(W) messages.

bool dropSubscriptionBuiltinTopicData = false

Flag to enable dropping of discovery Reader DATA(R) messages.

mutable std::atomic<uint8_t> dropDataFragMessagesPercentage = {0}

Percentage of data fragments being dropped.

filter drop_data_frag_messages_filter_ = [](fastdds::rtps::CDRMessage_t&){return false;}

Filtering function for dropping data fragments messages.

mutable std::atomic<uint8_t> dropHeartbeatMessagesPercentage = {0}

Percentage of heartbeats being dropped.

filter drop_heartbeat_messages_filter_ = [](fastdds::rtps::CDRMessage_t&){return false;}

Filtering function for dropping heartbeat messages.

mutable std::atomic<uint8_t> dropAckNackMessagesPercentage = {0}

Percentage of AckNacks being dropped.

filter drop_ack_nack_messages_filter_ = [](fastdds::rtps::CDRMessage_t&){return false;}

Filtering function for dropping AckNacks.

mutable std::atomic<uint8_t> dropGapMessagesPercentage = {0}

Percentage of gap messages being dropped.

filter drop_gap_messages_filter_ = [](fastdds::rtps::CDRMessage_t&){return false;}

Filtering function for dropping gap messages.

filter sub_messages_filter_ = [](fastdds::rtps::CDRMessage_t&){return false;}
mutable std::atomic<uint8_t> percentageOfMessagesToDrop = {0}
filter messages_filter_ = [](fastdds::rtps::CDRMessage_t&){return false;}
DestinationLocatorFilter locator_filter_ = [](const Locator&){return false;}

Filtering function for dropping messages to specific destinations.

std::vector<fastdds::rtps::SequenceNumber_t> sequenceNumberDataMessagesToDrop = {}

Vector containing the message’s sequence numbers being dropped.

uint32_t dropLogLength = 0

Log dropped packets.