blob: 2db8d5f9f2679c9b967269a9423eb1d19e2666aa [file] [log] [blame] [edit]
use alloc::vec::Vec;
use arbitrary::{Arbitrary, Unstructured};
/// The control plane of chaos mode.
/// Please see the [crate-level documentation](crate).
#[derive(Debug, Clone, Default)]
pub struct ControlPlane {
data: Vec<u8>,
fuel: Option<u8>,
/// This is used as a little optimization to avoid additional heap
/// allocations when using `Unstructured` internally. See the source of
/// [`ControlPlane::shuffle`] for an example.
tmp: Vec<u8>,
}
impl Arbitrary<'_> for ControlPlane {
fn arbitrary<'a>(u: &mut arbitrary::Unstructured<'a>) -> arbitrary::Result<Self> {
Ok(Self::new(u.arbitrary()?))
}
}
impl ControlPlane {
fn new(data: Vec<u8>) -> Self {
Self {
data,
fuel: None,
tmp: Vec::new(),
}
}
/// Set the [fuel limit](crate#fuel-limit). Zero is interpreted as the
/// fuel limit being deactivated, consistent with the cranelift setting
/// `control_plane_fuel`.
pub fn set_fuel(&mut self, fuel: u8) {
self.fuel = (fuel != 0).then_some(fuel)
}
/// Tries to consume fuel, returning `true` if successful (or if
/// fuel-limiting is disabled).
fn consume_fuel(&mut self) -> bool {
match self.fuel {
None => true, // fuel deactivated
Some(f) if f == 0 => false, // no more fuel
Some(ref mut f) => {
*f -= 1;
true
}
}
}
/// Returns a pseudo-random boolean if the control plane was constructed
/// with `arbitrary`.
///
/// The default value `false` will always be returned if the
/// pseudo-random data is exhausted or the control plane was constructed
/// with `default`.
pub fn get_decision(&mut self) -> bool {
self.consume_fuel() && self.data.pop().unwrap_or_default() & 1 == 1
}
/// Returns an arbitrary value if the control plane was constructed with
/// `arbitrary`.
///
/// The default value will always be returned if the pseudo-random data is
/// exhausted or the control plane was constructed with `default`.
pub fn get_arbitrary<T: for<'a> Arbitrary<'a> + Default>(&mut self) -> T {
if !self.consume_fuel() || self.data.is_empty() {
return T::default();
}
let mut u = Unstructured::new(&self.data);
let res = u.arbitrary().unwrap_or_default();
// take remaining bytes
let rest = u.take_rest();
self.tmp.resize(rest.len(), 0); // allocates once per control plane
self.tmp.copy_from_slice(rest);
core::mem::swap(&mut self.data, &mut self.tmp);
res
}
/// Shuffles the items in the slice into a pseudo-random permutation if
/// the control plane was constructed with `arbitrary`.
///
/// The default operation, to leave the slice unchanged, will always be
/// performed if the pseudo-random data is exhausted or the control
/// plane was constructed with `default`.
pub fn shuffle<T>(&mut self, slice: &mut [T]) {
if !self.consume_fuel() || self.data.is_empty() {
return;
}
let mut u = Unstructured::new(&self.data);
// adapted from:
// https://docs.rs/arbitrary/1.3.0/arbitrary/struct.Unstructured.html#examples-1
let mut to_permute = &mut slice[..];
while to_permute.len() > 1 {
if let Ok(idx) = u.choose_index(to_permute.len()) {
to_permute.swap(0, idx);
to_permute = &mut to_permute[1..];
} else {
break;
}
}
// take remaining bytes
let rest = u.take_rest();
self.tmp.resize(rest.len(), 0); // allocates once per control plane
self.tmp.copy_from_slice(rest);
core::mem::swap(&mut self.data, &mut self.tmp);
}
/// Returns a new iterator over the same items as the input iterator in
/// a pseudo-random order if the control plane was constructed with
/// `arbitrary`.
///
/// The default value, an iterator with an unchanged order, will always
/// be returned if the pseudo-random data is exhausted or the control
/// plane was constructed with `default`.
pub fn shuffled<T>(&mut self, iter: impl Iterator<Item = T>) -> impl Iterator<Item = T> {
let mut slice: Vec<_> = iter.collect();
self.shuffle(&mut slice);
slice.into_iter()
}
}