Struct Inner

struct Inner {
    config: Arc<OnionServiceConfigPublisherView>,
    file_watcher: Option<FileWatcher>,
    time_periods: Vec<TimePeriodContext>,
    netdir: Option<Arc<NetDir>>,
    last_uploaded: Option<Instant>,
    reupload_timers: BinaryHeap<ReuploadTimer>,
    authorized_clients: Option<Arc<BTreeMap<HsClientNickname, HsClientDescEncKey>>>,
}

The mutable state of a Reactor.

Fields

config: Arc<OnionServiceConfigPublisherView>

The onion service config.

file_watcher: Option<FileWatcher>

Watcher for key_dirs.

Set to None if the reactor is not running, or if watch_configuration is false.

The watcher is recreated whenever the restricted_discovery.key_dirs change.

time_periods: Vec<TimePeriodContext>

The relevant time periods.

This includes the current time period, as well as any other time periods we need to be publishing descriptors for.

This is empty until we fetch our first netdir in Reactor::run.

netdir: Option<Arc<NetDir>>

Our most up to date netdir.

This is initialized in Reactor::run.

last_uploaded: Option<Instant>

The timestamp of our last upload.

This is the time when the last update was initiated (rather than completed), to prevent the publisher from spawning multiple upload tasks at once in response to multiple external events happening in quick succession, such as the IPT manager sending multiple IPT change notifications in a short time frame (#1142), or an IPT change notification that’s immediately followed by a consensus change. Starting two upload tasks at once is not only inefficient, but it also causes the publisher to generate two different descriptors with the same revision counter (the revision counter is derived from the current timestamp), which ultimately causes the slower upload task to fail (see #1142).

Note: This is only used for deciding when to reschedule a rate-limited upload. It is not used for retrying failed uploads (these are handled internally by Reactor::upload_descriptor_with_retries).

reupload_timers: BinaryHeap<ReuploadTimer>

A max-heap containing the time periods for which we need to reupload the descriptor.

authorized_clients: Option<Arc<BTreeMap<HsClientNickname, HsClientDescEncKey>>>

The restricted discovery authorized clients.

None, unless the service is running in restricted discovery mode.