@@ -318,29 +318,29 @@ async fn task_cleanup_impl(
318
318
}
319
319
} ;
320
320
321
- let matched = actual_cache_size + active_downloading_size == * mg_cache_size;
321
+ let cache_size = * mg_cache_size;
322
+ let difference = cache_size. abs_diff ( actual_cache_size + active_downloading_size) ;
322
323
323
- if matched {
324
+ /* auto-repair small abnormalities */
325
+ if difference < 10 * 1024 {
326
+ * mg_cache_size = actual_cache_size + active_downloading_size;
327
+ }
328
+
329
+ drop ( mg_cache_size) ;
330
+
331
+ if difference == 0 {
324
332
debug ! (
325
333
"actual cache size: {}; stored cache size: {}; active download size: {}" ,
326
- actual_cache_size, * mg_cache_size , active_downloading_size,
334
+ actual_cache_size, cache_size , active_downloading_size,
327
335
) ;
328
336
} else {
329
337
// TODO: check for inconsistencies and repair
330
338
331
- let difference = ( * mg_cache_size) . abs_diff ( actual_cache_size + active_downloading_size) ;
332
339
warn ! (
333
340
"actual cache size: {}; stored cache size: {}; active download size: {}; size difference: {}" ,
334
- actual_cache_size, * mg_cache_size , active_downloading_size, difference,
341
+ actual_cache_size, cache_size , active_downloading_size, difference,
335
342
) ;
336
-
337
- /* auto-repair small abnormalities */
338
- if difference < 10 * 1024 {
339
- * mg_cache_size = actual_cache_size + active_downloading_size;
340
- }
341
343
}
342
-
343
- drop ( mg_cache_size) ;
344
344
}
345
345
346
346
info ! (
0 commit comments