corevm 0.1.28

The JAM CoreVM Service, a container service for running regular software on JAM.
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

use bytes::Bytes;
use corevm_engine::{InnerVm, OuterVm};
use corevm_host::{fs, PageNum};
use jam_pvm_common::{
	refine::{export_slice, expunge, foreign_lookup, invoke, machine, peek_into, poke, void, zero},
	ApiError, InvokeOutcome,
};
use jam_types::{PageMode, SignedGas, SEGMENT_LEN};

/// An implementation of `OuterVM` that forwards all host-calls to JAM.
#[derive(Default)]
pub struct JamOuterVm;

impl OuterVm for JamOuterVm {
	type InnerVm = JamInnerVm;

	fn export(&mut self, segment: &[u8; SEGMENT_LEN]) -> Result<(), ApiError> {
		export_slice(segment)?;
		Ok(())
	}

	fn read_file_block(&mut self, block_ref: &fs::BlockRef) -> Option<Bytes> {
		foreign_lookup(block_ref.service_id, &block_ref.hash.0).map(Into::into)
	}

	fn machine(&mut self, code: &[u8], program_counter: u64) -> Result<Self::InnerVm, ApiError> {
		Ok(JamInnerVm(machine(code, program_counter)?))
	}
}

/// An implementation of `InnerVM` that forwards all host-calls to JAM.
pub struct JamInnerVm(pub u64);

impl InnerVm for JamInnerVm {
	fn void(&mut self, page: PageNum, num_pages: u32) -> Result<(), ApiError> {
		void(self.0, u64::from(page.0), u64::from(num_pages))
	}

	fn zero(&mut self, page: PageNum, num_pages: u32) -> Result<(), ApiError> {
		zero(self.0, u64::from(page.0), u64::from(num_pages), PageMode::ReadWrite)
	}

	fn poke(&mut self, outer_src: &[u8], inner_dst: u32) -> Result<(), ApiError> {
		poke(self.0, outer_src, u64::from(inner_dst))
	}

	fn peek_into(&mut self, outer_dst: &mut [u8], inner_src: u32) -> Result<(), ApiError> {
		peek_into(self.0, outer_dst, u64::from(inner_src))
	}

	fn expunge(self) -> Result<u64, ApiError> {
		expunge(self.0)
	}

	fn invoke(
		&mut self,
		gas: SignedGas,
		regs: [u64; 13],
	) -> Result<(InvokeOutcome, SignedGas, [u64; 13]), ApiError> {
		invoke(self.0, gas, regs)
	}
}