use std::slice::{from_raw_parts, from_raw_parts_mut};
use std::cmp::Ordering::{Less, Greater};
use std::iter::FusedIterator;
use std::{fmt, marker};
use crate::{exponential_search_by, offset_from};
macro_rules! exponential_group_by {
(struct $name:ident, $elem:ty, $mkslice:ident) => {
impl<'a, T: 'a, P> $name<'a, T, P> {
#[inline]
pub fn is_empty(&self) -> bool {
self.ptr == self.end
}
#[inline]
pub fn remainder_len(&self) -> usize {
unsafe { offset_from(self.end, self.ptr) }
}
}
impl<'a, T: 'a, P> Iterator for $name<'a, T, P>
where P: FnMut(&T, &T) -> bool,
{
type Item = $elem;
fn next(&mut self) -> Option<Self::Item> {
if self.is_empty() { return None }
let first = unsafe { &*self.ptr };
let len = self.remainder_len();
let tail = unsafe { $mkslice(self.ptr.add(1), len - 1) };
let predicate = |x: &T| if (self.predicate)(first, x) { Less } else { Greater };
let index = exponential_search_by(tail, predicate).unwrap_err();
let left = unsafe { $mkslice(self.ptr, index + 1) };
self.ptr = unsafe { self.ptr.add(index + 1) };
Some(left)
}
fn size_hint(&self) -> (usize, Option<usize>) {
if self.is_empty() { return (0, Some(0)) }
let len = self.remainder_len();
(1, Some(len))
}
fn last(mut self) -> Option<Self::Item> {
self.next_back()
}
}
impl<'a, T: 'a, P> DoubleEndedIterator for $name<'a, T, P>
where P: FnMut(&T, &T) -> bool,
{
fn next_back(&mut self) -> Option<Self::Item> {
if self.is_empty() { return None }
let last = unsafe { &*self.end.sub(1) };
let len = self.remainder_len();
let head = unsafe { $mkslice(self.ptr, len - 1) };
let predicate = |x: &T| if (self.predicate)(last, x) { Greater } else { Less };
let index = exponential_search_by(head, predicate).unwrap_err();
let right = unsafe { $mkslice(self.ptr.add(index), len - index) };
self.end = unsafe { self.end.sub(len - index) };
Some(right)
}
}
impl<'a, T: 'a, P> FusedIterator for $name<'a, T, P>
where P: FnMut(&T, &T) -> bool,
{ }
}
}
pub struct ExponentialGroupBy<'a, T, P> {
ptr: *const T,
end: *const T,
predicate: P,
_phantom: marker::PhantomData<&'a T>,
}
impl<'a, T: 'a, P> ExponentialGroupBy<'a, T, P>
where P: FnMut(&T, &T) -> bool,
{
pub fn new(slice: &'a [T], predicate: P) -> Self {
ExponentialGroupBy {
ptr: slice.as_ptr(),
end: unsafe { slice.as_ptr().add(slice.len()) },
predicate: predicate,
_phantom: marker::PhantomData,
}
}
}
impl<'a, T: 'a, P> ExponentialGroupBy<'a, T, P> {
pub fn remainder(&self) -> &[T] {
let len = self.remainder_len();
unsafe { from_raw_parts(self.ptr, len) }
}
}
impl<'a, T: 'a + fmt::Debug, P> fmt::Debug for ExponentialGroupBy<'a, T, P> {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
f.debug_struct("ExponentialGroupBy")
.field("remainder", &self.remainder())
.finish()
}
}
exponential_group_by!{ struct ExponentialGroupBy, &'a [T], from_raw_parts }
pub struct ExponentialGroupByMut<'a, T, P> {
ptr: *mut T,
end: *mut T,
predicate: P,
_phantom: marker::PhantomData<&'a T>,
}
impl<'a, T: 'a, P> ExponentialGroupByMut<'a, T, P>
where P: FnMut(&T, &T) -> bool,
{
pub fn new(slice: &'a mut [T], predicate: P) -> Self {
ExponentialGroupByMut {
ptr: slice.as_mut_ptr(),
end: unsafe { slice.as_mut_ptr().add(slice.len()) },
predicate: predicate,
_phantom: marker::PhantomData,
}
}
}
impl<'a, T: 'a, P> ExponentialGroupByMut<'a, T, P> {
pub fn into_remainder(self) -> &'a mut [T] {
let len = self.remainder_len();
unsafe { from_raw_parts_mut(self.ptr, len) }
}
}
impl<'a, T: 'a + fmt::Debug, P> fmt::Debug for ExponentialGroupByMut<'a, T, P> {
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
let len = self.remainder_len();
let remainder = unsafe { from_raw_parts(self.ptr, len) };
f.debug_struct("ExponentialGroupByMut")
.field("remaining", &remainder)
.finish()
}
}
exponential_group_by!{ struct ExponentialGroupByMut, &'a mut [T], from_raw_parts_mut }
pub struct ExponentialGroup<'a, T: 'a>(ExponentialGroupBy<'a, T, fn(&T, &T) -> bool>);
impl<'a, T: 'a> ExponentialGroup<'a, T>
where T: PartialEq,
{
pub fn new(slice: &'a [T]) -> ExponentialGroup<'a, T> {
ExponentialGroup(ExponentialGroupBy::new(slice, PartialEq::eq))
}
}
group_by_partial_eq!{ struct ExponentialGroup, &'a [T] }
pub struct ExponentialGroupMut<'a, T: 'a>(ExponentialGroupByMut<'a, T, fn(&T, &T) -> bool>);
impl<'a, T: 'a> ExponentialGroupMut<'a, T>
where T: PartialEq,
{
pub fn new(slice: &'a mut [T]) -> ExponentialGroupMut<'a, T> {
ExponentialGroupMut(ExponentialGroupByMut::new(slice, PartialEq::eq))
}
}
group_by_partial_eq!{ struct ExponentialGroupMut, &'a mut [T] }
#[cfg(test)]
mod tests {
use super::*;
#[derive(Debug, Eq)]
enum Guard {
Valid(i32),
Invalid(i32),
}
impl PartialEq for Guard {
fn eq(&self, other: &Self) -> bool {
match (self, other) {
(Guard::Valid(_), Guard::Valid(_)) => true,
(a, b) => panic!("denied read on Guard::Invalid variant ({:?}, {:?})", a, b),
}
}
}
#[test]
fn one_big_group() {
let slice = &[1, 1, 1, 1];
let mut iter = ExponentialGroup::new(slice);
assert_eq!(iter.next(), Some(&[1, 1, 1, 1][..]));
assert_eq!(iter.next(), None);
}
#[test]
fn two_equal_groups() {
let slice = &[1, 1, 1, 1, 2, 2, 2, 2];
let mut iter = ExponentialGroup::new(slice);
assert_eq!(iter.next(), Some(&[1, 1, 1, 1][..]));
assert_eq!(iter.next(), Some(&[2, 2, 2, 2][..]));
assert_eq!(iter.next(), None);
}
#[test]
fn two_little_equal_groups() {
let slice = &[1, 2];
let mut iter = ExponentialGroup::new(slice);
assert_eq!(iter.next(), Some(&[1][..]));
assert_eq!(iter.next(), Some(&[2][..]));
assert_eq!(iter.next(), None);
}
#[test]
fn three_groups() {
let slice = &[1, 1, 1, 2, 2, 2, 3, 3];
let mut iter = ExponentialGroup::new(slice);
assert_eq!(iter.next(), Some(&[1, 1, 1][..]));
assert_eq!(iter.next(), Some(&[2, 2, 2][..]));
assert_eq!(iter.next(), Some(&[3, 3][..]));
assert_eq!(iter.next(), None);
}
#[test]
fn three_little_groups() {
let slice = &[1, 2, 3];
let mut iter = ExponentialGroup::new(slice);
assert_eq!(iter.next(), Some(&[1][..]));
assert_eq!(iter.next(), Some(&[2][..]));
assert_eq!(iter.next(), Some(&[3][..]));
assert_eq!(iter.next(), None);
}
#[test]
fn overflow() {
let slice = &[Guard::Invalid(0), Guard::Valid(1), Guard::Valid(2), Guard::Invalid(3)];
let mut iter = ExponentialGroup::new(&slice[1..3]);
assert_eq!(iter.next(), Some(&[Guard::Valid(1), Guard::Valid(2)][..]));
assert_eq!(iter.next(), None);
}
#[test]
fn last_three_little_groups() {
let slice = &[1, 2, 3];
let iter = ExponentialGroup::new(slice);
assert_eq!(iter.last(), Some(&[3][..]));
}
#[test]
fn last_three_groups() {
let slice = &[1, 1, 1, 2, 2, 2, 3, 3];
let iter = ExponentialGroup::new(slice);
assert_eq!(iter.last(), Some(&[3, 3][..]));
}
#[test]
fn last_overflow() {
let slice = &[Guard::Invalid(0), Guard::Valid(1), Guard::Valid(2), Guard::Invalid(3)];
println!("{:?}", (&slice[1..3]).as_ptr());
let iter = ExponentialGroup::new(&slice[1..3]);
assert_eq!(iter.last(), Some(&[Guard::Valid(1), Guard::Valid(2)][..]));
}
#[test]
fn back_empty_slice() {
let slice: &[i32] = &[];
let mut iter = ExponentialGroup::new(slice);
assert_eq!(iter.next_back(), None);
}
#[test]
fn back_one_little_group() {
let slice = &[1];
let mut iter = ExponentialGroup::new(slice);
assert_eq!(iter.next_back(), Some(&[1][..]));
assert_eq!(iter.next_back(), None);
assert_eq!(iter.next(), None);
}
#[test]
fn back_three_little_groups() {
let slice = &[1, 2, 3];
let mut iter = ExponentialGroup::new(slice);
assert_eq!(iter.next_back(), Some(&[3][..]));
assert_eq!(iter.next_back(), Some(&[2][..]));
assert_eq!(iter.next_back(), Some(&[1][..]));
assert_eq!(iter.next_back(), None);
}
#[test]
fn back_three_groups() {
let slice = &[1, 1, 1, 2, 2, 2, 3, 3];
let mut iter = ExponentialGroup::new(slice);
assert_eq!(iter.next_back(), Some(&[3, 3][..]));
assert_eq!(iter.next_back(), Some(&[2, 2, 2][..]));
assert_eq!(iter.next_back(), Some(&[1, 1, 1][..]));
assert_eq!(iter.next_back(), None);
}
#[test]
fn double_ended_dont_cross() {
let slice = &[1, 1, 1, 2, 2, 2, 3, 3];
let mut iter = ExponentialGroup::new(slice);
assert_eq!(iter.next(), Some(&[1, 1, 1][..]));
assert_eq!(iter.next_back(), Some(&[3, 3][..]));
assert_eq!(iter.next(), Some(&[2, 2, 2][..]));
assert_eq!(iter.next_back(), None);
assert_eq!(iter.next(), None);
}
#[test]
fn fused_iterator() {
let slice = &[1, 2, 3];
let mut iter = ExponentialGroup::new(slice);
assert_eq!(iter.next(), Some(&[1][..]));
assert_eq!(iter.next(), Some(&[2][..]));
assert_eq!(iter.next(), Some(&[3][..]));
assert_eq!(iter.next(), None);
assert_eq!(iter.next(), None);
}
#[test]
fn back_fused_iterator() {
let slice = &[1, 2, 3];
let mut iter = ExponentialGroup::new(slice);
assert_eq!(iter.next_back(), Some(&[3][..]));
assert_eq!(iter.next_back(), Some(&[2][..]));
assert_eq!(iter.next_back(), Some(&[1][..]));
assert_eq!(iter.next_back(), None);
assert_eq!(iter.next_back(), None);
}
}
#[cfg(all(feature = "nightly", test))]
mod bench {
extern crate test;
extern crate rand;
use super::*;
use self::rand::{Rng, SeedableRng};
use self::rand::rngs::StdRng;
use self::rand::distributions::Alphanumeric;
#[bench]
fn vector_16_000_sorted(b: &mut test::Bencher) {
let mut rng = StdRng::from_seed([42; 32]);
let len = 16_000;
let mut vec = Vec::with_capacity(len);
for _ in 0..len {
vec.push(rng.sample(Alphanumeric));
}
vec.sort_unstable();
b.iter(|| {
let group_by = ExponentialGroup::new(vec.as_slice());
test::black_box(group_by.count())
})
}
#[bench]
fn vector_little_sorted(b: &mut test::Bencher) {
let mut rng = StdRng::from_seed([42; 32]);
let len = 30;
let mut vec = Vec::with_capacity(len);
for _ in 0..len {
vec.push(rng.sample(Alphanumeric));
}
vec.sort_unstable();
b.iter(|| {
let group_by = ExponentialGroup::new(vec.as_slice());
test::black_box(group_by.count())
})
}
#[bench]
fn vector_16_000_one_group(b: &mut test::Bencher) {
let vec = vec![1; 16_000];
b.iter(|| {
let group_by = ExponentialGroup::new(vec.as_slice());
test::black_box(group_by.count())
})
}
#[bench]
fn rev_vector_16_000_sorted(b: &mut test::Bencher) {
let mut rng = StdRng::from_seed([42; 32]);
let len = 16_000;
let mut vec = Vec::with_capacity(len);
for _ in 0..len {
vec.push(rng.sample(Alphanumeric));
}
vec.sort_unstable();
b.iter(|| {
let group_by = ExponentialGroup::new(vec.as_slice());
test::black_box(group_by.rev().count())
})
}
#[bench]
fn rev_vector_16_000_one_group(b: &mut test::Bencher) {
let vec = vec![1; 16_000];
b.iter(|| {
let group_by = ExponentialGroup::new(vec.as_slice());
test::black_box(group_by.rev().count())
})
}
}