From 160ac3de7dce9fd668f4678c4bba32f7ad3eb60b Mon Sep 17 00:00:00 2001
From: Sven Friedrich <sven@autumnal.de>
Date: Wed, 24 Jan 2024 15:41:46 +0100
Subject: [PATCH] fix: change required trait for Queuing and Sampling Ports to
 Ext version

---
 src/apex/queuing.rs  | 18 +++++++++---------
 src/apex/sampling.rs | 20 +++++++++++---------
 2 files changed, 20 insertions(+), 18 deletions(-)

diff --git a/src/apex/queuing.rs b/src/apex/queuing.rs
index a1083c3..a124354 100644
--- a/src/apex/queuing.rs
+++ b/src/apex/queuing.rs
@@ -74,13 +74,13 @@ pub mod abstraction {
     pub struct QueuingPortSender<
         const MSG_SIZE: MessageSize,
         const NB_MSGS: MessageRange,
-        Q: ApexQueuingPortP4,
+        Q: ApexQueuingPortP4Ext,
     > {
         _b: PhantomData<AtomicPtr<Q>>,
         id: QueuingPortId,
     }
 
-    impl<const MSG_SIZE: MessageSize, const NB_MSGS: MessageRange, S: ApexQueuingPortP4> Clone
+    impl<const MSG_SIZE: MessageSize, const NB_MSGS: MessageRange, S: ApexQueuingPortP4Ext> Clone
         for QueuingPortSender<MSG_SIZE, NB_MSGS, S>
     {
         fn clone(&self) -> Self {
@@ -95,13 +95,13 @@ pub mod abstraction {
     pub struct QueuingPortReceiver<
         const MSG_SIZE: MessageSize,
         const NB_MSGS: MessageRange,
-        Q: ApexQueuingPortP4,
+        Q: ApexQueuingPortP4Ext,
     > {
         _b: PhantomData<AtomicPtr<Q>>,
         id: QueuingPortId,
     }
 
-    impl<const MSG_SIZE: MessageSize, const NB_MSGS: MessageRange, S: ApexQueuingPortP4> Clone
+    impl<const MSG_SIZE: MessageSize, const NB_MSGS: MessageRange, S: ApexQueuingPortP4Ext> Clone
         for QueuingPortReceiver<MSG_SIZE, NB_MSGS, S>
     {
         fn clone(&self) -> Self {
@@ -239,7 +239,7 @@ pub mod abstraction {
         }
     }
 
-    impl<const MSG_SIZE: MessageSize, const NB_MSGS: MessageRange, Q: ApexQueuingPortP4>
+    impl<const MSG_SIZE: MessageSize, const NB_MSGS: MessageRange, Q: ApexQueuingPortP4Ext>
         QueuingPortSender<MSG_SIZE, NB_MSGS, Q>
     {
         pub fn send(&self, buffer: &[ApexByte], timeout: SystemTime) -> Result<(), Error> {
@@ -268,7 +268,7 @@ pub mod abstraction {
         }
     }
 
-    impl<const MSG_SIZE: MessageSize, const NB_MSGS: MessageRange, Q: ApexQueuingPortP1>
+    impl<const MSG_SIZE: MessageSize, const NB_MSGS: MessageRange, Q: ApexQueuingPortP1Ext>
         QueuingPortSender<MSG_SIZE, NB_MSGS, Q>
     {
         pub fn from_name(name: Name) -> Result<QueuingPortSender<MSG_SIZE, NB_MSGS, Q>, Error> {
@@ -276,7 +276,7 @@ pub mod abstraction {
         }
     }
 
-    impl<const MSG_SIZE: MessageSize, const NB_MSGS: MessageRange, Q: ApexQueuingPortP4>
+    impl<const MSG_SIZE: MessageSize, const NB_MSGS: MessageRange, Q: ApexQueuingPortP4Ext>
         QueuingPortReceiver<MSG_SIZE, NB_MSGS, Q>
     {
         pub fn receive<'a>(
@@ -318,7 +318,7 @@ pub mod abstraction {
         }
     }
 
-    impl<const MSG_SIZE: MessageSize, const NB_MSGS: MessageRange, Q: ApexQueuingPortP1>
+    impl<const MSG_SIZE: MessageSize, const NB_MSGS: MessageRange, Q: ApexQueuingPortP1Ext>
         QueuingPortReceiver<MSG_SIZE, NB_MSGS, Q>
     {
         pub fn from_name(name: Name) -> Result<QueuingPortReceiver<MSG_SIZE, NB_MSGS, Q>, Error> {
@@ -326,7 +326,7 @@ pub mod abstraction {
         }
     }
 
-    impl<Q: ApexQueuingPortP4> StartContext<Q> {
+    impl<Q: ApexQueuingPortP4Ext> StartContext<Q> {
         pub fn create_queuing_port_sender<
             const MSG_SIZE: MessageSize,
             const NB_MSGS: MessageRange,
diff --git a/src/apex/sampling.rs b/src/apex/sampling.rs
index 47efe91..1dce440 100644
--- a/src/apex/sampling.rs
+++ b/src/apex/sampling.rs
@@ -97,12 +97,14 @@ pub mod abstraction {
     }
 
     #[derive(Debug)]
-    pub struct SamplingPortSource<const MSG_SIZE: MessageSize, S: ApexSamplingPortP4> {
+    pub struct SamplingPortSource<const MSG_SIZE: MessageSize, S: ApexSamplingPortP4Ext> {
         _b: PhantomData<AtomicPtr<S>>,
         id: SamplingPortId,
     }
 
-    impl<const MSG_SIZE: MessageSize, S: ApexSamplingPortP4> Clone for SamplingPortSource<MSG_SIZE, S> {
+    impl<const MSG_SIZE: MessageSize, S: ApexSamplingPortP4Ext> Clone
+        for SamplingPortSource<MSG_SIZE, S>
+    {
         fn clone(&self) -> Self {
             Self {
                 _b: self._b,
@@ -112,13 +114,13 @@ pub mod abstraction {
     }
 
     #[derive(Debug)]
-    pub struct SamplingPortDestination<const MSG_SIZE: MessageSize, S: ApexSamplingPortP4> {
+    pub struct SamplingPortDestination<const MSG_SIZE: MessageSize, S: ApexSamplingPortP4Ext> {
         _b: PhantomData<AtomicPtr<S>>,
         id: SamplingPortId,
         refresh: Duration,
     }
 
-    impl<const MSG_SIZE: MessageSize, S: ApexSamplingPortP4> Clone
+    impl<const MSG_SIZE: MessageSize, S: ApexSamplingPortP4Ext> Clone
         for SamplingPortDestination<MSG_SIZE, S>
     {
         fn clone(&self) -> Self {
@@ -244,7 +246,7 @@ pub mod abstraction {
         }
     }
 
-    impl<const MSG_SIZE: MessageSize, S: ApexSamplingPortP4> SamplingPortSource<MSG_SIZE, S> {
+    impl<const MSG_SIZE: MessageSize, S: ApexSamplingPortP4Ext> SamplingPortSource<MSG_SIZE, S> {
         pub fn send(&self, buffer: &[ApexByte]) -> Result<(), Error> {
             buffer.validate_write(MSG_SIZE)?;
             S::sampling_port_send_unchecked(self.id, buffer)
@@ -259,7 +261,7 @@ pub mod abstraction {
         }
     }
 
-    impl<const MSG_SIZE: MessageSize, S: ApexSamplingPortP1> SamplingPortSource<MSG_SIZE, S> {
+    impl<const MSG_SIZE: MessageSize, S: ApexSamplingPortP1Ext> SamplingPortSource<MSG_SIZE, S> {
         pub fn from_name(name: Name) -> Result<SamplingPortSource<MSG_SIZE, S>, Error> {
             S::get_sampling_port_source(name)
         }
@@ -273,7 +275,7 @@ pub mod abstraction {
         }
     }
 
-    impl<const MSG_SIZE: MessageSize, S: ApexSamplingPortP4> SamplingPortDestination<MSG_SIZE, S> {
+    impl<const MSG_SIZE: MessageSize, S: ApexSamplingPortP4Ext> SamplingPortDestination<MSG_SIZE, S> {
         pub fn receive<'a>(
             &self,
             buffer: &'a mut [ApexByte],
@@ -295,7 +297,7 @@ pub mod abstraction {
         }
     }
 
-    impl<const MSG_SIZE: MessageSize, S: ApexSamplingPortP1> SamplingPortDestination<MSG_SIZE, S> {
+    impl<const MSG_SIZE: MessageSize, S: ApexSamplingPortP1Ext> SamplingPortDestination<MSG_SIZE, S> {
         pub fn from_name(name: Name) -> Result<SamplingPortDestination<MSG_SIZE, S>, Error> {
             S::get_sampling_port_destination(name)
         }
@@ -309,7 +311,7 @@ pub mod abstraction {
         }
     }
 
-    impl<S: ApexSamplingPortP4> StartContext<S> {
+    impl<S: ApexSamplingPortP4Ext> StartContext<S> {
         pub fn create_sampling_port_source<const MSG_SIZE: MessageSize>(
             &mut self,
             name: Name,