Lines
51.16 %
Functions
56.1 %
Branches
0 %
#![forbid(unsafe_code)]
use std::fmt;
use merc_utilities::TagIndex;
/// A zero sized tag for the block.
pub struct BlockTag {}
/// The index for blocks.
pub type BlockIndex = TagIndex<usize, BlockTag>;
/// Special value used for elements that do not occur in the partition.
pub const NOT_IN_PARTITION: usize = usize::MAX;
/// Defines a partition based on an explicit indexing of elements to their block
/// number.
///
/// # Details
/// This partition always stores 0..max_value elements in the partition, but it
/// uses a special value to indicate that an element is not in the partition. So
/// this is not memory efficient.
#[derive(Clone, Debug)]
pub struct IndexedPartition {
/// Stores a mapping from element index to block number.
partition: Vec<BlockIndex>,
/// Keeps track of the number of blocks defined.
num_of_blocks: usize,
}
impl IndexedPartition {
/// Create a new partition with 0 to `num_of_elements` in a single block.
pub fn new(num_of_elements: usize) -> IndexedPartition {
IndexedPartition {
partition: vec![BlockIndex::new(0); num_of_elements],
num_of_blocks: 1,
/// Create a new partition where the given indices are in a single block.
pub fn with_subset<I>(num_of_elements: usize, included_indices: I) -> IndexedPartition
where
I: IntoIterator<Item = usize>,
{
let mut partition = vec![BlockIndex::new(NOT_IN_PARTITION); num_of_elements];
let mut has_included_indices = false;
for index in included_indices {
partition[index] = BlockIndex::new(0);
has_included_indices = true;
partition,
num_of_blocks: usize::from(has_included_indices),
/// Create a new partition with the given partitioning.
pub fn with_partition(partition: Vec<BlockIndex>, num_of_blocks: usize) -> IndexedPartition {
debug_assert!(
partition
.iter()
.all(|&block| block.value() < num_of_blocks || block.value() == NOT_IN_PARTITION),
"Block numbers must be less than the number of blocks, or equal to NOT_IN_PARTITION"
);
num_of_blocks,
/// Iterates over the blocks in the partition, blocks can be repeated.
pub fn iter(&self) -> impl Iterator<Item = BlockIndex> + '_ {
self.iter_elements().map(|(_, block)| block)
/// Iterates over element-block pairs in the partition.
pub fn iter_elements(&self) -> impl Iterator<Item = (usize, BlockIndex)> + '_ {
self.partition
.enumerate()
.filter_map(|(element_index, &block)| (block.value() != NOT_IN_PARTITION).then_some((element_index, block)))
/// Sets the block number of the given element
/// This assumes that the blocks numbers are dense, otherwise the partition
/// overestimates the total number of blocks present returned from [Self::num_of_blocks].
pub fn set_block(&mut self, element_index: usize, block_number: BlockIndex) {
block_number.value() != NOT_IN_PARTITION,
"Block number cannot be NOT_IN_PARTITION"
self.num_of_blocks = self.num_of_blocks.max(block_number.value() + 1);
self.partition[element_index] = block_number;
/// Returns the block number of the given element.
pub fn block(&self, element_index: usize) -> BlockIndex {
self.partition[element_index]
/// Returns the number of elements in the partition.
pub fn len(&self) -> usize {
self.partition.len()
/// Returns whether the partition is empty.
pub fn is_empty(&self) -> bool {
self.partition.is_empty()
/// Returns the number of blocks in the partition.
pub fn num_of_blocks(&self) -> usize {
self.num_of_blocks
/// Reorders the blocks of the given partition according to the given permutation.
pub fn reorder_partition<P>(partition: IndexedPartition, permutation: P) -> IndexedPartition
P: Fn(BlockIndex) -> BlockIndex,
let mut new_partition = partition.clone();
for (element_index, block) in partition.iter_elements() {
new_partition.set_block(element_index, permutation(block));
new_partition
impl fmt::Display for IndexedPartition {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
write!(f, "{{ ")?;
let mut first = true;
for block_index in self.iter() {
// Print all elements with the same block number.
let mut first_block = true;
for (element_index, _) in self.iter_elements().filter(|&(_, value)| value == block_index) {
if !first_block {
write!(f, ", ")?;
} else {
if !first {
write!(f, "{{")?;
write!(f, "{element_index}")?;
first_block = false;
write!(f, "}}")?;
first = false;
write!(f, " }}")