upleb.uk

Public git repos — served from a NIP-34 GRASP relay at git.upleb.uk

summaryrefslogtreecommitdiff
path: root/src/purgatory/sync
diff options
context:
space:
mode:
Diffstat (limited to 'src/purgatory/sync')
-rw-r--r--src/purgatory/sync/throttle.rs2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/purgatory/sync/throttle.rs b/src/purgatory/sync/throttle.rs
index a310a91..05b0878 100644
--- a/src/purgatory/sync/throttle.rs
+++ b/src/purgatory/sync/throttle.rs
@@ -343,6 +343,7 @@ impl ThrottleManager {
343 /// 343 ///
344 /// Decrements in-flight count and cleans up old timestamps. 344 /// Decrements in-flight count and cleans up old timestamps.
345 /// Does not trigger processing of queued identifiers. 345 /// Does not trigger processing of queued identifiers.
346 #[cfg(test)]
346 fn complete_request_internal(&self, domain: &str) { 347 fn complete_request_internal(&self, domain: &str) {
347 if let Some(entry) = self.throttles.get(domain) { 348 if let Some(entry) = self.throttles.get(domain) {
348 let mut throttle = entry.lock().unwrap(); 349 let mut throttle = entry.lock().unwrap();
@@ -377,6 +378,7 @@ impl ThrottleManager {
377 /// 378 ///
378 /// If the identifier is already queued for this domain, merges the tried_urls sets. 379 /// If the identifier is already queued for this domain, merges the tried_urls sets.
379 /// Does not trigger processing. 380 /// Does not trigger processing.
381 #[cfg(test)]
380 fn enqueue_identifier_internal( 382 fn enqueue_identifier_internal(
381 &self, 383 &self,
382 domain: &str, 384 domain: &str,