Struct Reactor

struct Reactor<R: Runtime> {
    runtime: R,
    nickname: HsNickname,
    pool: Arc<HsCircPool<R>>,
    netdir_provider: Arc<dyn NetDirProvider>,
    lid: IptLocalId,
    target: RelayIds,
    k_sid: Arc<HsIntroPtSessionIdKeypair>,
    extensions: EstIntroExtensionSet,
    introduce_tx: Sender<RendRequest>,
    state: Arc<Mutex<EstablisherState>>,
    request_context: Arc<RendRequestContext>,
    replay_log: Arc<Mutex<ReplayLog<IptReplayLogType>>>,
}

Implementation structure for the task that implements an IptEstablisher.

Fields

runtime: R

A copy of our runtime, used for timeouts and sleeping.

nickname: HsNickname

The nickname of the onion service we’re running. Used when logging.

pool: Arc<HsCircPool<R>>

A pool used to create circuits to the introduction point.

netdir_provider: Arc<dyn NetDirProvider>

A provider used to select the other relays in the circuit.

lid: IptLocalId

Identifier for the intro point.

target: RelayIds

The target introduction point.

k_sid: Arc<HsIntroPtSessionIdKeypair>

The keypair to use when establishing the introduction point.

Knowledge of this private key prevents anybody else from impersonating us to the introduction point.

extensions: EstIntroExtensionSet

The extensions to use when establishing the introduction point.

TODO (#1209): This should be able to change over time as we re-establish the intro point.

introduce_tx: Sender<RendRequest>

The stream that will receive INTRODUCE2 messages.

state: Arc<Mutex<EstablisherState>>

Mutable state shared with the Establisher, Reactor, and MsgHandler.

request_context: Arc<RendRequestContext>

Context information that we’ll need to answer rendezvous requests.

replay_log: Arc<Mutex<ReplayLog<IptReplayLogType>>>

Introduction request replay log

Shared between multiple IPT circuit control message handlers - IptMsgHandler contains the lock guard.

Has to be an async mutex since it’s locked for a long time, so we mustn’t block the async executor thread on it.

Implementations

impl<R: Runtime> Reactor<R>

async fn keep_intro_established( &self, status_tx: DropNotifyWatchSender<IptStatus>, ) -> Result<Void, IptEstablisherError>

Run forever, keeping an introduction point established.

async fn establish_intro_once( &self, ) -> Result<(IntroPtSession, GoodIptDetails), IptEstablisherError>

Try, once, to make a circuit to a single relay and establish an introduction point there.

Does not retry. Does not time out except via HsCircPool.