From 9322a6732f067dc2ca8ddc962e56497bd321615d Mon Sep 17 00:00:00 2001
From: Sven Friedrich <sven@autumnal.de>
Date: Tue, 30 Jan 2024 11:33:23 +0100
Subject: [PATCH 1/2] feat(a653rs): queuing ports can signal overflow

---
 examples/deps/dummy.rs |  2 +-
 src/apex/queuing.rs    | 21 ++++++++++++++-------
 2 files changed, 15 insertions(+), 8 deletions(-)

diff --git a/examples/deps/dummy.rs b/examples/deps/dummy.rs
index c3a8109..b04c92e 100644
--- a/examples/deps/dummy.rs
+++ b/examples/deps/dummy.rs
@@ -43,7 +43,7 @@ impl ApexQueuingPortP4 for DummyHypervisor {
         _queuing_port_id: QueuingPortId,
         _time_out: ApexSystemTime,
         _message: &mut [ApexByte],
-    ) -> Result<MessageSize, ErrorReturnCode> {
+    ) -> Result<(MessageSize, QueueOverflow), ErrorReturnCode> {
         todo!()
     }
 
diff --git a/src/apex/queuing.rs b/src/apex/queuing.rs
index a124354..5162a5b 100644
--- a/src/apex/queuing.rs
+++ b/src/apex/queuing.rs
@@ -10,6 +10,13 @@ pub mod basic {
     /// The implementing Hypervisor may cast this to 32-bit if needed
     pub type QueuingPortId = ApexLongInteger;
 
+    /// The queue overflowed on the sender side
+    pub type QueueOverflow = bool;
+
+    /// ARINC 653P1-5 3.6.2.2.3 states that [ErrorReturnCode::InvalidConfig] signals that the queue overflowed on the sender side
+    #[cfg_attr(not(feature = "bindings"), allow(dead_code))]
+    pub const QUEUE_OVERFLOW_ERROR: ErrorReturnCode = ErrorReturnCode::InvalidConfig;
+
     #[derive(Debug, Clone, PartialEq, Eq)]
     #[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
     pub struct QueuingPortStatus {
@@ -43,7 +50,7 @@ pub mod basic {
             queuing_port_id: QueuingPortId,
             time_out: ApexSystemTime,
             message: &mut [ApexByte],
-        ) -> Result<MessageSize, ErrorReturnCode>;
+        ) -> Result<(MessageSize, QueueOverflow), ErrorReturnCode>;
 
         fn get_queuing_port_status(
             queuing_port_id: QueuingPortId,
@@ -66,7 +73,7 @@ pub mod abstraction {
 
     use super::basic::{ApexQueuingPortP1, ApexQueuingPortP4};
     // Reexport important basic-types for downstream-user
-    pub use super::basic::{QueuingPortId, QueuingPortStatus};
+    pub use super::basic::{QueueOverflow, QueuingPortId, QueuingPortStatus};
     use crate::apex::types::basic::PortDirection;
     use crate::prelude::*;
 
@@ -126,7 +133,7 @@ pub mod abstraction {
             id: QueuingPortId,
             timeout: SystemTime,
             buffer: &mut [ApexByte],
-        ) -> Result<&[ApexByte], Error>;
+        ) -> Result<(&[ApexByte], QueueOverflow), Error>;
     }
 
     pub trait ApexQueuingPortP1Ext: ApexQueuingPortP1 + Sized {
@@ -159,9 +166,9 @@ pub mod abstraction {
             id: QueuingPortId,
             timeout: SystemTime,
             buffer: &mut [ApexByte],
-        ) -> Result<&[ApexByte], Error> {
-            let len = Q::receive_queuing_message(id, timeout.into(), buffer)? as usize;
-            Ok(&buffer[..len])
+        ) -> Result<(&[ApexByte], QueueOverflow), Error> {
+            let (len, overflow) = Q::receive_queuing_message(id, timeout.into(), buffer)?;
+            Ok((&buffer[..(len as usize)], overflow))
         }
     }
 
@@ -283,7 +290,7 @@ pub mod abstraction {
             &self,
             buffer: &'a mut [ApexByte],
             timeout: SystemTime,
-        ) -> Result<&'a [ApexByte], Error> {
+        ) -> Result<(&'a [ApexByte], QueueOverflow), Error> {
             buffer.validate_read(MSG_SIZE)?;
             unsafe { Q::queueing_port_receive_unchecked(self.id, timeout, buffer) }
         }

From ec56deeeee85f7ee179ef445c8be7d9aaef0d9fb Mon Sep 17 00:00:00 2001
From: Sven Friedrich <sven@autumnal.de>
Date: Tue, 30 Jan 2024 11:33:51 +0100
Subject: [PATCH 2/2] chore(a653rs): release 0.5.0

---
 Cargo.toml | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/Cargo.toml b/Cargo.toml
index fcd5848..4b8de00 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "a653rs"
-version = "0.4.1"
+version = "0.5.0"
 edition = "2021"
 authors = ["Sven Friedrich <sven.friedrich@dlr.de>"]
 license = "MIT OR Apache-2.0"