rsgc 1.1.0

Concurrent GC library for Rust
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

use std::{mem::size_of, ptr::null_mut, sync::atomic::{AtomicPtr, AtomicUsize}};

use crate::{sync::monitor::Monitor, offsetof};

pub struct LocalSSB {
    pub index: usize,
    pub buf: *mut *mut u8
}

impl LocalSSB {
    pub fn index_offset() -> usize {
        offsetof!(LocalSSB, index)
    }

    pub fn buffer_offset() -> usize {
        offsetof!(LocalSSB, buf)
    }


    pub fn try_enqueue(&mut self, obj: *mut u8) -> bool {
        let mut index = self.index;
        if index == 0 {
            return false;
        }

        let buffer = self.buf;
        unsafe {
            index -= 1;
            *buffer.add(index) = obj;
            self.index = index;
        }
        true
    }

    pub fn set_index(&mut self, index: usize) {
        self.index = index;
    }

    pub fn set_buffer(&mut self, buf: *mut *mut u8) {
        self.buf = buf;
    }

    pub fn buffer(&self) -> *mut *mut u8 {
        self.buf 
    }

    pub fn index(&self) -> usize {
        self.index
    }

    pub const fn new() -> Self {
        Self {
            index: 0,
            buf: null_mut()
        }
    }
}