deploy: e0a0cca

Author: Frando

pr/94/docs/src/iroh_blobs/store/fs/gc.rs.html

@@ -354,7 +354,12 @@
 <a href="#353" id="353">353</a>
 <a href="#354" id="354">354</a>
 <a href="#355" id="355">355</a>
-<a href="#356" id="356">356</a></pre></div><pre class="rust"><code><span class="kw">use </span>std::{collections::HashSet, pin::Pin, sync::Arc};
+<a href="#356" id="356">356</a>
+<a href="#357" id="357">357</a>
+<a href="#358" id="358">358</a>
+<a href="#359" id="359">359</a>
+<a href="#360" id="360">360</a>
+<a href="#361" id="361">361</a></pre></div><pre class="rust"><code><span class="kw">use </span>std::{collections::HashSet, pin::Pin, sync::Arc};
 
 <span class="kw">use </span>bao_tree::ChunkRanges;
 <span class="kw">use </span>genawaiter::sync::{Co, Gen};
@@ -510,6 +515,7 @@
 &gt;;
 
 <span class="kw">pub async fn </span>gc_run_once(store: <span class="kw-2">&amp;</span>Store, live: <span class="kw-2">&amp;mut </span>HashSet&lt;Hash&gt;) -&gt; <span class="kw">crate</span>::api::Result&lt;()&gt; {
+    <span class="macro">debug!</span>(externally_protected = live.len(), <span class="string">"gc: start"</span>);
     {
         store.clear_protected().<span class="kw">await</span><span class="question-mark">?</span>;
         <span class="kw">let </span><span class="kw-2">mut </span>stream = gc_mark(store, live);
@@ -528,6 +534,7 @@
             }
         }
     }
+    <span class="macro">debug!</span>(total_protected = live.len(), <span class="string">"gc: sweep"</span>);
     {
         <span class="kw">let </span><span class="kw-2">mut </span>stream = gc_sweep(store, live);
         <span class="kw">while let </span><span class="prelude-val">Some</span>(ev) = stream.next().<span class="kw">await </span>{
@@ -545,13 +552,16 @@
             }
         }
     }
+    <span class="macro">debug!</span>(<span class="string">"gc: done"</span>);
 
     <span class="prelude-val">Ok</span>(())
 }
 
 <span class="kw">pub async fn </span>run_gc(store: Store, config: GcConfig) {
+    <span class="macro">debug!</span>(<span class="string">"gc enabled with interval {:?}"</span>, config.interval);
     <span class="kw">let </span><span class="kw-2">mut </span>live = HashSet::new();
     <span class="kw">loop </span>{
+        live.clear();
         tokio::time::sleep(config.interval).<span class="kw">await</span>;
         <span class="kw">if let </span><span class="prelude-val">Some</span>(<span class="kw-2">ref </span>cb) = config.add_protected {
             <span class="kw">match </span>(cb)(<span class="kw-2">&amp;mut </span>live).<span class="kw">await </span>{