adaptions for spacepackets update
Some checks failed
Rust/sat-rs/pipeline/head There was a failure building this commit
Rust/sat-rs/pipeline/pr-main There was a failure building this commit

This commit is contained in:
Robin Müller 2023-08-18 10:21:15 +02:00
parent 698c2edb93
commit ad01472a8e
Signed by: muellerr
GPG Key ID: FCE0B2BD2195142F
10 changed files with 47 additions and 47 deletions

View File

@ -61,10 +61,11 @@ default-features = false
optional = true optional = true
[dependencies.spacepackets] [dependencies.spacepackets]
# version = "0.6" version = "0.7.0-beta.0"
# path = "../spacepackets" path = "../../spacepackets"
git = "https://egit.irs.uni-stuttgart.de/rust/spacepackets.git" # git = "https://egit.irs.uni-stuttgart.de/rust/spacepackets.git"
rev = "62df510147b" # rev = ""
# branch = "size-missmatch-struct-variant"
default-features = false default-features = false
[dev-dependencies] [dev-dependencies]

View File

@ -33,7 +33,7 @@ use core::marker::PhantomData;
use delegate::delegate; use delegate::delegate;
use spacepackets::ecss::EcssEnumeration; use spacepackets::ecss::EcssEnumeration;
use spacepackets::util::{ToBeBytes, UnsignedEnum}; use spacepackets::util::{ToBeBytes, UnsignedEnum};
use spacepackets::{ByteConversionError, SizeMissmatch}; use spacepackets::ByteConversionError;
/// Using a type definition allows to change this to u64 in the future more easily /// Using a type definition allows to change this to u64 in the future more easily
pub type LargestEventRaw = u32; pub type LargestEventRaw = u32;
@ -124,10 +124,10 @@ impl<RAW: ToBeBytes, GID, UID> EventBase<RAW, GID, UID> {
width: usize, width: usize,
) -> Result<usize, ByteConversionError> { ) -> Result<usize, ByteConversionError> {
if buf.len() < width { if buf.len() < width {
return Err(ByteConversionError::ToSliceTooSmall(SizeMissmatch { return Err(ByteConversionError::ToSliceTooSmall {
found: buf.len(), found: buf.len(),
expected: width, expected: width,
})); });
} }
buf.copy_from_slice(raw.to_be_bytes().as_ref()); buf.copy_from_slice(raw.to_be_bytes().as_ref());
Ok(raw.written_len()) Ok(raw.written_len())
@ -783,9 +783,9 @@ mod tests {
let err = HIGH_SEV_EVENT.write_to_be_bytes(&mut buf); let err = HIGH_SEV_EVENT.write_to_be_bytes(&mut buf);
assert!(err.is_err()); assert!(err.is_err());
let err = err.unwrap_err(); let err = err.unwrap_err();
if let ByteConversionError::ToSliceTooSmall(missmatch) = err { if let ByteConversionError::ToSliceTooSmall { found, expected } = err {
assert_eq!(missmatch.expected, 4); assert_eq!(expected, 4);
assert_eq!(missmatch.found, 3); assert_eq!(found, 3);
} }
} }
@ -795,9 +795,9 @@ mod tests {
let err = HIGH_SEV_EVENT_SMALL.write_to_be_bytes(&mut buf); let err = HIGH_SEV_EVENT_SMALL.write_to_be_bytes(&mut buf);
assert!(err.is_err()); assert!(err.is_err());
let err = err.unwrap_err(); let err = err.unwrap_err();
if let ByteConversionError::ToSliceTooSmall(missmatch) = err { if let ByteConversionError::ToSliceTooSmall { found, expected } = err {
assert_eq!(missmatch.expected, 2); assert_eq!(expected, 2);
assert_eq!(missmatch.found, 1); assert_eq!(found, 1);
} }
} }

View File

@ -2,7 +2,7 @@ use crate::tmtc::TargetId;
use core::mem::size_of; use core::mem::size_of;
#[cfg(feature = "serde")] #[cfg(feature = "serde")]
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use spacepackets::{ByteConversionError, SizeMissmatch}; use spacepackets::ByteConversionError;
#[derive(Debug, Copy, Clone, PartialEq, Eq)] #[derive(Debug, Copy, Clone, PartialEq, Eq)]
#[cfg_attr(feature = "serde", derive(Serialize, Deserialize))] #[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
@ -26,10 +26,10 @@ impl ModeAndSubmode {
pub fn from_be_bytes(buf: &[u8]) -> Result<Self, ByteConversionError> { pub fn from_be_bytes(buf: &[u8]) -> Result<Self, ByteConversionError> {
if buf.len() < 6 { if buf.len() < 6 {
return Err(ByteConversionError::FromSliceTooSmall(SizeMissmatch { return Err(ByteConversionError::FromSliceTooSmall {
expected: 6, expected: 6,
found: buf.len(), found: buf.len(),
})); });
} }
Ok(Self { Ok(Self {
mode: u32::from_be_bytes(buf[0..4].try_into().unwrap()), mode: u32::from_be_bytes(buf[0..4].try_into().unwrap()),

View File

@ -55,7 +55,6 @@ use paste::paste;
use spacepackets::ecss::{EcssEnumU16, EcssEnumU32, EcssEnumU64, EcssEnumU8}; use spacepackets::ecss::{EcssEnumU16, EcssEnumU32, EcssEnumU64, EcssEnumU8};
use spacepackets::util::UnsignedEnum; use spacepackets::util::UnsignedEnum;
use spacepackets::ByteConversionError; use spacepackets::ByteConversionError;
use spacepackets::SizeMissmatch;
#[cfg(feature = "alloc")] #[cfg(feature = "alloc")]
pub use alloc_mod::*; pub use alloc_mod::*;
@ -80,10 +79,10 @@ macro_rules! param_to_be_bytes_impl {
fn write_to_be_bytes(&self, buf: &mut [u8]) -> Result<usize, ByteConversionError> { fn write_to_be_bytes(&self, buf: &mut [u8]) -> Result<usize, ByteConversionError> {
let raw_len = self.raw_len(); let raw_len = self.raw_len();
if buf.len() < raw_len { if buf.len() < raw_len {
return Err(ByteConversionError::ToSliceTooSmall(SizeMissmatch { return Err(ByteConversionError::ToSliceTooSmall {
found: buf.len(), found: buf.len(),
expected: raw_len, expected: raw_len,
})); });
} }
buf[0..raw_len].copy_from_slice(&self.to_be_bytes()); buf[0..raw_len].copy_from_slice(&self.to_be_bytes());
Ok(raw_len) Ok(raw_len)
@ -186,10 +185,10 @@ macro_rules! scalar_byte_conversions_impl {
fn try_from(v: &[u8]) -> Result<Self, Self::Error> { fn try_from(v: &[u8]) -> Result<Self, Self::Error> {
if v.len() < size_of::<$ty>() { if v.len() < size_of::<$ty>() {
return Err(ByteConversionError::FromSliceTooSmall(SizeMissmatch { return Err(ByteConversionError::FromSliceTooSmall{
expected: size_of::<$ty>(), expected: size_of::<$ty>(),
found: v.len() found: v.len()
})); });
} }
Ok([<$ty:upper>]($ty::from_be_bytes(v[0..size_of::<$ty>()].try_into().unwrap()))) Ok([<$ty:upper>]($ty::from_be_bytes(v[0..size_of::<$ty>()].try_into().unwrap())))
} }
@ -225,10 +224,10 @@ macro_rules! pair_byte_conversions_impl {
fn try_from(v: &[u8]) -> Result<Self, Self::Error> { fn try_from(v: &[u8]) -> Result<Self, Self::Error> {
if v.len() < 2 * size_of::<$ty>() { if v.len() < 2 * size_of::<$ty>() {
return Err(ByteConversionError::FromSliceTooSmall(SizeMissmatch { return Err(ByteConversionError::FromSliceTooSmall{
expected: 2 * size_of::<$ty>(), expected: 2 * size_of::<$ty>(),
found: v.len() found: v.len()
})); });
} }
Ok([<$ty:upper Pair>]( Ok([<$ty:upper Pair>](
$ty::from_be_bytes(v[0..size_of::<$ty>()].try_into().unwrap()), $ty::from_be_bytes(v[0..size_of::<$ty>()].try_into().unwrap()),
@ -269,10 +268,10 @@ macro_rules! triplet_to_be_bytes_impl {
fn try_from(v: &[u8]) -> Result<Self, Self::Error> { fn try_from(v: &[u8]) -> Result<Self, Self::Error> {
if v.len() < 3 * size_of::<$ty>() { if v.len() < 3 * size_of::<$ty>() {
return Err(ByteConversionError::FromSliceTooSmall(SizeMissmatch { return Err(ByteConversionError::FromSliceTooSmall{
expected: 3 * size_of::<$ty>(), expected: 3 * size_of::<$ty>(),
found: v.len() found: v.len()
})); });
} }
Ok([<$ty:upper Triplet>]( Ok([<$ty:upper Triplet>](
$ty::from_be_bytes(v[0..size_of::<$ty>()].try_into().unwrap()), $ty::from_be_bytes(v[0..size_of::<$ty>()].try_into().unwrap()),

View File

@ -425,12 +425,12 @@ mod tests {
let err = reporter.event_info(sender, &time_stamp_empty, event, None); let err = reporter.event_info(sender, &time_stamp_empty, event, None);
assert!(err.is_err()); assert!(err.is_err());
let err = err.unwrap_err(); let err = err.unwrap_err();
if let EcssTmtcError::Pus(PusError::ByteConversion(ByteConversionError::ToSliceTooSmall( if let EcssTmtcError::Pus(PusError::ByteConversion(
missmatch, ByteConversionError::ToSliceTooSmall { found, expected },
))) = err )) = err
{ {
assert_eq!(missmatch.expected, 4); assert_eq!(expected, 4);
assert_eq!(missmatch.found, expected_found_len); assert_eq!(found, expected_found_len);
} else { } else {
panic!("Unexpected error {:?}", err); panic!("Unexpected error {:?}", err);
} }

View File

@ -14,7 +14,7 @@ use std::error::Error;
use spacepackets::ecss::tc::{PusTcCreator, PusTcReader}; use spacepackets::ecss::tc::{PusTcCreator, PusTcReader};
use spacepackets::ecss::tm::PusTmCreator; use spacepackets::ecss::tm::PusTmCreator;
use spacepackets::ecss::PusError; use spacepackets::ecss::PusError;
use spacepackets::{ByteConversionError, SizeMissmatch, SpHeader}; use spacepackets::{ByteConversionError, SpHeader};
pub mod event; pub mod event;
pub mod event_man; pub mod event_man;
@ -735,10 +735,10 @@ pub mod std_mod {
pub(crate) fn source_buffer_large_enough(cap: usize, len: usize) -> Result<(), EcssTmtcError> { pub(crate) fn source_buffer_large_enough(cap: usize, len: usize) -> Result<(), EcssTmtcError> {
if len > cap { if len > cap {
return Err( return Err(
PusError::ByteConversion(ByteConversionError::ToSliceTooSmall(SizeMissmatch { PusError::ByteConversion(ByteConversionError::ToSliceTooSmall {
found: cap, found: cap,
expected: len, expected: len,
})) })
.into(), .into(),
); );
} }

View File

@ -1584,12 +1584,12 @@ mod tests {
assert_eq!(err_with_token.1, tok); assert_eq!(err_with_token.1, tok);
match err_with_token.0 { match err_with_token.0 {
EcssTmtcError::Pus(PusError::ByteConversion(e)) => match e { EcssTmtcError::Pus(PusError::ByteConversion(e)) => match e {
ByteConversionError::ToSliceTooSmall(missmatch) => { ByteConversionError::ToSliceTooSmall { found, expected } => {
assert_eq!( assert_eq!(
missmatch.expected, expected,
fail_data.len() + RequestId::SIZE_AS_BYTES + fail_code.size() fail_data.len() + RequestId::SIZE_AS_BYTES + fail_code.size()
); );
assert_eq!(missmatch.found, b.rep().allowed_source_data_len()); assert_eq!(found, b.rep().allowed_source_data_len());
} }
_ => { _ => {
panic!("{}", format!("Unexpected error {:?}", e)) panic!("{}", format!("Unexpected error {:?}", e))

View File

@ -2,7 +2,7 @@
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use spacepackets::ecss::{EcssEnumU16, EcssEnumeration}; use spacepackets::ecss::{EcssEnumU16, EcssEnumeration};
use spacepackets::util::UnsignedEnum; use spacepackets::util::UnsignedEnum;
use spacepackets::{ByteConversionError, SizeMissmatch}; use spacepackets::ByteConversionError;
#[derive(Debug, Copy, Clone, PartialEq, Eq)] #[derive(Debug, Copy, Clone, PartialEq, Eq)]
#[cfg_attr(feature = "serde", derive(Serialize, Deserialize))] #[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
@ -42,10 +42,10 @@ impl UnsignedEnum for ResultU16 {
fn write_to_be_bytes(&self, buf: &mut [u8]) -> Result<usize, ByteConversionError> { fn write_to_be_bytes(&self, buf: &mut [u8]) -> Result<usize, ByteConversionError> {
if buf.len() < 2 { if buf.len() < 2 {
return Err(ByteConversionError::ToSliceTooSmall(SizeMissmatch { return Err(ByteConversionError::ToSliceTooSmall {
found: buf.len(), found: buf.len(),
expected: 2, expected: 2,
})); });
} }
buf[0] = self.group_id; buf[0] = self.group_id;
buf[1] = self.unique_id; buf[1] = self.unique_id;

View File

@ -89,7 +89,7 @@ use crate::tmtc::{ReceivesCcsdsTc, ReceivesTcCore};
use alloc::boxed::Box; use alloc::boxed::Box;
use core::fmt::{Display, Formatter}; use core::fmt::{Display, Formatter};
use downcast_rs::Downcast; use downcast_rs::Downcast;
use spacepackets::{ByteConversionError, CcsdsPacket, SizeMissmatch, SpHeader}; use spacepackets::{ByteConversionError, CcsdsPacket, SpHeader};
#[cfg(feature = "std")] #[cfg(feature = "std")]
use std::error::Error; use std::error::Error;
@ -174,10 +174,10 @@ impl<E: 'static> ReceivesTcCore for CcsdsDistributor<E> {
fn pass_tc(&mut self, tc_raw: &[u8]) -> Result<(), Self::Error> { fn pass_tc(&mut self, tc_raw: &[u8]) -> Result<(), Self::Error> {
if tc_raw.len() < 7 { if tc_raw.len() < 7 {
return Err(CcsdsError::ByteConversionError( return Err(CcsdsError::ByteConversionError(
ByteConversionError::FromSliceTooSmall(SizeMissmatch { ByteConversionError::FromSliceTooSmall {
found: tc_raw.len(), found: tc_raw.len(),
expected: 7, expected: 7,
}), },
)); ));
} }
let (sp_header, _) = let (sp_header, _) =

View File

@ -9,7 +9,7 @@
use downcast_rs::{impl_downcast, Downcast}; use downcast_rs::{impl_downcast, Downcast};
#[cfg(feature = "serde")] #[cfg(feature = "serde")]
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use spacepackets::{ByteConversionError, SizeMissmatch, SpHeader}; use spacepackets::{ByteConversionError, SpHeader};
#[cfg(feature = "alloc")] #[cfg(feature = "alloc")]
pub mod ccsds_distrib; pub mod ccsds_distrib;
@ -34,10 +34,10 @@ pub struct AddressableId {
impl AddressableId { impl AddressableId {
pub fn from_raw_be(buf: &[u8]) -> Result<Self, ByteConversionError> { pub fn from_raw_be(buf: &[u8]) -> Result<Self, ByteConversionError> {
if buf.len() < 8 { if buf.len() < 8 {
return Err(ByteConversionError::FromSliceTooSmall(SizeMissmatch { return Err(ByteConversionError::FromSliceTooSmall {
found: buf.len(), found: buf.len(),
expected: 8, expected: 8,
})); });
} }
Ok(Self { Ok(Self {
target_id: u32::from_be_bytes(buf[0..4].try_into().unwrap()), target_id: u32::from_be_bytes(buf[0..4].try_into().unwrap()),
@ -47,10 +47,10 @@ impl AddressableId {
pub fn write_to_be_bytes(&self, buf: &mut [u8]) -> Result<usize, ByteConversionError> { pub fn write_to_be_bytes(&self, buf: &mut [u8]) -> Result<usize, ByteConversionError> {
if buf.len() < 8 { if buf.len() < 8 {
return Err(ByteConversionError::ToSliceTooSmall(SizeMissmatch { return Err(ByteConversionError::ToSliceTooSmall {
found: buf.len(), found: buf.len(),
expected: 8, expected: 8,
})); });
} }
buf[0..4].copy_from_slice(&self.target_id.to_be_bytes()); buf[0..4].copy_from_slice(&self.target_id.to_be_bytes());
buf[4..8].copy_from_slice(&self.unique_id.to_be_bytes()); buf[4..8].copy_from_slice(&self.unique_id.to_be_bytes());