rlist_vfs 0.1.2

Virtual File System for rList
Documentation
use std::sync::Arc;
use std::sync::atomic::{AtomicPtr, Ordering};

pub struct ReadCopyUpdate<T> (AtomicPtr<Arc<T>>);

impl<T> ReadCopyUpdate<T> {
    pub fn new(value: T) -> Self {
        ReadCopyUpdate(
            AtomicPtr::new(
                Box::into_raw(
                    Box::new(
                        Arc::new(value)
                    )
                )
            )
        )
    }

    pub fn read(&self) -> Arc<T> {
        unsafe {
            Arc::clone(&*self.0.load(Ordering::Relaxed))
        }
    }

    pub fn update(&self, value: T) {
        let new = Arc::new(value);
        let old = self.0.swap(
            Box::into_raw(Box::new(new)),
            Ordering::Relaxed
        );
        unsafe {
            drop(Box::from_raw(old));
        }
    }
}

unsafe impl<T> Sync for ReadCopyUpdate<T> {}