Fix extra / prefix is add in fron the shm name on POSIX

Author: kzhdev

slick_queue_py.py

@@ -59,18 +59,22 @@ class SlickQueue:
     """
 
     def __init__(self, *, name: Optional[str] = None, size: Optional[int] = None, element_size: Optional[int] = None):
-        # On Linux, POSIX shared memory names must start with /
-        # The C++ slick_queue library passes the name directly to shm_open(),
-        # which requires the / prefix. Python's SharedMemory strips it from .name,
-        # but we need to add it for C++ interop.
+        # Store the original user-provided name (without / prefix)
+        # Python's SharedMemory will add the / prefix on POSIX systems automatically.
+        # We strip any leading / to avoid double-prefixing (//name) on POSIX systems.
         self.name = name
-        if self.name is not None and sys.platform != 'win32' and not self.name.startswith('/'):
-            self.name = '/' + self.name
+        if self.name is not None and self.name.startswith('/'):
+            # Strip leading / if user provided it - Python's SharedMemory will add it back on POSIX
+            self.name = self.name[1:]
 
         # macOS has a 31-character limit for POSIX shared memory names (including leading /)
-        if self.name is not None and sys.platform == 'darwin' and len(self.name) > 31:
-            raise ValueError(f"Shared memory name '{self.name}' is {len(self.name)} characters, "
-                           f"but macOS has a 31-character limit. Please use a shorter name.")
+        # Check the length that will be used (with / prefix on POSIX systems)
+        if self.name is not None and sys.platform == 'darwin':
+            # On macOS, Python's SharedMemory will prepend /, so check total length
+            final_name = '/' + self.name
+            if len(final_name) > 31:
+                raise ValueError(f"Shared memory name '{final_name}' is {len(final_name)} characters, "
+                               f"but macOS has a 31-character limit. Please use a shorter name.")
 
         self.use_shm = name is not None
         self._shm: Optional[SharedMemory] = None
@@ -206,17 +210,25 @@ def get_shm_name(self) -> Optional[str]:
         """
         Get the actual shared memory name for C++ interop.
 
-        Returns the name with POSIX / prefix on Linux (required by C++ shm_open).
-        Python's SharedMemory.name property strips the / prefix, but this method
-        returns self.name which preserves it for C++ interop.
+        Returns the name with POSIX / prefix (required by C++ shm_open).
+        On POSIX systems (Linux/macOS), this returns the name with the / prefix.
+        On Windows, it returns the name without modification.
 
         Returns:
             The shared memory name that C++ code should use to open the queue.
-            On Linux, this will have the / prefix that shm_open() requires.
+            On POSIX systems, this will have the / prefix that shm_open() requires.
         """
-        # Return self.name (which has / prefix on Linux) rather than self._shm.name
-        # (which has / stripped by Python)
-        return self.name
+        if self._shm is not None:
+            # Use the actual name from SharedMemory (which has / prefix on POSIX)
+            return self._shm._name
+        elif self.name is not None:
+            # If SharedMemory not created yet, construct the expected name
+            # On POSIX, need to add / prefix; on Windows, use as-is
+            if sys.platform != 'win32':
+                return '/' + self.name
+            else:
+                return self.name
+        return None
 
     # Public API mirroring C++ methods
     def reserve(self, n: int = 1) -> int:

tests/CMakeLists.txt

@@ -81,6 +81,7 @@ add_test(
     WORKING_DIRECTORY ${CMAKE_SOURCE_DIR}
 )
 
+# Python/C++ interop tests
 add_test(
     NAME python_producer_cpp_consumer
     COMMAND ${Python3_EXECUTABLE} ${CMAKE_SOURCE_DIR}/tests/test_interop.py --test python_producer_cpp_consumer
@@ -109,6 +110,5 @@ set_tests_properties(
     python_producer_cpp_consumer
     cpp_producer_python_consumer
     multi_producer_interop
-    PROPERTIES
-        TIMEOUT 120
+    PROPERTIES TIMEOUT 120
 )

tests/test_local_mode.py

@@ -29,7 +29,6 @@ def test_local_mode():
         data, size, read_index = q.read(read_index)
         assert data is not None, f"No data at iteration {i}"
         value = struct.unpack("<I", data[:4])[0]
-        print(f"Read value: {value}")
         assert value == i, f"Expected {i}, got {value}"
 
     # Cleanup (should be no-op for unlink in local mode)