Unload proc-macro dlls on changed timestamp

This commit is contained in:
Lukas Wirth 2024-12-11 09:24:24 +01:00
parent 41f3319173
commit f370550b0a
2 changed files with 30 additions and 17 deletions

View file

@ -3,7 +3,12 @@
mod version; mod version;
use proc_macro::bridge; use proc_macro::bridge;
use std::{fmt, fs::File, io}; use std::{
fmt,
fs::{self, File},
io,
time::SystemTime,
};
use libloading::Library; use libloading::Library;
use memmap2::Mmap; use memmap2::Mmap;
@ -136,6 +141,7 @@ impl ProcMacroLibraryLibloading {
pub(crate) struct Expander { pub(crate) struct Expander {
inner: ProcMacroLibraryLibloading, inner: ProcMacroLibraryLibloading,
path: Utf8PathBuf, path: Utf8PathBuf,
modified_time: SystemTime,
} }
impl Drop for Expander { impl Drop for Expander {
@ -151,12 +157,13 @@ impl Expander {
// Some libraries for dynamic loading require canonicalized path even when it is // Some libraries for dynamic loading require canonicalized path even when it is
// already absolute // already absolute
let lib = lib.canonicalize_utf8()?; let lib = lib.canonicalize_utf8()?;
let modified_time = fs::metadata(&lib).and_then(|it| it.modified())?;
let path = ensure_file_with_lock_free_access(&lib)?; let path = ensure_file_with_lock_free_access(&lib)?;
let library = ProcMacroLibraryLibloading::open(path.as_ref())?; let library = ProcMacroLibraryLibloading::open(path.as_ref())?;
Ok(Expander { inner: library, path }) Ok(Expander { inner: library, path, modified_time })
} }
pub(crate) fn expand<S: ProcMacroSrvSpan>( pub(crate) fn expand<S: ProcMacroSrvSpan>(
@ -181,6 +188,10 @@ impl Expander {
pub(crate) fn list_macros(&self) -> Vec<(String, ProcMacroKind)> { pub(crate) fn list_macros(&self) -> Vec<(String, ProcMacroKind)> {
self.inner.proc_macros.list_macros() self.inner.proc_macros.list_macros()
} }
pub(crate) fn modified_time(&self) -> SystemTime {
self.modified_time
}
} }
/// Copy the dylib to temp directory to prevent locking in Windows /// Copy the dylib to temp directory to prevent locking in Windows

View file

@ -35,7 +35,6 @@ use std::{
fs, fs,
path::{Path, PathBuf}, path::{Path, PathBuf},
thread, thread,
time::SystemTime,
}; };
use paths::{Utf8Path, Utf8PathBuf}; use paths::{Utf8Path, Utf8PathBuf};
@ -53,7 +52,7 @@ use crate::server_impl::TokenStream;
pub const RUSTC_VERSION_STRING: &str = env!("RUSTC_VERSION"); pub const RUSTC_VERSION_STRING: &str = env!("RUSTC_VERSION");
pub struct ProcMacroSrv<'env> { pub struct ProcMacroSrv<'env> {
expanders: HashMap<(Utf8PathBuf, SystemTime), dylib::Expander>, expanders: HashMap<Utf8PathBuf, dylib::Expander>,
span_mode: SpanMode, span_mode: SpanMode,
env: &'env EnvSnapshot, env: &'env EnvSnapshot,
} }
@ -81,10 +80,9 @@ impl<'env> ProcMacroSrv<'env> {
) -> Result<(msg::FlatTree, Vec<u32>), msg::PanicMessage> { ) -> Result<(msg::FlatTree, Vec<u32>), msg::PanicMessage> {
let span_mode = self.span_mode; let span_mode = self.span_mode;
let snapped_env = self.env; let snapped_env = self.env;
let expander = self.expander(lib.as_ref()).map_err(|err| { let expander = self
debug_assert!(false, "should list macros before asking to expand"); .expander(lib.as_ref())
msg::PanicMessage(format!("failed to load macro: {err}")) .map_err(|err| msg::PanicMessage(format!("failed to load macro: {err}")))?;
})?;
let prev_env = EnvChange::apply(snapped_env, env, current_dir.as_ref().map(<_>::as_ref)); let prev_env = EnvChange::apply(snapped_env, env, current_dir.as_ref().map(<_>::as_ref));
@ -107,16 +105,20 @@ impl<'env> ProcMacroSrv<'env> {
} }
fn expander(&mut self, path: &Utf8Path) -> Result<&dylib::Expander, String> { fn expander(&mut self, path: &Utf8Path) -> Result<&dylib::Expander, String> {
let time = fs::metadata(path) let expander = || {
.and_then(|it| it.modified()) dylib::Expander::new(path)
.map_err(|err| format!("Failed to get file metadata for {path}: {err}",))?; .map_err(|err| format!("Cannot create expander for {path}: {err}",))
};
Ok(match self.expanders.entry((path.to_path_buf(), time)) { Ok(match self.expanders.entry(path.to_path_buf()) {
Entry::Vacant(v) => v.insert( Entry::Vacant(v) => v.insert(expander()?),
dylib::Expander::new(path) Entry::Occupied(mut e) => {
.map_err(|err| format!("Cannot create expander for {path}: {err}",))?, let time = fs::metadata(path).and_then(|it| it.modified()).ok();
), if Some(e.get().modified_time()) != time {
Entry::Occupied(e) => e.into_mut(), e.insert(expander()?);
}
e.into_mut()
}
}) })
} }
} }