@@ -62,19 +62,23 @@ impl DepotManager {
6262 }
6363
6464 async fn sync_depot ( & self , depot : & mut Depot ) -> Result < ( ) , RemoteAccessError > {
65+ info ! ( "requesting manifest.json" ) ;
6566 let manifest_url = Url :: parse ( & depot. endpoint ) ?. join ( "manifest.json" ) ?;
6667 let manifest = DROP_CLIENT_ASYNC . get ( manifest_url) . send ( ) . await ?;
6768 let manifest: DepotManifest = manifest. json ( ) . await ?;
6869 depot. manifest . replace ( manifest) ;
6970
71+ info ! ( "running speedtest..." ) ;
7072 let speedtest_url = Url :: parse ( & depot. endpoint ) ?. join ( "speedtest" ) ?;
7173 let speedtest = DROP_CLIENT_ASYNC . get ( speedtest_url) . send ( ) . await ?;
7274
7375 let mut stream = speedtest. bytes_stream ( ) ;
7476 let start = Instant :: now ( ) ;
7577 let mut total_length = 0 ;
7678
79+ info ! ( "streaming speedtest..." ) ;
7780 while let Some ( chunk) = stream. next ( ) . await {
81+ info ! ( "total length: {}" , total_length) ;
7882 let length = chunk?. len ( ) ;
7983 total_length += length;
8084 if SPEEDTEST_TIMEOUT <= start. elapsed ( ) {
@@ -84,6 +88,7 @@ impl DepotManager {
8488
8589 let elapsed = start. elapsed ( ) . as_millis ( ) as usize ;
8690 let speed = total_length. checked_div ( elapsed) . unwrap_or ( usize:: MAX ) ;
91+ info ! ( "speed: {}" , speed) ;
8792 depot. latest_speed . replace ( speed) ;
8893
8994 Ok ( ( ) )
0 commit comments