pr47 0.1.4-CHARLIE

A semi-experimental programming language. Still working in progress.
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

use std::marker::PhantomPinned;
use std::ptr::NonNull;

use xjbutil::unchecked::UncheckedSendSync;

use crate::data::Value;
use crate::vm::al31f::AL31F;
use crate::vm::al31f::alloc::Alloc;
use crate::vm::al31f::compiled::CompiledProgram;
use crate::vm::al31f::exception::Exception;
use crate::vm::al31f::executor::{VMThread, vm_thread_run_function};
use crate::vm::al31f::stack::Stack;

#[cfg(feature = "async")]
use crate::util::serializer::CoroutineContext;

pub unsafe fn vm_run_function_sync<A: Alloc>(
    alloc: A,
    program: &CompiledProgram<A>,
    func_id: usize,
    args: &[Value]
) -> Result<Vec<Value>, Exception> {
    let vm: AL31F<A> = AL31F::new(alloc);

    #[cfg(feature = "async")]
    return pollster::block_on(async {
        let vm: CoroutineContext<AL31F<A>> = CoroutineContext::main_context(vm).await;
        let mut thread: VMThread<A> = VMThread {
            vm,
            program: NonNull::new_unchecked(program as *const _ as *mut _),
            stack: Stack::new(),
            _phantom: PhantomPinned::default()
        };
        thread.vm.get_shared_data_mut().alloc.add_stack(&thread.stack);
        vm_thread_run_function::<_, true>(UncheckedSendSync::new((&mut thread, func_id, args)))?
            .await
            .into_inner()
    });

    #[cfg(not(feature = "async"))]
    return pollster::block_on(async {
        let mut thread: VMThread<A> = VMThread {
            vm,
            program: NonNull::new_unchecked(program as *const _ as *mut _),
            stack: Stack::new(),
            _phantom: PhantomPinned
        };
        thread.vm.alloc.add_stack(&thread.stack);
        vm_thread_run_function::<_, true>(UncheckedSendSync::new((&mut thread, func_id, args)))?
            .await
            .into_inner()
    });
}