rust: replace std queue with baselibs rust

Author: pawelrutkaq

.vscode/settings.json

@@ -0,0 +1,6 @@
+{
+  // Generate `rust-project.json` with bazel run @rules_rust//tools/rust_analyzer:gen_rust_project
+  "rust-analyzer.linkedProjects": [
+    "rust-project.json"
+  ]
+}

MODULE.bazel

@@ -127,6 +127,14 @@ git_override(
     remote = "https://github.com/eclipse-score/baselibs.git",
 )
 
+bazel_dep(name = "score_baselibs_rust", version = "0.0.1")
+git_override(
+    module_name = "score_baselibs_rust",
+    commit = "9ee64ac85f2a990ef75b2858253ee44bfc1a7ab7",
+    remote = "https://github.com/eclipse-score/baselibs_rust.git",
+)
+
+
 # Doxygen extension for documentation generation
 doxygen_extension = use_extension("@rules_doxygen//:extensions.bzl", "doxygen_extension")
 use_repo(doxygen_extension, "doxygen")

score/mw/com/example/com-api-example/basic-consumer-producer.rs

@@ -34,7 +34,7 @@ impl<R: Runtime> VehicleMonitor<R> {
 
     /// Monitor tire data from the consumer
     pub fn read_tire_data(&self) -> Result<String> {
-        let mut sample_buf = SampleContainer::new();
+        let mut sample_buf = SampleContainer::new(3);
 
         match self.tire_subscriber.try_receive(&mut sample_buf, 1) {
             Ok(0) => Err(Error::Fail),

score/mw/com/impl/rust/com-api/com-api-concept/BUILD

@@ -22,7 +22,9 @@ rust_library(
     visibility = [
         "//visibility:public",  # platform_only
     ],
-    deps = [],
+    deps = [
+        "@score_baselibs_rust//src/containers:containers",
+    ],
 )
 
 rust_test(

score/mw/com/impl/rust/com-api/com-api-concept/com_api_concept.rs

@@ -50,8 +50,8 @@ use core::fmt::Debug;
 use core::future::Future;
 use core::ops::{Deref, DerefMut};
 pub mod reloc;
+use containers::fixed_capacity::FixedCapacityQueue;
 pub use reloc::Reloc;
-use std::collections::VecDeque;
 use std::path::Path;
 
 /// Error enumeration for different failure cases in the Consumer/Producer/Runtime APIs.
@@ -584,21 +584,15 @@ pub trait Subscriber<T: Reloc + Send + Debug, R: Runtime + ?Sized> {
 /// # Type Parameters
 /// * `S`: The sample type stored in the container.
 pub struct SampleContainer<S> {
-    inner: VecDeque<S>,
-}
-
-impl<S> Default for SampleContainer<S> {
-    fn default() -> Self {
-        Self {
-            inner: VecDeque::new(),
-        }
-    }
+    inner: FixedCapacityQueue<S>,
 }
 
 impl<S> SampleContainer<S> {
     /// Creates a new, empty `SampleContainer`
-    pub fn new() -> Self {
-        Self::default()
+    pub fn new(capacity: usize) -> Self {
+        Self {
+            inner: FixedCapacityQueue::new(capacity),
+        }
     }
 
     /// Returns an iterator over references to the samples in the container.
@@ -632,7 +626,7 @@ impl<S> SampleContainer<S> {
     /// # Returns
     /// A `Result` indicating success or failure.
     pub fn push_back(&mut self, new: S) -> Result<()> {
-        self.inner.push_back(new);
+        self.inner.push_back(new).map_err(|_| Error::AllocateFailed)?;
         Ok(())
     }