Skip to content

Commit 36cd61d

Browse files
committed
Added Connext configuration
1 parent d7909fd commit 36cd61d

2 files changed

Lines changed: 12 additions & 2 deletions

File tree

srcCxx/shape_configurator_rti_connext_dds.h

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -73,3 +73,13 @@ void configure_large_data(DDS::DataWriterQos &dw_qos) {
7373
}
7474
dw_qos.publish_mode.kind = DDS::ASYNCHRONOUS_PUBLISH_MODE_QOS;
7575
}
76+
77+
void config_dw_qos(DDS::DataWriterQos &dw_qos) {
78+
dw_qos.protocol.rtps_reliable_writer.max_nack_response_delay.sec = 0;
79+
dw_qos.protocol.rtps_reliable_writer.max_nack_response_delay.nanosec = 0;
80+
}
81+
82+
void config_dr_qos(DDS::DataReaderQos &dr_qos) {
83+
dr_qos.protocol.rtps_reliable_reader.max_heartbeat_response_delay.sec = 0;
84+
dr_qos.protocol.rtps_reliable_reader.max_heartbeat_response_delay.nanosec = 0;
85+
}

srcCxx/shape_main.cxx

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1368,7 +1368,7 @@ class ShapeApplication {
13681368
logger.log_message("Data Writer QoS:", Verbosity::DEBUG);
13691369
pub->get_default_datawriter_qos( dw_qos );
13701370

1371-
#if defined (RTI_CONNEXT_MICRO)
1371+
#if defined(RTI_CONNEXT_DDS) || defined(RTI_CONNEXT_MICRO)
13721372
config_dw_qos(dw_qos);
13731373
#endif
13741374

@@ -1595,7 +1595,7 @@ class ShapeApplication {
15951595
logger.log_message("Data Reader QoS:", Verbosity::DEBUG);
15961596
sub->get_default_datareader_qos( dr_qos );
15971597

1598-
#if defined (RTI_CONNEXT_MICRO)
1598+
#if defined(RTI_CONNEXT_DDS) || defined(RTI_CONNEXT_MICRO)
15991599
config_dr_qos(dr_qos);
16001600
#endif
16011601

0 commit comments

Comments
 (0)