pesde-pkg/pesde
1
1
Fork 0
mirror of https://github.com/pesde-pkg/pesde.git synced 2025-04-21 04:13:54 +01:00
Code Issues Projects Releases Packages Wiki Activity

refactor: remove unnecessary asyncness from download_and_link

Browse source 
Additionally fixes stack overflows by building the
`miniz_oxide` crate with release level
optimizations.

Signed-off-by: daimond113 <contact@daimond113.com>
This commit is contained in:
daimond113 2025-01-19 21:48:55 +01:00
parent 95896091cd
commit fe979f26c5
No known key found for this signature in database
GPG key ID: 640DC95EC1190354
2 changed files with 10 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
Cargo.toml
View file

@ -99,6 +99,9 @@ members = ["registry"]
[profile.dev.package.full_moon] [profile.dev.package.full_moon]
opt-level = 3 opt-level = 3
[profile.dev.package.miniz_oxide]
opt-level = 3
[profile.release] [profile.release]
opt-level = "s" opt-level = "s"
lto = true lto = true

18
src/download_and_link.rs
View file

@ -426,13 +426,13 @@ impl Project {
} }
} }
async fn index_entry( fn index_entry(
entry: fs::DirEntry, entry: fs::DirEntry,
packages_index_dir: &Path, packages_index_dir: &Path,
tasks: &mut JoinSet<std::io::Result<()>>, tasks: &mut JoinSet<std::io::Result<()>>,
used_paths: &Arc<HashSet<PathBuf>>, used_paths: &Arc<HashSet<PathBuf>>,
#[cfg(feature = "wally-compat")] used_wally_paths: &Arc<HashSet<PathBuf>>, #[cfg(feature = "wally-compat")] used_wally_paths: &Arc<HashSet<PathBuf>>,
) -> std::io::Result<()> { ) {
let path = entry.path(); let path = entry.path();
let path_relative = path.strip_prefix(packages_index_dir).unwrap().to_path_buf(); let path_relative = path.strip_prefix(packages_index_dir).unwrap().to_path_buf();
@ -455,7 +455,7 @@ impl Project {
); );
} }
return Ok(()); return ();
} }
let used_paths = used_paths.clone(); let used_paths = used_paths.clone();
@ -481,15 +481,13 @@ impl Project {
remove_empty_dir(&path).await remove_empty_dir(&path).await
}); });
Ok(())
} }
async fn packages_entry( fn packages_entry(
entry: fs::DirEntry, entry: fs::DirEntry,
tasks: &mut JoinSet<std::io::Result<()>>, tasks: &mut JoinSet<std::io::Result<()>>,
expected_aliases: &Arc<HashSet<Alias>>, expected_aliases: &Arc<HashSet<Alias>>,
) -> std::io::Result<()> { ) {
let expected_aliases = expected_aliases.clone(); let expected_aliases = expected_aliases.clone();
tasks.spawn(async move { tasks.spawn(async move {
if !entry.file_type().await?.is_file() { if !entry.file_type().await?.is_file() {
@ -517,8 +515,6 @@ impl Project {
Ok(()) Ok(())
}); });
Ok(())
} }
let used_paths = graph let used_paths = graph
@ -590,14 +586,14 @@ impl Project {
&used_paths, &used_paths,
#[cfg(feature = "wally-compat")] #[cfg(feature = "wally-compat")]
&used_wally_paths, &used_wally_paths,
).await?; );
} }
Some(entry) = packages_entries.next_entry().map(Result::transpose) => { Some(entry) = packages_entries.next_entry().map(Result::transpose) => {
packages_entry( packages_entry(
entry?, entry?,
&mut tasks, &mut tasks,
&expected_aliases, &expected_aliases,
).await?; );
} }
else => break, else => break,
} }