Refs #22055: Fix unique flows for TCP

Signed-off-by: cferreiragonz <[email protected]>
eProsima · Dec 5, 2024 · d046bdf · d046bdf
1 parent 6e89d32
commit d046bdf
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/src/cpp/rtps/participant/RTPSParticipantImpl.cpp b/src/cpp/rtps/participant/RTPSParticipantImpl.cpp
@@ -1737,7 +1737,15 @@ bool RTPSParticipantImpl::createAndAssociateReceiverswithEndpoint(
             // Set port on unicast locators
             for (Locator_t& loc : attributes.unicastLocatorList)
             {
-                loc.port = port;
+                // Set logical port only TCP locators
+                if (LOCATOR_KIND_TCPv4 == loc.kind || LOCATOR_KIND_TCPv6 == loc.kind)
+                {
+                    IPLocator::setLogicalPort(loc, port);
+                }
+                else
+                {
+                    loc.port = port;
+                }
             }
 
             // Try creating receiver resources