Module pipeline 

Packet pipeline for the HOPR protocol. HOPR packet processing pipeline.

Re-exports

pub use builder::PacketPipelineBuilder;

pub use builder::Unset;

pub use config::AcknowledgementPipelineConfig;

pub use config::PacketPipelineConfig;

pub use config::PoolArbitrationConfig;

Modules

builder 🔒

Builder for constructing the HOPR packet pipeline.

config 🔒

Configuration structures for the HOPR packet processing pipeline.

Enums

NodeType

Node type for which the packet processing pipeline is being constructed.

PacketPipelineProcesses

Constants

DEFAULT_ACK_INPUT_CONCURRENCY 🔒

Default concurrency for the incoming acknowledgement processing pipeline when not overridden via AcknowledgementPipelineConfig::ack_input_concurrency.

DEFAULT_ACK_OUTPUT_CONCURRENCY 🔒

Default concurrency for the outgoing acknowledgement processing pipeline when not overridden via AcknowledgementPipelineConfig::ack_output_concurrency.

PACKET_DECODING_TIMEOUT 🔒

PACKET_ENCODING_TIMEOUT 🔒

PIPELINE_CONCURRENCY_PER_CPU 🔒

Multiplier applied to the CPU count to size each pipeline stage’s ready-queue depth.

QUEUE_SEND_TIMEOUT 🔒

Functions

default_pipeline_concurrency 🔒

Default per-stage pipeline concurrency (the ready-queue depth feeding the shared Rayon pool) used when a PacketPipelineConfig concurrency field is unset or zero.

run_packet_pipeline_inner 🔒

Shared implementation of the packet pipeline used by PacketPipelineBuilder’s terminal build_for_* methods.

start_drain_incoming_ack_pipeline 🔒

Drains incoming acknowledgements without forwarding them to an UnacknowledgedTicketProcessor.

start_incoming_packet_pipeline 🔒

Performs HOPR protocol decoding of incoming packets into Application protocol packets.

start_outgoing_ack_pipeline 🔒

start_outgoing_packet_pipeline 🔒

Performs encoding of outgoing Application protocol packets into HOPR protocol outgoing packets.

start_relay_incoming_ack_pipeline 🔒