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
use std::sync::Arc;
use std::collections::HashMap;
use parking_lot::RwLock;
use elements::Module;
use interpreter::{Error, UserError};
use interpreter::env::{self, env_module};
use interpreter::module::{ModuleInstance, ModuleInstanceInterface};
pub struct ProgramInstance<E: UserError> {
essence: Arc<ProgramInstanceEssence<E>>,
}
pub struct ProgramInstanceEssence<E: UserError> {
modules: RwLock<HashMap<String, Arc<ModuleInstanceInterface<E>>>>,
}
impl<E> ProgramInstance<E> where E: UserError {
pub fn new() -> Result<Self, Error<E>> {
ProgramInstance::with_env_params(env::EnvParams::default())
}
pub fn with_env_params(params: env::EnvParams) -> Result<Self, Error<E>> {
Ok(ProgramInstance {
essence: Arc::new(ProgramInstanceEssence::with_env_params(params)?),
})
}
pub fn with_env_module(env_module: Arc<ModuleInstanceInterface<E>>) -> Self {
ProgramInstance {
essence: Arc::new(ProgramInstanceEssence::with_env_module(env_module)),
}
}
pub fn add_module<'a>(&self, name: &str, module: Module, externals: Option<&'a HashMap<String, Arc<ModuleInstanceInterface<E> + 'a>>>) -> Result<Arc<ModuleInstance<E>>, Error<E>> {
let mut module_instance = ModuleInstance::new(Arc::downgrade(&self.essence), name.into(), module)?;
module_instance.instantiate(externals)?;
let module_instance = Arc::new(module_instance);
self.essence.modules.write().insert(name.into(), module_instance.clone());
module_instance.run_start_function()?;
Ok(module_instance)
}
pub fn insert_loaded_module(&self, name: &str, module_instance: Arc<ModuleInstance<E>>) -> Result<Arc<ModuleInstance<E>>, Error<E>> {
self.essence.modules.write().insert(name.into(), module_instance.clone());
Ok(module_instance)
}
pub fn module(&self, name: &str) -> Option<Arc<ModuleInstanceInterface<E>>> {
self.essence.module(name)
}
}
impl<E> ProgramInstanceEssence<E> where E: UserError {
pub fn new() -> Result<Self, Error<E>> {
ProgramInstanceEssence::with_env_params(env::EnvParams::default())
}
pub fn with_env_params(env_params: env::EnvParams) -> Result<Self, Error<E>> {
let env_mod = env_module(env_params)?;
Ok(ProgramInstanceEssence::with_env_module(Arc::new(env_mod)))
}
pub fn with_env_module(env_module: Arc<ModuleInstanceInterface<E>>) -> Self {
let mut modules = HashMap::new();
modules.insert("env".into(), env_module);
ProgramInstanceEssence {
modules: RwLock::new(modules),
}
}
pub fn module(&self, name: &str) -> Option<Arc<ModuleInstanceInterface<E>>> {
self.modules.read().get(name).cloned()
}
}