cao-lang 0.2.6

The back-end of cao-lang, a node based visual scripting language
Documentation 
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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116

use tracing::debug;

use crate::vm::runtime::RuntimeData;

use super::{AllocError, Allocator};
use std::{
    alloc::{alloc, dealloc, Layout},
    cell::UnsafeCell,
    marker::PhantomData,
    ops::Deref,
    ptr::NonNull,
    rc::Rc,
    sync::atomic::{AtomicUsize, Ordering},
};

/// # Safety
///
/// Note that CaoLangAllocator is NOT thread-safe!
#[derive(Debug, Clone)]
pub struct AllocProxy {
    inner: Rc<UnsafeCell<CaoLangAllocator>>,
    _m: PhantomData<*mut CaoLangAllocator>,
}

impl From<CaoLangAllocator> for AllocProxy {
    fn from(inner: CaoLangAllocator) -> Self {
        Self {
            inner: Rc::new(UnsafeCell::new(inner)),
            _m: PhantomData,
        }
    }
}

impl Deref for AllocProxy {
    type Target = CaoLangAllocator;

    fn deref(&self) -> &Self::Target {
        unsafe { &*self.inner.get() }
    }
}

impl AllocProxy {
    pub unsafe fn get_inner(&mut self) -> &mut CaoLangAllocator {
        &mut *self.inner.get()
    }
}

#[derive(Debug)]
pub struct CaoLangAllocator {
    pub runtime: *mut RuntimeData,
    pub allocated: AtomicUsize,
    pub next_gc: AtomicUsize,
    pub limit: AtomicUsize,
}

impl CaoLangAllocator {
    pub fn new(vm: *mut RuntimeData, limit: usize) -> Self {
        Self {
            runtime: vm,
            allocated: AtomicUsize::new(0),
            next_gc: AtomicUsize::new((limit / 4).max(16)),
            limit: AtomicUsize::new(limit),
        }
    }

    /// # Safety
    /// `alloc` is not thread safe. It is on the caller to ensure that only a single thread uses
    /// the allocator at a time
    pub unsafe fn alloc(&self, l: Layout) -> Result<NonNull<u8>, AllocError> {
        let s = l.size() + l.align();
        let allocated = s + self.allocated.fetch_add(s, Ordering::Relaxed);
        if allocated > self.limit.load(Ordering::Relaxed) {
            return Err(AllocError::OutOfMemory);
        }
        if allocated > self.next_gc.load(Ordering::Relaxed) {
            self.next_gc.store(allocated * 2, Ordering::Relaxed);
            unsafe {
                (*self.runtime).gc();
            }
            debug!(
                "GC done. Allocated before: {allocated}. Allocated now: {}",
                self.allocated.load(Ordering::Relaxed)
            );
        }
        let ptr = alloc(l);
        Ok(NonNull::new(ptr).unwrap())
    }

    /// # Safety
    ///
    /// Only pointers allocated by this instance are safe to free
    pub unsafe fn dealloc(&self, p: NonNull<u8>, l: Layout) {
        let s = l.size() + l.align();
        self.allocated.fetch_sub(s, Ordering::Relaxed);
        dealloc(p.as_ptr(), l);
    }
}

impl Allocator for CaoLangAllocator {
    unsafe fn alloc(&self, l: Layout) -> Result<NonNull<u8>, AllocError> {
        CaoLangAllocator::alloc(self, l)
    }

    unsafe fn dealloc(&self, p: NonNull<u8>, l: Layout) {
        CaoLangAllocator::dealloc(self, p, l)
    }
}
impl Allocator for AllocProxy {
    unsafe fn alloc(&self, l: Layout) -> Result<NonNull<u8>, AllocError> {
        (*self.inner.get()).alloc(l)
    }

    unsafe fn dealloc(&self, p: NonNull<u8>, l: Layout) {
        (*self.inner.get()).dealloc(p, l)
    }
}