1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
use core::mem::MaybeUninit;
use ::refpool::{PoolClone, PoolDefault};
use crate::ring_buffer::index::RawIndex;
use crate::RingBuffer;
impl<A, const N: usize> PoolDefault for RingBuffer<A, N> {
unsafe fn default_uninit(target: &mut MaybeUninit<Self>) {
let ptr = target.as_mut_ptr();
let origin_ptr: *mut RawIndex<N> = &mut (*ptr).origin;
let length_ptr: *mut usize = &mut (*ptr).length;
origin_ptr.write(0.into());
length_ptr.write(0);
}
}
impl<A, const N: usize> PoolClone for RingBuffer<A, N>
where
A: Clone,
{
unsafe fn clone_uninit(&self, target: &mut MaybeUninit<Self>) {
let ptr = target.as_mut_ptr();
let origin_ptr: *mut RawIndex<N> = &mut (*ptr).origin;
let length_ptr: *mut usize = &mut (*ptr).length;
let data_ptr: *mut _ = &mut (*ptr).data;
let data_ptr: *mut A = (*data_ptr).as_mut_ptr().cast();
origin_ptr.write(self.origin);
length_ptr.write(self.length);
for index in self.range() {
data_ptr
.add(index.to_usize())
.write((*self.ptr(index)).clone());
}
}
}
#[cfg(test)]
mod test {
use super::*;
use ::refpool::{Pool, PoolRef};
use std::iter::FromIterator;
#[test]
fn default_and_clone() {
let pool: Pool<RingBuffer<usize, 64>> = Pool::new(16);
let mut ref1 = PoolRef::default(&pool);
{
let chunk = PoolRef::make_mut(&pool, &mut ref1);
chunk.push_back(1);
chunk.push_back(2);
chunk.push_back(3);
}
let ref2 = PoolRef::cloned(&pool, &ref1);
let ref3 = PoolRef::clone_from(&pool, &RingBuffer::from_iter(1..=3));
assert_eq!(RingBuffer::<usize, 64>::from_iter(1..=3), *ref1);
assert_eq!(RingBuffer::<usize, 64>::from_iter(1..=3), *ref2);
assert_eq!(RingBuffer::<usize, 64>::from_iter(1..=3), *ref3);
assert_eq!(ref1, ref2);
assert_eq!(ref1, ref3);
assert_eq!(ref2, ref3);
assert!(!PoolRef::ptr_eq(&ref1, &ref2));
}
}