[#129] fix missing connections

.cirrus.yml

@@ -19,7 +19,7 @@
 # Constants
 
 iox2_task_timeout_template: &IOX2_TASK_TIMEOUT
-  timeout_in: 30m  # This needs to be reasonable large in order not to run in a timeout in the docker image re-builds
+  timeout_in: 45m  # This needs to be reasonable large in order not to run in a timeout in the docker image re-builds
 
 iox2_common_cpu_and_memory_config_for_build_and_test_template: &IOX2_COMMON_CPU_AND_MEMORY_CONFIG_FOR_BUILD_AND_TEST
   cpu: 2
@@ -82,7 +82,7 @@ iox2_common_build_release_template: &IOX2_COMMON_BUILD_RELEASE
 
 iox2_common_build_and_test_no_doc_tests_release_template: &IOX2_COMMON_BUILD_AND_TEST_NO_DOC_TESTS_RELEASE
   <<: *IOX2_COMMON_BUILD_RELEASE
-  test_script: cargo test --release --tests --workspace --no-fail-fast
+  test_script: RUSTFLAGS="-C debug-assertions" cargo test --release --tests --workspace --no-fail-fast
 
 iox2_freebsd_setup_template: &IOX2_FREEBSD_SETUP
   setup_script:
@@ -148,18 +148,20 @@ ubuntu_22_04_x64_stable_debug_task:
   <<: *IOX2_COMMON_BUILD_AND_TEST_DEBUG
   linux_only_doc_test_script: cargo test --doc -- --ignored
 
-ubuntu_22_04_x64_beta_debug_task:
-  depends_on: ubuntu_22_04_x64_stable_debug
-  <<: *IOX2_CONTAINER_UBUNTU_22_04_X64
-  set_toolchain_script: rustup default beta
-  <<: *IOX2_COMMON_BUILD_AND_TEST_DEBUG
+### TODO commented out due to limited CI time
+### ubuntu_22_04_x64_beta_debug_task:
+###   depends_on: ubuntu_22_04_x64_stable_debug
+###   <<: *IOX2_CONTAINER_UBUNTU_22_04_X64
+###   set_toolchain_script: rustup default beta
+###   <<: *IOX2_COMMON_BUILD_AND_TEST_DEBUG
 
-ubuntu_22_04_x64_nightly_debug_task:
-  depends_on: ubuntu_22_04_x64_beta_debug
-  allow_failures: true
-  <<: *IOX2_CONTAINER_UBUNTU_22_04_X64
-  set_toolchain_script: rustup default nightly
-  <<: *IOX2_COMMON_BUILD_AND_TEST_DEBUG
+### TODO commented out due to limited CI time
+### ubuntu_22_04_x64_nightly_debug_task:
+###   depends_on: ubuntu_22_04_x64_beta_debug
+###   allow_failures: true
+###   <<: *IOX2_CONTAINER_UBUNTU_22_04_X64
+###   set_toolchain_script: rustup default nightly
+###   <<: *IOX2_COMMON_BUILD_AND_TEST_DEBUG
 
 # Pipeline 3
 
@@ -189,12 +191,13 @@ ubuntu_22_04_aarch64_stable_debug_task:
   <<: *IOX2_CARGO_FMT_AND_CLIPPY
   <<: *IOX2_COMMON_BUILD_AND_TEST_DEBUG
 
-ubuntu_22_04_aarch64_beta_debug_task:
-  depends_on: ubuntu_22_04_aarch64_stable_debug
-  allow_failures: true
-  <<: *IOX2_CONTAINER_UBUNTU_22_04_AARCH64
-  set_toolchain_script: rustup default beta
-  <<: *IOX2_COMMON_BUILD_AND_TEST_DEBUG
+### TODO commented out due to limited CI time
+### ubuntu_22_04_aarch64_beta_debug_task:
+###   depends_on: ubuntu_22_04_aarch64_stable_debug
+###   allow_failures: true
+###   <<: *IOX2_CONTAINER_UBUNTU_22_04_AARCH64
+###   set_toolchain_script: rustup default beta
+###   <<: *IOX2_COMMON_BUILD_AND_TEST_DEBUG
 
 # Pipeline 5
 

BEST_PRACTICES.md

@@ -71,6 +71,20 @@
    }
    ```
 
+ * If a panic error check is expensive and located on the hot path then use `debug_assert!`.
+   * Use it only when the panic check prevents API misuse and the misbehavior can be easily
+        detected with unit tests
+
+   ```rust
+    // bad
+    if expensive_check() {
+        fatal_panic!("oh no ...");
+    }
+
+    // good
+    debug_assert!(expensive_check(), "oh no ...");
+   ```
+
 ### Re-Exports And Preludes
 
  * The most common functionality of a construct shall be fully usable by only

doc/release-notes/iceoryx2-unreleased.md

@@ -13,6 +13,7 @@
  * New constructs from [#123](https://github.com/eclipse-iceoryx/iceoryx2/issues/123)
     * Introduce semantic string `iceoryx2-bb-system-types::base64url`
     * Introduce `iceoryx2-cal::hash::HashValue` that contains the result of a hash
+ * Port `UsedChunkList` from iceoryx1 [#129](https://github.com/eclipse-iceoryx/iceoryx2/issues/129)
  * Performance improvements, especially for AMD CPUs [#136](https://github.com/eclipse-iceoryx/iceoryx2/issues/136)
 
 ### Bugfixes
@@ -26,8 +27,12 @@
     * Fix `CreationMode::OpenOrCreate` in `iceoryx2-bb-posix::SharedMemory`
     * Add missing memory synchronization to posix shm zero copy connection
     * Remove retrieve buffer full check from zero copy connection - sender had insufficient infos available
+    * Fix data race in `iceoryx2-bb-lock-free::mpmc::Container`
  * Fix insufficient memory reordering protection in `spsc::Queue::push` and `spsc::Queue::pop` [#119](https://github.com/eclipse-iceoryx/iceoryx2/issues/119)
  * Fix data race due to operation reordering in `spmc::UnrestrictedAtomic::load` [#125](https://github.com/eclipse-iceoryx/iceoryx2/issues/125)
+ * Fix broken `Publisher|Subscriber::populate_{subscriber|publisher}_channels()` [#129](https://github.com/eclipse-iceoryx/iceoryx2/issues/129)
+ * Fix failing reacquire of delivered samples in the zero copy receive channel [#130](https://github.com/eclipse-iceoryx/iceoryx2/issues/130)
+ * Fix receiving of invalid samples when subscriber is connected [#131](https://github.com/eclipse-iceoryx/iceoryx2/issues/131)
  * Fixes for FreeBSD 14.0 [#140](https://github.com/eclipse-iceoryx/iceoryx2/issues/140)
     * Fix segfault in `iceoryx2-pal-posix;:shm_list()` caused by `sysctl`
     * Adjust test to handle unordered event notifications
@@ -38,6 +43,7 @@
 
  * Replace `iceoryx2::service::Service` with `iceoryx2::service::Details` [#100](https://github.com/eclipse-iceoryx/iceoryx2/issues/100)
  * Remove `'config` lifetime from all structs  [#100](https://github.com/eclipse-iceoryx/iceoryx2/issues/100)
+ * Remove `UniqueIndex` returning method from `iceoryx2-bb-lock-free::mpmc::Container`, cannot be implemented correctly in our context [#116](https://github.com/eclipse-iceoryx/iceoryx2/issues/116)
 
 ### Workflow
 

iceoryx2-bb/container/src/queue.rs

@@ -184,13 +184,14 @@ mod details {
     }
 
     impl<T, PointerType: PointerTrait<MaybeUninit<T>>> Queue<T, PointerType> {
+        #[inline(always)]
         fn verify_init(&self, source: &str) {
-            if !self
-                .is_initialized
-                .load(std::sync::atomic::Ordering::Relaxed)
-            {
-                fatal_panic!(from source, "Undefined behavior - the object was not initialized with 'init' before.");
-            }
+            debug_assert!(
+                self.is_initialized
+                    .load(std::sync::atomic::Ordering::Relaxed),
+                "From: {}, Undefined behavior - the object was not initialized with 'init' before.",
+                source
+            );
         }
 
         /// Returns the required memory size for a queue with a specified capacity

iceoryx2-bb/container/src/vec.rs

@@ -175,13 +175,14 @@ impl<T: PartialEq> PartialEq for Vec<T> {
 impl<T: Eq> Eq for Vec<T> {}
 
 impl<T> Vec<T> {
+    #[inline(always)]
     fn verify_init(&self, source: &str) {
-        if !self
-            .is_initialized
-            .load(std::sync::atomic::Ordering::Relaxed)
-        {
-            fatal_panic!(from source, "Undefined behavior - the object was not initialized with 'init' before.");
-        }
+        debug_assert!(
+            self.is_initialized
+                .load(std::sync::atomic::Ordering::Relaxed),
+            "From: {}, Undefined behavior - the object was not initialized with 'init' before.",
+            source
+        );
     }
 
     /// Returns the required memory size for a vec with a specified capacity

iceoryx2-bb/elementary/src/allocator.rs

@@ -28,7 +28,6 @@ pub enum AllocationError {
 /// Failures caused by [`Allocator::grow()`] or [`Allocator::grow_zeroed()`].
 #[derive(Debug, PartialEq, Eq, Copy, Clone)]
 pub enum AllocationGrowError {
-    ProvidedPointerNotContainedInAllocator,
     GrowWouldShrink,
     SizeIsZero,
     OutOfMemory,
@@ -39,20 +38,12 @@ pub enum AllocationGrowError {
 /// Failures caused by [`Allocator::shrink()`].
 #[derive(Debug, PartialEq, Eq, Copy, Clone)]
 pub enum AllocationShrinkError {
-    ProvidedPointerNotContainedInAllocator,
     ShrinkWouldGrow,
     SizeIsZero,
     AlignmentFailure,
     InternalError,
 }
 
-/// Failures caused by [`BaseAllocator::deallocate()`].
-#[derive(Debug, PartialEq, Eq, Copy, Clone)]
-pub enum DeallocationError {
-    ProvidedPointerNotContainedInAllocator,
-    InternalError,
-}
-
 /// The most minimalistic requirement for an allocator
 pub trait BaseAllocator {
     /// Allocates a memory chunk with the properties provided in layout and either
@@ -82,7 +73,7 @@ pub trait BaseAllocator {
     ///  * `layout` must have the same value as in the allocation or, when the memory was
     ///     resized, the same value as it was resized to
     ///
-    unsafe fn deallocate(&self, ptr: NonNull<u8>, layout: Layout) -> Result<(), DeallocationError>;
+    unsafe fn deallocate(&self, ptr: NonNull<u8>, layout: Layout);
 }
 
 /// Allocator with grow and shrink features.

iceoryx2-bb/elementary/src/bump_allocator.rs

@@ -45,12 +45,7 @@ impl BaseAllocator for BumpAllocator {
         }
     }
 
-    unsafe fn deallocate(
-        &self,
-        _ptr: std::ptr::NonNull<u8>,
-        _layout: std::alloc::Layout,
-    ) -> Result<(), crate::allocator::DeallocationError> {
+    unsafe fn deallocate(&self, _ptr: std::ptr::NonNull<u8>, _layout: std::alloc::Layout) {
         self.pos.store(self.start, Ordering::Relaxed);
-        Ok(())
     }
 }