@@ -42,6 +42,7 @@ class CLIParser
42
42
std::string topic_name = " benchmark_topic" ;
43
43
eprosima::fastdds::rtps::BuiltinTransports transport = eprosima::fastdds::rtps::BuiltinTransports::DEFAULT;
44
44
ReliabilityQosPolicyKind reliability = ReliabilityQosPolicyKind::BEST_EFFORT_RELIABILITY_QOS;
45
+ DurabilityQosPolicyKind durability = DurabilityQosPolicyKind::VOLATILE_DURABILITY_QOS;
45
46
};
46
47
47
48
public:
@@ -70,8 +71,8 @@ class CLIParser
70
71
struct publisher_config : public entity_config
71
72
{
72
73
uint16_t wait = 1000 ;
73
- uint32_t interval = 100 ;
74
- uint32_t end = 10000 ;
74
+ uint16_t interval = 100 ;
75
+ uint16_t end = 10000 ;
75
76
CLIParser::MsgSizeKind msg_size = CLIParser::MsgSizeKind::NONE;
76
77
};
77
78
@@ -113,6 +114,8 @@ class CLIParser
113
114
std::cout << " (Default: benchmark_topic)" << std::endl;
114
115
std::cout << " -r, --reliable Set Reliability QoS as reliable" << std::endl;
115
116
std::cout << " (Default: best effort)" << std::endl;
117
+ std::cout << " --transient-local Set Durability QoS as transient local" << std::endl;
118
+ std::cout << " (Default: volatile)" << std::endl;
116
119
std::cout << " -m <num>, --msg-size <num> Size of the message" << std::endl;
117
120
std::cout << " · NONE: Only an int value" << std::endl;
118
121
std::cout << " · SMALL: int value + array of 16Kb" << std::endl;
@@ -493,6 +496,12 @@ class CLIParser
493
496
print_help (EXIT_FAILURE);
494
497
}
495
498
}
499
+ else if (arg == " --transient-local" )
500
+ {
501
+ config.pub_config .durability = DurabilityQosPolicyKind::TRANSIENT_LOCAL_DURABILITY_QOS;
502
+ config.sub_config .durability = DurabilityQosPolicyKind::TRANSIENT_LOCAL_DURABILITY_QOS;
503
+
504
+ }
496
505
else
497
506
{
498
507
EPROSIMA_LOG_ERROR (CLI_PARSER, " parsing argument: " + arg);
0 commit comments