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>, id: QueuingPortId, } - impl Clone + impl Clone for QueuingPortSender { 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>, id: QueuingPortId, } - impl Clone + impl Clone for QueuingPortReceiver { fn clone(&self) -> Self { @@ -239,7 +239,7 @@ pub mod abstraction { } } - impl + impl QueuingPortSender { pub fn send(&self, buffer: &[ApexByte], timeout: SystemTime) -> Result<(), Error> { @@ -268,7 +268,7 @@ pub mod abstraction { } } - impl + impl QueuingPortSender { pub fn from_name(name: Name) -> Result, Error> { @@ -276,7 +276,7 @@ pub mod abstraction { } } - impl + impl QueuingPortReceiver { pub fn receive<'a>( @@ -318,7 +318,7 @@ pub mod abstraction { } } - impl + impl QueuingPortReceiver { pub fn from_name(name: Name) -> Result, Error> { @@ -326,7 +326,7 @@ pub mod abstraction { } } - impl StartContext { + impl StartContext { 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 { + pub struct SamplingPortSource { _b: PhantomData>, id: SamplingPortId, } - impl Clone for SamplingPortSource { + impl Clone + for SamplingPortSource + { fn clone(&self) -> Self { Self { _b: self._b, @@ -112,13 +114,13 @@ pub mod abstraction { } #[derive(Debug)] - pub struct SamplingPortDestination { + pub struct SamplingPortDestination { _b: PhantomData>, id: SamplingPortId, refresh: Duration, } - impl Clone + impl Clone for SamplingPortDestination { fn clone(&self) -> Self { @@ -244,7 +246,7 @@ pub mod abstraction { } } - impl SamplingPortSource { + impl SamplingPortSource { 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 SamplingPortSource { + impl SamplingPortSource { pub fn from_name(name: Name) -> Result, Error> { S::get_sampling_port_source(name) } @@ -273,7 +275,7 @@ pub mod abstraction { } } - impl SamplingPortDestination { + impl SamplingPortDestination { pub fn receive<'a>( &self, buffer: &'a mut [ApexByte], @@ -295,7 +297,7 @@ pub mod abstraction { } } - impl SamplingPortDestination { + impl SamplingPortDestination { pub fn from_name(name: Name) -> Result, Error> { S::get_sampling_port_destination(name) } @@ -309,7 +311,7 @@ pub mod abstraction { } } - impl StartContext { + impl StartContext { pub fn create_sampling_port_source( &mut self, name: Name,