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

add timing debug

Browse source
This commit is contained in:
yggverse 2025-07-09 15:06:28 +03:00
parent 7da1df7137
commit 76c2c1c0b8
1 changed files with 13 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

17
src/main.rs
View file

@ -24,10 +24,12 @@ use url::Url;
#[tokio::main] #[tokio::main]
async fn main() -> Result<()> { async fn main() -> Result<()> {
use chrono::Local;
use clap::Parser; use clap::Parser;
use tokio::time; use tokio::time;
// init components // init components
let time_init = Local::now();
let config = Config::parse(); let config = Config::parse();
if config.debug { if config.debug {
tracing_subscriber::fmt::init() tracing_subscriber::fmt::init()
@ -73,7 +75,7 @@ async fn main() -> Result<()> {
.await?; .await?;
// begin // begin
println!("Crawler started"); println!("Crawler started on {time_init}");
let mut index = Index::init( let mut index = Index::init(
config.index_capacity, config.index_capacity,
config.index_timeout, config.index_timeout,
@ -82,8 +84,9 @@ async fn main() -> Result<()> {
config.export_rss.is_some() && config.index_list, config.export_rss.is_some() && config.index_list,
); );
loop { loop {
let time_queue = Local::now();
if config.debug { if config.debug {
println!("\tQueue crawl begin...") println!("\tQueue crawl begin on {time_queue}...")
} }
index.refresh(); index.refresh();
for source in &config.infohash { for source in &config.infohash {
@ -287,8 +290,14 @@ async fn main() -> Result<()> {
} }
if config.debug { if config.debug {
println!( println!(
"Queue completed, {} total, await {} seconds to continue...", "Queue completed on {time_queue}\n\ttotal: {}\n\ttime: {}s\n\tuptime: {}s\n\tawait {} seconds to continue...",
index.len(), index.len(),
Local::now()
.signed_duration_since(time_queue)
.as_seconds_f32(),
Local::now()
.signed_duration_since(time_init)
.as_seconds_f32(),
config.sleep, config.sleep,
) )
} }
@ -307,7 +316,7 @@ fn save_torrent_file(t: &Torrent, i: &str, b: &[u8], d: bool) {
} }
} }
} }
Err(e) => eprintln!("Error on save torrent file `{i}`: {e}"), Err(e) => eprintln!("Error on save torrent file `{i}`: `{e}`"),
} }
} }