girineko/hbb_common
1
0
Fork 0
mirror of https://github.com/GiriNeko/hbb_common.git synced 2025-12-16 13:27:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

refact: optimize, preload peers.

Browse source 
Signed-off-by: fufesou <linlong1266@gmail.com>
This commit is contained in:
fufesou 2025-02-20 12:03:44 +08:00
parent f94753bddb
commit 33487a0b14
1 changed files with 6 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

7
src/config.rs
View file

@ -1346,7 +1346,12 @@ impl PeerConfig {
for (_, _, path) in vec_id_modified_time_path.into_iter() {
futs.push(Self::preload_file_async(path));
if futs.len() >= Self::BATCH_LOADING_COUNT {
let first_load_start = std::time::Instant::now();
futures::future::join_all(futs).await;
if first_load_start.elapsed().as_millis() < 10 {
// No need to preload the rest if the first load is fast.
return;
}
futs = vec![];
}
}
@ -1395,7 +1400,7 @@ impl PeerConfig {
Some(to) => to.min(all.len()),
None => (from + Self::BATCH_LOADING_COUNT).min(all.len()),
};
// to <= from is unexpected, but we can just return an empty vec in this case.
if to <= from {
return (vec![], from);