diff options
Diffstat (limited to 'src/purgatory/sync')
| -rw-r--r-- | src/purgatory/sync/throttle.rs | 2 |
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, |