[#96] introduce monitoring

ROADMAP.md

@@ -83,6 +83,11 @@
   * Buddy allocator for sender data-segment
   * Introduce runtime fixed-size types
 
+## Expert/Advanced Features
+
+* [ ] Filtering/Routing of messages in pub-sub
+* [ ] Handle approach to resend samples that could not be delivered caused by a full queue in pub-sub
+
 ## Robustness
 
 * [ ] Add ability to recover samples when subscriber died

doc/release-notes/iceoryx2-unreleased.md

@@ -9,6 +9,7 @@
  <!-- NOTE: Add new entries sorted by issue number to minimize the possibility of conflicts when merging. -->
 
  * Introduce `iceoryx2-bb-posix::process_state` for process monitoring [#96](https://github.com/eclipse-iceoryx/iceoryx2/issues/96)
+ * Introduce concept `iceoryx2-cal::monitoring` [#96](https://github.com/eclipse-iceoryx/iceoryx2/issues/96)
 
 ### Bugfixes
 

iceoryx2-bb/lock-free/src/mpmc/container.rs

@@ -271,14 +271,14 @@ impl<T: Copy + Debug> Container<T> {
     ///
     pub unsafe fn add(&self, value: T) -> Option<UniqueIndex<'_>> {
         self.verify_memory_initialization("add");
-        match self
-            .index_set
-            .acquire_with_additional_cleanup(|index: u32| {
-                // set deactivate the active index to indicate that the value can be used again
-                // requires that T does not implement drop
-                unsafe { &*self.active_index_ptr.as_ptr().offset(index as isize) }
-                    .store(false, Ordering::Relaxed);
-            }) {
+        let cleanup_call = |index: u32| {
+            // set deactivate the active index to indicate that the value can be used again
+            // requires that T does not implement drop
+            unsafe { &*self.active_index_ptr.as_ptr().offset(index as isize) }
+                .store(false, Ordering::Relaxed);
+        };
+
+        match self.index_set.acquire_with_additional_cleanup(cleanup_call) {
             Some(index) => {
                 unsafe {
                     *(*self.data_ptr.as_ptr().offset(index.value() as isize)).get() =

iceoryx2-bb/posix/src/shared_memory.rs

@@ -338,9 +338,10 @@ impl SharedMemoryCreationBuilder {
 
         if self.config.zero_memory {
             if POSIX_SUPPORT_ADVANCED_SIGNAL_HANDLING {
-                match SignalHandler::call_and_fetch(|| unsafe {
+                let memset_call = || unsafe {
                     posix::memset(shm.base_address as *mut posix::void, 0, self.config.size);
-                }) {
+                };
+                match SignalHandler::call_and_fetch(memset_call) {
                     None => (),
                     Some(v) => {
                         fail!(from self.config, with SharedMemoryCreationError::InsufficientMemory,

iceoryx2-bb/posix/src/udp_socket.rs

@@ -288,9 +288,11 @@ impl UdpClient {
                             "This should never happen! {} since the socket could not be attached to a fd set.", msg);
 
         let mut received_bytes = Ok(0);
-        match fd_set.timed_wait(timeout, FileEvent::Read, |_| {
+        let receive_call = |_: &FileDescriptor| {
             received_bytes = self.socket.receive(buffer);
-        }) {
+        };
+
+        match fd_set.timed_wait(timeout, FileEvent::Read, receive_call) {
             Err(FileDescriptorSetWaitError::Interrupt) => {
                 fail!(from self, with UdpReceiveError::Interrupt,
                     "{} since an interrupt signal was received.", msg);

iceoryx2-bb/system-types/src/path.rs

@@ -32,12 +32,11 @@ pub use iceoryx2_bb_container::semantic_string::SemanticString;
 use core::hash::{Hash, Hasher};
 use iceoryx2_bb_container::byte_string::FixedSizeByteString;
 use iceoryx2_bb_container::semantic_string;
-
+use iceoryx2_bb_container::semantic_string::*;
 use iceoryx2_bb_log::fail;
 use iceoryx2_pal_configuration::{FILENAME_LENGTH, PATH_SEPARATOR, ROOT};
 
 use crate::file_path::FilePath;
-use iceoryx2_bb_container::semantic_string::SemanticStringError;
 
 const PATH_LENGTH: usize = iceoryx2_pal_configuration::PATH_LENGTH;
 

iceoryx2-cal/src/lib.rs

@@ -14,6 +14,7 @@ pub mod communication_channel;
 pub mod dynamic_storage;
 pub mod event;
 pub mod hash;
+pub mod monitoring;
 pub mod named_concept;
 pub mod reactor;
 pub mod serialize;