tor_guardmgr/lib.rs
1#![cfg_attr(docsrs, feature(doc_cfg))]
2#![doc = include_str!("../README.md")]
3// @@ begin lint list maintained by maint/add_warning @@
4#![allow(renamed_and_removed_lints)] // @@REMOVE_WHEN(ci_arti_stable)
5#![allow(unknown_lints)] // @@REMOVE_WHEN(ci_arti_nightly)
6#![warn(missing_docs)]
7#![warn(noop_method_call)]
8#![warn(unreachable_pub)]
9#![warn(clippy::all)]
10#![deny(clippy::await_holding_lock)]
11#![deny(clippy::cargo_common_metadata)]
12#![deny(clippy::cast_lossless)]
13#![deny(clippy::checked_conversions)]
14#![warn(clippy::cognitive_complexity)]
15#![deny(clippy::debug_assert_with_mut_call)]
16#![deny(clippy::exhaustive_enums)]
17#![deny(clippy::exhaustive_structs)]
18#![deny(clippy::expl_impl_clone_on_copy)]
19#![deny(clippy::fallible_impl_from)]
20#![deny(clippy::implicit_clone)]
21#![deny(clippy::large_stack_arrays)]
22#![warn(clippy::manual_ok_or)]
23#![deny(clippy::missing_docs_in_private_items)]
24#![warn(clippy::needless_borrow)]
25#![warn(clippy::needless_pass_by_value)]
26#![warn(clippy::option_option)]
27#![deny(clippy::print_stderr)]
28#![deny(clippy::print_stdout)]
29#![warn(clippy::rc_buffer)]
30#![deny(clippy::ref_option_ref)]
31#![warn(clippy::semicolon_if_nothing_returned)]
32#![warn(clippy::trait_duplication_in_bounds)]
33#![deny(clippy::unchecked_time_subtraction)]
34#![deny(clippy::unnecessary_wraps)]
35#![warn(clippy::unseparated_literal_suffix)]
36#![deny(clippy::unwrap_used)]
37#![deny(clippy::mod_module_files)]
38#![allow(clippy::let_unit_value)] // This can reasonably be done for explicitness
39#![allow(clippy::uninlined_format_args)]
40#![allow(clippy::significant_drop_in_scrutinee)] // arti/-/merge_requests/588/#note_2812945
41#![allow(clippy::result_large_err)] // temporary workaround for arti#587
42#![allow(clippy::needless_raw_string_hashes)] // complained-about code is fine, often best
43#![allow(clippy::needless_lifetimes)] // See arti#1765
44#![allow(mismatched_lifetime_syntaxes)] // temporary workaround for arti#2060
45//! <!-- @@ end lint list maintained by maint/add_warning @@ -->
46
47// TODO #1645 (either remove this, or decide to have it everywhere)
48#![cfg_attr(not(all(feature = "full", feature = "experimental")), allow(unused))]
49
50// Glossary:
51// Primary guard
52// Sample
53// confirmed
54// filtered
55
56use futures::channel::mpsc;
57use itertools::Either;
58use serde::{Deserialize, Serialize};
59use std::collections::HashMap;
60use std::net::SocketAddr;
61use std::sync::{Arc, Mutex, Weak};
62use std::time::{Duration, Instant, SystemTime};
63#[cfg(feature = "bridge-client")]
64use tor_error::internal;
65use tor_linkspec::{OwnedChanTarget, OwnedCircTarget, RelayId, RelayIdSet};
66use tor_netdir::NetDirProvider;
67use tor_proto::ClockSkew;
68use tor_rtcompat::SpawnExt;
69use tor_units::BoundedInt32;
70use tracing::{debug, info, instrument, trace, warn};
71
72use tor_config::{ExplicitOrAuto, impl_standard_builder};
73use tor_config::{ReconfigureError, impl_not_auto_value};
74use tor_config::{define_list_builder_accessors, define_list_builder_helper};
75use tor_netdir::{NetDir, Relay, params::NetParameters};
76use tor_persist::{DynStorageHandle, StateMgr};
77use tor_rtcompat::Runtime;
78
79#[cfg(feature = "bridge-client")]
80pub mod bridge;
81mod config;
82mod daemon;
83mod dirstatus;
84mod err;
85mod events;
86pub mod fallback;
87mod filter;
88mod guard;
89mod ids;
90mod pending;
91mod sample;
92mod skew;
93mod util;
94#[cfg(feature = "vanguards")]
95pub mod vanguards;
96
97#[cfg(not(feature = "bridge-client"))]
98#[path = "bridge_disabled.rs"]
99pub mod bridge;
100
101#[cfg(any(test, feature = "testing"))]
102pub use config::testing::TestConfig;
103
104#[cfg(test)]
105use oneshot_fused_workaround as oneshot;
106
107pub use config::GuardMgrConfig;
108pub use err::{GuardMgrConfigError, GuardMgrError, PickGuardError};
109pub use events::ClockSkewEvents;
110pub use filter::GuardFilter;
111pub use ids::FirstHopId;
112pub use pending::{GuardMonitor, GuardStatus, GuardUsable};
113pub use skew::SkewEstimate;
114
115#[cfg(feature = "vanguards")]
116pub use vanguards::VanguardMgrError;
117
118use pending::{PendingRequest, RequestId};
119use sample::{GuardSet, Universe, UniverseRef};
120
121use crate::ids::{FirstHopIdInner, GuardId};
122
123use tor_config::ConfigBuildError;
124
125/// A "guard manager" that selects and remembers a persistent set of
126/// guard nodes.
127///
128/// This is a "handle"; clones of it share state.
129#[derive(Clone)]
130pub struct GuardMgr<R: Runtime> {
131 /// An asynchronous runtime object.
132 ///
133 /// GuardMgr uses this runtime for timing, timeouts, and spawning
134 /// tasks.
135 runtime: R,
136
137 /// Internal state for the guard manager.
138 inner: Arc<Mutex<GuardMgrInner>>,
139}
140
141/// Helper type that holds the data used by a [`GuardMgr`].
142///
143/// This would just be a [`GuardMgr`], except that it needs to sit inside
144/// a `Mutex` and get accessed by daemon tasks.
145struct GuardMgrInner {
146 /// Last time when marked all of our primary guards as retriable.
147 ///
148 /// We keep track of this time so that we can rate-limit
149 /// these attempts.
150 last_primary_retry_time: Instant,
151
152 /// Persistent guard manager state.
153 ///
154 /// This object remembers one or more persistent set of guards that we can
155 /// use, along with their relative priorities and statuses.
156 guards: GuardSets,
157
158 /// The current filter that we're using to decide which guards are
159 /// supported.
160 //
161 // TODO: This field is duplicated in the current active [`GuardSet`]; we
162 // should fix that.
163 filter: GuardFilter,
164
165 /// Configuration values derived from the consensus parameters.
166 ///
167 /// This is updated whenever the consensus parameters change.
168 params: GuardParams,
169
170 /// A mpsc channel, used to tell the task running in
171 /// [`daemon::report_status_events`] about a new event to monitor.
172 ///
173 /// This uses an `UnboundedSender` so that we don't have to await
174 /// while sending the message, which in turn allows the GuardMgr
175 /// API to be simpler. The risk, however, is that there's no
176 /// backpressure in the event that the task running
177 /// [`daemon::report_status_events`] fails to read from this
178 /// channel.
179 ctrl: mpsc::UnboundedSender<daemon::Msg>,
180
181 /// Information about guards that we've given out, but where we have
182 /// not yet heard whether the guard was successful.
183 ///
184 /// Upon leaning whether the guard was successful, the pending
185 /// requests in this map may be either moved to `waiting`, or
186 /// discarded.
187 ///
188 /// There can be multiple pending requests corresponding to the
189 /// same guard.
190 pending: HashMap<RequestId, PendingRequest>,
191
192 /// A list of pending requests for which we have heard that the
193 /// guard was successful, but we have not yet decided whether the
194 /// circuit may be used.
195 ///
196 /// There can be multiple waiting requests corresponding to the
197 /// same guard.
198 waiting: Vec<PendingRequest>,
199
200 /// A list of fallback directories used to access the directory system
201 /// when no other directory information is yet known.
202 fallbacks: fallback::FallbackState,
203
204 /// Location in which to store persistent state.
205 storage: DynStorageHandle<GuardSets>,
206
207 /// A sender object to publish changes in our estimated clock skew.
208 send_skew: postage::watch::Sender<Option<SkewEstimate>>,
209
210 /// A receiver object to hand out to observers who want to know about
211 /// changes in our estimated clock skew.
212 recv_skew: events::ClockSkewEvents,
213
214 /// A netdir provider that we can use for adding new guards when
215 /// insufficient guards are available.
216 ///
217 /// This has to be an Option so it can be initialized from None: at the
218 /// time a GuardMgr is created, there is no NetDirProvider for it to use.
219 netdir_provider: Option<Weak<dyn NetDirProvider>>,
220
221 /// A netdir provider that we can use for discovering bridge descriptors.
222 ///
223 /// This has to be an Option so it can be initialized from None: at the time
224 /// a GuardMgr is created, there is no BridgeDescProvider for it to use.
225 #[cfg(feature = "bridge-client")]
226 bridge_desc_provider: Option<Weak<dyn bridge::BridgeDescProvider>>,
227
228 /// A list of the bridges that we are configured to use, or "None" if we are
229 /// not configured to use bridges.
230 #[cfg(feature = "bridge-client")]
231 configured_bridges: Option<Arc<[bridge::BridgeConfig]>>,
232}
233
234/// A selector that tells us which [`GuardSet`] of several is currently in use.
235#[derive(Clone, Debug, Default, Eq, PartialEq, Ord, PartialOrd, strum::EnumIter)]
236enum GuardSetSelector {
237 /// The default guard set is currently in use: that's the one that we use
238 /// when we have no filter installed, or the filter permits most of the
239 /// guards on the network.
240 #[default]
241 Default,
242 /// A "restrictive" guard set is currently in use: that's the one that we
243 /// use when we have a filter that excludes a large fraction of the guards
244 /// on the network.
245 Restricted,
246 /// The "bridges" guard set is currently in use: we are selecting our guards
247 /// from among the universe of configured bridges.
248 #[cfg(feature = "bridge-client")]
249 Bridges,
250}
251
252/// Describes the [`Universe`] that a guard sample should take its guards from.
253#[derive(Clone, Copy, Debug, Eq, PartialEq)]
254enum UniverseType {
255 /// Take information from the network directory.
256 NetDir,
257 /// Take information from the configured bridges.
258 #[cfg(feature = "bridge-client")]
259 BridgeSet,
260}
261
262impl GuardSetSelector {
263 /// Return a description of which [`Universe`] this guard sample should take
264 /// its guards from.
265 fn universe_type(&self) -> UniverseType {
266 match self {
267 GuardSetSelector::Default | GuardSetSelector::Restricted => UniverseType::NetDir,
268 #[cfg(feature = "bridge-client")]
269 GuardSetSelector::Bridges => UniverseType::BridgeSet,
270 }
271 }
272}
273
274/// Persistent state for a guard manager, as serialized to disk.
275#[derive(Debug, Clone, Default, Serialize, Deserialize)]
276struct GuardSets {
277 /// Which set of guards is currently in use?
278 #[serde(skip)]
279 active_set: GuardSetSelector,
280
281 /// The default set of guards to use.
282 ///
283 /// We use this one when there is no filter, or the filter permits most of the
284 /// guards on the network.
285 default: GuardSet,
286
287 /// A guard set to use when we have a restrictive filter.
288 #[serde(default)]
289 restricted: GuardSet,
290
291 /// A guard set sampled from our configured bridges.
292 #[serde(default)]
293 #[cfg(feature = "bridge-client")]
294 bridges: GuardSet,
295
296 /// Unrecognized fields, including (possibly) other guard sets.
297 #[serde(flatten)]
298 remaining: HashMap<String, tor_persist::JsonValue>,
299}
300
301/// The key (filename) we use for storing our persistent guard state in the
302/// `StateMgr`.
303///
304/// We used to store this in a different format in a filename called
305/// "default_guards" (before Arti 0.1.0).
306const STORAGE_KEY: &str = "guards";
307
308/// A description of which circuits to retire because of a configuration change.
309///
310/// TODO(nickm): Eventually we will want to add a "Some" here, to support
311/// removing only those circuits that correspond to no-longer-usable guards.
312#[derive(Clone, Debug, Eq, PartialEq)]
313#[must_use]
314#[non_exhaustive]
315pub enum RetireCircuits {
316 /// There's no need to retire any circuits.
317 None,
318 /// All circuits should be retired.
319 All,
320}
321
322impl<R: Runtime> GuardMgr<R> {
323 /// Create a new "empty" guard manager and launch its background tasks.
324 ///
325 /// It won't be able to hand out any guards until a [`NetDirProvider`] has
326 /// been installed.
327 #[instrument(skip_all, level = "trace")]
328 pub fn new<S>(
329 runtime: R,
330 state_mgr: S,
331 config: &impl GuardMgrConfig,
332 ) -> Result<Self, GuardMgrError>
333 where
334 S: StateMgr + Send + Sync + 'static,
335 {
336 let (ctrl, rcv) = mpsc::unbounded();
337 let storage: DynStorageHandle<GuardSets> = state_mgr.create_handle(STORAGE_KEY);
338 // TODO(nickm): We should do something about the old state in
339 // `default_guards`. Probably it would be best to delete it. We could
340 // try to migrate it instead, but that's beyond the stability guarantee
341 // that we're getting at this stage of our (pre-0.1) development.
342 let state = storage.load()?.unwrap_or_default();
343
344 let (send_skew, recv_skew) = postage::watch::channel();
345 let recv_skew = ClockSkewEvents { inner: recv_skew };
346
347 let inner = Arc::new(Mutex::new(GuardMgrInner {
348 guards: state,
349 filter: GuardFilter::unfiltered(),
350 last_primary_retry_time: runtime.now(),
351 params: GuardParams::default(),
352 ctrl,
353 pending: HashMap::new(),
354 waiting: Vec::new(),
355 fallbacks: config.fallbacks().into(),
356 storage,
357 send_skew,
358 recv_skew,
359 netdir_provider: None,
360 #[cfg(feature = "bridge-client")]
361 bridge_desc_provider: None,
362 #[cfg(feature = "bridge-client")]
363 configured_bridges: None,
364 }));
365 #[cfg(feature = "bridge-client")]
366 {
367 let mut inner = inner.lock().expect("lock poisoned");
368 // TODO(nickm): This calls `GuardMgrInner::update`. Will we mind doing so before any
369 // providers are configured? I think not, but we should make sure.
370 let _: RetireCircuits =
371 inner.replace_bridge_config(config, runtime.wallclock(), runtime.now())?;
372 }
373 {
374 let weak_inner = Arc::downgrade(&inner);
375 let rt_clone = runtime.clone();
376 runtime
377 .spawn(daemon::report_status_events(rt_clone, weak_inner, rcv))
378 .map_err(|e| GuardMgrError::from_spawn("guard status event reporter", e))?;
379 }
380 {
381 let rt_clone = runtime.clone();
382 let weak_inner = Arc::downgrade(&inner);
383 runtime
384 .spawn(daemon::run_periodic(rt_clone, weak_inner))
385 .map_err(|e| GuardMgrError::from_spawn("periodic guard updater", e))?;
386 }
387 Ok(GuardMgr { runtime, inner })
388 }
389
390 /// Install a [`NetDirProvider`] for use by this guard manager.
391 ///
392 /// It will be used to keep the guards up-to-date with changes from the
393 /// network directory, and to find new guards when no NetDir is provided to
394 /// select_guard().
395 ///
396 /// TODO: we should eventually return some kind of a task handle from this
397 /// task, even though it is not strictly speaking periodic.
398 ///
399 /// The guardmgr retains only a `Weak` reference to `provider`,
400 /// `install_netdir_provider` downgrades it on entry,
401 // TODO add ref to document when https://gitlab.torproject.org/tpo/core/arti/-/issues/624
402 // is fixed. Also, maybe take an owned `Weak` to start with.
403 //
404 /// # Panics
405 ///
406 /// Panics if a [`NetDirProvider`] is already installed.
407 pub fn install_netdir_provider(
408 &self,
409 provider: &Arc<dyn NetDirProvider>,
410 ) -> Result<(), GuardMgrError> {
411 let weak_provider = Arc::downgrade(provider);
412 {
413 let mut inner = self.inner.lock().expect("Poisoned lock");
414 assert!(inner.netdir_provider.is_none());
415 inner.netdir_provider = Some(weak_provider.clone());
416 }
417 let weak_inner = Arc::downgrade(&self.inner);
418 let rt_clone = self.runtime.clone();
419 self.runtime
420 .spawn(daemon::keep_netdir_updated(
421 rt_clone,
422 weak_inner,
423 weak_provider,
424 ))
425 .map_err(|e| GuardMgrError::from_spawn("periodic guard netdir updater", e))?;
426 Ok(())
427 }
428
429 /// Configure a new [`bridge::BridgeDescProvider`] for this [`GuardMgr`].
430 ///
431 /// It will be used to learn about changes in the set of available bridge
432 /// descriptors; we'll inform it whenever our desired set of bridge
433 /// descriptors changes.
434 ///
435 /// TODO: Same todo as in `install_netdir_provider` about task handles.
436 ///
437 /// # Panics
438 ///
439 /// Panics if a [`bridge::BridgeDescProvider`] is already installed.
440 #[cfg(feature = "bridge-client")]
441 pub fn install_bridge_desc_provider(
442 &self,
443 provider: &Arc<dyn bridge::BridgeDescProvider>,
444 ) -> Result<(), GuardMgrError> {
445 let weak_provider = Arc::downgrade(provider);
446 {
447 let mut inner = self.inner.lock().expect("Poisoned lock");
448 assert!(inner.bridge_desc_provider.is_none());
449 inner.bridge_desc_provider = Some(weak_provider.clone());
450 }
451
452 let weak_inner = Arc::downgrade(&self.inner);
453 let rt_clone = self.runtime.clone();
454 self.runtime
455 .spawn(daemon::keep_bridge_descs_updated(
456 rt_clone,
457 weak_inner,
458 weak_provider,
459 ))
460 .map_err(|e| GuardMgrError::from_spawn("periodic guard netdir updater", e))?;
461
462 Ok(())
463 }
464
465 /// Flush our current guard state to the state manager, if there
466 /// is any unsaved state.
467 pub fn store_persistent_state(&self) -> Result<(), GuardMgrError> {
468 let inner = self.inner.lock().expect("Poisoned lock");
469 trace!("Flushing guard state to disk.");
470 inner.storage.store(&inner.guards)?;
471 Ok(())
472 }
473
474 /// Reload state from the state manager.
475 ///
476 /// We only call this method if we _don't_ have the lock on the state
477 /// files. If we have the lock, we only want to save.
478 #[instrument(level = "trace", skip_all)]
479 pub fn reload_persistent_state(&self) -> Result<(), GuardMgrError> {
480 let mut inner = self.inner.lock().expect("Poisoned lock");
481 if let Some(new_guards) = inner.storage.load()? {
482 inner.replace_guards_with(new_guards, self.runtime.wallclock(), self.runtime.now());
483 }
484 Ok(())
485 }
486
487 /// Switch from having an unowned persistent state to having an owned one.
488 ///
489 /// Requires that we hold the lock on the state files.
490 #[instrument(level = "trace", skip_all)]
491 pub fn upgrade_to_owned_persistent_state(&self) -> Result<(), GuardMgrError> {
492 let mut inner = self.inner.lock().expect("Poisoned lock");
493 debug_assert!(inner.storage.can_store());
494 let new_guards = inner.storage.load()?.unwrap_or_default();
495 let wallclock = self.runtime.wallclock();
496 let now = self.runtime.now();
497 inner.replace_guards_with(new_guards, wallclock, now);
498 Ok(())
499 }
500
501 /// Return true if `netdir` has enough information to safely become our new netdir.
502 pub fn netdir_is_sufficient(&self, netdir: &NetDir) -> bool {
503 let mut inner = self.inner.lock().expect("Poisoned lock");
504 if inner.guards.active_set.universe_type() != UniverseType::NetDir {
505 // If we aren't using the netdir, this isn't something we want to look at.
506 return true;
507 }
508 inner
509 .guards
510 .active_guards_mut()
511 .n_primary_without_id_info_in(netdir)
512 == 0
513 }
514
515 /// Mark every guard as potentially retriable, regardless of how recently we
516 /// failed to connect to it.
517 pub fn mark_all_guards_retriable(&self) {
518 let mut inner = self.inner.lock().expect("Poisoned lock");
519 inner.guards.active_guards_mut().mark_all_guards_retriable();
520 }
521
522 /// Configure this guardmgr to use a fixed [`NetDir`] instead of a provider.
523 ///
524 /// This function is for testing only, and is exclusive with
525 /// `install_netdir_provider`.
526 ///
527 /// # Panics
528 ///
529 /// Panics if any [`NetDirProvider`] has already been installed.
530 #[cfg(any(test, feature = "testing"))]
531 pub fn install_test_netdir(&self, netdir: &NetDir) {
532 use tor_netdir::testprovider::TestNetDirProvider;
533 let wallclock = self.runtime.wallclock();
534 let now = self.runtime.now();
535 let netdir_provider: Arc<dyn NetDirProvider> =
536 Arc::new(TestNetDirProvider::from(netdir.clone()));
537 self.install_netdir_provider(&netdir_provider)
538 .expect("Couldn't install testing network provider");
539
540 let mut inner = self.inner.lock().expect("Poisoned lock");
541 inner.update(wallclock, now);
542 }
543
544 /// Replace the configuration in this `GuardMgr` with `config`.
545 #[instrument(level = "trace", skip_all)]
546 pub fn reconfigure(
547 &self,
548 config: &impl GuardMgrConfig,
549 ) -> Result<RetireCircuits, ReconfigureError> {
550 let mut inner = self.inner.lock().expect("Poisoned lock");
551 // Change the set of configured fallbacks.
552 {
553 let mut fallbacks: fallback::FallbackState = config.fallbacks().into();
554 std::mem::swap(&mut inner.fallbacks, &mut fallbacks);
555 inner.fallbacks.take_status_from(fallbacks);
556 }
557 // If we are built to use bridges, change the bridge configuration.
558 #[cfg(feature = "bridge-client")]
559 {
560 let wallclock = self.runtime.wallclock();
561 let now = self.runtime.now();
562 Ok(inner.replace_bridge_config(config, wallclock, now)?)
563 }
564 // If we are built to use bridges, change the bridge configuration.
565 #[cfg(not(feature = "bridge-client"))]
566 {
567 Ok(RetireCircuits::None)
568 }
569 }
570
571 /// Replace the current [`GuardFilter`] used by this `GuardMgr`.
572 // TODO should this be part of the config?
573 pub fn set_filter(&self, filter: GuardFilter) {
574 let wallclock = self.runtime.wallclock();
575 let now = self.runtime.now();
576 let mut inner = self.inner.lock().expect("Poisoned lock");
577 inner.set_filter(filter, wallclock, now);
578 }
579
580 /// Select a guard for a given [`GuardUsage`].
581 ///
582 /// On success, we return a [`FirstHop`] object to identify which
583 /// guard we have picked, a [`GuardMonitor`] object that the
584 /// caller can use to report whether its attempt to use the guard
585 /// succeeded or failed, and a [`GuardUsable`] future that the
586 /// caller can use to decide whether a circuit built through the
587 /// guard is actually safe to use.
588 ///
589 /// That last point is important: It's okay to build a circuit
590 /// through the guard returned by this function, but you can't
591 /// actually use it for traffic unless the [`GuardUsable`] future
592 /// yields "true".
593 #[instrument(skip_all, level = "trace")]
594 pub fn select_guard(
595 &self,
596 usage: GuardUsage,
597 ) -> Result<(FirstHop, GuardMonitor, GuardUsable), PickGuardError> {
598 let now = self.runtime.now();
599 let wallclock = self.runtime.wallclock();
600
601 let mut inner = self.inner.lock().expect("Poisoned lock");
602
603 // (I am not 100% sure that we need to consider_all_retries here, but
604 // it should _probably_ not hurt.)
605 inner.guards.active_guards_mut().consider_all_retries(now);
606
607 let (origin, guard) = inner.select_guard_with_expand(&usage, now, wallclock)?;
608 trace!(?guard, ?usage, "Guard selected");
609
610 let (usable, usable_sender) = if origin.usable_immediately() {
611 (GuardUsable::new_usable_immediately(), None)
612 } else {
613 let (u, snd) = GuardUsable::new_uncertain();
614 (u, Some(snd))
615 };
616 let request_id = pending::RequestId::next();
617 let ctrl = inner.ctrl.clone();
618 let monitor = GuardMonitor::new(request_id, ctrl);
619
620 // Note that the network can be down even if all the primary guards
621 // are not yet marked as unreachable. But according to guard-spec we
622 // don't want to acknowledge the net as down before that point, since
623 // we don't mark all the primary guards as retriable unless
624 // we've been forced to non-primary guards.
625 let net_has_been_down =
626 if let Some(duration) = tor_proto::time_since_last_incoming_traffic() {
627 inner
628 .guards
629 .active_guards_mut()
630 .all_primary_guards_are_unreachable()
631 && duration >= inner.params.internet_down_timeout
632 } else {
633 // TODO: Is this the correct behavior in this case?
634 false
635 };
636
637 let pending_request = pending::PendingRequest::new(
638 guard.first_hop_id(),
639 usage,
640 usable_sender,
641 net_has_been_down,
642 );
643 inner.pending.insert(request_id, pending_request);
644
645 match &guard.sample {
646 Some(sample) => {
647 let guard_id = GuardId::from_relay_ids(&guard);
648 inner
649 .guards
650 .guards_mut(sample)
651 .record_attempt(&guard_id, now);
652 }
653 None => {
654 // We don't record attempts for fallbacks; we only care when
655 // they have failed.
656 }
657 }
658
659 Ok((guard, monitor, usable))
660 }
661
662 /// Record that _after_ we built a circuit with a guard, something described
663 /// in `external_failure` went wrong with it.
664 pub fn note_external_failure<T>(&self, identity: &T, external_failure: ExternalActivity)
665 where
666 T: tor_linkspec::HasRelayIds + ?Sized,
667 {
668 let now = self.runtime.now();
669 let mut inner = self.inner.lock().expect("Poisoned lock");
670 let ids = inner.lookup_ids(identity);
671 for id in ids {
672 match &id.0 {
673 FirstHopIdInner::Guard(sample, id) => {
674 inner
675 .guards
676 .guards_mut(sample)
677 .record_failure(id, Some(external_failure), now);
678 }
679 FirstHopIdInner::Fallback(id) => {
680 if external_failure == ExternalActivity::DirCache {
681 inner.fallbacks.note_failure(id, now);
682 }
683 }
684 }
685 }
686 }
687
688 /// Record that _after_ we built a circuit with a guard, some activity
689 /// described in `external_activity` was successful with it.
690 pub fn note_external_success<T>(&self, identity: &T, external_activity: ExternalActivity)
691 where
692 T: tor_linkspec::HasRelayIds + ?Sized,
693 {
694 let mut inner = self.inner.lock().expect("Poisoned lock");
695
696 inner.record_external_success(identity, external_activity, self.runtime.wallclock());
697 }
698
699 /// Return a stream of events about our estimated clock skew; these events
700 /// are `None` when we don't have enough information to make an estimate,
701 /// and `Some(`[`SkewEstimate`]`)` otherwise.
702 ///
703 /// Note that this stream can be lossy: if the estimate changes more than
704 /// one before you read from the stream, you might only get the most recent
705 /// update.
706 pub fn skew_events(&self) -> ClockSkewEvents {
707 let inner = self.inner.lock().expect("Poisoned lock");
708 inner.recv_skew.clone()
709 }
710
711 /// Ensure that the message queue is flushed before proceeding to
712 /// the next step. Used for testing.
713 #[cfg(test)]
714 async fn flush_msg_queue(&self) {
715 let (snd, rcv) = oneshot::channel();
716 let pingmsg = daemon::Msg::Ping(snd);
717 {
718 let inner = self.inner.lock().expect("Poisoned lock");
719 inner
720 .ctrl
721 .unbounded_send(pingmsg)
722 .expect("Guard observer task exited prematurely.");
723 }
724 let _ = rcv.await;
725 }
726}
727
728/// An activity that can succeed or fail, and whose success or failure can be
729/// attributed to a guard.
730#[derive(Copy, Clone, Debug, Eq, PartialEq)]
731#[non_exhaustive]
732pub enum ExternalActivity {
733 /// The activity of using the guard as a directory cache.
734 DirCache,
735}
736
737impl GuardSets {
738 /// Return a reference to the currently active set of guards.
739 ///
740 /// (That's easy enough for now, since there is never more than one set of
741 /// guards. But eventually that will change, as we add support for more
742 /// complex filter types, and for bridge relays. Those will use separate
743 /// `GuardSet` instances, and this accessor will choose the right one.)
744 fn active_guards(&self) -> &GuardSet {
745 self.guards(&self.active_set)
746 }
747
748 /// Return the set of guards corresponding to the provided selector.
749 fn guards(&self, selector: &GuardSetSelector) -> &GuardSet {
750 match selector {
751 GuardSetSelector::Default => &self.default,
752 GuardSetSelector::Restricted => &self.restricted,
753 #[cfg(feature = "bridge-client")]
754 GuardSetSelector::Bridges => &self.bridges,
755 }
756 }
757
758 /// Return a mutable reference to the currently active set of guards.
759 fn active_guards_mut(&mut self) -> &mut GuardSet {
760 self.guards_mut(&self.active_set.clone())
761 }
762
763 /// Return a mutable reference to the set of guards corresponding to the
764 /// provided selector.
765 fn guards_mut(&mut self, selector: &GuardSetSelector) -> &mut GuardSet {
766 match selector {
767 GuardSetSelector::Default => &mut self.default,
768 GuardSetSelector::Restricted => &mut self.restricted,
769 #[cfg(feature = "bridge-client")]
770 GuardSetSelector::Bridges => &mut self.bridges,
771 }
772 }
773
774 /// Update all non-persistent state for the guards in this object with the
775 /// state in `other`.
776 fn copy_status_from(&mut self, mut other: GuardSets) {
777 use strum::IntoEnumIterator;
778 for sample in GuardSetSelector::iter() {
779 self.guards_mut(&sample)
780 .copy_ephemeral_status_into_newly_loaded_state(std::mem::take(
781 other.guards_mut(&sample),
782 ));
783 }
784 self.active_set = other.active_set;
785 }
786}
787
788impl GuardMgrInner {
789 /// Look up the latest [`NetDir`] (if there is one) from our
790 /// [`NetDirProvider`] (if we have one).
791 fn timely_netdir(&self) -> Option<Arc<NetDir>> {
792 self.netdir_provider
793 .as_ref()
794 .and_then(Weak::upgrade)
795 .and_then(|np| np.timely_netdir().ok())
796 }
797
798 /// Look up the latest [`BridgeDescList`](bridge::BridgeDescList) (if there
799 /// is one) from our [`BridgeDescProvider`](bridge::BridgeDescProvider) (if
800 /// we have one).
801 #[cfg(feature = "bridge-client")]
802 fn latest_bridge_desc_list(&self) -> Option<Arc<bridge::BridgeDescList>> {
803 self.bridge_desc_provider
804 .as_ref()
805 .and_then(Weak::upgrade)
806 .map(|bp| bp.bridges())
807 }
808
809 /// Run a function that takes `&mut self` and an optional NetDir.
810 ///
811 /// We try to use the netdir from our [`NetDirProvider`] (if we have one).
812 /// Therefore, although its _parameters_ are suitable for every
813 /// [`GuardSet`], its _contents_ might not be. For those, call
814 /// [`with_opt_universe`](Self::with_opt_universe) instead.
815 //
816 // This function exists to handle the lifetime mess where sometimes the
817 // resulting NetDir will borrow from `netdir`, and sometimes it will borrow
818 // from an Arc returned by `self.latest_netdir()`.
819 fn with_opt_netdir<F, T>(&mut self, func: F) -> T
820 where
821 F: FnOnce(&mut Self, Option<&NetDir>) -> T,
822 {
823 if let Some(nd) = self.timely_netdir() {
824 func(self, Some(nd.as_ref()))
825 } else {
826 func(self, None)
827 }
828 }
829
830 /// Return the latest `BridgeSet` based on our `BridgeDescProvider` and our
831 /// configured bridges.
832 ///
833 /// Returns `None` if we are not configured to use bridges.
834 #[cfg(feature = "bridge-client")]
835 fn latest_bridge_set(&self) -> Option<bridge::BridgeSet> {
836 let bridge_config = self.configured_bridges.as_ref()?.clone();
837 let bridge_descs = self.latest_bridge_desc_list();
838 Some(bridge::BridgeSet::new(bridge_config, bridge_descs))
839 }
840
841 /// Run a function that takes `&mut self` and an optional [`UniverseRef`].
842 ///
843 /// We try to get a universe from the appropriate source for the current
844 /// active guard set.
845 fn with_opt_universe<F, T>(&mut self, func: F) -> T
846 where
847 F: FnOnce(&mut Self, Option<&UniverseRef>) -> T,
848 {
849 // TODO: it might be nice to make `func` take an GuardSet and a set of
850 // parameters, so we can't get the active set wrong. Doing that will
851 // require a fair amount of refactoring so that the borrow checker is
852 // happy, however.
853 match self.guards.active_set.universe_type() {
854 UniverseType::NetDir => {
855 if let Some(nd) = self.timely_netdir() {
856 func(self, Some(&UniverseRef::NetDir(nd)))
857 } else {
858 func(self, None)
859 }
860 }
861 #[cfg(feature = "bridge-client")]
862 UniverseType::BridgeSet => func(
863 self,
864 self.latest_bridge_set()
865 .map(UniverseRef::BridgeSet)
866 .as_ref(),
867 ),
868 }
869 }
870
871 /// Update the status of all guards in the active set, based on the passage
872 /// of time, our configuration, and the relevant Universe for our active
873 /// set.
874 #[instrument(skip_all, level = "trace")]
875 fn update(&mut self, wallclock: SystemTime, now: Instant) {
876 self.with_opt_netdir(|this, netdir| {
877 // Here we update our parameters from the latest NetDir, and check
878 // whether we need to change to a (non)-restrictive GuardSet based
879 // on those parameters and our configured filter.
880 //
881 // This uses a NetDir unconditionally, since we always want to take
882 // the network parameters our parameters from the consensus even if
883 // the guards themselves are from a BridgeSet.
884 this.update_active_set_params_and_filter(netdir);
885 });
886 self.with_opt_universe(|this, univ| {
887 // Now we update the set of guards themselves based on the
888 // Universe, which is either the latest NetDir, or the latest
889 // BridgeSet—depending on what the GuardSet wants.
890 Self::update_guardset_internal(
891 &this.params,
892 wallclock,
893 this.guards.active_set.universe_type(),
894 this.guards.active_guards_mut(),
895 univ,
896 );
897 #[cfg(feature = "bridge-client")]
898 this.update_desired_descriptors(now);
899 #[cfg(not(feature = "bridge-client"))]
900 let _ = now;
901 });
902 }
903
904 /// Replace our bridge configuration with the one from `new_config`.
905 #[cfg(feature = "bridge-client")]
906 #[instrument(level = "trace", skip_all)]
907 fn replace_bridge_config(
908 &mut self,
909 new_config: &impl GuardMgrConfig,
910 wallclock: SystemTime,
911 now: Instant,
912 ) -> Result<RetireCircuits, GuardMgrConfigError> {
913 match (&self.configured_bridges, new_config.bridges_enabled()) {
914 (None, false) => {
915 assert_ne!(
916 self.guards.active_set.universe_type(),
917 UniverseType::BridgeSet
918 );
919 return Ok(RetireCircuits::None); // nothing to do
920 }
921 (_, true) if !self.storage.can_store() => {
922 // TODO: Ideally we would try to upgrade, obtaining an exclusive lock,
923 // but `StorageHandle` currently lacks a method for that.
924 return Err(GuardMgrConfigError::NoLock("bridges configured".into()));
925 }
926 (Some(current_bridges), true) if new_config.bridges() == current_bridges.as_ref() => {
927 assert_eq!(
928 self.guards.active_set.universe_type(),
929 UniverseType::BridgeSet
930 );
931 return Ok(RetireCircuits::None); // nothing to do.
932 }
933 (_, true) => {
934 self.configured_bridges = Some(new_config.bridges().into());
935 self.guards.active_set = GuardSetSelector::Bridges;
936 }
937 (_, false) => {
938 self.configured_bridges = None;
939 self.guards.active_set = GuardSetSelector::Default;
940 }
941 }
942
943 // If we have gotten here, we have changed the set of bridges, changed
944 // which set is active, or changed them both. We need to make sure that
945 // our `GuardSet` object is up-to-date with our configuration.
946 self.update(wallclock, now);
947
948 // We also need to tell the caller that its circuits are no good any
949 // more.
950 //
951 // TODO(nickm): Someday we can do this more judiciously by retuning
952 // "Some" in the case where we're still using bridges but our new bridge
953 // set contains different elements; see comment on RetireCircuits.
954 //
955 // TODO(nickm): We could also safely return RetireCircuits::None if we
956 // are using bridges, and our new bridge list is a superset of the older
957 // one.
958 Ok(RetireCircuits::All)
959 }
960
961 /// Update our parameters, our selection (based on network parameters and
962 /// configuration), and make sure the active GuardSet has the right
963 /// configuration itself.
964 ///
965 /// We should call this whenever the NetDir's parameters change, or whenever
966 /// our filter changes. We do not need to call it for new elements arriving
967 /// in our Universe, since those do not affect anything here.
968 ///
969 /// We should also call this whenever a new GuardSet becomes active for any
970 /// reason _other_ than just having called this function.
971 ///
972 /// (This function is only invoked from `update`, which should be called
973 /// under the above circumstances.)
974 fn update_active_set_params_and_filter(&mut self, netdir: Option<&NetDir>) {
975 // Set the parameters. These always come from the NetDir, even if this
976 // is a bridge set.
977 if let Some(netdir) = netdir {
978 match GuardParams::try_from(netdir.params()) {
979 Ok(params) => self.params = params,
980 Err(e) => warn!("Unusable guard parameters from consensus: {}", e),
981 }
982
983 self.select_guard_set_based_on_filter(netdir);
984 }
985
986 // Change the filter, if it doesn't match what the guards have.
987 //
988 // TODO(nickm): We could use a "dirty" flag or something to decide
989 // whether we need to call set_filter, if this comparison starts to show
990 // up in profiles.
991 if self.guards.active_guards().filter() != &self.filter {
992 let restrictive = self.guards.active_set == GuardSetSelector::Restricted;
993 self.guards
994 .active_guards_mut()
995 .set_filter(self.filter.clone(), restrictive);
996 }
997 }
998
999 /// Update the status of every guard in `active_guards`, and expand it as
1000 /// needed.
1001 ///
1002 /// This function doesn't take `&self`, to make sure that we are only
1003 /// affecting a single `GuardSet`, and to avoid confusing the borrow
1004 /// checker.
1005 ///
1006 /// We should call this whenever the contents of the universe have changed.
1007 ///
1008 /// We should also call this whenever a new GuardSet becomes active.
1009 fn update_guardset_internal<U: Universe>(
1010 params: &GuardParams,
1011 now: SystemTime,
1012 universe_type: UniverseType,
1013 active_guards: &mut GuardSet,
1014 universe: Option<&U>,
1015 ) -> ExtendedStatus {
1016 // Expire guards. Do that early, in case doing so makes it clear that
1017 // we need to grab more guards or mark others as primary.
1018 active_guards.expire_old_guards(params, now);
1019
1020 let extended = if let Some(universe) = universe {
1021 // TODO: This check here may be completely unnecessary. I inserted
1022 // it back in 5ac0fcb7ef603e0d14 because I was originally concerned
1023 // it might be undesirable to list a primary guard as "missing dir
1024 // info" (and therefore unusable) if we were expecting to get its
1025 // microdescriptor "very soon."
1026 //
1027 // But due to the other check in `netdir_is_sufficient`, we
1028 // shouldn't be installing a netdir until it has microdescs for all
1029 // of the (non-bridge) primary guards that it lists. - nickm
1030 let n = active_guards.n_primary_without_id_info_in(universe);
1031 if n > 0 && universe_type == UniverseType::NetDir {
1032 // We are missing the information from a NetDir needed to see
1033 // whether our primary guards are listed, so we shouldn't update
1034 // our guard status.
1035 //
1036 // We don't want to do this check if we are using bridges, since
1037 // a missing bridge descriptor is not guaranteed to temporary
1038 // problem in the same way that a missing microdescriptor is.
1039 // (When a bridge desc is missing, the bridge could be down or
1040 // unreachable, and nobody else can help us. But if a microdesc
1041 // is missing, we just need to find a cache that has it.)
1042 trace!(
1043 n_primary_without_id_info = n,
1044 "Not extending guardset, missing information."
1045 );
1046 return ExtendedStatus::No;
1047 }
1048 active_guards.update_status_from_dir(universe);
1049 active_guards.extend_sample_as_needed(now, params, universe)
1050 } else {
1051 trace!("Not extending guardset, no universe given.");
1052 ExtendedStatus::No
1053 };
1054
1055 active_guards.select_primary_guards(params);
1056
1057 extended
1058 }
1059
1060 /// If using bridges, tell the BridgeDescProvider which descriptors we want.
1061 /// We need to check this *after* we select our primary guards.
1062 #[cfg(feature = "bridge-client")]
1063 fn update_desired_descriptors(&mut self, now: Instant) {
1064 if self.guards.active_set.universe_type() != UniverseType::BridgeSet {
1065 return;
1066 }
1067
1068 let provider = self.bridge_desc_provider.as_ref().and_then(Weak::upgrade);
1069 let bridge_set = self.latest_bridge_set();
1070 if let (Some(provider), Some(bridge_set)) = (provider, bridge_set) {
1071 let desired: Vec<_> = self
1072 .guards
1073 .active_guards()
1074 .descriptors_to_request(now, &self.params)
1075 .into_iter()
1076 .flat_map(|guard| bridge_set.bridge_by_guard(guard))
1077 .cloned()
1078 .collect();
1079
1080 provider.set_bridges(&desired);
1081 }
1082 }
1083
1084 /// Replace the active guard state with `new_state`, preserving
1085 /// non-persistent state for any guards that are retained.
1086 #[instrument(level = "trace", skip_all)]
1087 fn replace_guards_with(
1088 &mut self,
1089 mut new_guards: GuardSets,
1090 wallclock: SystemTime,
1091 now: Instant,
1092 ) {
1093 std::mem::swap(&mut self.guards, &mut new_guards);
1094 self.guards.copy_status_from(new_guards);
1095 self.update(wallclock, now);
1096 }
1097
1098 /// Update which guard set is active based on the current filter and the
1099 /// provided netdir.
1100 ///
1101 /// After calling this function, the new guard set's filter may be
1102 /// out-of-date: be sure to call `set_filter` as appropriate.
1103 fn select_guard_set_based_on_filter(&mut self, netdir: &NetDir) {
1104 // In general, we'd like to use the restricted set if we're under the
1105 // threshold, and the default set if we're over the threshold. But if
1106 // we're sitting close to the threshold, we want to avoid flapping back
1107 // and forth, so we only change when we're more than 5% "off" from
1108 // whatever our current setting is.
1109 //
1110 // (See guard-spec section 2 for more information.)
1111 let offset = match self.guards.active_set {
1112 GuardSetSelector::Default => -0.05,
1113 GuardSetSelector::Restricted => 0.05,
1114 // If we're using bridges, then we don't switch between the other guard sets based on on the filter at all.
1115 #[cfg(feature = "bridge-client")]
1116 GuardSetSelector::Bridges => return,
1117 };
1118 let frac_permitted = self.filter.frac_bw_permitted(netdir);
1119 let threshold = self.params.filter_threshold + offset;
1120 let new_choice = if frac_permitted < threshold {
1121 GuardSetSelector::Restricted
1122 } else {
1123 GuardSetSelector::Default
1124 };
1125
1126 if new_choice != self.guards.active_set {
1127 info!(
1128 "Guard selection changed; we are now using the {:?} guard set",
1129 &new_choice
1130 );
1131
1132 self.guards.active_set = new_choice;
1133
1134 if frac_permitted < self.params.extreme_threshold {
1135 warn!(
1136 "The number of guards permitted is smaller than the recommended minimum of {:.0}%.",
1137 self.params.extreme_threshold * 100.0,
1138 );
1139 }
1140 }
1141 }
1142
1143 /// Mark all of our primary guards as retriable, if we haven't done
1144 /// so since long enough before `now`.
1145 ///
1146 /// We want to call this function whenever a guard attempt succeeds,
1147 /// if the internet seemed to be down when the guard attempt was
1148 /// first launched.
1149 fn maybe_retry_primary_guards(&mut self, now: Instant) {
1150 // We don't actually want to mark our primary guards as
1151 // retriable more than once per internet_down_timeout: after
1152 // the first time, we would just be noticing the same "coming
1153 // back online" event more than once.
1154 let interval = self.params.internet_down_timeout;
1155 if self.last_primary_retry_time + interval <= now {
1156 debug!(
1157 "Successfully reached a guard after a while off the internet; marking all primary guards retriable."
1158 );
1159 self.guards
1160 .active_guards_mut()
1161 .mark_primary_guards_retriable();
1162 self.last_primary_retry_time = now;
1163 }
1164 }
1165
1166 /// Replace the current GuardFilter with `filter`.
1167 #[instrument(level = "trace", skip_all)]
1168 fn set_filter(&mut self, filter: GuardFilter, wallclock: SystemTime, now: Instant) {
1169 self.filter = filter;
1170 self.update(wallclock, now);
1171 }
1172
1173 /// Called when the circuit manager reports (via [`GuardMonitor`]) that
1174 /// a guard succeeded or failed.
1175 ///
1176 /// Changes the guard's status as appropriate, and updates the pending
1177 /// request as needed.
1178 #[allow(clippy::cognitive_complexity)]
1179 pub(crate) fn handle_msg(
1180 &mut self,
1181 request_id: RequestId,
1182 status: GuardStatus,
1183 skew: Option<ClockSkew>,
1184 runtime: &impl tor_rtcompat::SleepProvider,
1185 ) {
1186 if let Some(mut pending) = self.pending.remove(&request_id) {
1187 // If there was a pending request matching this RequestId, great!
1188 let guard_id = pending.guard_id();
1189 trace!(?guard_id, ?status, "Received report of guard status");
1190
1191 // First, handle the skew report (if any)
1192 if let Some(skew) = skew {
1193 let now = runtime.now();
1194 let observation = skew::SkewObservation { skew, when: now };
1195
1196 match &guard_id.0 {
1197 FirstHopIdInner::Guard(_, id) => {
1198 self.guards.active_guards_mut().record_skew(id, observation);
1199 }
1200 FirstHopIdInner::Fallback(id) => {
1201 self.fallbacks.note_skew(id, observation);
1202 }
1203 }
1204 // TODO: We call this whenever we receive an observed clock
1205 // skew. That's not the perfect timing for two reasons. First
1206 // off, it might be too frequent: it does an O(n) calculation,
1207 // which isn't ideal. Second, it might be too infrequent: after
1208 // an hour has passed, a given observation won't be up-to-date
1209 // any more, and we might want to recalculate the skew
1210 // accordingly.
1211 self.update_skew(now);
1212 }
1213
1214 match (status, &guard_id.0) {
1215 (GuardStatus::Failure, FirstHopIdInner::Fallback(id)) => {
1216 // We used a fallback, and we weren't able to build a circuit through it.
1217 self.fallbacks.note_failure(id, runtime.now());
1218 }
1219 (_, FirstHopIdInner::Fallback(_)) => {
1220 // We don't record any other kind of circuit activity if we
1221 // took the entry from the fallback list.
1222 }
1223 (GuardStatus::Success, FirstHopIdInner::Guard(sample, id)) => {
1224 // If we had gone too long without any net activity when we
1225 // gave out this guard, and now we're seeing a circuit
1226 // succeed, tell the primary guards that they might be
1227 // retriable.
1228 if pending.net_has_been_down() {
1229 self.maybe_retry_primary_guards(runtime.now());
1230 }
1231
1232 // The guard succeeded. Tell the GuardSet.
1233 self.guards.guards_mut(sample).record_success(
1234 id,
1235 &self.params,
1236 None,
1237 runtime.wallclock(),
1238 );
1239 // Either tell the request whether the guard is
1240 // usable, or schedule it as a "waiting" request.
1241 if let Some(usable) = self.guard_usability_status(&pending, runtime.now()) {
1242 trace!(?guard_id, usable, "Known usability status");
1243 pending.reply(usable);
1244 } else {
1245 // This is the one case where we can't use the
1246 // guard yet.
1247 trace!(?guard_id, "Not able to answer right now");
1248 pending.mark_waiting(runtime.now());
1249 self.waiting.push(pending);
1250 }
1251 }
1252 (GuardStatus::Failure, FirstHopIdInner::Guard(sample, id)) => {
1253 self.guards
1254 .guards_mut(sample)
1255 .record_failure(id, None, runtime.now());
1256 pending.reply(false);
1257 }
1258 (GuardStatus::AttemptAbandoned, FirstHopIdInner::Guard(sample, id)) => {
1259 self.guards.guards_mut(sample).record_attempt_abandoned(id);
1260 pending.reply(false);
1261 }
1262 (GuardStatus::Indeterminate, FirstHopIdInner::Guard(sample, id)) => {
1263 self.guards
1264 .guards_mut(sample)
1265 .record_indeterminate_result(id);
1266 pending.reply(false);
1267 }
1268 };
1269 } else {
1270 warn!(
1271 "Got a status {:?} for a request {:?} that wasn't pending",
1272 status, request_id
1273 );
1274 }
1275
1276 // We might need to update the primary guards based on changes in the
1277 // status of guards above.
1278 self.guards
1279 .active_guards_mut()
1280 .select_primary_guards(&self.params);
1281
1282 // Some waiting request may just have become ready (usable or
1283 // not); we need to give them the information they're waiting
1284 // for.
1285 self.expire_and_answer_pending_requests(runtime.now());
1286 }
1287
1288 /// Helper to implement `GuardMgr::note_external_success()`.
1289 ///
1290 /// (This has to be a separate function so that we can borrow params while
1291 /// we have `mut self` borrowed.)
1292 fn record_external_success<T>(
1293 &mut self,
1294 identity: &T,
1295 external_activity: ExternalActivity,
1296 now: SystemTime,
1297 ) where
1298 T: tor_linkspec::HasRelayIds + ?Sized,
1299 {
1300 for id in self.lookup_ids(identity) {
1301 match &id.0 {
1302 FirstHopIdInner::Guard(sample, id) => {
1303 self.guards.guards_mut(sample).record_success(
1304 id,
1305 &self.params,
1306 Some(external_activity),
1307 now,
1308 );
1309 }
1310 FirstHopIdInner::Fallback(id) => {
1311 if external_activity == ExternalActivity::DirCache {
1312 self.fallbacks.note_success(id);
1313 }
1314 }
1315 }
1316 }
1317 }
1318
1319 /// Return an iterator over all of the clock skew observations we've made
1320 /// for guards or fallbacks.
1321 fn skew_observations(&self) -> impl Iterator<Item = &skew::SkewObservation> {
1322 self.fallbacks
1323 .skew_observations()
1324 .chain(self.guards.active_guards().skew_observations())
1325 }
1326
1327 /// Recalculate our estimated clock skew, and publish it to anybody who
1328 /// cares.
1329 fn update_skew(&mut self, now: Instant) {
1330 let estimate = skew::SkewEstimate::estimate_skew(self.skew_observations(), now);
1331 // TODO: we might want to do this only conditionally, when the skew
1332 // estimate changes.
1333 *self.send_skew.borrow_mut() = estimate;
1334 }
1335
1336 /// If the circuit built because of a given [`PendingRequest`] may
1337 /// now be used (or discarded), return `Some(true)` or
1338 /// `Some(false)` respectively.
1339 ///
1340 /// Return None if we can't yet give an answer about whether such
1341 /// a circuit is usable.
1342 fn guard_usability_status(&self, pending: &PendingRequest, now: Instant) -> Option<bool> {
1343 match &pending.guard_id().0 {
1344 FirstHopIdInner::Guard(sample, id) => self.guards.guards(sample).circ_usability_status(
1345 id,
1346 pending.usage(),
1347 &self.params,
1348 now,
1349 ),
1350 // Fallback circuits are usable immediately, since we don't have to wait to
1351 // see whether any _other_ circuit succeeds or fails.
1352 FirstHopIdInner::Fallback(_) => Some(true),
1353 }
1354 }
1355
1356 /// For requests that have been "waiting" for an answer for too long,
1357 /// expire them and tell the circuit manager that their circuits
1358 /// are unusable.
1359 fn expire_and_answer_pending_requests(&mut self, now: Instant) {
1360 // A bit ugly: we use a separate Vec here to avoid borrowing issues,
1361 // and put it back when we're done.
1362 let mut waiting = Vec::new();
1363 std::mem::swap(&mut waiting, &mut self.waiting);
1364
1365 waiting.retain_mut(|pending| {
1366 let expired = pending
1367 .waiting_since()
1368 .and_then(|w| now.checked_duration_since(w))
1369 .map(|d| d >= self.params.np_idle_timeout)
1370 == Some(true);
1371 if expired {
1372 trace!(?pending, "Pending request expired");
1373 pending.reply(false);
1374 return false;
1375 }
1376
1377 // TODO-SPEC: guard_usability_status isn't what the spec says. It
1378 // says instead that we should look at _circuit_ status, saying:
1379 // " Definition: In the algorithm above, C2 "blocks" C1 if:
1380 // * C2 obeys all the restrictions that C1 had to obey, AND
1381 // * C2 has higher priority than C1, AND
1382 // * Either C2 is <complete>, or C2 is <waiting_for_better_guard>,
1383 // or C2 has been <usable_if_no_better_guard> for no more than
1384 // {NONPRIMARY_GUARD_CONNECT_TIMEOUT} seconds."
1385 //
1386 // See comments in sample::GuardSet::circ_usability_status.
1387
1388 if let Some(answer) = self.guard_usability_status(pending, now) {
1389 trace!(?pending, answer, "Pending request now ready");
1390 pending.reply(answer);
1391 return false;
1392 }
1393 true
1394 });
1395
1396 // Put the waiting list back.
1397 std::mem::swap(&mut waiting, &mut self.waiting);
1398 }
1399
1400 /// Return every currently extant FirstHopId for a guard or fallback
1401 /// directory matching (or possibly matching) the provided keys.
1402 ///
1403 /// An identity is _possibly matching_ if it contains some of the IDs in the
1404 /// provided identity, and it has no _contradictory_ identities, but it does
1405 /// not necessarily contain _all_ of those identities.
1406 ///
1407 /// # TODO
1408 ///
1409 /// This function should probably not exist; it's only used so that dirmgr
1410 /// can report successes or failures, since by the time it observes them it
1411 /// doesn't know whether its circuit came from a guard or a fallback. To
1412 /// solve that, we'll need CircMgr to record and report which one it was
1413 /// using, which will take some more plumbing.
1414 ///
1415 /// TODO relay: we will have to make the change above when we implement
1416 /// relays; otherwise, it would be possible for an attacker to exploit it to
1417 /// mislead us about our guard status.
1418 fn lookup_ids<T>(&self, identity: &T) -> Vec<FirstHopId>
1419 where
1420 T: tor_linkspec::HasRelayIds + ?Sized,
1421 {
1422 use strum::IntoEnumIterator;
1423 let mut vec = Vec::with_capacity(2);
1424
1425 let id = ids::GuardId::from_relay_ids(identity);
1426 for sample in GuardSetSelector::iter() {
1427 let guard_id = match self.guards.guards(&sample).contains(&id) {
1428 Ok(true) => &id,
1429 Err(other) => other,
1430 Ok(false) => continue,
1431 };
1432 vec.push(FirstHopId(FirstHopIdInner::Guard(sample, guard_id.clone())));
1433 }
1434
1435 let id = ids::FallbackId::from_relay_ids(identity);
1436 if self.fallbacks.contains(&id) {
1437 vec.push(id.into());
1438 }
1439
1440 vec
1441 }
1442
1443 /// Run any periodic events that update guard status, and return a
1444 /// duration after which periodic events should next be run.
1445 #[instrument(skip_all, level = "trace")]
1446 pub(crate) fn run_periodic_events(&mut self, wallclock: SystemTime, now: Instant) -> Duration {
1447 self.update(wallclock, now);
1448 self.expire_and_answer_pending_requests(now);
1449 Duration::from_secs(1) // TODO: Too aggressive.
1450 }
1451
1452 /// Try to select a guard, expanding the sample if the first attempt fails.
1453 #[instrument(skip_all, level = "trace")]
1454 fn select_guard_with_expand(
1455 &mut self,
1456 usage: &GuardUsage,
1457 now: Instant,
1458 wallclock: SystemTime,
1459 ) -> Result<(sample::ListKind, FirstHop), PickGuardError> {
1460 // Try to find a guard.
1461 let first_error = match self.select_guard_once(usage, now) {
1462 Ok(res1) => return Ok(res1),
1463 Err(e) => {
1464 trace!("Couldn't select guard on first attempt: {}", e);
1465 e
1466 }
1467 };
1468
1469 // That didn't work. If we have a netdir, expand the sample and try again.
1470 let res = self.with_opt_universe(|this, univ| {
1471 let univ = univ?;
1472 trace!("No guards available, trying to extend the sample.");
1473 // Make sure that the status on all of our guards are accurate, and
1474 // expand the sample if we can.
1475 //
1476 // Our parameters and configuration did not change, so we do not
1477 // need to call update() or update_active_set_and_filter(). This
1478 // call is sufficient to extend the sample and recompute primary
1479 // guards.
1480 let extended = Self::update_guardset_internal(
1481 &this.params,
1482 wallclock,
1483 this.guards.active_set.universe_type(),
1484 this.guards.active_guards_mut(),
1485 Some(univ),
1486 );
1487 if extended == ExtendedStatus::Yes {
1488 match this.select_guard_once(usage, now) {
1489 Ok(res) => return Some(res),
1490 Err(e) => {
1491 trace!("Couldn't select guard after update: {}", e);
1492 }
1493 }
1494 }
1495 None
1496 });
1497 if let Some(res) = res {
1498 return Ok(res);
1499 }
1500
1501 // Okay, that didn't work either. If we were asked for a directory
1502 // guard, and we aren't using bridges, then we may be able to use a
1503 // fallback.
1504 if usage.kind == GuardUsageKind::OneHopDirectory
1505 && self.guards.active_set.universe_type() == UniverseType::NetDir
1506 {
1507 return self.select_fallback(now);
1508 }
1509
1510 // Couldn't extend the sample or use a fallback; return the original error.
1511 Err(first_error)
1512 }
1513
1514 /// Helper: try to pick a single guard, without retrying on failure.
1515 fn select_guard_once(
1516 &self,
1517 usage: &GuardUsage,
1518 now: Instant,
1519 ) -> Result<(sample::ListKind, FirstHop), PickGuardError> {
1520 let active_set = &self.guards.active_set;
1521 #[cfg_attr(not(feature = "bridge-client"), allow(unused_mut))]
1522 let (list_kind, mut first_hop) =
1523 self.guards
1524 .guards(active_set)
1525 .pick_guard(active_set, usage, &self.params, now)?;
1526 #[cfg(feature = "bridge-client")]
1527 if self.guards.active_set.universe_type() == UniverseType::BridgeSet {
1528 // See if we can promote first_hop to a viable CircTarget.
1529 let bridges = self.latest_bridge_set().ok_or_else(|| {
1530 PickGuardError::Internal(internal!(
1531 "No bridge set available, even though this is the Bridges sample"
1532 ))
1533 })?;
1534 first_hop.lookup_bridge_circ_target(&bridges);
1535
1536 if usage.kind == GuardUsageKind::Data && !first_hop.contains_circ_target() {
1537 return Err(PickGuardError::Internal(internal!(
1538 "Tried to return a non-circtarget guard with Data usage!"
1539 )));
1540 }
1541 }
1542 Ok((list_kind, first_hop))
1543 }
1544
1545 /// Helper: Select a fallback directory.
1546 ///
1547 /// Called when we have no guard information to use. Return values are as
1548 /// for [`GuardMgr::select_guard()`]
1549 fn select_fallback(
1550 &self,
1551 now: Instant,
1552 ) -> Result<(sample::ListKind, FirstHop), PickGuardError> {
1553 let filt = self.guards.active_guards().filter();
1554
1555 let fallback = crate::FirstHop {
1556 sample: None,
1557 inner: crate::FirstHopInner::Chan(OwnedChanTarget::from_chan_target(
1558 self.fallbacks.choose(&mut rand::rng(), now, filt)?,
1559 )),
1560 };
1561 let fallback = filt.modify_hop(fallback)?;
1562 Ok((sample::ListKind::Fallback, fallback))
1563 }
1564}
1565
1566/// A possible outcome of trying to extend a guard sample.
1567#[derive(Copy, Clone, Debug, Eq, PartialEq)]
1568enum ExtendedStatus {
1569 /// The guard sample was extended. (At least one guard was added to it.)
1570 Yes,
1571 /// The guard sample was not extended.
1572 No,
1573}
1574
1575/// A set of parameters, derived from the consensus document, controlling
1576/// the behavior of a guard manager.
1577#[derive(Debug, Clone)]
1578#[cfg_attr(test, derive(PartialEq))]
1579struct GuardParams {
1580 /// How long should a sampled, un-confirmed guard be kept in the sample before it expires?
1581 lifetime_unconfirmed: Duration,
1582 /// How long should a confirmed guard be kept in the sample before
1583 /// it expires?
1584 lifetime_confirmed: Duration,
1585 /// How long may a guard be unlisted before we remove it from the sample?
1586 lifetime_unlisted: Duration,
1587 /// Largest number of guards we're willing to add to the sample.
1588 max_sample_size: usize,
1589 /// Largest fraction of the network's guard bandwidth that we're
1590 /// willing to add to the sample.
1591 max_sample_bw_fraction: f64,
1592 /// Smallest number of guards that we're willing to have in the
1593 /// sample, after applying a [`GuardFilter`].
1594 min_filtered_sample_size: usize,
1595 /// How many guards are considered "Primary"?
1596 n_primary: usize,
1597 /// When making a regular circuit, how many primary guards should we
1598 /// be willing to try?
1599 data_parallelism: usize,
1600 /// When making a one-hop directory circuit, how many primary
1601 /// guards should we be willing to try?
1602 dir_parallelism: usize,
1603 /// For how long does a pending attempt to connect to a guard
1604 /// block an attempt to use a less-favored non-primary guard?
1605 np_connect_timeout: Duration,
1606 /// How long do we allow a circuit to a successful but unfavored
1607 /// non-primary guard to sit around before deciding not to use it?
1608 np_idle_timeout: Duration,
1609 /// After how much time without successful activity does a
1610 /// successful circuit indicate that we should retry our primary
1611 /// guards?
1612 internet_down_timeout: Duration,
1613 /// What fraction of the guards can be can be filtered out before we
1614 /// decide that our filter is "very restrictive"?
1615 filter_threshold: f64,
1616 /// What fraction of the guards determine that our filter is "very
1617 /// restrictive"?
1618 extreme_threshold: f64,
1619}
1620
1621impl Default for GuardParams {
1622 fn default() -> Self {
1623 let one_day = Duration::from_secs(86400);
1624 GuardParams {
1625 lifetime_unconfirmed: one_day * 120,
1626 lifetime_confirmed: one_day * 60,
1627 lifetime_unlisted: one_day * 20,
1628 max_sample_size: 60,
1629 max_sample_bw_fraction: 0.2,
1630 min_filtered_sample_size: 20,
1631 n_primary: 3,
1632 data_parallelism: 1,
1633 dir_parallelism: 3,
1634 np_connect_timeout: Duration::from_secs(15),
1635 np_idle_timeout: Duration::from_secs(600),
1636 internet_down_timeout: Duration::from_secs(600),
1637 filter_threshold: 0.2,
1638 extreme_threshold: 0.01,
1639 }
1640 }
1641}
1642
1643impl TryFrom<&NetParameters> for GuardParams {
1644 type Error = tor_units::Error;
1645 fn try_from(p: &NetParameters) -> Result<GuardParams, Self::Error> {
1646 Ok(GuardParams {
1647 lifetime_unconfirmed: p.guard_lifetime_unconfirmed.try_into()?,
1648 lifetime_confirmed: p.guard_lifetime_confirmed.try_into()?,
1649 lifetime_unlisted: p.guard_remove_unlisted_after.try_into()?,
1650 max_sample_size: p.guard_max_sample_size.try_into()?,
1651 max_sample_bw_fraction: p.guard_max_sample_threshold.as_fraction(),
1652 min_filtered_sample_size: p.guard_filtered_min_sample_size.try_into()?,
1653 n_primary: p.guard_n_primary.try_into()?,
1654 data_parallelism: p.guard_use_parallelism.try_into()?,
1655 dir_parallelism: p.guard_dir_use_parallelism.try_into()?,
1656 np_connect_timeout: p.guard_nonprimary_connect_timeout.try_into()?,
1657 np_idle_timeout: p.guard_nonprimary_idle_timeout.try_into()?,
1658 internet_down_timeout: p.guard_internet_likely_down.try_into()?,
1659 filter_threshold: p.guard_meaningful_restriction.as_fraction(),
1660 extreme_threshold: p.guard_extreme_restriction.as_fraction(),
1661 })
1662 }
1663}
1664
1665/// Representation of a guard or fallback, as returned by [`GuardMgr::select_guard()`].
1666#[derive(Debug, Clone)]
1667pub struct FirstHop {
1668 /// The sample from which this guard was taken, or `None` if this is a fallback.
1669 sample: Option<GuardSetSelector>,
1670 /// Information about connecting to (or through) this guard.
1671 inner: FirstHopInner,
1672}
1673/// The enumeration inside a FirstHop that holds information about how to
1674/// connect to (and possibly through) a guard or fallback.
1675#[derive(Debug, Clone)]
1676enum FirstHopInner {
1677 /// We have enough information to connect to a guard.
1678 Chan(OwnedChanTarget),
1679 /// We have enough information to connect to a guards _and_ to build
1680 /// multihop circuits through it.
1681 #[cfg_attr(not(feature = "bridge-client"), allow(dead_code))]
1682 Circ(OwnedCircTarget),
1683}
1684
1685impl FirstHop {
1686 /// Return a new [`FirstHopId`] for this `FirstHop`.
1687 fn first_hop_id(&self) -> FirstHopId {
1688 match &self.sample {
1689 Some(sample) => {
1690 let guard_id = GuardId::from_relay_ids(self);
1691 FirstHopId::in_sample(sample.clone(), guard_id)
1692 }
1693 None => {
1694 let fallback_id = crate::ids::FallbackId::from_relay_ids(self);
1695 FirstHopId::from(fallback_id)
1696 }
1697 }
1698 }
1699
1700 /// Look up this guard in `netdir`.
1701 pub fn get_relay<'a>(&self, netdir: &'a NetDir) -> Option<Relay<'a>> {
1702 match &self.sample {
1703 #[cfg(feature = "bridge-client")]
1704 // Always return "None" for anything that isn't in the netdir.
1705 Some(s) if s.universe_type() == UniverseType::BridgeSet => None,
1706 // Otherwise ask the netdir.
1707 _ => netdir.by_ids(self),
1708 }
1709 }
1710
1711 /// Return true if this guard is a bridge.
1712 pub fn is_bridge(&self) -> bool {
1713 match &self.sample {
1714 #[cfg(feature = "bridge-client")]
1715 Some(s) if s.universe_type() == UniverseType::BridgeSet => true,
1716 _ => false,
1717 }
1718 }
1719
1720 /// If possible, return a view of this object that can be used to build a circuit.
1721 pub fn as_circ_target(&self) -> Option<&OwnedCircTarget> {
1722 match &self.inner {
1723 FirstHopInner::Chan(_) => None,
1724 FirstHopInner::Circ(ct) => Some(ct),
1725 }
1726 }
1727
1728 /// Return a view of this as an OwnedChanTarget.
1729 fn chan_target_mut(&mut self) -> &mut OwnedChanTarget {
1730 match &mut self.inner {
1731 FirstHopInner::Chan(ct) => ct,
1732 FirstHopInner::Circ(ct) => ct.chan_target_mut(),
1733 }
1734 }
1735
1736 /// If possible and appropriate, find a circuit target in `bridges` for this
1737 /// `FirstHop`, and make this `FirstHop` a viable circuit target.
1738 ///
1739 /// (By default, any `FirstHop` that a `GuardSet` returns will have enough
1740 /// information to be a `ChanTarget`, but it will be lacking the additional
1741 /// network information in `CircTarget`[^1] necessary for us to build a
1742 /// multi-hop circuit through it. If this FirstHop is a regular non-bridge
1743 /// `Relay`, then the `CircMgr` will later look up that circuit information
1744 /// itself from the network directory. But if this `FirstHop` *is* a bridge,
1745 /// then we need to find that information in the `BridgeSet`, since the
1746 /// CircMgr does not keep track of the `BridgeSet`.)
1747 ///
1748 /// [^1]: For example, supported protocol versions and ntor keys.
1749 #[cfg(feature = "bridge-client")]
1750 fn lookup_bridge_circ_target(&mut self, bridges: &bridge::BridgeSet) {
1751 use crate::sample::CandidateStatus::Present;
1752 if self.sample.as_ref().map(|s| s.universe_type()) == Some(UniverseType::BridgeSet)
1753 && matches!(self.inner, FirstHopInner::Chan(_))
1754 {
1755 if let Present(bridge_relay) = bridges.bridge_relay_by_guard(self) {
1756 if let Some(circ_target) = bridge_relay.as_relay_with_desc() {
1757 self.inner =
1758 FirstHopInner::Circ(OwnedCircTarget::from_circ_target(&circ_target));
1759 }
1760 }
1761 }
1762 }
1763
1764 /// Return true if this `FirstHop` contains circuit target information.
1765 ///
1766 /// This is true if `lookup_bridge_circ_target()` has been called, and it
1767 /// successfully found the circuit target information.
1768 #[cfg(feature = "bridge-client")]
1769 fn contains_circ_target(&self) -> bool {
1770 matches!(self.inner, FirstHopInner::Circ(_))
1771 }
1772}
1773
1774// This is somewhat redundant with the implementations in crate::guard::Guard.
1775impl tor_linkspec::HasAddrs for FirstHop {
1776 fn addrs(&self) -> impl Iterator<Item = SocketAddr> {
1777 match &self.inner {
1778 FirstHopInner::Chan(ct) => Either::Left(ct.addrs()),
1779 FirstHopInner::Circ(ct) => Either::Right(ct.addrs()),
1780 }
1781 }
1782}
1783impl tor_linkspec::HasRelayIds for FirstHop {
1784 fn identity(
1785 &self,
1786 key_type: tor_linkspec::RelayIdType,
1787 ) -> Option<tor_linkspec::RelayIdRef<'_>> {
1788 match &self.inner {
1789 FirstHopInner::Chan(ct) => ct.identity(key_type),
1790 FirstHopInner::Circ(ct) => ct.identity(key_type),
1791 }
1792 }
1793}
1794impl tor_linkspec::HasChanMethod for FirstHop {
1795 fn chan_method(&self) -> tor_linkspec::ChannelMethod {
1796 match &self.inner {
1797 FirstHopInner::Chan(ct) => ct.chan_method(),
1798 FirstHopInner::Circ(ct) => ct.chan_method(),
1799 }
1800 }
1801}
1802impl tor_linkspec::ChanTarget for FirstHop {}
1803
1804/// The purpose for which we plan to use a guard.
1805///
1806/// This can affect the guard selection algorithm.
1807#[derive(Clone, Debug, Default, Eq, PartialEq)]
1808#[non_exhaustive]
1809pub enum GuardUsageKind {
1810 /// We want to use this guard for a data circuit.
1811 ///
1812 /// (This encompasses everything except the `OneHopDirectory` case.)
1813 #[default]
1814 Data,
1815 /// We want to use this guard for a one-hop, non-anonymous
1816 /// directory request.
1817 ///
1818 /// (Our algorithm allows more parallelism for the guards that we use
1819 /// for these circuits.)
1820 OneHopDirectory,
1821}
1822
1823/// A set of parameters describing how a single guard should be selected.
1824///
1825/// Used as an argument to [`GuardMgr::select_guard`].
1826#[derive(Clone, Debug, derive_builder::Builder)]
1827#[builder(build_fn(error = "tor_config::ConfigBuildError"))]
1828pub struct GuardUsage {
1829 /// The purpose for which this guard will be used.
1830 #[builder(default)]
1831 kind: GuardUsageKind,
1832 /// A list of restrictions on which guard may be used.
1833 ///
1834 /// The default is the empty list.
1835 #[builder(sub_builder, setter(custom))]
1836 restrictions: GuardRestrictionList,
1837}
1838
1839impl_standard_builder! { GuardUsage: !Deserialize }
1840
1841/// List of socket restrictions, as configured
1842pub type GuardRestrictionList = Vec<GuardRestriction>;
1843
1844define_list_builder_helper! {
1845 pub struct GuardRestrictionListBuilder {
1846 restrictions: [GuardRestriction],
1847 }
1848 built: GuardRestrictionList = restrictions;
1849 default = vec![];
1850 item_build: |restriction| Ok(restriction.clone());
1851}
1852
1853define_list_builder_accessors! {
1854 struct GuardUsageBuilder {
1855 pub restrictions: [GuardRestriction],
1856 }
1857}
1858
1859impl GuardUsageBuilder {
1860 /// Create a new empty [`GuardUsageBuilder`].
1861 pub fn new() -> Self {
1862 Self::default()
1863 }
1864}
1865
1866/// A restriction that applies to a single request for a guard.
1867///
1868/// Restrictions differ from filters (see [`GuardFilter`]) in that
1869/// they apply to single requests, not to our entire set of guards.
1870/// They're suitable for things like making sure that we don't start
1871/// and end a circuit at the same relay, or requiring a specific
1872/// subprotocol version for certain kinds of requests.
1873#[derive(Clone, Debug, Serialize, Deserialize)]
1874#[non_exhaustive]
1875pub enum GuardRestriction {
1876 /// Don't pick a guard with the provided identity.
1877 AvoidId(RelayId),
1878 /// Don't pick a guard with any of the provided Ed25519 identities.
1879 AvoidAllIds(RelayIdSet),
1880}
1881
1882/// The kind of vanguards to use.
1883#[derive(Debug, Default, Clone, Copy, Eq, PartialEq, Ord, PartialOrd)] //
1884#[derive(Serialize, Deserialize)] //
1885#[derive(derive_more::Display)] //
1886#[serde(rename_all = "lowercase")]
1887#[cfg(feature = "vanguards")]
1888#[non_exhaustive]
1889pub enum VanguardMode {
1890 /// "Lite" vanguards.
1891 #[default]
1892 #[display("lite")]
1893 Lite = 1,
1894 /// "Full" vanguards.
1895 #[display("full")]
1896 Full = 2,
1897 /// Vanguards are disabled.
1898 #[display("disabled")]
1899 Disabled = 0,
1900}
1901
1902#[cfg(feature = "vanguards")]
1903impl VanguardMode {
1904 /// Build a `VanguardMode` from a [`NetParameters`] parameter.
1905 ///
1906 /// Used for converting [`vanguards_enabled`](NetParameters::vanguards_enabled)
1907 /// or [`vanguards_hs_service`](NetParameters::vanguards_hs_service)
1908 /// to the corresponding `VanguardMode`.
1909 pub(crate) fn from_net_parameter(val: BoundedInt32<0, 2>) -> Self {
1910 match val.get() {
1911 0 => VanguardMode::Disabled,
1912 1 => VanguardMode::Lite,
1913 2 => VanguardMode::Full,
1914 _ => unreachable!("BoundedInt32 was not bounded?!"),
1915 }
1916 }
1917}
1918
1919impl_not_auto_value!(VanguardMode);
1920
1921/// Vanguards configuration.
1922#[derive(Debug, Default, Clone, Eq, PartialEq, derive_builder::Builder)]
1923#[builder(build_fn(error = "ConfigBuildError"))]
1924#[builder(derive(Debug, Serialize, Deserialize))]
1925pub struct VanguardConfig {
1926 /// The kind of vanguards to use.
1927 #[builder_field_attr(serde(default))]
1928 #[builder(default)]
1929 mode: ExplicitOrAuto<VanguardMode>,
1930}
1931
1932impl VanguardConfig {
1933 /// Return the configured [`VanguardMode`].
1934 ///
1935 /// Returns the [`Default`] `VanguardMode`
1936 /// if the mode is [`Auto`](ExplicitOrAuto) or unspecified.
1937 pub fn mode(&self) -> VanguardMode {
1938 match self.mode {
1939 ExplicitOrAuto::Auto => Default::default(),
1940 ExplicitOrAuto::Explicit(mode) => mode,
1941 }
1942 }
1943}
1944
1945/// The kind of vanguards to use.
1946#[derive(Debug, Default, Clone, Copy, Eq, PartialEq, Ord, PartialOrd)] //
1947#[derive(Serialize, Deserialize)] //
1948#[derive(derive_more::Display)] //
1949#[serde(rename_all = "lowercase")]
1950#[cfg(not(feature = "vanguards"))]
1951#[non_exhaustive]
1952pub enum VanguardMode {
1953 /// Vanguards are disabled.
1954 #[default]
1955 #[display("disabled")]
1956 Disabled = 0,
1957}
1958
1959#[cfg(test)]
1960mod test {
1961 // @@ begin test lint list maintained by maint/add_warning @@
1962 #![allow(clippy::bool_assert_comparison)]
1963 #![allow(clippy::clone_on_copy)]
1964 #![allow(clippy::dbg_macro)]
1965 #![allow(clippy::mixed_attributes_style)]
1966 #![allow(clippy::print_stderr)]
1967 #![allow(clippy::print_stdout)]
1968 #![allow(clippy::single_char_pattern)]
1969 #![allow(clippy::unwrap_used)]
1970 #![allow(clippy::unchecked_time_subtraction)]
1971 #![allow(clippy::useless_vec)]
1972 #![allow(clippy::needless_pass_by_value)]
1973 //! <!-- @@ end test lint list maintained by maint/add_warning @@ -->
1974 use super::*;
1975 use tor_linkspec::{HasAddrs, HasRelayIds};
1976 use tor_persist::TestingStateMgr;
1977 use tor_rtcompat::test_with_all_runtimes;
1978
1979 #[test]
1980 fn guard_param_defaults() {
1981 let p1 = GuardParams::default();
1982 let p2: GuardParams = (&NetParameters::default()).try_into().unwrap();
1983 assert_eq!(p1, p2);
1984 }
1985
1986 fn init<R: Runtime>(rt: R) -> (GuardMgr<R>, TestingStateMgr, NetDir) {
1987 use tor_netdir::{MdReceiver, PartialNetDir, testnet};
1988 let statemgr = TestingStateMgr::new();
1989 let have_lock = statemgr.try_lock().unwrap();
1990 assert!(have_lock.held());
1991 let guardmgr = GuardMgr::new(rt, statemgr.clone(), &TestConfig::default()).unwrap();
1992 let (con, mds) = testnet::construct_network().unwrap();
1993 let param_overrides = vec![
1994 // We make the sample size smaller than usual to compensate for the
1995 // small testing network. (Otherwise, we'd sample the whole network,
1996 // and not be able to observe guards in the tests.)
1997 "guard-min-filtered-sample-size=5",
1998 // We choose only two primary guards, to make the tests easier to write.
1999 "guard-n-primary-guards=2",
2000 // We define any restriction that allows 75% or fewer of relays as "meaningful",
2001 // so that we can test the "restrictive" guard sample behavior, and to avoid
2002 "guard-meaningful-restriction-percent=75",
2003 ];
2004 let param_overrides: String =
2005 itertools::Itertools::intersperse(param_overrides.into_iter(), " ").collect();
2006 let override_p = param_overrides.parse().unwrap();
2007 let mut netdir = PartialNetDir::new(con, Some(&override_p));
2008 for md in mds {
2009 netdir.add_microdesc(md);
2010 }
2011 let netdir = netdir.unwrap_if_sufficient().unwrap();
2012
2013 (guardmgr, statemgr, netdir)
2014 }
2015
2016 #[test]
2017 #[allow(clippy::clone_on_copy)]
2018 fn simple_case() {
2019 test_with_all_runtimes!(|rt| async move {
2020 let (guardmgr, statemgr, netdir) = init(rt.clone());
2021 let usage = GuardUsage::default();
2022 guardmgr.install_test_netdir(&netdir);
2023
2024 let (id, mon, usable) = guardmgr.select_guard(usage).unwrap();
2025 // Report that the circuit succeeded.
2026 mon.succeeded();
2027
2028 // May we use the circuit?
2029 let usable = usable.await.unwrap();
2030 assert!(usable);
2031
2032 // Save the state...
2033 guardmgr.flush_msg_queue().await;
2034 guardmgr.store_persistent_state().unwrap();
2035 drop(guardmgr);
2036
2037 // Try reloading from the state...
2038 let guardmgr2 =
2039 GuardMgr::new(rt.clone(), statemgr.clone(), &TestConfig::default()).unwrap();
2040 guardmgr2.install_test_netdir(&netdir);
2041
2042 // Since the guard was confirmed, we should get the same one this time!
2043 let usage = GuardUsage::default();
2044 let (id2, _mon, _usable) = guardmgr2.select_guard(usage).unwrap();
2045 assert!(id2.same_relay_ids(&id));
2046 });
2047 }
2048
2049 #[test]
2050 fn simple_waiting() {
2051 // TODO(nickm): This test fails in rare cases; I suspect a
2052 // race condition somewhere.
2053 //
2054 // I've doubled up on the queue flushing in order to try to make the
2055 // race less likely, but we should investigate.
2056 test_with_all_runtimes!(|rt| async move {
2057 let (guardmgr, _statemgr, netdir) = init(rt);
2058 let u = GuardUsage::default();
2059 guardmgr.install_test_netdir(&netdir);
2060
2061 // We'll have the first two guard fail, which should make us
2062 // try a non-primary guard.
2063 let (id1, mon, _usable) = guardmgr.select_guard(u.clone()).unwrap();
2064 mon.failed();
2065 guardmgr.flush_msg_queue().await; // avoid race
2066 guardmgr.flush_msg_queue().await; // avoid race
2067 let (id2, mon, _usable) = guardmgr.select_guard(u.clone()).unwrap();
2068 mon.failed();
2069 guardmgr.flush_msg_queue().await; // avoid race
2070 guardmgr.flush_msg_queue().await; // avoid race
2071
2072 assert!(!id1.same_relay_ids(&id2));
2073
2074 // Now we should get two sampled guards. They should be different.
2075 let (id3, mon3, usable3) = guardmgr.select_guard(u.clone()).unwrap();
2076 let (id4, mon4, usable4) = guardmgr.select_guard(u.clone()).unwrap();
2077 assert!(!id3.same_relay_ids(&id4));
2078
2079 let (u3, u4) = futures::join!(
2080 async {
2081 mon3.failed();
2082 guardmgr.flush_msg_queue().await; // avoid race
2083 usable3.await.unwrap()
2084 },
2085 async {
2086 mon4.succeeded();
2087 usable4.await.unwrap()
2088 }
2089 );
2090
2091 assert_eq!((u3, u4), (false, true));
2092 });
2093 }
2094
2095 #[test]
2096 fn filtering_basics() {
2097 test_with_all_runtimes!(|rt| async move {
2098 let (guardmgr, _statemgr, netdir) = init(rt);
2099 let u = GuardUsage::default();
2100 let filter = {
2101 let mut f = GuardFilter::default();
2102 // All the addresses in the test network are {0,1,2,3,4}.0.0.3:9001.
2103 // Limit to only 2.0.0.0/8
2104 f.push_reachable_addresses(vec!["2.0.0.0/8:9001".parse().unwrap()]);
2105 f
2106 };
2107 guardmgr.set_filter(filter);
2108 guardmgr.install_test_netdir(&netdir);
2109 let (guard, _mon, _usable) = guardmgr.select_guard(u).unwrap();
2110 // Make sure that the filter worked.
2111 let addr = guard.addrs().next().unwrap();
2112 assert_eq!(addr, "2.0.0.3:9001".parse().unwrap());
2113 });
2114 }
2115
2116 #[test]
2117 fn external_status() {
2118 test_with_all_runtimes!(|rt| async move {
2119 let (guardmgr, _statemgr, netdir) = init(rt);
2120 let data_usage = GuardUsage::default();
2121 let dir_usage = GuardUsageBuilder::new()
2122 .kind(GuardUsageKind::OneHopDirectory)
2123 .build()
2124 .unwrap();
2125 guardmgr.install_test_netdir(&netdir);
2126 {
2127 // Override this parameter, so that we can get deterministic results below.
2128 let mut inner = guardmgr.inner.lock().unwrap();
2129 inner.params.dir_parallelism = 1;
2130 }
2131
2132 let (guard, mon, _usable) = guardmgr.select_guard(data_usage.clone()).unwrap();
2133 mon.succeeded();
2134
2135 // Record that this guard gave us a bad directory object.
2136 guardmgr.note_external_failure(&guard, ExternalActivity::DirCache);
2137
2138 // We ask for another guard, for data usage. We should get the same
2139 // one as last time, since the director failure doesn't mean this
2140 // guard is useless as a primary guard.
2141 let (g2, mon, _usable) = guardmgr.select_guard(data_usage).unwrap();
2142 assert_eq!(g2.ed_identity(), guard.ed_identity());
2143 mon.succeeded();
2144
2145 // But if we ask for a guard for directory usage, we should get a
2146 // different one, since the last guard we gave out failed.
2147 let (g3, mon, _usable) = guardmgr.select_guard(dir_usage.clone()).unwrap();
2148 assert_ne!(g3.ed_identity(), guard.ed_identity());
2149 mon.succeeded();
2150
2151 // Now record a success for for directory usage.
2152 guardmgr.note_external_success(&guard, ExternalActivity::DirCache);
2153
2154 // Now that the guard is working as a cache, asking for it should get us the same guard.
2155 let (g4, _mon, _usable) = guardmgr.select_guard(dir_usage).unwrap();
2156 assert_eq!(g4.ed_identity(), guard.ed_identity());
2157 });
2158 }
2159
2160 #[cfg(feature = "vanguards")]
2161 #[test]
2162 fn vanguard_mode_ord() {
2163 assert!(VanguardMode::Disabled < VanguardMode::Lite);
2164 assert!(VanguardMode::Disabled < VanguardMode::Full);
2165 assert!(VanguardMode::Lite < VanguardMode::Full);
2166 }
2167}