Refs #21913: Add check in RTPSParticipant

Signed-off-by: eProsima <[email protected]>
eProsima · Oct 17, 2024 · bb700cf · bb700cf
1 parent 837c6c8
commit bb700cf
Showing 1 changed file with 12 additions and 3 deletions.
diff --git a/src/cpp/rtps/participant/RTPSParticipantImpl.cpp b/src/cpp/rtps/participant/RTPSParticipantImpl.cpp
@@ -492,15 +492,24 @@ bool RTPSParticipantImpl::setup_transports()
 
         transportDescriptor->unlock();
 
+        auto shm_transport_descriptor = dynamic_cast<SharedMemTransportDescriptor*>(transportDescriptor.get());
         if (transport_registered)
         {
-            has_shm_transport_ |=
-                    (dynamic_cast<SharedMemTransportDescriptor*>(transportDescriptor.get()) != nullptr);
+            has_shm_transport_ |= (nullptr != shm_transport_descriptor);
+            if (nullptr != shm_transport_descriptor)
+            {
+                if (shm_transport_descriptor->max_message_size() > 572u)
+                {
+                    EPROSIMA_LOG_ERROR(RTPS_PARTICIPANT,
+                            "Unable to Register SHM Transport. Maximum message size needs to be"
+                            "equal or higher than the PDP package size.");
+                }
+            }
         }
         else
         {
             // SHM transport could be disabled
-            if ((dynamic_cast<SharedMemTransportDescriptor*>(transportDescriptor.get()) != nullptr))
+            if (nullptr != shm_transport_descriptor)
             {
                 EPROSIMA_LOG_ERROR(RTPS_PARTICIPANT,
                         "Unable to Register SHM Transport. SHM Transport is not supported in"