YGGverse/aquatic-crawler
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic-crawler.git synced 2026-03-31 17:15:35 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

require sleep timer value

Browse source
This commit is contained in:
yggverse 2025-08-13 15:39:07 +03:00
parent d1e93638d9
commit c44acbb50c
2 changed files with 5 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/config.rs
View file

@ -99,8 +99,8 @@ pub struct Config {
pub add_torrent_timeout: u64,
/// Crawl loop delay in seconds
#[arg(long)]
pub sleep: Option<u64>,
#[arg(long, default_value_t = 900)]
pub sleep: u64,
/// Ban unresolvable info-hashes for `n` seconds
#[arg(long, default_value_t = 3600)]

8
src/main.rs
View file

@ -232,7 +232,7 @@ async fn main() -> Result<()> {
}
}
log::debug!(
"queue completed at {time_queue} (time: {} / uptime: {} / banned: {})",
"queue completed at {time_queue} (time: {} / uptime: {} / banned: {}) await {} seconds to continue...",
Local::now()
.signed_duration_since(time_queue)
.as_seconds_f32(),
@ -240,11 +240,9 @@ async fn main() -> Result<()> {
.signed_duration_since(time_init)
.as_seconds_f32(),
ban.len(),
config.sleep
);
if let Some(sleep) = config.sleep {
log::debug!("await {sleep} seconds to continue...");
std::thread::sleep(Duration::from_secs(sleep))
}
std::thread::sleep(Duration::from_secs(config.sleep))
}
}