[eclipse-iceoryx#690] restructure client example; cap max memory size to 1mb

Author: elfenpiff

examples/rust/publish_subscribe_dynamic_data/publisher.rs

@@ -39,7 +39,7 @@ fn main() -> Result<(), Box<dyn core::error::Error>> {
     let mut counter = 0;
 
     while node.wait(CYCLE_TIME).is_ok() {
-        let required_memory_size = (counter + 1) * (counter + 1);
+        let required_memory_size = 1_000_000.min((counter + 1) * (counter + 1));
         let sample = publisher.loan_slice_uninit(required_memory_size)?;
         let sample = sample.write_from_fn(|byte_idx| ((byte_idx + counter) % 255) as u8);
 

examples/rust/request_response_dynamic_data/client.rs

@@ -38,32 +38,30 @@ fn main() -> Result<(), Box<dyn core::error::Error>> {
 
     let mut counter = 0;
 
-    let mut required_memory_size = 1;
-    let request = client.loan_slice_uninit(required_memory_size)?;
-    let request = request.write_from_fn(|_| 0);
-    let mut pending_response = request.send()?;
+    loop {
+        counter += 1;
+
+        let required_memory_size = 1_000_000.min((counter + 1) * (counter + 1));
+        let request = client.loan_slice_uninit(required_memory_size)?;
+        let request = request.write_from_fn(|byte_idx| ((byte_idx + counter) % 255) as u8);
+        let pending_response = request.send()?;
 
-    while node.wait(CYCLE_TIME).is_ok() {
         println!(
             "send request {} with {} bytes ...",
             counter, required_memory_size
         );
 
+        if !node.wait(CYCLE_TIME).is_ok() {
+            break;
+        }
+
         // acquire all responses to our request from our buffer that were sent by the servers
         while let Some(response) = pending_response.receive()? {
             println!(
                 "  received response with {} bytes",
                 response.payload().len()
             );
         }
-
-        counter += 1;
-        // send all other requests by using zero copy API
-        required_memory_size = (counter + 1) * (counter + 1);
-        let request = client.loan_slice_uninit(required_memory_size)?;
-        let request = request.write_from_fn(|byte_idx| ((byte_idx + counter) % 255) as u8);
-
-        pending_response = request.send()?;
     }
 
     println!("exit");

examples/rust/request_response_dynamic_data/server.rs

@@ -44,7 +44,7 @@ fn main() -> Result<(), Box<dyn core::error::Error>> {
                 active_request.payload().len()
             );
 
-            let required_memory_size = counter + 1;
+            let required_memory_size = 1_000_000.min((counter + 1) * (counter + 1));
             let response = active_request.loan_slice_uninit(required_memory_size)?;
             let response = response.write_from_fn(|byte_idx| ((byte_idx + counter) % 255) as u8);
             println!("  send response with {} bytes", response.payload().len());