Skip to content

Commit

Permalink
call instantiation_mode when pushing a new mono_item
Browse files Browse the repository at this point in the history
  • Loading branch information
SparrowLii committed May 26, 2022
1 parent 56d540e commit 480e603
Showing 1 changed file with 66 additions and 44 deletions.
110 changes: 66 additions & 44 deletions compiler/rustc_monomorphize/src/collector.rs
Original file line number Diff line number Diff line change
Expand Up @@ -201,7 +201,6 @@ use rustc_session::lint::builtin::LARGE_ASSIGNMENTS;
use rustc_session::Limit;
use rustc_span::source_map::{dummy_spanned, respan, Span, Spanned, DUMMY_SP};
use rustc_target::abi::Size;
use smallvec::SmallVec;
use std::iter;
use std::ops::Range;
use std::path::PathBuf;
Expand All @@ -226,6 +225,44 @@ pub struct InliningMap<'tcx> {
inlines: GrowableBitSet<usize>,
}

/// Struct to store mono items in each collecting and if they should
/// be inlined. We call `instantiation_mode` to get their inlining
/// status when inserting new elements, which avoids calling it in
/// `inlining_map.lock_mut()`. See the `collect_items_rec` implementation
/// below.
struct MonoItems<'tcx> {
// If this is false, we do not need to compute whether items
// will need to be inlined.
compute_inlining: bool,

// The TyCtxt used to determine whether the a item should
// be inlined.
tcx: TyCtxt<'tcx>,

// The collected mono items. The bool field in each element
// indicates whether this element should be inlined.
items: Vec<(Spanned<MonoItem<'tcx>>, bool /*inlined*/)>,
}

impl<'tcx> MonoItems<'tcx> {
#[inline]
fn push(&mut self, item: Spanned<MonoItem<'tcx>>) {
self.extend([item]);
}

#[inline]
fn extend<T: IntoIterator<Item = Spanned<MonoItem<'tcx>>>>(&mut self, iter: T) {
self.items.extend(iter.into_iter().map(|mono_item| {
let inlined = if !self.compute_inlining {
false
} else {
mono_item.node.instantiation_mode(self.tcx) == InstantiationMode::LocalCopy
};
(mono_item, inlined)
}))
}
}

impl<'tcx> InliningMap<'tcx> {
fn new() -> InliningMap<'tcx> {
InliningMap {
Expand All @@ -235,17 +272,23 @@ impl<'tcx> InliningMap<'tcx> {
}
}

fn record_accesses(&mut self, source: MonoItem<'tcx>, new_targets: &[(MonoItem<'tcx>, bool)]) {
fn record_accesses<'a>(
&mut self,
source: MonoItem<'tcx>,
new_targets: &'a [(Spanned<MonoItem<'tcx>>, bool)],
) where
'tcx: 'a,
{
let start_index = self.targets.len();
let new_items_count = new_targets.len();
let new_items_count_total = new_items_count + self.targets.len();

self.targets.reserve(new_items_count);
self.inlines.ensure(new_items_count_total);

for (i, (target, inline)) in new_targets.iter().enumerate() {
self.targets.push(*target);
if *inline {
for (i, (Spanned { node: mono_item, .. }, inlined)) in new_targets.into_iter().enumerate() {
self.targets.push(*mono_item);
if *inlined {
self.inlines.insert(i + start_index);
}
}
Expand Down Expand Up @@ -321,7 +364,7 @@ pub fn collect_crate_mono_items(
// start monomorphizing from.
fn collect_roots(tcx: TyCtxt<'_>, mode: MonoItemCollectionMode) -> Vec<MonoItem<'_>> {
debug!("collecting roots");
let mut roots = Vec::new();
let mut roots = MonoItems { compute_inlining: false, tcx, items: Vec::new() };

{
let entry_fn = tcx.entry_fn(());
Expand All @@ -347,8 +390,11 @@ fn collect_roots(tcx: TyCtxt<'_>, mode: MonoItemCollectionMode) -> Vec<MonoItem<
// whose predicates hold. Luckily, items that aren't instantiable
// can't actually be used, so we can just skip codegenning them.
roots
.items
.into_iter()
.filter_map(|root| root.node.is_instantiable(tcx).then_some(root.node))
.filter_map(|(Spanned { node: mono_item, .. }, _)| {
mono_item.is_instantiable(tcx).then_some(mono_item)
})
.collect()
}

Expand All @@ -368,7 +414,7 @@ fn collect_items_rec<'tcx>(
}
debug!("BEGIN collect_items_rec({})", starting_point.node);

let mut neighbors = Vec::new();
let mut neighbors = MonoItems { compute_inlining: true, tcx, items: Vec::new() };
let recursion_depth_reset;

//
Expand Down Expand Up @@ -483,10 +529,9 @@ fn collect_items_rec<'tcx>(
&format!("the above error was encountered while instantiating `{}`", formatted_item),
);
}
inlining_map.lock_mut().record_accesses(starting_point.node, &neighbors.items);

record_accesses(tcx, starting_point.node, neighbors.iter().map(|i| &i.node), inlining_map);

for neighbour in neighbors {
for (neighbour, _) in neighbors.items {
collect_items_rec(tcx, neighbour, visited, recursion_depths, recursion_limit, inlining_map);
}

Expand All @@ -497,25 +542,6 @@ fn collect_items_rec<'tcx>(
debug!("END collect_items_rec({})", starting_point.node);
}

fn record_accesses<'a, 'tcx: 'a>(
tcx: TyCtxt<'tcx>,
caller: MonoItem<'tcx>,
callees: impl Iterator<Item = &'a MonoItem<'tcx>>,
inlining_map: MTRef<'_, MTLock<InliningMap<'tcx>>>,
) {
let is_inlining_candidate = |mono_item: &MonoItem<'tcx>| {
mono_item.instantiation_mode(tcx) == InstantiationMode::LocalCopy
};

// We collect this into a `SmallVec` to avoid calling `is_inlining_candidate` in the lock.
// FIXME: Call `is_inlining_candidate` when pushing to `neighbors` in `collect_items_rec`
// instead to avoid creating this `SmallVec`.
let accesses: SmallVec<[_; 128]> =
callees.map(|mono_item| (*mono_item, is_inlining_candidate(mono_item))).collect();

inlining_map.lock_mut().record_accesses(caller, &accesses);
}

/// Format instance name that is already known to be too long for rustc.
/// Show only the first and last 32 characters to avoid blasting
/// the user's terminal with thousands of lines of type-name.
Expand Down Expand Up @@ -627,7 +653,7 @@ fn check_type_length_limit<'tcx>(tcx: TyCtxt<'tcx>, instance: Instance<'tcx>) {
struct MirNeighborCollector<'a, 'tcx> {
tcx: TyCtxt<'tcx>,
body: &'a mir::Body<'tcx>,
output: &'a mut Vec<Spanned<MonoItem<'tcx>>>,
output: &'a mut MonoItems<'tcx>,
instance: Instance<'tcx>,
}

Expand Down Expand Up @@ -905,7 +931,7 @@ fn visit_drop_use<'tcx>(
ty: Ty<'tcx>,
is_direct_call: bool,
source: Span,
output: &mut Vec<Spanned<MonoItem<'tcx>>>,
output: &mut MonoItems<'tcx>,
) {
let instance = Instance::resolve_drop_in_place(tcx, ty);
visit_instance_use(tcx, instance, is_direct_call, source, output);
Expand All @@ -916,7 +942,7 @@ fn visit_fn_use<'tcx>(
ty: Ty<'tcx>,
is_direct_call: bool,
source: Span,
output: &mut Vec<Spanned<MonoItem<'tcx>>>,
output: &mut MonoItems<'tcx>,
) {
if let ty::FnDef(def_id, substs) = *ty.kind() {
let instance = if is_direct_call {
Expand All @@ -934,7 +960,7 @@ fn visit_instance_use<'tcx>(
instance: ty::Instance<'tcx>,
is_direct_call: bool,
source: Span,
output: &mut Vec<Spanned<MonoItem<'tcx>>>,
output: &mut MonoItems<'tcx>,
) {
debug!("visit_item_use({:?}, is_direct_call={:?})", instance, is_direct_call);
if !should_codegen_locally(tcx, &instance) {
Expand Down Expand Up @@ -1117,7 +1143,7 @@ fn create_mono_items_for_vtable_methods<'tcx>(
trait_ty: Ty<'tcx>,
impl_ty: Ty<'tcx>,
source: Span,
output: &mut Vec<Spanned<MonoItem<'tcx>>>,
output: &mut MonoItems<'tcx>,
) {
assert!(!trait_ty.has_escaping_bound_vars() && !impl_ty.has_escaping_bound_vars());

Expand Down Expand Up @@ -1159,7 +1185,7 @@ fn create_mono_items_for_vtable_methods<'tcx>(
struct RootCollector<'a, 'tcx> {
tcx: TyCtxt<'tcx>,
mode: MonoItemCollectionMode,
output: &'a mut Vec<Spanned<MonoItem<'tcx>>>,
output: &'a mut MonoItems<'tcx>,
entry_fn: Option<(DefId, EntryFnType)>,
}

Expand Down Expand Up @@ -1305,7 +1331,7 @@ fn item_requires_monomorphization(tcx: TyCtxt<'_>, def_id: LocalDefId) -> bool {
fn create_mono_items_for_default_impls<'tcx>(
tcx: TyCtxt<'tcx>,
item: &'tcx hir::Item<'tcx>,
output: &mut Vec<Spanned<MonoItem<'tcx>>>,
output: &mut MonoItems<'tcx>,
) {
match item.kind {
hir::ItemKind::Impl(ref impl_) => {
Expand Down Expand Up @@ -1361,11 +1387,7 @@ fn create_mono_items_for_default_impls<'tcx>(
}

/// Scans the miri alloc in order to find function calls, closures, and drop-glue.
fn collect_miri<'tcx>(
tcx: TyCtxt<'tcx>,
alloc_id: AllocId,
output: &mut Vec<Spanned<MonoItem<'tcx>>>,
) {
fn collect_miri<'tcx>(tcx: TyCtxt<'tcx>, alloc_id: AllocId, output: &mut MonoItems<'tcx>) {
match tcx.global_alloc(alloc_id) {
GlobalAlloc::Static(def_id) => {
assert!(!tcx.is_thread_local_static(def_id));
Expand Down Expand Up @@ -1396,7 +1418,7 @@ fn collect_miri<'tcx>(
fn collect_neighbours<'tcx>(
tcx: TyCtxt<'tcx>,
instance: Instance<'tcx>,
output: &mut Vec<Spanned<MonoItem<'tcx>>>,
output: &mut MonoItems<'tcx>,
) {
debug!("collect_neighbours: {:?}", instance.def_id());
let body = tcx.instance_mir(instance.def);
Expand All @@ -1407,7 +1429,7 @@ fn collect_neighbours<'tcx>(
fn collect_const_value<'tcx>(
tcx: TyCtxt<'tcx>,
value: ConstValue<'tcx>,
output: &mut Vec<Spanned<MonoItem<'tcx>>>,
output: &mut MonoItems<'tcx>,
) {
match value {
ConstValue::Scalar(Scalar::Ptr(ptr, _size)) => collect_miri(tcx, ptr.provenance, output),
Expand Down

0 comments on commit 480e603

Please sign in to comment.