Refs #22841. Consider a mean message size of half the max message size.

MiguelCompany · MiguelCompany · commit 04f176e22fab · 2025-02-24T14:47:51.000+01:00
Signed-off-by: Miguel Company &lt;miguelcompany@eprosima.com&gt;
diff --git a/src/cpp/rtps/transport/shared_mem/SharedMemTransport.cpp b/src/cpp/rtps/transport/shared_mem/SharedMemTransport.cpp
@@ -301,11 +301,8 @@ bool SharedMemTransport::init(
         {
             return false;
         }
-        uint32_t max_allocations = configuration_.segment_size() / configuration_.max_message_size();
-        if ((configuration_.segment_size() % configuration_.max_message_size()) != 0)
-        {
-            ++max_allocations;
-        }
+        uint32_t mean_message_size = configuration_.max_message_size() / 2;
+        uint32_t max_allocations = configuration_.segment_size() / mean_message_size;
         if (configuration_.port_queue_capacity() > max_allocations)
         {
             max_allocations = configuration_.port_queue_capacity();

Original file line number	Diff line number	Diff line change
`@@ -301,11 +301,8 @@ bool SharedMemTransport::init(`
`301`	`301`	`{`
`302`	`302`	`return false;`
`303`	`303`	`}`
`304`		`- uint32_t max_allocations = configuration_.segment_size() / configuration_.max_message_size();`
`305`		`- if ((configuration_.segment_size() % configuration_.max_message_size()) != 0)`
`306`		`- {`
`307`		`- ++max_allocations;`
`308`		`- }`
	`304`	`+ uint32_t mean_message_size = configuration_.max_message_size() / 2;`
	`305`	`+ uint32_t max_allocations = configuration_.segment_size() / mean_message_size;`
`309`	`306`	`if (configuration_.port_queue_capacity() > max_allocations)`
`310`	`307`	`{`
`311`	`308`	`max_allocations = configuration_.port_queue_capacity();`