| 1 | use crate::errors::OutIsTooSmallError; | 
| 2 | use core::{marker::PhantomData, slice}; | 
|---|
| 3 |  | 
|---|
| 4 | #[ cfg(feature = "block-padding")] | 
|---|
| 5 | use crate::errors::PadError; | 
|---|
| 6 | #[ cfg(feature = "block-padding")] | 
|---|
| 7 | use crate::{InOut, InOutBuf}; | 
|---|
| 8 | #[ cfg(feature = "block-padding")] | 
|---|
| 9 | use block_padding::{PadType, Padding}; | 
|---|
| 10 | #[ cfg(feature = "block-padding")] | 
|---|
| 11 | use generic_array::{ArrayLength, GenericArray}; | 
|---|
| 12 |  | 
|---|
| 13 | /// Custom slice type which references one immutable (input) slice and one | 
|---|
| 14 | /// mutable (output) slice. Input and output slices are either the same or | 
|---|
| 15 | /// do not overlap. Length of the output slice is always equal or bigger than | 
|---|
| 16 | /// length of the input slice. | 
|---|
| 17 | pub struct InOutBufReserved<'inp, 'out, T> { | 
|---|
| 18 | in_ptr: *const T, | 
|---|
| 19 | out_ptr: *mut T, | 
|---|
| 20 | in_len: usize, | 
|---|
| 21 | out_len: usize, | 
|---|
| 22 | _pd: PhantomData<(&'inp T, &'out mut T)>, | 
|---|
| 23 | } | 
|---|
| 24 |  | 
|---|
| 25 | impl<'a, T> InOutBufReserved<'a, 'a, T> { | 
|---|
| 26 | /// Crate [`InOutBufReserved`] from a single mutable slice. | 
|---|
| 27 | pub fn from_mut_slice(buf: &'a mut [T], msg_len: usize) -> Result<Self, OutIsTooSmallError> { | 
|---|
| 28 | if msg_len > buf.len() { | 
|---|
| 29 | return Err(OutIsTooSmallError); | 
|---|
| 30 | } | 
|---|
| 31 | let p = buf.as_mut_ptr(); | 
|---|
| 32 | let out_len = buf.len(); | 
|---|
| 33 | Ok(Self { | 
|---|
| 34 | in_ptr: p, | 
|---|
| 35 | out_ptr: p, | 
|---|
| 36 | in_len: msg_len, | 
|---|
| 37 | out_len, | 
|---|
| 38 | _pd: PhantomData, | 
|---|
| 39 | }) | 
|---|
| 40 | } | 
|---|
| 41 |  | 
|---|
| 42 | /// Create [`InOutBufReserved`] from raw input and output pointers. | 
|---|
| 43 | /// | 
|---|
| 44 | /// # Safety | 
|---|
| 45 | /// Behavior is undefined if any of the following conditions are violated: | 
|---|
| 46 | /// - `in_ptr` must point to a properly initialized value of type `T` and | 
|---|
| 47 | /// must be valid for reads for `in_len * mem::size_of::<T>()` many bytes. | 
|---|
| 48 | /// - `out_ptr` must point to a properly initialized value of type `T` and | 
|---|
| 49 | /// must be valid for both reads and writes for `out_len * mem::size_of::<T>()` | 
|---|
| 50 | /// many bytes. | 
|---|
| 51 | /// - `in_ptr` and `out_ptr` must be either equal or non-overlapping. | 
|---|
| 52 | /// - If `in_ptr` and `out_ptr` are equal, then the memory referenced by | 
|---|
| 53 | /// them must not be accessed through any other pointer (not derived from | 
|---|
| 54 | /// the return value) for the duration of lifetime 'a. Both read and write | 
|---|
| 55 | /// accesses are forbidden. | 
|---|
| 56 | /// - If `in_ptr` and `out_ptr` are not equal, then the memory referenced by | 
|---|
| 57 | /// `out_ptr` must not be accessed through any other pointer (not derived from | 
|---|
| 58 | /// the return value) for the duration of lifetime 'a. Both read and write | 
|---|
| 59 | /// accesses are forbidden. The memory referenced by `in_ptr` must not be | 
|---|
| 60 | /// mutated for the duration of lifetime `'a`, except inside an `UnsafeCell`. | 
|---|
| 61 | /// - The total size `in_len * mem::size_of::<T>()` and | 
|---|
| 62 | /// `out_len * mem::size_of::<T>()`  must be no larger than `isize::MAX`. | 
|---|
| 63 | #[ inline(always)] | 
|---|
| 64 | pub unsafe fn from_raw( | 
|---|
| 65 | in_ptr: *const T, | 
|---|
| 66 | in_len: usize, | 
|---|
| 67 | out_ptr: *mut T, | 
|---|
| 68 | out_len: usize, | 
|---|
| 69 | ) -> Self { | 
|---|
| 70 | Self { | 
|---|
| 71 | in_ptr, | 
|---|
| 72 | out_ptr, | 
|---|
| 73 | in_len, | 
|---|
| 74 | out_len, | 
|---|
| 75 | _pd: PhantomData, | 
|---|
| 76 | } | 
|---|
| 77 | } | 
|---|
| 78 |  | 
|---|
| 79 | /// Get raw input and output pointers. | 
|---|
| 80 | #[ inline(always)] | 
|---|
| 81 | pub fn into_raw(self) -> (*const T, *mut T) { | 
|---|
| 82 | (self.in_ptr, self.out_ptr) | 
|---|
| 83 | } | 
|---|
| 84 |  | 
|---|
| 85 | /// Get input buffer length. | 
|---|
| 86 | #[ inline(always)] | 
|---|
| 87 | pub fn get_in_len(&self) -> usize { | 
|---|
| 88 | self.in_len | 
|---|
| 89 | } | 
|---|
| 90 |  | 
|---|
| 91 | /// Get output buffer length. | 
|---|
| 92 | #[ inline(always)] | 
|---|
| 93 | pub fn get_out_len(&self) -> usize { | 
|---|
| 94 | self.in_len | 
|---|
| 95 | } | 
|---|
| 96 | } | 
|---|
| 97 |  | 
|---|
| 98 | impl<'inp, 'out, T> InOutBufReserved<'inp, 'out, T> { | 
|---|
| 99 | /// Crate [`InOutBufReserved`] from two separate slices. | 
|---|
| 100 | pub fn from_slices( | 
|---|
| 101 | in_buf: &'inp [T], | 
|---|
| 102 | out_buf: &'out mut [T], | 
|---|
| 103 | ) -> Result<Self, OutIsTooSmallError> { | 
|---|
| 104 | if in_buf.len() > out_buf.len() { | 
|---|
| 105 | return Err(OutIsTooSmallError); | 
|---|
| 106 | } | 
|---|
| 107 | Ok(Self { | 
|---|
| 108 | in_ptr: in_buf.as_ptr(), | 
|---|
| 109 | out_ptr: out_buf.as_mut_ptr(), | 
|---|
| 110 | in_len: in_buf.len(), | 
|---|
| 111 | out_len: out_buf.len(), | 
|---|
| 112 | _pd: PhantomData, | 
|---|
| 113 | }) | 
|---|
| 114 | } | 
|---|
| 115 |  | 
|---|
| 116 | /// Get input slice. | 
|---|
| 117 | #[ inline(always)] | 
|---|
| 118 | pub fn get_in<'a>(&'a self) -> &'a [T] { | 
|---|
| 119 | unsafe { slice::from_raw_parts(self.in_ptr, self.in_len) } | 
|---|
| 120 | } | 
|---|
| 121 |  | 
|---|
| 122 | /// Get output slice. | 
|---|
| 123 | #[ inline(always)] | 
|---|
| 124 | pub fn get_out<'a>(&'a mut self) -> &'a mut [T] { | 
|---|
| 125 | unsafe { slice::from_raw_parts_mut(self.out_ptr, self.out_len) } | 
|---|
| 126 | } | 
|---|
| 127 | } | 
|---|
| 128 |  | 
|---|
| 129 | impl<'inp, 'out> InOutBufReserved<'inp, 'out, u8> { | 
|---|
| 130 | /// Transform buffer into [`PaddedInOutBuf`] using padding algorithm `P`. | 
|---|
| 131 | #[ cfg(feature = "block-padding")] | 
|---|
| 132 | #[ cfg_attr(docsrs, doc(cfg(feature = "block-padding")))] | 
|---|
| 133 | #[ inline(always)] | 
|---|
| 134 | pub fn into_padded_blocks<P, BS>(self) -> Result<PaddedInOutBuf<'inp, 'out, BS>, PadError> | 
|---|
| 135 | where | 
|---|
| 136 | P: Padding<BS>, | 
|---|
| 137 | BS: ArrayLength<u8>, | 
|---|
| 138 | { | 
|---|
| 139 | let bs = BS::USIZE; | 
|---|
| 140 | let blocks_len = self.in_len / bs; | 
|---|
| 141 | let tail_len = self.in_len - bs * blocks_len; | 
|---|
| 142 | let blocks = unsafe { | 
|---|
| 143 | InOutBuf::from_raw( | 
|---|
| 144 | self.in_ptr as *const GenericArray<u8, BS>, | 
|---|
| 145 | self.out_ptr as *mut GenericArray<u8, BS>, | 
|---|
| 146 | blocks_len, | 
|---|
| 147 | ) | 
|---|
| 148 | }; | 
|---|
| 149 | let mut tail_in = GenericArray::<u8, BS>::default(); | 
|---|
| 150 | let tail_out = match P::TYPE { | 
|---|
| 151 | PadType::NoPadding | PadType::Ambiguous if tail_len == 0 => None, | 
|---|
| 152 | PadType::NoPadding => return Err(PadError), | 
|---|
| 153 | PadType::Reversible | PadType::Ambiguous => { | 
|---|
| 154 | let blen = bs * blocks_len; | 
|---|
| 155 | let res_len = blen + bs; | 
|---|
| 156 | if res_len > self.out_len { | 
|---|
| 157 | return Err(PadError); | 
|---|
| 158 | } | 
|---|
| 159 | // SAFETY: `in_ptr + blen..in_ptr + blen + tail_len` | 
|---|
| 160 | // is valid region for reads and `tail_len` is smaller than `BS`. | 
|---|
| 161 | // we have verified that `blen + bs <= out_len`, in other words, | 
|---|
| 162 | // `out_ptr + blen..out_ptr + blen + bs` is valid region | 
|---|
| 163 | // for writes. | 
|---|
| 164 | let out_block = unsafe { | 
|---|
| 165 | core::ptr::copy_nonoverlapping( | 
|---|
| 166 | self.in_ptr.add(blen), | 
|---|
| 167 | tail_in.as_mut_ptr(), | 
|---|
| 168 | tail_len, | 
|---|
| 169 | ); | 
|---|
| 170 | &mut *(self.out_ptr.add(blen) as *mut GenericArray<u8, BS>) | 
|---|
| 171 | }; | 
|---|
| 172 | P::pad(&mut tail_in, tail_len); | 
|---|
| 173 | Some(out_block) | 
|---|
| 174 | } | 
|---|
| 175 | }; | 
|---|
| 176 | Ok(PaddedInOutBuf { | 
|---|
| 177 | blocks, | 
|---|
| 178 | tail_in, | 
|---|
| 179 | tail_out, | 
|---|
| 180 | }) | 
|---|
| 181 | } | 
|---|
| 182 | } | 
|---|
| 183 |  | 
|---|
| 184 | /// Variant of [`InOutBuf`] with optional padded tail block. | 
|---|
| 185 | #[ cfg(feature = "block-padding")] | 
|---|
| 186 | #[ cfg_attr(docsrs, doc(cfg(feature = "block-padding")))] | 
|---|
| 187 | pub struct PaddedInOutBuf<'inp, 'out, BS: ArrayLength<u8>> { | 
|---|
| 188 | blocks: InOutBuf<'inp, 'out, GenericArray<u8, BS>>, | 
|---|
| 189 | tail_in: GenericArray<u8, BS>, | 
|---|
| 190 | tail_out: Option<&'out mut GenericArray<u8, BS>>, | 
|---|
| 191 | } | 
|---|
| 192 |  | 
|---|
| 193 | #[ cfg(feature = "block-padding")] | 
|---|
| 194 | impl<'inp, 'out, BS: ArrayLength<u8>> PaddedInOutBuf<'inp, 'out, BS> { | 
|---|
| 195 | /// Get full blocks. | 
|---|
| 196 | #[ inline(always)] | 
|---|
| 197 | pub fn get_blocks<'a>(&'a mut self) -> InOutBuf<'a, 'a, GenericArray<u8, BS>> { | 
|---|
| 198 | self.blocks.reborrow() | 
|---|
| 199 | } | 
|---|
| 200 |  | 
|---|
| 201 | /// Get padded tail block. | 
|---|
| 202 | /// | 
|---|
| 203 | /// For paddings with `P::TYPE = PadType::Reversible` it always returns `Some`. | 
|---|
| 204 | #[ inline(always)] | 
|---|
| 205 | pub fn get_tail_block<'a>(&'a mut self) -> Option<InOut<'a, 'a, GenericArray<u8, BS>>> { | 
|---|
| 206 | match self.tail_out.as_deref_mut() { | 
|---|
| 207 | Some(out_block) => Some((&self.tail_in, out_block).into()), | 
|---|
| 208 | None => None, | 
|---|
| 209 | } | 
|---|
| 210 | } | 
|---|
| 211 |  | 
|---|
| 212 | /// Convert buffer into output slice. | 
|---|
| 213 | #[ inline(always)] | 
|---|
| 214 | pub fn into_out(self) -> &'out [u8] { | 
|---|
| 215 | let total_blocks = if self.tail_out.is_some() { | 
|---|
| 216 | self.blocks.len() + 1 | 
|---|
| 217 | } else { | 
|---|
| 218 | self.blocks.len() | 
|---|
| 219 | }; | 
|---|
| 220 | let res_len = BS::USIZE * total_blocks; | 
|---|
| 221 | let (_, out_ptr) = self.blocks.into_raw(); | 
|---|
| 222 | // SAFETY: `res_len` is always valid for the output buffer since | 
|---|
| 223 | // it's checked during type construction | 
|---|
| 224 | unsafe { slice::from_raw_parts(out_ptr as *const u8, res_len) } | 
|---|
| 225 | } | 
|---|
| 226 | } | 
|---|
| 227 |  | 
|---|