use crate::plan::global::BasePlan;
use crate::plan::nogc::mutator::ALLOCATOR_MAPPING;
use crate::plan::AllocationSemantics;
use crate::plan::Plan;
use crate::plan::PlanConstraints;
use crate::policy::immortalspace::ImmortalSpace;
use crate::policy::space::Space;
use crate::scheduler::GCWorkScheduler;
use crate::util::alloc::allocators::AllocatorSelector;
use crate::util::heap::layout::heap_layout::Mmapper;
use crate::util::heap::layout::heap_layout::VMMap;
use crate::util::heap::HeapMeta;
#[allow(unused_imports)]
use crate::util::heap::VMRequest;
use crate::util::metadata::side_metadata::{SideMetadataContext, SideMetadataSanity};
use crate::util::opaque_pointer::*;
use crate::util::options::Options;
use crate::vm::VMBinding;
use enum_map::EnumMap;
use std::sync::Arc;
#[cfg(not(feature = "nogc_lock_free"))]
use crate::policy::immortalspace::ImmortalSpace as NoGCImmortalSpace;
#[cfg(feature = "nogc_lock_free")]
use crate::policy::lockfreeimmortalspace::LockFreeImmortalSpace as NoGCImmortalSpace;
pub struct NoGC<VM: VMBinding> {
pub base: BasePlan<VM>,
pub nogc_space: NoGCImmortalSpace<VM>,
pub immortal: ImmortalSpace<VM>,
pub los: ImmortalSpace<VM>,
}
pub const NOGC_CONSTRAINTS: PlanConstraints = PlanConstraints::default();
impl<VM: VMBinding> Plan for NoGC<VM> {
type VM = VM;
fn constraints(&self) -> &'static PlanConstraints {
&NOGC_CONSTRAINTS
}
fn get_spaces(&self) -> Vec<&dyn Space<Self::VM>> {
let mut ret = self.base.get_spaces();
ret.push(&self.nogc_space);
ret.push(&self.immortal);
ret.push(&self.los);
ret
}
fn collection_required(&self, space_full: bool, _space: Option<&dyn Space<Self::VM>>) -> bool {
self.base().collection_required(self, space_full)
}
fn base(&self) -> &BasePlan<VM> {
&self.base
}
fn prepare(&mut self, _tls: VMWorkerThread) {
unreachable!()
}
fn release(&mut self, _tls: VMWorkerThread) {
unreachable!()
}
fn get_allocator_mapping(&self) -> &'static EnumMap<AllocationSemantics, AllocatorSelector> {
&*ALLOCATOR_MAPPING
}
fn schedule_collection(&'static self, _scheduler: &GCWorkScheduler<VM>) {
unreachable!("GC triggered in nogc")
}
fn get_used_pages(&self) -> usize {
self.nogc_space.reserved_pages()
+ self.immortal.reserved_pages()
+ self.los.reserved_pages()
+ self.base.get_used_pages()
}
fn handle_user_collection_request(&self, _tls: VMMutatorThread, _force: bool) {
warn!("User attempted a collection request, but it is not supported in NoGC. The request is ignored.");
}
}
impl<VM: VMBinding> NoGC<VM> {
pub fn new(vm_map: &'static VMMap, mmapper: &'static Mmapper, options: Arc<Options>) -> Self {
#[cfg(not(feature = "nogc_lock_free"))]
let mut heap = HeapMeta::new(&options);
#[cfg(feature = "nogc_lock_free")]
let mut heap = HeapMeta::new(&options);
let global_specs = SideMetadataContext::new_global_specs(&[]);
#[cfg(feature = "nogc_lock_free")]
let nogc_space = NoGCImmortalSpace::new(
"nogc_space",
cfg!(not(feature = "nogc_no_zeroing")),
&options,
global_specs.clone(),
);
#[cfg(not(feature = "nogc_lock_free"))]
let nogc_space = NoGCImmortalSpace::new(
"nogc_space",
true,
VMRequest::discontiguous(),
global_specs.clone(),
vm_map,
mmapper,
&mut heap,
&NOGC_CONSTRAINTS,
);
let res = NoGC {
nogc_space,
immortal: ImmortalSpace::new(
"immortal",
true,
VMRequest::discontiguous(),
global_specs.clone(),
vm_map,
mmapper,
&mut heap,
&NOGC_CONSTRAINTS,
),
los: ImmortalSpace::new(
"los",
true,
VMRequest::discontiguous(),
global_specs.clone(),
vm_map,
mmapper,
&mut heap,
&NOGC_CONSTRAINTS,
),
base: BasePlan::new(
vm_map,
mmapper,
options,
heap,
&NOGC_CONSTRAINTS,
global_specs,
),
};
let mut side_metadata_sanity_checker = SideMetadataSanity::new();
res.base()
.verify_side_metadata_sanity(&mut side_metadata_sanity_checker);
res.nogc_space
.verify_side_metadata_sanity(&mut side_metadata_sanity_checker);
res
}
}