Enhance memory usage tests with ShapeType configuration and add MemoryTestShape.xml

Author: kyoungho

README.md

@@ -92,7 +92,7 @@ $env:PATH = "$(pwd)\rticonnextdds-connector\lib\win-x64;$env:PATH"
 
   <types>
     <struct name="ShapeType">
-      <member name="color" type="string" key="true"/>
+      <member name="color" type="string" key="true" stringMaxLength="128"/>
       <member name="x" type="long"/>
       <member name="y" type="long"/>
       <member name="shapesize" type="long"/>

memory_usage_test.go

@@ -3,6 +3,7 @@ package rti
 import (
 	"os"
 	"os/exec"
+	"path"
 	"runtime"
 	"strconv"
 	"strings"
@@ -27,6 +28,13 @@ func getProcessMemory() (int64, error) {
 	return rssKB * 1024, nil // Convert KB to bytes
 }
 
+// newMemoryTestConnector creates a connector using ShapeType (like README example)
+func newMemoryTestConnector() (*Connector, error) {
+	_, curPath, _, _ := runtime.Caller(0)
+	xmlPath := path.Join(path.Dir(curPath), "./test/xml/MemoryTestShape.xml")
+	return NewConnector("MyParticipantLibrary::Zero", xmlPath)
+}
+
 // TestMemoryUsage tests RTI Connector with comprehensive memory profiling
 func TestMemoryUsage(t *testing.T) {
 	iterations := 1
@@ -105,23 +113,25 @@ func max(a, b int) int {
 }
 
 func runConnectorExample(t *testing.T, iteration int) {
-	// Use existing test configuration for reliability
-	connector, err := newTestConnector()
+	// Use ShapeType configuration like in the main README example
+	// This provides realistic memory usage measurements for the documented API
+	connector, err := newMemoryTestConnector()
 	if err != nil {
 		t.Fatalf("Iteration %d: Failed to create connector: %v", iteration, err)
 	}
 	defer connector.Delete()
 
-	// Get output (writer) and publish test data
-	output, err := newTestOutput(connector)
+	// Get output (writer) and publish shape data
+	output, err := connector.GetOutput("MyPublisher::MySquareWriter")
 	if err != nil {
 		t.Fatalf("Iteration %d: Failed to get output: %v", iteration, err)
 	}
 
-	// Publish test data using existing TestType
-	output.Instance.SetString("st", "MemoryTest")
-	output.Instance.SetInt32("l", int32(iteration*10))
-	output.Instance.SetFloat32("f", float32(iteration)+0.5)
+	// Publish shape data (same as README example)
+	output.Instance.SetString("color", "BLUE")
+	output.Instance.SetInt("x", iteration*10)
+	output.Instance.SetInt("y", iteration*20)
+	output.Instance.SetInt("shapesize", 30)
 	err = output.Write()
 	if err != nil {
 		t.Fatalf("Iteration %d: Failed to write: %v", iteration, err)
@@ -132,24 +142,25 @@ func runConnectorExample(t *testing.T, iteration int) {
 	}
 }
 
-// BenchmarkConnectorMemory provides benchmark-based memory analysis
+// BenchmarkConnectorMemory provides benchmark-based memory analysis using ShapeType
 func BenchmarkConnectorMemory(b *testing.B) {
 	b.ResetTimer()
 	for i := 0; i < b.N; i++ {
-		connector, err := newTestConnector()
+		connector, err := newMemoryTestConnector()
 		if err != nil {
 			b.Fatalf("Failed to create connector: %v", err)
 		}
 
-		output, err := newTestOutput(connector)
+		output, err := connector.GetOutput("MyPublisher::MySquareWriter")
 		if err != nil {
 			connector.Delete()
 			b.Fatalf("Failed to get output: %v", err)
 		}
 
-		output.Instance.SetString("st", "BenchmarkTest")
-		output.Instance.SetInt32("l", int32(i*10))
-		output.Instance.SetFloat32("f", float32(i)+0.5)
+		output.Instance.SetString("color", "BLUE")
+		output.Instance.SetInt("x", i*10)
+		output.Instance.SetInt("y", i*20)
+		output.Instance.SetInt("shapesize", 30)
 		output.Write()
 
 		connector.Delete()

test/xml/MemoryTestShape.xml

@@ -0,0 +1,41 @@
+<?xml version="1.0"?>
+<dds xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:noNamespaceSchemaLocation="http://community.rti.com/schema/5.1.0/rti_dds_profiles.xsd" version="5.1.0">
+
+  <qos_library name="QosLibrary">
+    <qos_profile name="DefaultProfile" base_name="BuiltinQosLibExp::Generic.StrictReliable" is_default_qos="true">
+      <participant_qos>
+        <discovery>
+          <initial_peers>
+            <element>shmem://</element>
+          </initial_peers>
+          <multicast_receive_addresses/>
+        </discovery>
+      </participant_qos>
+    </qos_profile>
+  </qos_library>
+  
+  <types>
+    <struct name="ShapeType">
+      <member name="color" type="string" key="true" stringMaxLength="128"/>
+      <member name="x" type="long"/>
+      <member name="y" type="long"/>
+      <member name="shapesize" type="long"/>
+    </struct>
+  </types>
+  
+  <domain_library name="MyDomainLibrary">
+    <domain name="MyDomain" domain_id="0">
+      <register_type name="ShapeType" type_ref="ShapeType" kind="dynamicData"/>
+      <topic name="Square" register_type_ref="ShapeType"/>
+    </domain>
+  </domain_library>
+  
+  <participant_library name="MyParticipantLibrary">
+    <domain_participant name="Zero" domain_ref="MyDomainLibrary::MyDomain">
+      <publisher name="MyPublisher">
+        <data_writer name="MySquareWriter" topic_ref="Square"/>
+      </publisher>
+    </domain_participant>
+  </participant_library>
+</dds>