Module reactor 

Code to handle incoming cells on a circuit.

On message validation

There are three steps for validating an incoming message on a stream:

1. Is the message contextually appropriate? (e.g., no more than one CONNECTED message per stream.) This is handled by calling CmdChecker::check_msg.
2. Does the message comply with flow-control rules? (e.g., no more SENDMEs than we’ve sent data for.) This is handled within the reactor by the StreamFlowCtrl. For half-closed streams which don’t send stream SENDMEs, an additional receive-window check is performed in the halfstream module.
3. Does the message have an acceptable command type, and is the message well-formed? For open streams, the streams themselves handle this check. For half-closed streams, the reactor handles it by calling consume_checked_msg().

Modules

circuit 🔒

Module exposing types for representing circuits in the tunnel reactor.

conflux 🔒

Conflux-related functionality

control 🔒

Module providing CtrlMsg.

syncview 🔒

Implement synchronous views of circuit internals.

Macros

unwrap_or_shutdown 🔒

Unwrap the specified Option, returning a ReactorError::Shutdown if it is None.

Structs

CellHandlers 🔒

Cell handlers, shared between the Reactor and its underlying Circuits.

ConfluxHandshakeCtx 🔒 conflux

The context for an on-going conflux handshake.

ConfluxHeapEntry 🔒 conflux

An out-of-order message buffered in Reactor::ooo_msgs.

NoHopsBuiltError 🔒

The tunnel does not have any hops.

NoJoinPointError 🔒

The tunnel does not have a join point.

Reactor

Object to handle incoming cells and background tasks on a circuit

Enums

CircuitEvent 🔒

A command to execute at the end of Reactor::run_once.

CircuitHandshake 🔒

A handshake type, to be used when creating circuit hops.

MetaCellDisposition

A possible successful outcome of giving a message to a MsgHandler.

RunOnceCmd 🔒

One or more RunOnceCmdInner to run inside Reactor::run_once.

RunOnceCmdInner 🔒

Instructions for running something in the reactor loop.

Traits

MetaCellHandler 🔒

An object that’s waiting for a meta cell (one not associated with a stream) in order to make progress.

Functions

send_conflux_outcome 🔒 conflux

Notify the conflux handshake initiator of the handshake outcome.

Type Aliases

ConfluxHandshakeResult 🔒 conflux

Contains a list of conflux handshake results.

ConfluxLinkResultChannel 🔒 conflux

The type of oneshot channel used to inform reactor users of the outcome of a client-side conflux handshake.

ReactorResultChannel 🔒

The type of a oneshot channel used to inform reactor of the result of an operation.