Configured Connext and micro udp transport size to 65504

Author: angelrti

doc/test_description.template.rst

@@ -63,6 +63,8 @@ product versions.
   * Content Filtered Topic uses MATCH operator for string comparisons.
   * Increased the periodic discovery announcements to 5s in the tests where
     the subscriber is OpenDDS and the publisher is Connext DDS.
+  * Configured UDP transport message size max to 65504 bytes to make it
+    compatible with other vendors.
 
 * **FastDDS**:
 

srcCxx/shape_configurator_rti_connext_dds.h

@@ -24,13 +24,29 @@ bool configure_datafrag_size(
     if (datafrag_size == 0) {
         ok = false;
     } else {
-        DDS_PropertyQosPolicyHelper_add_property(
+        if (DDS_PropertyQosPolicyHelper_assert_property(
                 &dp_qos.property,
                 "dds.transport.UDPv4.builtin.parent.message_size_max",
                 std::to_string(datafrag_size).c_str(),
-                DDS_BOOLEAN_FALSE);
+                DDS_BOOLEAN_FALSE) != DDS_RETCODE_OK) {
+            ok = false;
+            printf("failed to set datafrag_size\n");
+        } else {
+            ok = true;
+        }
+    }
+    return ok;
+}
+
+
+static bool configure_dp_qos(DDS::DomainParticipantQos &dp_qos) {
+    bool ok = false;
+    if (!configure_datafrag_size(dp_qos, 65504)) {
+        printf("failed to configure dp qos\n");
+    } else {
         ok = true;
     }
+
     return ok;
 }
 

srcCxx/shape_configurator_rti_connext_micro.h

@@ -115,7 +115,7 @@ static bool config_micro()
       goto done;
   }
 
-  udp_property->max_message_size = 64 * 1024; //64KB
+  udp_property->max_message_size = 65504;
 
   if (!registry->register_component(
         NETIO_DEFAULT_UDP_NAME,

srcCxx/shape_main.cxx

@@ -1209,6 +1209,16 @@ class ShapeApplication {
         DDS::DomainParticipantQos dp_qos;
         dpf->get_default_participant_qos(dp_qos);
 
+#if   defined(RTI_CONNEXT_DDS) || defined(RTI_CONNEXT_MICRO)
+        if (!configure_dp_qos(dp_qos)) {
+            return false;
+        }
+#endif
+
+#ifdef RTI_CONNEXT_DDS
+        configure_participant_announcements_period(dp_qos, options->periodic_announcement_period_us);
+#endif
+
         if (options->datafrag_size > 0) {
             bool result = false;
   #if defined(RTI_CONNEXT_DDS)
@@ -1227,16 +1237,6 @@ class ShapeApplication {
             }
         }
 
-#ifdef RTI_CONNEXT_MICRO
-        if (!configure_dp_qos(dp_qos)) {
-            return false;
-        }
-#endif
-
-#ifdef RTI_CONNEXT_DDS
-        configure_participant_announcements_period(dp_qos, options->periodic_announcement_period_us);
-#endif
-
         dp = dpf->create_participant( options->domain_id, dp_qos, &dp_listener, LISTENER_STATUS_MASK_ALL );
         if (dp == NULL) {
             logger.log_message("failed to create participant (missing license?).", Verbosity::ERROR);