Struct CreateRequestHandler 

pub struct CreateRequestHandler {
    chan_provider: Weak<dyn ChannelProvider<BuildSpec = OwnedChanTarget> + Send + Sync>,
    circ_net_params: RwLock<CircNetParameters>,
    ntor_keys: RwLock<RelayNtorKeys>,
}

Everything needed to handle CREATE* messages on channels.

Fields

chan_provider: Weak<dyn ChannelProvider<BuildSpec = OwnedChanTarget> + Send + Sync>

Something that can launch channels. Typically the ChanMgr.

circ_net_params: RwLock<CircNetParameters>

Circuit-related network parameters.

ntor_keys: RwLock<RelayNtorKeys>

The circuit extension keys.

Implementations

impl CreateRequestHandler

pub fn new( chan_provider: Weak<dyn ChannelProvider<BuildSpec = OwnedChanTarget> + Send + Sync>, circ_net_params: CircNetParameters, ntor_keys: RelayNtorKeys, ) -> Self

Build a new CreateRequestHandler.

pub fn update_params(&self, circ_net_params: CircNetParameters)

Update the circuit parameters from a network consensus.

pub fn update_ntor_keys(&self, ntor_keys: RelayNtorKeys)

Update the handler with a new set of circuit extension keys.

This is called periodically by the relay key rotation task.

pub(crate) fn handle_create<R: Runtime>( &self, runtime: &R, channel: &Arc<Channel>, our_ed25519_id: &Ed25519Identity, our_rsa_id: &RsaIdentity, circ_id: CircId, msg: &CreateRequest, memquota: &ChannelAccount, circ_unique_id: UniqId, ) -> Result<(CreateResponse, RelayCircComponents), Destroy>

Handle a CREATE* cell.

This intentionally does not return a crate::Error so that we don’t accidentally shut down the channel reactor when we really should be returning a DESTROY. Shutting down a channel may cause us to leak information about paths of circuits travelling through this relay. This is especially important here since we’re handling data that is controllable from the other end of the circuit.

fn handle_create_inner<R: Runtime>( &self, runtime: &R, channel: &Arc<Channel>, _our_ed25519_id: &Ed25519Identity, _our_rsa_id: &RsaIdentity, circ_id: CircId, msg: &CreateRequest, memquota: &ChannelAccount, circ_unique_id: UniqId, ) -> Result<(CreateResponse, RelayCircComponents), HandleCreateError>

See Self::handle_create.

fn handle_create_fast( &self, msg: &CreateFast, ) -> Result<CompletedHandshakeComponents, HandleCreateError>

The handshake code for a CREATE_FAST request.

Trait Implementations

impl Debug for CreateRequestHandler

fn fmt(&self, __derive_more_f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.