#[macro_use] mod macros;
mod chunks;
mod windows;
mod lanes;
pub mod iter;
use std::marker::PhantomData;
use std::ptr;
use Ix1;
use super::{Dimension, Ix, Ixs};
use super::{
ArrayBase,
Data,
ArrayView,
ArrayViewMut,
RemoveAxis,
Axis,
NdProducer,
};
pub use self::windows::Windows;
pub use self::chunks::{
ExactChunks,
ExactChunksIter,
ExactChunksMut,
ExactChunksIterMut,
};
pub use self::lanes::{
Lanes,
LanesMut,
};
use std::slice::{self, Iter as SliceIter, IterMut as SliceIterMut};
pub struct Baseiter<A, D> {
ptr: *mut A,
dim: D,
strides: D,
index: Option<D>,
}
impl<A, D: Dimension> Baseiter<A, D> {
#[inline]
pub unsafe fn new(ptr: *mut A, len: D, stride: D) -> Baseiter<A, D> {
Baseiter {
ptr: ptr,
index: len.first_index(),
dim: len,
strides: stride,
}
}
}
impl<A, D: Dimension> Iterator for Baseiter<A, D> {
type Item = *mut A;
#[inline]
fn next(&mut self) -> Option<*mut A> {
let index = match self.index {
None => return None,
Some(ref ix) => ix.clone(),
};
let offset = D::stride_offset(&index, &self.strides);
self.index = self.dim.next_for(index);
unsafe { Some(self.ptr.offset(offset)) }
}
fn size_hint(&self) -> (usize, Option<usize>) {
let len = self.len();
(len, Some(len))
}
fn fold<Acc, G>(mut self, init: Acc, mut g: G) -> Acc
where G: FnMut(Acc, *mut A) -> Acc,
{
let ndim = self.dim.ndim();
debug_assert_ne!(ndim, 0);
let mut accum = init;
loop {
if let Some(mut index) = self.index.clone() {
let stride = self.strides.last_elem() as isize;
let elem_index = index.last_elem();
let len = self.dim.last_elem();
let offset = D::stride_offset(&index, &self.strides);
unsafe {
let row_ptr = self.ptr.offset(offset);
for i in 0..(len - elem_index) {
accum = g(accum, row_ptr.offset(i as isize * stride));
}
}
index.set_last_elem(len - 1);
self.index = self.dim.next_for(index);
} else {
break;
};
}
accum
}
}
impl<'a, A, D: Dimension> ExactSizeIterator for Baseiter<A, D> {
fn len(&self) -> usize {
match self.index {
None => 0,
Some(ref ix) => {
let gone = self.dim
.default_strides()
.slice()
.iter()
.zip(ix.slice().iter())
.fold(0, |s, (&a, &b)| s + a as usize * b as usize);
self.dim.size() - gone
}
}
}
}
impl<A> DoubleEndedIterator for Baseiter<A, Ix1> {
#[inline]
fn next_back(&mut self) -> Option<*mut A> {
let index = match self.index {
None => return None,
Some(ix) => ix,
};
self.dim[0] -= 1;
let offset = <_>::stride_offset(&self.dim, &self.strides);
if index == self.dim {
self.index = None;
}
unsafe { Some(self.ptr.offset(offset)) }
}
fn rfold<Acc, G>(mut self, init: Acc, mut g: G) -> Acc
where G: FnMut(Acc, *mut A) -> Acc,
{
let mut accum = init;
if let Some(index) = self.index {
let elem_index = index[0];
unsafe {
while self.dim[0] > elem_index {
self.dim[0] -= 1;
accum = g(accum, self.ptr.offset(Ix1::stride_offset(&self.dim, &self.strides)));
}
}
}
accum
}
}
clone_bounds!(
[A, D: Clone]
Baseiter[A, D] {
@copy {
ptr,
}
dim,
strides,
index,
}
);
clone_bounds!(
['a, A, D: Clone]
ElementsBase['a, A, D] {
@copy {
life,
}
inner,
}
);
impl<'a, A, D: Dimension> ElementsBase<'a, A, D> {
pub fn new(v: ArrayView<'a, A, D>) -> Self {
ElementsBase {
inner: v.into_base_iter(),
life: PhantomData,
}
}
}
impl<'a, A, D: Dimension> Iterator for ElementsBase<'a, A, D> {
type Item = &'a A;
#[inline]
fn next(&mut self) -> Option<&'a A> {
self.inner.next().map(|p| unsafe { &*p })
}
fn size_hint(&self) -> (usize, Option<usize>) {
self.inner.size_hint()
}
fn fold<Acc, G>(self, init: Acc, mut g: G) -> Acc
where G: FnMut(Acc, Self::Item) -> Acc,
{
unsafe {
self.inner.fold(init, move |acc, ptr| g(acc, &*ptr))
}
}
}
impl<'a, A> DoubleEndedIterator for ElementsBase<'a, A, Ix1> {
#[inline]
fn next_back(&mut self) -> Option<&'a A> {
self.inner.next_back().map(|p| unsafe { &*p })
}
fn rfold<Acc, G>(self, init: Acc, mut g: G) -> Acc
where G: FnMut(Acc, Self::Item) -> Acc,
{
unsafe {
self.inner.rfold(init, move |acc, ptr| g(acc, &*ptr))
}
}
}
impl<'a, A, D> ExactSizeIterator for ElementsBase<'a, A, D>
where D: Dimension
{
fn len(&self) -> usize {
self.inner.len()
}
}
macro_rules! either {
($value:expr, $inner:pat => $result:expr) => (
match $value {
ElementsRepr::Slice($inner) => $result,
ElementsRepr::Counted($inner) => $result,
}
)
}
macro_rules! either_mut {
($value:expr, $inner:ident => $result:expr) => (
match $value {
ElementsRepr::Slice(ref mut $inner) => $result,
ElementsRepr::Counted(ref mut $inner) => $result,
}
)
}
clone_bounds!(
['a, A, D: Clone]
Iter['a, A, D] {
@copy {
}
inner,
}
);
impl<'a, A, D> Iter<'a, A, D>
where D: Dimension
{
pub(crate) fn new(self_: ArrayView<'a, A, D>) -> Self {
Iter {
inner: if let Some(slc) = self_.into_slice() {
ElementsRepr::Slice(slc.iter())
} else {
ElementsRepr::Counted(self_.into_elements_base())
},
}
}
}
impl<'a, A, D> IterMut<'a, A, D>
where D: Dimension
{
pub(crate) fn new(self_: ArrayViewMut<'a, A, D>) -> Self {
IterMut {
inner:
match self_.into_slice_() {
Ok(x) => ElementsRepr::Slice(x.into_iter()),
Err(self_) => ElementsRepr::Counted(self_.into_elements_base()),
}
}
}
}
#[derive(Clone)]
pub enum ElementsRepr<S, C> {
Slice(S),
Counted(C),
}
pub struct Iter<'a, A: 'a, D> {
inner: ElementsRepr<SliceIter<'a, A>, ElementsBase<'a, A, D>>,
}
pub struct ElementsBase<'a, A: 'a, D> {
inner: Baseiter<A, D>,
life: PhantomData<&'a A>,
}
pub struct IterMut<'a, A: 'a, D> {
inner: ElementsRepr<SliceIterMut<'a, A>, ElementsBaseMut<'a, A, D>>,
}
pub struct ElementsBaseMut<'a, A: 'a, D> {
inner: Baseiter<A, D>,
life: PhantomData<&'a mut A>,
}
impl<'a, A, D: Dimension> ElementsBaseMut<'a, A, D> {
pub fn new(v: ArrayViewMut<'a, A, D>) -> Self {
ElementsBaseMut {
inner: v.into_base_iter(),
life: PhantomData,
}
}
}
#[derive(Clone)]
pub struct IndexedIter<'a, A: 'a, D>(ElementsBase<'a, A, D>);
pub struct IndexedIterMut<'a, A: 'a, D>(ElementsBaseMut<'a, A, D>);
impl<'a, A, D> IndexedIter<'a, A, D>
where D: Dimension
{
pub(crate) fn new(x: ElementsBase<'a, A, D>) -> Self {
IndexedIter(x)
}
}
impl<'a, A, D> IndexedIterMut<'a, A, D>
where D: Dimension
{
pub(crate) fn new(x: ElementsBaseMut<'a, A, D>) -> Self {
IndexedIterMut(x)
}
}
impl<'a, A, D: Dimension> Iterator for Iter<'a, A, D> {
type Item = &'a A;
#[inline]
fn next(&mut self) -> Option<&'a A> {
either_mut!(self.inner, iter => iter.next())
}
fn size_hint(&self) -> (usize, Option<usize>) {
either!(self.inner, ref iter => iter.size_hint())
}
fn fold<Acc, G>(self, init: Acc, g: G) -> Acc
where G: FnMut(Acc, Self::Item) -> Acc
{
either!(self.inner, iter => iter.fold(init, g))
}
}
impl<'a, A> DoubleEndedIterator for Iter<'a, A, Ix1> {
#[inline]
fn next_back(&mut self) -> Option<&'a A> {
either_mut!(self.inner, iter => iter.next_back())
}
fn rfold<Acc, G>(self, init: Acc, g: G) -> Acc
where G: FnMut(Acc, Self::Item) -> Acc
{
either!(self.inner, iter => iter.rfold(init, g))
}
}
impl<'a, A, D> ExactSizeIterator for Iter<'a, A, D>
where D: Dimension
{
fn len(&self) -> usize {
either!(self.inner, ref iter => iter.len())
}
}
impl<'a, A, D: Dimension> Iterator for IndexedIter<'a, A, D> {
type Item = (D::Pattern, &'a A);
#[inline]
fn next(&mut self) -> Option<Self::Item> {
let index = match self.0.inner.index {
None => return None,
Some(ref ix) => ix.clone(),
};
match self.0.next() {
None => None,
Some(elem) => Some((index.into_pattern(), elem)),
}
}
fn size_hint(&self) -> (usize, Option<usize>) {
self.0.size_hint()
}
}
impl<'a, A, D> ExactSizeIterator for IndexedIter<'a, A, D>
where D: Dimension
{
fn len(&self) -> usize {
self.0.inner.len()
}
}
impl<'a, A, D: Dimension> Iterator for IterMut<'a, A, D> {
type Item = &'a mut A;
#[inline]
fn next(&mut self) -> Option<&'a mut A> {
either_mut!(self.inner, iter => iter.next())
}
fn size_hint(&self) -> (usize, Option<usize>) {
either!(self.inner, ref iter => iter.size_hint())
}
fn fold<Acc, G>(self, init: Acc, g: G) -> Acc
where G: FnMut(Acc, Self::Item) -> Acc
{
either!(self.inner, iter => iter.fold(init, g))
}
}
impl<'a, A> DoubleEndedIterator for IterMut<'a, A, Ix1> {
#[inline]
fn next_back(&mut self) -> Option<&'a mut A> {
either_mut!(self.inner, iter => iter.next_back())
}
fn rfold<Acc, G>(self, init: Acc, g: G) -> Acc
where G: FnMut(Acc, Self::Item) -> Acc
{
either!(self.inner, iter => iter.rfold(init, g))
}
}
impl<'a, A, D> ExactSizeIterator for IterMut<'a, A, D>
where D: Dimension
{
fn len(&self) -> usize {
either!(self.inner, ref iter => iter.len())
}
}
impl<'a, A, D: Dimension> Iterator for ElementsBaseMut<'a, A, D> {
type Item = &'a mut A;
#[inline]
fn next(&mut self) -> Option<&'a mut A> {
self.inner.next().map(|p| unsafe { &mut *p })
}
fn size_hint(&self) -> (usize, Option<usize>) {
self.inner.size_hint()
}
fn fold<Acc, G>(self, init: Acc, mut g: G) -> Acc
where G: FnMut(Acc, Self::Item) -> Acc
{
unsafe {
self.inner.fold(init, move |acc, ptr| g(acc, &mut *ptr))
}
}
}
impl<'a, A> DoubleEndedIterator for ElementsBaseMut<'a, A, Ix1> {
#[inline]
fn next_back(&mut self) -> Option<&'a mut A> {
self.inner.next_back().map(|p| unsafe { &mut *p })
}
fn rfold<Acc, G>(self, init: Acc, mut g: G) -> Acc
where G: FnMut(Acc, Self::Item) -> Acc
{
unsafe {
self.inner.rfold(init, move |acc, ptr| g(acc, &mut *ptr))
}
}
}
impl<'a, A, D> ExactSizeIterator for ElementsBaseMut<'a, A, D>
where D: Dimension
{
fn len(&self) -> usize {
self.inner.len()
}
}
impl<'a, A, D: Dimension> Iterator for IndexedIterMut<'a, A, D> {
type Item = (D::Pattern, &'a mut A);
#[inline]
fn next(&mut self) -> Option<Self::Item> {
let index = match self.0.inner.index {
None => return None,
Some(ref ix) => ix.clone(),
};
match self.0.next() {
None => None,
Some(elem) => Some((index.into_pattern(), elem)),
}
}
fn size_hint(&self) -> (usize, Option<usize>) {
self.0.size_hint()
}
}
impl<'a, A, D> ExactSizeIterator for IndexedIterMut<'a, A, D>
where D: Dimension
{
fn len(&self) -> usize {
self.0.inner.len()
}
}
pub struct LanesIter<'a, A: 'a, D> {
inner_len: Ix,
inner_stride: Ixs,
iter: Baseiter<A, D>,
life: PhantomData<&'a A>,
}
clone_bounds!(
['a, A, D: Clone]
LanesIter['a, A, D] {
@copy {
inner_len,
inner_stride,
life,
}
iter,
}
);
impl<'a, A, D> Iterator for LanesIter<'a, A, D>
where D: Dimension
{
type Item = ArrayView<'a, A, Ix1>;
fn next(&mut self) -> Option<Self::Item> {
self.iter.next().map(|ptr| {
unsafe { ArrayView::new_(ptr, Ix1(self.inner_len), Ix1(self.inner_stride as Ix)) }
})
}
fn size_hint(&self) -> (usize, Option<usize>) {
self.iter.size_hint()
}
}
impl<'a, A, D> ExactSizeIterator for LanesIter<'a, A, D>
where D: Dimension
{
fn len(&self) -> usize {
self.iter.len()
}
}
pub struct LanesIterMut<'a, A: 'a, D> {
inner_len: Ix,
inner_stride: Ixs,
iter: Baseiter<A, D>,
life: PhantomData<&'a mut A>,
}
impl<'a, A, D> Iterator for LanesIterMut<'a, A, D>
where D: Dimension,
{
type Item = ArrayViewMut<'a, A, Ix1>;
fn next(&mut self) -> Option<Self::Item> {
self.iter.next().map(|ptr| {
unsafe {
ArrayViewMut::new_(ptr, Ix1(self.inner_len), Ix1(self.inner_stride as Ix))
}
})
}
fn size_hint(&self) -> (usize, Option<usize>) {
self.iter.size_hint()
}
}
impl<'a, A, D> ExactSizeIterator for LanesIterMut<'a, A, D>
where D: Dimension,
{
fn len(&self) -> usize {
self.iter.len()
}
}
#[derive(Debug)]
pub struct AxisIterCore<A, D> {
index: Ix,
len: Ix,
stride: Ixs,
inner_dim: D,
inner_strides: D,
ptr: *mut A,
}
clone_bounds!(
[A, D: Clone]
AxisIterCore[A, D] {
@copy {
index,
len,
stride,
ptr,
}
inner_dim,
inner_strides,
}
);
impl<A, D: Dimension> AxisIterCore<A, D> {
fn new<S, Di>(v: ArrayBase<S, Di>, axis: Axis) -> Self
where
Di: RemoveAxis<Smaller = D>,
S: Data<Elem = A>,
{
let shape = v.shape()[axis.index()];
let stride = v.strides()[axis.index()];
AxisIterCore {
index: 0,
len: shape,
stride: stride,
inner_dim: v.dim.remove_axis(axis),
inner_strides: v.strides.remove_axis(axis),
ptr: v.ptr,
}
}
unsafe fn offset(&self, index: usize) -> *mut A {
debug_assert!(index <= self.len,
"index={}, len={}, stride={}", index, self.len, self.stride);
self.ptr.offset(index as isize * self.stride)
}
fn split_at(self, index: usize) -> (Self, Self) {
assert!(index <= self.len);
let right_ptr = if index != self.len {
unsafe { self.offset(index) }
} else {
self.ptr
};
let left = AxisIterCore {
index: 0,
len: index,
stride: self.stride,
inner_dim: self.inner_dim.clone(),
inner_strides: self.inner_strides.clone(),
ptr: self.ptr,
};
let right = AxisIterCore {
index: 0,
len: self.len - index,
stride: self.stride,
inner_dim: self.inner_dim,
inner_strides: self.inner_strides,
ptr: right_ptr,
};
(left, right)
}
}
impl<A, D> Iterator for AxisIterCore<A, D>
where D: Dimension,
{
type Item = *mut A;
fn next(&mut self) -> Option<Self::Item> {
if self.index >= self.len {
None
} else {
let ptr = unsafe { self.offset(self.index) };
self.index += 1;
Some(ptr)
}
}
fn size_hint(&self) -> (usize, Option<usize>) {
let len = self.len - self.index;
(len, Some(len))
}
}
impl<A, D> DoubleEndedIterator for AxisIterCore<A, D>
where D: Dimension,
{
fn next_back(&mut self) -> Option<Self::Item> {
if self.index >= self.len {
None
} else {
self.len -= 1;
let ptr = unsafe { self.offset(self.len) };
Some(ptr)
}
}
}
#[derive(Debug)]
pub struct AxisIter<'a, A: 'a, D> {
iter: AxisIterCore<A, D>,
life: PhantomData<&'a A>,
}
clone_bounds!(
['a, A, D: Clone]
AxisIter['a, A, D] {
@copy {
life,
}
iter,
}
);
impl<'a, A, D: Dimension> AxisIter<'a, A, D> {
pub(crate) fn new<Di>(v: ArrayView<'a, A, Di>, axis: Axis) -> Self
where
Di: RemoveAxis<Smaller = D>,
{
AxisIter {
iter: AxisIterCore::new(v, axis),
life: PhantomData,
}
}
pub fn split_at(self, index: usize) -> (Self, Self) {
let (left, right) = self.iter.split_at(index);
(
AxisIter {
iter: left,
life: self.life,
},
AxisIter {
iter: right,
life: self.life,
},
)
}
}
impl<'a, A, D> Iterator for AxisIter<'a, A, D>
where D: Dimension
{
type Item = ArrayView<'a, A, D>;
fn next(&mut self) -> Option<Self::Item> {
self.iter.next().map(|ptr| {
unsafe {
self.as_ref(ptr)
}
})
}
fn size_hint(&self) -> (usize, Option<usize>) {
self.iter.size_hint()
}
}
impl<'a, A, D> DoubleEndedIterator for AxisIter<'a, A, D>
where D: Dimension
{
fn next_back(&mut self) -> Option<Self::Item> {
self.iter.next_back().map(|ptr| {
unsafe {
self.as_ref(ptr)
}
})
}
}
impl<'a, A, D> ExactSizeIterator for AxisIter<'a, A, D>
where D: Dimension
{
fn len(&self) -> usize {
self.size_hint().0
}
}
pub struct AxisIterMut<'a, A: 'a, D> {
iter: AxisIterCore<A, D>,
life: PhantomData<&'a mut A>,
}
impl<'a, A, D: Dimension> AxisIterMut<'a, A, D> {
pub(crate) fn new<Di>(v: ArrayViewMut<'a, A, Di>, axis: Axis) -> Self
where
Di: RemoveAxis<Smaller = D>,
{
AxisIterMut {
iter: AxisIterCore::new(v, axis),
life: PhantomData,
}
}
pub fn split_at(self, index: usize) -> (Self, Self) {
let (left, right) = self.iter.split_at(index);
(
AxisIterMut {
iter: left,
life: self.life,
},
AxisIterMut {
iter: right,
life: self.life,
},
)
}
}
impl<'a, A, D> Iterator for AxisIterMut<'a, A, D>
where D: Dimension
{
type Item = ArrayViewMut<'a, A, D>;
fn next(&mut self) -> Option<Self::Item> {
self.iter.next().map(|ptr| {
unsafe {
self.as_ref(ptr)
}
})
}
fn size_hint(&self) -> (usize, Option<usize>) {
self.iter.size_hint()
}
}
impl<'a, A, D> DoubleEndedIterator for AxisIterMut<'a, A, D>
where D: Dimension
{
fn next_back(&mut self) -> Option<Self::Item> {
self.iter.next_back().map(|ptr| {
unsafe {
self.as_ref(ptr)
}
})
}
}
impl<'a, A, D> ExactSizeIterator for AxisIterMut<'a, A, D>
where D: Dimension
{
fn len(&self) -> usize {
self.size_hint().0
}
}
impl<'a, A, D: Dimension> NdProducer for AxisIter<'a, A, D>
{
type Item = <Self as Iterator>::Item;
type Dim = Ix1;
type Ptr = *mut A;
type Stride = isize;
#[doc(hidden)]
fn layout(&self) -> ::Layout {
::Layout::one_dimensional()
}
#[doc(hidden)]
fn raw_dim(&self) -> Self::Dim {
Ix1(self.len())
}
#[doc(hidden)]
fn as_ptr(&self) -> Self::Ptr {
self.iter.ptr
}
fn contiguous_stride(&self) -> isize {
self.iter.stride
}
#[doc(hidden)]
unsafe fn as_ref(&self, ptr: Self::Ptr) -> Self::Item {
ArrayView::new_(ptr,
self.iter.inner_dim.clone(),
self.iter.inner_strides.clone())
}
#[doc(hidden)]
unsafe fn uget_ptr(&self, i: &Self::Dim) -> Self::Ptr {
self.iter.ptr.offset(self.iter.stride * i[0] as isize)
}
#[doc(hidden)]
fn stride_of(&self, _axis: Axis) -> isize {
self.contiguous_stride()
}
#[doc(hidden)]
fn split_at(self, _axis: Axis, index: usize) -> (Self, Self) {
self.split_at(index)
}
private_impl!{}
}
impl<'a, A, D: Dimension> NdProducer for AxisIterMut<'a, A, D>
{
type Item = <Self as Iterator>::Item;
type Dim = Ix1;
type Ptr = *mut A;
type Stride = isize;
#[doc(hidden)]
fn layout(&self) -> ::Layout {
::Layout::one_dimensional()
}
#[doc(hidden)]
fn raw_dim(&self) -> Self::Dim {
Ix1(self.len())
}
#[doc(hidden)]
fn as_ptr(&self) -> Self::Ptr {
self.iter.ptr
}
fn contiguous_stride(&self) -> isize {
self.iter.stride
}
#[doc(hidden)]
unsafe fn as_ref(&self, ptr: Self::Ptr) -> Self::Item {
ArrayViewMut::new_(ptr,
self.iter.inner_dim.clone(),
self.iter.inner_strides.clone())
}
#[doc(hidden)]
unsafe fn uget_ptr(&self, i: &Self::Dim) -> Self::Ptr {
self.iter.ptr.offset(self.iter.stride * i[0] as isize)
}
#[doc(hidden)]
fn stride_of(&self, _axis: Axis) -> isize {
self.contiguous_stride()
}
#[doc(hidden)]
fn split_at(self, _axis: Axis, index: usize) -> (Self, Self) {
self.split_at(index)
}
private_impl!{}
}
pub struct AxisChunksIter<'a, A: 'a, D> {
iter: AxisIterCore<A, D>,
n_whole_chunks: usize,
last_dim: D,
life: PhantomData<&'a A>,
}
clone_bounds!(
['a, A, D: Clone]
AxisChunksIter['a, A, D] {
@copy {
life,
n_whole_chunks,
}
iter,
last_dim,
}
);
fn chunk_iter_parts<A, D: Dimension>(v: ArrayView<A, D>, axis: Axis, size: usize)
-> (AxisIterCore<A, D>, usize, D)
{
let axis_len = v.len_of(axis);
let size = if size > axis_len { axis_len } else { size };
let n_whole_chunks = axis_len / size;
let chunk_remainder = axis_len % size;
let iter_len = if chunk_remainder == 0 { n_whole_chunks } else { n_whole_chunks + 1 };
let stride = v.stride_of(axis) * size as isize;
let axis = axis.index();
let mut inner_dim = v.dim.clone();
inner_dim[axis] = size;
let mut last_dim = v.dim;
last_dim[axis] = if chunk_remainder == 0 { size } else { chunk_remainder };
let iter = AxisIterCore {
index: 0,
len: iter_len,
stride: stride,
inner_dim: inner_dim,
inner_strides: v.strides,
ptr: v.ptr,
};
(iter, n_whole_chunks, last_dim)
}
impl<'a, A, D: Dimension> AxisChunksIter<'a, A, D> {
pub(crate) fn new(v: ArrayView<'a, A, D>, axis: Axis, size: usize) -> Self {
let (iter, n_whole_chunks, last_dim) = chunk_iter_parts(v, axis, size);
AxisChunksIter {
iter: iter,
n_whole_chunks: n_whole_chunks,
last_dim: last_dim,
life: PhantomData,
}
}
}
macro_rules! chunk_iter_impl {
($iter:ident, $array:ident) => (
impl<'a, A, D> $iter<'a, A, D>
where D: Dimension
{
fn get_subview(&self, iter_item: Option<*mut A>, is_uneven: bool)
-> Option<$array<'a, A, D>>
{
iter_item.map(|ptr| {
if !is_uneven {
unsafe {
$array::new_(ptr,
self.iter.inner_dim.clone(),
self.iter.inner_strides.clone())
}
}
else {
unsafe {
$array::new_(ptr,
self.last_dim.clone(),
self.iter.inner_strides.clone())
}
}
})
}
}
impl<'a, A, D> Iterator for $iter<'a, A, D>
where D: Dimension,
{
type Item = $array<'a, A, D>;
fn next(&mut self) -> Option<Self::Item> {
let res = self.iter.next();
let is_uneven = self.iter.index > self.n_whole_chunks;
self.get_subview(res, is_uneven)
}
fn size_hint(&self) -> (usize, Option<usize>) {
self.iter.size_hint()
}
}
impl<'a, A, D> DoubleEndedIterator for $iter<'a, A, D>
where D: Dimension,
{
fn next_back(&mut self) -> Option<Self::Item> {
let is_uneven = self.iter.len > self.n_whole_chunks;
let res = self.iter.next_back();
self.get_subview(res, is_uneven)
}
}
impl<'a, A, D> ExactSizeIterator for $iter<'a, A, D>
where D: Dimension,
{ }
)
}
pub struct AxisChunksIterMut<'a, A: 'a, D> {
iter: AxisIterCore<A, D>,
n_whole_chunks: usize,
last_dim: D,
life: PhantomData<&'a mut A>,
}
impl<'a, A, D: Dimension> AxisChunksIterMut<'a, A, D> {
pub(crate) fn new(v: ArrayViewMut<'a, A, D>, axis: Axis, size: usize) -> Self {
let (iter, len, last_dim) = chunk_iter_parts(v.into_view(), axis, size);
AxisChunksIterMut {
iter: iter,
n_whole_chunks: len,
last_dim: last_dim,
life: PhantomData,
}
}
}
chunk_iter_impl!(AxisChunksIter, ArrayView);
chunk_iter_impl!(AxisChunksIterMut, ArrayViewMut);
send_sync_read_only!(Iter);
send_sync_read_only!(IndexedIter);
send_sync_read_only!(LanesIter);
send_sync_read_only!(AxisIter);
send_sync_read_only!(AxisChunksIter);
send_sync_read_only!(ElementsBase);
send_sync_read_write!(IterMut);
send_sync_read_write!(IndexedIterMut);
send_sync_read_write!(LanesIterMut);
send_sync_read_write!(AxisIterMut);
send_sync_read_write!(AxisChunksIterMut);
send_sync_read_write!(ElementsBaseMut);
pub unsafe trait TrustedIterator { }
use std;
use linspace::Linspace;
use iter::IndicesIter;
use indexes::IndicesIterF;
unsafe impl<F> TrustedIterator for Linspace<F> { }
unsafe impl<'a, A, D> TrustedIterator for Iter<'a, A, D> { }
unsafe impl<'a, A, D> TrustedIterator for IterMut<'a, A, D> { }
unsafe impl<I, F> TrustedIterator for std::iter::Map<I, F>
where I: TrustedIterator { }
unsafe impl<'a, A> TrustedIterator for slice::Iter<'a, A> { }
unsafe impl<'a, A> TrustedIterator for slice::IterMut<'a, A> { }
unsafe impl TrustedIterator for ::std::ops::Range<usize> { }
unsafe impl<D> TrustedIterator for IndicesIter<D> where D: Dimension { }
unsafe impl<D> TrustedIterator for IndicesIterF<D> where D: Dimension { }
pub fn to_vec<I>(iter: I) -> Vec<I::Item>
where I: TrustedIterator + ExactSizeIterator
{
to_vec_mapped(iter, |x| x)
}
pub fn to_vec_mapped<I, F, B>(iter: I, mut f: F) -> Vec<B>
where I: TrustedIterator + ExactSizeIterator,
F: FnMut(I::Item) -> B,
{
let (size, _) = iter.size_hint();
let mut result = Vec::with_capacity(size);
let mut out_ptr = result.as_mut_ptr();
let mut len = 0;
iter.fold((), |(), elt| {
unsafe {
ptr::write(out_ptr, f(elt));
len += 1;
result.set_len(len);
out_ptr = out_ptr.offset(1);
}
});
debug_assert_eq!(size, result.len());
result
}